Method before

test/BaseTestRegionClient.java:87–122

()

  protected RegionClient region_client;
  
  @Before
  public void before() throws Exception {
    config = new Config();
    hbase_client = mock(HBaseClient.class);
    timer = new FakeTimer();
    when(hbase_client.getConfig()).thenReturn(config);
    when(hbase_client.getTimer()).thenReturn(timer);
    when(hbase_client.getRpcTimeoutTimer()).thenReturn(timer);
    when(hbase_client.getDefaultRpcTimeout()).thenReturn(60000);
    
    chan = mock(Channel.class, Mockito.RETURNS_DEEP_STUBS);
    ctx = mock(ChannelHandlerContext.class);
    cse = mock(ChannelStateEvent.class);
    secure_rpc_helper = mock(SecureRpcHelper.class);
    
    when(ctx.getChannel()).thenReturn(chan);
    final HeapChannelBufferFactory factory = new HeapChannelBufferFactory();
    when(chan.getConfig().getBufferFactory()).thenReturn(factory);
    
    PowerMockito.doAnswer(new Answer<RegionClient>(){
      @Override
      public RegionClient answer(InvocationOnMock invocation) throws Throwable {
        final Object[] args = invocation.getArguments();
        final String endpoint = (String)args[0] + ":" + (Integer)args[1];
        final RegionClient rc = mock(RegionClient.class);
        when(rc.getRemoteAddress()).thenReturn(endpoint);
        return rc;
      }
    }).when(hbase_client, "newClient", anyString(), anyInt());
    
    region_client = PowerMockito.spy(new RegionClient(hbase_client));
    Whitebox.setInternalState(region_client, "chan", chan);
    Whitebox.setInternalState(region_client, "server_version", 
        RegionClient.SERVER_VERSION_095_OR_ABOVE);
    rpcs_inflight = Whitebox.getInternalState(region_client, "rpcs_inflight");
  }
  
  /**
   * Injects the security helper mock in the class. The default is to operate