From bf4ef2cab6fb0dc722f5b5b9deed78c3e27258db Mon Sep 17 00:00:00 2001 From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= Date: Fri, 7 Jul 2023 20:00:55 +0200 Subject: [PATCH] refactor: cleanups MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit Signed-off-by: Jérôme Benoit --- src/pools/abstract-pool.ts | 2 +- src/pools/worker-node.ts | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts index 48d0ed9a..d6cbf8f2 100644 --- a/src/pools/abstract-pool.ts +++ b/src/pools/abstract-pool.ts @@ -982,7 +982,7 @@ export abstract class AbstractPool< // Worker started message received const worker = this.getWorkerById(message.workerId as number) if (worker != null) { - this.workerNodes[this.getWorkerNodeKey(worker)].info.started = + this.getWorkerInfo(this.getWorkerNodeKey(worker)).started = message.started as boolean } else { throw new Error( diff --git a/src/pools/worker-node.ts b/src/pools/worker-node.ts index a493b65d..eb2085bc 100644 --- a/src/pools/worker-node.ts +++ b/src/pools/worker-node.ts @@ -70,7 +70,7 @@ implements IWorkerNode { const getTasksQueueSize = (): number => { return this.tasksQueueSize() } - const getTasksMaxQueueSize = (): number => { + const getTasksQueueMaxSize = (): number => { return this.tasksQueueMaxSize() } return { @@ -81,7 +81,7 @@ implements IWorkerNode { return getTasksQueueSize() }, get maxQueued (): number { - return getTasksMaxQueueSize() + return getTasksQueueMaxSize() }, failed: 0 }, -- 2.34.1