Repository: ignite Updated Branches: refs/heads/ignite-zk-ce cbe9980b4 -> ed492a4f3
IGNITE-5731: curWaitingJobs and avgJobWaitTime calculation fixed Signed-off-by: Andrey Gura <ag...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/321ba606 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/321ba606 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/321ba606 Branch: refs/heads/ignite-zk-ce Commit: 321ba6063306ec1271258b47dd0236a1f07a3e77 Parents: d4233dc Author: Denis Loginov <da.logi...@jet.msk.su> Authored: Mon Dec 11 16:16:07 2017 +0300 Committer: Andrey Gura <ag...@apache.org> Committed: Mon Dec 11 16:16:07 2017 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/internal/ClusterMetricsSnapshot.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/321ba606/modules/core/src/main/java/org/apache/ignite/internal/ClusterMetricsSnapshot.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/ClusterMetricsSnapshot.java b/modules/core/src/main/java/org/apache/ignite/internal/ClusterMetricsSnapshot.java index 5f29167..60f26a3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/ClusterMetricsSnapshot.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/ClusterMetricsSnapshot.java @@ -353,7 +353,7 @@ public class ClusterMetricsSnapshot implements ClusterMetrics { maxRejectedJobs = max(maxRejectedJobs, m.getCurrentRejectedJobs()); avgRejectedJobs += m.getCurrentRejectedJobs(); - curWaitingJobs += m.getCurrentJobWaitTime(); + curWaitingJobs += m.getCurrentWaitingJobs(); maxWaitingJobs = max(maxWaitingJobs, m.getCurrentWaitingJobs()); avgWaitingJobs += m.getCurrentWaitingJobs(); @@ -363,7 +363,7 @@ public class ClusterMetricsSnapshot implements ClusterMetrics { curJobWaitTime = min(curJobWaitTime, m.getCurrentJobWaitTime()); maxJobWaitTime = max(maxJobWaitTime, m.getCurrentJobWaitTime()); - avgJobWaitTime += m.getCurrentJobWaitTime(); + avgJobWaitTime += m.getAverageJobWaitTime(); daemonThreadCnt += m.getCurrentDaemonThreadCount();
