diff options
Diffstat (limited to 'src/transport/test_transport_plugin_cmd_simple_send.c')
-rw-r--r-- | src/transport/test_transport_plugin_cmd_simple_send.c | 21 |
1 files changed, 19 insertions, 2 deletions
diff --git a/src/transport/test_transport_plugin_cmd_simple_send.c b/src/transport/test_transport_plugin_cmd_simple_send.c index 4b5018b60..35aa07ecd 100644 --- a/src/transport/test_transport_plugin_cmd_simple_send.c +++ b/src/transport/test_transport_plugin_cmd_simple_send.c | |||
@@ -55,6 +55,11 @@ char *cfgname; | |||
55 | */ | 55 | */ |
56 | unsigned int are_all_peers_started; | 56 | unsigned int are_all_peers_started; |
57 | 57 | ||
58 | /** | ||
59 | * Flag indicating a received message. | ||
60 | */ | ||
61 | unsigned int message_received; | ||
62 | |||
58 | 63 | ||
59 | /** | 64 | /** |
60 | * Function called to check a message of type GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE being | 65 | * Function called to check a message of type GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE being |
@@ -80,6 +85,7 @@ handle_test (void *cls, | |||
80 | { | 85 | { |
81 | LOG (GNUNET_ERROR_TYPE_ERROR, | 86 | LOG (GNUNET_ERROR_TYPE_ERROR, |
82 | "message received\n"); | 87 | "message received\n"); |
88 | message_received = GNUNET_YES; | ||
83 | } | 89 | } |
84 | 90 | ||
85 | 91 | ||
@@ -144,7 +150,7 @@ start_testcase (TESTING_CMD_HELPER_write_cb write_message, char *router_ip, | |||
144 | 150 | ||
145 | GNUNET_asprintf (&cfgname, | 151 | GNUNET_asprintf (&cfgname, |
146 | "test_transport_api2_tcp_node%s.conf", | 152 | "test_transport_api2_tcp_node%s.conf", |
147 | n); | 153 | "1"); |
148 | 154 | ||
149 | LOG (GNUNET_ERROR_TYPE_ERROR, | 155 | LOG (GNUNET_ERROR_TYPE_ERROR, |
150 | "plugin cfgname: %s\n", | 156 | "plugin cfgname: %s\n", |
@@ -154,6 +160,11 @@ start_testcase (TESTING_CMD_HELPER_write_cb write_message, char *router_ip, | |||
154 | "node ip: %s\n", | 160 | "node ip: %s\n", |
155 | node_ip); | 161 | node_ip); |
156 | 162 | ||
163 | LOG (GNUNET_ERROR_TYPE_ERROR, | ||
164 | "m: %s n: %s\n", | ||
165 | m, | ||
166 | n); | ||
167 | |||
157 | GNUNET_asprintf (&testdir, | 168 | GNUNET_asprintf (&testdir, |
158 | "%s%s%s", | 169 | "%s%s%s", |
159 | BASE_DIR, | 170 | BASE_DIR, |
@@ -180,6 +191,7 @@ start_testcase (TESTING_CMD_HELPER_write_cb write_message, char *router_ip, | |||
180 | m, | 191 | m, |
181 | n, | 192 | n, |
182 | local_m, | 193 | local_m, |
194 | node_ip, | ||
183 | handlers, | 195 | handlers, |
184 | cfgname), | 196 | cfgname), |
185 | GNUNET_TESTING_cmd_send_peer_ready ("send-peer-ready", | 197 | GNUNET_TESTING_cmd_send_peer_ready ("send-peer-ready", |
@@ -187,13 +199,18 @@ start_testcase (TESTING_CMD_HELPER_write_cb write_message, char *router_ip, | |||
187 | GNUNET_TESTING_cmd_block_until_all_peers_started ("block", | 199 | GNUNET_TESTING_cmd_block_until_all_peers_started ("block", |
188 | &are_all_peers_started), | 200 | &are_all_peers_started), |
189 | GNUNET_TRANSPORT_cmd_connect_peers ("connect-peers", | 201 | GNUNET_TRANSPORT_cmd_connect_peers ("connect-peers", |
190 | "start-peer"), | 202 | "start-peer", |
203 | "system-create", | ||
204 | (atoi (n) - 1) * atoi (local_m) + atoi ( | ||
205 | m)), | ||
191 | GNUNET_TRANSPORT_cmd_send_simple ("send-simple", | 206 | GNUNET_TRANSPORT_cmd_send_simple ("send-simple", |
192 | m, | 207 | m, |
193 | n, | 208 | n, |
194 | (atoi (n) - 1) * atoi (local_m) + atoi ( | 209 | (atoi (n) - 1) * atoi (local_m) + atoi ( |
195 | m), | 210 | m), |
196 | "start-peer"), | 211 | "start-peer"), |
212 | GNUNET_TESTING_cmd_block_until_external_trigger ("block-receive", | ||
213 | &message_received), | ||
197 | GNUNET_TRANSPORT_cmd_stop_peer ("stop-peer", | 214 | GNUNET_TRANSPORT_cmd_stop_peer ("stop-peer", |
198 | "start-peer"), | 215 | "start-peer"), |
199 | GNUNET_TESTING_cmd_system_destroy ("system-destroy", | 216 | GNUNET_TESTING_cmd_system_destroy ("system-destroy", |