diff options
author | Christian Grothoff <christian@grothoff.org> | 2017-02-19 18:48:02 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2017-02-19 18:48:02 +0100 |
commit | 8802f213c67692abebebdf9fe2d4a77afe2b1fcb (patch) | |
tree | 6ca39dbf3d851a88f2ed7f21faba3616c13b3796 /src/set/set_api.c | |
parent | 360d7afad50d1af425a20e89419d2063a6a0e220 (diff) | |
download | gnunet-8802f213c67692abebebdf9fe2d4a77afe2b1fcb.tar.gz gnunet-8802f213c67692abebebdf9fe2d4a77afe2b1fcb.zip |
misc logging, no semantic changes
Diffstat (limited to 'src/set/set_api.c')
-rw-r--r-- | src/set/set_api.c | 20 |
1 files changed, 15 insertions, 5 deletions
diff --git a/src/set/set_api.c b/src/set/set_api.c index 769be82d2..baeee6da0 100644 --- a/src/set/set_api.c +++ b/src/set/set_api.c | |||
@@ -297,9 +297,9 @@ check_iter_element (void *cls, | |||
297 | * @param cls the `struct GNUNET_SET_Handle *` | 297 | * @param cls the `struct GNUNET_SET_Handle *` |
298 | * @param mh the message | 298 | * @param mh the message |
299 | */ | 299 | */ |
300 | static void | 300 | static void |
301 | handle_iter_element (void *cls, | 301 | handle_iter_element (void *cls, |
302 | const struct GNUNET_SET_IterResponseMessage *msg) | 302 | const struct GNUNET_SET_IterResponseMessage *msg) |
303 | { | 303 | { |
304 | struct GNUNET_SET_Handle *set = cls; | 304 | struct GNUNET_SET_Handle *set = cls; |
305 | GNUNET_SET_ElementIterator iter = set->iterator; | 305 | GNUNET_SET_ElementIterator iter = set->iterator; |
@@ -773,6 +773,9 @@ GNUNET_SET_prepare (const struct GNUNET_PeerIdentity *other_peer, | |||
773 | struct GNUNET_SET_OperationHandle *oh; | 773 | struct GNUNET_SET_OperationHandle *oh; |
774 | struct GNUNET_SET_EvaluateMessage *msg; | 774 | struct GNUNET_SET_EvaluateMessage *msg; |
775 | 775 | ||
776 | LOG (GNUNET_ERROR_TYPE_DEBUG, | ||
777 | "Client prepares set operation (%d)\n", | ||
778 | result_mode); | ||
776 | oh = GNUNET_new (struct GNUNET_SET_OperationHandle); | 779 | oh = GNUNET_new (struct GNUNET_SET_OperationHandle); |
777 | oh->result_cb = result_cb; | 780 | oh->result_cb = result_cb; |
778 | oh->result_cls = result_cls; | 781 | oh->result_cls = result_cls; |
@@ -1011,6 +1014,9 @@ GNUNET_SET_accept (struct GNUNET_SET_Request *request, | |||
1011 | struct GNUNET_SET_AcceptMessage *msg; | 1014 | struct GNUNET_SET_AcceptMessage *msg; |
1012 | 1015 | ||
1013 | GNUNET_assert (GNUNET_NO == request->accepted); | 1016 | GNUNET_assert (GNUNET_NO == request->accepted); |
1017 | LOG (GNUNET_ERROR_TYPE_DEBUG, | ||
1018 | "Client accepts set operation (%d)\n", | ||
1019 | result_mode); | ||
1014 | request->accepted = GNUNET_YES; | 1020 | request->accepted = GNUNET_YES; |
1015 | mqm = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_SET_ACCEPT); | 1021 | mqm = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_SET_ACCEPT); |
1016 | msg->accept_reject_id = htonl (request->accept_id); | 1022 | msg->accept_reject_id = htonl (request->accept_id); |
@@ -1050,14 +1056,18 @@ GNUNET_SET_commit (struct GNUNET_SET_OperationHandle *oh, | |||
1050 | } | 1056 | } |
1051 | if (GNUNET_YES == set->invalid) | 1057 | if (GNUNET_YES == set->invalid) |
1052 | return GNUNET_SYSERR; | 1058 | return GNUNET_SYSERR; |
1059 | LOG (GNUNET_ERROR_TYPE_DEBUG, | ||
1060 | "Client commits to SET\n"); | ||
1053 | GNUNET_assert (NULL != oh->conclude_mqm); | 1061 | GNUNET_assert (NULL != oh->conclude_mqm); |
1054 | oh->set = set; | 1062 | oh->set = set; |
1055 | GNUNET_CONTAINER_DLL_insert (set->ops_head, | 1063 | GNUNET_CONTAINER_DLL_insert (set->ops_head, |
1056 | set->ops_tail, | 1064 | set->ops_tail, |
1057 | oh); | 1065 | oh); |
1058 | oh->request_id = GNUNET_MQ_assoc_add (set->mq, oh); | 1066 | oh->request_id = GNUNET_MQ_assoc_add (set->mq, |
1067 | oh); | ||
1059 | *oh->request_id_addr = htonl (oh->request_id); | 1068 | *oh->request_id_addr = htonl (oh->request_id); |
1060 | GNUNET_MQ_send (set->mq, oh->conclude_mqm); | 1069 | GNUNET_MQ_send (set->mq, |
1070 | oh->conclude_mqm); | ||
1061 | oh->conclude_mqm = NULL; | 1071 | oh->conclude_mqm = NULL; |
1062 | oh->request_id_addr = NULL; | 1072 | oh->request_id_addr = NULL; |
1063 | return GNUNET_OK; | 1073 | return GNUNET_OK; |