opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-28 20:09:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #9811] Fixed the issue of excessive loop iterations in reput service (#9812)

Browse Source
This commit is contained in:
lizhimins
2025-11-06 11:37:39 +08:00
committed by GitHub
parent 6b91c7d4a2
commit 440341b604
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+1 -1
View File
@@ -2536,7 +2536,7 @@ public class DefaultMessageStore implements MessageStore {
if (!isCommitLogAvailable) {
currentReputTimestamp = System.currentTimeMillis();
}
for (boolean doNext = true; isCommitLogAvailable && doNext; ) {
for (boolean doNext = true; isCommitLogAvailable() && doNext; ) {
SelectMappedBufferResult result = DefaultMessageStore.this.commitLog.getData(reputFromOffset);