Author: mircea.markus
Date: 2009-02-02 08:07:49 -0500 (Mon, 02 Feb 2009)
New Revision: 7623
Modified:
core/trunk/src/test/java/org/jboss/cache/loader/AsyncFileCacheLoaderTest.java
Log:
made more stable
Modified: core/trunk/src/test/java/org/jboss/cache/loader/AsyncFileCacheLoaderTest.java
===================================================================
---
core/trunk/src/test/java/org/jboss/cache/loader/AsyncFileCacheLoaderTest.java 2009-01-31
10:39:31 UTC (rev 7622)
+++
core/trunk/src/test/java/org/jboss/cache/loader/AsyncFileCacheLoaderTest.java 2009-02-02
13:07:49 UTC (rev 7623)
@@ -21,7 +21,7 @@
import org.jboss.cache.factories.UnitTestConfigurationFactory;
import org.jboss.cache.util.TestingUtil;
-@Test(groups = "functional", sequential = true, testName =
"loader.AsyncFileCacheLoaderTest")
+@Test(groups = "functional", testName =
"loader.AsyncFileCacheLoaderTest")
public class AsyncFileCacheLoaderTest
{
private CacheSPI<Object, Object> cache;
@@ -112,7 +112,13 @@
{
cache.put(fqn, "key" + i, "value1");
}
- Thread.sleep(1000);
+ //this happens async, so expect this will happen at a further point in time
+ long start = System.currentTimeMillis();
+ while (System.currentTimeMillis() - start < 50000)
+ {
+ if (loader.get(fqn) != null && loader.get(fqn).size() == 50) break;
+ Thread.sleep(100);
+ }
assertEquals(50, loader.get(fqn).size());
loader.remove(fqn);
}
@@ -168,7 +174,13 @@
{
cache.put(fqn, "key" + i, "value1");
}
- Thread.sleep(1000);
+ //this happens async, so expect this will happen at a further point in time
+ long start = System.currentTimeMillis();
+ while (System.currentTimeMillis() - start < 50000)
+ {
+ if (loader.get(fqn) != null && loader.get(fqn).size() == 50) break;
+ Thread.sleep(100);
+ }
assertEquals(50, loader.get(fqn).size());
loader.remove(fqn);
}