| 520 | } |
| 521 | |
| 522 | @Test |
| 523 | public void headerCDH3b3() throws Exception { |
| 524 | RegionClient rclient = mock(RegionClient.class); |
| 525 | byte[] user = Bytes.UTF8("some value"); |
| 526 | byte[] buf = new byte[4 + 1 + 4 + 4 + user.length]; |
| 527 | ChannelBuffer header = mock(ChannelBuffer.class); |
| 528 | |
| 529 | PowerMockito.mockStatic(System.class); |
| 530 | PowerMockito.when(System.getProperty("user.name", "asynchbase")) |
| 531 | .thenReturn("some value"); |
| 532 | PowerMockito.when(rclient, "commonHeader", buf, HRPC3).thenReturn(header); |
| 533 | PowerMockito.when(rclient, "headerCDH3b3").thenCallRealMethod(); |
| 534 | |
| 535 | ChannelBuffer headerCDH3b3 = Whitebox.invokeMethod(rclient, "headerCDH3b3"); |
| 536 | |
| 537 | verifyPrivate(rclient, Mockito.atMost(1)).invoke("commonHeader", buf, HRPC3); |
| 538 | verifyPrivate(header, Mockito.atMost(2)).invoke("writeInt", Mockito.anyInt()); |
| 539 | verifyPrivate(header, Mockito.atMost(1)).invoke("writeBytes", user); |
| 540 | |
| 541 | assertNotNull(headerCDH3b3); |
| 542 | } |
| 543 | |
| 544 | } |