Lines Matching refs:worker
112 const worker = fork(process.argv[1],
118 workers[worker.pid] = worker;
120 worker.messagesReceived = [];
121 worker.messagesNeeded = messagesNeeded;
124 worker.on('exit', (code) => {
125 // Don't consider this a true death if the worker has finished
127 if (worker.isDone || code === 0) {
133 worker.pid,
147 worker.on('message', (msg) => {
156 worker.messagesReceived.push(msg.message);
158 if (worker.messagesReceived.length === worker.messagesNeeded.length) {
160 worker.isDone = true;
162 worker.pid,
163 worker.messagesReceived.length);
172 const worker = workers[pid];
176 worker.messagesReceived.forEach((buf) => {
177 for (let i = 0; i < worker.messagesNeeded.length; ++i) {
178 if (buf.toString() === worker.messagesNeeded[i]) {
186 worker.pid,
189 assert.strictEqual(count, worker.messagesNeeded.length,
190 'A worker received ' +