diff options
Diffstat (limited to 'src/mesh/mesh_api_enc.c')
-rw-r--r-- | src/mesh/mesh_api_enc.c | 26 |
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 | */ |
580 | static void | 580 | static 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 | */ |
1416 | struct GNUNET_MESH_Channel * | 1416 | struct GNUNET_MESH_Channel * |
1417 | GNUNET_MESH_channel_create (struct GNUNET_MESH_Handle *h, | 1417 | GNUNET_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 | |||
1695 | mesh_mq_ntr (void *cls, size_t size, | 1695 | mesh_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 | */ |