nghttpx: Reset write timer on write

9b5ce363 · Tatsuhiro Tsujikawa · f69b52b1 · 9b5ce363
Commit 9b5ce363 authored Mar 18, 2017 by Tatsuhiro Tsujikawa
Hide whitespace changes
Inline Side-by-side

Showing with 8 additions and 0 deletions

src/shrpx_connection.cc src/shrpx_connection.cc +8 -0

No files found.
--- 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;
 }