You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by tr...@apache.org on 2007/11/06 03:18:03 UTC
svn commit: r592225 - in
/mina/trunk/example/src/main/java/org/apache/mina/example/echoserver:
EchoProtocolHandler.java Main.java
Author: trustin
Date: Mon Nov 5 18:18:02 2007
New Revision: 592225
URL: http://svn.apache.org/viewvc?rev=592225&view=rev
Log:
Now echoserver example performs very very well without any custom configuration. :D
Modified:
mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/EchoProtocolHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/Main.java
Modified: mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/EchoProtocolHandler.java
URL: http://svn.apache.org/viewvc/mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/EchoProtocolHandler.java?rev=592225&r1=592224&r2=592225&view=diff
==============================================================================
--- mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/EchoProtocolHandler.java (original)
+++ mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/EchoProtocolHandler.java Mon Nov 5 18:18:02 2007
@@ -21,12 +21,10 @@
import org.apache.mina.common.IdleStatus;
import org.apache.mina.common.IoBuffer;
-import org.apache.mina.common.IoFutureListener;
import org.apache.mina.common.IoHandler;
import org.apache.mina.common.IoHandlerAdapter;
import org.apache.mina.common.IoSession;
import org.apache.mina.common.IoSessionLogger;
-import org.apache.mina.common.WriteFuture;
import org.apache.mina.filter.ssl.SslFilter;
/**
@@ -69,11 +67,6 @@
public void messageReceived(IoSession session, Object message)
throws Exception {
// Write the received data back to remote peer
- final IoBuffer src = (IoBuffer) message;
- session.write(src.duplicate()).addListener(new IoFutureListener<WriteFuture>() {
- public void operationComplete(WriteFuture future) {
- src.free();
- }
- });
+ session.write(((IoBuffer) message).duplicate());
}
}
Modified: mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/Main.java
URL: http://svn.apache.org/viewvc/mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/Main.java?rev=592225&r1=592224&r2=592225&view=diff
==============================================================================
--- mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/Main.java (original)
+++ mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/Main.java Mon Nov 5 18:18:02 2007
@@ -22,9 +22,7 @@
import java.net.InetSocketAddress;
import java.util.concurrent.Executors;
-import org.apache.mina.common.CachedBufferAllocator;
import org.apache.mina.common.DefaultIoFilterChainBuilder;
-import org.apache.mina.common.IoBuffer;
import org.apache.mina.example.echoserver.ssl.BogusSslContextFactory;
import org.apache.mina.filter.logging.LoggingFilter;
import org.apache.mina.filter.ssl.SslFilter;
@@ -48,8 +46,6 @@
SocketAcceptor acceptor = new NioSocketAcceptor(Executors.newCachedThreadPool());
DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();
- IoBuffer.setAllocator(new CachedBufferAllocator());
-
// Add SSL filter if SSL is enabled.
if (USE_SSL) {
addSSLSupport(chain);