diff options
Diffstat (limited to 'src/transport')
29 files changed, 87 insertions, 85 deletions
diff --git a/src/transport/gnunet-communicator-tcp.c b/src/transport/gnunet-communicator-tcp.c index 9dd2797df..a871d980f 100644 --- a/src/transport/gnunet-communicator-tcp.c +++ b/src/transport/gnunet-communicator-tcp.c | |||
@@ -1954,7 +1954,7 @@ queue_read (void *cls) | |||
1954 | wrong key for everything after the rekey; in that case, we have | 1954 | wrong key for everything after the rekey; in that case, we have |
1955 | to re-do the decryption at 'total' instead of at 'max'. | 1955 | to re-do the decryption at 'total' instead of at 'max'. |
1956 | However, we have to take into account that the plaintext buffer may have | 1956 | However, we have to take into account that the plaintext buffer may have |
1957 | already contained data and not jumpt too far ahead in the ciphertext. | 1957 | already contained data and not jumped too far ahead in the ciphertext. |
1958 | If there is no rekey and the last message is incomplete (max > total), | 1958 | If there is no rekey and the last message is incomplete (max > total), |
1959 | it is safe to keep the decryption so we shift by 'max' */ | 1959 | it is safe to keep the decryption so we shift by 'max' */ |
1960 | if (GNUNET_YES == queue->rekeyed) | 1960 | if (GNUNET_YES == queue->rekeyed) |
diff --git a/src/transport/gnunet-communicator-udp.c b/src/transport/gnunet-communicator-udp.c index d75f4ae00..fa9bb5d0a 100644 --- a/src/transport/gnunet-communicator-udp.c +++ b/src/transport/gnunet-communicator-udp.c | |||
@@ -626,7 +626,7 @@ struct ReceiverAddress | |||
626 | int rekeying; | 626 | int rekeying; |
627 | 627 | ||
628 | /** | 628 | /** |
629 | * Numer of kce we retain for sending the rekeying shared secret. | 629 | * Number of kce we retain for sending the rekeying shared secret. |
630 | */ | 630 | */ |
631 | int number_rekeying_kce; | 631 | int number_rekeying_kce; |
632 | 632 | ||
@@ -1130,7 +1130,7 @@ sender_destroy (struct SenderAddress *sender) | |||
1130 | * | 1130 | * |
1131 | * @param msec master secret for calculation | 1131 | * @param msec master secret for calculation |
1132 | * @param serial number for the @a smac calculation | 1132 | * @param serial number for the @a smac calculation |
1133 | * @param key[out] where to write the decrption key | 1133 | * @param key[out] where to write the decryption key |
1134 | * @param iv[out] where to write the IV | 1134 | * @param iv[out] where to write the IV |
1135 | */ | 1135 | */ |
1136 | static void | 1136 | static void |
@@ -1235,7 +1235,7 @@ check_timeouts (void *cls) | |||
1235 | 1235 | ||
1236 | 1236 | ||
1237 | /** | 1237 | /** |
1238 | * Calcualte cmac from master in @a ss. | 1238 | * Calculate cmac from master in @a ss. |
1239 | * | 1239 | * |
1240 | * @param ss[in,out] data structure to complete | 1240 | * @param ss[in,out] data structure to complete |
1241 | */ | 1241 | */ |
@@ -1811,7 +1811,7 @@ kce_generate_rekey_cb (void *cls) | |||
1811 | * recently). | 1811 | * recently). |
1812 | * | 1812 | * |
1813 | * @param ss shared secret to generate ACKs for | 1813 | * @param ss shared secret to generate ACKs for |
1814 | * @param intial The SharedSecret came with initial KX. | 1814 | * @param initial The SharedSecret came with initial KX. |
1815 | */ | 1815 | */ |
1816 | static void | 1816 | static void |
1817 | consider_ss_ack (struct SharedSecret *ss, int initial) | 1817 | consider_ss_ack (struct SharedSecret *ss, int initial) |
@@ -1866,7 +1866,7 @@ consider_ss_ack (struct SharedSecret *ss, int initial) | |||
1866 | ack.acks_available = ss->sender->acks_available; | 1866 | ack.acks_available = ss->sender->acks_available; |
1867 | ack.cmac = ss_tell->cmac; | 1867 | ack.cmac = ss_tell->cmac; |
1868 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1868 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
1869 | "Notifying transport of UDPAck %s with intial %u and master %s\n", | 1869 | "Notifying transport of UDPAck %s with initial %u and master %s\n", |
1870 | GNUNET_i2s_full (&ss_tell->sender->target), | 1870 | GNUNET_i2s_full (&ss_tell->sender->target), |
1871 | initial, | 1871 | initial, |
1872 | GNUNET_h2s (&(ss_tell->master))); | 1872 | GNUNET_h2s (&(ss_tell->master))); |
@@ -2486,7 +2486,7 @@ udp_address_to_sockaddr (const char *bindto, socklen_t *sock_len) | |||
2486 | colon = strrchr (cp, ':'); | 2486 | colon = strrchr (cp, ':'); |
2487 | if (NULL != colon) | 2487 | if (NULL != colon) |
2488 | { | 2488 | { |
2489 | /* interpet value after colon as port */ | 2489 | /* interpret value after colon as port */ |
2490 | *colon = '\0'; | 2490 | *colon = '\0'; |
2491 | colon++; | 2491 | colon++; |
2492 | if (1 == sscanf (colon, "%u%1s", &port, dummy)) | 2492 | if (1 == sscanf (colon, "%u%1s", &port, dummy)) |
diff --git a/src/transport/gnunet-helper-transport-bluetooth.c b/src/transport/gnunet-helper-transport-bluetooth.c index ef3a6292b..019f3914f 100644 --- a/src/transport/gnunet-helper-transport-bluetooth.c +++ b/src/transport/gnunet-helper-transport-bluetooth.c | |||
@@ -416,7 +416,7 @@ do_align: | |||
416 | else | 416 | else |
417 | { | 417 | { |
418 | /* need to copy to private buffer to align; | 418 | /* need to copy to private buffer to align; |
419 | * yes, we go a bit more spagetti than usual here */ | 419 | * yes, we go a bit more spaghetti than usual here */ |
420 | goto do_align; | 420 | goto do_align; |
421 | } | 421 | } |
422 | } | 422 | } |
diff --git a/src/transport/gnunet-helper-transport-wlan.c b/src/transport/gnunet-helper-transport-wlan.c index d90565c9c..72dd8b594 100644 --- a/src/transport/gnunet-helper-transport-wlan.c +++ b/src/transport/gnunet-helper-transport-wlan.c | |||
@@ -983,7 +983,7 @@ do_align: | |||
983 | else | 983 | else |
984 | { | 984 | { |
985 | /* need to copy to private buffer to align; | 985 | /* need to copy to private buffer to align; |
986 | * yes, we go a bit more spagetti than usual here */ | 986 | * yes, we go a bit more spaghetti than usual here */ |
987 | goto do_align; | 987 | goto do_align; |
988 | } | 988 | } |
989 | } | 989 | } |
@@ -1093,7 +1093,7 @@ ieee80211_radiotap_iterator_init (struct | |||
1093 | iterator->arg += sizeof(uint32_t); | 1093 | iterator->arg += sizeof(uint32_t); |
1094 | /* | 1094 | /* |
1095 | * no need to check again for blowing past stated radiotap | 1095 | * no need to check again for blowing past stated radiotap |
1096 | * header length, becuase ieee80211_radiotap_iterator_next | 1096 | * header length, because ieee80211_radiotap_iterator_next |
1097 | * checks it before it is dereferenced | 1097 | * checks it before it is dereferenced |
1098 | */} | 1098 | */} |
1099 | /* we are all initialized happily */ | 1099 | /* we are all initialized happily */ |
diff --git a/src/transport/gnunet-service-tng.c b/src/transport/gnunet-service-tng.c index cbf795eea..613477220 100644 --- a/src/transport/gnunet-service-tng.c +++ b/src/transport/gnunet-service-tng.c | |||
@@ -47,7 +47,7 @@ | |||
47 | * - When we passively learned DV (with unconfirmed freshness), we | 47 | * - When we passively learned DV (with unconfirmed freshness), we |
48 | * right now add the path to our list but with a zero path_valid_until | 48 | * right now add the path to our list but with a zero path_valid_until |
49 | * time and only use it for unconfirmed routes. However, we could consider | 49 | * time and only use it for unconfirmed routes. However, we could consider |
50 | * triggering an explicit validation mechansim ourselves, specifically routing | 50 | * triggering an explicit validation mechanism ourselves, specifically routing |
51 | * a challenge-response message over the path [ROUTING] | 51 | * a challenge-response message over the path [ROUTING] |
52 | * = if available, try to confirm unconfirmed DV paths when trying to establish | 52 | * = if available, try to confirm unconfirmed DV paths when trying to establish |
53 | * virtual link for a `struct IncomingRequest`. (i.e. if DVH is | 53 | * virtual link for a `struct IncomingRequest`. (i.e. if DVH is |
@@ -83,7 +83,7 @@ | |||
83 | 83 | ||
84 | /** | 84 | /** |
85 | * Maximum number of messages we acknowledge together in one | 85 | * Maximum number of messages we acknowledge together in one |
86 | * cummulative ACK. Larger values may save a bit of bandwidth. | 86 | * cumulative ACK. Larger values may save a bit of bandwidth. |
87 | */ | 87 | */ |
88 | #define MAX_CUMMULATIVE_ACKS 64 | 88 | #define MAX_CUMMULATIVE_ACKS 64 |
89 | 89 | ||
@@ -453,7 +453,7 @@ struct TransportReliabilityBoxMessage | |||
453 | struct TransportCummulativeAckPayloadP | 453 | struct TransportCummulativeAckPayloadP |
454 | { | 454 | { |
455 | /** | 455 | /** |
456 | * How long was the ACK delayed for generating cummulative ACKs? | 456 | * How long was the ACK delayed for generating cumulative ACKs? |
457 | * Used to calculate the correct network RTT by taking the receipt | 457 | * Used to calculate the correct network RTT by taking the receipt |
458 | * time of the ack minus the transmission time of the sender minus | 458 | * time of the ack minus the transmission time of the sender minus |
459 | * this value. | 459 | * this value. |
@@ -514,7 +514,7 @@ struct TransportFragmentBoxMessage | |||
514 | 514 | ||
515 | /** | 515 | /** |
516 | * Unique ID of this fragment (and fragment transmission!). Will | 516 | * Unique ID of this fragment (and fragment transmission!). Will |
517 | * change even if a fragement is retransmitted to make each | 517 | * change even if a fragment is retransmitted to make each |
518 | * transmission attempt unique! If a client receives a duplicate | 518 | * transmission attempt unique! If a client receives a duplicate |
519 | * fragment (same @e frag_off for same @a msg_uuid, it must send | 519 | * fragment (same @e frag_off for same @a msg_uuid, it must send |
520 | * #GNUNET_MESSAGE_TYPE_TRANSPORT_RELIABILITY_ACK immediately. | 520 | * #GNUNET_MESSAGE_TYPE_TRANSPORT_RELIABILITY_ACK immediately. |
@@ -1944,7 +1944,7 @@ struct Neighbour | |||
1944 | struct GNUNET_TIME_Absolute last_dv_learn_monotime; | 1944 | struct GNUNET_TIME_Absolute last_dv_learn_monotime; |
1945 | 1945 | ||
1946 | /** | 1946 | /** |
1947 | * Do we have the lastest value for @e last_dv_learn_monotime from | 1947 | * Do we have the latest value for @e last_dv_learn_monotime from |
1948 | * PEERSTORE yet, or are we still waiting for a reply of PEERSTORE? | 1948 | * PEERSTORE yet, or are we still waiting for a reply of PEERSTORE? |
1949 | */ | 1949 | */ |
1950 | int dv_monotime_available; | 1950 | int dv_monotime_available; |
@@ -2238,7 +2238,7 @@ struct AcknowledgementCummulator | |||
2238 | struct TransportCummulativeAckPayload ack_uuids[MAX_CUMMULATIVE_ACKS]; | 2238 | struct TransportCummulativeAckPayload ack_uuids[MAX_CUMMULATIVE_ACKS]; |
2239 | 2239 | ||
2240 | /** | 2240 | /** |
2241 | * Task scheduled either to transmit the cummulative ACK message, | 2241 | * Task scheduled either to transmit the cumulative ACK message, |
2242 | * or to clean up this data structure after extended periods of | 2242 | * or to clean up this data structure after extended periods of |
2243 | * inactivity (if @e num_acks is zero). | 2243 | * inactivity (if @e num_acks is zero). |
2244 | */ | 2244 | */ |
@@ -2657,7 +2657,7 @@ static struct GNUNET_CONTAINER_MultiPeerMap *backtalkers; | |||
2657 | 2657 | ||
2658 | /** | 2658 | /** |
2659 | * Map from PIDs to `struct AcknowledgementCummulator`s. | 2659 | * Map from PIDs to `struct AcknowledgementCummulator`s. |
2660 | * Here we track the cummulative ACKs for transmission. | 2660 | * Here we track the cumulative ACKs for transmission. |
2661 | */ | 2661 | */ |
2662 | static struct GNUNET_CONTAINER_MultiPeerMap *ack_cummulators; | 2662 | static struct GNUNET_CONTAINER_MultiPeerMap *ack_cummulators; |
2663 | 2663 | ||
@@ -2735,7 +2735,7 @@ static struct PendingAcknowledgement *pa_head; | |||
2735 | static struct PendingAcknowledgement *pa_tail; | 2735 | static struct PendingAcknowledgement *pa_tail; |
2736 | 2736 | ||
2737 | /** | 2737 | /** |
2738 | * List of incomming connections where we are trying | 2738 | * List of incoming connections where we are trying |
2739 | * to get a connection back established. Length | 2739 | * to get a connection back established. Length |
2740 | * kept in #ir_total. | 2740 | * kept in #ir_total. |
2741 | */ | 2741 | */ |
@@ -3888,10 +3888,10 @@ client_send_response (struct PendingMessage *pm) | |||
3888 | if (NULL != tc) | 3888 | if (NULL != tc) |
3889 | { | 3889 | { |
3890 | struct GNUNET_MQ_Envelope *env; | 3890 | struct GNUNET_MQ_Envelope *env; |
3891 | struct SendOkMessage *som; | 3891 | struct SendOkMessage *so_msg; |
3892 | 3892 | ||
3893 | env = GNUNET_MQ_msg (som, GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_OK); | 3893 | env = GNUNET_MQ_msg (so_msg, GNUNET_MESSAGE_TYPE_TRANSPORT_SEND_OK); |
3894 | som->peer = vl->target; | 3894 | so_msg->peer = vl->target; |
3895 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 3895 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
3896 | "Confirming transmission of <%llu> to %s\n", | 3896 | "Confirming transmission of <%llu> to %s\n", |
3897 | pm->logging_uuid, | 3897 | pm->logging_uuid, |
@@ -4713,7 +4713,7 @@ route_control_message_without_fc (const struct GNUNET_PeerIdentity *target, | |||
4713 | } | 4713 | } |
4714 | if ((NULL != n) && (NULL != dv)) | 4714 | if ((NULL != n) && (NULL != dv)) |
4715 | options &= ~RMO_REDUNDANT; /* We will do one DV and one direct, that's | 4715 | options &= ~RMO_REDUNDANT; /* We will do one DV and one direct, that's |
4716 | enough for redunancy, so clear the flag. */ | 4716 | enough for redundancy, so clear the flag. */ |
4717 | rtt1 = GNUNET_TIME_UNIT_FOREVER_REL; | 4717 | rtt1 = GNUNET_TIME_UNIT_FOREVER_REL; |
4718 | rtt2 = GNUNET_TIME_UNIT_FOREVER_REL; | 4718 | rtt2 = GNUNET_TIME_UNIT_FOREVER_REL; |
4719 | if (NULL != n) | 4719 | if (NULL != n) |
@@ -4862,7 +4862,7 @@ check_vl_transmission (struct VirtualLink *vl) | |||
4862 | vl->outbound_fc_window_size) | 4862 | vl->outbound_fc_window_size) |
4863 | { | 4863 | { |
4864 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 4864 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
4865 | "Stalled transmision on VL %s due to flow control: %llu < %llu\n", | 4865 | "Stalled transmission on VL %s due to flow control: %llu < %llu\n", |
4866 | GNUNET_i2s (&vl->target), | 4866 | GNUNET_i2s (&vl->target), |
4867 | (unsigned long long) vl->outbound_fc_window_size, | 4867 | (unsigned long long) vl->outbound_fc_window_size, |
4868 | (unsigned long long) (pm->bytes_msg | 4868 | (unsigned long long) (pm->bytes_msg |
@@ -5286,7 +5286,7 @@ handle_raw_message (void *cls, const struct GNUNET_MessageHeader *mh) | |||
5286 | it. Thus logging as error for now. */ | 5286 | it. Thus logging as error for now. */ |
5287 | GNUNET_break_op (0); | 5287 | GNUNET_break_op (0); |
5288 | GNUNET_STATISTICS_update (GST_stats, | 5288 | GNUNET_STATISTICS_update (GST_stats, |
5289 | "# CORE messages droped (virtual link still down)", | 5289 | "# CORE messages dropped (virtual link still down)", |
5290 | 1, | 5290 | 1, |
5291 | GNUNET_NO); | 5291 | GNUNET_NO); |
5292 | 5292 | ||
@@ -5296,7 +5296,7 @@ handle_raw_message (void *cls, const struct GNUNET_MessageHeader *mh) | |||
5296 | if (vl->incoming_fc_window_size_ram > UINT_MAX - size) | 5296 | if (vl->incoming_fc_window_size_ram > UINT_MAX - size) |
5297 | { | 5297 | { |
5298 | GNUNET_STATISTICS_update (GST_stats, | 5298 | GNUNET_STATISTICS_update (GST_stats, |
5299 | "# CORE messages droped (FC arithmetic overflow)", | 5299 | "# CORE messages dropped (FC arithmetic overflow)", |
5300 | 1, | 5300 | 1, |
5301 | GNUNET_NO); | 5301 | GNUNET_NO); |
5302 | 5302 | ||
@@ -5306,7 +5306,7 @@ handle_raw_message (void *cls, const struct GNUNET_MessageHeader *mh) | |||
5306 | if (vl->incoming_fc_window_size_ram + size > vl->available_fc_window_size) | 5306 | if (vl->incoming_fc_window_size_ram + size > vl->available_fc_window_size) |
5307 | { | 5307 | { |
5308 | GNUNET_STATISTICS_update (GST_stats, | 5308 | GNUNET_STATISTICS_update (GST_stats, |
5309 | "# CORE messages droped (FC window overflow)", | 5309 | "# CORE messages dropped (FC window overflow)", |
5310 | 1, | 5310 | 1, |
5311 | GNUNET_NO); | 5311 | GNUNET_NO); |
5312 | finish_cmc_handling (cmc); | 5312 | finish_cmc_handling (cmc); |
@@ -5397,7 +5397,7 @@ check_fragment_box (void *cls, const struct TransportFragmentBoxMessage *fb) | |||
5397 | 5397 | ||
5398 | 5398 | ||
5399 | /** | 5399 | /** |
5400 | * Clean up an idle cummulative acknowledgement data structure. | 5400 | * Clean up an idle cumulative acknowledgement data structure. |
5401 | * | 5401 | * |
5402 | * @param cls a `struct AcknowledgementCummulator *` | 5402 | * @param cls a `struct AcknowledgementCummulator *` |
5403 | */ | 5403 | */ |
@@ -5416,7 +5416,7 @@ destroy_ack_cummulator (void *cls) | |||
5416 | 5416 | ||
5417 | 5417 | ||
5418 | /** | 5418 | /** |
5419 | * Do the transmission of a cummulative acknowledgement now. | 5419 | * Do the transmission of a cumulative acknowledgement now. |
5420 | * | 5420 | * |
5421 | * @param cls a `struct AcknowledgementCummulator *` | 5421 | * @param cls a `struct AcknowledgementCummulator *` |
5422 | */ | 5422 | */ |
@@ -5674,7 +5674,7 @@ handle_fragment_box (void *cls, const struct TransportFragmentBoxMessage *fb) | |||
5674 | } | 5674 | } |
5675 | } | 5675 | } |
5676 | 5676 | ||
5677 | /* Compute cummulative ACK */ | 5677 | /* Compute cumulative ACK */ |
5678 | cdelay = GNUNET_TIME_absolute_get_duration (rc->last_frag); | 5678 | cdelay = GNUNET_TIME_absolute_get_duration (rc->last_frag); |
5679 | cdelay = GNUNET_TIME_relative_multiply (cdelay, rc->msg_missing / fsize); | 5679 | cdelay = GNUNET_TIME_relative_multiply (cdelay, rc->msg_missing / fsize); |
5680 | if (0 == rc->msg_missing) | 5680 | if (0 == rc->msg_missing) |
@@ -5911,7 +5911,7 @@ completed_pending_message (struct PendingMessage *pm) | |||
5911 | * The @a pa was acknowledged, process the acknowledgement. | 5911 | * The @a pa was acknowledged, process the acknowledgement. |
5912 | * | 5912 | * |
5913 | * @param pa the pending acknowledgement that was satisfied | 5913 | * @param pa the pending acknowledgement that was satisfied |
5914 | * @param ack_delay artificial delay from cummulative acks created by the | 5914 | * @param ack_delay artificial delay from cumulative acks created by the |
5915 | * other peer | 5915 | * other peer |
5916 | */ | 5916 | */ |
5917 | static void | 5917 | static void |
@@ -7353,7 +7353,7 @@ handle_dv_box (void *cls, const struct TransportDVBoxMessage *dvb) | |||
7353 | path = tmp; | 7353 | path = tmp; |
7354 | } | 7354 | } |
7355 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 7355 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
7356 | "Received DVBox with remainig path %s\n", | 7356 | "Received DVBox with remaining path %s\n", |
7357 | path); | 7357 | path); |
7358 | GNUNET_free (path); | 7358 | GNUNET_free (path); |
7359 | } | 7359 | } |
@@ -7418,7 +7418,7 @@ handle_dv_box (void *cls, const struct TransportDVBoxMessage *dvb) | |||
7418 | dv_hmac (&key, &hmac, hdr, hdr_len); | 7418 | dv_hmac (&key, &hmac, hdr, hdr_len); |
7419 | if (0 != GNUNET_memcmp (&hmac, &dvb->hmac)) | 7419 | if (0 != GNUNET_memcmp (&hmac, &dvb->hmac)) |
7420 | { | 7420 | { |
7421 | /* HMAC missmatch, disard! */ | 7421 | /* HMAC mismatch, discard! */ |
7422 | GNUNET_break_op (0); | 7422 | GNUNET_break_op (0); |
7423 | finish_cmc_handling (cmc); | 7423 | finish_cmc_handling (cmc); |
7424 | return; | 7424 | return; |
@@ -7493,7 +7493,7 @@ handle_dv_box (void *cls, const struct TransportDVBoxMessage *dvb) | |||
7493 | &ppay.sender_sig, | 7493 | &ppay.sender_sig, |
7494 | &ppay.sender.public_key)) | 7494 | &ppay.sender.public_key)) |
7495 | { | 7495 | { |
7496 | /* Signature invalid, disard! */ | 7496 | /* Signature invalid, discard! */ |
7497 | GNUNET_break_op (0); | 7497 | GNUNET_break_op (0); |
7498 | finish_cmc_handling (cmc); | 7498 | finish_cmc_handling (cmc); |
7499 | return; | 7499 | return; |
@@ -8210,7 +8210,7 @@ handle_flow_control (void *cls, const struct TransportFlowControlMessage *fc) | |||
8210 | % FC_NO_CHANGE_REPLY_PROBABILITY)) | 8210 | % FC_NO_CHANGE_REPLY_PROBABILITY)) |
8211 | { | 8211 | { |
8212 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 8212 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
8213 | "Consider re-sending our FC message, as clearly the ther peer's idea of the window is not up-to-date (%llu vs %llu)\n", | 8213 | "Consider re-sending our FC message, as clearly the other peer's idea of the window is not up-to-date (%llu vs %llu)\n", |
8214 | (unsigned long long) wnd, | 8214 | (unsigned long long) wnd, |
8215 | (unsigned long long) vl->incoming_fc_window_size); | 8215 | (unsigned long long) vl->incoming_fc_window_size); |
8216 | consider_sending_fc (vl); | 8216 | consider_sending_fc (vl); |
@@ -8563,7 +8563,7 @@ reliability_box_message (struct Queue *queue, | |||
8563 | /** | 8563 | /** |
8564 | * Change the value of the `next_attempt` field of @a pm | 8564 | * Change the value of the `next_attempt` field of @a pm |
8565 | * to @a next_attempt and re-order @a pm in the transmission | 8565 | * to @a next_attempt and re-order @a pm in the transmission |
8566 | * list as required by the new timestmap. | 8566 | * list as required by the new timestamp. |
8567 | * | 8567 | * |
8568 | * @param pm a pending message to update | 8568 | * @param pm a pending message to update |
8569 | * @param next_attempt timestamp to use | 8569 | * @param next_attempt timestamp to use |
@@ -8755,7 +8755,7 @@ select_best_pending_from_link (struct PendingMessageScoreContext *sc, | |||
8755 | 10; /* increase weight, favors 'sc->best', which is low latency */ | 8755 | 10; /* increase weight, favors 'sc->best', which is low latency */ |
8756 | if (0 != queue->mtu) | 8756 | if (0 != queue->mtu) |
8757 | { | 8757 | { |
8758 | /* Grant bonus if we are bellow MTU, larger bonus the closer we will | 8758 | /* Grant bonus if we are below MTU, larger bonus the closer we will |
8759 | be to the MTU */ | 8759 | be to the MTU */ |
8760 | if (queue->mtu > sc->real_overhead + sc->best->bytes_msg) | 8760 | if (queue->mtu > sc->real_overhead + sc->best->bytes_msg) |
8761 | sc_score -= queue->mtu - (sc->real_overhead + sc->best->bytes_msg); | 8761 | sc_score -= queue->mtu - (sc->real_overhead + sc->best->bytes_msg); |
@@ -9645,7 +9645,9 @@ handle_add_queue_message (void *cls, | |||
9645 | if (NULL != queue) | 9645 | if (NULL != queue) |
9646 | { | 9646 | { |
9647 | neighbour = queue->neighbour; | 9647 | neighbour = queue->neighbour; |
9648 | } else { | 9648 | } |
9649 | else | ||
9650 | { | ||
9649 | neighbour = lookup_neighbour (&aqm->receiver); | 9651 | neighbour = lookup_neighbour (&aqm->receiver); |
9650 | if (NULL == neighbour) | 9652 | if (NULL == neighbour) |
9651 | { | 9653 | { |
diff --git a/src/transport/gnunet-service-transport.c b/src/transport/gnunet-service-transport.c index a819d82a5..24cc6464a 100644 --- a/src/transport/gnunet-service-transport.c +++ b/src/transport/gnunet-service-transport.c | |||
@@ -357,7 +357,7 @@ static struct TransportClient *sync_client; | |||
357 | 357 | ||
358 | /** | 358 | /** |
359 | * Peer identity that is all zeros, used as a way to indicate | 359 | * Peer identity that is all zeros, used as a way to indicate |
360 | * "all peers". Used for comparissons. | 360 | * "all peers". Used for comparisons. |
361 | */ | 361 | */ |
362 | static struct GNUNET_PeerIdentity all_zeros; | 362 | static struct GNUNET_PeerIdentity all_zeros; |
363 | 363 | ||
@@ -830,7 +830,7 @@ handle_client_send (void *cls, const struct OutboundMessage *obm) | |||
830 | 830 | ||
831 | /** | 831 | /** |
832 | * Take the given address and append it to the set of results sent back to | 832 | * Take the given address and append it to the set of results sent back to |
833 | * the client. This function may be called serveral times for a single | 833 | * the client. This function may be called several times for a single |
834 | * conversion. The last invocation will be with a @a address of | 834 | * conversion. The last invocation will be with a @a address of |
835 | * NULL and a @a res of #GNUNET_OK. Thus, to indicate conversion | 835 | * NULL and a @a res of #GNUNET_OK. Thus, to indicate conversion |
836 | * errors, the callback might be called first with @a address NULL and | 836 | * errors, the callback might be called first with @a address NULL and |
@@ -877,7 +877,7 @@ transmit_address_to_client (void *cls, const char *buf, int res) | |||
877 | } | 877 | } |
878 | } | 878 | } |
879 | GNUNET_assert (GNUNET_OK == res); | 879 | GNUNET_assert (GNUNET_OK == res); |
880 | /* succesful conversion, append*/ | 880 | /* successful conversion, append*/ |
881 | slen = strlen (buf) + 1; | 881 | slen = strlen (buf) + 1; |
882 | env = | 882 | env = |
883 | GNUNET_MQ_msg_extra (atsm, | 883 | GNUNET_MQ_msg_extra (atsm, |
@@ -1545,7 +1545,7 @@ kill_session (const char *plugin_name, struct GNUNET_ATS_Session *session) | |||
1545 | 1545 | ||
1546 | /** | 1546 | /** |
1547 | * Black list check result for try_connect call | 1547 | * Black list check result for try_connect call |
1548 | * If connection to the peer is allowed request adddress and ??? | 1548 | * If connection to the peer is allowed request address and ??? |
1549 | * | 1549 | * |
1550 | * @param cls the message | 1550 | * @param cls the message |
1551 | * @param peer the peer | 1551 | * @param peer the peer |
@@ -1782,7 +1782,7 @@ plugin_env_address_change_notification ( | |||
1782 | * | 1782 | * |
1783 | * @param cls closure | 1783 | * @param cls closure |
1784 | * @param address which address was the session for | 1784 | * @param address which address was the session for |
1785 | * @param session which session is being destoyed | 1785 | * @param session which session is being destroyed |
1786 | */ | 1786 | */ |
1787 | static void | 1787 | static void |
1788 | plugin_env_session_end (void *cls, | 1788 | plugin_env_session_end (void *cls, |
diff --git a/src/transport/gnunet-service-transport_validation.c b/src/transport/gnunet-service-transport_validation.c index e5d670889..86161bd85 100644 --- a/src/transport/gnunet-service-transport_validation.c +++ b/src/transport/gnunet-service-transport_validation.c | |||
@@ -68,7 +68,7 @@ enum GNUNET_TRANSPORT_ValidationState | |||
68 | /** | 68 | /** |
69 | * Timeout for validation entry | 69 | * Timeout for validation entry |
70 | * | 70 | * |
71 | * A timeout occured during the validation process | 71 | * A timeout occurred during the validation process |
72 | */ | 72 | */ |
73 | GNUNET_TRANSPORT_VS_TIMEOUT, | 73 | GNUNET_TRANSPORT_VS_TIMEOUT, |
74 | 74 | ||
@@ -1361,7 +1361,7 @@ GST_validation_handle_address (const struct GNUNET_HELLO_Address *address) | |||
1361 | papi = GST_plugins_find (address->transport_name); | 1361 | papi = GST_plugins_find (address->transport_name); |
1362 | if (NULL == papi) | 1362 | if (NULL == papi) |
1363 | { | 1363 | { |
1364 | /* This plugin is currently unvailable ... ignore */ | 1364 | /* This plugin is currently unavailable ... ignore */ |
1365 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, | 1365 | GNUNET_log (GNUNET_ERROR_TYPE_INFO, |
1366 | "No plugin available for %s\n", | 1366 | "No plugin available for %s\n", |
1367 | address->transport_name); | 1367 | address->transport_name); |
@@ -1807,7 +1807,7 @@ GST_validation_set_address_use (const struct GNUNET_HELLO_Address *address, | |||
1807 | ve->in_use = in_use; | 1807 | ve->in_use = in_use; |
1808 | if (GNUNET_YES == in_use) | 1808 | if (GNUNET_YES == in_use) |
1809 | { | 1809 | { |
1810 | /* from now on, higher frequeny, so reschedule now */ | 1810 | /* from now on, higher frequency, so reschedule now */ |
1811 | if (NULL != ve->revalidation_task) | 1811 | if (NULL != ve->revalidation_task) |
1812 | GNUNET_SCHEDULER_cancel (ve->revalidation_task); | 1812 | GNUNET_SCHEDULER_cancel (ve->revalidation_task); |
1813 | ve->revalidation_task = GNUNET_SCHEDULER_add_now (&revalidate_address, | 1813 | ve->revalidation_task = GNUNET_SCHEDULER_add_now (&revalidate_address, |
diff --git a/src/transport/gnunet-transport-profiler.c b/src/transport/gnunet-transport-profiler.c index 81678fa20..6e5204e28 100644 --- a/src/transport/gnunet-transport-profiler.c +++ b/src/transport/gnunet-transport-profiler.c | |||
@@ -204,7 +204,7 @@ shutdown_task (void *cls) | |||
204 | 204 | ||
205 | if (benchmark_send) | 205 | if (benchmark_send) |
206 | { | 206 | { |
207 | /* First iteration to calculcate avg and stddev */ | 207 | /* First iteration to calculate avg and stddev */ |
208 | iterations = 0; | 208 | iterations = 0; |
209 | avg_duration = 0; | 209 | avg_duration = 0; |
210 | avg_rate = 0.0; | 210 | avg_rate = 0.0; |
diff --git a/src/transport/gnunet-transport.c b/src/transport/gnunet-transport.c index 0d71e1ff9..b5ad43770 100644 --- a/src/transport/gnunet-transport.c +++ b/src/transport/gnunet-transport.c | |||
@@ -78,7 +78,7 @@ struct ValidationResolutionContext | |||
78 | struct GNUNET_TIME_Absolute next_validation; | 78 | struct GNUNET_TIME_Absolute next_validation; |
79 | 79 | ||
80 | /** | 80 | /** |
81 | * Tranport conversion handle | 81 | * Transport conversion handle |
82 | */ | 82 | */ |
83 | struct GNUNET_TRANSPORT_AddressToStringContext *asc; | 83 | struct GNUNET_TRANSPORT_AddressToStringContext *asc; |
84 | 84 | ||
diff --git a/src/transport/plugin_transport_http_client.c b/src/transport/plugin_transport_http_client.c index 219fae57b..18bfcc054 100644 --- a/src/transport/plugin_transport_http_client.c +++ b/src/transport/plugin_transport_http_client.c | |||
@@ -639,7 +639,7 @@ client_schedule (struct HTTP_Client_Plugin *plugin, | |||
639 | 639 | ||
640 | #if VERBOSE_CURL | 640 | #if VERBOSE_CURL |
641 | /** | 641 | /** |
642 | * Loggging function | 642 | * Logging function |
643 | * | 643 | * |
644 | * @param curl the curl easy handle | 644 | * @param curl the curl easy handle |
645 | * @param type message type | 645 | * @param type message type |
@@ -1306,7 +1306,7 @@ client_run (void *cls) | |||
1306 | int msgs_left; | 1306 | int msgs_left; |
1307 | 1307 | ||
1308 | plugin->client_perform_task = NULL; | 1308 | plugin->client_perform_task = NULL; |
1309 | /* While data are available or timeouts occured */ | 1309 | /* While data are available or timeouts occurred */ |
1310 | do | 1310 | do |
1311 | { | 1311 | { |
1312 | running = 0; | 1312 | running = 0; |
@@ -1390,7 +1390,7 @@ client_run (void *cls) | |||
1390 | break; | 1390 | break; |
1391 | 1391 | ||
1392 | case H_TMP_RECONNECT_REQUIRED: | 1392 | case H_TMP_RECONNECT_REQUIRED: |
1393 | /* Transport called send while disconnect in progess, reconnect */ | 1393 | /* Transport called send while disconnect in progress, reconnect */ |
1394 | if (GNUNET_SYSERR == client_connect_put (s)) | 1394 | if (GNUNET_SYSERR == client_connect_put (s)) |
1395 | { | 1395 | { |
1396 | /* Reconnect failed, disconnect session */ | 1396 | /* Reconnect failed, disconnect session */ |
@@ -2478,7 +2478,7 @@ LIBGNUNET_PLUGIN_TRANSPORT_INIT (void *cls) | |||
2478 | if (NULL == env->receive) | 2478 | if (NULL == env->receive) |
2479 | { | 2479 | { |
2480 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully | 2480 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully |
2481 | initialze the plugin or the API */ | 2481 | initialize the plugin or the API */ |
2482 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); | 2482 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); |
2483 | api->cls = NULL; | 2483 | api->cls = NULL; |
2484 | api->address_to_string = &http_client_plugin_address_to_string; | 2484 | api->address_to_string = &http_client_plugin_address_to_string; |
diff --git a/src/transport/plugin_transport_http_common.c b/src/transport/plugin_transport_http_common.c index 0e3778837..75bf8b74a 100644 --- a/src/transport/plugin_transport_http_common.c +++ b/src/transport/plugin_transport_http_common.c | |||
@@ -210,7 +210,7 @@ struct PrettyPrinterContext | |||
210 | struct GNUNET_SCHEDULER_Task *timeout_task; | 210 | struct GNUNET_SCHEDULER_Task *timeout_task; |
211 | 211 | ||
212 | /** | 212 | /** |
213 | * Splitted Address | 213 | * Split Address |
214 | */ | 214 | */ |
215 | struct SplittedHTTPAddress *saddr; | 215 | struct SplittedHTTPAddress *saddr; |
216 | 216 | ||
@@ -222,7 +222,7 @@ struct PrettyPrinterContext | |||
222 | /** | 222 | /** |
223 | * Was conversion successful | 223 | * Was conversion successful |
224 | */ | 224 | */ |
225 | int sucess; | 225 | int success; |
226 | 226 | ||
227 | /** | 227 | /** |
228 | * Address options | 228 | * Address options |
@@ -247,7 +247,7 @@ static struct PrettyPrinterContext *dll_ppc_tail; | |||
247 | * to override the address again. | 247 | * to override the address again. |
248 | * | 248 | * |
249 | * @param plugin the name of the plugin | 249 | * @param plugin the name of the plugin |
250 | * @param saddr the splitted http address | 250 | * @param saddr the split http address |
251 | * @param options address options | 251 | * @param options address options |
252 | * @param dnsresult dns name to include in address | 252 | * @param dnsresult dns name to include in address |
253 | * @return string representing the same address or NULL on error | 253 | * @return string representing the same address or NULL on error |
@@ -287,12 +287,12 @@ http_common_dns_reverse_lookup_cb (void *cls, const char *hostname) | |||
287 | http_common_plugin_dnsresult_to_address (ppc->plugin, ppc->saddr, | 287 | http_common_plugin_dnsresult_to_address (ppc->plugin, ppc->saddr, |
288 | ppc->options, | 288 | ppc->options, |
289 | hostname), GNUNET_OK); | 289 | hostname), GNUNET_OK); |
290 | ppc->sucess = GNUNET_YES; | 290 | ppc->success = GNUNET_YES; |
291 | } | 291 | } |
292 | else | 292 | else |
293 | { | 293 | { |
294 | ppc->asc (ppc->asc_cls, NULL, | 294 | ppc->asc (ppc->asc_cls, NULL, |
295 | (GNUNET_NO == ppc->sucess) ? GNUNET_SYSERR : GNUNET_OK); | 295 | (GNUNET_NO == ppc->success) ? GNUNET_SYSERR : GNUNET_OK); |
296 | 296 | ||
297 | GNUNET_CONTAINER_DLL_remove (dll_ppc_head, dll_ppc_tail, ppc); | 297 | GNUNET_CONTAINER_DLL_remove (dll_ppc_head, dll_ppc_tail, ppc); |
298 | http_clean_splitted (ppc->saddr); | 298 | http_clean_splitted (ppc->saddr); |
@@ -355,13 +355,13 @@ http_common_dns_ip_lookup_cb (void *cls, | |||
355 | GNUNET_a2s (addr, | 355 | GNUNET_a2s (addr, |
356 | addrlen)), | 356 | addrlen)), |
357 | GNUNET_OK); | 357 | GNUNET_OK); |
358 | ppc->sucess = GNUNET_YES; | 358 | ppc->success = GNUNET_YES; |
359 | ppc->asc (ppc->asc_cls, GNUNET_a2s (addr, addrlen), GNUNET_OK); | 359 | ppc->asc (ppc->asc_cls, GNUNET_a2s (addr, addrlen), GNUNET_OK); |
360 | } | 360 | } |
361 | else | 361 | else |
362 | { | 362 | { |
363 | ppc->asc (ppc->asc_cls, NULL, | 363 | ppc->asc (ppc->asc_cls, NULL, |
364 | (GNUNET_NO == ppc->sucess) ? GNUNET_SYSERR : GNUNET_OK); | 364 | (GNUNET_NO == ppc->success) ? GNUNET_SYSERR : GNUNET_OK); |
365 | 365 | ||
366 | GNUNET_CONTAINER_DLL_remove (dll_ppc_head, dll_ppc_tail, ppc); | 366 | GNUNET_CONTAINER_DLL_remove (dll_ppc_head, dll_ppc_tail, ppc); |
367 | GNUNET_free (ppc->plugin); | 367 | GNUNET_free (ppc->plugin); |
@@ -383,7 +383,7 @@ http_common_dns_ip_lookup (const char *name, | |||
383 | struct PrettyPrinterContext *ppc; | 383 | struct PrettyPrinterContext *ppc; |
384 | 384 | ||
385 | ppc = GNUNET_new (struct PrettyPrinterContext); | 385 | ppc = GNUNET_new (struct PrettyPrinterContext); |
386 | ppc->sucess = GNUNET_NO; | 386 | ppc->success = GNUNET_NO; |
387 | ppc->saddr = saddr; | 387 | ppc->saddr = saddr; |
388 | ppc->asc = asc; | 388 | ppc->asc = asc; |
389 | ppc->asc_cls = asc_cls; | 389 | ppc->asc_cls = asc_cls; |
diff --git a/src/transport/plugin_transport_http_server.c b/src/transport/plugin_transport_http_server.c index 6e95ca00c..78b030e9a 100644 --- a/src/transport/plugin_transport_http_server.c +++ b/src/transport/plugin_transport_http_server.c | |||
@@ -2569,7 +2569,7 @@ server_remove_address (void *cls, | |||
2569 | * the previous (now invalid) one | 2569 | * the previous (now invalid) one |
2570 | * @param ac address class the address belongs to | 2570 | * @param ac address class the address belongs to |
2571 | * @param addr either the previous or the new public IP address | 2571 | * @param addr either the previous or the new public IP address |
2572 | * @param addrlen actual lenght of the address | 2572 | * @param addrlen actual length of the address |
2573 | */ | 2573 | */ |
2574 | static void | 2574 | static void |
2575 | server_nat_port_map_callback (void *cls, | 2575 | server_nat_port_map_callback (void *cls, |
@@ -3512,7 +3512,7 @@ LIBGNUNET_PLUGIN_TRANSPORT_INIT (void *cls) | |||
3512 | if (NULL == env->receive) | 3512 | if (NULL == env->receive) |
3513 | { | 3513 | { |
3514 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully | 3514 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully |
3515 | initialze the plugin or the API */ | 3515 | initialize the plugin or the API */ |
3516 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); | 3516 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); |
3517 | api->cls = NULL; | 3517 | api->cls = NULL; |
3518 | api->address_to_string = &http_server_plugin_address_to_string; | 3518 | api->address_to_string = &http_server_plugin_address_to_string; |
diff --git a/src/transport/plugin_transport_tcp.c b/src/transport/plugin_transport_tcp.c index 8378a64dd..ac4cc672f 100644 --- a/src/transport/plugin_transport_tcp.c +++ b/src/transport/plugin_transport_tcp.c | |||
@@ -164,7 +164,7 @@ typedef int (*GNUNET_CONNECTION_AccessCheck) ( | |||
164 | * | 164 | * |
165 | * @param cls closure | 165 | * @param cls closure |
166 | * @param buf pointer to received data | 166 | * @param buf pointer to received data |
167 | * @param available number of bytes availabe in "buf", | 167 | * @param available number of bytes available in "buf", |
168 | * possibly 0 (on errors) | 168 | * possibly 0 (on errors) |
169 | * @param addr address of the sender | 169 | * @param addr address of the sender |
170 | * @param addrlen size of addr | 170 | * @param addrlen size of addr |
@@ -3674,7 +3674,7 @@ libgnunet_plugin_transport_tcp_init (void *cls) | |||
3674 | if (NULL == env->receive) | 3674 | if (NULL == env->receive) |
3675 | { | 3675 | { |
3676 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully | 3676 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully |
3677 | initialze the plugin or the API */ | 3677 | initialize the plugin or the API */ |
3678 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); | 3678 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); |
3679 | api->cls = NULL; | 3679 | api->cls = NULL; |
3680 | api->address_pretty_printer = &tcp_plugin_address_pretty_printer; | 3680 | api->address_pretty_printer = &tcp_plugin_address_pretty_printer; |
diff --git a/src/transport/plugin_transport_template.c b/src/transport/plugin_transport_template.c index 239f32f4a..c39c72178 100644 --- a/src/transport/plugin_transport_template.c +++ b/src/transport/plugin_transport_template.c | |||
@@ -516,7 +516,7 @@ libgnunet_plugin_transport_template_init (void *cls) | |||
516 | if (NULL == env->receive) | 516 | if (NULL == env->receive) |
517 | { | 517 | { |
518 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully | 518 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully |
519 | initialze the plugin or the API */ | 519 | initialize the plugin or the API */ |
520 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); | 520 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); |
521 | api->cls = NULL; | 521 | api->cls = NULL; |
522 | api->address_to_string = &template_plugin_address_to_string; | 522 | api->address_to_string = &template_plugin_address_to_string; |
diff --git a/src/transport/plugin_transport_udp.c b/src/transport/plugin_transport_udp.c index 49e84dfe7..2db31caa3 100644 --- a/src/transport/plugin_transport_udp.c +++ b/src/transport/plugin_transport_udp.c | |||
@@ -2390,7 +2390,7 @@ read_process_ack (struct Plugin *plugin, | |||
2390 | 2390 | ||
2391 | 2391 | ||
2392 | /** | 2392 | /** |
2393 | * Message tokenizer has broken up an incomming message. Pass it on | 2393 | * Message tokenizer has broken up an incoming message. Pass it on |
2394 | * to the service. | 2394 | * to the service. |
2395 | * | 2395 | * |
2396 | * @param cls the `struct GNUNET_ATS_Session *` | 2396 | * @param cls the `struct GNUNET_ATS_Session *` |
@@ -3605,7 +3605,7 @@ libgnunet_plugin_transport_udp_init (void *cls) | |||
3605 | if (NULL == env->receive) | 3605 | if (NULL == env->receive) |
3606 | { | 3606 | { |
3607 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully | 3607 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully |
3608 | initialze the plugin or the API */ | 3608 | initialize the plugin or the API */ |
3609 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); | 3609 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); |
3610 | api->cls = NULL; | 3610 | api->cls = NULL; |
3611 | api->address_pretty_printer = &udp_plugin_address_pretty_printer; | 3611 | api->address_pretty_printer = &udp_plugin_address_pretty_printer; |
diff --git a/src/transport/plugin_transport_unix.c b/src/transport/plugin_transport_unix.c index 2324914c9..269949a99 100644 --- a/src/transport/plugin_transport_unix.c +++ b/src/transport/plugin_transport_unix.c | |||
@@ -1729,7 +1729,7 @@ libgnunet_plugin_transport_unix_init (void *cls) | |||
1729 | if (NULL == env->receive) | 1729 | if (NULL == env->receive) |
1730 | { | 1730 | { |
1731 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully | 1731 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully |
1732 | initialze the plugin or the API */ | 1732 | initialize the plugin or the API */ |
1733 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); | 1733 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); |
1734 | api->cls = NULL; | 1734 | api->cls = NULL; |
1735 | api->address_pretty_printer = &unix_plugin_address_pretty_printer; | 1735 | api->address_pretty_printer = &unix_plugin_address_pretty_printer; |
diff --git a/src/transport/plugin_transport_wlan.c b/src/transport/plugin_transport_wlan.c index 1b2b6d0d2..138fb5080 100644 --- a/src/transport/plugin_transport_wlan.c +++ b/src/transport/plugin_transport_wlan.c | |||
@@ -470,7 +470,7 @@ struct Plugin | |||
470 | struct GNUNET_TRANSPORT_PluginEnvironment *env; | 470 | struct GNUNET_TRANSPORT_PluginEnvironment *env; |
471 | 471 | ||
472 | /** | 472 | /** |
473 | * Handle to helper process for priviledged operations. | 473 | * Handle to helper process for privileged operations. |
474 | */ | 474 | */ |
475 | struct GNUNET_HELPER_Handle *suid_helper; | 475 | struct GNUNET_HELPER_Handle *suid_helper; |
476 | 476 | ||
@@ -2262,7 +2262,7 @@ LIBGNUNET_PLUGIN_TRANSPORT_INIT (void *cls) | |||
2262 | if (NULL == env->receive) | 2262 | if (NULL == env->receive) |
2263 | { | 2263 | { |
2264 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully | 2264 | /* run in 'stub' mode (i.e. as part of gnunet-peerinfo), don't fully |
2265 | initialze the plugin or the API */ | 2265 | initialize the plugin or the API */ |
2266 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); | 2266 | api = GNUNET_new (struct GNUNET_TRANSPORT_PluginFunctions); |
2267 | api->cls = NULL; | 2267 | api->cls = NULL; |
2268 | api->address_pretty_printer = &wlan_plugin_address_pretty_printer; | 2268 | api->address_pretty_printer = &wlan_plugin_address_pretty_printer; |
diff --git a/src/transport/tcp_connection_legacy.c b/src/transport/tcp_connection_legacy.c index 924362ef2..551e79055 100644 --- a/src/transport/tcp_connection_legacy.c +++ b/src/transport/tcp_connection_legacy.c | |||
@@ -120,7 +120,7 @@ struct AddressProbe | |||
120 | struct GNUNET_CONNECTION_Handle *connection; | 120 | struct GNUNET_CONNECTION_Handle *connection; |
121 | 121 | ||
122 | /** | 122 | /** |
123 | * Lenth of addr. | 123 | * Length of addr. |
124 | */ | 124 | */ |
125 | socklen_t addrlen; | 125 | socklen_t addrlen; |
126 | 126 | ||
@@ -538,7 +538,7 @@ signal_transmit_error (struct GNUNET_CONNECTION_Handle *connection, int ecode) | |||
538 | GNUNET_CONNECTION_TransmitReadyNotify notify; | 538 | GNUNET_CONNECTION_TransmitReadyNotify notify; |
539 | 539 | ||
540 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 540 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
541 | "Transmission encounterd error (%s), connection closed (%p)\n", | 541 | "Transmission encountered error (%s), connection closed (%p)\n", |
542 | strerror (ecode), | 542 | strerror (ecode), |
543 | connection); | 543 | connection); |
544 | if (NULL != connection->sock) | 544 | if (NULL != connection->sock) |
diff --git a/src/transport/tcp_server_legacy.c b/src/transport/tcp_server_legacy.c index 59b4fc20a..f4d48d4f6 100644 --- a/src/transport/tcp_server_legacy.c +++ b/src/transport/tcp_server_legacy.c | |||
@@ -836,7 +836,7 @@ GNUNET_SERVER_destroy (struct GNUNET_SERVER_Handle *server) | |||
836 | * incoming messages; the last entry must | 836 | * incoming messages; the last entry must |
837 | * have "NULL" for the "callback"; multiple | 837 | * have "NULL" for the "callback"; multiple |
838 | * entries for the same type are allowed, | 838 | * entries for the same type are allowed, |
839 | * they will be called in order of occurence. | 839 | * they will be called in order of occurrence. |
840 | * These handlers can be removed later; | 840 | * These handlers can be removed later; |
841 | * the handlers array must exist until removed | 841 | * the handlers array must exist until removed |
842 | * (or server is destroyed). | 842 | * (or server is destroyed). |
diff --git a/src/transport/tcp_server_mst_legacy.c b/src/transport/tcp_server_mst_legacy.c index cef41c5b0..bed6874c9 100644 --- a/src/transport/tcp_server_mst_legacy.c +++ b/src/transport/tcp_server_mst_legacy.c | |||
@@ -262,7 +262,7 @@ do_align: | |||
262 | else | 262 | else |
263 | { | 263 | { |
264 | /* need to copy to private buffer to align; | 264 | /* need to copy to private buffer to align; |
265 | * yes, we go a bit more spagetti than usual here */ | 265 | * yes, we go a bit more spaghetti than usual here */ |
266 | goto do_align; | 266 | goto do_align; |
267 | } | 267 | } |
268 | } | 268 | } |
diff --git a/src/transport/test_communicator_basic.c b/src/transport/test_communicator_basic.c index 98b49012a..202bc0a5b 100644 --- a/src/transport/test_communicator_basic.c +++ b/src/transport/test_communicator_basic.c | |||
@@ -998,7 +998,7 @@ static void | |||
998 | do_shutdown (void *cls) | 998 | do_shutdown (void *cls) |
999 | { | 999 | { |
1000 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 1000 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
1001 | "shuting down test.\n"); | 1001 | "shutting down test.\n"); |
1002 | 1002 | ||
1003 | for (unsigned int i = 0; i < NUM_PEERS; i++) | 1003 | for (unsigned int i = 0; i < NUM_PEERS; i++) |
1004 | { | 1004 | { |
diff --git a/src/transport/test_transport_address_switch.c b/src/transport/test_transport_address_switch.c index b49cb187b..ce5117bd1 100644 --- a/src/transport/test_transport_address_switch.c +++ b/src/transport/test_transport_address_switch.c | |||
@@ -77,7 +77,7 @@ struct PeerStats | |||
77 | 77 | ||
78 | static struct PeerStats stats[2]; | 78 | static struct PeerStats stats[2]; |
79 | 79 | ||
80 | /* Amount of data transfered since last switch attempt */ | 80 | /* Amount of data transferred since last switch attempt */ |
81 | static unsigned long long bytes_sent_after_switch; | 81 | static unsigned long long bytes_sent_after_switch; |
82 | 82 | ||
83 | static unsigned long long bytes_recv_after_switch; | 83 | static unsigned long long bytes_recv_after_switch; |
diff --git a/src/transport/test_transport_api_reliability.c b/src/transport/test_transport_api_reliability.c index deb943956..508fed4f5 100644 --- a/src/transport/test_transport_api_reliability.c +++ b/src/transport/test_transport_api_reliability.c | |||
@@ -174,7 +174,7 @@ custom_shutdown (void *cls) | |||
174 | unsigned long long rate; | 174 | unsigned long long rate; |
175 | int ok; | 175 | int ok; |
176 | 176 | ||
177 | /* Calculcate statistics */ | 177 | /* Calculate statistics */ |
178 | delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value_us; | 178 | delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value_us; |
179 | if (0 == delta) | 179 | if (0 == delta) |
180 | delta = 1; | 180 | delta = 1; |
diff --git a/src/transport/transport-testing-communicator.c b/src/transport/transport-testing-communicator.c index 040f16d5d..ce4af01f2 100644 --- a/src/transport/transport-testing-communicator.c +++ b/src/transport/transport-testing-communicator.c | |||
@@ -431,7 +431,7 @@ handle_queue_create_ok (void *cls, | |||
431 | 431 | ||
432 | 432 | ||
433 | /** | 433 | /** |
434 | * @brief Communicator informs that it wont try establishing requested queue. | 434 | * @brief Communicator informs that it won't try establishing requested queue. |
435 | * | 435 | * |
436 | * It will not do so probably because the address is bougus (see comment to | 436 | * It will not do so probably because the address is bougus (see comment to |
437 | * #GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_FAIL) | 437 | * #GNUNET_MESSAGE_TYPE_TRANSPORT_QUEUE_CREATE_FAIL) |
diff --git a/src/transport/transport-testing.c b/src/transport/transport-testing.c index 2da193b31..a7ee563d7 100644 --- a/src/transport/transport-testing.c +++ b/src/transport/transport-testing.c | |||
@@ -824,7 +824,7 @@ GNUNET_TRANSPORT_TESTING_connect_peers (struct | |||
824 | 824 | ||
825 | /** | 825 | /** |
826 | * Cancel the request to connect two peers | 826 | * Cancel the request to connect two peers |
827 | * Tou MUST cancel the request if you stop the peers before the peers connected succesfully | 827 | * Tou MUST cancel the request if you stop the peers before the peers connected successfully |
828 | * | 828 | * |
829 | * @param tth transport testing handle | 829 | * @param tth transport testing handle |
830 | * @param cc a connect request handle | 830 | * @param cc a connect request handle |
diff --git a/src/transport/transport-testing2.c b/src/transport/transport-testing2.c index eaa8a5f15..96d305fd8 100644 --- a/src/transport/transport-testing2.c +++ b/src/transport/transport-testing2.c | |||
@@ -859,7 +859,7 @@ GNUNET_TRANSPORT_TESTING_connect_peers (struct | |||
859 | 859 | ||
860 | /** | 860 | /** |
861 | * Cancel the request to connect two peers | 861 | * Cancel the request to connect two peers |
862 | * Tou MUST cancel the request if you stop the peers before the peers connected succesfully | 862 | * Tou MUST cancel the request if you stop the peers before the peers connected successfully |
863 | * | 863 | * |
864 | * @param tth transport testing handle | 864 | * @param tth transport testing handle |
865 | * @param cc a connect request handle | 865 | * @param cc a connect request handle |
diff --git a/src/transport/transport_api2_application.c b/src/transport/transport_api2_application.c index 4862863dd..00f5f62eb 100644 --- a/src/transport/transport_api2_application.c +++ b/src/transport/transport_api2_application.c | |||
@@ -282,7 +282,7 @@ GNUNET_TRANSPORT_application_done ( | |||
282 | * @param peer identity of the peer we need an address for | 282 | * @param peer identity of the peer we need an address for |
283 | * @param pk what kind of application will the application require (can be | 283 | * @param pk what kind of application will the application require (can be |
284 | * #GNUNET_MQ_PRIO_BACKGROUND, we will still try to connect) | 284 | * #GNUNET_MQ_PRIO_BACKGROUND, we will still try to connect) |
285 | * @param bw desired bandwith, can be zero (we will still try to connect) | 285 | * @param bw desired bandwidth, can be zero (we will still try to connect) |
286 | * @return suggest handle, NULL if a request is already pending | 286 | * @return suggest handle, NULL if a request is already pending |
287 | */ | 287 | */ |
288 | struct GNUNET_TRANSPORT_ApplicationSuggestHandle * | 288 | struct GNUNET_TRANSPORT_ApplicationSuggestHandle * |
@@ -359,7 +359,7 @@ GNUNET_TRANSPORT_application_suggest_cancel ( | |||
359 | * @param peer identity of the peer we have an address for | 359 | * @param peer identity of the peer we have an address for |
360 | * @param nt network type of @a addr (as claimed by the other peer); | 360 | * @param nt network type of @a addr (as claimed by the other peer); |
361 | * used by TRANSPORT to avoid trying @a addr's that really cannot work | 361 | * used by TRANSPORT to avoid trying @a addr's that really cannot work |
362 | * due to network type missmatches | 362 | * due to network type mismatches |
363 | * @param addr address to validate | 363 | * @param addr address to validate |
364 | */ | 364 | */ |
365 | void | 365 | void |
diff --git a/src/transport/transport_api2_communication.c b/src/transport/transport_api2_communication.c index 3d9da08e4..446add6f6 100644 --- a/src/transport/transport_api2_communication.c +++ b/src/transport/transport_api2_communication.c | |||
@@ -198,7 +198,7 @@ struct GNUNET_TRANSPORT_CommunicatorHandle | |||
198 | struct GNUNET_MQ_Handle *mq; | 198 | struct GNUNET_MQ_Handle *mq; |
199 | 199 | ||
200 | /** | 200 | /** |
201 | * Maximum permissable queue length. | 201 | * Maximum permissible queue length. |
202 | */ | 202 | */ |
203 | unsigned long long max_queue_length; | 203 | unsigned long long max_queue_length; |
204 | 204 | ||
@@ -262,7 +262,7 @@ struct GNUNET_TRANSPORT_QueueHandle | |||
262 | struct GNUNET_PeerIdentity peer; | 262 | struct GNUNET_PeerIdentity peer; |
263 | 263 | ||
264 | /** | 264 | /** |
265 | * Network type of the communciation queue. | 265 | * Network type of the communication queue. |
266 | */ | 266 | */ |
267 | enum GNUNET_NetworkType nt; | 267 | enum GNUNET_NetworkType nt; |
268 | 268 | ||
@@ -889,7 +889,7 @@ GNUNET_TRANSPORT_communicator_disconnect ( | |||
889 | * immediately dropped due to memory limitations (communicator | 889 | * immediately dropped due to memory limitations (communicator |
890 | * should try to apply back pressure), | 890 | * should try to apply back pressure), |
891 | * #GNUNET_SYSERR if the message could not be delivered because | 891 | * #GNUNET_SYSERR if the message could not be delivered because |
892 | * the tranport service is not yet up | 892 | * the transport service is not yet up |
893 | */ | 893 | */ |
894 | int | 894 | int |
895 | GNUNET_TRANSPORT_communicator_receive ( | 895 | GNUNET_TRANSPORT_communicator_receive ( |
diff --git a/src/transport/transport_api_core.c b/src/transport/transport_api_core.c index 7d4b415bd..0ffaeb444 100644 --- a/src/transport/transport_api_core.c +++ b/src/transport/transport_api_core.c | |||
@@ -82,7 +82,7 @@ struct Neighbour | |||
82 | struct GNUNET_BANDWIDTH_Tracker out_tracker; | 82 | struct GNUNET_BANDWIDTH_Tracker out_tracker; |
83 | 83 | ||
84 | /** | 84 | /** |
85 | * Entry in our readyness heap (which is sorted by @e next_ready | 85 | * Entry in our readiness heap (which is sorted by @e next_ready |
86 | * value). NULL if there is no pending transmission request for | 86 | * value). NULL if there is no pending transmission request for |
87 | * this neighbour or if we're waiting for @e is_ready to become | 87 | * this neighbour or if we're waiting for @e is_ready to become |
88 | * true AFTER the @e out_tracker suggested that this peer's quota | 88 | * true AFTER the @e out_tracker suggested that this peer's quota |