diff options
Diffstat (limited to 'src/set/set_api.c')
-rw-r--r-- | src/set/set_api.c | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/set/set_api.c b/src/set/set_api.c index 7f52fb0a9..3b287d5a4 100644 --- a/src/set/set_api.c +++ b/src/set/set_api.c | |||
@@ -222,6 +222,8 @@ handle_iter_element (void *cls, const struct GNUNET_MessageHeader *mh) | |||
222 | struct GNUNET_SET_Element element; | 222 | struct GNUNET_SET_Element element; |
223 | const struct GNUNET_SET_IterResponseMessage *msg = | 223 | const struct GNUNET_SET_IterResponseMessage *msg = |
224 | (const struct GNUNET_SET_IterResponseMessage *) mh; | 224 | (const struct GNUNET_SET_IterResponseMessage *) mh; |
225 | struct GNUNET_SET_IterAckMessage *ack_msg; | ||
226 | struct GNUNET_MQ_Envelope *ev; | ||
225 | 227 | ||
226 | if (NULL == set->iterator) | 228 | if (NULL == set->iterator) |
227 | return; | 229 | return; |
@@ -230,6 +232,9 @@ handle_iter_element (void *cls, const struct GNUNET_MessageHeader *mh) | |||
230 | element.type = htons (msg->element_type); | 232 | element.type = htons (msg->element_type); |
231 | element.data = &msg[1]; | 233 | element.data = &msg[1]; |
232 | set->iterator (set->iterator_cls, &element); | 234 | set->iterator (set->iterator_cls, &element); |
235 | ev = GNUNET_MQ_msg (ack_msg, GNUNET_MESSAGE_TYPE_SET_ITER_ACK); | ||
236 | ack_msg->send_more = htonl (1); | ||
237 | GNUNET_MQ_send (set->mq, ev); | ||
233 | } | 238 | } |
234 | 239 | ||
235 | 240 | ||