Searched refs:numMessages (Results 1 – 3 of 3) sorted by relevance
97 private void generateRandomBufers(byte[][] buffers, long timestamps[], int numMessages) { in generateRandomBufers() argument100 for(int buffIndex = 0; buffIndex < numMessages; buffIndex++) { in generateRandomBufers()295 final int numMessages = 1; in test_C_EchoSmallMessage() local296 final int timeoutMs = TIMEOUT_PER_MESSAGE_MS * numMessages; in test_C_EchoSmallMessage()299 numMessages, getNumReceivedMessages(mTestContext)); in test_C_EchoSmallMessage()310 int numMessages = 100; in test_D_EchoNMessages() local311 byte[][] buffers = new byte[numMessages][]; in test_D_EchoNMessages()312 long timestamps[] = new long[numMessages]; in test_D_EchoNMessages()313 generateRandomBufers(buffers, timestamps, numMessages); in test_D_EchoNMessages()315 for (int msgIndex = 0; msgIndex < numMessages; msgIndex++) { in test_D_EchoNMessages()[all …]
432 final int numMessages = 10; in testEchoLatency() local440 for (int index = 0; index < numMessages; index++) { in testEchoLatency()446 final int timeoutMs = (numMessages * maxLatencyMs) + 20; in testEchoLatency()448 receiver.waitForMessages(numMessages, timeoutMs); in testEchoLatency()450 assertEquals("number of messages.", numMessages, receiver.getMessageCount()); in testEchoLatency()452 for (int index = 0; index < numMessages; index++) { in testEchoLatency()480 final int numMessages = 100; in testEchoMultipleMessages() local487 for (int messageIndex = 0; messageIndex < numMessages; messageIndex++) { in testEchoMultipleMessages()
224 size_t numMessages = mSentMsgs.size(); in compareInsAndOuts() local225 for (size_t msgIndex = 0; msgIndex < numMessages; msgIndex++) { in compareInsAndOuts()266 int numMessages = mSentMsgs.size(); in checkInOutLatency() local267 for (int msgIndex = 0; msgIndex < numMessages; msgIndex++) { in checkInOutLatency()322 ssize_t numMessages = in readThreadRoutine() local326 if (numMessages > 0) { in readThreadRoutine()