Method timeoutDifferentHandle

test/TestHBaseRpc.java:301–314

()

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