[jboss-cvs] JBoss Messaging SVN: r3890 - projects/network-benchmark/src/network.

[jboss-cvs-commits at lists.jboss.org]

Author: jmesnil
Date: 2008-03-18 09:05:52 -0400 (Tue, 18 Mar 2008)
New Revision: 3890

Modified:
   projects/network-benchmark/src/network/NetworkClientTest.java
Log:
* added TCP_SEND_BUFFER_SIZE to BIO and MINA clients

Modified: projects/network-benchmark/src/network/NetworkClientTest.java
===================================================================
--- projects/network-benchmark/src/network/NetworkClientTest.java	2008-03-18 12:34:32 UTC (rev 3889)
+++ projects/network-benchmark/src/network/NetworkClientTest.java	2008-03-18 13:05:52 UTC (rev 3890)
@@ -27,6 +27,7 @@
    private static final long DURATION = 10000; // in ms   
    public static final int MESSAGE_SIZE = 1000; // in bytes
    private static final boolean  ENABLE_TCP_NO_DELAY = false;
+   private static final int TCP_SEND_BUFFER_SIZE = 8192; //16258; // 8192 by default on Linux, 131070 on Mac OS X
    
    // Constants -----------------------------------------------------
 
@@ -44,7 +45,8 @@
    static {
       System.out.println("Duration: " + DURATION + " ms");
       System.out.println("Message size: " + MESSAGE_SIZE + " bytes");
-      System.out.println("TCP no delay: " + ENABLE_TCP_NO_DELAY + "\n");
+      System.out.println("TCP no delay: " + ENABLE_TCP_NO_DELAY);
+      System.out.println("TCP send buffer size: " + TCP_SEND_BUFFER_SIZE + " bytes\n");
    }
 
    // Constructors --------------------------------------------------
@@ -143,6 +145,7 @@
    {
       Socket clientSocket = new Socket();
       clientSocket.setTcpNoDelay(ENABLE_TCP_NO_DELAY);
+      clientSocket.setSendBufferSize(TCP_SEND_BUFFER_SIZE);
       clientSocket.connect(address);
       OutputStream os = clientSocket.getOutputStream();
       InputStream is = clientSocket.getInputStream();
@@ -172,6 +175,7 @@
    {
       final Socket clientSocket = new Socket();
       clientSocket.setTcpNoDelay(ENABLE_TCP_NO_DELAY);
+      clientSocket.setSendBufferSize(TCP_SEND_BUFFER_SIZE);
       clientSocket.connect(address);
       OutputStream os = clientSocket.getOutputStream();
       final InputStream is = clientSocket.getInputStream();
@@ -228,6 +232,7 @@
    {
       NioSocketConnector client = new NioSocketConnector();
       client.getSessionConfig().setTcpNoDelay(ENABLE_TCP_NO_DELAY);
+      client.getSessionConfig().setSendBufferSize(TCP_SEND_BUFFER_SIZE);
       client.getSessionConfig().setUseReadOperation(true);
 
       final AtomicLong count = new AtomicLong(0);
@@ -268,6 +273,7 @@
    {
       NioSocketConnector client = new NioSocketConnector();
       client.getSessionConfig().setTcpNoDelay(ENABLE_TCP_NO_DELAY);
+      client.getSessionConfig().setSendBufferSize(TCP_SEND_BUFFER_SIZE);
       client.getSessionConfig().setUseReadOperation(true);
 
       final AtomicLong count = new AtomicLong(0);