提交 b3f8008d 编写于 作者: W wqliang

check transferOK to reduce unnecessary wait

上级 85a6cc1c
...@@ -282,12 +282,9 @@ public class HAService { ...@@ -282,12 +282,9 @@ public class HAService {
boolean transferOK = HAService.this.push2SlaveMaxOffset.get() >= req.getNextOffset(); boolean transferOK = HAService.this.push2SlaveMaxOffset.get() >= req.getNextOffset();
long waitUntillWhen = HAService.this.defaultMessageStore.getSystemClock().now() long waitUntillWhen = HAService.this.defaultMessageStore.getSystemClock().now()
+ HAService.this.defaultMessageStore.getMessageStoreConfig().getSyncFlushTimeout(); + HAService.this.defaultMessageStore.getMessageStoreConfig().getSyncFlushTimeout();
while (HAService.this.defaultMessageStore.getSystemClock().now() < waitUntillWhen) { while (!transferOK && HAService.this.defaultMessageStore.getSystemClock().now() < waitUntillWhen) {
this.notifyTransferObject.waitForRunning(1000); this.notifyTransferObject.waitForRunning(1000);
transferOK = HAService.this.push2SlaveMaxOffset.get() >= req.getNextOffset(); transferOK = HAService.this.push2SlaveMaxOffset.get() >= req.getNextOffset();
if (transferOK) {
break;
}
} }
if (!transferOK) { if (!transferOK) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册