Skip to content

Commit 4aecb7f

Browse files
committed
test: add tests for getActiveRequests and getActiveHandles
1 parent f7d15c4 commit 4aecb7f

File tree

2 files changed

+59
-0
lines changed

2 files changed

+59
-0
lines changed
Lines changed: 48 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,48 @@
1+
'use strict';
2+
3+
require('../common');
4+
const assert = require('assert');
5+
const async_hooks = require('async_hooks');
6+
const net = require('net');
7+
const NUM = 8;
8+
const connections = [];
9+
const clients = [];
10+
let clients_counter = 0;
11+
12+
const server = net.createServer(function listener(c) {
13+
connections.push(c);
14+
}).listen(0, makeConnection);
15+
16+
17+
function makeConnection() {
18+
if (clients_counter >= NUM) return;
19+
net.connect(server.address().port, function connected() {
20+
clientConnected(this);
21+
makeConnection();
22+
});
23+
}
24+
25+
26+
function clientConnected(client) {
27+
clients.push(client);
28+
if (++clients_counter >= NUM)
29+
checkAll();
30+
}
31+
32+
33+
function checkAll() {
34+
const handles = async_hooks.getActiveHandles();
35+
36+
clients.forEach(function(item) {
37+
assert.ok(handles.includes(item));
38+
item.destroy();
39+
});
40+
41+
connections.forEach(function(item) {
42+
assert.ok(handles.includes(item));
43+
item.end();
44+
});
45+
46+
assert.ok(handles.includes(server));
47+
server.close();
48+
}
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
'use strict';
2+
3+
const common = require('../common');
4+
const assert = require('assert');
5+
const fs = require('fs');
6+
const async_hooks = require('async_hooks');
7+
8+
for (let i = 0; i < 12; i++)
9+
fs.open(__filename, 'r', common.mustCall());
10+
11+
assert.strictEqual(async_hooks.getActiveRequests().length, 12);

0 commit comments

Comments
 (0)