aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_tcp.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2013-12-13 13:25:31 +0000
committerChristian Grothoff <christian@grothoff.org>2013-12-13 13:25:31 +0000
commitcdeef5dacc29fd2192b2df784a717812d4c80ec2 (patch)
tree907dd14832f7c473bf4a0a6b5bd848f678b09658 /src/transport/plugin_transport_tcp.c
parentf588c2993d8034a5c893dacc770a367c7cb69c55 (diff)
downloadgnunet-cdeef5dacc29fd2192b2df784a717812d4c80ec2.tar.gz
gnunet-cdeef5dacc29fd2192b2df784a717812d4c80ec2.zip
-fix 3208 by making kills async
Diffstat (limited to 'src/transport/plugin_transport_tcp.c')
-rw-r--r--src/transport/plugin_transport_tcp.c12
1 files changed, 5 insertions, 7 deletions
diff --git a/src/transport/plugin_transport_tcp.c b/src/transport/plugin_transport_tcp.c
index 9e78e47d9..e0572d5d0 100644
--- a/src/transport/plugin_transport_tcp.c
+++ b/src/transport/plugin_transport_tcp.c
@@ -2297,13 +2297,11 @@ handle_tcp_data (void *cls, struct GNUNET_SERVER_Client *client,
2297 (GNUNET_YES == session->inbound) ? NULL : session->addr, 2297 (GNUNET_YES == session->inbound) ? NULL : session->addr,
2298 (GNUNET_YES == session->inbound) ? 0 : session->addrlen); 2298 (GNUNET_YES == session->inbound) ? 0 : session->addrlen);
2299 plugin->env->update_address_metrics (plugin->env->cls, 2299 plugin->env->update_address_metrics (plugin->env->cls,
2300 &session->target, 2300 &session->target,
2301 (GNUNET_YES == session->inbound) ? NULL : session->addr, 2301 (GNUNET_YES == session->inbound) ? NULL : session->addr,
2302 (GNUNET_YES == session->inbound) ? 0 : session->addrlen, 2302 (GNUNET_YES == session->inbound) ? 0 : session->addrlen,
2303 session, &distance, 1); 2303 session, &distance, 1);
2304
2305 reschedule_session_timeout (session); 2304 reschedule_session_timeout (session);
2306
2307 if (0 == delay.rel_value_us) 2305 if (0 == delay.rel_value_us)
2308 { 2306 {
2309 GNUNET_SERVER_receive_done (client, GNUNET_OK); 2307 GNUNET_SERVER_receive_done (client, GNUNET_OK);
@@ -2316,7 +2314,7 @@ handle_tcp_data (void *cls, struct GNUNET_SERVER_Client *client,
2316 GNUNET_STRINGS_relative_time_to_string (delay, GNUNET_YES)); 2314 GNUNET_STRINGS_relative_time_to_string (delay, GNUNET_YES));
2317 GNUNET_SERVER_disable_receive_done_warning (client); 2315 GNUNET_SERVER_disable_receive_done_warning (client);
2318 session->receive_delay_task = 2316 session->receive_delay_task =
2319 GNUNET_SCHEDULER_add_delayed (delay, &delayed_done, session); 2317 GNUNET_SCHEDULER_add_delayed (delay, &delayed_done, session);
2320 } 2318 }
2321} 2319}
2322 2320