Won't happen with puts but we run it to prove we don't care about the response for puts
()
| 383 | /** Won't happen with puts but we run it to prove we don't care about the |
| 384 | * response for puts */ |
| 385 | @Test |
| 386 | public void deserializePutsWithValues() throws Exception { |
| 387 | final List<ResultOrException> results = new ArrayList<ResultOrException>(2); |
| 388 | |
| 389 | results.add(PBufResponses.kvToROE(new KeyValue(KEY, FAMILY, QUALIFIER, 1, VALUE), 0)); |
| 390 | results.add(PBufResponses.kvToROE(new KeyValue(KEY, FAMILY, QUALIFIER, 2, VALUE), 1)); |
| 391 | |
| 392 | PutRequest put1 = new PutRequest(TABLE, KEY, FAMILY, QUALIFIER, VALUE); |
| 393 | put1.region = region; |
| 394 | PutRequest put2 = new PutRequest(TABLE, KEY, FAMILY, "myqual".getBytes(), VALUE); |
| 395 | put2.region = region; |
| 396 | MultiAction multi = new MultiAction(); |
| 397 | multi.add(put1); |
| 398 | multi.add(put2); |
| 399 | |
| 400 | final MultiAction.Response decoded = |
| 401 | (MultiAction.Response)multi.deserialize( |
| 402 | PBufResponses.encodeResponse( |
| 403 | PBufResponses.generateMultiActionResponse(results)), 0); |
| 404 | assertEquals(2, decoded.size()); |
| 405 | assertTrue(decoded.result(0) == MultiAction.SUCCESS); |
| 406 | assertTrue(decoded.result(1) == MultiAction.SUCCESS); |
| 407 | } |
| 408 | |
| 409 | /** This shouldn't happen. It means we had n RPC in our multi action but |
| 410 | somehow HBase returned n+ responses. */ |
nothing calls this directly
no test coverage detected