[rocketmq] branch develop updated: [ISSUE #6478] Fix outTPS in mqadmin when using compactionTopic

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 9ccfcfbd1 [ISSUE #6478] Fix outTPS in mqadmin when using 
compactionTopic
9ccfcfbd1 is described below

commit 9ccfcfbd1396e57b015cec3ea747b49b366dd5a0
Author: guyinyou <36399867+guyin...@users.noreply.github.com>
AuthorDate: Mon Mar 27 16:24:08 2023 +0800

    [ISSUE #6478] Fix outTPS in mqadmin when using compactionTopic
    
    Co-authored-by: guyinyou <guyinyou....@alibaba-inc.com>
---
 .../main/java/org/apache/rocketmq/store/kv/CompactionLog.java  | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git 
a/store/src/main/java/org/apache/rocketmq/store/kv/CompactionLog.java 
b/store/src/main/java/org/apache/rocketmq/store/kv/CompactionLog.java
index 7ade9e5ae..793f6203e 100644
--- a/store/src/main/java/org/apache/rocketmq/store/kv/CompactionLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/kv/CompactionLog.java
@@ -524,7 +524,7 @@ public class CompactionLog {
                                     nextPhyFileStartOffset = 
rollNextFile(offsetPy);
                                     continue;
                                 }
-
+                                
this.defaultMessageStore.getStoreStatsService().getGetMessageTransferredMsgCount().add(cqUnit.getBatchNum());
                                 getResult.addMessage(selectResult, 
cqUnit.getQueueOffset(), cqUnit.getBatchNum());
                                 status = GetMessageStatus.FOUND;
                                 nextPhyFileStartOffset = Long.MIN_VALUE;
@@ -543,6 +543,14 @@ public class CompactionLog {
                 nextBeginOffset = nextOffsetCorrection(offset, 0);
             }
 
+            if (GetMessageStatus.FOUND == status) {
+                
this.defaultMessageStore.getStoreStatsService().getGetMessageTimesTotalFound().add(getResult.getMessageCount());
+            } else {
+                
this.defaultMessageStore.getStoreStatsService().getGetMessageTimesTotalMiss().add(getResult.getMessageCount());
+            }
+            long elapsedTime = this.defaultMessageStore.getSystemClock().now() 
- beginTime;
+            
this.defaultMessageStore.getStoreStatsService().setGetMessageEntireTimeMax(elapsedTime);
+
             getResult.setStatus(status);
             getResult.setNextBeginOffset(nextBeginOffset);
             getResult.setMaxOffset(maxOffset);