Author: jeagles Date: Mon Dec 9 19:12:52 2013 New Revision: 1549648 URL: http://svn.apache.org/r1549648 Log: HADOOP-10148. backport hadoop-10107 to branch-0.23 (Chen He via jeagles)
Modified: hadoop/common/branches/branch-0.23/hadoop-common-project/hadoop-common/CHANGES.txt hadoop/common/branches/branch-0.23/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java Modified: hadoop/common/branches/branch-0.23/hadoop-common-project/hadoop-common/CHANGES.txt URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-common-project/hadoop-common/CHANGES.txt?rev=1549648&r1=1549647&r2=1549648&view=diff ============================================================================== --- hadoop/common/branches/branch-0.23/hadoop-common-project/hadoop-common/CHANGES.txt (original) +++ hadoop/common/branches/branch-0.23/hadoop-common-project/hadoop-common/CHANGES.txt Mon Dec 9 19:12:52 2013 @@ -8,6 +8,8 @@ Release 0.23.11 - UNRELEASED IMPROVEMENTS + HADOOP-10148. backport hadoop-10107 to branch-0.23 (Chen He via jeagles) + OPTIMIZATIONS BUG FIXES Modified: hadoop/common/branches/branch-0.23/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-0.23/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java?rev=1549648&r1=1549647&r2=1549648&view=diff ============================================================================== --- hadoop/common/branches/branch-0.23/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java (original) +++ hadoop/common/branches/branch-0.23/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Server.java Mon Dec 9 19:12:52 2013 @@ -1600,6 +1600,7 @@ public abstract class Server { // Start the listener here and let it bind to the port listener = new Listener(); this.port = listener.getAddress().getPort(); + connectionManager = new ConnectionManager(); this.rpcMetrics = RpcMetrics.create(this); this.rpcDetailedMetrics = RpcDetailedMetrics.create(this.port); this.tcpNoDelay = conf.getBoolean( @@ -1608,7 +1609,6 @@ public abstract class Server { // Create the responder here responder = new Responder(); - connectionManager = new ConnectionManager(); if (isSecurityEnabled) { SaslRpcServer.init(conf);