diff options
Diffstat (limited to 'src/consensus/gnunet-consensus.c')
-rw-r--r-- | src/consensus/gnunet-consensus.c | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/consensus/gnunet-consensus.c b/src/consensus/gnunet-consensus.c index dca18cece..42040527f 100644 --- a/src/consensus/gnunet-consensus.c +++ b/src/consensus/gnunet-consensus.c | |||
@@ -99,8 +99,9 @@ destroy (void *cls, const struct GNUNET_SCHEDULER_TaskContext *ctx) | |||
99 | static void | 99 | static void |
100 | conclude_cb (void *cls) | 100 | conclude_cb (void *cls) |
101 | { | 101 | { |
102 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "consensus done\n"); | 102 | struct GNUNET_CONSENSUS_Handle **chp = cls; |
103 | GNUNET_SCHEDULER_add_now (destroy, cls); | 103 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "consensus %d done\n", chp - consensus_handles); |
104 | GNUNET_SCHEDULER_add_now (destroy, *chp); | ||
104 | } | 105 | } |
105 | 106 | ||
106 | 107 | ||
@@ -159,7 +160,7 @@ do_consensus () | |||
159 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "all elements inserted, calling conclude\n"); | 160 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, "all elements inserted, calling conclude\n"); |
160 | 161 | ||
161 | for (i = 0; i < num_peers; i++) | 162 | for (i = 0; i < num_peers; i++) |
162 | GNUNET_CONSENSUS_conclude (consensus_handles[i], conclude_timeout, conclude_cb, consensus_handles[i]); | 163 | GNUNET_CONSENSUS_conclude (consensus_handles[i], conclude_timeout, conclude_cb, &consensus_handles[i]); |
163 | } | 164 | } |
164 | 165 | ||
165 | 166 | ||