use refresh instead of collect

apache · Mar 26, 2023 · d6c12d1 · d6c12d1
1 parent 3c3d284
commit d6c12d1
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 14 deletions.
diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/StatsBuckets.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/StatsBuckets.java
@@ -73,19 +73,6 @@ public void refresh() {
         this.count = count;
     }
 
-    public void collect() {
-        long count = 0;
-        sum = sumCounter.sum();
-
-        for (int i = 0; i < buckets.length; i++) {
-            long value = buckets[i].sum();
-            count += value;
-            values[i] = value;
-        }
-
-        this.count = count;
-    }
-
     public void reset() {
         sum = 0;
         sumCounter.reset();

diff --git a/...src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedMessageIndexStats.java b/...src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedMessageIndexStats.java
@@ -79,7 +79,7 @@ public Map<String, TopicMetricBean> genTopicMetricMap() {
         });
 
         delayedMessageIndexBucketOpLatencyMs.forEach((typeName, statsBuckets) -> {
-            statsBuckets.collect();
+            statsBuckets.refresh();
             long[] buckets = statsBuckets.getBuckets();
             for (int i = 0; i < buckets.length; i++) {
                 long count = buckets[i];