Method putBatched

test/TestRegionClientSendRpc.java:76–101

()

  }
  
  @Test
  public void putBatched() throws Exception {
    when(hbase_client.getFlushInterval()).thenReturn((short)1000);
    final PutRequest put = new PutRequest(TABLE, KEY, FAMILY, QUALIFIER, VALUE);
    put.region = region;
    final Deferred<Object> deferred = put.getDeferred();
    
    region_client.sendRpc(put);
    
    try {
      deferred.join(1);
    } catch (TimeoutException e) { }
    final MultiAction batched_rpcs = 
        Whitebox.getInternalState(region_client, "batched_rpcs");
    assertNotNull(batched_rpcs);
    assertEquals(1, batched_rpcs.size());
    PowerMockito.verifyStatic(never());
    Channels.write((Channel)any(), (ChannelBuffer)any());
    verify(hbase_client, never()).sendRpcToRegion(put);
    assertEquals(0, rpcs_inflight.size());
    assertEquals(0, region_client.stats().rpcsSent());
    assertEquals(0, region_client.stats().writesBlocked());
    assertEquals(1, region_client.stats().pendingBatchedRPCs());
    assertEquals(0, region_client.stats().pendingRPCs());
    assertEquals(0, timer.tasks.size());
  }
  
  @Test
  public void putNoFlushing() throws Exception {