You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by je...@apache.org on 2014/12/12 22:21:08 UTC
mina git commit: Fix previous commit
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 <je...@apache.org>
Authored: Fri Dec 12 22:21:00 2014 +0100
Committer: Jeff MAURY <je...@apache.org>
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);