Diff of /tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationListener.java

Parent Directory | Revision Log | Patch

--- tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationListener.java	2006/03/01 15:33:23	382060
+++ tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationListener.java	2006/03/01 15:34:59	382061
@@ -43,11 +43,11 @@ public class ReplicationListener impleme
     /**
      * @todo make this configurable
      */
-    protected int rxBufSize = XByteBuffer.DEF_SIZE;
+    protected int rxBufSize = 43800;
     /**
      * We are only sending acks
      */
-    protected int txBufSize = 128;
+    protected int txBufSize = 25188;
 
     protected static org.apache.commons.logging.Log log = org.apache.commons.logging.LogFactory.getLog(ReplicationListener.class);
 
@@ -197,6 +197,10 @@ public class ReplicationListener impleme
                         ServerSocketChannel server =
                             (ServerSocketChannel) key.channel();
                         SocketChannel channel = server.accept();
+
+//System.out.println("DEFAULT CHANNEL RX="+channel.socket().getReceiveBufferSize() +" our="+rxBufSize);
+//System.out.println("DEFAULT CHANNEL TX="+channel.socket().getSendBufferSize() +" our="+txBufSize);
+
                         channel.socket().setReceiveBufferSize(rxBufSize);
                         channel.socket().setSendBufferSize(txBufSize);
                         Object attach = new ObjectReader(channel, selector,this);