You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zookeeper.apache.org by fa...@apache.org on 2020/01/07 19:39:13 UTC
[zookeeper] branch master updated: ZOOKEEPER-3656: Properly set
lastFlushTime when flushing
This is an automated email from the ASF dual-hosted git repository.
fangmin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/zookeeper.git
The following commit(s) were added to refs/heads/master by this push:
new 7408ff4 ZOOKEEPER-3656: Properly set lastFlushTime when flushing
7408ff4 is described below
commit 7408ff43777602937a54af7e66913138c8c2a3b4
Author: hammerle <ha...@fb.com>
AuthorDate: Tue Jan 7 11:39:06 2020 -0800
ZOOKEEPER-3656: Properly set lastFlushTime when flushing
Author: hammerle <ha...@fb.com>
Reviewers: hanm@apache.org, fangmin@apache.org
Closes #1189 from hammerlefb/syncrequestfix
---
.../src/main/java/org/apache/zookeeper/server/SyncRequestProcessor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/SyncRequestProcessor.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/SyncRequestProcessor.java
index 7c5e5ef..66e85b1 100644
--- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/SyncRequestProcessor.java
+++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/SyncRequestProcessor.java
@@ -248,8 +248,8 @@ public class SyncRequestProcessor extends ZooKeeperCriticalThread implements Req
if (this.nextProcessor instanceof Flushable) {
((Flushable) this.nextProcessor).flush();
}
- lastFlushTime = Time.currentElapsedTime();
}
+ lastFlushTime = Time.currentElapsedTime();
}
public void shutdown() {