Method deserializeMultipleActions

test/TestMultiAction.java:806–846

()

  }

  @Test
  public void deserializeMultipleActions() throws Exception {
    final List<ResultOrException> results = new ArrayList<ResultOrException>(2);
    results.add(PBufResponses.generateEmptyResult(0));
    results.add(PBufResponses.generateEmptyResult(1));
    
    final RegionActionResult rar1 = PBufResponses.generateRegionActionResult(results);
    results.clear();

    results.add(PBufResponses.generateEmptyResult(2));
    results.add(PBufResponses.generateEmptyResult(3));
    final RegionActionResult rar2 = PBufResponses.generateRegionActionResult(results);
    
    final List<RegionActionResult> rars = new ArrayList<RegionActionResult>(2);
    rars.add(rar1);
    rars.add(rar2);
    
    PutRequest put1 = new PutRequest(TABLE, KEY, FAMILY, QUALIFIER, VALUE);
    put1.region = region;
    PutRequest put2 = new PutRequest(TABLE, KEY, FAMILY, QUALIFIER, VALUE);
    put2.region = region;
    PutRequest put3 = new PutRequest(TABLE, KEY, FAMILY, QUALIFIER, VALUE);
    put3.region = region;
    PutRequest put4 = new PutRequest(TABLE, KEY, FAMILY, QUALIFIER, VALUE);
    put4.region = region;
    MultiAction multi = new MultiAction();
    multi.add(put1);
    multi.add(put2);
    multi.add(put3);
    multi.add(put4);
    
    final MultiAction.Response decoded = 
        (MultiAction.Response)multi.deserialize(
            PBufResponses.encodeResponse(
                PBufResponses.generateMultiActionResponseFromRars(rars)), 0);
    assertEquals(4, decoded.size());
    assertTrue(decoded.result(0) == MultiAction.SUCCESS);
    assertTrue(decoded.result(1) == MultiAction.SUCCESS);
    assertTrue(decoded.result(2) == MultiAction.SUCCESS);
    assertTrue(decoded.result(3) == MultiAction.SUCCESS);
  }
  
  @Test
  public void deserializeMultipleActionsOneFailed() throws Exception {