aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_tcp.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/plugin_transport_tcp.c')
-rw-r--r--src/transport/plugin_transport_tcp.c30
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