http2: improved coverage of Http2Stream destroy
Refs: https://github.com/nodejs/node/issues/14985 PR-URL: https://github.com/nodejs/node/pull/15461 Reviewed-By: Matteo Collina <matteo.collina@gmail.com> Reviewed-By: James M Snell <jasnell@gmail.com>
This commit is contained in:
parent
11f7dcf91e
commit
6c38ab34a3
41
test/parallel/test-http2-server-destroy-before-priority.js
Normal file
41
test/parallel/test-http2-server-destroy-before-priority.js
Normal file
@ -0,0 +1,41 @@
|
|||||||
|
// Flags: --expose-http2
|
||||||
|
'use strict';
|
||||||
|
|
||||||
|
const common = require('../common');
|
||||||
|
if (!common.hasCrypto)
|
||||||
|
common.skip('missing crypto');
|
||||||
|
const assert = require('assert');
|
||||||
|
const http2 = require('http2');
|
||||||
|
|
||||||
|
const server = http2.createServer();
|
||||||
|
|
||||||
|
// Test that ERR_HTTP2_INVALID_STREAM is thrown when a stream is destroyed
|
||||||
|
// before calling stream.priority
|
||||||
|
server.on('stream', common.mustCall(onStream));
|
||||||
|
|
||||||
|
function onStream(stream, headers, flags) {
|
||||||
|
stream.session.destroy();
|
||||||
|
assert.throws(() => stream.priority(),
|
||||||
|
common.expectsError({
|
||||||
|
code: 'ERR_HTTP2_INVALID_STREAM',
|
||||||
|
message: /^The stream has been destroyed$/
|
||||||
|
}));
|
||||||
|
}
|
||||||
|
|
||||||
|
server.listen(0);
|
||||||
|
|
||||||
|
server.on('listening', common.mustCall(() => {
|
||||||
|
|
||||||
|
const client = http2.connect(`http://localhost:${server.address().port}`);
|
||||||
|
|
||||||
|
const req = client.request({ ':path': '/' });
|
||||||
|
|
||||||
|
req.on('response', common.mustNotCall());
|
||||||
|
req.resume();
|
||||||
|
req.on('end', common.mustCall(() => {
|
||||||
|
server.close();
|
||||||
|
client.destroy();
|
||||||
|
}));
|
||||||
|
req.end();
|
||||||
|
|
||||||
|
}));
|
41
test/parallel/test-http2-server-destroy-before-rst.js
Normal file
41
test/parallel/test-http2-server-destroy-before-rst.js
Normal file
@ -0,0 +1,41 @@
|
|||||||
|
// Flags: --expose-http2
|
||||||
|
'use strict';
|
||||||
|
|
||||||
|
const common = require('../common');
|
||||||
|
if (!common.hasCrypto)
|
||||||
|
common.skip('missing crypto');
|
||||||
|
const assert = require('assert');
|
||||||
|
const http2 = require('http2');
|
||||||
|
|
||||||
|
const server = http2.createServer();
|
||||||
|
|
||||||
|
// Test that ERR_HTTP2_INVALID_STREAM is thrown when a stream is destroyed
|
||||||
|
// before calling stream.rstStream
|
||||||
|
server.on('stream', common.mustCall(onStream));
|
||||||
|
|
||||||
|
function onStream(stream, headers, flags) {
|
||||||
|
stream.session.destroy();
|
||||||
|
assert.throws(() => stream.rstStream(),
|
||||||
|
common.expectsError({
|
||||||
|
code: 'ERR_HTTP2_INVALID_STREAM',
|
||||||
|
message: /^The stream has been destroyed$/
|
||||||
|
}));
|
||||||
|
}
|
||||||
|
|
||||||
|
server.listen(0);
|
||||||
|
|
||||||
|
server.on('listening', common.mustCall(() => {
|
||||||
|
|
||||||
|
const client = http2.connect(`http://localhost:${server.address().port}`);
|
||||||
|
|
||||||
|
const req = client.request({ ':path': '/' });
|
||||||
|
|
||||||
|
req.on('response', common.mustNotCall());
|
||||||
|
req.resume();
|
||||||
|
req.on('end', common.mustCall(() => {
|
||||||
|
server.close();
|
||||||
|
client.destroy();
|
||||||
|
}));
|
||||||
|
req.end();
|
||||||
|
|
||||||
|
}));
|
37
test/parallel/test-http2-server-destroy-before-state.js
Normal file
37
test/parallel/test-http2-server-destroy-before-state.js
Normal file
@ -0,0 +1,37 @@
|
|||||||
|
// Flags: --expose-http2
|
||||||
|
'use strict';
|
||||||
|
|
||||||
|
const common = require('../common');
|
||||||
|
if (!common.hasCrypto)
|
||||||
|
common.skip('missing crypto');
|
||||||
|
const assert = require('assert');
|
||||||
|
const http2 = require('http2');
|
||||||
|
|
||||||
|
const server = http2.createServer();
|
||||||
|
|
||||||
|
// Test that stream.state getter returns and empty object
|
||||||
|
// if the stream session has been destroyed
|
||||||
|
server.on('stream', common.mustCall(onStream));
|
||||||
|
|
||||||
|
function onStream(stream, headers, flags) {
|
||||||
|
stream.session.destroy();
|
||||||
|
assert.deepStrictEqual(Object.create(null), stream.state);
|
||||||
|
}
|
||||||
|
|
||||||
|
server.listen(0);
|
||||||
|
|
||||||
|
server.on('listening', common.mustCall(() => {
|
||||||
|
|
||||||
|
const client = http2.connect(`http://localhost:${server.address().port}`);
|
||||||
|
|
||||||
|
const req = client.request({ ':path': '/' });
|
||||||
|
|
||||||
|
req.on('response', common.mustNotCall());
|
||||||
|
req.resume();
|
||||||
|
req.on('end', common.mustCall(() => {
|
||||||
|
server.close();
|
||||||
|
client.destroy();
|
||||||
|
}));
|
||||||
|
req.end();
|
||||||
|
|
||||||
|
}));
|
Loading…
x
Reference in New Issue
Block a user