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

[jbosscache-commits at lists.jboss.org]

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);
    }