svn commit: r575339 - in /mina/sandbox/jvermillard/apr/src/main/java/org/apache/mina/transport/apr: APRIoProcessor.java APRSessionImpl.java

[jvermillard]

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