Lines Matching refs:worker
40 const worker = fork(__filename, ['child']);
41 workers[worker.pid] = worker;
43 worker.messagesReceived = [];
46 worker.on('exit', function(code) {
47 // Don't consider this the true death if the worker has finished
49 if (worker.isDone || code === 0) {
55 worker.pid,
66 worker.on('message', function(msg) {
77 worker.messagesReceived.push(msg.message);
79 if (worker.messagesReceived.length === messages.length) {
81 worker.isDone = true;
83 worker.pid,
84 worker.messagesReceived.length);
92 const worker = workers[pid];
96 worker.messagesReceived.forEach(function(buf) {
106 worker.pid, count);