};
static GArray *events;
+static bt_message_iterator_class *msg_iter_class;
static bt_component_class_source *src_comp_class;
static bt_component_class_sink *sink_comp_class;
static enum test current_test;
}
static
-bt_component_class_message_iterator_next_method_status src_iter_next(
+bt_message_iterator_class_next_method_status src_iter_next(
bt_self_message_iterator *self_iterator,
bt_message_array_const msgs, uint64_t capacity,
uint64_t *count)
{
- return BT_COMPONENT_CLASS_MESSAGE_ITERATOR_NEXT_METHOD_STATUS_ERROR;
+ return BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_ERROR;
}
static
{
int ret;
+ msg_iter_class = bt_message_iterator_class_create(src_iter_next);
+ BT_ASSERT(msg_iter_class);
+
src_comp_class = bt_component_class_source_create(
- "src", src_iter_next);
+ "src", msg_iter_class);
BT_ASSERT(src_comp_class);
ret = bt_component_class_source_set_initialize_method(
src_comp_class, src_init);
ok(src_port_connected_pos < graph_port_added_src_pos,
"event order is good");
- bt_component_source_put_ref(src);
- bt_component_sink_put_ref(sink);
bt_graph_put_ref(graph);
}
event.data.sink_comp_input_port_connected.other_port = gsrc_def_port;
ok(has_event(&event), "got the expected sink's port connected event");
- bt_component_sink_put_ref(sink);
bt_graph_put_ref(graph);
- bt_component_source_put_ref(src);
}
static
ok(has_event(&event), "got the expected source's port connected event");
bt_graph_put_ref(graph);
- bt_component_sink_put_ref(sink);
- bt_component_source_put_ref(src);
- bt_connection_put_ref(conn);
}
static
event.data.sink_comp_input_port_connected.other_port = gsrc_def_port;
ok(has_event(&event), "got the expected sink's port connected event");
- bt_connection_put_ref(conn);
bt_graph_put_ref(graph);
- bt_component_sink_put_ref(sink);
- bt_component_source_put_ref(src);
}
static