You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zookeeper.apache.org by ph...@apache.org on 2008/09/09 19:56:19 UTC
svn commit: r693529 - in /hadoop/zookeeper/trunk: CHANGES.txt
src/java/main/org/apache/zookeeper/server/quorum/FollowerRequestProcessor.java
Author: phunt
Date: Tue Sep 9 10:56:19 2008
New Revision: 693529
URL: http://svn.apache.org/viewvc?rev=693529&view=rev
Log:
applied doc patch for ZOOKEEPER-118
Modified:
hadoop/zookeeper/trunk/CHANGES.txt
hadoop/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/FollowerRequestProcessor.java
Modified: hadoop/zookeeper/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/zookeeper/trunk/CHANGES.txt?rev=693529&r1=693528&r2=693529&view=diff
==============================================================================
--- hadoop/zookeeper/trunk/CHANGES.txt (original)
+++ hadoop/zookeeper/trunk/CHANGES.txt Tue Sep 9 10:56:19 2008
@@ -2,12 +2,14 @@
Non-backward compatible changes:
- ZOOKEEPER-132: Create Enum to replace CreateFlag in ZooKepper.create method (Jakob Homan)
+ ZOOKEEPER-132. Create Enum to replace CreateFlag in ZooKepper.create method (Jakob Homan via phunt)
Backward compatibile changes:
BUGFIXES:
+ ZOOKEEPER-118. findbugs flagged switch statement in followerrequestprocessor.run() (Flavio Paiva Junqueira via phunt)
+
ZOOKEEPER-39. Use Watcher objects rather than boolean on read operations.
(Andrew Kornev)
Modified: hadoop/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/FollowerRequestProcessor.java
URL: http://svn.apache.org/viewvc/hadoop/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/FollowerRequestProcessor.java?rev=693529&r1=693528&r2=693529&view=diff
==============================================================================
--- hadoop/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/FollowerRequestProcessor.java (original)
+++ hadoop/zookeeper/trunk/src/java/main/org/apache/zookeeper/server/quorum/FollowerRequestProcessor.java Tue Sep 9 10:56:19 2008
@@ -64,6 +64,12 @@
// the request to the leader so that we are ready to receive
// the response
nextProcessor.processRequest(request);
+
+ // We now ship the request to the leader. As with all
+ // other quorum operations, sync also follows this code
+ // path, but different from others, we need to keep track
+ // of the sync operations this follower has pending, so we
+ // add it to pendingSyncs.
switch (request.type) {
case OpCode.sync:
zks.pendingSyncs.add(request);