aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2009-10-01 23:40:21 +0000
committerChristian Grothoff <christian@grothoff.org>2009-10-01 23:40:21 +0000
commit617747c896dfb1de59fd5dff77cb8c02ef92108e (patch)
treea3864d90fdfd65dcfe3f24584ce681a76abfd57d
parent1d2235ed369e751cd54c2fca5bafb5ee25d4470b (diff)
downloadgnunet-617747c896dfb1de59fd5dff77cb8c02ef92108e.tar.gz
gnunet-617747c896dfb1de59fd5dff77cb8c02ef92108e.zip
fix
-rw-r--r--src/util/connection.c17
1 files changed, 10 insertions, 7 deletions
diff --git a/src/util/connection.c b/src/util/connection.c
index 7792ce686..cabe00355 100644
--- a/src/util/connection.c
+++ b/src/util/connection.c
@@ -598,11 +598,10 @@ connect_probe_continuation (void *cls,
598 struct AddressProbe *ap = cls; 598 struct AddressProbe *ap = cls;
599 struct GNUNET_CONNECTION_Handle *h = ap->h; 599 struct GNUNET_CONNECTION_Handle *h = ap->h;
600 struct AddressProbe *pos; 600 struct AddressProbe *pos;
601 int error; 601 int error;
602 unsigned int len; 602 unsigned int len;
603 603
604 GNUNET_CONTAINER_DLL_remove (h->ap_head, h->ap_tail, ap); 604 GNUNET_CONTAINER_DLL_remove (h->ap_head, h->ap_tail, ap);
605
606 len = sizeof (error); 605 len = sizeof (error);
607 errno = 0; 606 errno = 0;
608 error = 0; 607 error = 0;
@@ -1032,10 +1031,11 @@ receive_ready (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
1032 (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) ) 1031 (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) )
1033 { 1032 {
1034#if DEBUG_CONNECTION 1033#if DEBUG_CONNECTION
1035 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 1034 if (0 == (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
1036 "Receive from %s encounters error: time out by %llums...\n", 1035 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1037 GNUNET_a2s (sh->addr, sh->addrlen), 1036 "Receive from `%s' encounters error: time out by %llums...\n",
1038 now.value - sh->receive_timeout.value); 1037 GNUNET_a2s (sh->addr, sh->addrlen),
1038 GNUNET_TIME_absolute_get_duration (sh->receive_timeout).value);
1039#endif 1039#endif
1040 signal_timeout (sh); 1040 signal_timeout (sh);
1041 return; 1041 return;
@@ -1269,7 +1269,9 @@ transmit_timeout (void *cls,
1269 sock->nth.timeout_task = GNUNET_SCHEDULER_NO_TASK; 1269 sock->nth.timeout_task = GNUNET_SCHEDULER_NO_TASK;
1270#if DEBUG_CONNECTION 1270#if DEBUG_CONNECTION
1271 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 1271 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1272 "Transmit to `%s' fails, time out reached.\n", 1272 "Transmit to `%s:%u/%s' fails, time out reached.\n",
1273 sock->hostname,
1274 sock->port,
1273 GNUNET_a2s (sock->addr, sock->addrlen)); 1275 GNUNET_a2s (sock->addr, sock->addrlen));
1274#endif 1276#endif
1275 GNUNET_assert (0 != (sock->ccs & CC_TRANSMIT_READY)); 1277 GNUNET_assert (0 != (sock->ccs & CC_TRANSMIT_READY));
@@ -1502,6 +1504,7 @@ GNUNET_CONNECTION_notify_transmit_ready_cancel (struct
1502 { 1504 {
1503 GNUNET_SCHEDULER_cancel (h->sh->sched, 1505 GNUNET_SCHEDULER_cancel (h->sh->sched,
1504 h->sh->write_task); 1506 h->sh->write_task);
1507 h->sh->write_task = GNUNET_SCHEDULER_NO_TASK;
1505 } 1508 }
1506 h->notify_ready = NULL; 1509 h->notify_ready = NULL;
1507} 1510}