aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_tcp.c
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2012-06-29 09:26:40 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2012-06-29 09:26:40 +0000
commit2265f50f2fa412d412fe239f44c0264b99d494d6 (patch)
tree4abf177ae7d3d006329da61cbc98d4553631c436 /src/transport/plugin_transport_tcp.c
parent65bd2954fccfb94b0ccc91eba559d73c2852f803 (diff)
downloadgnunet-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.c42
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
2220reschedule_session_timeout (struct Session *s) 2219reschedule_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
2245stop_session_timeout (struct Session *s) 2238stop_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