From b39031a7d1a3dd6a1cce011791edaec6ee541226 Mon Sep 17 00:00:00 2001
From: zhanguohuang <779134714@qq.com>
Date: Sat, 27 Jul 2019 09:49:19 +0800
Subject: [PATCH] [ISSUE #1082] Fix disconnection of HA (#1083)

---
 store/src/main/java/org/apache/rocketmq/store/ha/HAService.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 bbadd1bc..84fb4217 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
@@ -374,6 +374,7 @@ public class HAService {
                 }
             }
 
+            lastWriteTimestamp = HAService.this.defaultMessageStore.getSystemClock().now();
             return !this.reportOffset.hasRemaining();
         }
 
@@ -406,7 +407,6 @@ public class HAService {
                 try {
                     int readSize = this.socketChannel.read(this.byteBufferRead);
                     if (readSize > 0) {
-                        lastWriteTimestamp = HAService.this.defaultMessageStore.getSystemClock().now();
                         readSizeZeroTimes = 0;
                         boolean result = this.dispatchReadRequest();
                         if (!result) {
-- 
GitLab