You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by tr...@apache.org on 2006/09/05 05:33:34 UTC

svn commit: r440239 - /directory/trunks/mina/core/src/test/java/org/apache/mina/filter/thread/ThreadPoolFilterRegressionTest.java

Author: trustin
Date: Mon Sep  4 20:33:33 2006
New Revision: 440239

URL: http://svn.apache.org/viewvc?view=rev&rev=440239
Log:
Added additional check to find an additional thread pool problem.

Modified:
    directory/trunks/mina/core/src/test/java/org/apache/mina/filter/thread/ThreadPoolFilterRegressionTest.java

Modified: directory/trunks/mina/core/src/test/java/org/apache/mina/filter/thread/ThreadPoolFilterRegressionTest.java
URL: http://svn.apache.org/viewvc/directory/trunks/mina/core/src/test/java/org/apache/mina/filter/thread/ThreadPoolFilterRegressionTest.java?view=diff&rev=440239&r1=440238&r2=440239
==============================================================================
--- directory/trunks/mina/core/src/test/java/org/apache/mina/filter/thread/ThreadPoolFilterRegressionTest.java (original)
+++ directory/trunks/mina/core/src/test/java/org/apache/mina/filter/thread/ThreadPoolFilterRegressionTest.java Mon Sep  4 20:33:33 2006
@@ -73,7 +73,7 @@
     public void testEventOrder() throws Throwable
     {
         final EventOrderChecker nextFilter = new EventOrderChecker();
-        final IoSession[] sessions = new IoSession[]
+        final EventOrderCounter[] sessions = new EventOrderCounter[]
         {
             new EventOrderCounter(),
             new EventOrderCounter(),
@@ -86,11 +86,12 @@
             new EventOrderCounter(),
             new EventOrderCounter(),
         };
+        final int loop = 1000000;
         final int end = sessions.length - 1;
         final ThreadPoolFilter filter = this.filter;
         filter.getThreadPool().setKeepAliveTime( 3000 );
         
-        for( int i = 0; i < 1000000 ; i++ )
+        for( int i = 0; i < loop ; i++ )
         {
             Integer objI = new Integer( i );
 
@@ -108,6 +109,10 @@
         Thread.sleep( 3500 );
         
         Assert.assertEquals( 1, filter.getThreadPool().getPoolSize() );
+        for( int i = end; i >= 0; i-- )
+        {
+            Assert.assertEquals( loop - 1, sessions[ i ].lastCount.intValue() );
+        }
     }
     
     public void testShutdown() throws Exception