http: add max for http keepalive

PR-URL: #44217
Reviewed-By: Robert Nagy <ronagy@icloud.com>
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>

Author: theanarkh

lib/_http_outgoing.js

@@ -463,7 +463,11 @@ function _storeHeader(firstLine, headers) {
 header+='Connection: keep-alive\r\n';
 if(this._keepAliveTimeout&&this._defaultKeepAlive){
 consttimeoutSeconds=MathFloor(this._keepAliveTimeout/1000);
-header+=`Keep-Alive: timeout=${timeoutSeconds}\r\n`;
+letmax='';
+if(~~this._maxRequestsPerSocket>0){
+max=`, max=${this._maxRequestsPerSocket}`;
+}
+header+=`Keep-Alive: timeout=${timeoutSeconds}${max}\r\n`;
 }
 }else{
 this._last=true;

lib/_http_server.js

@@ -959,6 +959,7 @@ function parserOnIncoming(server, socket, state, req, keepAlive) {
 
 constres=newserver[kServerResponse](req);
 res._keepAliveTimeout=server.keepAliveTimeout;
+res._maxRequestsPerSocket=server.maxRequestsPerSocket;
 res._onPendingData=updateOutgoingData.bind(undefined,
 socket,state);
 

test/parallel/test-http-keep-alive-max-requests.js

@@ -14,7 +14,7 @@ function assertResponse(headers, body, expectClosed) {
 assert.match(body,/HelloWorld!/m);
 }else{
 assert.match(headers,/Connection:keep-alive\r\n/m);
-assert.match(headers,/Keep-Alive:timeout=5\r\n/m);
+assert.match(headers,/Keep-Alive:timeout=5,max=3\r\n/m);
 assert.match(body,/HelloWorld!/m);
 }
 }

test/parallel/test-http-keep-alive-pipeline-max-requests.js

@@ -10,11 +10,11 @@ const bodySent = 'This is my request';
 functionassertResponse(headers,body,expectClosed){
 if(expectClosed){
 assert.match(headers,/Connection:close\r\n/m);
-assert.strictEqual(headers.search(/Keep-Alive:timeout=5\r\n/m),-1);
+assert.strictEqual(headers.search(/Keep-Alive:timeout=5,max=3\r\n/m),-1);
 assert.match(body,/HelloWorld!/m);
 }else{
 assert.match(headers,/Connection:keep-alive\r\n/m);
-assert.match(headers,/Keep-Alive:timeout=5\r\n/m);
+assert.match(headers,/Keep-Alive:timeout=5,max=3\r\n/m);
 assert.match(body,/HelloWorld!/m);
 }
 }