aboutsummaryrefslogtreecommitdiff
path: root/src/consensus/consensus_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/consensus/consensus_api.c')
-rw-r--r--src/consensus/consensus_api.c16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/consensus/consensus_api.c b/src/consensus/consensus_api.c
index 088fafd08..18898bebd 100644
--- a/src/consensus/consensus_api.c
+++ b/src/consensus/consensus_api.c
@@ -202,17 +202,17 @@ GNUNET_CONSENSUS_create (const struct GNUNET_CONFIGURATION_Handle *cfg,
202 GNUNET_CONSENSUS_ElementCallback new_element_cb, 202 GNUNET_CONSENSUS_ElementCallback new_element_cb,
203 void *new_element_cls) 203 void *new_element_cls)
204{ 204{
205 GNUNET_MQ_hd_var_size (new_element,
206 GNUNET_MESSAGE_TYPE_CONSENSUS_CLIENT_RECEIVED_ELEMENT,
207 struct GNUNET_CONSENSUS_ElementMessage);
208 GNUNET_MQ_hd_fixed_size (conclude_done,
209 GNUNET_MESSAGE_TYPE_CONSENSUS_CLIENT_CONCLUDE_DONE,
210 struct GNUNET_MessageHeader);
211 struct GNUNET_CONSENSUS_Handle *consensus 205 struct GNUNET_CONSENSUS_Handle *consensus
212 = GNUNET_new (struct GNUNET_CONSENSUS_Handle); 206 = GNUNET_new (struct GNUNET_CONSENSUS_Handle);
213 struct GNUNET_MQ_MessageHandler mq_handlers[] = { 207 struct GNUNET_MQ_MessageHandler mq_handlers[] = {
214 make_new_element_handler (consensus), 208 GNUNET_MQ_hd_var_size (new_element,
215 make_conclude_done_handler (consensus), 209 GNUNET_MESSAGE_TYPE_CONSENSUS_CLIENT_RECEIVED_ELEMENT,
210 struct GNUNET_CONSENSUS_ElementMessage,
211 consensus),
212 GNUNET_MQ_hd_fixed_size (conclude_done,
213 GNUNET_MESSAGE_TYPE_CONSENSUS_CLIENT_CONCLUDE_DONE,
214 struct GNUNET_MessageHeader,
215 consensus),
216 GNUNET_MQ_handler_end () 216 GNUNET_MQ_handler_end ()
217 }; 217 };
218 struct GNUNET_CONSENSUS_JoinMessage *join_msg; 218 struct GNUNET_CONSENSUS_JoinMessage *join_msg;