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

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2007-11-12 10:38:10 -0500 (Mon, 12 Nov 2007)
New Revision: 4746

Modified:
   core/trunk/src/test/java/org/jboss/cache/loader/ClusteredCacheLoaderTest.java
Log:
Added some logging

Modified: core/trunk/src/test/java/org/jboss/cache/loader/ClusteredCacheLoaderTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/loader/ClusteredCacheLoaderTest.java	2007-11-12 15:37:53 UTC (rev 4745)
+++ core/trunk/src/test/java/org/jboss/cache/loader/ClusteredCacheLoaderTest.java	2007-11-12 15:38:10 UTC (rev 4746)
@@ -13,6 +13,7 @@
 import org.jboss.cache.DefaultCacheFactory;
 import org.jboss.cache.Fqn;
 import org.jboss.cache.Region;
+import org.jboss.cache.misc.TestingUtil;
 import org.jboss.cache.config.Configuration;
 import org.jboss.cache.lock.TimeoutException;
 import org.testng.annotations.AfterMethod;
@@ -244,7 +245,7 @@
          cache2.put(fqn, "k", "v");
          cache1.evict(fqn);
       }
-      final int loops = 10000;
+      final int loops = 1000;
       final Set<Exception> exceptions = new CopyOnWriteArraySet<Exception>();
 
       Thread evictor = new Thread("Evictor")
@@ -256,8 +257,10 @@
                latch.await();
                for (int i = 0; i < loops; i++)
                {
+                  System.out.println("Evict in loop " + i);
                   Fqn f = singleFqn ? fqn : fqns.get(r.nextInt(fqns.size()));
                   cache1.evict(f);
+                  TestingUtil.sleepRandom(50);
                }
             }
             catch (TimeoutException te)
@@ -282,8 +285,10 @@
                latch.await();
                for (int i = 0; i < loops; i++)
                {
+                  System.out.println("Write in loop " + i);
                   Fqn f = singleFqn ? fqn : fqns.get(r.nextInt(fqns.size()));
                   cache2.put(f, "k", "v");
+                  TestingUtil.sleepRandom(50);
                }
             }
             catch (Exception e)
@@ -305,7 +310,9 @@
                latch.await();
                for (int i = 0; i < loops; i++)
                {
+                  System.out.println("R1 in loop " + i);
                   loader1.get(singleFqn ? fqn : fqns.get(r.nextInt(fqns.size())));
+                  TestingUtil.sleepRandom(50);
                }
             }
             catch (Exception e)
@@ -325,7 +332,9 @@
                latch.await();
                for (int i = 0; i < loops; i++)
                {
+                  System.out.println("R2 in loop " + i);
                   loader1.getChildrenNames(singleFqn ? fqn.getParent() : fqns.get(r.nextInt(fqns.size())).getParent());
+                  TestingUtil.sleepRandom(50);
                }
             }
             catch (Exception e)
@@ -345,7 +354,9 @@
                latch.await();
                for (int i = 0; i < loops; i++)
                {
+                  System.out.println("R3 in loop " + i);
                   loader1.getChildrenNames(singleFqn ? fqn : fqns.get(r.nextInt(fqns.size())));
+                  TestingUtil.sleepRandom(50);
                }
             }
             catch (Exception e)