You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by no...@apache.org on 2010/12/10 10:45:13 UTC

svn commit: r1044253 - /james/protocols/trunk/impl/src/main/java/org/apache/james/protocols/impl/AbstractChannelUpstreamHandler.java

Author: norman
Date: Fri Dec 10 09:45:13 2010
New Revision: 1044253

URL: http://svn.apache.org/viewvc?rev=1044253&view=rev
Log:
Log connection establish / close events

Modified:
    james/protocols/trunk/impl/src/main/java/org/apache/james/protocols/impl/AbstractChannelUpstreamHandler.java

Modified: james/protocols/trunk/impl/src/main/java/org/apache/james/protocols/impl/AbstractChannelUpstreamHandler.java
URL: http://svn.apache.org/viewvc/james/protocols/trunk/impl/src/main/java/org/apache/james/protocols/impl/AbstractChannelUpstreamHandler.java?rev=1044253&r1=1044252&r2=1044253&view=diff
==============================================================================
--- james/protocols/trunk/impl/src/main/java/org/apache/james/protocols/impl/AbstractChannelUpstreamHandler.java (original)
+++ james/protocols/trunk/impl/src/main/java/org/apache/james/protocols/impl/AbstractChannelUpstreamHandler.java Fri Dec 10 09:45:13 2010
@@ -70,6 +70,7 @@ public abstract class AbstractChannelUps
         List<ConnectHandler> connectHandlers = chain.getHandlers(ConnectHandler.class);
         List<ConnectHandlerResultHandler> resultHandlers = chain.getHandlers(ConnectHandlerResultHandler.class);
         ProtocolSession session = (ProtocolSession) attributes.get(ctx.getChannel());
+        session.getLogger().info("Connection established from " + session.getRemoteHost() + " (" + session.getRemoteIPAddress()+ ")");
         if (connectHandlers != null) {
             for (int i = 0; i < connectHandlers.size(); i++) {
                 ConnectHandler cHandler = connectHandlers.get(i);
@@ -134,8 +135,10 @@ public abstract class AbstractChannelUps
 
     @Override
     public void channelClosed(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
+        ProtocolSession session = (ProtocolSession) attributes.get(ctx.getChannel());
+        session.getLogger().info("Connection closed for " + session.getRemoteHost() + " (" + session.getRemoteIPAddress()+ ")");
         cleanup(ctx.getChannel());
-        
+
         super.channelClosed(ctx, e);
     }
 



---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org