[jboss-cvs] JBossAS SVN: r64830 - branches/JBPAPP_4_2_0_GA_CP/ejb3/src/test/org/jboss/ejb3/test/stateful/unit.

[jboss-cvs-commits at lists.jboss.org]

Author: bdecoste
Date: 2007-08-23 20:27:55 -0400 (Thu, 23 Aug 2007)
New Revision: 64830

Modified:
   branches/JBPAPP_4_2_0_GA_CP/ejb3/src/test/org/jboss/ejb3/test/stateful/unit/RemoteUnitTestCase.java
Log:
fixed infinite loop in org.jboss.ejb3.test.stateful.unit.RemoteUnitTestCase#testConcurrentClusteredTimeoutRemoval

Modified: branches/JBPAPP_4_2_0_GA_CP/ejb3/src/test/org/jboss/ejb3/test/stateful/unit/RemoteUnitTestCase.java
===================================================================
--- branches/JBPAPP_4_2_0_GA_CP/ejb3/src/test/org/jboss/ejb3/test/stateful/unit/RemoteUnitTestCase.java	2007-08-23 22:21:31 UTC (rev 64829)
+++ branches/JBPAPP_4_2_0_GA_CP/ejb3/src/test/org/jboss/ejb3/test/stateful/unit/RemoteUnitTestCase.java	2007-08-24 00:27:55 UTC (rev 64830)
@@ -123,7 +123,7 @@
       public Exception ex;
       private int id;
       private int wait;
-      public Exception e;
+      public Exception failure;
       public boolean removed = false;
       
       public ConcurrentStatefulTimeoutClient(int id, int wait)
@@ -165,7 +165,7 @@
             }
             catch (Exception e)
             {
-               this.e = e;
+               this.failure = e;
             }
          }
       }
@@ -508,9 +508,12 @@
       while (!allRemoved)
       {
          int i = 0;
-         while (i < numThreads && clients[i].removed)
+         while (i < numThreads && clients[i].removed && clients[i].failure == null)
             ++i;
          
+         if (i < numThreads && clients[i].failure != null)
+            throw clients[i].failure;
+         
          System.out.println("----- removed " + i);
          
          if (i == numThreads)