From e5a1ff94fd11b014790b71348228e04a36398a75 Mon Sep 17 00:00:00 2001 From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= Date: Thu, 10 Jul 2025 16:36:54 +0200 Subject: [PATCH] test: refine pool destroy time expectation MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit Signed-off-by: Jérôme Benoit --- src/queues/abstract-fixed-queue.ts | 2 +- src/queues/fixed-priority-queue.ts | 2 +- tests/pools/abstract-pool.test.mjs | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/queues/abstract-fixed-queue.ts b/src/queues/abstract-fixed-queue.ts index 54dee480e..36f178f55 100644 --- a/src/queues/abstract-fixed-queue.ts +++ b/src/queues/abstract-fixed-queue.ts @@ -55,7 +55,7 @@ export abstract class AbstractFixedQueue implements IFixedQueue { logicalIndex = i break } - currentPhysicalIndex++ + ++currentPhysicalIndex if (currentPhysicalIndex === this.capacity) { currentPhysicalIndex = 0 } diff --git a/src/queues/fixed-priority-queue.ts b/src/queues/fixed-priority-queue.ts index d7f65b5ad..35b262d6e 100644 --- a/src/queues/fixed-priority-queue.ts +++ b/src/queues/fixed-priority-queue.ts @@ -24,7 +24,7 @@ export class FixedPriorityQueue insertionPhysicalIndex = currentPhysicalIndex break } - currentPhysicalIndex++ + ++currentPhysicalIndex if (currentPhysicalIndex === this.capacity) { currentPhysicalIndex = 0 } diff --git a/tests/pools/abstract-pool.test.mjs b/tests/pools/abstract-pool.test.mjs index 99fceb448..210ac186e 100644 --- a/tests/pools/abstract-pool.test.mjs +++ b/tests/pools/abstract-pool.test.mjs @@ -1449,7 +1449,7 @@ describe('Abstract pool test suite', () => { expect(elapsedTime).toBeGreaterThanOrEqual(2000) // Worker kill message response timeout is 1000ms expect(elapsedTime).toBeLessThanOrEqual( - tasksFinishedTimeout + 1000 * tasksFinished + 800 + tasksFinishedTimeout + 1000 * tasksFinished + 1000 ) }) @@ -1480,7 +1480,7 @@ describe('Abstract pool test suite', () => { expect(tasksFinished).toBe(0) // Worker kill message response timeout is 1000ms expect(elapsedTime).toBeLessThanOrEqual( - tasksFinishedTimeout + 1000 * tasksFinished + 800 + tasksFinishedTimeout + 1000 * tasksFinished + 1000 ) }) -- 2.43.0