aboutsummaryrefslogtreecommitdiff
path: root/src/messenger/testing_messenger_setup.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/messenger/testing_messenger_setup.c')
-rw-r--r--src/messenger/testing_messenger_setup.c4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/messenger/testing_messenger_setup.c b/src/messenger/testing_messenger_setup.c
index dbab3e82d..29db25bd8 100644
--- a/src/messenger/testing_messenger_setup.c
+++ b/src/messenger/testing_messenger_setup.c
@@ -284,8 +284,10 @@ on_message (void *cls,
284 GNUNET_CONTAINER_multipeermap_put (peer->map, &(message->body.peer.peer), NULL, 284 GNUNET_CONTAINER_multipeermap_put (peer->map, &(message->body.peer.peer), NULL,
285 GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE); 285 GNUNET_CONTAINER_MULTIHASHMAPOPTION_REPLACE);
286 286
287 const int members = GNUNET_MESSENGER_iterate_members(peer->room, NULL, NULL);
288
287 const uint32_t num_peers = GNUNET_CONTAINER_multipeermap_size (peer->map); 289 const uint32_t num_peers = GNUNET_CONTAINER_multipeermap_size (peer->map);
288 if (peer->props->num_hosts == num_peers) 290 if ((members == peer->props->num_peer) && (peer->props->num_hosts == num_peers))
289 peer->wait = GNUNET_wait_barrier (peer->props->barrier, &barrier2_wait_cb, peer); 291 peer->wait = GNUNET_wait_barrier (peer->props->barrier, &barrier2_wait_cb, peer);
290 else if (peer->props->num_hosts < num_peers) 292 else if (peer->props->num_hosts < num_peers)
291 { 293 {