Method multiAction

test/TestRegionClientSendRpc.java:349–378

()

  }
  
  @Test
  public void multiAction() throws Exception {
    final Counter counter = new Counter();
    Whitebox.setInternalState(hbase_client, "num_multi_rpcs", counter);
    final MultiAction ma = new MultiAction();
    final PutRequest put1 = new PutRequest(TABLE, KEY, FAMILY, QUALIFIER, VALUE);
    put1.setRegion(region);
    ma.add(put1);
    final PutRequest put2 = new PutRequest(TABLE, KEY, FAMILY, QUALIFIER, VALUE);
    put2.setRegion(region);
    ma.add(put2);
    final Deferred<Object> deferred = ma.getDeferred();
    
    region_client.sendRpc(ma);
    
    Exception ex = null;
    try {
      deferred.join(1);
    } catch (Exception e) {
      ex = e;
    }
    assertTrue(ex instanceof TimeoutException);
    PowerMockito.verifyStatic(times(1));
    Channels.write((Channel)any(), (ChannelBuffer)any());
    verify(hbase_client, never()).sendRpcToRegion(ma);
    assertEquals(1, region_client.stats().rpcsSent());
    assertEquals(0, region_client.stats().pendingBatchedRPCs());
    assertEquals(0, region_client.stats().pendingRPCs());
    assertEquals(1, counter.get());
  }
  
  @Test
  public void multiActionToSingle() throws Exception {