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 2022/05/17 01:44:23 UTC
[rocketmq] branch develop updated: [ISSUE #4317] Fix for statement does not loop
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 84fb5e107 [ISSUE #4317] Fix for statement does not loop
84fb5e107 is described below
commit 84fb5e1078a016c913a1e74905b275528d18abff
Author: CoderBruis <37...@users.noreply.github.com>
AuthorDate: Tue May 17 09:44:18 2022 +0800
[ISSUE #4317] Fix for statement does not loop
---
.../main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 7 ++-----
1 file changed, 2 insertions(+), 5 deletions(-)
diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
index 586718a95..872062bd3 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -1183,11 +1183,8 @@ public class DefaultMessageStore implements MessageStore {
SelectMappedBufferResult bufferConsumeQueue = consumeQueue.getIndexBuffer(consumeOffset);
if (bufferConsumeQueue != null) {
try {
- for (int i = 0; i < bufferConsumeQueue.getSize(); ) {
- i += ConsumeQueue.CQ_STORE_UNIT_SIZE;
- long offsetPy = bufferConsumeQueue.getByteBuffer().getLong();
- return checkInDiskByCommitOffset(offsetPy, maxOffsetPy);
- }
+ long offsetPy = bufferConsumeQueue.getByteBuffer().getLong();
+ return checkInDiskByCommitOffset(offsetPy, maxOffsetPy);
} finally {
bufferConsumeQueue.release();