Searched refs:mEventQueue (Results 1 – 7 of 7) sorted by relevance
| /hardware/interfaces/automotive/vehicle/2.0/default/impl/vhal_v2_0/ |
| D | GeneratorHub.cpp | 50 mEventQueue.push({cookie, generator->nextEvent()}); in registerGenerator()
72 while (!mEventQueue.empty() in run()
73 && mGenerators.find(mEventQueue.top().cookie) == mGenerators.end()) { in run()
74 mEventQueue.pop(); in run()
77 mCond.wait(g, [this] { return !mEventQueue.empty() || mShuttingDownFlag.load(); }); in run()
82 const VhalEvent& curEvent = mEventQueue.top(); in run()
96 mEventQueue.pop(); in run()
98 mEventQueue.push({cookie, mGenerators[cookie]->nextEvent()}); in run()
|
| D | GeneratorHub.h | 80 std::priority_queue<VhalEvent, std::vector<VhalEvent>, GreaterByTime> mEventQueue;
|
| /hardware/interfaces/sensors/common/utils/ |
| D | ISensorsWrapper.h | 197 mEventQueue = std::make_unique<EventMessageQueueWrapperV1_0>(eventQueue); in ISensorsWrapperV2_0()
204 EventMessageQueueWrapperBase* getEventQueue() override { return mEventQueue.get(); } in getEventQueue()
208 return mSensors->initialize(*mEventQueue->getDesc(), wakeLockDesc, callback); in initialize()
212 std::unique_ptr<EventMessageQueueWrapperV1_0> mEventQueue;
223 mEventQueue = std::make_unique<EventMessageQueueWrapperV2_1>(eventQueue); in ISensorsWrapperV2_1()
230 EventMessageQueueWrapperBase* getEventQueue() override { return mEventQueue.get(); } in getEventQueue()
243 return mSensors->initialize_2_1(*mEventQueue->getDesc(), wakeLockDesc, callback); in initialize()
247 std::unique_ptr<EventMessageQueueWrapperV2_1> mEventQueue;
|
| /hardware/interfaces/sensors/common/default/2.X/ |
| D | Sensors.h | 129 mEventQueue = std::move(eventQueue); in initializeBase()
136 if (EventFlag::createEventFlag(mEventQueue->getEventFlagWord(), &mEventQueueFlag) != OK) { in initializeBase()
145 if (!mCallback || !mEventQueue || !mWakeLockQueue || mEventQueueFlag == nullptr) { in initializeBase()
202 if (mEventQueue->write(events)) { in postEvents()
294 std::unique_ptr<V2_1::implementation::EventMessageQueueWrapperBase> mEventQueue; member
|
| /hardware/interfaces/sensors/common/default/2.X/multihal/ |
| D | HalProxy.cpp | 221 mEventQueue = std::move(eventQueue); in initializeCommon()
234 if (EventFlag::createEventFlag(mEventQueue->getEventFlagWord(), &mEventQueueFlag) != OK) { in initializeCommon()
240 if (!mDynamicSensorsCallback || !mEventQueue || !mWakeLockQueue || mEventQueueFlag == nullptr) { in initializeCommon()
521 if (mEventQueueFlag != nullptr && mEventQueue != nullptr) { in stopThreads()
522 size_t numToRead = mEventQueue->availableToRead(); in stopThreads()
524 mEventQueue->read(events.data(), numToRead); in stopThreads()
568 size_t eventQueueSize = mEventQueue->getQuantumCount(); in handlePendingWrites()
571 if (!mEventQueue->writeBlocking( in handlePendingWrites()
655 numToWrite = std::min(events.size(), mEventQueue->availableToWrite()); in postEventsToMessageQueue()
657 if (mEventQueue->write(events.data(), numToWrite)) { in postEventsToMessageQueue()
|
| /hardware/interfaces/automotive/vehicle/2.0/default/common/include/vhal_v2_0/ |
| D | VehicleHalManager.h | 150 ConcurrentQueue<VehiclePropValuePtr> mEventQueue; variable
|
| /hardware/interfaces/sensors/common/default/2.X/multihal/include/ |
| D | HalProxy.h | 152 std::unique_ptr<EventMessageQueueWrapperBase> mEventQueue; variable
|