Searched refs:commitRead (Results 1 – 7 of 7) sorted by relevance
94 readMq.commitRead(numElements); in reader()
422 bool commitRead(size_t nMessages);1141 commitRead(nMessages); in read()1220 MessageQueueBase<MQDescriptorType, T, flavor>::commitRead(size_t nMessages) { in commitRead() function
694 ASSERT_TRUE(this->mQueue->commitRead(dataLen)); in TYPED_TEST()737 ASSERT_TRUE(this->mQueue->commitRead(dataLen)); in TYPED_TEST()975 ASSERT_TRUE(this->mQueue->commitRead(this->mNumMessagesMax)); in TYPED_TEST()
678 this->mQueue->commitRead(dataLen); in TYPED_TEST()712 ASSERT_TRUE(this->mQueue->commitRead(dataLen)); in TYPED_TEST()
168 if (!mDvrMQ->commitRead(ret)) { in writeToFile()
107 mQueue->commitRead(staleDataSize); in writeQueue()
111 mQueue->commitRead(staleDataSize); in writeQueue()