Method goodGetRequest

test/TestRegionClientDecode.java:98–119

()

  }
  
  @Test
  public void goodGetRequest() throws Exception {
    final int id = 42;
    final ChannelBuffer buffer = buildGoodResponse(false, id);
    final GetRequest get = new GetRequest(TABLE, ROW);
    final Deferred<Object> deferred = get.getDeferred();
    inflightTheRpc(id, get);
    
    assertNull(region_client.decode(ctx, chan, buffer, VOID));
    @SuppressWarnings("unchecked")
    final List<KeyValue> kvs = (List<KeyValue>)deferred.joinUninterruptibly();
    assertEquals(1, kvs.size());
    assertArrayEquals(ROW, kvs.get(0).key());
    assertArrayEquals(FAMILY, kvs.get(0).family());
    assertArrayEquals(QUALIFIER, kvs.get(0).qualifier());
    assertArrayEquals(VALUE, kvs.get(0).value());
    assertEquals(TIMESTAMP, kvs.get(0).timestamp());
    verify(secure_rpc_helper, never()).handleResponse(buffer, chan);
    assertEquals(1, timer.tasks.size());
    assertEquals(60000, (long)timer.tasks.get(0).getValue());
    verify(timer.timeouts.get(0), times(1)).cancel();
  }
  
  @Test
  public void goodGetRequestArrayBacked() throws Exception {