diff options
Diffstat (limited to 'src/set/set_api.c')
-rw-r--r-- | src/set/set_api.c | 40 |
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, | |||
901 | static void | 901 | static void |
902 | listen_connect (void *cls) | 902 | listen_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; |