diff options
author | Matthias Wachs <wachs@net.in.tum.de> | 2012-06-29 09:26:40 +0000 |
---|---|---|
committer | Matthias Wachs <wachs@net.in.tum.de> | 2012-06-29 09:26:40 +0000 |
commit | 2265f50f2fa412d412fe239f44c0264b99d494d6 (patch) | |
tree | 4abf177ae7d3d006329da61cbc98d4553631c436 /src/transport/plugin_transport_tcp.c | |
parent | 65bd2954fccfb94b0ccc91eba559d73c2852f803 (diff) | |
download | gnunet-2265f50f2fa412d412fe239f44c0264b99d494d6.tar.gz gnunet-2265f50f2fa412d412fe239f44c0264b99d494d6.zip |
- fixed session code
Diffstat (limited to 'src/transport/plugin_transport_tcp.c')
-rw-r--r-- | src/transport/plugin_transport_tcp.c | 42 |
1 files changed, 15 insertions, 27 deletions
diff --git a/src/transport/plugin_transport_tcp.c b/src/transport/plugin_transport_tcp.c index 007e87f93..e5b821978 100644 --- a/src/transport/plugin_transport_tcp.c +++ b/src/transport/plugin_transport_tcp.c | |||
@@ -1706,7 +1706,7 @@ handle_tcp_nat_probe (void *cls, struct GNUNET_SERVER_Client *client, | |||
1706 | const struct sockaddr_in *s4; | 1706 | const struct sockaddr_in *s4; |
1707 | const struct sockaddr_in6 *s6; | 1707 | const struct sockaddr_in6 *s6; |
1708 | 1708 | ||
1709 | LOG (GNUNET_ERROR_TYPE_DEBUG, "received NAT probe\n"); | 1709 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Received NAT probe\n"); |
1710 | 1710 | ||
1711 | /* We have received a TCP NAT probe, meaning we (hopefully) initiated | 1711 | /* We have received a TCP NAT probe, meaning we (hopefully) initiated |
1712 | * a connection to this peer by running gnunet-nat-client. This peer | 1712 | * a connection to this peer by running gnunet-nat-client. This peer |
@@ -2188,8 +2188,8 @@ session_timeout (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
2188 | 2188 | ||
2189 | s->timeout_task = GNUNET_SCHEDULER_NO_TASK; | 2189 | s->timeout_task = GNUNET_SCHEDULER_NO_TASK; |
2190 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 2190 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
2191 | "Session %p was idle for %llu, disconnecting\n", | 2191 | "Session %p was idle for %llu ms, disconnecting\n", |
2192 | s, GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT.rel_value); | 2192 | s, (unsigned long long) GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT.rel_value); |
2193 | /* call session destroy function */ | 2193 | /* call session destroy function */ |
2194 | disconnect_session(s); | 2194 | disconnect_session(s); |
2195 | } | 2195 | } |
@@ -2206,10 +2206,9 @@ start_session_timeout (struct Session *s) | |||
2206 | s->timeout_task = GNUNET_SCHEDULER_add_delayed (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT, | 2206 | s->timeout_task = GNUNET_SCHEDULER_add_delayed (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT, |
2207 | &session_timeout, | 2207 | &session_timeout, |
2208 | s); | 2208 | s); |
2209 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 2209 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
2210 | "Timeout for session %p set to %llu\n", | 2210 | "Timeout for session %p set to %llu ms\n", |
2211 | s, | 2211 | s, (unsigned long long) GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT.rel_value); |
2212 | GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT.rel_value); | ||
2213 | } | 2212 | } |
2214 | 2213 | ||
2215 | 2214 | ||
@@ -2220,21 +2219,15 @@ static void | |||
2220 | reschedule_session_timeout (struct Session *s) | 2219 | reschedule_session_timeout (struct Session *s) |
2221 | { | 2220 | { |
2222 | GNUNET_assert (NULL != s); | 2221 | GNUNET_assert (NULL != s); |
2223 | if (GNUNET_SCHEDULER_NO_TASK == s->timeout_task) | 2222 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK != s->timeout_task); |
2224 | { | 2223 | |
2225 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, | ||
2226 | "Timeout for peer `%s' %s not scheduled\n", | ||
2227 | GNUNET_i2s (&s->target), | ||
2228 | tcp_address_to_string(NULL, s->addr, s->addrlen)); | ||
2229 | return; | ||
2230 | } | ||
2231 | GNUNET_SCHEDULER_cancel (s->timeout_task); | 2224 | GNUNET_SCHEDULER_cancel (s->timeout_task); |
2232 | s->timeout_task = GNUNET_SCHEDULER_add_delayed (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT, | 2225 | s->timeout_task = GNUNET_SCHEDULER_add_delayed (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT, |
2233 | &session_timeout, | 2226 | &session_timeout, |
2234 | s); | 2227 | s); |
2235 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Timeout rescheduled for session %p set to %llu\n", | 2228 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
2236 | s, | 2229 | "Timeout rescheduled for session %p set to %llu ms\n", |
2237 | (unsigned long long) GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT.rel_value); | 2230 | s, (unsigned long long) GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT.rel_value); |
2238 | } | 2231 | } |
2239 | 2232 | ||
2240 | 2233 | ||
@@ -2245,19 +2238,14 @@ static void | |||
2245 | stop_session_timeout (struct Session *s) | 2238 | stop_session_timeout (struct Session *s) |
2246 | { | 2239 | { |
2247 | GNUNET_assert (NULL != s); | 2240 | GNUNET_assert (NULL != s); |
2241 | |||
2248 | if (GNUNET_SCHEDULER_NO_TASK != s->timeout_task) | 2242 | if (GNUNET_SCHEDULER_NO_TASK != s->timeout_task) |
2249 | { | 2243 | { |
2250 | GNUNET_SCHEDULER_cancel (s->timeout_task); | 2244 | GNUNET_SCHEDULER_cancel (s->timeout_task); |
2251 | s->timeout_task = GNUNET_SCHEDULER_NO_TASK; | 2245 | s->timeout_task = GNUNET_SCHEDULER_NO_TASK; |
2252 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 2246 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
2253 | "Timeout rescheduled for session %p canceled\n", | 2247 | "Timeout stopped for session %p canceled\n", |
2254 | s, GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT.rel_value); | 2248 | s, (unsigned long long) GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT.rel_value); |
2255 | } | ||
2256 | else | ||
2257 | { | ||
2258 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
2259 | "Timeout for session %p was not active\n", | ||
2260 | s); | ||
2261 | } | 2249 | } |
2262 | } | 2250 | } |
2263 | 2251 | ||