21 lines
1.3 KiB
JavaScript
21 lines
1.3 KiB
JavaScript
// Controlled child for lane crash tests; no live service, network or model.
|
|
import { writeFileSync } from 'node:fs';
|
|
const [mode,marker]=process.argv.slice(2);
|
|
if(marker&&mode!=='lock-probe')writeFileSync(marker,String(process.pid));
|
|
if(mode!=='lock-probe')process.stdout.write('READY\n');
|
|
if(mode==='ignore-term')process.on('SIGTERM',()=>{});
|
|
else process.on('SIGTERM',()=>process.exit(0));
|
|
setInterval(()=>{},1000);
|
|
if(mode==='lock-probe'){
|
|
const stateRoot=marker;
|
|
const {verifyLocks,executeSteps}=await import('../../../../scripts/testing/gate-lane.mjs');
|
|
verifyLocks({lane:'a',stateRoot,exclusive:false});
|
|
const {appendRecord,identity}=await import('../../../../scripts/testing/lane-state.mjs');
|
|
const {mkdirSync}=await import('node:fs');const {join}=await import('node:path');
|
|
const out=join(stateRoot,'out');mkdirSync(out);
|
|
appendRecord(join(stateRoot,'runs','abcdef123456'),{kind:'start',lane:'a',owner:identity()});
|
|
const result=await executeSteps([{name:'fds',cwd:stateRoot,argv:[process.execPath,'-e',"const fs=require('fs'); for(const fd of fs.readdirSync('/proc/self/fd')){let p;try{p=fs.readlinkSync('/proc/self/fd/'+fd)}catch{continue}if(p.endsWith('/a.lock')||p.endsWith('/image.lock'))process.exit(7)}"]}],{out,env:process.env,record:()=>{}});
|
|
if(result.rc)process.exit(result.rc);
|
|
writeFileSync(join(stateRoot,'ready'),'verified');
|
|
}
|