1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.hbase.ipc;
19
20 import org.apache.hadoop.hbase.monitoring.MonitoredRPCHandlerImpl;
21 import org.apache.hadoop.hbase.testclassification.SmallTests;
22 import org.apache.hadoop.hbase.security.UserProvider;
23 import org.junit.Test;
24 import org.junit.experimental.categories.Category;
25 import org.mockito.Mockito;
26
27 @Category(SmallTests.class)
28 public class TestCallRunner {
29
30
31
32 @Test
33 public void testSimpleCall() {
34 RpcServerInterface mockRpcServer = Mockito.mock(RpcServerInterface.class);
35 Mockito.when(mockRpcServer.isStarted()).thenReturn(true);
36 RpcServer.Call mockCall = Mockito.mock(RpcServer.Call.class);
37 mockCall.connection = Mockito.mock(RpcServer.Connection.class);
38 CallRunner cr = new CallRunner(mockRpcServer, mockCall);
39 cr.setStatus(new MonitoredRPCHandlerImpl());
40 cr.run();
41 }
42 }