X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fabstract-pool.ts;h=53bce7d2b7523f6a819cc5fd2dba3cbf5c84cc6a;hb=7c8381eb33aaff689afe1944d8643508003cf0b1;hp=9da566212877c60c5135f095e812035c2d086260;hpb=60664f486ce7ff5a437b52c545cf219eca5aebd2;p=poolifier.git diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts index 9da56621..53bce7d2 100644 --- a/src/pools/abstract-pool.ts +++ b/src/pools/abstract-pool.ts @@ -968,9 +968,9 @@ export abstract class AbstractPool< */ protected workerListener (): (message: MessageValue) => void { return message => { - if (message.workerId != null && message.started != null) { - // Worker started message received - this.handleWorkerStartedMessage(message) + if (message.workerId != null && message.ready != null) { + // Worker ready message received + this.handleWorkerReadyMessage(message) } else if (message.id != null) { // Task execution response received this.handleTaskExecutionResponse(message) @@ -978,14 +978,14 @@ export abstract class AbstractPool< } } - private handleWorkerStartedMessage (message: MessageValue): void { + private handleWorkerReadyMessage (message: MessageValue): void { const worker = this.getWorkerById(message.workerId as number) if (worker != null) { - this.getWorkerInfo(this.getWorkerNodeKey(worker)).started = - message.started as boolean + this.getWorkerInfo(this.getWorkerNodeKey(worker)).ready = + message.ready as boolean } else { throw new Error( - `Worker started message received from unknown worker '${ + `Worker ready message received from unknown worker '${ message.workerId as number }'` )