svn commit: r541023 - /incubator/ftpserver/trunk/core/src/java/org/apache/ftpserver/listener/mina/MinaFtpProtocolHandler.java

[ng...@apache.org]

Author: ngn
Date: Wed May 23 11:48:14 2007
New Revision: 541023

URL: http://svn.apache.org/viewvc?view=rev&rev=541023
Log:
Fix for bug where a connection manager would not find MINA sessions to close them after timeout. New connections was not registred with the ConnectionManager. Reported by Steve Jones. (FTPSERVER-86)

Modified:
    incubator/ftpserver/trunk/core/src/java/org/apache/ftpserver/listener/mina/MinaFtpProtocolHandler.java

Modified: incubator/ftpserver/trunk/core/src/java/org/apache/ftpserver/listener/mina/MinaFtpProtocolHandler.java
URL: http://svn.apache.org/viewvc/incubator/ftpserver/trunk/core/src/java/org/apache/ftpserver/listener/mina/MinaFtpProtocolHandler.java?view=diff&rev=541023&r1=541022&r2=541023
==============================================================================
--- incubator/ftpserver/trunk/core/src/java/org/apache/ftpserver/listener/mina/MinaFtpProtocolHandler.java (original)
+++ incubator/ftpserver/trunk/core/src/java/org/apache/ftpserver/listener/mina/MinaFtpProtocolHandler.java Wed May 23 11:48:14 2007
@@ -26,6 +26,7 @@
 import org.apache.ftpserver.ftplet.FtpException;
 import org.apache.ftpserver.ftplet.FtpRequest;
 import org.apache.ftpserver.interfaces.FtpServerContext;
+import org.apache.ftpserver.listener.ConnectionManager;
 import org.apache.ftpserver.listener.ConnectionObserver;
 import org.apache.ftpserver.listener.FtpProtocolHandler;
 import org.apache.mina.common.IdleStatus;
@@ -59,6 +60,9 @@
      */
     public void sessionCreated(IoSession session) throws Exception {
         MinaConnection connection = new MinaConnection(serverContext, session, listener);
+        ConnectionManager conManager = serverContext.getConnectionManager();
+        conManager.newConnection(connection);
+        
         session.setAttribute(CONNECTION_KEY, connection);
         
         MinaFtpResponseOutput output = new MinaFtpResponseOutput(session);