Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Missed a fix for that test 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1090461 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jean-Daniel Cryans 2011-04-08 21:49:19 +00:00
parent 9413b5ebe2
commit 2ed9853572
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java
View File

@ -66,7 +66,8 @@ public class TestExecutorService {
// Submit maxThreads executors.
for (int i = 0; i < maxThreads; i++) {
executorService.submit(
new TestEventHandler(EventType.M_SERVER_SHUTDOWN, lock, counter));
new TestEventHandler(mockedServer, EventType.M_SERVER_SHUTDOWN,
lock, counter));
}
// The TestEventHandler will increment counter when it starts.
@ -101,7 +102,8 @@ public class TestExecutorService {
// Make sure we don't get RejectedExecutionException.
for (int i = 0; i < (2 * maxThreads); i++) {
executorService.submit(
new TestEventHandler(EventType.M_SERVER_SHUTDOWN, lock, counter));
new TestEventHandler(mockedServer, EventType.M_SERVER_SHUTDOWN,
lock, counter));
}
// Now interrupt the running Executor
synchronized (lock) {
@ -118,9 +120,9 @@ public class TestExecutorService {
private AtomicBoolean lock;
private AtomicInteger counter;
public TestEventHandler(EventType eventType, AtomicBoolean lock,
AtomicInteger counter) {
super(null, eventType);
public TestEventHandler(Server server, EventType eventType,
AtomicBoolean lock, AtomicInteger counter) {
super(server, eventType);
this.lock = lock;
this.counter = counter;
}