aboutsummaryrefslogtreecommitdiff
path: root/src/transport/test_transport_plugin_cmd_simple_send_v2.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/test_transport_plugin_cmd_simple_send_v2.c')
-rw-r--r--src/transport/test_transport_plugin_cmd_simple_send_v2.c44
1 files changed, 8 insertions, 36 deletions
diff --git a/src/transport/test_transport_plugin_cmd_simple_send_v2.c b/src/transport/test_transport_plugin_cmd_simple_send_v2.c
index ce1245296..c79b5c7e2 100644
--- a/src/transport/test_transport_plugin_cmd_simple_send_v2.c
+++ b/src/transport/test_transport_plugin_cmd_simple_send_v2.c
@@ -57,6 +57,11 @@ char *cfgname;
57 */ 57 */
58unsigned int are_all_peers_started; 58unsigned int are_all_peers_started;
59 59
60/**
61 * Flag indicating a received message.
62 */
63unsigned int message_received;
64
60 65
61/** 66/**
62 * Function called to check a message of type GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE being 67 * Function called to check a message of type GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE being
@@ -80,35 +85,7 @@ static void
80handle_test (void *cls, 85handle_test (void *cls,
81 const struct GNUNET_TRANSPORT_TESTING_TestMessage *message) 86 const struct GNUNET_TRANSPORT_TESTING_TestMessage *message)
82{ 87{
83 LOG (GNUNET_ERROR_TYPE_ERROR, 88 message_received = GNUNET_YES;
84 "message received\n");
85}
86
87
88/**
89 * Function called to check a message of type GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE2
90 * being received.
91 *
92 */
93static int
94check_test2 (void *cls,
95 const struct GNUNET_TRANSPORT_TESTING_TestMessage *message)
96{
97 return GNUNET_OK;
98}
99
100
101/**
102 * Function called to handle a message of type GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE2
103 * being received.
104 *
105 */
106static void
107handle_test2 (void *cls,
108 const struct GNUNET_TRANSPORT_TESTING_TestMessage *message)
109{
110 LOG (GNUNET_ERROR_TYPE_ERROR,
111 "message received\n");
112} 89}
113 90
114 91
@@ -120,9 +97,6 @@ static void
120all_peers_started () 97all_peers_started ()
121{ 98{
122 are_all_peers_started = GNUNET_YES; 99 are_all_peers_started = GNUNET_YES;
123 LOG (GNUNET_ERROR_TYPE_ERROR,
124 "setting are_all_peers_started: %d\n",
125 are_all_peers_started);
126} 100}
127 101
128 102
@@ -181,10 +155,6 @@ start_testcase (TESTING_CMD_HELPER_write_cb write_message, char *router_ip,
181 GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE, 155 GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE,
182 struct GNUNET_TRANSPORT_TESTING_TestMessage, 156 struct GNUNET_TRANSPORT_TESTING_TestMessage,
183 NULL), 157 NULL),
184 GNUNET_MQ_hd_var_size (test2,
185 GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE2,
186 struct GNUNET_TRANSPORT_TESTING_TestMessage,
187 NULL),
188 GNUNET_MQ_handler_end () 158 GNUNET_MQ_handler_end ()
189 }; 159 };
190 160
@@ -208,6 +178,8 @@ start_testcase (TESTING_CMD_HELPER_write_cb write_message, char *router_ip,
208 GNUNET_TRANSPORT_cmd_send_simple_v2 ("send-simple", 178 GNUNET_TRANSPORT_cmd_send_simple_v2 ("send-simple",
209 "start-peer", 179 "start-peer",
210 num), 180 num),
181 GNUNET_TESTING_cmd_block_until_external_trigger ("block-receive",
182 &message_received),
211 GNUNET_TRANSPORT_cmd_stop_peer ("stop-peer", 183 GNUNET_TRANSPORT_cmd_stop_peer ("stop-peer",
212 "start-peer"), 184 "start-peer"),
213 GNUNET_TESTING_cmd_system_destroy ("system-destroy", 185 GNUNET_TESTING_cmd_system_destroy ("system-destroy",