Method wrap

test/TestRegionClientSendRpc.java:532–557

()

  }

  @Test
  public void wrap() throws Exception {
    final SecureRpcHelper helper = mock(SecureRpcHelper.class);
    Whitebox.setInternalState(region_client, "secure_rpc_helper", helper);
    doAnswer(new Answer<ChannelBuffer>() {
      @Override
      public ChannelBuffer answer(final InvocationOnMock invocation) 
          throws Throwable {
        return ChannelBuffers.wrappedBuffer(new byte[]{ 42 });
      }
    }).when(helper).wrap(any(ChannelBuffer.class));
    
    final GetRequest get = new GetRequest(TABLE, KEY, FAMILY, QUALIFIER);
    get.setRegion(region);
    get.getDeferred(); // required to initialize the deferred
    
    region_client.sendRpc(get);
    
    PowerMockito.verifyStatic(times(1));
    Channels.write((Channel)any(), (ChannelBuffer)any());
    verify(hbase_client, never()).sendRpcToRegion(get);
    assertEquals(1, region_client.stats().rpcsSent());
    assertEquals(0, region_client.stats().pendingBatchedRPCs());
    assertEquals(0, region_client.stats().pendingRPCs());
    verify(helper, times(1)).wrap(any(ChannelBuffer.class));
  }

  @Test
  public void pendingBreached() throws Exception {