Github user afine commented on a diff in the pull request:
https://github.com/apache/zookeeper/pull/300#discussion_r154786233
--- Diff:
src/java/main/org/apache/zookeeper/server/quorum/CommitProcessor.java ---
@@ -327,6 +257,95 @@ public void run() {
LOG.info("CommitProcessor exited loop!");
}
+ private void processCommittedRequest() throws IOException,
InterruptedException {
+ // In case of a spurious wakeup in waitForCommittedRequests we
should not
+ // remove the request from the queue until it has been processed
+ Request request = committedRequests.peek();
+
+ if (request == null) {
+ committedRequests.poll();
--- End diff --
we don't
---
