chukwa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shre...@apache.org
Subject svn commit: r1589550 - in /chukwa/trunk/src/main/java/org/apache/hadoop/chukwa/datacollection: adaptor/SocketAdaptor.java agent/ChukwaAgent.java
Date Thu, 24 Apr 2014 00:11:39 GMT
Author: shreyas
Date: Thu Apr 24 00:11:38 2014
New Revision: 1589550

URL: http://svn.apache.org/r1589550
Log:
CHUKWA-710. Set TCP socket reuse option

Modified:
    chukwa/trunk/src/main/java/org/apache/hadoop/chukwa/datacollection/adaptor/SocketAdaptor.java
    chukwa/trunk/src/main/java/org/apache/hadoop/chukwa/datacollection/agent/ChukwaAgent.java

Modified: chukwa/trunk/src/main/java/org/apache/hadoop/chukwa/datacollection/adaptor/SocketAdaptor.java
URL: http://svn.apache.org/viewvc/chukwa/trunk/src/main/java/org/apache/hadoop/chukwa/datacollection/adaptor/SocketAdaptor.java?rev=1589550&r1=1589549&r2=1589550&view=diff
==============================================================================
--- chukwa/trunk/src/main/java/org/apache/hadoop/chukwa/datacollection/adaptor/SocketAdaptor.java
(original)
+++ chukwa/trunk/src/main/java/org/apache/hadoop/chukwa/datacollection/adaptor/SocketAdaptor.java
Thu Apr 24 00:11:38 2014
@@ -55,6 +55,7 @@ public class SocketAdaptor extends Abstr
     public void run() {
       try{
         listener = new ServerSocket(port);
+        listener.setReuseAddress(true);
         Socket server;
 
         while(running){

Modified: chukwa/trunk/src/main/java/org/apache/hadoop/chukwa/datacollection/agent/ChukwaAgent.java
URL: http://svn.apache.org/viewvc/chukwa/trunk/src/main/java/org/apache/hadoop/chukwa/datacollection/agent/ChukwaAgent.java?rev=1589550&r1=1589549&r2=1589550&view=diff
==============================================================================
--- chukwa/trunk/src/main/java/org/apache/hadoop/chukwa/datacollection/agent/ChukwaAgent.java
(original)
+++ chukwa/trunk/src/main/java/org/apache/hadoop/chukwa/datacollection/agent/ChukwaAgent.java
Thu Apr 24 00:11:38 2014
@@ -336,6 +336,7 @@ public class ChukwaAgent implements Adap
     jettyConnector.setLowResourcesConnections(HTTP_SERVER_THREADS - 10);
     jettyConnector.setLowResourceMaxIdleTime(1500);
     jettyConnector.setPort(portNum);
+    jettyConnector.setReuseAddress(true);
 
     // Set up jetty server, using connector
     jettyServer = new Server(portNum);



Mime
View raw message