Lines Matching refs:mQueue

57         : mQueue(std::move(queue)) {}  in EventMessageQueueWrapperV1_0()
60 return mQueue->getDesc(); in getDesc()
64 return mQueue->getEventFlagWord(); in getEventFlagWord()
67 virtual size_t availableToRead() override { return mQueue->availableToRead(); } in availableToRead()
69 size_t availableToWrite() override { return mQueue->availableToWrite(); } in availableToWrite()
72 return mQueue->read(reinterpret_cast<V1_0::Event*>(events), numToRead); in read()
76 return mQueue->write(reinterpret_cast<const V1_0::Event*>(events), numToWrite); in write()
81 return mQueue->write(oldEvents.data(), oldEvents.size()); in write()
87 return mQueue->writeBlocking(reinterpret_cast<const V1_0::Event*>(events), count, in writeBlocking()
91 size_t getQuantumCount() override { return mQueue->getQuantumCount(); } in getQuantumCount()
94 std::unique_ptr<EventMessageQueue> mQueue;
102 : mQueue(std::move(queue)) {} in EventMessageQueueWrapperV2_1()
105 return mQueue->getDesc(); in getDesc()
108 std::atomic<uint32_t>* getEventFlagWord() override { return mQueue->getEventFlagWord(); } in getEventFlagWord()
110 virtual size_t availableToRead() override { return mQueue->availableToRead(); } in availableToRead()
112 size_t availableToWrite() override { return mQueue->availableToWrite(); } in availableToWrite()
115 return mQueue->read(events, numToRead); in read()
119 return mQueue->write(events, numToWrite); in write()
123 return mQueue->write(events.data(), events.size()); in write()
129 return mQueue->writeBlocking(events, count, readNotification, writeNotification, in writeBlocking()
133 size_t getQuantumCount() override { return mQueue->getQuantumCount(); } in getQuantumCount()
136 std::unique_ptr<EventMessageQueue> mQueue;