Searched refs:mFilterMQ (Results 1 – 5 of 5) sorted by relevance
97 _hidl_cb(Result::SUCCESS, *mFilterMQ->getDesc()); in getQueueDesc()144 int size = mFilterMQ->availableToRead(); in flush()146 mFilterMQ->read((unsigned char*)&buffer[0], size); in flush()180 mFilterMQ = std::move(tmpFilterMQ); in createFilterMQ()182 if (EventFlag::createEventFlag(mFilterMQ->getEventFlagWord(), &mFilterEventFlag) != OK) { in createFilterMQ()286 int availableToRead = mFilterMQ->availableToRead(); in maySendFilterStatusCallback()287 int availableToWrite = mFilterMQ->availableToWrite(); in maySendFilterStatusCallback()288 int fmqSize = mFilterMQ->getQuantumCount(); in maySendFilterStatusCallback()591 if (mFilterMQ->write(data.data(), data.size())) { in writeDataToFilterMQ()
119 unique_ptr<FilterMQ> mFilterMQ; variable
42 mFilterMQ = std::make_unique<FilterMQ>(filterMQDescriptor, true /* resetPointers */); in updateFilterMQ()43 EXPECT_TRUE(mFilterMQ); in updateFilterMQ()44 EXPECT_TRUE(EventFlag::createEventFlag(mFilterMQ->getEventFlagWord(), &mFilterMQEventFlag) == in updateFilterMQ()100 result = mFilterMQ->read(mDataOutputBuffer.data(), mDataLength); in readFilterEventData()
125 std::map<uint32_t, std::unique_ptr<FilterMQ>> mFilterMQ; variable
132 std::unique_ptr<FilterMQ> mFilterMQ; variable