svn commit: r592225 - in /mina/trunk/example/src/main/java/org/apache/mina/example/echoserver: EchoProtocolHandler.java Main.java

[trustin]

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);