(worker, message)
| 261 | } |
| 262 | |
| 263 | function exitedAfterDisconnect(worker, message) { |
| 264 | worker.exitedAfterDisconnect = true; |
| 265 | send(worker, { ack: message.seq }); |
| 266 | } |
| 267 | |
| 268 | function queryServer(worker, message) { |
| 269 | // Stop processing if worker already disconnecting |