Fix previous commit

apache · Dec 12, 2014 · 904f444 · 904f444
1 parent 9fe463d
commit 904f444
Show file tree

Hide file tree

Showing 5 changed files with 10 additions and 10 deletions.
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
@@ -23,8 +23,8 @@
 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 void start(int port) throws IOException {
         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);

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
@@ -24,8 +24,8 @@
 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 void start(int port, final CountDownLatch counter, final byte[] data) thr
         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);

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
@@ -23,8 +23,8 @@
 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 void start(int port) throws IOException {
         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);
             }

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
@@ -25,9 +25,9 @@
 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);

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
@@ -23,8 +23,8 @@
 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 void start(int port) throws IOException {
         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);