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