diff options
author | Sree Harsha Totakura <totakura@in.tum.de> | 2014-08-20 13:14:03 +0000 |
---|---|---|
committer | Sree Harsha Totakura <totakura@in.tum.de> | 2014-08-20 13:14:03 +0000 |
commit | da64da684e5e05349a5b0bbf17a9fc6667fb5d78 (patch) | |
tree | 44ad32accd5e0fe3924d0f3bc8e537c46a4d44e0 /src | |
parent | c7208b6d94fb6b5c0506a56c16e9b32664eb8147 (diff) | |
download | gnunet-da64da684e5e05349a5b0bbf17a9fc6667fb5d78.tar.gz gnunet-da64da684e5e05349a5b0bbf17a9fc6667fb5d78.zip |
Fix counting started peers.
Diffstat (limited to 'src')
-rw-r--r-- | src/dht/gnunet_dht_profiler.c | 18 |
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 | } |