Repository: zookeeper
Updated Branches:
  refs/heads/master a680655a3 -> 0a3e2d1d4


ZOOKEEPER-2785: Server inappropriately throttles connections under loa…

…d before SASL completes

Author: Abhishek Singh Chouhan <[email protected]>

Reviewers: Michael Han <[email protected]>

Closes #256 from abhishek-chouhan/ZOOKEEPER-2785


Project: http://git-wip-us.apache.org/repos/asf/zookeeper/repo
Commit: http://git-wip-us.apache.org/repos/asf/zookeeper/commit/0a3e2d1d
Tree: http://git-wip-us.apache.org/repos/asf/zookeeper/tree/0a3e2d1d
Diff: http://git-wip-us.apache.org/repos/asf/zookeeper/diff/0a3e2d1d

Branch: refs/heads/master
Commit: 0a3e2d1d4bdbb96f41da7111db3913ef08068722
Parents: a680655
Author: Abhishek Singh Chouhan <[email protected]>
Authored: Thu May 18 14:14:39 2017 -0700
Committer: Michael Han <[email protected]>
Committed: Thu May 18 14:14:39 2017 -0700

----------------------------------------------------------------------
 src/java/main/org/apache/zookeeper/server/ZooKeeperServer.java | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/zookeeper/blob/0a3e2d1d/src/java/main/org/apache/zookeeper/server/ZooKeeperServer.java
----------------------------------------------------------------------
diff --git a/src/java/main/org/apache/zookeeper/server/ZooKeeperServer.java 
b/src/java/main/org/apache/zookeeper/server/ZooKeeperServer.java
index e2fba10..86f8bea 100644
--- a/src/java/main/org/apache/zookeeper/server/ZooKeeperServer.java
+++ b/src/java/main/org/apache/zookeeper/server/ZooKeeperServer.java
@@ -1099,6 +1099,7 @@ public class ZooKeeperServer implements SessionExpirer, 
ServerStats.Provider {
                 Record rsp = processSasl(incomingBuffer,cnxn);
                 ReplyHeader rh = new ReplyHeader(h.getXid(), 0, 
KeeperException.Code.OK.intValue());
                 cnxn.sendResponse(rh,rsp, "response"); // not sure about 3rd 
arg..what is it?
+                return;
             }
             else {
                 Request si = new Request(cnxn, cnxn.getSessionId(), h.getXid(),

Reply via email to