[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r34181 - gnunet/src/dht
From: |
gnunet |
Subject: |
[GNUnet-SVN] r34181 - gnunet/src/dht |
Date: |
Wed, 20 Aug 2014 15:14:03 +0200 |
Author: harsha
Date: 2014-08-20 15:14:03 +0200 (Wed, 20 Aug 2014)
New Revision: 34181
Modified:
gnunet/src/dht/gnunet_dht_profiler.c
Log:
Fix counting started peers.
Modified: gnunet/src/dht/gnunet_dht_profiler.c
===================================================================
--- gnunet/src/dht/gnunet_dht_profiler.c 2014-08-20 13:00:31 UTC (rev
34180)
+++ gnunet/src/dht/gnunet_dht_profiler.c 2014-08-20 13:14:03 UTC (rev
34181)
@@ -923,34 +923,22 @@
const char *emsg)
{
struct Context *ctx = cls;
-
+
GNUNET_assert (NULL != ctx);
GNUNET_assert (NULL != ctx->op);
GNUNET_TESTBED_operation_done (ctx->op);
- ctx->op = NULL;
- if (NULL == ctx->ac)
- return;
-
- if (NULL == peer_contexts)
- {
- peer_contexts = GNUNET_malloc(num_peers * sizeof(struct Context *));
- }
-
- peer_contexts[peers_started] = ctx;
peers_started++;
DEBUG("Peers Started = %d; num_peers = %d \n", peers_started, num_peers);
-
if (GNUNET_SCHEDULER_NO_TASK == successor_stats_task && peers_started ==
num_peers)
{
DEBUG("successor_stats_task \n");
struct Collect_Stat_Context *collect_stat_cls = GNUNET_new(struct
Collect_Stat_Context);
collect_stat_cls->service_connect_ctx = cls;
collect_stat_cls->op = op;
-
successor_peer_hashmap = GNUNET_CONTAINER_multihashmap_create (num_peers,
GNUNET_NO);
- successor_stats_task = GNUNET_SCHEDULER_add_delayed (delay,
- &collect_stats,
+ successor_stats_task = GNUNET_SCHEDULER_add_delayed (delay,
+ &collect_stats,
collect_stat_cls);
}
}
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r34181 - gnunet/src/dht,
gnunet <=