hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jdcry...@apache.org
Subject svn commit: r1090460 - /hbase/branches/0.90/src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java
Date Fri, 08 Apr 2011 21:48:58 GMT
Author: jdcryans
Date: Fri Apr  8 21:48:58 2011
New Revision: 1090460

URL: http://svn.apache.org/viewvc?rev=1090460&view=rev
Log:
Missed a fix for that test

Modified:
    hbase/branches/0.90/src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java

Modified: hbase/branches/0.90/src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java?rev=1090460&r1=1090459&r2=1090460&view=diff
==============================================================================
--- hbase/branches/0.90/src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java
(original)
+++ hbase/branches/0.90/src/test/java/org/apache/hadoop/hbase/executor/TestExecutorService.java
Fri Apr  8 21:48:58 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;
     }



Mime
View raw message