Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/nodejs/node.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
path: root/test
diff options
context:
space:
mode:
authorLuigi Pinca <luigipinca@gmail.com>2018-11-30 21:27:26 +0300
committerMyles Borins <mylesborins@google.com>2018-12-06 00:46:15 +0300
commitfb99a4e9fafc5d9674f629deead3f7dacbe41ace (patch)
treeec0781a7e6382d07cc4d903a54e4aaf24c81fc4d /test
parent4035ca16c512eac0c58fbb0ba0053b52cd91e437 (diff)
http: destroy the socket on parse error
Destroy the socket if the `'clientError'` event is emitted and there is no listener for it. Fixes: https://github.com/nodejs/node/issues/24586 PR-URL: https://github.com/nodejs/node/pull/24757 Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Matteo Collina <matteo.collina@gmail.com> Reviewed-By: Ruben Bridgewater <ruben@bridgewater.de>
Diffstat (limited to 'test')
-rw-r--r--test/parallel/test-http-server-destroy-socket-on-client-error.js45
1 files changed, 45 insertions, 0 deletions
diff --git a/test/parallel/test-http-server-destroy-socket-on-client-error.js b/test/parallel/test-http-server-destroy-socket-on-client-error.js
new file mode 100644
index 00000000000..9d513641833
--- /dev/null
+++ b/test/parallel/test-http-server-destroy-socket-on-client-error.js
@@ -0,0 +1,45 @@
+'use strict';
+
+const { expectsError, mustCall } = require('../common');
+
+// Test that the request socket is destroyed if the `'clientError'` event is
+// emitted and there is no listener for it.
+
+const assert = require('assert');
+const { createServer } = require('http');
+const { createConnection } = require('net');
+
+const server = createServer();
+
+server.on('connection', mustCall((socket) => {
+ socket.on('error', expectsError({
+ type: Error,
+ message: 'Parse Error',
+ code: 'HPE_INVALID_METHOD',
+ bytesParsed: 0,
+ rawPacket: Buffer.from('FOO /\r\n')
+ }));
+}));
+
+server.listen(0, () => {
+ const chunks = [];
+ const socket = createConnection({
+ allowHalfOpen: true,
+ port: server.address().port
+ });
+
+ socket.on('connect', mustCall(() => {
+ socket.write('FOO /\r\n');
+ }));
+
+ socket.on('data', (chunk) => {
+ chunks.push(chunk);
+ });
+
+ socket.on('end', mustCall(() => {
+ const expected = Buffer.from('HTTP/1.1 400 Bad Request\r\n\r\n');
+ assert(Buffer.concat(chunks).equals(expected));
+
+ server.close();
+ }));
+});