diff options
Diffstat (limited to 'src/set/gnunet-service-set.c')
-rw-r--r-- | src/set/gnunet-service-set.c | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/set/gnunet-service-set.c b/src/set/gnunet-service-set.c index a339bb993..99deb3b23 100644 --- a/src/set/gnunet-service-set.c +++ b/src/set/gnunet-service-set.c | |||
@@ -530,7 +530,7 @@ handle_client_iterate (void *cls, | |||
530 | const struct GNUNET_MessageHeader *m) | 530 | const struct GNUNET_MessageHeader *m) |
531 | { | 531 | { |
532 | struct Set *set; | 532 | struct Set *set; |
533 | 533 | ||
534 | set = set_get (client); | 534 | set = set_get (client); |
535 | if (NULL == set) | 535 | if (NULL == set) |
536 | { | 536 | { |
@@ -717,7 +717,7 @@ handle_client_add_remove (void *cls, | |||
717 | GNUNET_SERVER_receive_done (client, GNUNET_OK); | 717 | GNUNET_SERVER_receive_done (client, GNUNET_OK); |
718 | msg = (const struct GNUNET_SET_ElementMessage *) m; | 718 | msg = (const struct GNUNET_SET_ElementMessage *) m; |
719 | el.size = ntohs (m->size) - sizeof *msg; | 719 | el.size = ntohs (m->size) - sizeof *msg; |
720 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 720 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
721 | "client ins/rem element of size %u\n", el.size); | 721 | "client ins/rem element of size %u\n", el.size); |
722 | el.data = &msg[1]; | 722 | el.data = &msg[1]; |
723 | if (GNUNET_MESSAGE_TYPE_SET_REMOVE == ntohs (m->type)) | 723 | if (GNUNET_MESSAGE_TYPE_SET_REMOVE == ntohs (m->type)) |
@@ -829,7 +829,7 @@ handle_client_iter_ack (void *cls, | |||
829 | const struct GNUNET_MessageHeader *m) | 829 | const struct GNUNET_MessageHeader *m) |
830 | { | 830 | { |
831 | struct Set *set; | 831 | struct Set *set; |
832 | 832 | ||
833 | set = set_get (client); | 833 | set = set_get (client); |
834 | if (NULL == set) | 834 | if (NULL == set) |
835 | { | 835 | { |
@@ -1023,7 +1023,7 @@ tunnel_new_cb (void *cls, | |||
1023 | incoming->tc = GNUNET_new (struct TunnelContext);; | 1023 | incoming->tc = GNUNET_new (struct TunnelContext);; |
1024 | incoming->tc->vt = &incoming_vt; | 1024 | incoming->tc->vt = &incoming_vt; |
1025 | incoming->tc->op = (struct OperationState *) incoming; | 1025 | incoming->tc->op = (struct OperationState *) incoming; |
1026 | incoming->timeout_task = | 1026 | incoming->timeout_task = |
1027 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES, incoming_timeout_cb, incoming); | 1027 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_MINUTES, incoming_timeout_cb, incoming); |
1028 | GNUNET_CONTAINER_DLL_insert_tail (incoming_head, incoming_tail, incoming); | 1028 | GNUNET_CONTAINER_DLL_insert_tail (incoming_head, incoming_tail, incoming); |
1029 | 1029 | ||
@@ -1057,7 +1057,7 @@ tunnel_end_cb (void *cls, | |||
1057 | /** | 1057 | /** |
1058 | * Functions with this signature are called whenever a message is | 1058 | * Functions with this signature are called whenever a message is |
1059 | * received. | 1059 | * received. |
1060 | * | 1060 | * |
1061 | * Each time the function must call GNUNET_MESH_receive_done on the tunnel | 1061 | * Each time the function must call GNUNET_MESH_receive_done on the tunnel |
1062 | * in order to receive the next message. This doesn't need to be immediate: | 1062 | * in order to receive the next message. This doesn't need to be immediate: |
1063 | * can be delayed if some processing is done on the message. | 1063 | * can be delayed if some processing is done on the message. |
@@ -1066,7 +1066,7 @@ tunnel_end_cb (void *cls, | |||
1066 | * @param tunnel Connection to the other end. | 1066 | * @param tunnel Connection to the other end. |
1067 | * @param tunnel_ctx Place to store local state associated with the tunnel. | 1067 | * @param tunnel_ctx Place to store local state associated with the tunnel. |
1068 | * @param message The actual message. | 1068 | * @param message The actual message. |
1069 | * | 1069 | * |
1070 | * @return GNUNET_OK to keep the tunnel open, | 1070 | * @return GNUNET_OK to keep the tunnel open, |
1071 | * GNUNET_SYSERR to close it (signal serious error). | 1071 | * GNUNET_SYSERR to close it (signal serious error). |
1072 | */ | 1072 | */ |