[rocketmq] branch develop updated: [ISSUE #1082] Fix disconnection of HA (#1083)

[vongosling]

This is an automated email from the ASF dual-hosted git repository.

vongosling 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 b39031a  [ISSUE #1082] Fix disconnection of HA (#1083)
b39031a is described below

commit b39031a7d1a3dd6a1cce011791edaec6ee541226
Author: zhanguohuang <779134...@qq.com>
AuthorDate: Sat Jul 27 09:49:19 2019 +0800

    [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 bbadd1b..84fb421 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) {