diff options
Diffstat (limited to 'src/testing/testing_api_cmd_barrier_reached.c')
-rw-r--r-- | src/testing/testing_api_cmd_barrier_reached.c | 6 |
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 | } |