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

HADOOP-13289. Remove unused variables in TestFairCallQueue. Contributed by Ye Zhou. 

(cherry picked from commit 1381483233)
(cherry picked from commit 2231ef22f5)
This commit is contained in:
Akira Ajisaka 2016-07-14 23:13:55 -07:00
parent 6a04d9ab63
commit bc21763da4
1 changed files with 0 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/ipc/TestFairCallQueue.java
View File

@ -32,7 +32,6 @@ import java.util.concurrent.BlockingQueue;
import org.apache.hadoop.security.UserGroupInformation; import org.apache.hadoop.security.UserGroupInformation;
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configuration;
import org.mockito.Matchers;
public class TestFairCallQueue extends TestCase { public class TestFairCallQueue extends TestCase {
private FairCallQueue<Schedulable> fcq; private FairCallQueue<Schedulable> fcq;
@ -52,14 +51,6 @@ public class TestFairCallQueue extends TestCase {
return mockCall(id, 0); return mockCall(id, 0);
} }
// A scheduler which always schedules into priority zero
private RpcScheduler alwaysZeroScheduler;
{
RpcScheduler sched = mock(RpcScheduler.class);
when(sched.getPriorityLevel(Matchers.<Schedulable>any())).thenReturn(0); // always queue 0
alwaysZeroScheduler = sched;
}
@SuppressWarnings("deprecation") @SuppressWarnings("deprecation")
public void setUp() { public void setUp() {
Configuration conf = new Configuration(); Configuration conf = new Configuration();
@ -124,7 +115,6 @@ public class TestFairCallQueue extends TestCase {
public void testOfferSucceedsWhenScheduledLowPriority() { public void testOfferSucceedsWhenScheduledLowPriority() {
// Scheduler will schedule into queue 0 x 5, then queue 1 // Scheduler will schedule into queue 0 x 5, then queue 1
RpcScheduler sched = mock(RpcScheduler.class);
int mockedPriorities[] = {0, 0, 0, 0, 0, 1, 0}; int mockedPriorities[] = {0, 0, 0, 0, 0, 1, 0};
for (int i = 0; i < 5; i++) { assertTrue(fcq.offer(mockCall("c", mockedPriorities[i]))); } for (int i = 0; i < 5; i++) { assertTrue(fcq.offer(mockCall("c", mockedPriorities[i]))); }