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.c5
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