aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSree Harsha Totakura <totakura@in.tum.de>2014-08-20 13:14:03 +0000
committerSree Harsha Totakura <totakura@in.tum.de>2014-08-20 13:14:03 +0000
commitda64da684e5e05349a5b0bbf17a9fc6667fb5d78 (patch)
tree44ad32accd5e0fe3924d0f3bc8e537c46a4d44e0
parentc7208b6d94fb6b5c0506a56c16e9b32664eb8147 (diff)
downloadgnunet-da64da684e5e05349a5b0bbf17a9fc6667fb5d78.tar.gz
gnunet-da64da684e5e05349a5b0bbf17a9fc6667fb5d78.zip
Fix counting started peers.
-rw-r--r--src/dht/gnunet_dht_profiler.c18
1 files changed, 3 insertions, 15 deletions
diff --git a/src/dht/gnunet_dht_profiler.c b/src/dht/gnunet_dht_profiler.c
index 0b81a004a..7854ac319 100644
--- a/src/dht/gnunet_dht_profiler.c
+++ b/src/dht/gnunet_dht_profiler.c
@@ -923,34 +923,22 @@ service_started (void *cls,
923 const char *emsg) 923 const char *emsg)
924{ 924{
925 struct Context *ctx = cls; 925 struct Context *ctx = cls;
926 926
927 GNUNET_assert (NULL != ctx); 927 GNUNET_assert (NULL != ctx);
928 GNUNET_assert (NULL != ctx->op); 928 GNUNET_assert (NULL != ctx->op);
929 GNUNET_TESTBED_operation_done (ctx->op); 929 GNUNET_TESTBED_operation_done (ctx->op);
930 ctx->op = NULL;
931 if (NULL == ctx->ac)
932 return;
933
934 if (NULL == peer_contexts)
935 {
936 peer_contexts = GNUNET_malloc(num_peers * sizeof(struct Context *));
937 }
938
939 peer_contexts[peers_started] = ctx;
940 peers_started++; 930 peers_started++;
941 DEBUG("Peers Started = %d; num_peers = %d \n", peers_started, num_peers); 931 DEBUG("Peers Started = %d; num_peers = %d \n", peers_started, num_peers);
942
943 if (GNUNET_SCHEDULER_NO_TASK == successor_stats_task && peers_started == num_peers) 932 if (GNUNET_SCHEDULER_NO_TASK == successor_stats_task && peers_started == num_peers)
944 { 933 {
945 DEBUG("successor_stats_task \n"); 934 DEBUG("successor_stats_task \n");
946 struct Collect_Stat_Context *collect_stat_cls = GNUNET_new(struct Collect_Stat_Context); 935 struct Collect_Stat_Context *collect_stat_cls = GNUNET_new(struct Collect_Stat_Context);
947 collect_stat_cls->service_connect_ctx = cls; 936 collect_stat_cls->service_connect_ctx = cls;
948 collect_stat_cls->op = op; 937 collect_stat_cls->op = op;
949
950 successor_peer_hashmap = GNUNET_CONTAINER_multihashmap_create (num_peers, 938 successor_peer_hashmap = GNUNET_CONTAINER_multihashmap_create (num_peers,
951 GNUNET_NO); 939 GNUNET_NO);
952 successor_stats_task = GNUNET_SCHEDULER_add_delayed (delay, 940 successor_stats_task = GNUNET_SCHEDULER_add_delayed (delay,
953 &collect_stats, 941 &collect_stats,
954 collect_stat_cls); 942 collect_stat_cls);
955 } 943 }
956} 944}