[jbosscache-commits] JBoss Cache SVN: r7847 - core/branches/flat/src/test/java/org/horizon/test/testng.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at 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 at redhat.com
  * @author Mircea.Markus at 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() + ".");
    }
 }