Searched refs:mRecordMQ (Results 1 – 6 of 6) sorted by relevance
135 mRecordMQ = std::make_unique<FilterMQ>(recordMQDescriptor, true /* resetPointers */); in startRecordOutputThread()136 EXPECT_TRUE(mRecordMQ); in startRecordOutputThread()164 EXPECT_TRUE(EventFlag::createEventFlag(mRecordMQ->getEventFlagWord(), &recordMQEventFlag) == in recordThreadLoop()194 int readSize = mRecordMQ->availableToRead(); in readRecordFMQ()197 result = mRecordMQ->read(mDataOutputBuffer.data(), readSize); in readRecordFMQ()
127 std::unique_ptr<FilterMQ> mRecordMQ; variable
134 mRecordMQ = std::make_unique<FilterMQ>(recordMQDescriptor, true /* resetPointers */); in startRecordOutputThread()135 EXPECT_TRUE(mRecordMQ); in startRecordOutputThread()163 EXPECT_TRUE(EventFlag::createEventFlag(mRecordMQ->getEventFlagWord(), &recordMQEventFlag) == in recordThreadLoop()193 int readSize = mRecordMQ->availableToRead(); in readRecordFMQ()196 result = mRecordMQ->read(mDataOutputBuffer.data(), readSize); in readRecordFMQ()
128 std::unique_ptr<FilterMQ> mRecordMQ; variable
137 mRecordMQ = std::make_unique<FilterMQ>(recordMQDescriptor, true /* resetPointers */); in startRecordOutputThread()138 EXPECT_TRUE(mRecordMQ); in startRecordOutputThread()151 EXPECT_TRUE(EventFlag::createEventFlag(mRecordMQ->getEventFlagWord(), &recordMQEventFlag) == in recordThreadLoop()181 int readSize = mRecordMQ->availableToRead(); in readRecordFMQ()184 result = mRecordMQ->read(mDataOutputBuffer.data(), readSize); in readRecordFMQ()
116 std::unique_ptr<FilterMQ> mRecordMQ; variable