You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zookeeper.apache.org by br...@apache.org on 2010/11/04 17:28:16 UTC
svn commit: r1031064 - in /hadoop/zookeeper/branches/branch-3.3: CHANGES.txt
src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java
Author: breed
Date: Thu Nov 4 16:28:16 2010
New Revision: 1031064
URL: http://svn.apache.org/viewvc?rev=1031064&view=rev
Log:
ZOOKEEPER-907. Spurious "KeeperErrorCode = Session moved" messages
Modified:
hadoop/zookeeper/branches/branch-3.3/CHANGES.txt
hadoop/zookeeper/branches/branch-3.3/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java
Modified: hadoop/zookeeper/branches/branch-3.3/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/zookeeper/branches/branch-3.3/CHANGES.txt?rev=1031064&r1=1031063&r2=1031064&view=diff
==============================================================================
--- hadoop/zookeeper/branches/branch-3.3/CHANGES.txt (original)
+++ hadoop/zookeeper/branches/branch-3.3/CHANGES.txt Thu Nov 4 16:28:16 2010
@@ -64,6 +64,8 @@ BUGFIXES:
ZOOKEEPER-898. C Client might not cleanup correctly during close
(jared cantwell via mahadev)
+ ZOOKEEPER-907. Spurious "KeeperErrorCode = Session moved" messages (vishal k via breed)
+
IMPROVEMENTS:
ZOOKEEPER-789. Improve FLE log messages (flavio via phunt)
Modified: hadoop/zookeeper/branches/branch-3.3/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java
URL: http://svn.apache.org/viewvc/hadoop/zookeeper/branches/branch-3.3/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java?rev=1031064&r1=1031063&r2=1031064&view=diff
==============================================================================
--- hadoop/zookeeper/branches/branch-3.3/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java (original)
+++ hadoop/zookeeper/branches/branch-3.3/src/java/main/org/apache/zookeeper/server/quorum/LearnerHandler.java Thu Nov 4 16:28:16 2010
@@ -449,14 +449,14 @@ public class LearnerHandler extends Thre
cxid = bb.getInt();
type = bb.getInt();
bb = bb.slice();
+ Request si;
if(type == OpCode.sync){
- leader.zk.submitRequest(new LearnerSyncRequest(this, sessionId, cxid, type, bb,
- qp.getAuthinfo()));
+ si = new LearnerSyncRequest(this, sessionId, cxid, type, bb, qp.getAuthinfo());
} else {
- Request si = new Request(null, sessionId, cxid, type, bb, qp.getAuthinfo());
- si.setOwner(this);
- leader.zk.submitRequest(si);
+ si = new Request(null, sessionId, cxid, type, bb, qp.getAuthinfo());
}
+ si.setOwner(this);
+ leader.zk.submitRequest(si);
break;
default:
}