http2: skip writeHead if stream is closed

islandryu · RafaelGSS · commit 8f3aeea6135b · 2025-05-02T17:05:59.000-03:00
Fixes: #57416 PR-URL: #57686 Reviewed-By: Luigi Pinca <luigipinca@gmail.com> Reviewed-By: Tim Perry <pimterry@gmail.com> Reviewed-By: Matteo Collina <matteo.collina@gmail.com> Reviewed-By: Rafael Gonzaga <rafael.nunu@hotmail.com> Reviewed-By: Jake Yuesong Li <jake.yuesong@gmail.com>
diff --git a/lib/internal/http2/compat.js b/lib/internal/http2/compat.js
@@ -706,7 +706,7 @@ class Http2ServerResponse extends Stream {
   writeHead(statusCode, statusMessage, headers) {
     const state = this[kState];
 
-    if (state.closed || this.stream.destroyed)
+    if (state.closed || this.stream.destroyed || this.stream.closed)
       return this;
     if (this[kStream].headersSent)
       throw new ERR_HTTP2_HEADERS_SENT();
diff --git a/test/parallel/test-http2-compat-write-head-after-close.js b/test/parallel/test-http2-compat-write-head-after-close.js
@@ -0,0 +1,23 @@
+'use strict';
+
+const common = require('../common');
+if (!common.hasCrypto) { common.skip('missing crypto'); };
+const h2 = require('http2');
+
+const server = h2.createServer((req, res) => {
+  const stream = req.stream;
+  stream.close();
+  res.writeHead(200, { 'content-type': 'text/plain' });
+});
+
+server.listen(0, common.mustCall(() => {
+  const port = server.address().port;
+  const client = h2.connect(`http://localhost:${port}`);
+  const req = client.request({ ':path': '/' });
+  req.on('response', common.mustNotCall('head after close should not be sent'));
+  req.on('end', common.mustCall(() => {
+    client.close();
+    server.close();
+  }));
+  req.end();
+}));
