diff options
Diffstat (limited to 'vespajlib/src/main/java/com/yahoo/concurrent/maintenance/JobMetrics.java')
-rw-r--r-- | vespajlib/src/main/java/com/yahoo/concurrent/maintenance/JobMetrics.java | 23 |
1 files changed, 2 insertions, 21 deletions
diff --git a/vespajlib/src/main/java/com/yahoo/concurrent/maintenance/JobMetrics.java b/vespajlib/src/main/java/com/yahoo/concurrent/maintenance/JobMetrics.java index 73a5dc77743..da5a596edea 100644 --- a/vespajlib/src/main/java/com/yahoo/concurrent/maintenance/JobMetrics.java +++ b/vespajlib/src/main/java/com/yahoo/concurrent/maintenance/JobMetrics.java @@ -10,29 +10,10 @@ import java.util.concurrent.ConcurrentHashMap; */ public abstract class JobMetrics { - private final ConcurrentHashMap<String, Long> incompleteRuns = new ConcurrentHashMap<>(); - - /** Record starting of a run of a job */ - public void starting(String job) { - incompleteRuns.merge(job, 1L, Long::sum); - } - - /** Record completion of given job */ - public void recordCompletionOf(String job) { - incompleteRuns.put(job, 0L); - } - /** * Records completion of a run of a job. - * This is guaranteed to always be called once whenever starting has been called. + * This is guaranteed to always be called once after each maintainer run. */ - public void completed(String job, double successFactor) { - Long incompleteRuns = this.incompleteRuns.get(job); - if (incompleteRuns != null) { - recordCompletion(job, incompleteRuns, successFactor); - } - } - - protected abstract void recordCompletion(String job, Long incompleteRuns, double successFactor); + public abstract void completed(String job, double successFactor); } |