init metric calculate

apache · Jan 22, 2025 · 8e155e3 · 8e155e3
1 parent 5fe5a6c
commit 8e155e3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/store/src/main/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStore.java b/store/src/main/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStore.java
@@ -221,7 +221,7 @@ private void initService() {
     }
 
     private void calcTimerDistribution() {
-        // TODO fix
+        // TODO fix sync metric
         int slotNumber = precisionMs / 100;
         int rocksdbNumber = 0;
         for (int i = 0; i < this.slotSize; i++) {
@@ -366,7 +366,7 @@ private void fetchAndPutTimerRequest() throws InterruptedException {
             // sync cq read offset
             timerMessageKVStore.writeAssignRecords(getColumnFamily(0), new ArrayList<>(), commitOffset.addAndGet(trs.size()));
 
-            // sync metric
+            // TODO sync metric
             for (Map.Entry<Long, Map<Integer, List<TimerMessageRecord>>> entry : deleteMetric.entrySet()) {
                 long delayTime = entry.getKey();
                 for (Map.Entry<Integer, List<TimerMessageRecord>> entry1 : entry.getValue().entrySet()) {