workerChoiceStrategy
).previousWorkerNodeKey
).toBe(0)
- if (workerChoiceStrategy === WorkerChoiceStrategies.FAIR_SHARE) {
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp
- ).toBeInstanceOf(Array)
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp.length
- ).toBe(0)
- } else if (
+ if (
workerChoiceStrategy === WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
) {
expect(
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
workerChoiceStrategy
- ).workerVirtualTaskRunTime
+ ).workerNodeVirtualTaskRunTime
).toBe(0)
} else if (
workerChoiceStrategy ===
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
workerChoiceStrategy
- ).workerVirtualTaskRunTime
+ ).workerNodeVirtualTaskRunTime
).toBe(0)
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
max * maxMultiplier
)
}
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).nextWorkerNodeKey
+ ).toEqual(expect.any(Number))
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).previousWorkerNodeKey
+ ).toEqual(expect.any(Number))
// We need to clean up the resources after our test
await pool.destroy()
})
max * maxMultiplier
)
}
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).nextWorkerNodeKey
+ ).toEqual(expect.any(Number))
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).previousWorkerNodeKey
+ ).toEqual(expect.any(Number))
// We need to clean up the resources after our test
await pool.destroy()
})
expect(workerNode.usage.waitTime.aggregate).toBeGreaterThan(0)
}
}
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).nextWorkerNodeKey
+ ).toEqual(expect.any(Number))
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).previousWorkerNodeKey
+ ).toEqual(expect.any(Number))
// We need to clean up the resources after our test
await pool.destroy()
})
expect(workerNode.usage.waitTime.aggregate).toBeGreaterThan(0)
}
}
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).nextWorkerNodeKey
+ ).toEqual(expect.any(Number))
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).previousWorkerNodeKey
+ ).toEqual(expect.any(Number))
// We need to clean up the resources after our test
await pool.destroy()
})
expect(workerNode.usage.elu.utilization).toBeLessThanOrEqual(1)
}
}
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).nextWorkerNodeKey
+ ).toEqual(expect.any(Number))
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).previousWorkerNodeKey
+ ).toEqual(expect.any(Number))
// We need to clean up the resources after our test
await pool.destroy()
})
expect(workerNode.usage.elu.utilization).toBeLessThanOrEqual(1)
}
}
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).nextWorkerNodeKey
+ ).toEqual(expect.any(Number))
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).previousWorkerNodeKey
+ ).toEqual(expect.any(Number))
// We need to clean up the resources after our test
await pool.destroy()
})
expect(workerNode.usage.elu.utilization).toBeGreaterThanOrEqual(0)
expect(workerNode.usage.elu.utilization).toBeLessThanOrEqual(1)
}
+ expect(workerNode.strategyData.virtualTaskEndTimestamp).toBeGreaterThan(0)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
pool.workerChoiceStrategyContext.workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp.length
- ).toBe(pool.workerNodes.length)
+ ).nextWorkerNodeKey
+ ).toEqual(expect.any(Number))
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).previousWorkerNodeKey
+ ).toEqual(expect.any(Number))
// We need to clean up the resources after our test
await pool.destroy()
})
expect(workerNode.usage.elu.utilization).toBeGreaterThanOrEqual(0)
expect(workerNode.usage.elu.utilization).toBeLessThanOrEqual(1)
}
+ expect(workerNode.strategyData.virtualTaskEndTimestamp).toBeGreaterThan(0)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
pool.workerChoiceStrategyContext.workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp.length
- ).toBe(pool.workerNodes.length)
+ ).nextWorkerNodeKey
+ ).toEqual(expect.any(Number))
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).previousWorkerNodeKey
+ ).toEqual(expect.any(Number))
// We need to clean up the resources after our test
await pool.destroy()
})
expect(workerNode.usage.elu.utilization).toBeGreaterThanOrEqual(0)
expect(workerNode.usage.elu.utilization).toBeLessThanOrEqual(1)
}
+ expect(workerNode.strategyData.virtualTaskEndTimestamp).toBeGreaterThan(0)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
pool.workerChoiceStrategyContext.workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp.length
- ).toBe(pool.workerNodes.length)
+ ).nextWorkerNodeKey
+ ).toEqual(expect.any(Number))
+ expect(
+ pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
+ pool.workerChoiceStrategyContext.workerChoiceStrategy
+ ).previousWorkerNodeKey
+ ).toEqual(expect.any(Number))
// We need to clean up the resources after our test
await pool.destroy()
})
max,
'./tests/worker-files/thread/testWorker.js'
)
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp
- ).toBeInstanceOf(Array)
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp.length
- ).toBe(0)
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp[0] = performance.now()
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp.length
- ).toBe(1)
+ for (const workerNode of pool.workerNodes) {
+ workerNode.strategyData = {
+ virtualTaskEndTimestamp: performance.now()
+ }
+ }
pool.setWorkerChoiceStrategy(workerChoiceStrategy)
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- pool.workerChoiceStrategyContext.workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp
- ).toBeInstanceOf(Array)
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- pool.workerChoiceStrategyContext.workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp.length
- ).toBe(0)
+ for (const workerNode of pool.workerNodes) {
+ expect(workerNode.strategyData.virtualTaskEndTimestamp).toBeUndefined()
+ }
await pool.destroy()
pool = new DynamicThreadPool(
min,
max,
'./tests/worker-files/thread/testWorker.js'
)
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp
- ).toBeInstanceOf(Array)
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp.length
- ).toBe(0)
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp[0] = performance.now()
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp.length
- ).toBe(1)
+ for (const workerNode of pool.workerNodes) {
+ workerNode.strategyData = {
+ virtualTaskEndTimestamp: performance.now()
+ }
+ }
pool.setWorkerChoiceStrategy(workerChoiceStrategy)
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- pool.workerChoiceStrategyContext.workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp
- ).toBeInstanceOf(Array)
- expect(
- pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
- pool.workerChoiceStrategyContext.workerChoiceStrategy
- ).workersVirtualTaskEndTimestamp.length
- ).toBe(0)
+ for (const workerNode of pool.workerNodes) {
+ expect(workerNode.strategyData.virtualTaskEndTimestamp).toBeUndefined()
+ }
// We need to clean up the resources after our test
await pool.destroy()
})
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
pool.workerChoiceStrategyContext.workerChoiceStrategy
- ).workerVirtualTaskRunTime
+ ).workerNodeVirtualTaskRunTime
).toBeGreaterThanOrEqual(0)
// We need to clean up the resources after our test
await pool.destroy()
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
pool.workerChoiceStrategyContext.workerChoiceStrategy
- ).workerVirtualTaskRunTime
+ ).workerNodeVirtualTaskRunTime
).toBeGreaterThanOrEqual(0)
// We need to clean up the resources after our test
await pool.destroy()
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
pool.workerChoiceStrategyContext.workerChoiceStrategy
- ).workerVirtualTaskRunTime
+ ).workerNodeVirtualTaskRunTime
).toBeGreaterThanOrEqual(0)
// We need to clean up the resources after our test
await pool.destroy()
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
workerChoiceStrategy
- ).workerVirtualTaskRunTime
+ ).workerNodeVirtualTaskRunTime
).toBeDefined()
pool.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
pool.workerChoiceStrategyContext.workerChoiceStrategy
- ).workerVirtualTaskRunTime
+ ).workerNodeVirtualTaskRunTime
).toBe(0)
await pool.destroy()
pool = new DynamicThreadPool(
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
workerChoiceStrategy
- ).workerVirtualTaskRunTime
+ ).workerNodeVirtualTaskRunTime
).toBeDefined()
pool.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
pool.workerChoiceStrategyContext.workerChoiceStrategy
- ).workerVirtualTaskRunTime
+ ).workerNodeVirtualTaskRunTime
).toBe(0)
// We need to clean up the resources after our test
await pool.destroy()