From: Jérôme Benoit Date: Thu, 10 Jul 2025 14:36:54 +0000 (+0200) Subject: test: refine pool destroy time expectation X-Git-Tag: v5.0.7~1 X-Git-Url: https://git.piment-noir.org/?a=commitdiff_plain;h=e5a1ff94fd11b014790b71348228e04a36398a75;p=poolifier.git test: refine pool destroy time expectation Signed-off-by: Jérôme Benoit --- 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 ) })