Searched refs:receivedBytes (Results 1 – 4 of 4) sorted by relevance
137 byte[] receivedBytes = new byte[bytes.length]; in checkSendingData()138 receiveBuffer.get(receivedBytes); in checkSendingData()139 Assert.assertTrue(Arrays.equals(bytes, receivedBytes)); in checkSendingData()154 byte[] receivedBytes = new byte[bytes.length]; in checkSharing()155 buffer2.get(receivedBytes); in checkSharing()157 Assert.assertTrue(Arrays.equals(bytes, receivedBytes)); in checkSharing()330 byte[] receivedBytes = new byte[bytes.length]; in testDataPipeTwoPhaseSend()331 receiveBuffer.get(receivedBytes); in testDataPipeTwoPhaseSend()332 Assert.assertTrue(Arrays.equals(bytes, receivedBytes)); in testDataPipeTwoPhaseSend()369 byte[] receivedBytes = new byte[bytes.length - nbBytesToDiscard]; in testDataPipeDiscard()[all …]
270 byte[] receivedBytes = new byte[receivedLen1]; in unprotectLargeIncomingFrame()271 receivedData1.readBytes(receivedBytes, 0, receivedLen1); in unprotectLargeIncomingFrame()273 assertThat(unprotectedBytes.length).isEqualTo(receivedBytes.length); in unprotectLargeIncomingFrame()274 assertThat(unprotectedBytes).isEqualTo(receivedBytes); in unprotectLargeIncomingFrame()
645 int receivedBytes = 0; in runClient() local659 receivedBytes += (int)static_cast<const ProcessLogDataMessage*>(msg.get())->logData.length(); in runClient()683 if (receivedBytes != DATA_SIZE) in runClient()685 printf(" received: %d bytes\n expected: %d bytes\n", receivedBytes, DATA_SIZE); in runClient()
META-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...