X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fabstract-worker-choice-strategy.ts;h=2b40f0c6de497a630808fbffe6a9ec3f59039e91;hb=3d84cdaec91dfe96a82462c902bead4067b452d2;hp=3618944c2043a07b1e8e709aa877d831b2bfc76b;hpb=ded253e27e59ae936fe91d789d8454b7eb11dd6a;p=poolifier.git diff --git a/src/pools/selection-strategies/abstract-worker-choice-strategy.ts b/src/pools/selection-strategies/abstract-worker-choice-strategy.ts index 3618944c..2b40f0c6 100644 --- a/src/pools/selection-strategies/abstract-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/abstract-worker-choice-strategy.ts @@ -1,16 +1,16 @@ import type { IPool } from '../pool.js' -import { - buildWorkerChoiceStrategyOptions, - DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS -} from '../utils.js' +import { DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS } from '../utils.js' import type { IWorker } from '../worker.js' import type { IWorkerChoiceStrategy, - MeasurementStatisticsRequirements, StrategyPolicy, TaskStatisticsRequirements, WorkerChoiceStrategyOptions } from './selection-strategies-types.js' +import { + buildWorkerChoiceStrategyOptions, + toggleMedianMeasurementStatisticsRequirements +} from './selection-strategies-utils.js' /** * Worker choice strategy abstract base class. @@ -64,37 +64,23 @@ export abstract class AbstractWorkerChoiceStrategy< protected setTaskStatisticsRequirements ( opts: WorkerChoiceStrategyOptions | undefined ): void { - this.toggleMedianMeasurementStatisticsRequirements( + toggleMedianMeasurementStatisticsRequirements( this.taskStatisticsRequirements.runTime, // eslint-disable-next-line @typescript-eslint/no-non-null-assertion opts!.runTime!.median ) - this.toggleMedianMeasurementStatisticsRequirements( + toggleMedianMeasurementStatisticsRequirements( this.taskStatisticsRequirements.waitTime, // eslint-disable-next-line @typescript-eslint/no-non-null-assertion opts!.waitTime!.median ) - this.toggleMedianMeasurementStatisticsRequirements( + toggleMedianMeasurementStatisticsRequirements( this.taskStatisticsRequirements.elu, // eslint-disable-next-line @typescript-eslint/no-non-null-assertion opts!.elu!.median ) } - private toggleMedianMeasurementStatisticsRequirements ( - measurementStatisticsRequirements: MeasurementStatisticsRequirements, - toggleMedian: boolean - ): void { - if (measurementStatisticsRequirements.average && toggleMedian) { - measurementStatisticsRequirements.average = false - measurementStatisticsRequirements.median = toggleMedian - } - if (measurementStatisticsRequirements.median && !toggleMedian) { - measurementStatisticsRequirements.average = true - measurementStatisticsRequirements.median = toggleMedian - } - } - protected resetWorkerNodeKeyProperties (): void { this.nextWorkerNodeKey = 0 this.previousWorkerNodeKey = 0 @@ -147,7 +133,7 @@ export abstract class AbstractWorkerChoiceStrategy< /** * Gets the worker node task runtime. * If the task statistics require the average runtime, the average runtime is returned. - * If the task statistics require the median runtime , the median runtime is returned. + * If the task statistics require the median runtime, the median runtime is returned. * * @param workerNodeKey - The worker node key. * @returns The worker node task runtime.