fix: make pipelining limit work for h2

nodejs · Feb 28, 2024 · 5ad15a9 · 5ad15a9
1 parent 861f782
commit 5ad15a9
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/lib/dispatcher/client-h1.js b/lib/dispatcher/client-h1.js
@@ -612,7 +612,7 @@ class Parser {
       // have been queued since then.
       util.destroy(socket, new InformationalError('reset'))
       return constants.ERROR.PAUSED
-    } else if (client[kPipelining] === 1) {
+    } else if (client[kPipelining] == null || client[kPipelining] === 1) {
       // We must wait a full event loop cycle to reuse this socket to make sure
       // that non-spec compliant servers are not closing the connection even if they
       // said they won't.

diff --git a/lib/dispatcher/client.js b/lib/dispatcher/client.js
@@ -66,6 +66,10 @@ const connectH2 = require('./client-h2.js')
 
 const kClosedResolve = Symbol('kClosedResolve')
 
+function getPipelining (client) {
+  return client[kPipelining] ?? (client[kHTTPContext]?.version === 'h2' ? Infinity : 1)
+}
+
 /**
  * @type {import('../../types/client.js').default}
  */
@@ -280,7 +284,7 @@ class Client extends DispatcherBase {
     const socket = this[kSocket]
     return (
       (socket && (socket[kReset] || socket[kWriting] || socket[kBlocking])) ||
-      (this[kSize] >= (this[kPipelining] || 1)) ||
+      (this[kSize] >= (getPipelining(this) || 1)) ||
       this[kPending] > 0
     )
   }
@@ -564,10 +568,8 @@ function _resume (client, sync) {
       return
     }
 
-    if (client[kHTTPContext]?.version === 'h1') {
-      if (client[kRunning] >= (client[kPipelining] || 1)) {
-        return
-      }
+    if (client[kRunning] >= (getPipelining(client) || 1)) {
+      return
     }
 
     const request = client[kQueue][client[kPendingIdx]]