%PDF- <> %âãÏÓ endobj 2 0 obj <> endobj 3 0 obj <>/ExtGState<>/ProcSet[/PDF/Text/ImageB/ImageC/ImageI] >>/Annots[ 28 0 R 29 0 R] /MediaBox[ 0 0 595.5 842.25] /Contents 4 0 R/Group<>/Tabs/S>> endobj ºaâÚÎΞ-ÌE1ÍØÄ÷{òò2ÿ ÛÖ^ÔÀá TÎ{¦?§®¥kuµùÕ5sLOšuY>endobj 2 0 obj<>endobj 2 0 obj<>endobj 2 0 obj<>endobj 2 0 obj<> endobj 2 0 obj<>endobj 2 0 obj<>es 3 0 R>> endobj 2 0 obj<> ox[ 0.000000 0.000000 609.600000 935.600000]/Fi endobj 3 0 obj<> endobj 7 1 obj<>/ProcSet[/PDF/Text/ImageB/ImageC/ImageI]>>/Subtype/Form>> stream
'use strict'; // Ref: https://github.com/nodejs/node/issues/32106 const common = require('../common'); const assert = require('assert'); const cluster = require('cluster'); const os = require('os'); if (cluster.isPrimary) { const workers = []; const numCPUs = os.cpus().length; let waitOnline = numCPUs; for (let i = 0; i < numCPUs; i++) { const worker = cluster.fork(); workers[i] = worker; worker.once('online', common.mustCall(() => { if (--waitOnline === 0) for (const worker of workers) if (worker.isConnected()) worker.send(i % 2 ? 'disconnect' : 'destroy'); })); // These errors can occur due to the nature of the test, we might be trying // to send messages when the worker is disconnecting. worker.on('error', (err) => { assert.strictEqual(err.syscall, 'write'); if (common.isOSX) { assert(['EPIPE', 'ENOTCONN'].includes(err.code), err); } else { assert(['EPIPE', 'ECONNRESET'].includes(err.code), err); } }); worker.once('disconnect', common.mustCall(() => { for (const worker of workers) if (worker.isConnected()) worker.send('disconnect'); })); worker.once('exit', common.mustCall((code, signal) => { assert.strictEqual(code, 0); assert.strictEqual(signal, null); })); } } else { process.on('message', (msg) => { if (cluster.worker.isConnected()) cluster.worker[msg](); }); }