Author: manik.surtani(a)jboss.com Date: 2009-03-04 08:32:42 -0500 (Wed, 04 Mar 2009) New Revision: 7847 Modified: core/branches/flat/src/test/java/org/horizon/test/testng/UnitTestTestNGListener.java Log: Improved listener Modified: core/branches/flat/src/test/java/org/horizon/test/testng/UnitTestTestNGListener.java =================================================================== --- core/branches/flat/src/test/java/org/horizon/test/testng/UnitTestTestNGListener.java 2009-03-04 13:28:08 UTC (rev 7846) +++ core/branches/flat/src/test/java/org/horizon/test/testng/UnitTestTestNGListener.java 2009-03-04 13:32:42 UTC (rev 7847) @@ -7,6 +7,8 @@ import org.testng.ITestListener; import org.testng.ITestResult; +import java.util.concurrent.atomic.AtomicInteger; + /** * @author dpospisi(a)redhat.com * @author Mircea.Markus(a)jboss.com @@ -19,9 +21,9 @@ private ThreadLocal<IClass> threadTestClass = new ThreadLocal<IClass>(); Log log = LogFactory.getLog(UnitTestTestNGListener.class); - private int failed = 0; - private int succeded = 0; - private int skipped = 0; + private AtomicInteger failed = new AtomicInteger(0); + private AtomicInteger succeded = new AtomicInteger(0); + private AtomicInteger skipped = new AtomicInteger(0); public void onTestStart(ITestResult res) { log.info("Starting test " + getTestDesc(res)); @@ -29,16 +31,16 @@ } synchronized public void onTestSuccess(ITestResult arg0) { - System.out.println(getThreadId() + " Test " + getTestDesc(arg0) + " succeded."); - log.info("Test succeded " + getTestDesc(arg0) + "."); - succeded++; + System.out.println(getThreadId() + " Test " + getTestDesc(arg0) + " succeeded."); + log.info("Test succeeded " + getTestDesc(arg0) + "."); + succeded.incrementAndGet(); printStatus(); } synchronized public void onTestFailure(ITestResult arg0) { System.out.println(getThreadId() + " Test " + getTestDesc(arg0) + " failed."); if (arg0.getThrowable() != null) log.error("Test failed " + getTestDesc(arg0), arg0.getThrowable()); - failed++; + failed.incrementAndGet(); printStatus(); } @@ -46,7 +48,7 @@ System.out.println(getThreadId() + " Test " + getTestDesc(arg0) + " skipped."); log.info(" Test " + getTestDesc(arg0) + " skipped."); if (arg0.getThrowable() != null) log.error("Test skipped : " + arg0.getThrowable(), arg0.getThrowable()); - skipped++; + skipped.incrementAndGet(); printStatus(); } @@ -68,6 +70,6 @@ } private void printStatus() { - System.out.println("Testsuite execution progress: tests succeded " + succeded + ", failed " + failed + ", skipped " + skipped + "."); + System.out.println("Test suite progress: tests succeeded: " + succeded.get() + ", failed: " + failed.get() + ", skipped: " + skipped.get() + "."); } }