[jbosscache-commits] JBoss Cache SVN: r7308 - core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic.

Author: mircea.markus Date: 2008-12-12 03:52:57 -0500 (Fri, 12 Dec 2008) New Revision: 7308 Modified: core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic/AbortionTest.java core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic/PessimisticTransactionTest.java core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic/PrepareTxTest.java Log: removed System.out.print Modified: core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic/AbortionTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic/AbortionTest.java 2008-12-12 08:51:34 UTC (rev 7307) +++ core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic/AbortionTest.java 2008-12-12 08:52:57 UTC (rev 7308) @@ -167,7 +167,6 @@ OrderedSynchronizationHandler osh = transactionContext.getOrderedSynchronizationHandler(); final Transaction finalTx = tx; - System.out.println("Notify called."); // add an aborting sync handler. Synchronization abort = new Synchronization() { @@ -177,7 +176,6 @@ if (abortBeforeCompletion) { cache3.getConfiguration().getRuntimeConfig().getChannel().close(); - System.out.println("Returning from abort.beforeCompletion"); try { finalTx.setRollbackOnly(); @@ -195,14 +193,12 @@ if (!abortBeforeCompletion) { cache3.getConfiguration().getRuntimeConfig().getChannel().close(); - System.out.println("Returning from abort.afterCompletion"); throw new RuntimeException("Dummy exception"); } } }; osh.registerAtHead(abort); - System.out.println("Added sync handler."); } } Modified: core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic/PessimisticTransactionTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic/PessimisticTransactionTest.java 2008-12-12 08:51:34 UTC (rev 7307) +++ core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic/PessimisticTransactionTest.java 2008-12-12 08:52:57 UTC (rev 7308) @@ -265,11 +265,8 @@ try { tx.begin(); - System.out.println("initial state:\n" + cache); cache.put("/bela/ban", "key", "value"); - System.out.println("after put():\n" + cache); tx.rollback(); - System.out.println("after rollback():\n" + cache); assertNull("node should be not existent", cache.getNode("/bela/ban")); } @@ -818,8 +815,6 @@ cache.put(fqn, "entry", "rollback"); tx.rollback(); - System.out.println("Cache: " + CachePrinter.printCacheDetails(cache)); - assertEquals("Node should keep the commited value", "commit", cache.getNode(fqn).get("entry"));// THIS FAILS } @@ -852,13 +847,9 @@ try { thread_tx = startTransaction(); - log("acquiring RL"); cache.get("/1/2/3", "foo");// acquires RLs on all 3 nodes - log("RL acquired successfully"); sleep(2000); - log("committing TX"); thread_tx.commit();// releases RLs - log("committed TX"); } catch (Exception e) { @@ -882,12 +873,8 @@ { sleep(500);// give the Reader a chance to acquire the RLs thread_tx = startTransaction(); - log("acquiring WL"); cache.put("/1", "foo", "bar2");// needs to acquired a WL on /1 - log("acquired WL successfully"); - log("committing TX"); thread_tx.commit(); - log("committed TX"); } catch (Exception e) { @@ -1064,10 +1051,4 @@ assertEquals("v", this.cache.get(fqn, "k")); } - - private static void log(String msg) - { - System.out.println(Thread.currentThread().getName() + ": " + msg); - } - } Modified: core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic/PrepareTxTest.java =================================================================== --- core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic/PrepareTxTest.java 2008-12-12 08:51:34 UTC (rev 7307) +++ core/trunk/src/test/java/org/jboss/cache/transaction/pessimistic/PrepareTxTest.java 2008-12-12 08:52:57 UTC (rev 7308) @@ -95,8 +95,6 @@ TransactionTable tx_table = cache.getTransactionTable(); num_local_txs = tx_table.getNumLocalTransactions(); num_global_txs = tx_table.getNumGlobalTransactions(); - System.out.println("Number of Transactions: " + num_local_txs + "\nNumber of GlobalTransactions: " + num_global_txs + "\nTransactionTable:\n " - + tx_table.toString(true)); assertEquals(num_local_txs, num_global_txs); assertEquals(0, num_local_txs); } @@ -149,8 +147,6 @@ TransactionTable tx_table = cache.getTransactionTable(); num_local_txs = tx_table.getNumLocalTransactions(); num_global_txs = tx_table.getNumGlobalTransactions(); - System.out.println("Number of Transactions: " + num_local_txs + "\nNumber of GlobalTransactions: " + num_global_txs + "\nTransactionTable:\n " - + tx_table.toString(true)); assertEquals(num_local_txs, num_global_txs); assertEquals(0, num_local_txs); }