aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorSree Harsha Totakura <totakura@in.tum.de>2014-08-20 13:00:31 +0000
committerSree Harsha Totakura <totakura@in.tum.de>2014-08-20 13:00:31 +0000
commitc7208b6d94fb6b5c0506a56c16e9b32664eb8147 (patch)
tree28397a5863b2fceb9b283b0c01bd9344f0804e9d /src
parentab18dc025d49c720bf59eb88748a8c1d58d50af2 (diff)
downloadgnunet-c7208b6d94fb6b5c0506a56c16e9b32664eb8147.tar.gz
gnunet-c7208b6d94fb6b5c0506a56c16e9b32664eb8147.zip
Start PUTs and GETs only from active peers
Diffstat (limited to 'src')
-rw-r--r--src/dht/gnunet_dht_profiler.c23
1 files changed, 11 insertions, 12 deletions
diff --git a/src/dht/gnunet_dht_profiler.c b/src/dht/gnunet_dht_profiler.c
index 9c0693e43..0b81a004a 100644
--- a/src/dht/gnunet_dht_profiler.c
+++ b/src/dht/gnunet_dht_profiler.c
@@ -728,19 +728,18 @@ static void
728start_testbed_service_on_all_peers() 728start_testbed_service_on_all_peers()
729{ 729{
730 unsigned int i; 730 unsigned int i;
731 for(i = 0; i < peers_started; i++) 731 DEBUG("GNUNET_TESTBED_service_connect \n");
732 for(i = 0; i < n_active; i++)
732 { 733 {
733 struct Context *ctx = peer_contexts[i]; 734 struct ActiveContext *ac = &a_ac[i];
734 DEBUG("GNUNET_TESTBED_service_connect \n"); 735 ac->ctx->op =
735 ctx->op = 736 GNUNET_TESTBED_service_connect (ac->ctx,
736 GNUNET_TESTBED_service_connect (ctx, 737 ac->ctx->peer,
737 ctx->peer, 738 "dht",
738 "dht", 739 &dht_connected, ac,
739 &dht_connected, ctx->ac, 740 &dht_connect,
740 &dht_connect, 741 &dht_disconnect,
741 &dht_disconnect, 742 ac);
742 ctx->ac);
743
744 } 743 }
745} 744}
746 745