aboutsummaryrefslogtreecommitdiff
path: root/src/testing/testing_api_cmd_barrier_reached.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/testing/testing_api_cmd_barrier_reached.c')
-rw-r--r--src/testing/testing_api_cmd_barrier_reached.c6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/testing/testing_api_cmd_barrier_reached.c b/src/testing/testing_api_cmd_barrier_reached.c
index 58f420214..eca422b1d 100644
--- a/src/testing/testing_api_cmd_barrier_reached.c
+++ b/src/testing/testing_api_cmd_barrier_reached.c
@@ -91,6 +91,7 @@ barrier_reached_run (void *cls,
91 struct CommandListEntry *cle; 91 struct CommandListEntry *cle;
92 size_t msg_length; 92 size_t msg_length;
93 struct GNUNET_TESTING_CommandBarrierReached *msg; 93 struct GNUNET_TESTING_CommandBarrierReached *msg;
94 size_t name_len;
94 95
95 barrier = GNUNET_TESTING_get_barrier (is, brs->barrier_name); 96 barrier = GNUNET_TESTING_get_barrier (is, brs->barrier_name);
96 if (NULL == barrier) 97 if (NULL == barrier)
@@ -106,7 +107,7 @@ barrier_reached_run (void *cls,
106 //FIXME cmd uninitialized 107 //FIXME cmd uninitialized
107 GNUNET_assert (NULL != cmd); 108 GNUNET_assert (NULL != cmd);
108 cmd->asynchronous_finish = GNUNET_YES; 109 cmd->asynchronous_finish = GNUNET_YES;
109 GNUNET_TESTING_finish_attached_cmds (is, barrier); 110 GNUNET_TESTING_finish_attached_cmds (is, barrier->name);
110 } 111 }
111 else if (GNUNET_NO == brs->asynchronous_finish) 112 else if (GNUNET_NO == brs->asynchronous_finish)
112 { 113 {
@@ -126,11 +127,12 @@ barrier_reached_run (void *cls,
126 } 127 }
127 if (GNUNET_NO == brs->running_on_master) 128 if (GNUNET_NO == brs->running_on_master)
128 { 129 {
130 name_len = strlen (barrier->name) + 1;
129 msg_length = sizeof(struct GNUNET_TESTING_CommandBarrierReached); 131 msg_length = sizeof(struct GNUNET_TESTING_CommandBarrierReached);
130 msg = GNUNET_new (struct GNUNET_TESTING_CommandBarrierReached); 132 msg = GNUNET_new (struct GNUNET_TESTING_CommandBarrierReached);
131 msg->header.size = htons ((uint16_t) msg_length); 133 msg->header.size = htons ((uint16_t) msg_length);
132 msg->header.type = htons (GNUNET_MESSAGE_TYPE_CMDS_HELPER_BARRIER_REACHED); 134 msg->header.type = htons (GNUNET_MESSAGE_TYPE_CMDS_HELPER_BARRIER_REACHED);
133 msg->barrier_name = barrier->name; 135 memcpy (&msg[1], barrier->name, name_len);
134 msg->node_number = brs->node_number; 136 msg->node_number = brs->node_number;
135 brs->write_message ((struct GNUNET_MessageHeader *) msg, msg_length); 137 brs->write_message ((struct GNUNET_MessageHeader *) msg, msg_length);
136 } 138 }