Searched refs:mEventQueue (Results 1 – 10 of 10) sorted by relevance
| /hardware/interfaces/automotive/vehicle/2.0/default/impl/vhal_v2_0/ |
| D | GeneratorHub.cpp | 42 mEventQueue.push({cookie, generator->nextEvent()}); in registerGenerator()
64 while (!mEventQueue.empty() in run()
65 && mGenerators.find(mEventQueue.top().cookie) == mGenerators.end()) { in run()
66 mEventQueue.pop(); in run()
69 mCond.wait(g, [this] { return !mEventQueue.empty(); }); in run()
71 const VhalEvent& curEvent = mEventQueue.top(); in run()
85 mEventQueue.pop(); in run()
87 mEventQueue.push({cookie, mGenerators[cookie]->nextEvent()}); in run()
|
| D | GeneratorHub.h | 80 std::priority_queue<VhalEvent, std::vector<VhalEvent>, GreaterByTime> mEventQueue;
|
| /hardware/interfaces/sensors/2.0/vts/functional/ |
| D | SensorsHidlEnvironmentV2_0.cpp | 68 mEventQueue = std::make_unique<EventMessageQueue>(MAX_RECEIVE_BUFFER_EVENT_COUNT, in resetHal()
74 if (mEventQueue == nullptr || mWakeLockQueue == nullptr) { in resetHal()
79 EventFlag::createEventFlag(mEventQueue->getEventFlagWord(), &mEventQueueFlag); in resetHal()
84 mSensors->initialize(*mEventQueue->getDesc(), *mWakeLockQueue->getDesc(), in resetHal()
137 size_t availableEvents = mEventQueue->availableToRead(); in readEvents()
143 availableEvents = mEventQueue->availableToRead(); in readEvents()
148 if (mEventQueue->read(mEventBuffer.data(), eventsToRead)) { in readEvents()
|
| D | SensorsHidlEnvironmentV2_0.h | 102 std::unique_ptr<EventMessageQueue> mEventQueue; variable
|
| /hardware/interfaces/sensors/2.0/default/ |
| D | Sensors.cpp | 112 mEventQueue = in initialize()
120 if (EventFlag::createEventFlag(mEventQueue->getEventFlagWord(), &mEventQueueFlag) != OK) { in initialize()
129 if (!mCallback || !mEventQueue || !mWakeLockQueue || mEventQueueFlag == nullptr) { in initialize()
185 if (mEventQueue->write(events.data(), events.size())) { in postEvents()
|
| D | Sensors.h | 122 std::unique_ptr<EventMessageQueue> mEventQueue; member
|
| /hardware/interfaces/sensors/2.0/multihal/ |
| D | HalProxy.cpp | 161 mEventQueue = in initialize()
175 if (EventFlag::createEventFlag(mEventQueue->getEventFlagWord(), &mEventQueueFlag) != OK) { in initialize()
181 if (!mDynamicSensorsCallback || !mEventQueue || !mWakeLockQueue || mEventQueueFlag == nullptr) { in initialize()
444 if (mEventQueueFlag != nullptr && mEventQueue != nullptr) { in stopThreads()
445 size_t numToRead = mEventQueue->availableToRead(); in stopThreads()
447 mEventQueue->read(events.data(), numToRead); in stopThreads()
491 size_t eventQueueSize = mEventQueue->getQuantumCount(); in handlePendingWrites()
494 if (!mEventQueue->writeBlocking( in handlePendingWrites()
578 numToWrite = std::min(events.size(), mEventQueue->availableToWrite()); in postEventsToMessageQueue()
580 if (mEventQueue->write(events.data(), numToWrite)) { in postEventsToMessageQueue()
|
| /hardware/interfaces/automotive/vehicle/2.0/default/common/src/ |
| D | VehicleHalManager.cpp | 181 mBatchingConsumer.run(&mEventQueue, in init()
204 mEventQueue.deactivate(); in ~VehicleHalManager()
212 mEventQueue.push(std::move(v)); in onHalEvent()
|
| /hardware/interfaces/automotive/vehicle/2.0/default/common/include/vhal_v2_0/ |
| D | VehicleHalManager.h | 112 ConcurrentQueue<VehiclePropValuePtr> mEventQueue; variable
|
| /hardware/interfaces/sensors/2.0/multihal/include/ |
| D | HalProxy.h | 144 std::unique_ptr<EventMessageQueue> mEventQueue; variable
|