Author: mircea.markus
Date: 2008-05-12 16:45:48 -0400 (Mon, 12 May 2008)
New Revision: 5833
Modified:
core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferConcurrencyTest.java
Log:
fixed issue
Modified:
core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferConcurrencyTest.java
===================================================================
---
core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferConcurrencyTest.java 2008-05-12
19:24:51 UTC (rev 5832)
+++
core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferConcurrencyTest.java 2008-05-12
20:45:48 UTC (rev 5833)
@@ -105,7 +105,8 @@
semaphore.release(count);
// Sleep to ensure the threads get all the semaphore tickets
- waitUntillUsersFinish(activators);
+ TestingUtil.sleepThread((long) 1000);
+
// Reacquire the semaphore tickets; when we have them all
// we know the threads are done
for (int i = 0; i < count; i++)
@@ -159,15 +160,6 @@
}
- private void waitUntillUsersFinish(CacheActivator[] activators)
- throws Exception
- {
- for (CacheActivator activator : activators)
- {
- activator.waitUntillFinished();
- }
- }
-
private void waitTillAllReplicationsFinish(int count, CacheSPI[] caches)
throws Exception
{