repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge pull request #758 from poolifier/waittime
[poolifier.git]
/
src
/
pools
/
abstract-pool.ts
diff --git
a/src/pools/abstract-pool.ts
b/src/pools/abstract-pool.ts
index 2e769fc9c2660305bbbb84ab370468e7d4326da0..724785f534b6a4c3b971d97aad8b7d7d598de666 100644
(file)
--- a/
src/pools/abstract-pool.ts
+++ b/
src/pools/abstract-pool.ts
@@
-430,13
+430,21
@@
export abstract class AbstractPool<
worker: Worker,
message: MessageValue<Response>
): void {
worker: Worker,
message: MessageValue<Response>
): void {
- const worker
NodeKey = this.getWorkerNodeKey(worker)
-
const workerTasksUsage = this.workerNodes[workerNodeKey
].tasksUsage
+ const worker
TasksUsage =
+
this.workerNodes[this.getWorkerNodeKey(worker)
].tasksUsage
--workerTasksUsage.running
++workerTasksUsage.run
if (message.error != null) {
++workerTasksUsage.error
}
--workerTasksUsage.running
++workerTasksUsage.run
if (message.error != null) {
++workerTasksUsage.error
}
+ this.updateRunTimeTasksUsage(workerTasksUsage, message)
+ this.updateWaitTasksUsage(workerTasksUsage, message)
+ }
+
+ private updateRunTimeTasksUsage (
+ workerTasksUsage: TasksUsage,
+ message: MessageValue<Response>
+ ): void {
if (this.workerChoiceStrategyContext.getRequiredStatistics().runTime) {
workerTasksUsage.runTime += message.runTime ?? 0
if (
if (this.workerChoiceStrategyContext.getRequiredStatistics().runTime) {
workerTasksUsage.runTime += message.runTime ?? 0
if (
@@
-454,6
+462,12
@@
export abstract class AbstractPool<
workerTasksUsage.medRunTime = median(workerTasksUsage.runTimeHistory)
}
}
workerTasksUsage.medRunTime = median(workerTasksUsage.runTimeHistory)
}
}
+ }
+
+ private updateWaitTasksUsage (
+ workerTasksUsage: TasksUsage,
+ message: MessageValue<Response>
+ ): void {
if (this.workerChoiceStrategyContext.getRequiredStatistics().waitTime) {
workerTasksUsage.waitTime += message.waitTime ?? 0
if (
if (this.workerChoiceStrategyContext.getRequiredStatistics().waitTime) {
workerTasksUsage.waitTime += message.waitTime ?? 0
if (