diff options
Diffstat (limited to 'src/testing/testing_api_cmd_barrier.c')
-rw-r--r-- | src/testing/testing_api_cmd_barrier.c | 20 |
1 files changed, 6 insertions, 14 deletions
diff --git a/src/testing/testing_api_cmd_barrier.c b/src/testing/testing_api_cmd_barrier.c index 64cefd235..d27ce9d94 100644 --- a/src/testing/testing_api_cmd_barrier.c +++ b/src/testing/testing_api_cmd_barrier.c | |||
@@ -62,12 +62,14 @@ GNUNET_TESTING_send_barrier_attach (struct GNUNET_TESTING_Interpreter *is, | |||
62 | { | 62 | { |
63 | struct GNUNET_TESTING_CommandBarrierAttached *atm = GNUNET_new (struct GNUNET_TESTING_CommandBarrierAttached); | 63 | struct GNUNET_TESTING_CommandBarrierAttached *atm = GNUNET_new (struct GNUNET_TESTING_CommandBarrierAttached); |
64 | size_t msg_length = sizeof(struct GNUNET_TESTING_CommandBarrierAttached); | 64 | size_t msg_length = sizeof(struct GNUNET_TESTING_CommandBarrierAttached); |
65 | size_t name_len; | ||
65 | 66 | ||
67 | name_len = strlen (barrier_name) + 1; | ||
66 | atm->header.type = htons (GNUNET_MESSAGE_TYPE_CMDS_HELPER_BARRIER_ATTACHED); | 68 | atm->header.type = htons (GNUNET_MESSAGE_TYPE_CMDS_HELPER_BARRIER_ATTACHED); |
67 | atm->header.size = htons ((uint16_t) msg_length); | 69 | atm->header.size = htons ((uint16_t) msg_length); |
68 | atm->barrier_name = barrier_name; | ||
69 | atm->expected_reaches = expected_reaches; | 70 | atm->expected_reaches = expected_reaches; |
70 | atm->node_number = global_node_number; | 71 | atm->node_number = global_node_number; |
72 | memcpy (&atm[1], barrier_name, name_len); | ||
71 | write_message ((struct GNUNET_MessageHeader *) atm, msg_length); | 73 | write_message ((struct GNUNET_MessageHeader *) atm, msg_length); |
72 | 74 | ||
73 | GNUNET_free (atm); | 75 | GNUNET_free (atm); |
@@ -88,10 +90,12 @@ GNUNET_TESTING_send_barrier_advance (struct GNUNET_TESTING_Interpreter *is, | |||
88 | { | 90 | { |
89 | struct GNUNET_TESTING_CommandBarrierAdvanced *adm = GNUNET_new (struct GNUNET_TESTING_CommandBarrierAdvanced); | 91 | struct GNUNET_TESTING_CommandBarrierAdvanced *adm = GNUNET_new (struct GNUNET_TESTING_CommandBarrierAdvanced); |
90 | size_t msg_length = sizeof(struct GNUNET_TESTING_CommandBarrierAdvanced); | 92 | size_t msg_length = sizeof(struct GNUNET_TESTING_CommandBarrierAdvanced); |
93 | size_t name_len; | ||
91 | 94 | ||
95 | name_len = strlen (barrier_name) + 1; | ||
92 | adm->header.type = htons (GNUNET_MESSAGE_TYPE_CMDS_HELPER_BARRIER_ADVANCED); | 96 | adm->header.type = htons (GNUNET_MESSAGE_TYPE_CMDS_HELPER_BARRIER_ADVANCED); |
93 | adm->header.size = htons ((uint16_t) msg_length); | 97 | adm->header.size = htons ((uint16_t) msg_length); |
94 | adm->barrier_name = barrier_name; | 98 | memcpy (&adm[1], barrier_name, name_len); |
95 | GNUNET_TESTING_send_message_to_netjail (is, | 99 | GNUNET_TESTING_send_message_to_netjail (is, |
96 | global_node_number, | 100 | global_node_number, |
97 | &adm->header); | 101 | &adm->header); |
@@ -225,15 +229,3 @@ GNUNET_TESTING_cmd_barrier_create (const char *label, | |||
225 | &barrier_traits, | 229 | &barrier_traits, |
226 | NULL); | 230 | NULL); |
227 | } | 231 | } |
228 | |||
229 | /** | ||
230 | * FIXME: Not sure if this is correct here | ||
231 | */ | ||
232 | struct GNUNET_TESTING_Barrier* | ||
233 | GNUNET_TESTING_barrier_new (const char* testcase_name) | ||
234 | { | ||
235 | struct GNUNET_TESTING_Barrier *barr; | ||
236 | barr = GNUNET_new (struct GNUNET_TESTING_Barrier); | ||
237 | barr->name = GNUNET_strdup (testcase_name); | ||
238 | return barr; | ||
239 | } | ||