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.c8
1 files changed, 6 insertions, 2 deletions
diff --git a/src/set/set_api.c b/src/set/set_api.c
index b2491afe7..daa15c081 100644
--- a/src/set/set_api.c
+++ b/src/set/set_api.c
@@ -288,6 +288,7 @@ GNUNET_SET_evaluate (struct GNUNET_SET_Handle *set,
288 const struct GNUNET_PeerIdentity *other_peer, 288 const struct GNUNET_PeerIdentity *other_peer,
289 const struct GNUNET_HashCode *app_id, 289 const struct GNUNET_HashCode *app_id,
290 const struct GNUNET_MessageHeader *context_msg, 290 const struct GNUNET_MessageHeader *context_msg,
291 uint16_t salt,
291 struct GNUNET_TIME_Relative timeout, 292 struct GNUNET_TIME_Relative timeout,
292 enum GNUNET_SET_ResultMode result_mode, 293 enum GNUNET_SET_ResultMode result_mode,
293 GNUNET_SET_ResultIterator result_cb, 294 GNUNET_SET_ResultIterator result_cb,
@@ -302,11 +303,14 @@ GNUNET_SET_evaluate (struct GNUNET_SET_Handle *set,
302 oh->result_cls = result_cls; 303 oh->result_cls = result_cls;
303 oh->set = set; 304 oh->set = set;
304 305
305 mqm = GNUNET_MQ_msg_extra (msg, htons(context_msg->size), GNUNET_MESSAGE_TYPE_SET_EVALUATE); 306 mqm = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_SET_EVALUATE);
306 msg->request_id = htonl (GNUNET_MQ_assoc_add (set->mq, mqm, oh)); 307 msg->request_id = htonl (GNUNET_MQ_assoc_add (set->mq, mqm, oh));
307 msg->peer = *other_peer; 308 msg->peer = *other_peer;
308 msg->app_id = *app_id; 309 msg->app_id = *app_id;
309 memcpy (&msg[1], context_msg, htons (context_msg->size)); 310
311 if (GNUNET_OK != GNUNET_MQ_nest (mqm, context_msg))
312 GNUNET_assert (0);
313
310 oh->timeout_task = GNUNET_SCHEDULER_add_delayed (timeout, operation_timeout_task, oh); 314 oh->timeout_task = GNUNET_SCHEDULER_add_delayed (timeout, operation_timeout_task, oh);
311 GNUNET_MQ_send (set->mq, mqm); 315 GNUNET_MQ_send (set->mq, mqm);
312 316