nodejs
diff --git a/Collapse file
‎src/node_http_parser_impl.h‎
Copy file name to clipboardExpand all lines: src/node_http_parser_impl.h
+1Lines changed: 1 addition & 0 deletions b/Collapse file
‎src/node_http_parser_impl.h‎
Copy file name to clipboardExpand all lines: src/node_http_parser_impl.h
+1Lines changed: 1 addition & 0 deletions
diff --git a/Collapse file
‎test/parallel/test-http-parser-timeout-reset.js‎
Copy file name to clipboard
+44Lines changed: 44 additions & 0 deletions b/Collapse file
‎test/parallel/test-http-parser-timeout-reset.js‎
Copy file name to clipboard
+44Lines changed: 44 additions & 0 deletions
@@ -265,6 +265,7 @@ class Parser : public AsyncWrap, public StreamListener {
 #ifdef NODE_EXPERIMENTAL_HTTP
     header_nread_ = 0;
 #endif  /* NODE_EXPERIMENTAL_HTTP */
+    header_parsing_start_time_ = 0;
 
     // Arguments for the on-headers-complete javascript callback. This
     // list needs to be kept in sync with the actual argument list for
 
@@ -0,0 +1,44 @@
+'use strict';
+const common = require('../common');
+
+const net = require('net');
+const { HTTPParser } = process.binding('http_parser');
+
+const server = net.createServer((socket) => {
+  socket.write('HTTP/1.1 200 OK\r\n');
+  socket.write('Transfer-Encoding: chunked\r\n\r\n');
+  setTimeout(() => {
+    socket.write('1\r\n');
+    socket.write('\n\r\n');
+    setTimeout(() => {
+      socket.write('1\r\n');
+      socket.write('\n\r\n');
+      setImmediate(() => {
+        socket.destroy();
+        server.close();
+      });
+    }, 500);
+  }, 500);
+}).listen(0, () => {
+  const socket = net.connect(server.address().port);
+  const parser = new HTTPParser(HTTPParser.RESPONSE, false);
+  parser.initialize(
+    HTTPParser.RESPONSE,
+    {},
+    1e3
+  );
+
+  parser[HTTPParser.kOnTimeout] = common.mustNotCall();
+
+  parser[HTTPParser.kOnHeaders] = common.mustNotCall();
+
+  parser[HTTPParser.kOnExecute] = common.mustCallAtLeast(3);
+
+  parser[HTTPParser.kOnHeadersComplete] = common.mustCall();
+
+  parser[HTTPParser.kOnBody] = common.mustCall(2);
+
+  parser[HTTPParser.kOnMessageComplete] = common.mustNotCall();
+
+  parser.consume(socket._handle);
+});