diff options
author | Christian Grothoff <christian@grothoff.org> | 2013-12-13 13:25:31 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2013-12-13 13:25:31 +0000 |
commit | cdeef5dacc29fd2192b2df784a717812d4c80ec2 (patch) | |
tree | 907dd14832f7c473bf4a0a6b5bd848f678b09658 /src/transport/plugin_transport_tcp.c | |
parent | f588c2993d8034a5c893dacc770a367c7cb69c55 (diff) | |
download | gnunet-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.c | 12 |
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 | ||