http: remove misleading warning

There are cases where the `'clientError'` event can be emitted multiple
times, even if the socket is correctly destroyed.

Fixes: https://github.com/nodejs/node/issues/51073
PR-URL: https://github.com/nodejs/node/pull/51204
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Reviewed-By: Paolo Insogna <paolo@cowtech.it>
This commit is contained in:
Luigi Pinca authored and GitHub committed 2023-12-21 20:09:01 +00:00
1 parent f5c95991d2
commit 30f8ef1a97
3 files changed
+56 -18

No files matched your search

-15
View File
@@ -866,27 +866,12 @@ const requestHeaderFieldsTooLargeResponse = Buffer.from(
'Connection: close\r\n\r\n', 'ascii',
);
function warnUnclosedSocket() {
if (warnUnclosedSocket.emitted) {
return;
}
warnUnclosedSocket.emitted = true;
process.emitWarning(
'An error event has already been emitted on the socket. ' +
'Please use the destroy method on the socket while handling ' +
"a 'clientError' event.",
);
}
function socketOnError(e) {
// Ignore further errors
this.removeListener('error', socketOnError);
if (this.listenerCount('error', noop) === 0) {
this.on('error', noop);
} else {
warnUnclosedSocket();
}
if (!this.server.emit('clientError', e, this)) {
@@ -0,0 +1,55 @@
'use strict';
const common = require('../common');
// Test that the `'clientError'` event can be emitted multiple times even if the
// socket is correctly destroyed and that no warning is raised.
const assert = require('assert');
const http = require('http');
const net = require('net');
process.on('warning', common.mustNotCall());
function socketListener(socket) {
const firstByte = socket.read(1);
if (firstByte === null) {
socket.once('readable', () => {
socketListener(socket);
});
return;
}
socket.unshift(firstByte);
httpServer.emit('connection', socket);
}
const netServer = net.createServer(socketListener);
const httpServer = http.createServer(common.mustNotCall());
httpServer.once('clientError', common.mustCall((err, socket) => {
assert.strictEqual(err.code, 'HPE_INVALID_METHOD');
assert.strictEqual(err.rawPacket.toString(), 'Q');
socket.destroy();
httpServer.once('clientError', common.mustCall((err) => {
assert.strictEqual(err.code, 'HPE_INVALID_METHOD');
assert.strictEqual(
err.rawPacket.toString(),
'WE http://example.com HTTP/1.1\r\n\r\n'
);
}));
}));
netServer.listen(0, common.mustCall(() => {
const socket = net.createConnection(netServer.address().port);
socket.on('connect', common.mustCall(() => {
socket.end('QWE http://example.com HTTP/1.1\r\n\r\n');
}));
socket.on('close', () => {
netServer.close();
});
socket.resume();
}));
@@ -1,5 +1,3 @@
// Flags: --no-warnings
'use strict';
const common = require('../common');
@@ -17,7 +15,7 @@ const net = require('net');
{
let i = 0;
let socket;
process.on('warning', common.mustCall());
process.on('warning', common.mustNotCall());
const server = http.createServer(common.mustNotCall());