fixing handling of transmit errors

1 files changed, 8 insertions, 0 deletions

diff --git a/src/util/connection.c b/src/util/connection.c
index 290a361b3..8c7a2c4f8 100644
--- a/src/util/connection.c
+++ b/src/util/connection.c
@@ -1352,6 +1352,14 @@ transmit_error (struct GNUNET_CONNECTION_Handle *sock)
                     GNUNET_NETWORK_socket_close (sock->sock));
       sock->sock = NULL;
     }
+  if (sock->read_task != GNUNET_SCHEDULER_NO_TASK)
+    {
+      GNUNET_SCHEDULER_cancel (sock->sched,
+                               sock->read_task);
+      sock->read_task = GNUNET_SCHEDULER_NO_TASK;
+      signal_timeout (sock);
+      return;
+    }
   if (sock->nth.notify_ready == NULL)
     return;                     /* nobody to tell about it */
   notify = sock->nth.notify_ready;