when meeting END_OF_FILE, other exceptions should be validated too.

apache · Dec 25, 2023 · 9d8a834 · 9d8a834
1 parent 8a2d0cd
commit 9d8a834
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -1197,7 +1197,13 @@ public CompletableFuture<PutMessageResult> asyncPutMessages(final MessageExtBatc
                             setFileReadMode(mappedFile, LibC.MADV_RANDOM);
                         }
                         result = mappedFile.appendMessages(messageExtBatch, this.appendMessageCallback, putMessageContext);
-                        break;
+                        CompletableFuture<PutMessageResult> validateAppendMessageResult = validateAppendMessageResult(result);
+                        if (null == validateAppendMessageResult) {
+                            break;
+                        } else {
+                            beginTimeInLock = 0;
+                            return validateAppendMessageResult;
+                        }
                     case MESSAGE_SIZE_EXCEEDED:
                     case PROPERTIES_SIZE_EXCEEDED:
                         beginTimeInLock = 0;