[rocketmq] branch develop updated: [ISSUE #4183] When the reportSlaveMaxOffset method fails, end the current loop early (#4184)

[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 a597c8e34 [ISSUE #4183] When the reportSlaveMaxOffset method fails, 
end the current loop early (#4184)
a597c8e34 is described below

commit a597c8e341b3c6070a3bd6bf0f73a5945f0cd56a
Author: 灼华 <43363120+burnin...@users.noreply.github.com>
AuthorDate: Thu Apr 21 11:14:21 2022 +0800

    [ISSUE #4183] When the reportSlaveMaxOffset method fails, end the current 
loop early (#4184)
    
    * [ISSUE #4183] When the reportSlaveMaxOffset method fails, end the current 
loop early
    
    * Update HAService.java
---
 store/src/main/java/org/apache/rocketmq/store/ha/HAService.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java 
b/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
index c9c05b308..12c5a16f2 100644
--- a/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
+++ b/store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
@@ -555,6 +555,7 @@ public class HAService {
                             boolean result = 
this.reportSlaveMaxOffset(this.currentReportedOffset);
                             if (!result) {
                                 this.closeMaster();
+                                continue;
                             }
                         }
 
@@ -563,6 +564,7 @@ public class HAService {
                         boolean ok = this.processReadEvent();
                         if (!ok) {
                             this.closeMaster();
+                            continue;
                         }
 
                         if (!reportSlaveMaxOffsetPlus()) {