aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/dht/gnunet-dht-driver.c8
1 files changed, 5 insertions, 3 deletions
diff --git a/src/dht/gnunet-dht-driver.c b/src/dht/gnunet-dht-driver.c
index db7bf2159..dd2feac45 100644
--- a/src/dht/gnunet-dht-driver.c
+++ b/src/dht/gnunet-dht-driver.c
@@ -63,7 +63,9 @@
63 63
64#define DEFAULT_MAX_OUTSTANDING_PUTS 10 64#define DEFAULT_MAX_OUTSTANDING_PUTS 10
65 65
66#define DEFAULT_MAX_OUTSTANDING_FIND_PEERS 1 66#define DEFAULT_MAX_OUTSTANDING_FIND_PEERS 10
67
68#define DEFAULT_FIND_PEER_OFFSET GNUNET_TIME_relative_divide (DEFAULT_SECONDS_PER_PEER_START, DEFAULT_MAX_OUTSTANDING_FIND_PEERS)
67 69
68#define DEFAULT_MAX_OUTSTANDING_GETS 10 70#define DEFAULT_MAX_OUTSTANDING_GETS 10
69 71
@@ -1168,7 +1170,7 @@ send_find_peer_request (void *cls, const struct GNUNET_SCHEDULER_TaskContext * t
1168 1170
1169 if (test_find_peer->find_peer_context->outstanding > max_outstanding_find_peers) 1171 if (test_find_peer->find_peer_context->outstanding > max_outstanding_find_peers)
1170 { 1172 {
1171 GNUNET_SCHEDULER_add_delayed(sched, GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_MILLISECONDS, 300), &send_find_peer_request, test_find_peer); 1173 GNUNET_SCHEDULER_add_delayed(sched, DEFAULT_FIND_PEER_OFFSET, &send_find_peer_request, test_find_peer);
1172 return; 1174 return;
1173 } 1175 }
1174 1176
@@ -1206,7 +1208,7 @@ schedule_find_peer_requests (void *cls, const struct GNUNET_SCHEDULER_TaskContex
1206 test_find_peer->daemon = GNUNET_TESTING_daemon_get(pg, random); 1208 test_find_peer->daemon = GNUNET_TESTING_daemon_get(pg, random);
1207 test_find_peer->find_peer_context = find_peer_ctx; 1209 test_find_peer->find_peer_context = find_peer_ctx;
1208 find_peer_ctx->total++; 1210 find_peer_ctx->total++;
1209 GNUNET_SCHEDULER_add_now(sched, &send_find_peer_request, test_find_peer); 1211 GNUNET_SCHEDULER_add_delayed(sched, GNUNET_TIME_relative_multiply(DEFAULT_FIND_PEER_OFFSET, i), &send_find_peer_request, test_find_peer);
1210 } 1212 }
1211} 1213}
1212 1214