Disabling timer when request header has been entirely read.

1 files changed, 8 insertions, 2 deletions

diff --git a/src/nxt_h1proto.c b/src/nxt_h1proto.c
index 03f232b1..3eaabce7 100644
--- a/src/nxt_h1proto.c
+++ b/src/nxt_h1proto.c
@@ -179,6 +179,7 @@ static const nxt_conn_state_t  nxt_h1p_idle_state
     .timer_handler = nxt_h1p_conn_timeout,
     .timer_value = nxt_h1p_conn_timeout_value,
     .timer_data = offsetof(nxt_socket_conf_t, idle_timeout),
+    .timer_autoreset = 1,
 };
 
 
@@ -307,10 +308,14 @@ nxt_h1p_conn_header_parse(nxt_task_t *task, void *obj, void *data)
 
     ret = nxt_http_parse_request(&h1p->parser, &c->read->mem);
 
-    r = h1p->request;
-
     ret = nxt_expect(NXT_DONE, ret);
 
+    if (ret != NXT_AGAIN) {
+        nxt_timer_disable(task->thread->engine, &c->read_timer);
+    }
+
+    r = h1p->request;
+
     switch (ret) {
 
     case NXT_DONE:
@@ -1076,6 +1081,7 @@ static const nxt_conn_state_t  nxt_h1p_keepalive_state
     .timer_handler = nxt_h1p_conn_timeout,
     .timer_value = nxt_h1p_conn_timeout_value,
     .timer_data = offsetof(nxt_socket_conf_t, idle_timeout),
+    .timer_autoreset = 1,
 };