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