You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vo...@apache.org on 2019/07/27 01:49:25 UTC
[rocketmq] branch develop updated: [ISSUE #1082] Fix disconnection
of HA (#1083)
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 <77...@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) {