svn commit: r1549648 - in /hadoop/common/branches/branch-0.23/hadoop-common-project/hadoop-common: CHANGES.txt src/main/java/org/apache/hadoop/ipc/Server.java

[jeagles]

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);