diff --git a/src/shrpx_connection.cc b/src/shrpx_connection.cc index a4d4c598..a0c9d93a 100644 --- a/src/shrpx_connection.cc +++ b/src/shrpx_connection.cc @@ -730,6 +730,10 @@ ssize_t Connection::write_clear(const void *data, size_t len) { wlimit.drain(nwrite); + if (ev_is_active(&wt)) { + ev_timer_again(loop, &wt); + } + return nwrite; } @@ -753,6 +757,10 @@ ssize_t Connection::writev_clear(struct iovec *iov, int iovcnt) { wlimit.drain(nwrite); + if (ev_is_active(&wt)) { + ev_timer_again(loop, &wt); + } + return nwrite; }