X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fselection-strategies%2Fabstract-worker-choice-strategy.ts;h=efa9578d8b2f889630aadec6da595ded93cd087f;hb=ace229a1b5029d3acaeeb4e8abdab415de5318f1;hp=a4455d28a8e33c5bac1bceaf679b8feab5de533b;hpb=f6b641d651fdd5114bcd63bf1c991955d5b7d3eb;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 a4455d28..efa9578d 100644 --- a/src/pools/selection-strategies/abstract-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/abstract-worker-choice-strategy.ts @@ -27,7 +27,10 @@ export abstract class AbstractWorkerChoiceStrategy< public readonly requiredStatistics: RequiredStatistics = { runTime: false, avgRunTime: false, - medRunTime: false + medRunTime: false, + waitTime: false, + avgWaitTime: false, + medWaitTime: false } /** @@ -52,6 +55,14 @@ export abstract class AbstractWorkerChoiceStrategy< this.requiredStatistics.avgRunTime = true this.requiredStatistics.medRunTime = opts.medRunTime as boolean } + if (this.requiredStatistics.avgWaitTime && opts.medWaitTime === true) { + this.requiredStatistics.avgWaitTime = false + this.requiredStatistics.medWaitTime = opts.medWaitTime as boolean + } + if (this.requiredStatistics.medWaitTime && opts.medWaitTime === false) { + this.requiredStatistics.avgWaitTime = true + this.requiredStatistics.medWaitTime = opts.medWaitTime as boolean + } } /** @inheritDoc */ @@ -88,12 +99,12 @@ export abstract class AbstractWorkerChoiceStrategy< } /** - * Gets the worker task run time. - * If the required statistics are `avgRunTime`, the average run time is returned. - * If the required statistics are `medRunTime`, the median run time is returned. + * Gets the worker task runtime. + * If the required statistics are `avgRunTime`, the average runtime is returned. + * If the required statistics are `medRunTime`, the median runtime is returned. * * @param workerNodeKey - The worker node key. - * @returns The worker task run time. + * @returns The worker task runtime. */ protected getWorkerTaskRunTime (workerNodeKey: number): number { return this.requiredStatistics.medRunTime