diff options
author | Christian Grothoff <christian@grothoff.org> | 2015-02-28 18:49:25 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2015-02-28 18:49:25 +0000 |
commit | 70e4fde281b319ea93a454f8a8fa8a65d08c8969 (patch) | |
tree | c8b909939399d6d5821ed3068d43b10de3d40328 /src/transport/plugin_transport_udp.c | |
parent | 7e5583d5334f7241686dad86a2110d7d6a7ecfc2 (diff) | |
download | gnunet-70e4fde281b319ea93a454f8a8fa8a65d08c8969.tar.gz gnunet-70e4fde281b319ea93a454f8a8fa8a65d08c8969.zip |
call GNUNET_SERVER_receive_done() also on internal error paths
Diffstat (limited to 'src/transport/plugin_transport_udp.c')
-rw-r--r-- | src/transport/plugin_transport_udp.c | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/src/transport/plugin_transport_udp.c b/src/transport/plugin_transport_udp.c index 8c6a0d854..a5db667b7 100644 --- a/src/transport/plugin_transport_udp.c +++ b/src/transport/plugin_transport_udp.c | |||
@@ -1929,7 +1929,9 @@ enqueue (struct Plugin *plugin, | |||
1929 | else | 1929 | else |
1930 | { | 1930 | { |
1931 | GNUNET_STATISTICS_update (plugin->env->stats, | 1931 | GNUNET_STATISTICS_update (plugin->env->stats, |
1932 | "# UDP, total, bytes in buffers", udpw->msg_size, GNUNET_NO); | 1932 | "# UDP, total, bytes in buffers", |
1933 | udpw->msg_size, | ||
1934 | GNUNET_NO); | ||
1933 | plugin->bytes_in_buffer += udpw->msg_size; | 1935 | plugin->bytes_in_buffer += udpw->msg_size; |
1934 | } | 1936 | } |
1935 | GNUNET_STATISTICS_update (plugin->env->stats, | 1937 | GNUNET_STATISTICS_update (plugin->env->stats, |
@@ -2509,9 +2511,10 @@ read_process_ack (struct Plugin *plugin, | |||
2509 | 2511 | ||
2510 | flow_delay.rel_value_us = (uint64_t) ntohl (udp_ack->delay); | 2512 | flow_delay.rel_value_us = (uint64_t) ntohl (udp_ack->delay); |
2511 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 2513 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
2512 | "We received a sending delay of %s\n", | 2514 | "We received a sending delay of %s for %s\n", |
2513 | GNUNET_STRINGS_relative_time_to_string (flow_delay, | 2515 | GNUNET_STRINGS_relative_time_to_string (flow_delay, |
2514 | GNUNET_YES)); | 2516 | GNUNET_YES), |
2517 | GNUNET_i2s (&udp_ack->sender)); | ||
2515 | s->flow_delay_from_other_peer = GNUNET_TIME_relative_to_absolute (flow_delay); | 2518 | s->flow_delay_from_other_peer = GNUNET_TIME_relative_to_absolute (flow_delay); |
2516 | 2519 | ||
2517 | ack = (const struct GNUNET_MessageHeader *) &udp_ack[1]; | 2520 | ack = (const struct GNUNET_MessageHeader *) &udp_ack[1]; |
@@ -2537,8 +2540,7 @@ read_process_ack (struct Plugin *plugin, | |||
2537 | } | 2540 | } |
2538 | 2541 | ||
2539 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 2542 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
2540 | "Message full ACK'ed\n", | 2543 | "Message from %s at %s full ACK'ed\n", |
2541 | (unsigned int ) ntohs (msg->size), | ||
2542 | GNUNET_i2s (&udp_ack->sender), | 2544 | GNUNET_i2s (&udp_ack->sender), |
2543 | udp_address_to_string (plugin, | 2545 | udp_address_to_string (plugin, |
2544 | udp_addr, | 2546 | udp_addr, |