summaryrefslogtreecommitdiff
path: root/test/parallel/test-http2-client-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-client-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-client-destroy.js')
-rw-r--r--test/parallel/test-http2-client-destroy.js54
1 files changed, 54 insertions, 0 deletions
diff --git a/test/parallel/test-http2-client-destroy.js b/test/parallel/test-http2-client-destroy.js
new file mode 100644
index 0000000000..56cfec5d65
--- /dev/null
+++ b/test/parallel/test-http2-client-destroy.js
@@ -0,0 +1,54 @@
+// Flags: --expose-http2
+'use strict';
+
+const common = require('../common');
+const assert = require('assert');
+const h2 = require('http2');
+
+const server = h2.createServer();
+server.listen(0);
+
+server.on('listening', common.mustCall(function() {
+ const port = this.address().port;
+
+ const destroyCallbacks = [
+ (client) => client.destroy(),
+ (client) => client.socket.destroy()
+ ];
+
+ let remaining = destroyCallbacks.length;
+
+ destroyCallbacks.forEach((destroyCallback) => {
+ const client = h2.connect(`http://localhost:${port}`);
+ client.on('connect', common.mustCall(() => {
+ const socket = client.socket;
+
+ assert(client.socket, 'client session has associated socket');
+ assert(!client.destroyed,
+ 'client has not been destroyed before destroy is called');
+ assert(!socket.destroyed,
+ 'socket has not been destroyed before destroy is called');
+
+ // Ensure that 'close' event is emitted
+ client.on('close', common.mustCall());
+
+ destroyCallback(client);
+
+ assert(!client.socket, 'client.socket undefined after destroy is called');
+
+ // Must must be closed
+ client.on('close', common.mustCall(() => {
+ assert(client.destroyed);
+ }));
+
+ // socket will close on process.nextTick
+ socket.on('close', common.mustCall(() => {
+ assert(socket.destroyed);
+ }));
+
+ if (--remaining === 0) {
+ server.close();
+ }
+ }));
+ });
+}));