ikan Uploader :
Directory : /home/ubuntu/node-v16.18.1/test/parallel/
Upload File : |
| Current File : //home/ubuntu/node-v16.18.1/test/parallel/test-inspector-workers-flat-list.js |
'use strict';
const common = require('../common');
common.skipIfInspectorDisabled();
const { Worker, isMainThread, parentPort, workerData } =
require('worker_threads');
if (isMainThread || workerData !== 'launched by test') {
common.skipIfWorker();
}
const { Session } = require('inspector');
const MAX_DEPTH = 3;
let rootWorker = null;
const runTest = common.mustCall(function() {
let reportedWorkersCount = 0;
const session = new Session();
session.connect();
session.on('NodeWorker.attachedToWorker', common.mustCall(
({ params: { workerInfo } }) => {
console.log(`Worker ${workerInfo.title} was reported`);
if (++reportedWorkersCount === MAX_DEPTH) {
rootWorker.postMessage({ done: true });
}
}, MAX_DEPTH));
session.post('NodeWorker.enable', { waitForDebuggerOnStart: false });
});
function processMessage({ child }) {
console.log(`Worker ${child} is running`);
if (child === MAX_DEPTH) {
runTest();
}
}
function workerCallback(message) {
parentPort.postMessage(message);
}
function startWorker(depth, messageCallback) {
const worker = new Worker(__filename, { workerData: 'launched by test' });
worker.on('message', messageCallback);
worker.postMessage({ depth });
return worker;
}
function runMainThread() {
rootWorker = startWorker(1, processMessage);
}
function runChildWorkerThread() {
let worker = null;
parentPort.on('message', ({ child, depth, done }) => {
if (done) {
if (worker) {
worker.postMessage({ done: true });
}
parentPort.close();
} else if (depth) {
parentPort.postMessage({ child: depth });
if (depth < MAX_DEPTH) {
worker = startWorker(depth + 1, workerCallback);
}
} else if (child) {
parentPort.postMessage({ child });
}
});
}
if (isMainThread) {
runMainThread();
} else {
runChildWorkerThread();
}
Kontol Shell Bypass