X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Ffixed.ts;h=522e7b672abb09feb5700f7a854a00234889b103;hb=23a6c28d3cc6edb778653a4d9d9a4d36f9a961c3;hp=fe920f8a48126529a31dafc2d0c9f31bb4c0e4cf;hpb=4b628b4844b461e434c5945feead43b0cc7aab01;p=poolifier.git diff --git a/src/pools/cluster/fixed.ts b/src/pools/cluster/fixed.ts index fe920f8a..522e7b67 100644 --- a/src/pools/cluster/fixed.ts +++ b/src/pools/cluster/fixed.ts @@ -60,17 +60,45 @@ export class FixedClusterPool< } /** @inheritDoc */ - protected destroyWorker (worker: Worker): void { - this.sendToWorker(worker, { kill: 1 }) + protected async destroyWorkerNode (workerNodeKey: number): Promise { + this.flushTasksQueue(workerNodeKey) + // FIXME: wait for tasks to be finished + const worker = this.workerNodes[workerNodeKey].worker + const waitWorkerExit = new Promise(resolve => { + worker.on('exit', () => { + resolve() + }) + }) worker.on('disconnect', () => { worker.kill() }) + this.sendToWorker(workerNodeKey, { kill: true, workerId: worker.id }) worker.disconnect() + await waitWorkerExit + } + + /** @inheritDoc */ + protected sendToWorker ( + workerNodeKey: number, + message: MessageValue + ): void { + this.workerNodes[workerNodeKey].worker.send(message) + } + + /** @inheritDoc */ + protected sendStartupMessageToWorker (workerNodeKey: number): void { + this.sendToWorker(workerNodeKey, { + ready: false, + workerId: this.workerNodes[workerNodeKey].worker.id + }) } /** @inheritDoc */ - protected sendToWorker (worker: Worker, message: MessageValue): void { - worker.send(message) + protected registerWorkerMessageListener( + workerNodeKey: number, + listener: (message: MessageValue) => void + ): void { + this.workerNodes[workerNodeKey].worker.on('message', listener) } /** @inheritDoc */