commons: add a way to reset gauges and counters

Acked-by: Gerd Behrmann Target: master Require-book: no Require-notes: no
dCache · Nov 13, 2013 · fb28839 · fb28839
1 parent dc7cb31
commit fb28839
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 1 deletion.
diff --git a/modules/common/src/main/java/org/dcache/commons/stats/RequestExecutionTimeGauge.java b/modules/common/src/main/java/org/dcache/commons/stats/RequestExecutionTimeGauge.java
@@ -78,4 +78,9 @@ public interface RequestExecutionTimeGauge {
      * @param nextExecTime
      */
     void update(long nextExecTime);
+
+    /**
+     * Reset the gauge.
+     */
+    void reset();
 }
diff --git a/modules/common/src/main/java/org/dcache/commons/stats/RequestExecutionTimeGaugeImpl.java b/modules/common/src/main/java/org/dcache/commons/stats/RequestExecutionTimeGaugeImpl.java
@@ -286,5 +286,16 @@ public synchronized long getPeriodUpdateNum() {
         return periodUpdateNum;
     }
 
-
+    @Override
+    public synchronized void reset() {
+        periodStartTime = System.currentTimeMillis();
+        periodAverageExecutionTime = 0;
+        periodUpdateNum = 0;
+        averageExecutionTime=0;
+        minExecutionTime=0;
+        maxExecutionTime=0;
+        executionTimeRMSS=0;
+        lastExecutionTime = 0;
+        updateNum = 0;
+    }
 }
diff --git a/modules/common/src/main/java/org/dcache/commons/stats/RequestExecutionTimeGauges.java b/modules/common/src/main/java/org/dcache/commons/stats/RequestExecutionTimeGauges.java
@@ -174,4 +174,12 @@ public Set<T> keySet() {
     }
 
 
+    /**
+     * reset all gauges.
+     */
+    public synchronized void reset() {
+        for (RequestExecutionTimeGauge gauge: gauges.values()) {
+            gauge.reset();
+        }
+    }
 }