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/06 05:59:47 UTC
svn commit: r592279 - in /mina:
branches/1.0/core/src/main/java/org/apache/mina/common/support/
branches/1.1/core/src/main/java/org/apache/mina/common/support/
trunk/core/src/main/java/org/apache/mina/common/
Author: trustin
Date: Mon Nov 5 20:59:46 2007
New Revision: 592279
URL: http://svn.apache.org/viewvc?rev=592279&view=rev
Log:
Fixed a problem that lastReadTime and lastWriteTime is not maintained in VM-pipe transport.
Modified:
mina/branches/1.0/core/src/main/java/org/apache/mina/common/support/BaseIoSession.java
mina/branches/1.1/core/src/main/java/org/apache/mina/common/support/BaseIoSession.java
mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSession.java
Modified: mina/branches/1.0/core/src/main/java/org/apache/mina/common/support/BaseIoSession.java
URL: http://svn.apache.org/viewvc/mina/branches/1.0/core/src/main/java/org/apache/mina/common/support/BaseIoSession.java?rev=592279&r1=592278&r2=592279&view=diff
==============================================================================
--- mina/branches/1.0/core/src/main/java/org/apache/mina/common/support/BaseIoSession.java (original)
+++ mina/branches/1.0/core/src/main/java/org/apache/mina/common/support/BaseIoSession.java Mon Nov 5 20:59:46 2007
@@ -368,10 +368,12 @@
public void increaseReadMessages() {
readMessages++;
+ lastReadTime = System.currentTimeMillis();
}
public void increaseWrittenMessages() {
writtenMessages++;
+ lastWriteTime = System.currentTimeMillis();
scheduledWriteRequests.decrementAndGet();
}
Modified: mina/branches/1.1/core/src/main/java/org/apache/mina/common/support/BaseIoSession.java
URL: http://svn.apache.org/viewvc/mina/branches/1.1/core/src/main/java/org/apache/mina/common/support/BaseIoSession.java?rev=592279&r1=592278&r2=592279&view=diff
==============================================================================
--- mina/branches/1.1/core/src/main/java/org/apache/mina/common/support/BaseIoSession.java (original)
+++ mina/branches/1.1/core/src/main/java/org/apache/mina/common/support/BaseIoSession.java Mon Nov 5 20:59:46 2007
@@ -365,10 +365,12 @@
public void increaseReadMessages() {
readMessages++;
+ lastReadTime = System.currentTimeMillis();
}
public void increaseWrittenMessages() {
writtenMessages++;
+ lastWriteTime = System.currentTimeMillis();
scheduledWriteRequests.decrementAndGet();
}
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSession.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSession.java?rev=592279&r1=592278&r2=592279&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSession.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSession.java Mon Nov 5 20:59:46 2007
@@ -385,6 +385,14 @@
}
}
+ protected void increaseReadMessages() {
+ readMessages++;
+ lastWriteTime = System.currentTimeMillis();
+ if (getService() instanceof AbstractIoService) {
+ ((AbstractIoService) getService()).increaseReadMessages();
+ }
+ }
+
protected void increaseWrittenBytesAndMessages(WriteRequest request) {
Object message = request.getMessage();
if (message instanceof IoBuffer) {
@@ -414,15 +422,9 @@
}
}
- protected void increaseReadMessages() {
- readMessages++;
- if (getService() instanceof AbstractIoService) {
- ((AbstractIoService) getService()).increaseReadMessages();
- }
- }
-
protected void increaseWrittenMessages() {
writtenMessages++;
+ lastWriteTime = System.currentTimeMillis();
if (getService() instanceof AbstractIoService) {
((AbstractIoService) getService()).increaseWrittenMessages();
}