Author: jmesnil
Date: 2008-03-18 08:16:43 -0400 (Tue, 18 Mar 2008)
New Revision: 3888
Modified:
projects/network-benchmark/src/network/NetworkClientTest.java
Log:
* added ENABLE_TCP_NO_DELAY to BIO and MINA clients
Modified: projects/network-benchmark/src/network/NetworkClientTest.java
===================================================================
--- projects/network-benchmark/src/network/NetworkClientTest.java 2008-03-18 12:12:22 UTC (rev 3887)
+++ projects/network-benchmark/src/network/NetworkClientTest.java 2008-03-18 12:16:43 UTC (rev 3888)
@@ -34,6 +34,8 @@
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;
// Attributes ----------------------------------------------------
@@ -41,7 +43,8 @@
static {
System.out.println("Duration: " + DURATION + " ms");
- System.out.println("Message size: " + MESSAGE_SIZE + " bytes\n");
+ System.out.println("Message size: " + MESSAGE_SIZE + " bytes");
+ System.out.println("TCP no delay: " + ENABLE_TCP_NO_DELAY + "\n");
}
// Constructors --------------------------------------------------
@@ -139,6 +142,7 @@
throws UnknownHostException, IOException
{
Socket clientSocket = new Socket();
+ clientSocket.setTcpNoDelay(ENABLE_TCP_NO_DELAY);
clientSocket.connect(address);
OutputStream os = clientSocket.getOutputStream();
InputStream is = clientSocket.getInputStream();
@@ -167,6 +171,7 @@
throws UnknownHostException, IOException, InterruptedException
{
final Socket clientSocket = new Socket();
+ clientSocket.setTcpNoDelay(ENABLE_TCP_NO_DELAY);
clientSocket.connect(address);
OutputStream os = clientSocket.getOutputStream();
final InputStream is = clientSocket.getInputStream();
@@ -222,6 +227,7 @@
private void startBlockingMINAClient(SocketAddress address)
{
NioSocketConnector client = new NioSocketConnector();
+ client.getSessionConfig().setTcpNoDelay(ENABLE_TCP_NO_DELAY);
client.getSessionConfig().setUseReadOperation(true);
final AtomicLong count = new AtomicLong(0);
@@ -261,6 +267,7 @@
throws InterruptedException
{
NioSocketConnector client = new NioSocketConnector();
+ client.getSessionConfig().setTcpNoDelay(ENABLE_TCP_NO_DELAY);
client.getSessionConfig().setUseReadOperation(true);
final AtomicLong count = new AtomicLong(0);