X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=lib%2Fgraph%2Fcomponent-class-sink-colander.c;fp=lib%2Fgraph%2Fcomponent-class-sink-colander.c;h=7f3cfeca6329f94604cc4f9127d4bd6f782c7fe6;hp=9a70f105218172060aa6f39d2ae3ce149abb53bb;hb=36d1acad60fd6c9cfb933f3f2fbc039443d47115;hpb=65531d5502d759226b18a2974dd77c78d58ab4dc diff --git a/lib/graph/component-class-sink-colander.c b/lib/graph/component-class-sink-colander.c index 9a70f105..7f3cfeca 100644 --- a/lib/graph/component-class-sink-colander.c +++ b/lib/graph/component-class-sink-colander.c @@ -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);