You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by jv...@apache.org on 2007/09/13 18:04:07 UTC
svn commit: r575339 - in
/mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr:
APRIoProcessor.java APRSessionImpl.java
Author: jvermillard
Date: Thu Sep 13 09:04:06 2007
New Revision: 575339
URL: http://svn.apache.org/viewvc?rev=575339&view=rev
Log:
correct closing of session
Modified:
mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRIoProcessor.java
mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRSessionImpl.java
Modified: mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRIoProcessor.java
URL: http://svn.apache.org/viewvc/mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRIoProcessor.java?rev=575339&r1=575338&r2=575339&view=diff
==============================================================================
--- mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRIoProcessor.java (original)
+++ mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRIoProcessor.java Thu Sep 13 09:04:06 2007
@@ -347,6 +347,7 @@
}
private class Worker implements Runnable {
+
public void run() {
Thread.currentThread().setName(APRIoProcessor.this.threadName);
@@ -367,7 +368,7 @@
long[] desc = new long[socketCount * 2];
/* use 100 milliseconds poll timeout, TODO : parameterize for more latency/CPU usage control*/
- int rv = Poll.poll(pollset, 100000, desc, false);
+ int rv = Poll.poll(pollset, 1000000, desc, false);
if (rv > 0) {
for (int n = 0; n < rv; n++) {
long clientSock = desc[n * 2 + 1];
Modified: mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRSessionImpl.java
URL: http://svn.apache.org/viewvc/mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRSessionImpl.java?rev=575339&r1=575338&r2=575339&view=diff
==============================================================================
--- mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRSessionImpl.java (original)
+++ mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr/APRSessionImpl.java Thu Sep 13 09:04:06 2007
@@ -144,6 +144,11 @@
return size;
}
+ @Override
+ protected void close0() {
+ filterChain.fireFilterClose(this);
+ }
+
public IoService getService() {
return service;
}