Repository: mina Updated Branches: refs/heads/trunk 9fe463d1d -> 904f44473
Fix previous commit Project: http://git-wip-us.apache.org/repos/asf/mina/repo Commit: http://git-wip-us.apache.org/repos/asf/mina/commit/904f4447 Tree: http://git-wip-us.apache.org/repos/asf/mina/tree/904f4447 Diff: http://git-wip-us.apache.org/repos/asf/mina/diff/904f4447 Branch: refs/heads/trunk Commit: 904f44473dde13a7dd7848626998f6a0ba06a56e Parents: 9fe463d Author: Jeff MAURY <[email protected]> Authored: Fri Dec 12 22:21:00 2014 +0100 Committer: Jeff MAURY <[email protected]> Committed: Fri Dec 12 22:21:00 2014 +0100 ---------------------------------------------------------------------- .../java/org/apache/mina/core/bio/udp/BioUdpBenchmarkServer.java | 4 ++-- .../org/apache/mina/core/nio/tcp/Mina3TcpBenchmarkClient.java | 4 ++-- .../org/apache/mina/core/nio/tcp/Mina3TcpBenchmarkServer.java | 4 ++-- .../org/apache/mina/core/nio/udp/Mina3UdpBenchmarkClient.java | 4 ++-- .../org/apache/mina/core/nio/udp/Mina3UdpBenchmarkServer.java | 4 ++-- 5 files changed, 10 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mina/blob/904f4447/benchmarks/common/src/test/java/org/apache/mina/core/bio/udp/BioUdpBenchmarkServer.java ---------------------------------------------------------------------- diff --git a/benchmarks/common/src/test/java/org/apache/mina/core/bio/udp/BioUdpBenchmarkServer.java b/benchmarks/common/src/test/java/org/apache/mina/core/bio/udp/BioUdpBenchmarkServer.java index fd9af8d..5fae052 100644 --- a/benchmarks/common/src/test/java/org/apache/mina/core/bio/udp/BioUdpBenchmarkServer.java +++ b/benchmarks/common/src/test/java/org/apache/mina/core/bio/udp/BioUdpBenchmarkServer.java @@ -23,8 +23,8 @@ import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; +import org.apache.mina.api.AbstractIoHandler; import org.apache.mina.api.IdleStatus; -import org.apache.mina.api.IoHandler; import org.apache.mina.api.IoService; import org.apache.mina.api.IoSession; import org.apache.mina.core.BenchmarkServer; @@ -68,7 +68,7 @@ public class BioUdpBenchmarkServer implements BenchmarkServer { UdpSessionConfig config = new DefaultUdpSessionConfig(); config.setReadBufferSize(65536); udpServer = new BioUdpServer(config, null); - udpServer.setIoHandler(new IoHandler() { + udpServer.setIoHandler(new AbstractIoHandler() { @Override public void sessionOpened(IoSession session) { session.setAttribute(STATE_ATTRIBUTE, State.WAIT_FOR_FIRST_BYTE_LENGTH); http://git-wip-us.apache.org/repos/asf/mina/blob/904f4447/benchmarks/common/src/test/java/org/apache/mina/core/nio/tcp/Mina3TcpBenchmarkClient.java ---------------------------------------------------------------------- diff --git a/benchmarks/common/src/test/java/org/apache/mina/core/nio/tcp/Mina3TcpBenchmarkClient.java b/benchmarks/common/src/test/java/org/apache/mina/core/nio/tcp/Mina3TcpBenchmarkClient.java index 44ceeb7..77acf2a 100644 --- a/benchmarks/common/src/test/java/org/apache/mina/core/nio/tcp/Mina3TcpBenchmarkClient.java +++ b/benchmarks/common/src/test/java/org/apache/mina/core/nio/tcp/Mina3TcpBenchmarkClient.java @@ -24,8 +24,8 @@ import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.util.concurrent.CountDownLatch; +import org.apache.mina.api.AbstractIoHandler; import org.apache.mina.api.IdleStatus; -import org.apache.mina.api.IoHandler; import org.apache.mina.api.IoService; import org.apache.mina.api.IoSession; import org.apache.mina.core.BenchmarkClient; @@ -46,7 +46,7 @@ public class Mina3TcpBenchmarkClient implements BenchmarkClient { client = new NioTcpClient(); client.getSessionConfig().setSendBufferSize(64 * 1024); client.getSessionConfig().setTcpNoDelay(true); - client.setIoHandler(new IoHandler() { + client.setIoHandler(new AbstractIoHandler() { private void sendMessage(IoSession session, byte[] data) { ByteBuffer iobuf = ByteBuffer.wrap(data); session.write(iobuf); http://git-wip-us.apache.org/repos/asf/mina/blob/904f4447/benchmarks/common/src/test/java/org/apache/mina/core/nio/tcp/Mina3TcpBenchmarkServer.java ---------------------------------------------------------------------- diff --git a/benchmarks/common/src/test/java/org/apache/mina/core/nio/tcp/Mina3TcpBenchmarkServer.java b/benchmarks/common/src/test/java/org/apache/mina/core/nio/tcp/Mina3TcpBenchmarkServer.java index c8153a2..f4e8c22 100644 --- a/benchmarks/common/src/test/java/org/apache/mina/core/nio/tcp/Mina3TcpBenchmarkServer.java +++ b/benchmarks/common/src/test/java/org/apache/mina/core/nio/tcp/Mina3TcpBenchmarkServer.java @@ -23,8 +23,8 @@ import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; +import org.apache.mina.api.AbstractIoHandler; import org.apache.mina.api.IdleStatus; -import org.apache.mina.api.IoHandler; import org.apache.mina.api.IoService; import org.apache.mina.api.IoSession; import org.apache.mina.core.BenchmarkServer; @@ -65,7 +65,7 @@ public class Mina3TcpBenchmarkServer implements BenchmarkServer { tcpServer = new NioTcpServer(new FixedSelectorLoopPool("Server", 1), null); tcpServer.getSessionConfig().setReadBufferSize(128 * 1024); tcpServer.getSessionConfig().setTcpNoDelay(true); - tcpServer.setIoHandler(new IoHandler() { + tcpServer.setIoHandler(new AbstractIoHandler() { public void sessionOpened(IoSession session) { session.setAttribute(STATE_ATTRIBUTE, State.WAIT_FOR_FIRST_BYTE_LENGTH); } http://git-wip-us.apache.org/repos/asf/mina/blob/904f4447/benchmarks/common/src/test/java/org/apache/mina/core/nio/udp/Mina3UdpBenchmarkClient.java ---------------------------------------------------------------------- diff --git a/benchmarks/common/src/test/java/org/apache/mina/core/nio/udp/Mina3UdpBenchmarkClient.java b/benchmarks/common/src/test/java/org/apache/mina/core/nio/udp/Mina3UdpBenchmarkClient.java index a4dcf4d..f8d7dc7 100644 --- a/benchmarks/common/src/test/java/org/apache/mina/core/nio/udp/Mina3UdpBenchmarkClient.java +++ b/benchmarks/common/src/test/java/org/apache/mina/core/nio/udp/Mina3UdpBenchmarkClient.java @@ -25,9 +25,9 @@ import java.nio.ByteBuffer; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; +import org.apache.mina.api.AbstractIoHandler; import org.apache.mina.api.IdleStatus; import org.apache.mina.api.IoFuture; -import org.apache.mina.api.IoHandler; import org.apache.mina.api.IoService; import org.apache.mina.api.IoSession; import org.apache.mina.core.BenchmarkClient; @@ -47,7 +47,7 @@ public class Mina3UdpBenchmarkClient implements BenchmarkClient { */ public void start(int port, final CountDownLatch counter, final byte[] data) throws IOException { udpClient = new NioUdpClient(); - udpClient.setIoHandler(new IoHandler() { + udpClient.setIoHandler(new AbstractIoHandler() { private void sendMessage(IoSession session, byte[] data) { ByteBuffer iobuf = ByteBuffer.wrap(data); session.write(iobuf); http://git-wip-us.apache.org/repos/asf/mina/blob/904f4447/benchmarks/common/src/test/java/org/apache/mina/core/nio/udp/Mina3UdpBenchmarkServer.java ---------------------------------------------------------------------- diff --git a/benchmarks/common/src/test/java/org/apache/mina/core/nio/udp/Mina3UdpBenchmarkServer.java b/benchmarks/common/src/test/java/org/apache/mina/core/nio/udp/Mina3UdpBenchmarkServer.java index a9bf2a9..63aa148 100644 --- a/benchmarks/common/src/test/java/org/apache/mina/core/nio/udp/Mina3UdpBenchmarkServer.java +++ b/benchmarks/common/src/test/java/org/apache/mina/core/nio/udp/Mina3UdpBenchmarkServer.java @@ -23,8 +23,8 @@ import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; +import org.apache.mina.api.AbstractIoHandler; import org.apache.mina.api.IdleStatus; -import org.apache.mina.api.IoHandler; import org.apache.mina.api.IoService; import org.apache.mina.api.IoSession; import org.apache.mina.core.BenchmarkServer; @@ -68,7 +68,7 @@ public class Mina3UdpBenchmarkServer implements BenchmarkServer { UdpSessionConfig config = new DefaultUdpSessionConfig(); config.setReadBufferSize(65536); udpServer = new NioUdpServer(config); - udpServer.setIoHandler(new IoHandler() { + udpServer.setIoHandler(new AbstractIoHandler() { @Override public void sessionOpened(IoSession session) { session.setAttribute(STATE_ATTRIBUTE, State.WAIT_FOR_FIRST_BYTE_LENGTH);
