aboutsummaryrefslogtreecommitdiff
path: root/test/parallel/test-http2-server-socket-destroy.js
diff options
context:
space:
mode:
authorJames M Snell <jasnell@gmail.com>2017-07-17 10:29:42 -0700
committerJames M Snell <jasnell@gmail.com>2017-08-04 12:55:58 -0700
commitb1e055696fbcd4b8829630d0be787cfc74fe913b (patch)
treed0d5be3a2e46ff5a38e139eb519e3aa5322a2d71 /test/parallel/test-http2-server-socket-destroy.js
parente71e71b5138c3dfee080f4215dd957dc7a6cbdaf (diff)
downloadandroid-node-v8-b1e055696fbcd4b8829630d0be787cfc74fe913b.tar.gz
android-node-v8-b1e055696fbcd4b8829630d0be787cfc74fe913b.tar.bz2
android-node-v8-b1e055696fbcd4b8829630d0be787cfc74fe913b.zip
http2: add tests and benchmarks
PR-URL: https://github.com/nodejs/node/pull/14239 Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Colin Ihrig <cjihrig@gmail.com> Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Diffstat (limited to 'test/parallel/test-http2-server-socket-destroy.js')
-rw-r--r--test/parallel/test-http2-server-socket-destroy.js57
1 files changed, 57 insertions, 0 deletions
diff --git a/test/parallel/test-http2-server-socket-destroy.js b/test/parallel/test-http2-server-socket-destroy.js
new file mode 100644
index 0000000000..c10bbd0ccb
--- /dev/null
+++ b/test/parallel/test-http2-server-socket-destroy.js
@@ -0,0 +1,57 @@
+// Flags: --expose-http2
+'use strict';
+
+const common = require('../common');
+const h2 = require('http2');
+const assert = require('assert');
+
+const {
+ HTTP2_HEADER_METHOD,
+ HTTP2_HEADER_PATH,
+ HTTP2_METHOD_POST
+} = h2.constants;
+
+const server = h2.createServer();
+
+// we use the lower-level API here
+server.on('stream', common.mustCall(onStream));
+
+function onStream(stream) {
+ stream.respond({
+ 'content-type': 'text/html',
+ ':status': 200
+ });
+ stream.write('test');
+
+ const socket = stream.session.socket;
+
+ // When the socket is destroyed, the close events must be triggered
+ // on the socket, server and session.
+ socket.on('close', common.mustCall());
+ server.on('close', common.mustCall());
+ stream.session.on('close', common.mustCall(() => server.close()));
+
+ // Also, the aborted event must be triggered on the stream
+ stream.on('aborted', common.mustCall());
+
+ assert.notStrictEqual(stream.session, undefined);
+ socket.destroy();
+ assert.strictEqual(stream.session, undefined);
+}
+
+server.listen(0);
+
+server.on('listening', common.mustCall(() => {
+ const client = h2.connect(`http://localhost:${server.address().port}`);
+
+ const req = client.request({
+ [HTTP2_HEADER_PATH]: '/',
+ [HTTP2_HEADER_METHOD]: HTTP2_METHOD_POST });
+
+ req.on('aborted', common.mustCall());
+ req.on('end', common.mustCall());
+ req.on('response', common.mustCall());
+ req.on('data', common.mustCall());
+
+ client.on('close', common.mustCall());
+}));