aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_http_client.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_http_client.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_http_client.c')
-rw-r--r--src/transport/plugin_transport_http_client.c6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/transport/plugin_transport_http_client.c b/src/transport/plugin_transport_http_client.c
index a2024953c..a27997d33 100644
--- a/src/transport/plugin_transport_http_client.c
+++ b/src/transport/plugin_transport_http_client.c
@@ -322,7 +322,11 @@ client_receive_mst_cb (void *cls, void *client,
322 struct GNUNET_TIME_Relative delay; 322 struct GNUNET_TIME_Relative delay;
323 323
324 delay = http_plugin_receive (s, &s->target, message, s, s->addr, s->addrlen); 324 delay = http_plugin_receive (s, &s->target, message, s, s->addr, s->addrlen);
325 s->next_receive = GNUNET_TIME_absolute_add(GNUNET_TIME_absolute_get(), delay); 325 if (delay.rel_value == GNUNET_TIME_UNIT_FOREVER_REL.rel_value)
326 {
327 // FIXME: terminate connection!
328 }
329 s->next_receive = GNUNET_TIME_relative_to_absolute (delay);
326 330
327 if (GNUNET_TIME_absolute_get().abs_value < s->next_receive.abs_value) 331 if (GNUNET_TIME_absolute_get().abs_value < s->next_receive.abs_value)
328 { 332 {