fix: Improve timeout handling during event loop lag

Make timeouts behave more closer that what is expected
during event loop lag.

lib/dispatcher/client-h1.js

@@ -158,6 +158,7 @@ class Parser {
 
     this.bytesRead = 0
 
+    this.timeoutDeadline = 0
     this.keepAlive = ''
     this.contentLength = ''
     this.connection = ''
@@ -170,6 +171,8 @@ class Parser {
       timers.clearTimeout(this.timeout)
       if (value) {
         this.timeout = timers.setTimeout(onParserTimeout, value, this)
+        this.timeoutDeadline = this.timeoutValue ? Date.now() + this.timeoutValue : 0
+
         // istanbul ignore else: only for jest
         if (this.timeout.unref) {
           this.timeout.unref()
@@ -182,10 +185,17 @@ class Parser {
       // istanbul ignore else: only for jest
       if (this.timeout.refresh) {
         this.timeout.refresh()
+        this.timeoutDeadline = this.timeoutValue ? Date.now() + this.timeoutValue : 0
       }
     }
   }
 
+  updateTimeout () {
+    if (this.timeoutDeadline && this.timeoutDeadline < Date.now()) {
+      onParserTimeout(this)
+    }
+  }
+
   resume () {
     if (this.socket.destroyed || !this.paused) {
       return
@@ -615,6 +625,8 @@ class Parser {
 function onParserTimeout (parser) {
   const { socket, timeoutType, client } = parser
 
+  parser.timeoutDeadline = 0
+
   /* istanbul ignore else */
   if (timeoutType === TIMEOUT_HEADERS) {
     if (!socket[kWriting] || socket.writableNeedDrain || client[kRunning] > 1) {
@@ -815,6 +827,8 @@ function resumeH1 (client) {
         socket[kParser].setTimeout(headersTimeout, TIMEOUT_HEADERS)
       }
     }
+
+    socket[kParser].updateTimeout()
   }
 }
 

lib/util/timers.js

@@ -2,13 +2,13 @@
 
 const TICK_MS = 499
 
-let fastNow = Date.now()
+let fastNow = 0
 let fastNowTimeout
 
 const fastTimers = []
 
 function onTimeout () {
-  fastNow = Date.now()
+  fastNow += TICK_MS
 
   let len = fastTimers.length
   let idx = 0