X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=lib%2Fgraph%2Fcomponent-class-sink-colander.c;h=6a9d287e2a9983dac998dbfebe92a320e4d9e2a0;hb=3fadfbc0c91f82c46bd36e6e0657ea93570c9db1;hp=9a70f105218172060aa6f39d2ae3ce149abb53bb;hpb=7474e7d3f0d005280c6614be5c818735e65d8b3b;p=babeltrace.git

diff --git a/lib/graph/component-class-sink-colander.c b/lib/graph/component-class-sink-colander.c
index 9a70f105..6a9d287e 100644
--- a/lib/graph/component-class-sink-colander.c
+++ b/lib/graph/component-class-sink-colander.c
@@ -21,17 +21,17 @@
  */
 
 #define BT_LOG_TAG "COLANDER"
-#include <babeltrace/lib-logging-internal.h>
-
-#include <babeltrace/assert-internal.h>
-#include <babeltrace/assert-pre-internal.h>
-#include <babeltrace/object-internal.h>
-#include <babeltrace/graph/component-class-sink.h>
-#include <babeltrace/graph/self-component-sink.h>
-#include <babeltrace/graph/self-component-port.h>
-#include <babeltrace/graph/self-component-port-input-message-iterator.h>
-#include <babeltrace/graph/self-component.h>
-#include <babeltrace/graph/component-class-sink-colander-internal.h>
+#include <babeltrace2/lib-logging-internal.h>
+
+#include <babeltrace2/assert-internal.h>
+#include <babeltrace2/assert-pre-internal.h>
+#include <babeltrace2/object-internal.h>
+#include <babeltrace2/graph/component-class-sink.h>
+#include <babeltrace2/graph/self-component-sink.h>
+#include <babeltrace2/graph/self-component-port.h>
+#include <babeltrace2/graph/self-component-port-input-message-iterator.h>
+#include <babeltrace2/graph/self-component.h>
+#include <babeltrace2/graph/component-class-sink-colander-internal.h>
 #include <glib.h>
 
 static
@@ -94,16 +94,18 @@ void colander_finalize(struct bt_self_component_sink *self_comp)
 }
 
 static
-enum bt_self_component_status colander_input_port_connected(
-		struct bt_self_component_sink *self_comp,
-		struct bt_self_component_port_input *self_port,
-		const struct bt_port_output *other_port)
+enum bt_self_component_status colander_graph_is_configured(
+	bt_self_component_sink *self_comp)
 {
 	enum bt_self_component_status status = BT_SELF_COMPONENT_STATUS_OK;
 	struct bt_component_class_sink_colander_priv_data *colander_data =
 		bt_self_component_get_data(
 			bt_self_component_sink_as_self_component(self_comp));
 
+	struct bt_self_component_port_input *self_port =
+		bt_self_component_sink_borrow_input_port_by_name(self_comp, "in");
+	BT_ASSERT(self_port);
+
 	BT_ASSERT(colander_data);
 	BT_OBJECT_PUT_REF_AND_RESET(colander_data->msg_iter);
 	colander_data->msg_iter =
@@ -183,8 +185,8 @@ struct bt_component_class_sink *bt_component_class_sink_colander_get(void)
 		colander_comp_cls, colander_init);
 	(void) bt_component_class_sink_set_finalize_method(
 		colander_comp_cls, colander_finalize);
-	(void) bt_component_class_sink_set_input_port_connected_method(
-		colander_comp_cls, colander_input_port_connected);
+	(void) bt_component_class_sink_set_graph_is_configured_method(
+		colander_comp_cls, colander_graph_is_configured);
 
 end:
 	bt_object_get_ref(colander_comp_cls);