Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

convert int array to atomic int array in test case 

git-svn-id: svn+ssh://dev.eclipse.org/svnroot/rt/org.eclipse.jetty/jetty/trunk@377 7e9141cc-0065-0410-87d8-b60c137991c4
This commit is contained in:
Jesse McConnell 2009-06-11 22:08:19 +00:00
parent 23db59ab77
commit 3821eebb43
2 changed files with 13 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
jetty-util/src/main/java/org/eclipse/jetty/util/log/StdErrLog.java
View File

@ -14,6 +14,7 @@
package org.eclipse.jetty.util.log; package org.eclipse.jetty.util.log;
import org.eclipse.jetty.util.DateCache; import org.eclipse.jetty.util.DateCache;
import org.eclipse.jetty.util.annotation.PermissionNote;
/*-----------------------------------------------------------------------*/ /*-----------------------------------------------------------------------*/
/** StdErr Logging. /** StdErr Logging.
@ -26,6 +27,7 @@ import org.eclipse.jetty.util.DateCache;
public class StdErrLog implements Logger public class StdErrLog implements Logger
{ {
private static DateCache _dateCache; private static DateCache _dateCache;
@PermissionNote(clazz = "java.util.PropertyPermission", name="org.eclipse.jetty.util.log.DEBUG", actions="read" )
private static boolean _debug = System.getProperty("org.eclipse.jetty.util.log.DEBUG",null)!=null; private static boolean _debug = System.getProperty("org.eclipse.jetty.util.log.DEBUG",null)!=null;
private String _name; private String _name;
private boolean _hideStacks=false; private boolean _hideStacks=false;

18
jetty-util/src/test/java/org/eclipse/jetty/util/thread/TimeoutTest.java
View File

@ -13,6 +13,9 @@
package org.eclipse.jetty.util.thread; package org.eclipse.jetty.util.thread;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicIntegerArray;
import junit.framework.TestCase; import junit.framework.TestCase;
public class TimeoutTest extends TestCase public class TimeoutTest extends TestCase
@ -132,7 +135,8 @@ public class TimeoutTest extends TestCase
{ {
final int LOOP=500; final int LOOP=500;
final boolean[] running = {true}; final boolean[] running = {true};
final int[] count = {0,0,0}; final AtomicIntegerArray count = new AtomicIntegerArray( 3 );
timeout.setNow(System.currentTimeMillis()); timeout.setNow(System.currentTimeMillis());
timeout.setDuration(500); timeout.setDuration(500);
@ -175,7 +179,7 @@ public class TimeoutTest extends TestCase
// count how many threads were started (should == LOOP) // count how many threads were started (should == LOOP)
synchronized(count) synchronized(count)
{ {
count[0]++; count.incrementAndGet( 0 );
} }
// create a task for this thread // create a task for this thread
@ -186,7 +190,7 @@ public class TimeoutTest extends TestCase
// count the number of expires // count the number of expires
synchronized(count) synchronized(count)
{ {
count[2]++; count.incrementAndGet( 2 );
} }
} }
}; };
@ -212,7 +216,7 @@ public class TimeoutTest extends TestCase
// THIS loop is the one time we wait 1000ms // THIS loop is the one time we wait 1000ms
synchronized(count) synchronized(count)
{ {
count[1]++; count.incrementAndGet( 1 );
} }
delay=200; delay=200;
wait=1000; wait=1000;
@ -248,8 +252,8 @@ public class TimeoutTest extends TestCase
Thread.sleep(1000); Thread.sleep(1000);
// check the counts // check the counts
assertEquals("count threads", LOOP,count[0]); assertEquals("count threads", LOOP,count.get( 0 ));
assertEquals("count once waits",LOOP,count[1]); assertEquals("count once waits",LOOP,count.get(1 ));
assertEquals("count expires",LOOP,count[2]); assertEquals("count expires",LOOP,count.get(2));
} }
} }