summaryrefslogtreecommitdiff
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.c6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/consensus/gnunet-consensus.c b/src/consensus/gnunet-consensus.c
index d8c1b14ee..60db8c61a 100644
--- a/src/consensus/gnunet-consensus.c
+++ b/src/consensus/gnunet-consensus.c
@@ -133,7 +133,7 @@ do_consensus ()
133 { 133 {
134 int j; 134 int j;
135 struct GNUNET_HashCode *val; 135 struct GNUNET_HashCode *val;
136 struct GNUNET_CONSENSUS_Element *element; 136 struct GNUNET_SET_Element *element;
137 generate_indices(unique_indices); 137 generate_indices(unique_indices);
138 138
139 val = GNUNET_malloc (sizeof *val); 139 val = GNUNET_malloc (sizeof *val);
@@ -151,6 +151,8 @@ do_consensus ()
151 } 151 }
152 } 152 }
153 153
154 GNUNET_log (GNUNET_ERROR_TYPE_INFO, "all elements inserted, calling conclude\n");
155
154 for (i = 0; i < num_peers; i++) 156 for (i = 0; i < num_peers; i++)
155 GNUNET_CONSENSUS_conclude (consensus_handles[i], conclude_timeout, conclude_cb, consensus_handles[i]); 157 GNUNET_CONSENSUS_conclude (consensus_handles[i], conclude_timeout, conclude_cb, consensus_handles[i]);
156} 158}
@@ -194,7 +196,7 @@ connect_complete (void *cls,
194 196
195static void 197static void
196new_element_cb (void *cls, 198new_element_cb (void *cls,
197 const struct GNUNET_CONSENSUS_Element *element) 199 const struct GNUNET_SET_Element *element)
198{ 200{
199 GNUNET_log (GNUNET_ERROR_TYPE_INFO, "received new element\n"); 201 GNUNET_log (GNUNET_ERROR_TYPE_INFO, "received new element\n");
200} 202}