diff options
| -rw-r--r-- | lib/event.c | 15 | 
1 files changed, 15 insertions, 0 deletions
| diff --git a/lib/event.c b/lib/event.c index c625850..b572184 100644 --- a/lib/event.c +++ b/lib/event.c @@ -92,6 +92,21 @@ event_retransmit_timeout_cb (int fd, short event, void *data)        rs_debug (("%s: retransmission timeout on %p (fd %d) sending to %p\n",  		 __func__, conn, conn->fd, conn->active_peer));        rs_err_conn_push_fl (conn, RSE_TIMEOUT_IO, __FILE__, __LINE__, NULL); + +      /* Disable/delete read and write events. Timing out on reading +         might f.ex. trigger resending of a message. It'd be +         surprising to end up reading without having enabled/created a +         read event in that case. */ +      if (conn->bev)            /* TCP. */ +        bufferevent_disable (conn->bev, EV_WRITE|EV_READ); +      else                      /* UDP. */ +        { +          if (conn->wev) +            event_del (conn->wev); +          if (conn->rev) +            event_del (conn->rev); +        } +        event_loopbreak (conn);      }  } | 
