diff options
Diffstat (limited to 'src/set/set_api.c')
-rw-r--r-- | src/set/set_api.c | 8 |
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 | ||