aboutsummaryrefslogtreecommitdiff
path: root/src/consensus/gnunet-consensus.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/consensus/gnunet-consensus.c')
-rw-r--r--src/consensus/gnunet-consensus.c7
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)
99static void 99static void
100conclude_cb (void *cls) 100conclude_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