Author: fhanik
Date: Thu Mar 2 16:10:54 2006
New Revision: 382584
URL: http://svn.apache.org/viewcvs?rev=382584&view=rev
Log:
Who would have known, buffer size is the key in throughput
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/nio/NioSender.java
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/nio/ParallelNioSender.java
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/nio/NioSender.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/nio/NioSender.java?rev=382584&r1=382583&r2=382584&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/nio/NioSender.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/nio/NioSender.java
Thu Mar 2 16:10:54 2006
@@ -88,6 +88,8 @@
if ( socketChannel.finishConnect() ) {
//we connected, register ourselves for writing
connected = true;
+ socketChannel.socket().setSendBufferSize(txBufSize);
+ socketChannel.socket().setReceiveBufferSize(rxBufSize);
if ( current != null ) key.interestOps(key.interestOps() |
SelectionKey.OP_WRITE);
return false;
} else {
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/nio/ParallelNioSender.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/nio/ParallelNioSender.java?rev=382584&r1=382583&r2=382584&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/nio/ParallelNioSender.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/nio/ParallelNioSender.java
Thu Mar 2 16:10:54 2006
@@ -43,7 +43,7 @@
*/
public class ParallelNioSender implements MultiPointSender {
protected long timeout = 15000;
- protected long selectTimeout = 50;
+ protected long selectTimeout = 1000;
protected boolean waitForAck = false;
protected int retryAttempts=0;
protected int keepAliveCount = Integer.MAX_VALUE;
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
