blob: c384fdee6faf75ef3c2d394b907e6820c89b9284 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
'use strict';
const common = require('../common');
if (!common.hasCrypto)
common.skip('missing crypto');
const { readSync } = require('../common/fixtures');
const net = require('net');
const http2 = require('http2');
const { once } = require('events');
async function main() {
const blobWithEmptyFrame = readSync('emptyframe.http2');
const server = net.createServer((socket) => {
socket.once('data', () => {
socket.end(blobWithEmptyFrame);
});
}).listen(0);
await once(server, 'listening');
for (const maxSessionInvalidFrames of [0, 2]) {
const client = http2.connect(`http://localhost:${server.address().port}`, {
maxSessionInvalidFrames
});
const stream = client.request({
':method': 'GET',
':path': '/'
});
if (maxSessionInvalidFrames) {
stream.on('error', common.mustNotCall());
client.on('error', common.mustNotCall());
} else {
const expected = {
code: 'ERR_HTTP2_TOO_MANY_INVALID_FRAMES',
message: 'Too many invalid HTTP/2 frames'
};
stream.on('error', common.expectsError(expected));
client.on('error', common.expectsError(expected));
}
stream.resume();
await new Promise((resolve) => {
stream.once('close', resolve);
});
client.close();
}
server.close();
}
main().then(common.mustCall());
|
