X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fabstract%2Fabstract-pool.test.js;h=05e4c34ea094023d61db4f0584c022af645e8c5e;hb=2dca6cabeaaf9c19cca7574deff10ef7af183a92;hp=349521d277901ca29c82881d9d8e0bb690cb1847;hpb=85c03385d4a5d06c979104ae7e96d68b2301d10a;p=poolifier.git

diff --git a/tests/pools/abstract/abstract-pool.test.js b/tests/pools/abstract/abstract-pool.test.js
index 349521d2..05e4c34e 100644
--- a/tests/pools/abstract/abstract-pool.test.js
+++ b/tests/pools/abstract/abstract-pool.test.js
@@ -432,6 +432,24 @@ describe('Abstract pool test suite', () => {
       maxQueuedTasks: 0,
       failedTasks: 0
     })
+    await waitPoolEvents(pool, PoolEvents.ready, 1)
+    expect(pool.info).toStrictEqual({
+      version,
+      type: PoolTypes.fixed,
+      worker: WorkerTypes.thread,
+      ready: true,
+      strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+      minSize: numberOfWorkers,
+      maxSize: numberOfWorkers,
+      workerNodes: numberOfWorkers,
+      idleWorkerNodes: numberOfWorkers,
+      busyWorkerNodes: 0,
+      executedTasks: 0,
+      executingTasks: 0,
+      queuedTasks: 0,
+      maxQueuedTasks: 0,
+      failedTasks: 0
+    })
     await pool.destroy()
     pool = new DynamicClusterPool(
       Math.floor(numberOfWorkers / 2),
@@ -455,6 +473,24 @@ describe('Abstract pool test suite', () => {
       maxQueuedTasks: 0,
       failedTasks: 0
     })
+    await waitPoolEvents(pool, PoolEvents.ready, 1)
+    expect(pool.info).toStrictEqual({
+      version,
+      type: PoolTypes.dynamic,
+      worker: WorkerTypes.cluster,
+      ready: true,
+      strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+      minSize: Math.floor(numberOfWorkers / 2),
+      maxSize: numberOfWorkers,
+      workerNodes: Math.floor(numberOfWorkers / 2),
+      idleWorkerNodes: Math.floor(numberOfWorkers / 2),
+      busyWorkerNodes: 0,
+      executedTasks: 0,
+      executingTasks: 0,
+      queuedTasks: 0,
+      maxQueuedTasks: 0,
+      failedTasks: 0
+    })
     await pool.destroy()
   })
 
@@ -529,6 +565,15 @@ describe('Abstract pool test suite', () => {
         ready: false
       })
     }
+    await waitPoolEvents(pool, PoolEvents.ready, 1)
+    for (const workerNode of pool.workerNodes) {
+      expect(workerNode.info).toStrictEqual({
+        id: expect.any(Number),
+        type: WorkerTypes.cluster,
+        dynamic: false,
+        ready: true
+      })
+    }
     await pool.destroy()
     pool = new DynamicThreadPool(
       Math.floor(numberOfWorkers / 2),
@@ -543,6 +588,15 @@ describe('Abstract pool test suite', () => {
         ready: false
       })
     }
+    await waitPoolEvents(pool, PoolEvents.ready, 1)
+    for (const workerNode of pool.workerNodes) {
+      expect(workerNode.info).toStrictEqual({
+        id: expect.any(Number),
+        type: WorkerTypes.thread,
+        dynamic: false,
+        ready: true
+      })
+    }
   })
 
   it('Verify that pool worker tasks usage are computed', async () => {