Method timeout

test/TestHBaseRpc.java:277–290

()

  }

  @Test
  public void timeout() 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(rpc.timeout_handle);
    
    assertNull(rpc.timeout_handle);
    verify(regionclient).removeRpc(rpc, true);
    try {
      deferred.join(1);
      fail("Expected a RpcTimedOutException");
    } catch (RpcTimedOutException ex) { }
  }
  
  @Test (expected = IllegalStateException.class)
  public void timeoutAlreadyTimedout() throws Exception {