aboutsummaryrefslogtreecommitdiff
path: root/src/mesh/mesh_api_enc.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/mesh/mesh_api_enc.c')
-rw-r--r--src/mesh/mesh_api_enc.c26
1 files changed, 13 insertions, 13 deletions
diff --git a/src/mesh/mesh_api_enc.c b/src/mesh/mesh_api_enc.c
index 75adb6544..93099abdb 100644
--- a/src/mesh/mesh_api_enc.c
+++ b/src/mesh/mesh_api_enc.c
@@ -178,7 +178,7 @@ struct GNUNET_MESH_Handle
178 * Time to the next reconnect in case one reconnect fails 178 * Time to the next reconnect in case one reconnect fails
179 */ 179 */
180 struct GNUNET_TIME_Relative reconnect_time; 180 struct GNUNET_TIME_Relative reconnect_time;
181 181
182 /** 182 /**
183 * Task for trying to reconnect. 183 * Task for trying to reconnect.
184 */ 184 */
@@ -356,9 +356,9 @@ th_is_payload (struct GNUNET_MESH_TransmitHandle *th)
356 356
357/** 357/**
358 * Check whether there is any message ready in the queue and find the size. 358 * Check whether there is any message ready in the queue and find the size.
359 * 359 *
360 * @param h Mesh handle. 360 * @param h Mesh handle.
361 * 361 *
362 * @return The size of the first ready message in the queue, 362 * @return The size of the first ready message in the queue,
363 * 0 if there is none. 363 * 0 if there is none.
364 */ 364 */
@@ -492,7 +492,7 @@ destroy_channel (struct GNUNET_MESH_Channel *ch, int call_cleaner)
492 /* clean up request */ 492 /* clean up request */
493 if (GNUNET_SCHEDULER_NO_TASK != th->timeout_task) 493 if (GNUNET_SCHEDULER_NO_TASK != th->timeout_task)
494 GNUNET_SCHEDULER_cancel (th->timeout_task); 494 GNUNET_SCHEDULER_cancel (th->timeout_task);
495 GNUNET_free (th); 495 GNUNET_free (th);
496 } 496 }
497 497
498 /* if there are no more pending requests with mesh service, cancel active request */ 498 /* if there are no more pending requests with mesh service, cancel active request */
@@ -512,7 +512,7 @@ destroy_channel (struct GNUNET_MESH_Channel *ch, int call_cleaner)
512 512
513/** 513/**
514 * Notify client that the transmission has timed out 514 * Notify client that the transmission has timed out
515 * 515 *
516 * @param cls closure 516 * @param cls closure
517 * @param tc task context 517 * @param tc task context
518 */ 518 */
@@ -574,7 +574,7 @@ send_packet (struct GNUNET_MESH_Handle *h,
574 574
575/** 575/**
576 * Send an ack on the channel to confirm the processing of a message. 576 * Send an ack on the channel to confirm the processing of a message.
577 * 577 *
578 * @param ch Channel on which to send the ACK. 578 * @param ch Channel on which to send the ACK.
579 */ 579 */
580static void 580static void
@@ -926,7 +926,7 @@ process_incoming_data (struct GNUNET_MESH_Handle *h,
926/** 926/**
927 * Process a local ACK message, enabling the client to send 927 * Process a local ACK message, enabling the client to send
928 * more data to the service. 928 * more data to the service.
929 * 929 *
930 * @param h Mesh handle. 930 * @param h Mesh handle.
931 * @param message Message itself. 931 * @param message Message itself.
932 */ 932 */
@@ -1059,7 +1059,7 @@ msg_received (void *cls, const struct GNUNET_MessageHeader *msg)
1059 1059
1060 if (msg == NULL) 1060 if (msg == NULL)
1061 { 1061 {
1062 LOG (GNUNET_ERROR_TYPE_DEBUG, 1062 LOG (GNUNET_ERROR_TYPE_DEBUG,
1063 "Mesh service disconnected, reconnecting\n", h); 1063 "Mesh service disconnected, reconnecting\n", h);
1064 reconnect (h); 1064 reconnect (h);
1065 return; 1065 return;
@@ -1242,7 +1242,7 @@ send_callback (void *cls, size_t size, void *buf)
1242 * Auxiliary function to send an already constructed packet to the service. 1242 * Auxiliary function to send an already constructed packet to the service.
1243 * Takes care of creating a new queue element, copying the message and 1243 * Takes care of creating a new queue element, copying the message and
1244 * calling the tmt_rdy function if necessary. 1244 * calling the tmt_rdy function if necessary.
1245 * 1245 *
1246 * @param h mesh handle 1246 * @param h mesh handle
1247 * @param msg message to transmit 1247 * @param msg message to transmit
1248 * @param channel channel this send is related to (NULL if N/A) 1248 * @param channel channel this send is related to (NULL if N/A)
@@ -1414,7 +1414,7 @@ GNUNET_MESH_disconnect (struct GNUNET_MESH_Handle *handle)
1414 * @return handle to the channel 1414 * @return handle to the channel
1415 */ 1415 */
1416struct GNUNET_MESH_Channel * 1416struct GNUNET_MESH_Channel *
1417GNUNET_MESH_channel_create (struct GNUNET_MESH_Handle *h, 1417GNUNET_MESH_channel_create (struct GNUNET_MESH_Handle *h,
1418 void *channel_ctx, 1418 void *channel_ctx,
1419 const struct GNUNET_PeerIdentity *peer, 1419 const struct GNUNET_PeerIdentity *peer,
1420 uint32_t port, 1420 uint32_t port,
@@ -1695,7 +1695,7 @@ static size_t
1695mesh_mq_ntr (void *cls, size_t size, 1695mesh_mq_ntr (void *cls, size_t size,
1696 void *buf) 1696 void *buf)
1697{ 1697{
1698 struct GNUNET_MQ_Handle *mq = cls; 1698 struct GNUNET_MQ_Handle *mq = cls;
1699 struct MeshMQState *state = GNUNET_MQ_impl_state (mq); 1699 struct MeshMQState *state = GNUNET_MQ_impl_state (mq);
1700 const struct GNUNET_MessageHeader *msg = GNUNET_MQ_impl_current (mq); 1700 const struct GNUNET_MessageHeader *msg = GNUNET_MQ_impl_current (mq);
1701 uint16_t msize; 1701 uint16_t msize;
@@ -1734,7 +1734,7 @@ mesh_mq_send_impl (struct GNUNET_MQ_Handle *mq,
1734 GNUNET_MESH_notify_transmit_ready (state->channel, 1734 GNUNET_MESH_notify_transmit_ready (state->channel,
1735 /* FIXME: add option for corking */ 1735 /* FIXME: add option for corking */
1736 GNUNET_NO, 1736 GNUNET_NO,
1737 GNUNET_TIME_UNIT_FOREVER_REL, 1737 GNUNET_TIME_UNIT_FOREVER_REL,
1738 ntohs (msg->size), 1738 ntohs (msg->size),
1739 mesh_mq_ntr, mq); 1739 mesh_mq_ntr, mq);
1740 1740
@@ -1746,7 +1746,7 @@ mesh_mq_send_impl (struct GNUNET_MQ_Handle *mq,
1746 * destruction of a message queue. 1746 * destruction of a message queue.
1747 * Implementations must not free 'mq', but should 1747 * Implementations must not free 'mq', but should
1748 * take care of 'impl_state'. 1748 * take care of 'impl_state'.
1749 * 1749 *
1750 * @param mq the message queue to destroy 1750 * @param mq the message queue to destroy
1751 * @param impl_state state of the implementation 1751 * @param impl_state state of the implementation
1752 */ 1752 */