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

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2008-12-12 03:44:51 -0500 (Fri, 12 Dec 2008)
New Revision: 7302

Modified:
   core/trunk/src/test/java/org/jboss/cache/statetransfer/ForcedStateTransferTest.java
   core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferConcurrencyTest.java
   core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferTestBase.java
Log:
removed System.out.print

Modified: core/trunk/src/test/java/org/jboss/cache/statetransfer/ForcedStateTransferTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/statetransfer/ForcedStateTransferTest.java	2008-12-12 08:44:07 UTC (rev 7301)
+++ core/trunk/src/test/java/org/jboss/cache/statetransfer/ForcedStateTransferTest.java	2008-12-12 08:44:51 UTC (rev 7302)
@@ -217,7 +217,6 @@
          if (!alreadyHung && toHang.equals(fqn))
          {
             asleep = true;
-            //System.out.println("Hanging thread changing node " + fqn);
             alreadyHung = true;
             TestingUtil.sleepThread((long) 30000);
             done = true;

Modified: core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferConcurrencyTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferConcurrencyTest.java	2008-12-12 08:44:07 UTC (rev 7301)
+++ core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferConcurrencyTest.java	2008-12-12 08:44:51 UTC (rev 7302)
@@ -146,7 +146,6 @@
                Fqn fqn = Fqn.fromRelativeElements(A_B, names[j]);
                assertEquals("Incorrect value for " + fqn + " on activator " + names[i],
                      "VALUE", activators[i].getCacheValue(fqn));
-               //               System.out.println(names[i] + ":" + fqn + " = " + activators[i].getCacheValue(fqn));
             }
          }
       }
@@ -391,7 +390,6 @@
                Region r = cacheA.getRegion(Fqn.fromString("/" + names[i]), true);
                r.registerContextClassLoader(getClass().getClassLoader());
                r.deactivate();
-               System.out.println("Run " + x + "-- /" + names[i] + " deactivated on A");
                stressors[i].startPuts();
             }
 
@@ -405,10 +403,8 @@
             // Activate cacheA
             for (CacheStressor stressor : stressors)
             {
-               System.out.println("Activating /" + stressor.getName() + " on A");
                cacheA.getRegion(Fqn.fromString("/" + stressor.getName()), true).activate();
                stressor.stopPuts();
-               System.out.println("Run " + x + "-- /" + stressor.getName() + " activated on A");
                // Reacquire one semaphore ticket
                boolean acquired = semaphore.tryAcquire(60, TimeUnit.SECONDS);
                if (!acquired)
@@ -493,7 +489,6 @@
       int events = nodeEventQueueSize;
       while (events > 0)
       {
-         System.out.println(++i + ") Queue contains : " + region.getEvictionEventQueue().poll(0, TimeUnit.MILLISECONDS));
          events = region.getEvictionEventQueue().size();
       }
       boolean mvcc = cache2.getConfiguration().getNodeLockingScheme() == NodeLockingScheme.MVCC;
@@ -593,7 +588,6 @@
             int dataCount = children.size();
             if (dataCount < maxCountData)
             {
-               System.out.println("data " + dataCount + " < " + maxCountData + " elapsed = " + (System.currentTimeMillis() - start));
                sawDataDecrease = true;
             }
             else
@@ -609,7 +603,6 @@
             int baseCount = children.size();
             if (baseCount < maxCountBase)
             {
-               System.out.println("base " + baseCount + " < " + maxCountBase + " elapsed = " + (System.currentTimeMillis() - start));
                sawBaseDecrease = true;
             }
             else
@@ -643,14 +636,12 @@
       children = parent.getChildren();
       if (children != null)
       {
-         System.out.println(children.size());
          assertTrue("Excess children evicted", children.size() <= 5);
       }
       parent = cache2.getRoot().getChild(Fqn.fromString("/org/jboss/data"));
       children = parent.getChildren();
       if (children != null)
       {
-         System.out.println(children.size());
          assertTrue("Excess children evicted", children.size() <= 25000);
       }
 
@@ -686,10 +677,8 @@
       @SuppressWarnings("unchecked")
       void useCache() throws Exception
       {
-         System.out.println("---- Cache" + name + " = " + cache.getLocalAddress() + " being used");
          TestingUtil.sleepRandom(5000);
          createAndActivateRegion(cache, A_B);
-         System.out.println(name + " activated region" + " " + System.currentTimeMillis());
          Fqn childFqn = Fqn.fromRelativeElements(A_B, name);
          cache.put(childFqn, "KEY", "VALUE");
       }
@@ -782,8 +771,6 @@
                i++;
             }
 
-            System.out.println(name + ": last put [#" + i + "] -- " + fqn + " = " + (factor / SUBTREE_SIZE));
-
             semaphore.release();
 
             // Go to sleep until directed otherwise

Modified: core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferTestBase.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferTestBase.java	2008-12-12 08:44:07 UTC (rev 7301)
+++ core/trunk/src/test/java/org/jboss/cache/statetransfer/StateTransferTestBase.java	2008-12-12 08:44:51 UTC (rev 7302)
@@ -332,8 +332,6 @@
    {
       Map<String, Cache> caches = cachesTL.get();
 
-      System.out.println("*** in tearDown()");
-
       // Restore the TCL in case a test changed it
       Thread.currentThread().setContextClassLoader(orig_TCL_TL.get());
 
@@ -371,7 +369,6 @@
          }
          catch (Exception e)
          {
-            System.out.println("Exception stopping cache " + e.getMessage());
             e.printStackTrace(System.out);
          }
       }
@@ -471,14 +468,12 @@
             {
                throw new Exception(name + " cannot acquire semaphore");
             }
-            //System.out.println(name + " acquired semaphore");
 
             useCache();
 
          }
          catch (Exception e)
          {
-            System.out.println(name + ": " + e.getLocalizedMessage());
             e.printStackTrace(System.out);
 
             // Save it for the test to check