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

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-02-27 08:08:31 -0500 (Fri, 27 Feb 2009)
New Revision: 7805

Modified:
   core/trunk/src/test/java/org/jboss/cache/statetransfer/NonBlockingStateTransferTest.java
Log:
Writer thread to stop on error and if test exists

Modified: core/trunk/src/test/java/org/jboss/cache/statetransfer/NonBlockingStateTransferTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/statetransfer/NonBlockingStateTransferTest.java	2009-02-27 12:52:48 UTC (rev 7804)
+++ core/trunk/src/test/java/org/jboss/cache/statetransfer/NonBlockingStateTransferTest.java	2009-02-27 13:08:31 UTC (rev 7805)
@@ -87,7 +87,7 @@
       WritingRunner(Cache<Object, Object> cache, boolean tx)
       {
          this.cache = cache;
-         this.tx = tx;
+         this.tx = tx;         
       }
 
       public int result()
@@ -120,6 +120,7 @@
             {
                e.printStackTrace();
                log.error(e);
+               stop = true;
             }
          }
          result = c;
@@ -331,6 +332,7 @@
 
          WritingRunner writer = new WritingRunner(cache3, tx);
          Thread writerThread = new Thread(writer);
+         writerThread.setDaemon(true);
          writerThread.start();
 
          cache2 = createCache(name);
@@ -384,6 +386,7 @@
 
          WritingRunner writer = new WritingRunner(cache1, tx);
          Thread writerThread = new Thread(writer);
+         writerThread.setDaemon(true);
          writerThread.start();
 
          cache2 = createCache(name);