X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=tests%2Flib%2Ftest_graph_topo.c;h=d6c4c07411c2f439572cea0319fc56ac0b13a6fa;hb=72c6811a481b55f9a5541938b0b93c402467f32a;hp=3689a75baf45ba5872e5ecc89fc12c8c1322f13f;hpb=59225a3e0e13a9c674234755e55055d9ff68d635;p=babeltrace.git

diff --git a/tests/lib/test_graph_topo.c b/tests/lib/test_graph_topo.c
index 3689a75b..d6c4c074 100644
--- a/tests/lib/test_graph_topo.c
+++ b/tests/lib/test_graph_topo.c
@@ -26,14 +26,13 @@
 
 #include "tap/tap.h"
 
-#define NR_TESTS	33
+#define NR_TESTS	26
 
 enum event_type {
 	SRC_COMP_OUTPUT_PORT_CONNECTED,
 	SINK_COMP_INPUT_PORT_CONNECTED,
 	GRAPH_SRC_OUTPUT_PORT_ADDED,
 	GRAPH_SINK_INPUT_PORT_ADDED,
-	GRAPH_SRC_SINK_PORTS_CONNECTED,
 };
 
 enum test {
@@ -69,17 +68,11 @@ struct event {
 			const bt_component *comp;
 			const bt_port *port;
 		} graph_sink_input_port_added;
-
-		struct {
-			const bt_component *upstream_comp;
-			const bt_component *downstream_comp;
-			const bt_port *upstream_port;
-			const bt_port *downstream_port;
-		} graph_src_sink_ports_connected;
 	} data;
 };
 
 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;
@@ -158,27 +151,6 @@ bool compare_events(struct event *ev_a, struct event *ev_b)
 				return false;
 			}
 			break;
-		case GRAPH_SRC_SINK_PORTS_CONNECTED:
-			if (ev_a->data.graph_src_sink_ports_connected.upstream_comp !=
-					ev_b->data.graph_src_sink_ports_connected.upstream_comp) {
-				return false;
-			}
-
-			if (ev_a->data.graph_src_sink_ports_connected.downstream_comp !=
-					ev_b->data.graph_src_sink_ports_connected.downstream_comp) {
-				return false;
-			}
-
-			if (ev_a->data.graph_src_sink_ports_connected.upstream_port !=
-					ev_b->data.graph_src_sink_ports_connected.upstream_port) {
-				return false;
-			}
-
-			if (ev_a->data.graph_src_sink_ports_connected.downstream_port !=
-					ev_b->data.graph_src_sink_ports_connected.downstream_port) {
-				return false;
-			}
-			break;
 		default:
 			abort();
 	}
@@ -219,12 +191,12 @@ size_t event_pos(struct event *event)
 }
 
 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
@@ -293,7 +265,7 @@ bt_component_class_port_connected_method_status sink_input_port_connected(
 }
 
 static
-bt_component_class_init_method_status src_init(
+bt_component_class_initialize_method_status src_init(
 	bt_self_component_source *self_comp,
 	bt_self_component_source_configuration *config,
 	const bt_value *params, void *init_method_data)
@@ -303,11 +275,11 @@ bt_component_class_init_method_status src_init(
 	ret = bt_self_component_source_add_output_port(
 		self_comp, "out", NULL, NULL);
 	BT_ASSERT(ret == 0);
-	return BT_COMPONENT_CLASS_INIT_METHOD_STATUS_OK;
+	return BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_OK;
 }
 
 static
-bt_component_class_init_method_status sink_init(
+bt_component_class_initialize_method_status sink_init(
 	bt_self_component_sink *self_comp,
 	bt_self_component_sink_configuration *config,
 	const bt_value *params, void *init_method_data)
@@ -317,7 +289,7 @@ bt_component_class_init_method_status sink_init(
 	ret = bt_self_component_sink_add_input_port(self_comp,
 		"in", NULL, NULL);
 	BT_ASSERT(ret == 0);
-	return BT_COMPONENT_CLASS_INIT_METHOD_STATUS_OK;
+	return BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_OK;
 }
 
 static
@@ -363,41 +335,18 @@ bt_graph_listener_func_status graph_sink_input_port_added(
 	return BT_GRAPH_LISTENER_FUNC_STATUS_OK;
 }
 
-static
-bt_graph_listener_func_status graph_src_sink_ports_connected(
-		const bt_component_source *upstream_comp,
-		const bt_component_sink *downstream_comp,
-		const bt_port_output *upstream_port,
-		const bt_port_input *downstream_port, void *data)
-{
-	struct event event = {
-		.type = GRAPH_SRC_SINK_PORTS_CONNECTED,
-		.data.graph_src_sink_ports_connected = {
-			.upstream_comp =
-				bt_component_source_as_component_const(upstream_comp),
-				.downstream_comp =
-				bt_component_sink_as_component_const(downstream_comp),
-				.upstream_port =
-				bt_port_output_as_port_const(upstream_port),
-				.downstream_port =
-				bt_port_input_as_port_const(downstream_port),
-		},
-	};
-
-	append_event(&event);
-
-	return BT_GRAPH_LISTENER_FUNC_STATUS_OK;
-}
-
 static
 void init_test(void)
 {
 	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_init_method(
+	ret = bt_component_class_source_set_initialize_method(
 		src_comp_class, src_init);
 	BT_ASSERT(ret == 0);
 	ret = bt_component_class_source_set_output_port_connected_method(
@@ -406,7 +355,7 @@ void init_test(void)
 	sink_comp_class = bt_component_class_sink_create("sink",
 		sink_consume);
 	BT_ASSERT(sink_comp_class);
-	ret = bt_component_class_sink_set_init_method(sink_comp_class,
+	ret = bt_component_class_sink_set_initialize_method(sink_comp_class,
 		sink_init);
 	BT_ASSERT(ret == 0);
 	ret = bt_component_class_sink_set_input_port_connected_method(
@@ -456,13 +405,10 @@ bt_graph *create_graph(void)
 
 	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(
-		graph, graph_sink_input_port_added, NULL, NULL, NULL);
-	BT_ASSERT(ret >= 0);
-	ret = bt_graph_add_source_sink_component_ports_connected_listener(
-		graph, graph_src_sink_ports_connected, NULL, NULL, NULL);
+		graph, graph_sink_input_port_added, NULL, NULL);
 	BT_ASSERT(ret >= 0);
 	return graph;
 }
@@ -492,8 +438,6 @@ void test_src_adds_port_in_port_connected(void)
 	struct event event;
 	bt_graph_connect_ports_status status;
 	size_t src_port_connected_pos;
-	size_t sink_port_connected_pos;
-	size_t graph_ports_connected_pos;
 	size_t graph_port_added_src_pos;
 
 	prepare_test(TEST_SRC_ADDS_PORT_IN_PORT_CONNECTED,
@@ -520,8 +464,8 @@ void test_src_adds_port_in_port_connected(void)
 	gsrc_hello_port = bt_port_output_as_port_const(src_hello_port);
 	gsink_def_port = bt_port_input_as_port_const(sink_def_port);
 
-	/* We're supposed to have 6 events */
-	ok(events->len == 6, "we have the expected number of events");
+	/* We're supposed to have 5 events */
+	ok(events->len == 5, "we have the expected number of events");
 
 	/* Source's port added */
 	event.type = GRAPH_SRC_OUTPUT_PORT_ADDED;
@@ -556,29 +500,11 @@ void test_src_adds_port_in_port_connected(void)
 	event.data.sink_comp_input_port_connected.self_port = gsink_def_port;
 	event.data.sink_comp_input_port_connected.other_port = gsrc_def_port;
 	ok(has_event(&event), "got the expected sink's port connected event");
-	sink_port_connected_pos = event_pos(&event);
-
-	/* Graph's ports connected */
-	event.type = GRAPH_SRC_SINK_PORTS_CONNECTED;
-	event.data.graph_src_sink_ports_connected.upstream_comp = gsrc;
-	event.data.graph_src_sink_ports_connected.downstream_comp = gsink;
-	event.data.graph_src_sink_ports_connected.upstream_port = gsrc_def_port;
-	event.data.graph_src_sink_ports_connected.downstream_port = gsink_def_port;
-	ok(has_event(&event), "got the expected graph's ports connected event");
-	graph_ports_connected_pos = event_pos(&event);
 
 	/* Order of events */
-	ok(src_port_connected_pos < graph_ports_connected_pos,
-		"event order is good (1)");
-	ok(sink_port_connected_pos < graph_ports_connected_pos,
-		"event order is good (2)");
 	ok(src_port_connected_pos < graph_port_added_src_pos,
-		"event order is good (3)");
-	ok(graph_port_added_src_pos < graph_ports_connected_pos,
-		"event order is good (4)");
+		"event order is good");
 
-	bt_component_source_put_ref(src);
-	bt_component_sink_put_ref(sink);
 	bt_graph_put_ref(graph);
 }
 
@@ -596,9 +522,6 @@ void test_simple(void)
 	const bt_port *gsink_def_port;
 	struct event event;
 	bt_graph_connect_ports_status status;
-	size_t src_port_connected_pos;
-	size_t sink_port_connected_pos;
-	size_t graph_ports_connected_pos;
 
 	prepare_test(TEST_SIMPLE, "simple");
 	graph = create_graph();
@@ -619,8 +542,8 @@ void test_simple(void)
 	gsrc_def_port = bt_port_output_as_port_const(src_def_port);
 	gsink_def_port = bt_port_input_as_port_const(sink_def_port);
 
-	/* We're supposed to have 5 events */
-	ok(events->len == 5, "we have the expected number of events");
+	/* We're supposed to have 4 events */
+	ok(events->len == 4, "we have the expected number of events");
 
 	/* Source's port added */
 	event.type = GRAPH_SRC_OUTPUT_PORT_ADDED;
@@ -640,7 +563,6 @@ void test_simple(void)
 	event.data.src_comp_output_port_connected.self_port = gsrc_def_port;
 	event.data.src_comp_output_port_connected.other_port = gsink_def_port;
 	ok(has_event(&event), "got the expected source's port connected event");
-	src_port_connected_pos = event_pos(&event);
 
 	/* Sink's port connected */
 	event.type = SINK_COMP_INPUT_PORT_CONNECTED;
@@ -648,26 +570,8 @@ void test_simple(void)
 	event.data.sink_comp_input_port_connected.self_port = gsink_def_port;
 	event.data.sink_comp_input_port_connected.other_port = gsrc_def_port;
 	ok(has_event(&event), "got the expected sink's port connected event");
-	sink_port_connected_pos = event_pos(&event);
-
-	/* Graph's ports connected */
-	event.type = GRAPH_SRC_SINK_PORTS_CONNECTED;
-	event.data.graph_src_sink_ports_connected.upstream_comp = gsrc;
-	event.data.graph_src_sink_ports_connected.downstream_comp = gsink;
-	event.data.graph_src_sink_ports_connected.upstream_port = gsrc_def_port;
-	event.data.graph_src_sink_ports_connected.downstream_port = gsink_def_port;
-	ok(has_event(&event), "got the expected graph's ports connected event");
-	graph_ports_connected_pos = event_pos(&event);
-
-	/* Order of events */
-	ok(src_port_connected_pos < graph_ports_connected_pos,
-		"event order is good (1)");
-	ok(sink_port_connected_pos < graph_ports_connected_pos,
-		"event order is good (2)");
 
-	bt_component_sink_put_ref(sink);
 	bt_graph_put_ref(graph);
-	bt_component_source_put_ref(src);
 }
 
 static
@@ -731,9 +635,6 @@ void test_src_port_connected_error(void)
 	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
@@ -803,10 +704,7 @@ void test_sink_port_connected_error(void)
 	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