aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_udp.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-10-23 15:18:48 +0000
committerChristian Grothoff <christian@grothoff.org>2011-10-23 15:18:48 +0000
commit1207885b627afe3bcdb5fafa17a4edf2730882ef (patch)
tree6c9c231aba928a6def475977f42d175cb09cf955 /src/transport/plugin_transport_udp.c
parent4db8b7f55e29c77d107257386de1bf75062caee3 (diff)
downloadgnunet-1207885b627afe3bcdb5fafa17a4edf2730882ef.tar.gz
gnunet-1207885b627afe3bcdb5fafa17a4edf2730882ef.zip
Adding FIXMEs: if delay is FOREVER, session should be terminated
Diffstat (limited to 'src/transport/plugin_transport_udp.c')
-rw-r--r--src/transport/plugin_transport_udp.c4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/transport/plugin_transport_udp.c b/src/transport/plugin_transport_udp.c
index 9812416de..077fe38e3 100644
--- a/src/transport/plugin_transport_udp.c
+++ b/src/transport/plugin_transport_udp.c
@@ -861,6 +861,10 @@ process_inbound_tokenized_messages (void *cls, void *client,
861 "Giving Session %X %s to transport\n", si->session, GNUNET_i2s(&si->session->target)); 861 "Giving Session %X %s to transport\n", si->session, GNUNET_i2s(&si->session->target));
862 delay = plugin->env->receive (plugin->env->cls, &si->sender, hdr, &distance, 1, si->session, 862 delay = plugin->env->receive (plugin->env->cls, &si->sender, hdr, &distance, 1, si->session,
863 si->arg, si->args); 863 si->arg, si->args);
864 if (delay.rel_value == GNUNET_TIME_UNIT_FOREVER_REL.rel_value)
865 {
866 // FIXME: terminate session!
867 }
864 si->session->flow_delay_for_other_peer = delay; 868 si->session->flow_delay_for_other_peer = delay;
865} 869}
866 870