+
+ this.updateRunTimeWorkerUsage(workerUsage, message)
+ this.updateWaitTimeWorkerUsage(workerUsage, message)
+ this.updateEluWorkerUsage(workerUsage, message)
+ }
+
+ private updateRunTimeWorkerUsage (
+ workerUsage: WorkerUsage,
+ message: MessageValue<Response>
+ ): void {
+ if (this.workerChoiceStrategyContext.getTaskStatistics().runTime) {
+ workerUsage.runTime.aggregation += message.taskPerformance?.runTime ?? 0
+ if (
+ this.workerChoiceStrategyContext.getTaskStatistics().avgRunTime &&
+ workerUsage.tasks.executed !== 0
+ ) {
+ workerUsage.runTime.average =
+ workerUsage.runTime.aggregation / workerUsage.tasks.executed
+ }
+ if (
+ this.workerChoiceStrategyContext.getTaskStatistics().medRunTime &&
+ message.taskPerformance?.runTime != null
+ ) {
+ workerUsage.runTime.history.push(message.taskPerformance.runTime)
+ workerUsage.runTime.median = median(workerUsage.runTime.history)
+ }
+ }
+ }
+
+ private updateWaitTimeWorkerUsage (
+ workerUsage: WorkerUsage,
+ message: MessageValue<Response>
+ ): void {
+ if (this.workerChoiceStrategyContext.getTaskStatistics().waitTime) {
+ workerUsage.waitTime.aggregation += message.taskPerformance?.waitTime ?? 0
+ if (
+ this.workerChoiceStrategyContext.getTaskStatistics().avgWaitTime &&
+ workerUsage.tasks.executed !== 0
+ ) {
+ workerUsage.waitTime.average =
+ workerUsage.waitTime.aggregation / workerUsage.tasks.executed
+ }