X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fabstract-worker-choice-strategy.ts;h=2b40f0c6de497a630808fbffe6a9ec3f59039e91;hb=63af54001cdb7be2f14d51be593a7f96c8c480b6;hp=f244374291da55b9173129b6384b00f49d952e65;hpb=e372f3935374fbbea3a5d3acc72813b36ced86ff;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 f2443742..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 { - DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS, - buildWorkerChoiceStrategyOptions -} from '../../utils.js' import type { IPool } from '../pool.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.