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/27 04:27:43 UTC

svn commit: r598509 - in /mina/trunk/core/src/main/java/org/apache/mina/common: AbstractIoService.java DefaultIoFilterChain.java

Author: trustin
Date: Mon Nov 26 19:27:42 2007
New Revision: 598509

URL: http://svn.apache.org/viewvc?rev=598509&view=rev
Log:
Fixed a bug that lastIoTime of an AbstractIoService is not updated on sessionCreated event


Modified:
    mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoService.java
    mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChain.java

Modified: mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoService.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoService.java?rev=598509&r1=598508&r2=598509&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoService.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoService.java Mon Nov 26 19:27:42 2007
@@ -368,8 +368,16 @@
         return lastReadTime;
     }
 
+    protected final void setLastReadTime(long lastReadTime) {
+        this.lastReadTime = lastReadTime;
+    }
+
     public final long getLastWriteTime() {
         return lastWriteTime;
+    }
+    
+    protected final void setLastWriteTime(long lastWriteTime) {
+        this.lastWriteTime = lastWriteTime;
     }
 
     public final long getWrittenBytes() {

Modified: mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChain.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChain.java?rev=598509&r1=598508&r2=598509&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChain.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChain.java Mon Nov 26 19:27:42 2007
@@ -322,6 +322,13 @@
     }
 
     public void fireSessionCreated() {
+        IoService service = session.getService();
+        if (service instanceof AbstractIoService) {
+            AbstractIoService s = (AbstractIoService) service;
+            s.setLastReadTime(session.getCreationTime());
+            s.setLastWriteTime(session.getCreationTime());
+        }
+
         Entry head = this.head;
         callNextSessionCreated(head, session);
     }