aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_udp.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2015-10-18 18:16:59 +0000
committerChristian Grothoff <christian@grothoff.org>2015-10-18 18:16:59 +0000
commit0a86d72d1701fdcf193331d882218a41939fc138 (patch)
tree6d7597908ffafbb50e4f24d9e76d4bd70e6563ec /src/transport/plugin_transport_udp.c
parent1258d72197693be2daa54b69dc57b61f8638d7fa (diff)
downloadgnunet-0a86d72d1701fdcf193331d882218a41939fc138.tar.gz
gnunet-0a86d72d1701fdcf193331d882218a41939fc138.zip
-only schedule select once per fragmented message
Diffstat (limited to 'src/transport/plugin_transport_udp.c')
-rw-r--r--src/transport/plugin_transport_udp.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/transport/plugin_transport_udp.c b/src/transport/plugin_transport_udp.c
index af1b412c2..e10a924d1 100644
--- a/src/transport/plugin_transport_udp.c
+++ b/src/transport/plugin_transport_udp.c
@@ -1859,10 +1859,6 @@ enqueue_fragment (void *cls,
1859 msg_len); 1859 msg_len);
1860 enqueue (plugin, 1860 enqueue (plugin,
1861 udpw); 1861 udpw);
1862 if (sizeof (struct IPv4UdpAddress) == session->address->address_length)
1863 schedule_select_v4 (plugin);
1864 else
1865 schedule_select_v6 (plugin);
1866} 1862}
1867 1863
1868 1864
@@ -2101,6 +2097,10 @@ udp_plugin_send (void *cls,
2101 frag_ctx); 2097 frag_ctx);
2102 s->frag_ctx = frag_ctx; 2098 s->frag_ctx = frag_ctx;
2103 s->last_transmit_time = frag_ctx->next_frag_time; 2099 s->last_transmit_time = frag_ctx->next_frag_time;
2100 if (sizeof (struct IPv4UdpAddress) == s->address->address_length)
2101 schedule_select_v4 (plugin);
2102 else
2103 schedule_select_v6 (plugin);
2104 GNUNET_STATISTICS_update (plugin->env->stats, 2104 GNUNET_STATISTICS_update (plugin->env->stats,
2105 "# UDP, fragmented messages active", 2105 "# UDP, fragmented messages active",
2106 1, 2106 1,