nodejs
diff --git a/Collapse file
‎lib/_http_server.js‎
Copy file name to clipboardExpand all lines: lib/_http_server.js
+4Lines changed: 4 additions & 0 deletions b/Collapse file
‎lib/_http_server.js‎
Copy file name to clipboardExpand all lines: lib/_http_server.js
+4Lines changed: 4 additions & 0 deletions
diff --git a/Collapse file
‎test/parallel/test-http-server-close-idle-wait-response.js‎
Copy file name to clipboard
+26Lines changed: 26 additions & 0 deletions b/Collapse file
‎test/parallel/test-http-server-close-idle-wait-response.js‎
Copy file name to clipboard
+26Lines changed: 26 additions & 0 deletions
@@ -494,6 +494,10 @@ Server.prototype.closeIdleConnections = function() {
   const connections = this[kConnections].idle();
 
   for (let i = 0, l = connections.length; i < l; i++) {
+    if (connections[i].socket._httpMessage && !connections[i].socket._httpMessage.finished) {
+      continue;
+    }
+
     connections[i].socket.destroy();
   }
 };
 
@@ -0,0 +1,26 @@
+'use strict';
+
+const common = require('../common');
+
+const { createServer, get } = require('http');
+
+const server = createServer(common.mustCall(function(req, res) {
+  req.resume();
+
+  setTimeout(common.mustCall(() => {
+    res.writeHead(204, { 'Connection': 'keep-alive', 'Keep-Alive': 'timeout=1' });
+    res.end();
+  }), common.platformTimeout(1000));
+}));
+
+server.listen(0, function() {
+  const port = server.address().port;
+
+  get(`http://localhost:${port}`, common.mustCall((res) => {
+    server.close();
+  })).on('finish', common.mustCall(() => {
+    setTimeout(common.mustCall(() => {
+      server.closeIdleConnections();
+    }), common.platformTimeout(500));
+  }));
+});