diff options
Diffstat (limited to 'src/core/gnunet-service-core.c')
-rw-r--r-- | src/core/gnunet-service-core.c | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/src/core/gnunet-service-core.c b/src/core/gnunet-service-core.c index 7385991a2..1b8bb630c 100644 --- a/src/core/gnunet-service-core.c +++ b/src/core/gnunet-service-core.c | |||
@@ -71,7 +71,7 @@ | |||
71 | 71 | ||
72 | /** | 72 | /** |
73 | * After how much time past the "official" expiration time do | 73 | * After how much time past the "official" expiration time do |
74 | * we discard messages? Should not be zero since we may | 74 | * we discard messages? Should not be zero since we may |
75 | * intentionally defer transmission until close to the deadline | 75 | * intentionally defer transmission until close to the deadline |
76 | * and then may be slightly past the deadline due to inaccuracy | 76 | * and then may be slightly past the deadline due to inaccuracy |
77 | * in sleep and our own CPU consumption. | 77 | * in sleep and our own CPU consumption. |
@@ -410,7 +410,7 @@ struct MessageEntry | |||
410 | 410 | ||
411 | 411 | ||
412 | /** | 412 | /** |
413 | * Record kept for each request for transmission issued by a | 413 | * Record kept for each request for transmission issued by a |
414 | * client that is still pending. | 414 | * client that is still pending. |
415 | */ | 415 | */ |
416 | struct ClientActiveRequest; | 416 | struct ClientActiveRequest; |
@@ -439,13 +439,13 @@ struct Neighbour | |||
439 | struct MessageEntry *encrypted_tail; | 439 | struct MessageEntry *encrypted_tail; |
440 | 440 | ||
441 | /** | 441 | /** |
442 | * Head of list of requests from clients for transmission to | 442 | * Head of list of requests from clients for transmission to |
443 | * this peer. | 443 | * this peer. |
444 | */ | 444 | */ |
445 | struct ClientActiveRequest *active_client_request_head; | 445 | struct ClientActiveRequest *active_client_request_head; |
446 | 446 | ||
447 | /** | 447 | /** |
448 | * Tail of list of requests from clients for transmission to | 448 | * Tail of list of requests from clients for transmission to |
449 | * this peer. | 449 | * this peer. |
450 | */ | 450 | */ |
451 | struct ClientActiveRequest *active_client_request_tail; | 451 | struct ClientActiveRequest *active_client_request_tail; |
@@ -684,7 +684,7 @@ struct Client | |||
684 | 684 | ||
685 | 685 | ||
686 | /** | 686 | /** |
687 | * Record kept for each request for transmission issued by a | 687 | * Record kept for each request for transmission issued by a |
688 | * client that is still pending. | 688 | * client that is still pending. |
689 | */ | 689 | */ |
690 | struct ClientActiveRequest | 690 | struct ClientActiveRequest |
@@ -962,10 +962,10 @@ send_to_client (struct Client *client, const struct GNUNET_MessageHeader *msg, | |||
962 | /** | 962 | /** |
963 | * Send a message to all of our current clients that have | 963 | * Send a message to all of our current clients that have |
964 | * the right options set. | 964 | * the right options set. |
965 | * | 965 | * |
966 | * @param msg message to multicast | 966 | * @param msg message to multicast |
967 | * @param can_drop can this message be discarded if the queue is too long | 967 | * @param can_drop can this message be discarded if the queue is too long |
968 | * @param options mask to use | 968 | * @param options mask to use |
969 | */ | 969 | */ |
970 | static void | 970 | static void |
971 | send_to_all_clients (const struct GNUNET_MessageHeader *msg, int can_drop, | 971 | send_to_all_clients (const struct GNUNET_MessageHeader *msg, int can_drop, |
@@ -1225,7 +1225,7 @@ handle_client_send_request (void *cls, struct GNUNET_SERVER_Client *client, | |||
1225 | (n->status != PEER_STATE_KEY_CONFIRMED)) | 1225 | (n->status != PEER_STATE_KEY_CONFIRMED)) |
1226 | { | 1226 | { |
1227 | /* neighbour must have disconnected since request was issued, | 1227 | /* neighbour must have disconnected since request was issued, |
1228 | * ignore (client will realize it once it processes the | 1228 | * ignore (client will realize it once it processes the |
1229 | * disconnect notification) */ | 1229 | * disconnect notification) */ |
1230 | #if DEBUG_CORE_CLIENT | 1230 | #if DEBUG_CORE_CLIENT |
1231 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1231 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
@@ -1705,7 +1705,7 @@ handle_client_request_info (void *cls, struct GNUNET_SERVER_Client *client, | |||
1705 | else | 1705 | else |
1706 | { | 1706 | { |
1707 | /* Technically, this COULD happen (due to asynchronous behavior), | 1707 | /* Technically, this COULD happen (due to asynchronous behavior), |
1708 | * but it should be rare, so we should generate an info event | 1708 | * but it should be rare, so we should generate an info event |
1709 | * to help diagnosis of serious errors that might be masked by this */ | 1709 | * to help diagnosis of serious errors that might be masked by this */ |
1710 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | 1710 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, |
1711 | _ | 1711 | _ |
@@ -1860,7 +1860,7 @@ consider_free_neighbour (struct Neighbour *n); | |||
1860 | 1860 | ||
1861 | 1861 | ||
1862 | /** | 1862 | /** |
1863 | * Task triggered when a neighbour entry is about to time out | 1863 | * Task triggered when a neighbour entry is about to time out |
1864 | * (and we should prevent this by sending a PING). | 1864 | * (and we should prevent this by sending a PING). |
1865 | * | 1865 | * |
1866 | * @param cls the 'struct Neighbour' | 1866 | * @param cls the 'struct Neighbour' |
@@ -2733,7 +2733,7 @@ process_plaintext_neighbour_queue (struct Neighbour *n) | |||
2733 | /** | 2733 | /** |
2734 | * Function that recalculates the bandwidth quota for the | 2734 | * Function that recalculates the bandwidth quota for the |
2735 | * given neighbour and transmits it to the transport service. | 2735 | * given neighbour and transmits it to the transport service. |
2736 | * | 2736 | * |
2737 | * @param cls neighbour for the quota update | 2737 | * @param cls neighbour for the quota update |
2738 | * @param tc context | 2738 | * @param tc context |
2739 | */ | 2739 | */ |
@@ -2850,7 +2850,7 @@ handle_client_send (void *cls, struct GNUNET_SERVER_Client *client, | |||
2850 | if ((n == NULL) || (GNUNET_YES != n->is_connected) || | 2850 | if ((n == NULL) || (GNUNET_YES != n->is_connected) || |
2851 | (n->status != PEER_STATE_KEY_CONFIRMED)) | 2851 | (n->status != PEER_STATE_KEY_CONFIRMED)) |
2852 | { | 2852 | { |
2853 | /* attempt to send message to peer that is not connected anymore | 2853 | /* attempt to send message to peer that is not connected anymore |
2854 | * (can happen due to asynchrony) */ | 2854 | * (can happen due to asynchrony) */ |
2855 | GNUNET_STATISTICS_update (stats, | 2855 | GNUNET_STATISTICS_update (stats, |
2856 | gettext_noop | 2856 | gettext_noop |
@@ -4256,7 +4256,7 @@ handle_transport_receive (void *cls, const struct GNUNET_PeerIdentity *peer, | |||
4256 | /** | 4256 | /** |
4257 | * Function that recalculates the bandwidth quota for the | 4257 | * Function that recalculates the bandwidth quota for the |
4258 | * given neighbour and transmits it to the transport service. | 4258 | * given neighbour and transmits it to the transport service. |
4259 | * | 4259 | * |
4260 | * @param cls neighbour for the quota update | 4260 | * @param cls neighbour for the quota update |
4261 | * @param tc context | 4261 | * @param tc context |
4262 | */ | 4262 | */ |
@@ -4283,7 +4283,7 @@ neighbour_quota_update (void *cls, | |||
4283 | n->quota_update_task = GNUNET_SCHEDULER_NO_TASK; | 4283 | n->quota_update_task = GNUNET_SCHEDULER_NO_TASK; |
4284 | /* calculate relative preference among all neighbours; | 4284 | /* calculate relative preference among all neighbours; |
4285 | * divides by a bit more to avoid division by zero AND to | 4285 | * divides by a bit more to avoid division by zero AND to |
4286 | * account for possibility of new neighbours joining any time | 4286 | * account for possibility of new neighbours joining any time |
4287 | * AND to convert to double... */ | 4287 | * AND to convert to double... */ |
4288 | neighbour_count = GNUNET_CONTAINER_multihashmap_size (neighbours); | 4288 | neighbour_count = GNUNET_CONTAINER_multihashmap_size (neighbours); |
4289 | if (neighbour_count == 0) | 4289 | if (neighbour_count == 0) |