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