[jbosscache-commits] JBoss Cache SVN: r6441 - core/trunk/src/test/java/org/jboss/cache/statetransfer.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2008-07-30 11:42:20 -0400 (Wed, 30 Jul 2008)
New Revision: 6441

Modified:
   core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferConcurrencyTest.java
   core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferTestBase.java
Log:
Added better state retrieval timeout

Modified: core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferConcurrencyTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferConcurrencyTest.java	2008-07-30 15:23:30 UTC (rev 6440)
+++ core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferConcurrencyTest.java	2008-07-30 15:42:20 UTC (rev 6441)
@@ -63,7 +63,6 @@
     *
     * @throws Exception
     */
-   @Test(invocationCount = 5)
    public void testConcurrentActivationAsync() throws Exception
    {
       concurrentActivationTest(false);
@@ -672,7 +671,7 @@
                      boolean sync, CacheSPI[] caches)
             throws Exception
       {
-         super(semaphore, name, sync, false);
+         super(semaphore, name, sync, false, 120000);
          this.caches = caches;
       }
 

Modified: core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferTestBase.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferTestBase.java	2008-07-30 15:23:30 UTC (rev 6440)
+++ core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferTestBase.java	2008-07-30 15:42:20 UTC (rev 6441)
@@ -446,6 +446,24 @@
          }
       }
 
+      CacheUser(Semaphore semaphore,
+                String name,
+                boolean sync,
+                boolean activateRoot, long stateRetrievalTimeout)
+            throws Exception
+      {
+         cache = createCache(name, sync, true, false, false, false, true);
+         cache.getConfiguration().setStateRetrievalTimeout(stateRetrievalTimeout);
+         cache.start();
+         this.semaphore = semaphore;
+         this.name = name;
+
+         if (activateRoot)
+         {
+            cache.getRegion(Fqn.ROOT, true).activate();
+         }
+      }
+
       public void run()
       {
          boolean acquired = false;