Searched refs:receivedBytes (Results 1 – 2 of 2) sorted by relevance
124 byte[] receivedBytes = new byte[result.getValue().getMessageSize()]; in checkSendingMessage()125 receiveBuffer.get(receivedBytes); in checkSendingMessage()126 assertTrue(Arrays.equals(bytes, receivedBytes)); in checkSendingMessage()163 byte[] receivedBytes = new byte[bytes.length]; in checkSendingData()164 receiveBuffer.get(receivedBytes); in checkSendingData()165 assertTrue(Arrays.equals(bytes, receivedBytes)); in checkSendingData()180 byte[] receivedBytes = new byte[bytes.length]; in checkSharing()181 buffer2.get(receivedBytes); in checkSharing()183 assertTrue(Arrays.equals(bytes, receivedBytes)); in checkSharing()452 byte[] receivedBytes = new byte[bytes.length]; in testDataPipeTwoPhaseSend()[all …]
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()