diff options
author | Christian Grothoff <christian@grothoff.org> | 2009-10-01 23:40:21 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2009-10-01 23:40:21 +0000 |
commit | 617747c896dfb1de59fd5dff77cb8c02ef92108e (patch) | |
tree | a3864d90fdfd65dcfe3f24584ce681a76abfd57d | |
parent | 1d2235ed369e751cd54c2fca5bafb5ee25d4470b (diff) | |
download | gnunet-617747c896dfb1de59fd5dff77cb8c02ef92108e.tar.gz gnunet-617747c896dfb1de59fd5dff77cb8c02ef92108e.zip |
fix
-rw-r--r-- | src/util/connection.c | 17 |
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 | } |