From 988034be6aece7bd103249e18ac7f0a5d3f92545 Mon Sep 17 00:00:00 2001 From: Denys Otrishko Date: Mon, 18 Nov 2019 22:12:15 +0200 Subject: http2: make maximum tolerated rejected streams configurable PR-URL: https://github.com/nodejs/node/pull/30534 Fixes: https://github.com/nodejs/node/issues/30505 Reviewed-By: Anna Henningsen Reviewed-By: David Carlier Reviewed-By: James M Snell --- lib/internal/http2/core.js | 14 ++++++++++++++ 1 file changed, 14 insertions(+) (limited to 'lib') diff --git a/lib/internal/http2/core.js b/lib/internal/http2/core.js index 7eaf1f4e92..c4d12f9205 100644 --- a/lib/internal/http2/core.js +++ b/lib/internal/http2/core.js @@ -211,6 +211,7 @@ const { kSessionPriorityListenerCount, kSessionFrameErrorListenerCount, kSessionMaxInvalidFrames, + kSessionMaxRejectedStreams, kSessionUint8FieldCount, kSessionHasRemoteSettingsListeners, kSessionRemoteSettingsIsUpToDate, @@ -955,6 +956,12 @@ function setupHandle(socket, type, options) { uint32[0] = options.maxSessionInvalidFrames; } + if (isUint32(options.maxSessionRejectedStreams)) { + const uint32 = new Uint32Array( + this[kNativeFields].buffer, kSessionMaxRejectedStreams, 1); + uint32[0] = options.maxSessionRejectedStreams; + } + const settings = typeof options.settings === 'object' ? options.settings : {}; @@ -2788,6 +2795,13 @@ function initializeOptions(options) { if (options.maxSessionInvalidFrames !== undefined) validateUint32(options.maxSessionInvalidFrames, 'maxSessionInvalidFrames'); + if (options.maxSessionRejectedStreams !== undefined) { + validateUint32( + options.maxSessionRejectedStreams, + 'maxSessionRejectedStreams' + ); + } + // Used only with allowHTTP1 options.Http1IncomingMessage = options.Http1IncomingMessage || http.IncomingMessage; -- cgit v1.2.3