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: --test-udp-no-try-send
'use strict';
const common = require('../common');
const assert = require('assert');
const initHooks = require('./init-hooks');
const { checkInvocations } = require('./hook-checks');
const dgram = require('dgram');
const hooks = initHooks();
hooks.enable();
let send;
const sock = dgram
.createSocket('udp4')
.on('listening', common.mustCall(onlistening))
.bind();
function onlistening() {
sock.send(
Buffer.alloc(2), 0, 2, sock.address().port,
undefined, common.mustCall(onsent));
// Init not called synchronously because dns lookup always wraps
// callback in a next tick even if no lookup is needed
// TODO (trevnorris) submit patch to fix creation of tick objects and instead
// create the send wrap synchronously.
assert.strictEqual(hooks.activitiesOfTypes('UDPSENDWRAP').length, 0);
}
function onsent() {
const as = hooks.activitiesOfTypes('UDPSENDWRAP');
send = as[0];
assert.strictEqual(as.length, 1);
assert.strictEqual(send.type, 'UDPSENDWRAP');
assert.strictEqual(typeof send.uid, 'number');
assert.strictEqual(typeof send.triggerAsyncId, 'number');
checkInvocations(send, { init: 1, before: 1 }, 'when message sent');
sock.close(common.mustCall(onsockClosed));
}
function onsockClosed() {
checkInvocations(send, { init: 1, before: 1, after: 1 }, 'when sock closed');
}
process.on('exit', onexit);
function onexit() {
hooks.disable();
hooks.sanityCheck('UDPSENDWRAP');
checkInvocations(send, { init: 1, before: 1, after: 1, destroy: 1 },
'when process exits');
}
|
