diff options
Diffstat (limited to 'src/messenger/testing_messenger_setup.c')
-rw-r--r-- | src/messenger/testing_messenger_setup.c | 4 |
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 | { |