svn commit: r634270 - /commons/sandbox/monitoring/trunk/src/test/java/org/apache/commons/monitoring/MonitoringTest.java

[ni...@apache.org]

Author: nicolas
Date: Thu Mar  6 05:42:27 2008
New Revision: 634270

URL: http://svn.apache.org/viewvc?rev=634270&view=rev
Log:
increase TO to avoid failure when ran by cobertura 

Modified:
    commons/sandbox/monitoring/trunk/src/test/java/org/apache/commons/monitoring/MonitoringTest.java

Modified: commons/sandbox/monitoring/trunk/src/test/java/org/apache/commons/monitoring/MonitoringTest.java
URL: http://svn.apache.org/viewvc/commons/sandbox/monitoring/trunk/src/test/java/org/apache/commons/monitoring/MonitoringTest.java?rev=634270&r1=634269&r2=634270&view=diff
==============================================================================
--- commons/sandbox/monitoring/trunk/src/test/java/org/apache/commons/monitoring/MonitoringTest.java (original)
+++ commons/sandbox/monitoring/trunk/src/test/java/org/apache/commons/monitoring/MonitoringTest.java Thu Mar  6 05:42:27 2008
@@ -58,6 +58,7 @@
 
         Monitoring.setRepository( new DefaultRepository() );
 
+        StopWatch s = Monitoring.start( "testThreadSafety" );
         ExecutorService pool = Executors.newFixedThreadPool( threads );
         for ( int i = 0; i < threads; i++ )
         {
@@ -83,12 +84,18 @@
             } );
         }
         pool.shutdown();
-        pool.awaitTermination( 30, TimeUnit.SECONDS );
+        pool.awaitTermination( 120, TimeUnit.SECONDS );
+
+        System.out.println( (threads * loops) + " executions took " + s.getElapsedTime() + "ns" );
 
         Monitor monitor = Monitoring.getMonitor( "MonitoringTest.testMultiThreading", "test", "utils" );
-        assertEquals( threads * loops, monitor.getCounter( "COUNTER" ).getHits() );
-        assertEquals( threads * loops, monitor.getCounter( "COUNTER" ).get() );
-        assertEquals( threads * loops, monitor.getGauge( "GAUGE" ).get() );
+
+        Counter counter = monitor.getCounter( "COUNTER" );
+        assertEquals( counter.getClass() + " is not thread safe", threads * loops, counter.getHits() );
+        assertEquals( counter.getClass() + " is not thread safe", threads * loops, counter.get() );
+
+        Gauge gauge = monitor.getGauge( "GAUGE" );
+        assertEquals( gauge.getClass() + " is not thread safe", threads * loops, gauge.get() );
     }
 
 }