]> Piment Noir Git Repositories - poolifier.git/commitdiff
fix: ensure worker kill message response is not handled by the generic master
authorJérôme Benoit <jerome.benoit@piment-noir.org>
Mon, 7 Jul 2025 19:31:38 +0000 (21:31 +0200)
committerJérôme Benoit <jerome.benoit@piment-noir.org>
Mon, 7 Jul 2025 19:31:38 +0000 (21:31 +0200)
listener

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
src/pools/abstract-pool.ts

index 43b1a1d6019000c73a8bc263a3672e3bf1eee809..59aab397867d975f62d3fafb2b9608ec2f5ce32a 100644 (file)
@@ -1331,6 +1331,9 @@ export abstract class AbstractPool<
   protected readonly workerMessageListener = (
     message: MessageValue<Response>
   ): void => {
+    if (message.kill != null) {
+      return
+    }
     this.checkMessageWorkerId(message)
     const { ready, taskFunctionsProperties, taskId, workerId } = message
     if (ready != null && taskFunctionsProperties != null) {