Method enqueueTimeout

test/TestHBaseRpc.java:79–99

()

  }
  
  @Test
  public void enqueueTimeout() throws Exception {
    final GetRequest rpc = new GetRequest(TABLE, KEY, FAMILY);
    final Deferred<Object> deferred = rpc.getDeferred();
    assertNull(rpc.timeout_handle);
    assertEquals(0, timer.tasks.size());
    assertFalse(rpc.hasTimedOut());
    
    rpc.enqueueTimeout(regionclient);
    
    assertEquals(1, timer.tasks.size());
    assertNotNull(rpc.timeout_handle);
    assertEquals(default_timeout, rpc.getTimeout());
    assertEquals(default_timeout, (long)timer.tasks.get(0).getValue());
    assertFalse(rpc.hasTimedOut());
    verify(regionclient, never()).removeRpc(any(HBaseRpc.class), anyBoolean());
    try {
      deferred.join(1);
      fail("Expected a TimeoutException");
    } catch (TimeoutException e) { }
  }
  
  @Test
  public void enqueueTimeoutCustomTimeout() throws Exception {