Home
last modified time | relevance | path

Searched refs:numMessages (Results 1 – 5 of 5) sorted by relevance

/system/libfmq/tests/
Dmsgq_test_client.cpp793 const size_t numMessages = 2; in TYPED_TEST() local
794 ASSERT_LE(numMessages, kNumElementsInSyncQueue); in TYPED_TEST()
795 int32_t readData[numMessages]; in TYPED_TEST()
796 ASSERT_FALSE(this->mQueue->read(readData, numMessages)); in TYPED_TEST()
837 const size_t numMessages = 2048; in TYPED_TEST() local
838 ASSERT_GT(numMessages, kNumElementsInSyncQueue); in TYPED_TEST()
839 bool ret = this->requestWriteFmqSync(numMessages); in TYPED_TEST()
872 const size_t numMessages = chunkSize * chunkNum; in TYPED_TEST() local
873 ASSERT_LE(numMessages, kNumElementsInSyncQueue); in TYPED_TEST()
877 bool ret = this->requestWriteFmqSync(numMessages); in TYPED_TEST()
[all …]
Dfmq_unit_tests.cpp1061 size_t numMessages = this->mNumMessagesMax - 1; in TYPED_TEST() local
1065 ASSERT_TRUE(this->mQueue->write(&data[0], numMessages)); in TYPED_TEST()
1066 ASSERT_TRUE(this->mQueue->read(&readData[0], numMessages)); in TYPED_TEST()
1273 size_t numMessages = this->mNumMessagesMax - 1; in TYPED_TEST() local
1278 ASSERT_TRUE(this->mQueue->write(&data[0], numMessages)); in TYPED_TEST()
1279 ASSERT_TRUE(this->mQueue->read(&readData[0], numMessages)); in TYPED_TEST()
/system/chre/apps/test/common/chre_reliable_message_test/src/
Dchre_reliable_message_test_manager.cc121 LOGI("Sending %" PRIu32 " messages of size %" PRIu32, command->numMessages, in sendMessages()
127 mNumExpectedHostEchoMessages = command->numMessages; in sendMessages()
128 mNumExpectedAsyncResults = command->numMessages; in sendMessages()
130 mNumExpectedFreeMessageCallbacks = command->numMessages; in sendMessages()
132 for (uint32_t i = 0; i < command->numMessages; i++) { in sendMessages()
/system/chre/java/test/chqts/src/com/google/android/chre/test/chqts/
DContextHubReliableMessageTestExecutor.java105 public void messageToHostTest(int numMessages, int messageSize) { in messageToHostTest() argument
158 numMessages).setMessageSize(messageSize).build(); in messageToHostTest()
187 public void messageToNanoappTest(int numMessages, int messageSize) { in messageToNanoappTest() argument
188 Log.i(TAG, "Sending %d messages of size %d".formatted(numMessages, messageSize)); in messageToNanoappTest()
190 CountDownLatch messageLatch = new CountDownLatch(numMessages); in messageToNanoappTest()
191 CountDownLatch statusLatch = new CountDownLatch(numMessages); in messageToNanoappTest()
227 for (int i = 0; i < numMessages; ++i) { in messageToNanoappTest()
/system/chre/apps/test/common/proto/
Dchre_reliable_message_test.proto24 required uint32 numMessages = 1; field