aboutsummaryrefslogtreecommitdiff
path: root/src/transport/test_transport_plugin_cmd_simple_send.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/test_transport_plugin_cmd_simple_send.c')
-rw-r--r--src/transport/test_transport_plugin_cmd_simple_send.c21
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 */
56unsigned int are_all_peers_started; 56unsigned int are_all_peers_started;
57 57
58/**
59 * Flag indicating a received message.
60 */
61unsigned 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",