X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Ffair-share-worker-choice-strategy.ts;h=357b770a1f3eec275e87e8d7702ed42a8fd26bbd;hb=c4d1efd35b3963f0e251df2b220a850d7afa8a69;hp=58982f192ee457865e46115203b9509bdc24e29d;hpb=39618ede0e08d380c1ac82005bcc2ab1f3c227b6;p=poolifier.git diff --git a/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts b/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts index 58982f19..357b770a 100644 --- a/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts @@ -1,4 +1,3 @@ -import { DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS } from '../../utils.js' import type { IPool } from '../pool.js' import type { IWorker } from '../worker.js' import { AbstractWorkerChoiceStrategy } from './abstract-worker-choice-strategy.js' @@ -31,7 +30,11 @@ export class FairShareWorkerChoiceStrategy< average: true, median: false }, - waitTime: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS, + waitTime: { + aggregate: true, + average: true, + median: false + }, elu: { aggregate: true, average: true, @@ -117,12 +120,13 @@ export class FairShareWorkerChoiceStrategy< workerNodeKey: number, workerNodeVirtualTaskStartTimestamp: number ): number { - const workerNodeTaskRunTime = + const workerNodeTaskExecutionTime = + this.getWorkerNodeTaskWaitTime(workerNodeKey) + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion - this.opts!.measurement === Measurements.elu + (this.opts!.measurement === Measurements.elu ? this.getWorkerNodeTaskElu(workerNodeKey) - : this.getWorkerNodeTaskRunTime(workerNodeKey) - return workerNodeVirtualTaskStartTimestamp + workerNodeTaskRunTime + : this.getWorkerNodeTaskRunTime(workerNodeKey)) + return workerNodeVirtualTaskStartTimestamp + workerNodeTaskExecutionTime } private getWorkerNodeVirtualTaskStartTimestamp (