svn commit: r1446389 - in /incubator/ambari/trunk: CHANGES.txt ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariServer.java

[mahadev]

Author: mahadev
Date: Thu Feb 14 23:17:19 2013
New Revision: 1446389

URL: http://svn.apache.org/r1446389
Log:
AMBARI-1432. Ambari Agent registration hangs due to Acceptor bug in Jetty for 
not reading through accepted connections. (mahadev)

Modified:
    incubator/ambari/trunk/CHANGES.txt
    
incubator/ambari/trunk/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariServer.java

Modified: incubator/ambari/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/incubator/ambari/trunk/CHANGES.txt?rev=1446389&r1=1446388&r2=1446389&view=diff
==============================================================================
--- incubator/ambari/trunk/CHANGES.txt (original)
+++ incubator/ambari/trunk/CHANGES.txt Thu Feb 14 23:17:19 2013
@@ -492,6 +492,8 @@ Trunk (unreleased changes):
 
  AMBARI-1358. Clean up alert messages. (Yusaku Sako via mahadev)
 
+ AMBARI-1432. Ambari Agent registration hangs due to Acceptor bug in Jetty for
+ not reading through accepted connections. (mahadev)
 
 AMBARI-1.2.0 branch:
 

Modified: 
incubator/ambari/trunk/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariServer.java
URL: 
http://svn.apache.org/viewvc/incubator/ambari/trunk/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariServer.java?rev=1446389&r1=1446388&r2=1446389&view=diff
==============================================================================
--- 
incubator/ambari/trunk/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariServer.java
 (original)
+++ 
incubator/ambari/trunk/ambari-server/src/main/java/org/apache/ambari/server/controller/AmbariServer.java
 Thu Feb 14 23:17:19 2013
@@ -214,7 +214,8 @@ public class AmbariServer {
       // sslConnectorOneWay.setNeedClientAuth(false);
       SslSelectChannelConnector sslConnectorOneWay = new 
SslSelectChannelConnector(contextFactory);
       sslConnectorOneWay.setPort(AGENT_ONE_WAY_AUTH);
-
+      sslConnectorOneWay.setAcceptors(2);
+      sslConnectorTwoWay.setAcceptors(2);
       serverForAgent.setConnectors(new Connector[]{ sslConnectorOneWay, 
sslConnectorTwoWay});
 
       ServletHolder sh = new ServletHolder(ServletContainer.class);