You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by jd...@apache.org on 2011/04/08 23:49:19 UTC
svn commit: r1090461 -
/hbase/trunk/src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java
Author: jdcryans
Date: Fri Apr 8 21:49:19 2011
New Revision: 1090461
URL: http://svn.apache.org/viewvc?rev=1090461&view=rev
Log:
Missed a fix for that test
Modified:
hbase/trunk/src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java
Modified: hbase/trunk/src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java
URL: http://svn.apache.org/viewvc/hbase/trunk/src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java?rev=1090461&r1=1090460&r2=1090461&view=diff
==============================================================================
--- hbase/trunk/src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java (original)
+++ hbase/trunk/src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java Fri Apr 8 21:49:19 2011
@@ -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;
}