You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2023/03/27 08:24:31 UTC
[rocketmq] branch develop updated: [ISSUE #6478] Fix outTPS in mqadmin when using compactionTopic
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 <36...@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 <gu...@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);