diff options
Diffstat (limited to 'src/transport/plugin_transport_tcp.c')
-rw-r--r-- | src/transport/plugin_transport_tcp.c | 30 |
1 files changed, 18 insertions, 12 deletions
diff --git a/src/transport/plugin_transport_tcp.c b/src/transport/plugin_transport_tcp.c index dc0beb73f..b1c4cab2b 100644 --- a/src/transport/plugin_transport_tcp.c +++ b/src/transport/plugin_transport_tcp.c | |||
@@ -1,6 +1,6 @@ | |||
1 | /* | 1 | /* |
2 | This file is part of GNUnet | 2 | This file is part of GNUnet |
3 | (C) 2002--2012 Christian Grothoff (and other contributing authors) | 3 | (C) 2002--2013 Christian Grothoff (and other contributing authors) |
4 | 4 | ||
5 | GNUnet is free software; you can redistribute it and/or modify | 5 | GNUnet is free software; you can redistribute it and/or modify |
6 | it under the terms of the GNU General Public License as published | 6 | it under the terms of the GNU General Public License as published |
@@ -897,7 +897,7 @@ do_transmit (void *cls, size_t size, void *buf) | |||
897 | ret = 0; | 897 | ret = 0; |
898 | now = GNUNET_TIME_absolute_get (); | 898 | now = GNUNET_TIME_absolute_get (); |
899 | while ((NULL != (pos = session->pending_messages_head)) && | 899 | while ((NULL != (pos = session->pending_messages_head)) && |
900 | (pos->timeout.abs_value <= now.abs_value)) | 900 | (pos->timeout.abs_value_us <= now.abs_value_us)) |
901 | { | 901 | { |
902 | GNUNET_CONTAINER_DLL_remove (session->pending_messages_head, | 902 | GNUNET_CONTAINER_DLL_remove (session->pending_messages_head, |
903 | session->pending_messages_tail, pos); | 903 | session->pending_messages_tail, pos); |
@@ -2269,16 +2269,16 @@ handle_tcp_data (void *cls, struct GNUNET_SERVER_Client *client, | |||
2269 | 2269 | ||
2270 | reschedule_session_timeout (session); | 2270 | reschedule_session_timeout (session); |
2271 | 2271 | ||
2272 | if (delay.rel_value == 0) | 2272 | if (0 == delay.rel_value_us) |
2273 | { | 2273 | { |
2274 | GNUNET_SERVER_receive_done (client, GNUNET_OK); | 2274 | GNUNET_SERVER_receive_done (client, GNUNET_OK); |
2275 | } | 2275 | } |
2276 | else | 2276 | else |
2277 | { | 2277 | { |
2278 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 2278 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
2279 | "Throttling receiving from `%s' for %llu ms\n", | 2279 | "Throttling receiving from `%s' for %s\n", |
2280 | GNUNET_i2s (&session->target), | 2280 | GNUNET_i2s (&session->target), |
2281 | (unsigned long long) delay.rel_value); | 2281 | GNUNET_STRINGS_relative_time_to_string (delay, GNUNET_YES)); |
2282 | GNUNET_SERVER_disable_receive_done_warning (client); | 2282 | GNUNET_SERVER_disable_receive_done_warning (client); |
2283 | session->receive_delay_task = | 2283 | session->receive_delay_task = |
2284 | GNUNET_SCHEDULER_add_delayed (delay, &delayed_done, session); | 2284 | GNUNET_SCHEDULER_add_delayed (delay, &delayed_done, session); |
@@ -2426,8 +2426,10 @@ session_timeout (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
2426 | 2426 | ||
2427 | s->timeout_task = GNUNET_SCHEDULER_NO_TASK; | 2427 | s->timeout_task = GNUNET_SCHEDULER_NO_TASK; |
2428 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 2428 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
2429 | "Session %p was idle for %llu ms, disconnecting\n", | 2429 | "Session %p was idle for %s, disconnecting\n", |
2430 | s, (unsigned long long) GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT.rel_value); | 2430 | s, |
2431 | GNUNET_STRINGS_relative_time_to_string (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT, | ||
2432 | GNUNET_YES)); | ||
2431 | /* call session destroy function */ | 2433 | /* call session destroy function */ |
2432 | disconnect_session(s); | 2434 | disconnect_session(s); |
2433 | } | 2435 | } |
@@ -2445,8 +2447,10 @@ start_session_timeout (struct Session *s) | |||
2445 | &session_timeout, | 2447 | &session_timeout, |
2446 | s); | 2448 | s); |
2447 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 2449 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
2448 | "Timeout for session %p set to %llu ms\n", | 2450 | "Timeout for session %p set to %s\n", |
2449 | s, (unsigned long long) GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT.rel_value); | 2451 | s, |
2452 | GNUNET_STRINGS_relative_time_to_string (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT, | ||
2453 | GNUNET_YES)); | ||
2450 | } | 2454 | } |
2451 | 2455 | ||
2452 | 2456 | ||
@@ -2464,8 +2468,10 @@ reschedule_session_timeout (struct Session *s) | |||
2464 | &session_timeout, | 2468 | &session_timeout, |
2465 | s); | 2469 | s); |
2466 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 2470 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
2467 | "Timeout rescheduled for session %p set to %llu ms\n", | 2471 | "Timeout rescheduled for session %p set to %s\n", |
2468 | s, (unsigned long long) GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT.rel_value); | 2472 | s, |
2473 | GNUNET_STRINGS_relative_time_to_string (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT, | ||
2474 | GNUNET_YES)); | ||
2469 | } | 2475 | } |
2470 | 2476 | ||
2471 | 2477 | ||
@@ -2483,7 +2489,7 @@ stop_session_timeout (struct Session *s) | |||
2483 | s->timeout_task = GNUNET_SCHEDULER_NO_TASK; | 2489 | s->timeout_task = GNUNET_SCHEDULER_NO_TASK; |
2484 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 2490 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
2485 | "Timeout stopped for session %p canceled\n", | 2491 | "Timeout stopped for session %p canceled\n", |
2486 | s, (unsigned long long) GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT.rel_value); | 2492 | s); |
2487 | } | 2493 | } |
2488 | } | 2494 | } |
2489 | 2495 | ||