Skip to content

http2: add support for AbortSignal to http2Session.request #36070

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
MadaraUchiha wants to merge 9 commits into from
Closed

http2: add support for AbortSignal to http2Session.request #36070

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
ba7f38b
http2: add support for AbortSignal to http2Session.request
MadaraUchiha Nov 10, 2020
aec2c2b
http2: Document AbortSignalSupport
MadaraUchiha Nov 10, 2020
a88f87b
http2: Fix lint errors
MadaraUchiha Nov 10, 2020
90ab360
http2: Remove redundant empty line in docs
MadaraUchiha Nov 10, 2020
2cd337e
http2: Use existing signal constant
MadaraUchiha Nov 10, 2020
05f68a2
http2: Goodify test
MadaraUchiha Nov 10, 2020
dc99724
http2: Abort calls destroy with an AbortError
MadaraUchiha Nov 19, 2020
3d5177d
http2: Update documentation
MadaraUchiha Nov 19, 2020
9aca7c4
http2: Abort immediately if passed an already aborted signal
MadaraUchiha Nov 19, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
http2: add support for AbortSignal to http2Session.request 
- Add support
- Add test
- Docs once PR is up
  • Loading branch information
@MadaraUchiha
MadaraUchiha committed Nov 21, 2020
commit ba7f38b1f376778f279b22a9a44f56c1079fe3b4
11 changes: 11 additions & 0 deletions lib/internal/http2/core.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -118,6 +118,7 @@ const {
validateNumber,
validateString,
validateUint32,
validateAbortSignal,
} = require('internal/validators');
const fsPromisesInternal = require('internal/fs/promises');
const { utcDate } = require('internal/http');
Expand Down Expand Up @@ -1721,6 +1722,16 @@ class ClientHttp2Session extends Http2Session {
if (options.waitForTrailers)
stream[kState].flags |= STREAM_FLAGS_HAS_TRAILERS;

const signal = options.signal;
if (options.signal) {
validateAbortSignal(signal, 'options.signal');
const listener = () => stream.destroy();
signal.addEventListener('abort', listener);
stream.once('close', () => {
signal.removeEventListener('abort', listener);
})
}

const onConnect = FunctionPrototypeBind(requestOnConnect,
stream, headersList, options);
if (this.connecting) {
Expand Down
29 changes: 29 additions & 0 deletions test/parallel/test-http2-client-destroy.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -167,3 +167,32 @@ const Countdown = require('../common/countdown');
req.on('close', common.mustCall(() => server.close()));
}));
}

// Destroy with AbortSignal
{
const server = h2.createServer();
const controller = new AbortController();

server.on('stream', common.mustNotCall());
server.listen(0, common.mustCall(() => {
const client = h2.connect(`http://localhost:${server.address().port}`);
client.on('close', common.mustCall());
const socket = client[kSocket];
socket.on('close', common.mustCall(() => {
assert(socket.destroyed);
}));

const req = client.request({}, { signal: controller.signal });
client.on('error', common.mustCall((err) => {
assert.strictEqual(err.code, 'ECONNREFUSED');
server.close();
}));

assert.strictEqual(req.aborted, false);
assert.strictEqual(req.destroyed, false);
controller.abort();
assert.strictEqual(req.aborted, false);
assert.strictEqual(req.destroyed, true);
req.on('close', common.mustCall(() => server.close()));
}));
}