projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
lib: introduce bt_message_iterator_class
[babeltrace.git]
/
tests
/
lib
/
test_graph_topo.c
diff --git
a/tests/lib/test_graph_topo.c
b/tests/lib/test_graph_topo.c
index 184528d1a1a7b6b8fa09a7ead957e1258ebf6069..d3d45818d224531517935b4318aa328549c6e9da 100644
(file)
--- a/
tests/lib/test_graph_topo.c
+++ b/
tests/lib/test_graph_topo.c
@@
-72,6
+72,7
@@
struct event {
};
static GArray *events;
};
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_source *src_comp_class;
static bt_component_class_sink *sink_comp_class;
static enum test current_test;
@@
-190,12
+191,12
@@
size_t event_pos(struct event *event)
}
static
}
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)
{
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
}
static
@@
-339,8
+340,11
@@
void init_test(void)
{
int ret;
{
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_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);
BT_ASSERT(src_comp_class);
ret = bt_component_class_source_set_initialize_method(
src_comp_class, src_init);
@@
-401,10
+405,10
@@
bt_graph *create_graph(void)
BT_ASSERT(graph);
ret = bt_graph_add_source_component_output_port_added_listener(
BT_ASSERT(graph);
ret = bt_graph_add_source_component_output_port_added_listener(
- graph, graph_src_output_port_added, NULL, NULL
, NULL
);
+ graph, graph_src_output_port_added, NULL, NULL);
BT_ASSERT(ret >= 0);
ret = bt_graph_add_sink_component_input_port_added_listener(
BT_ASSERT(ret >= 0);
ret = bt_graph_add_sink_component_input_port_added_listener(
- graph, graph_sink_input_port_added, NULL, NULL
, NULL
);
+ graph, graph_sink_input_port_added, NULL, NULL);
BT_ASSERT(ret >= 0);
return graph;
}
BT_ASSERT(ret >= 0);
return graph;
}
This page took
0.026185 seconds
and
4
git commands to generate.