[jbosscache-commits] JBoss Cache SVN: r7805 - core/trunk/src/test/java/org/jboss/cache/statetransfer.
Author: manik.surtani(a)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);