aboutsummaryrefslogtreecommitdiff
path: root/src/testing/testing_api_cmd_barrier.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/testing/testing_api_cmd_barrier.c')
-rw-r--r--src/testing/testing_api_cmd_barrier.c20
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 */
232struct GNUNET_TESTING_Barrier*
233GNUNET_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}