aboutsummaryrefslogtreecommitdiff
path: root/src/set/set_api.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2014-11-27 11:35:42 +0000
committerChristian Grothoff <christian@grothoff.org>2014-11-27 11:35:42 +0000
commit2b0e3f9ba871095d003fc078eee75b5eda6fc8b8 (patch)
treeb37e6f7d930ca23b0743bda4a76f82aa7c794e13 /src/set/set_api.c
parent393b5b11525badff59ff6df0572c5cdf42c1587c (diff)
downloadgnunet-2b0e3f9ba871095d003fc078eee75b5eda6fc8b8.tar.gz
gnunet-2b0e3f9ba871095d003fc078eee75b5eda6fc8b8.zip
again, do not pass salt around, code cleanup, etc.
Diffstat (limited to 'src/set/set_api.c')
-rw-r--r--src/set/set_api.c14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/set/set_api.c b/src/set/set_api.c
index 1ef0cc50c..ff0c959e4 100644
--- a/src/set/set_api.c
+++ b/src/set/set_api.c
@@ -325,14 +325,14 @@ handle_request (void *cls,
325 const struct GNUNET_SET_RequestMessage *msg = (const struct GNUNET_SET_RequestMessage *) mh; 325 const struct GNUNET_SET_RequestMessage *msg = (const struct GNUNET_SET_RequestMessage *) mh;
326 struct GNUNET_SET_ListenHandle *lh = cls; 326 struct GNUNET_SET_ListenHandle *lh = cls;
327 struct GNUNET_SET_Request *req; 327 struct GNUNET_SET_Request *req;
328 struct GNUNET_MessageHeader *context_msg; 328 const struct GNUNET_MessageHeader *context_msg;
329 329
330 LOG (GNUNET_ERROR_TYPE_DEBUG, 330 LOG (GNUNET_ERROR_TYPE_DEBUG,
331 "processing operation request\n"); 331 "processing operation request\n");
332 req = GNUNET_new (struct GNUNET_SET_Request); 332 req = GNUNET_new (struct GNUNET_SET_Request);
333 req->accept_id = ntohl (msg->accept_id); 333 req->accept_id = ntohl (msg->accept_id);
334 context_msg = GNUNET_MQ_extract_nested_mh (msg); 334 context_msg = GNUNET_MQ_extract_nested_mh (msg);
335 /* calling GNUNET_SET_accept in the listen cb will set req->accepted */ 335 /* calling #GNUNET_SET_accept() in the listen cb will set req->accepted */
336 lh->listen_cb (lh->listen_cls, &msg->peer_id, context_msg, req); 336 lh->listen_cb (lh->listen_cls, &msg->peer_id, context_msg, req);
337 337
338 /* we got another request => reset the backoff */ 338 /* we got another request => reset the backoff */
@@ -345,8 +345,6 @@ handle_request (void *cls,
345 345
346 mqm = GNUNET_MQ_msg (rmsg, 346 mqm = GNUNET_MQ_msg (rmsg,
347 GNUNET_MESSAGE_TYPE_SET_REJECT); 347 GNUNET_MESSAGE_TYPE_SET_REJECT);
348 /* no request id, as we refused */
349 rmsg->request_id = htonl (0);
350 rmsg->accept_reject_id = msg->accept_id; 348 rmsg->accept_reject_id = msg->accept_id;
351 GNUNET_MQ_send (lh->mq, mqm); 349 GNUNET_MQ_send (lh->mq, mqm);
352 LOG (GNUNET_ERROR_TYPE_DEBUG, 350 LOG (GNUNET_ERROR_TYPE_DEBUG,
@@ -363,7 +361,8 @@ handle_request (void *cls,
363 361
364 362
365static void 363static void
366handle_client_listener_error (void *cls, enum GNUNET_MQ_Error error) 364handle_client_listener_error (void *cls,
365 enum GNUNET_MQ_Error error)
367{ 366{
368 struct GNUNET_SET_ListenHandle *lh = cls; 367 struct GNUNET_SET_ListenHandle *lh = cls;
369 368
@@ -639,7 +638,6 @@ GNUNET_SET_prepare (const struct GNUNET_PeerIdentity *other_peer,
639 oh = GNUNET_new (struct GNUNET_SET_OperationHandle); 638 oh = GNUNET_new (struct GNUNET_SET_OperationHandle);
640 oh->result_cb = result_cb; 639 oh->result_cb = result_cb;
641 oh->result_cls = result_cls; 640 oh->result_cls = result_cls;
642
643 mqm = GNUNET_MQ_msg_nested_mh (msg, 641 mqm = GNUNET_MQ_msg_nested_mh (msg,
644 GNUNET_MESSAGE_TYPE_SET_EVALUATE, 642 GNUNET_MESSAGE_TYPE_SET_EVALUATE,
645 context_msg); 643 context_msg);
@@ -825,7 +823,9 @@ GNUNET_SET_commit (struct GNUNET_SET_OperationHandle *oh,
825 return GNUNET_SYSERR; 823 return GNUNET_SYSERR;
826 GNUNET_assert (NULL != oh->conclude_mqm); 824 GNUNET_assert (NULL != oh->conclude_mqm);
827 oh->set = set; 825 oh->set = set;
828 GNUNET_CONTAINER_DLL_insert (set->ops_head, set->ops_tail, oh); 826 GNUNET_CONTAINER_DLL_insert (set->ops_head,
827 set->ops_tail,
828 oh);
829 oh->request_id = GNUNET_MQ_assoc_add (set->mq, oh); 829 oh->request_id = GNUNET_MQ_assoc_add (set->mq, oh);
830 *oh->request_id_addr = htonl (oh->request_id); 830 *oh->request_id_addr = htonl (oh->request_id);
831 GNUNET_MQ_send (set->mq, oh->conclude_mqm); 831 GNUNET_MQ_send (set->mq, oh->conclude_mqm);