summaryrefslogtreecommitdiffstats
path: root/vespajlib/src/main/java/com/yahoo/concurrent/maintenance/JobMetrics.java
diff options
context:
space:
mode:
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.java23
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);
}