aboutsummaryrefslogtreecommitdiff
path: root/src/set/set_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/set/set_api.c')
-rw-r--r--src/set/set_api.c40
1 files changed, 20 insertions, 20 deletions
diff --git a/src/set/set_api.c b/src/set/set_api.c
index 3e9a4fdcf..7a33b86ea 100644
--- a/src/set/set_api.c
+++ b/src/set/set_api.c
@@ -561,24 +561,24 @@ create_internal (const struct GNUNET_CONFIGURATION_Handle *cfg,
561 enum GNUNET_SET_OperationType op, 561 enum GNUNET_SET_OperationType op,
562 const uint32_t *cookie) 562 const uint32_t *cookie)
563{ 563{
564 GNUNET_MQ_hd_var_size (result,
565 GNUNET_MESSAGE_TYPE_SET_RESULT,
566 struct GNUNET_SET_ResultMessage);
567 GNUNET_MQ_hd_var_size (iter_element,
568 GNUNET_MESSAGE_TYPE_SET_ITER_ELEMENT,
569 struct GNUNET_SET_IterResponseMessage);
570 GNUNET_MQ_hd_fixed_size (iter_done,
571 GNUNET_MESSAGE_TYPE_SET_ITER_DONE,
572 struct GNUNET_MessageHeader);
573 GNUNET_MQ_hd_fixed_size (copy_lazy,
574 GNUNET_MESSAGE_TYPE_SET_COPY_LAZY_RESPONSE,
575 struct GNUNET_SET_CopyLazyResponseMessage);
576 struct GNUNET_SET_Handle *set = GNUNET_new (struct GNUNET_SET_Handle); 564 struct GNUNET_SET_Handle *set = GNUNET_new (struct GNUNET_SET_Handle);
577 struct GNUNET_MQ_MessageHandler mq_handlers[] = { 565 struct GNUNET_MQ_MessageHandler mq_handlers[] = {
578 make_result_handler (set), 566 GNUNET_MQ_hd_var_size (result,
579 make_iter_element_handler (set), 567 GNUNET_MESSAGE_TYPE_SET_RESULT,
580 make_iter_done_handler (set), 568 struct GNUNET_SET_ResultMessage,
581 make_copy_lazy_handler (set), 569 set),
570 GNUNET_MQ_hd_var_size (iter_element,
571 GNUNET_MESSAGE_TYPE_SET_ITER_ELEMENT,
572 struct GNUNET_SET_IterResponseMessage,
573 set),
574 GNUNET_MQ_hd_fixed_size (iter_done,
575 GNUNET_MESSAGE_TYPE_SET_ITER_DONE,
576 struct GNUNET_MessageHeader,
577 set),
578 GNUNET_MQ_hd_fixed_size (copy_lazy,
579 GNUNET_MESSAGE_TYPE_SET_COPY_LAZY_RESPONSE,
580 struct GNUNET_SET_CopyLazyResponseMessage,
581 set),
582 GNUNET_MQ_handler_end () 582 GNUNET_MQ_handler_end ()
583 }; 583 };
584 struct GNUNET_MQ_Envelope *mqm; 584 struct GNUNET_MQ_Envelope *mqm;
@@ -901,12 +901,12 @@ handle_client_listener_error (void *cls,
901static void 901static void
902listen_connect (void *cls) 902listen_connect (void *cls)
903{ 903{
904 GNUNET_MQ_hd_var_size (request,
905 GNUNET_MESSAGE_TYPE_SET_REQUEST,
906 struct GNUNET_SET_RequestMessage);
907 struct GNUNET_SET_ListenHandle *lh = cls; 904 struct GNUNET_SET_ListenHandle *lh = cls;
908 struct GNUNET_MQ_MessageHandler mq_handlers[] = { 905 struct GNUNET_MQ_MessageHandler mq_handlers[] = {
909 make_request_handler (lh), 906 GNUNET_MQ_hd_var_size (request,
907 GNUNET_MESSAGE_TYPE_SET_REQUEST,
908 struct GNUNET_SET_RequestMessage,
909 lh),
910 GNUNET_MQ_handler_end () 910 GNUNET_MQ_handler_end ()
911 }; 911 };
912 struct GNUNET_MQ_Envelope *mqm; 912 struct GNUNET_MQ_Envelope *mqm;