diff options
author | Christian Grothoff <christian@grothoff.org> | 2014-11-27 11:35:42 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2014-11-27 11:35:42 +0000 |
commit | 2b0e3f9ba871095d003fc078eee75b5eda6fc8b8 (patch) | |
tree | b37e6f7d930ca23b0743bda4a76f82aa7c794e13 /src/set/set_api.c | |
parent | 393b5b11525badff59ff6df0572c5cdf42c1587c (diff) | |
download | gnunet-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.c | 14 |
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 | ||
365 | static void | 363 | static void |
366 | handle_client_listener_error (void *cls, enum GNUNET_MQ_Error error) | 364 | handle_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); |