Lines Matching refs:worker

46   const worker = fork(__filename, ['child']);
47   workers[worker.pid] = worker;
49   worker.messagesReceived = [];
52   worker.on('exit', function(code) {
55     if (worker.isDone || code === 0) {
61                   worker.pid,
72   worker.on('message', function(msg) {
83       worker.messagesReceived.push(msg.message);
85       if (worker.messagesReceived.length === messages.length) {
87         worker.isDone = true;
89                       worker.pid,
90                       worker.messagesReceived.length);
98           const worker = workers[pid];
102           worker.messagesReceived.forEach(function(buf) {
112                         worker.pid, count);