aboutsummaryrefslogtreecommitdiff
path: root/src/set/set_api.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2017-02-19 18:48:02 +0100
committerChristian Grothoff <christian@grothoff.org>2017-02-19 18:48:02 +0100
commit8802f213c67692abebebdf9fe2d4a77afe2b1fcb (patch)
tree6ca39dbf3d851a88f2ed7f21faba3616c13b3796 /src/set/set_api.c
parent360d7afad50d1af425a20e89419d2063a6a0e220 (diff)
downloadgnunet-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.c20
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 300static void
301 handle_iter_element (void *cls, 301handle_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;