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
48
49
50
51
52
53
54
55
56
|
// Flags: --expose-internals
'use strict';
const common = require('../common');
if (!common.hasCrypto)
common.skip('missing crypto');
const assert = require('assert');
const http2 = require('http2');
const { kSocket } = require('internal/http2/util');
const server = http2.createServer();
server.on('stream', common.mustCall((stream) => {
stream.respond();
stream.end('ok');
}));
server.on('session', common.mustCall((session) => {
// First, test that the socketError event is forwarded to the session object
// and not the server object.
const handler = common.mustCall((error, socket) => {
common.expectsError({
type: Error,
message: 'test'
})(error);
assert.strictEqual(socket, session[kSocket]);
});
const isNotCalled = common.mustNotCall();
session.on('socketError', handler);
server.on('socketError', isNotCalled);
session[kSocket].emit('error', new Error('test'));
session.removeListener('socketError', handler);
server.removeListener('socketError', isNotCalled);
// Second, test that the socketError is forwarded to the server object when
// no socketError listener is registered for the session
server.on('socketError', common.mustCall((error, socket, session) => {
common.expectsError({
type: Error,
message: 'test'
})(error);
assert.strictEqual(socket, session[kSocket]);
assert.strictEqual(session, session);
}));
session[kSocket].emit('error', new Error('test'));
}));
server.listen(0, common.mustCall(() => {
const client = http2.connect(`http://localhost:${server.address().port}`);
const req = client.request();
req.resume();
req.on('end', common.mustCall());
req.on('streamClosed', common.mustCall(() => {
client.destroy();
server.close();
}));
}));
|
