You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by el...@apache.org on 2013/01/04 08:32:23 UTC
svn commit: r1428736 - in
/mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core:
Mina3BenchmarkClient.java Mina3BenchmarkServer.java
Mina3ClientVsMina3ServerBenchmarkBinaryTest.java
Author: elecharny
Date: Fri Jan 4 07:32:23 2013
New Revision: 1428736
URL: http://svn.apache.org/viewvc?rev=1428736&view=rev
Log:
Commented the sysout, added some more loops
Modified:
mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3BenchmarkClient.java
mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3BenchmarkServer.java
mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3ClientVsMina3ServerBenchmarkBinaryTest.java
Modified: mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3BenchmarkClient.java
URL: http://svn.apache.org/viewvc/mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3BenchmarkClient.java?rev=1428736&r1=1428735&r2=1428736&view=diff
==============================================================================
--- mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3BenchmarkClient.java (original)
+++ mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3BenchmarkClient.java Fri Jan 4 07:32:23 2013
@@ -51,21 +51,21 @@ public class Mina3BenchmarkClient implem
}
public void sessionOpened(IoSession session) {
- System.out.println("Client session opened");
+ //System.out.println("Client session opened");
sendMessage(session, data);
}
public void messageReceived(IoSession session, Object message) {
- System.out.println("Client message received : " + message);
+ //System.out.println("Client message received : " + message);
if (message instanceof ByteBuffer) {
ByteBuffer buffer = (ByteBuffer) message;
- System.out.println("length=" + buffer.remaining());
+ //System.out.println("length=" + buffer.remaining());
for (int i = 0; i < buffer.remaining(); ++i) {
counter.countDown();
long count = counter.getCount();
if (count > 0) {
sendMessage(session, data);
- if (count % 10000 == 0) {
+ if (count % 100000 == 0) {
System.out.println("Received " + count);
}
}
@@ -87,7 +87,7 @@ public class Mina3BenchmarkClient implem
@Override
public void messageSent(IoSession session, Object message) {
- System.out.println("Client message sent : " + message);
+ //System.out.println("Client message sent : " + message);
}
@Override
Modified: mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3BenchmarkServer.java
URL: http://svn.apache.org/viewvc/mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3BenchmarkServer.java?rev=1428736&r1=1428735&r2=1428736&view=diff
==============================================================================
--- mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3BenchmarkServer.java (original)
+++ mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3BenchmarkServer.java Fri Jan 4 07:32:23 2013
@@ -63,18 +63,12 @@ public class Mina3BenchmarkServer implem
tcpServer.getSessionConfig().setTcpNoDelay(true);
tcpServer.setIoHandler(new IoHandler() {
public void sessionOpened(IoSession session) {
- System.out.println("Server session opened");
+ //System.out.println("Server session opened");
session.setAttribute(STATE_ATTRIBUTE, State.WAIT_FOR_FIRST_BYTE_LENGTH);
- State state = session.getAttribute(STATE_ATTRIBUTE);
-
- if (state == null) {
- System.out.println("State is null");
- }
-
}
public void messageReceived(IoSession session, Object message) {
- System.out.println("Server Message received : " + message);
+ //System.out.println("Server Message received : " + message);
if (message instanceof ByteBuffer) {
ByteBuffer buffer = (ByteBuffer) message;
@@ -139,7 +133,7 @@ public class Mina3BenchmarkServer implem
@Override
public void messageSent(IoSession session, Object message) {
- System.out.println("Server message sent :" + message);
+ //System.out.println("Server message sent :" + message);
}
@Override
Modified: mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3ClientVsMina3ServerBenchmarkBinaryTest.java
URL: http://svn.apache.org/viewvc/mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3ClientVsMina3ServerBenchmarkBinaryTest.java?rev=1428736&r1=1428735&r2=1428736&view=diff
==============================================================================
--- mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3ClientVsMina3ServerBenchmarkBinaryTest.java (original)
+++ mina/mina/trunk/benchmarks/src/test/java/org/apache/mina/core/Mina3ClientVsMina3ServerBenchmarkBinaryTest.java Fri Jan 4 07:32:23 2013
@@ -53,14 +53,14 @@ public class Mina3ClientVsMina3ServerBen
public Type getServerType() {
return Type.Mina;
}
-
+
@Parameters
public static Collection<Object[]> getParameters() {
Object[][] parameters = new Object[][] {
- { 200000, 10, 2 * 60 } //,
- //{ 1000000, 1 * 1024, 2 * 60 },
- //{ 1000000, 10 * 1024, 2 * 60 },
- //{ 100, 64 * 1024 * 1024, 10 * 60 }
+ { 1000000, 10, 2 * 60 },
+ { 1000000, 1 * 1024, 2 * 60 },
+ { 1000000, 10 * 1024, 2 * 60 },
+ { 100, 64 * 1024 * 1024, 10 * 60 }
};
return Arrays.asList(parameters);
}