Author: manik.surtani(a)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;