Method replayed

test/TestRegionClientDecode.java:465–502

()

  }
  
  @Test
  public void replayed() throws Exception {
    resetMockClient();
    
    final int id = 42;
    final ChannelBuffer buffer = buildGoodResponse(true, id);
    final byte[] array = new byte[buffer.writerIndex()];
    buffer.readBytes(array);
    
    final GetRequest get = new GetRequest(TABLE, ROW);
    final Deferred<Object> deferred = get.getDeferred();
    inflightTheRpc(id, get);
    
    final MessageEvent event = mock(MessageEvent.class);
    when(event.getMessage())
      .thenReturn(ChannelBuffers.wrappedBuffer(Arrays.copyOf(array, 3)))
      .thenReturn(ChannelBuffers.wrappedBuffer(
          Arrays.copyOfRange(array, 3, 10)))
      .thenReturn(ChannelBuffers.wrappedBuffer(
          Arrays.copyOfRange(array, 10, array.length)));
    
    region_client.messageReceived(ctx, event);
    region_client.messageReceived(ctx, event);
    region_client.messageReceived(ctx, event);
    
    @SuppressWarnings("unchecked")
    final List<KeyValue> kvs = (List<KeyValue>)deferred.join(100);
    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 replayedMissingMiddle() throws Exception {