From eed1bbcef229e68cc978032ede771a08862f7e28 Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Thu, 29 Sep 2011 23:07:27 +0000 Subject: [PATCH] use unique keys for each peer pair --- src/dht/test_dht_multipeer.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/dht/test_dht_multipeer.c b/src/dht/test_dht_multipeer.c index baa8cabab..361fd6954 100644 --- a/src/dht/test_dht_multipeer.c +++ b/src/dht/test_dht_multipeer.c @@ -498,7 +498,7 @@ put_finished (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) GNUNET_SCHEDULER_cancel (test_put->task); test_put->task = GNUNET_SCHEDULER_add_now (&put_disconnect_task, test_put); - if (puts_completed != num_peers) + if (puts_completed != num_peers * num_peers) return; GNUNET_assert (outstanding_puts == 0); @@ -509,7 +509,7 @@ put_finished (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) for (j = 0; j < num_peers; j++) { test_get = GNUNET_malloc (sizeof (struct TestGetContext)); - test_get->uid = i; + test_get->uid = i + j*num_peers; test_get->daemon = GNUNET_TESTING_daemon_get (pg, j); GNUNET_CONTAINER_DLL_insert (all_gets_head, all_gets_tail, @@ -590,11 +590,11 @@ run_dht_test (void *cls, const char *emsg) fprintf (stderr, "Issuing %llu PUTs (one per peer)\n", num_peers); - for (i = 0; i < num_peers; i++) + for (i = 0; i < num_peers * num_peers; i++) { test_put = GNUNET_malloc (sizeof (struct TestPutContext)); test_put->uid = i; - test_put->daemon = GNUNET_TESTING_daemon_get (pg, i); + test_put->daemon = GNUNET_TESTING_daemon_get (pg, i % num_peers); test_put->task = GNUNET_SCHEDULER_add_now (&do_put, test_put); GNUNET_CONTAINER_DLL_insert (all_puts_head, all_puts_tail, -- 2.25.1