Method timeoutNulledRegionClient

test/TestHBaseRpc.java:316–330

()

  }
  
  @Test
  public void timeoutNulledRegionClient() throws Exception {
    final GetRequest rpc = new GetRequest(TABLE, KEY, FAMILY);
    final Deferred<Object> deferred = rpc.getDeferred();
    rpc.enqueueTimeout(regionclient);
    Whitebox.setInternalState(rpc, "region_client", (RegionClient)null);
    timer.tasks.get(0).getKey().run(rpc.timeout_handle);
    
    assertNull(rpc.timeout_handle);
    verify(regionclient, never()).removeRpc(rpc, true);
    try {
      deferred.join(1);
      fail("Expected a RpcTimedOutException");
    } catch (RpcTimedOutException ex) { }
  }
}