Skip to content

Commit dcbd907

Browse files
joyeecheungrvagg
authored andcommitted
test: add test for node.async_hooks tracing in workers
PR-URL: #26062 Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Richard Lau <riclau@uk.ibm.com> Reviewed-By: James M Snell <jasnell@gmail.com>
1 parent 966546c commit dcbd907

1 file changed

Lines changed: 94 additions & 0 deletions

File tree

Lines changed: 94 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,94 @@
1+
'use strict';
2+
3+
constcommon=require('../common');
4+
if(!process.binding('config').hasTracing)
5+
common.skip('missing trace events');
6+
7+
constassert=require('assert');
8+
constcp=require('child_process');
9+
constfs=require('fs');
10+
constpath=require('path');
11+
constutil=require('util');
12+
13+
constcode=
14+
'setTimeout(() => { for (var i = 0; i < 100000; i++) { "test" + i } }, 1)';
15+
constworker=`const { Worker } = require('worker_threads');
16+
const worker = new Worker('${code}',
17+
{ eval: true, stdout: true, stderr: true });
18+
worker.stdout.on('data',
19+
(chunk) => console.log('worker', chunk.toString()));
20+
worker.stderr.on('data',
21+
(chunk) => console.error('worker', chunk.toString()));`;
22+
23+
consttmpdir=require('../common/tmpdir');
24+
constfilename=path.join(tmpdir.path,'node_trace.1.log');
25+
26+
tmpdir.refresh();
27+
constproc=cp.spawnSync(
28+
process.execPath,
29+
['--trace-event-categories','node.async_hooks','-e',worker],
30+
{
31+
cwd: tmpdir.path,
32+
env: Object.assign({},process.env,{
33+
'NODE_DEBUG_NATIVE': 'tracing',
34+
'NODE_DEBUG': 'tracing'
35+
})
36+
});
37+
38+
console.log(proc.signal);
39+
console.log(proc.stderr.toString());
40+
assert.strictEqual(proc.status,0);
41+
42+
assert(fs.existsSync(filename));
43+
constdata=fs.readFileSync(filename,'utf-8');
44+
consttraces=JSON.parse(data).traceEvents;
45+
assert(traces.length>0);
46+
// V8 trace events should be generated.
47+
assert(!traces.some((trace)=>{
48+
if(trace.pid!==proc.pid)
49+
returnfalse;
50+
if(trace.cat!=='v8')
51+
returnfalse;
52+
if(trace.name!=='V8.ScriptCompiler')
53+
returnfalse;
54+
returntrue;
55+
}));
56+
57+
// C++ async_hooks trace events should be generated.
58+
assert(traces.some((trace)=>{
59+
if(trace.pid!==proc.pid)
60+
returnfalse;
61+
if(trace.cat!=='node,node.async_hooks')
62+
returnfalse;
63+
returntrue;
64+
}));
65+
66+
// JavaScript async_hooks trace events should be generated.
67+
assert(traces.some((trace)=>{
68+
if(trace.pid!==proc.pid)
69+
returnfalse;
70+
if(trace.cat!=='node,node.async_hooks')
71+
returnfalse;
72+
if(trace.name!=='Timeout')
73+
returnfalse;
74+
returntrue;
75+
}));
76+
77+
// Check args in init events
78+
constinitEvents=traces.filter((trace)=>{
79+
return(trace.ph==='b'&&!trace.name.includes('_CALLBACK'));
80+
});
81+
82+
for(consttraceofinitEvents){
83+
if(trace.name==='MESSAGEPORT'&&
84+
trace.args.data.executionAsyncId===0&&
85+
trace.args.data.triggerAsyncId===0){
86+
continue;
87+
}
88+
if(trace.args.data.executionAsyncId>0&&
89+
trace.args.data.triggerAsyncId>0){
90+
continue;
91+
}
92+
assert.fail('Unexpected initEvent: ',
93+
util.inspect(trace,{depth: Infinity}));
94+
}

0 commit comments

Comments
 (0)