You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by ng...@apache.org on 2008/06/25 16:34:46 UTC

svn commit: r671570 - /mina/ftpserver/trunk/core/src/main/java/org/apache/ftpserver/FtpStatisticsImpl.java

Author: ngn
Date: Wed Jun 25 07:34:45 2008
New Revision: 671570

URL: http://svn.apache.org/viewvc?rev=671570&view=rev
Log:
Make FtpStatisticsImpl thread safe

Modified:
    mina/ftpserver/trunk/core/src/main/java/org/apache/ftpserver/FtpStatisticsImpl.java

Modified: mina/ftpserver/trunk/core/src/main/java/org/apache/ftpserver/FtpStatisticsImpl.java
URL: http://svn.apache.org/viewvc/mina/ftpserver/trunk/core/src/main/java/org/apache/ftpserver/FtpStatisticsImpl.java?rev=671570&r1=671569&r2=671570&view=diff
==============================================================================
--- mina/ftpserver/trunk/core/src/main/java/org/apache/ftpserver/FtpStatisticsImpl.java (original)
+++ mina/ftpserver/trunk/core/src/main/java/org/apache/ftpserver/FtpStatisticsImpl.java Wed Jun 25 07:34:45 2008
@@ -371,12 +371,13 @@
         }
 
         synchronized (user) {
-            UserLogins statisticsTable = userLoginTable.get(user.getName());
+            UserLogins userLogins = userLoginTable.get(user.getName());
 
-            if (statisticsTable != null) {
-                statisticsTable.totalLogins.decrementAndGet();
+            if (userLogins != null) {
+                userLogins.totalLogins.decrementAndGet();
                 if (session.getRemoteAddress() instanceof InetSocketAddress) {
                     InetAddress address = ((InetSocketAddress) session.getRemoteAddress()).getAddress();
+                    userLogins.loginsFromInetAddress(address).decrementAndGet();
                 }
             }