http: add drop request event for http server

Author: theanarkh

doc/api/http.md

@@ -1445,6 +1445,20 @@ This event is guaranteed to be passed an instance of the {net.Socket} class,
 a subclass of {stream.Duplex}, unless the user specifies a socket
 type other than {net.Socket}.
 
+### Event: `'dropRequest'`
+
+<!-- YAML
+added: REPLACEME
+-->
+
+* `request` {http.IncomingMessage} Arguments for the HTTP request, as it is in
+  the [`'request'`][] event
+* `socket` {stream.Duplex} Network socket between the server and client
+
+When the number of requests on a socket reaches the threshold of
+`server.maxRequestsPerSocket`, the server will drop new requests
+and emit `'dropRequest'` event instead.
+
 ### `server.close([callback])`
 
 <!-- YAML

lib/_http_server.js

@@ -985,7 +985,7 @@ function parserOnIncoming(server, socket, state, req, keepAlive) {
     if (isRequestsLimitSet &&
       (server.maxRequestsPerSocket < state.requestsCount)) {
       handled = true;
-
+      server.emit('dropRequest', req, socket);
       res.writeHead(503);
       res.end();
     } else if (req.headers.expect !== undefined) {

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

@@ -0,0 +1,34 @@
+'use strict';
+
+const common = require('../common');
+const http = require('http');
+const net = require('net');
+const assert = require('assert');
+
+function request(socket) {
+  socket.write('GET / HTTP/1.1\r\n');
+  socket.write('Connection: keep-alive\r\n');
+  socket.write('\r\n\r\n');
+}
+
+const server = http.createServer(common.mustCall((req, res) => {
+  res.end('ok');
+}));
+
+server.on('dropRequest', common.mustCall((request, socket) => {
+  assert.strictEqual(request instanceof http.IncomingMessage, true);
+  assert.strictEqual(socket instanceof net.Socket, true);
+  server.close();
+}));
+
+server.listen(0, common.mustCall(() => {
+  const socket = net.connect(server.address().port);
+  socket.on('connect', common.mustCall(() => {
+    request(socket);
+    request(socket);
+  }));
+  socket.on('data', common.mustCallAtLeast());
+  socket.on('close', common.mustCall());
+}));
+
+server.maxRequestsPerSocket = 1;