X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=plugins%2Futils%2Fmuxer%2Fmuxer.c;h=032fef41be05dac7bbe47874a839007fc28894e4;hb=4725a2013cb518374822ccb490610b45f74dbdbf;hp=19c6b768f6d7079a21c6c0399e76d9e39787b56f;hpb=13d428598c645803f8745b6db2c6dc2cde5e33c4;p=babeltrace.git

diff --git a/plugins/utils/muxer/muxer.c b/plugins/utils/muxer/muxer.c
index 19c6b768..032fef41 100644
--- a/plugins/utils/muxer/muxer.c
+++ b/plugins/utils/muxer/muxer.c
@@ -1117,10 +1117,10 @@ bt_self_message_iterator_status muxer_msg_iter_do_next(
 		BT_SELF_MESSAGE_ITERATOR_STATUS_OK;
 	uint64_t i = 0;
 
-	while (i < capacity && status == BT_MESSAGE_ITERATOR_STATUS_OK) {
+	while (i < capacity && status == BT_SELF_MESSAGE_ITERATOR_STATUS_OK) {
 		status = muxer_msg_iter_do_next_one(muxer_comp,
 			muxer_msg_iter, &msgs[i]);
-		if (status == BT_MESSAGE_ITERATOR_STATUS_OK) {
+		if (status == BT_SELF_MESSAGE_ITERATOR_STATUS_OK) {
 			i++;
 		}
 	}
@@ -1462,29 +1462,3 @@ bt_self_component_status muxer_input_port_connected(
 end:
 	return status;
 }
-
-BT_HIDDEN
-void muxer_input_port_disconnected(
-		bt_self_component_filter *self_component,
-		bt_self_component_port_input *self_port)
-{
-	struct muxer_comp *muxer_comp =
-		bt_self_component_get_data(
-			bt_self_component_filter_as_self_component(
-				self_component));
-	const bt_port *port =
-		bt_self_component_port_as_port(
-			bt_self_component_port_input_as_self_component_port(
-				self_port));
-
-	BT_ASSERT(port);
-	BT_ASSERT(muxer_comp);
-
-	/* One more available input port */
-	muxer_comp->available_input_ports++;
-	BT_LOGD("Leaving disconnected input port available for future connections: "
-		"comp-addr=%p, muxer-comp-addr=%p, port-addr=%p, "
-		"port-name=\"%s\", avail-input-port-count=%zu",
-		self_component, muxer_comp, port, bt_port_get_name(port),
-		muxer_comp->available_input_ports);
-}