| /hardware/interfaces/automotive/vehicle/2.0/default/impl/vhal_v2_0/ |
| D | GeneratorHub.cpp | 57 mEventQueue.push({cookie, generator->nextEvent()}); in registerGenerator()
79 while (!mEventQueue.empty() in run()
80 && mGenerators.find(mEventQueue.top().cookie) == mGenerators.end()) { in run()
81 mEventQueue.pop(); in run()
84 mCond.wait(g, [this] { return !mEventQueue.empty() || mShuttingDownFlag.load(); }); in run()
89 const VhalEvent& curEvent = mEventQueue.top(); in run()
103 mEventQueue.pop(); in run()
105 mEventQueue.push({cookie, mGenerators[cookie]->nextEvent()}); in run()
|
| D | GeneratorHub.h | 80 std::priority_queue<VhalEvent, std::vector<VhalEvent>, GreaterByTime> mEventQueue;
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/3/fake_impl/GeneratorHub/src/ |
| D | GeneratorHub.cpp | 59 mEventQueue.push({id, maybeNextEvent.value()}); in registerGenerator()
84 while (!mEventQueue.empty() && in run()
85 mGenerators.find(mEventQueue.top().generatorId) == mGenerators.end()) { in run()
86 mEventQueue.pop(); in run()
90 mCond.wait(lock, [this] { return !mEventQueue.empty() || mShuttingDownFlag.load(); }); in run()
95 const VhalEvent& curEvent = mEventQueue.top(); in run()
114 mEventQueue.pop(); in run()
118 mEventQueue.push({id, maybeNextEvent.value()}); in run()
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/current/fake_impl/GeneratorHub/src/ |
| D | GeneratorHub.cpp | 59 mEventQueue.push({id, maybeNextEvent.value()}); in registerGenerator()
84 while (!mEventQueue.empty() && in run()
85 mGenerators.find(mEventQueue.top().generatorId) == mGenerators.end()) { in run()
86 mEventQueue.pop(); in run()
90 mCond.wait(lock, [this] { return !mEventQueue.empty() || mShuttingDownFlag.load(); }); in run()
95 const VhalEvent& curEvent = mEventQueue.top(); in run()
114 mEventQueue.pop(); in run()
118 mEventQueue.push({id, maybeNextEvent.value()}); in run()
|
| /hardware/interfaces/sensors/aidl/vts/ |
| D | SensorsAidlEnvironment.cpp | 71 mEventQueue = std::make_unique<EventQueue>(MAX_RECEIVE_BUFFER_EVENT_COUNT, in resetHal()
74 if (mWakeLockQueue == nullptr || mEventQueue == nullptr) { in resetHal()
79 EventFlag::createEventFlag(mEventQueue->getEventFlagWord(), &mEventQueueFlag); in resetHal()
84 mSensors->initialize(mEventQueue->dupeDesc(), mWakeLockQueue->dupeDesc(), mCallback); in resetHal()
136 size_t availableEvents = mEventQueue->availableToRead(); in readEvents()
142 availableEvents = mEventQueue->availableToRead(); in readEvents()
147 if (mEventQueue->read(mEventBuffer.data(), eventsToRead)) { in readEvents()
|
| D | SensorsAidlEnvironment.h | 91 std::unique_ptr<EventQueue> mEventQueue; variable
|
| /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/google/aemu/base/ |
| D | HealthMonitor.cpp | 53 mEventQueue.push(std::move(event)); in ~HealthMonitor()
80 mEventQueue.push(std::move(event)); in startMonitoringTask()
89 mEventQueue.push(std::move(event)); in touchMonitoredTask()
97 mEventQueue.push(std::move(event)); in stopMonitoringTask()
107 mEventQueue.push(std::move(event)); in poll()
124 if (mEventQueue.empty()) { in main()
130 mEventQueue.swap(events); in main()
|
| /hardware/interfaces/automotive/vehicle/2.0/default/impl/vhal_v2_0/tests/ |
| D | DefaultVhalImpl_test.cpp | 100 mEventQueue.deactivate(); in ~DefaultVhalImplTest()
129 android::ConcurrentQueue<VehiclePropValuePtr> mEventQueue; member in __anonde9c36280111::DefaultVhalImplTest
135 mEventQueue.waitForItems(); in waitForEvents()
136 auto newEvents = mEventQueue.flush(); in waitForEvents()
147 mEventQueue.push(std::move(v)); in onHalEvent()
327 mEventQueue.flush(); in TEST_F()
356 mEventQueue.flush(); in TEST_F()
408 mEventQueue.flush(); in TEST_F()
414 auto events = mEventQueue.flush(); in TEST_F()
759 mEventQueue.flush(); in TEST_F()
[all …]
|
| /hardware/interfaces/sensors/aidl/default/ |
| D | Sensors.cpp | 106 mEventQueue = std::make_unique<AidlMessageQueue<Event, SynchronizedReadWrite>>( in initialize()
114 if (EventFlag::createEventFlag(mEventQueue->getEventFlagWord(), &mEventQueueFlag) != OK) { in initialize()
123 if (!mCallback || !mEventQueue || !mWakeLockQueue || mEventQueueFlag == nullptr) { in initialize()
|
| /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 | 236 mEventQueue = std::move(eventQueue); in initializeCommon()
248 if (EventFlag::createEventFlag(mEventQueue->getEventFlagWord(), &mEventQueueFlag) != OK) { in initializeCommon()
254 if (!mDynamicSensorsCallback || !mEventQueue || !mWakeLockQueue || mEventQueueFlag == nullptr) { in initializeCommon()
535 if (mEventQueueFlag != nullptr && mEventQueue != nullptr) { in stopThreads()
536 size_t numToRead = mEventQueue->availableToRead(); in stopThreads()
538 mEventQueue->read(events.data(), numToRead); in stopThreads()
582 size_t eventQueueSize = mEventQueue->getQuantumCount(); in handlePendingWrites()
585 if (!mEventQueue->writeBlocking( in handlePendingWrites()
670 numToWrite = std::min(events.size(), mEventQueue->availableToWrite()); in postEventsToMessageQueue()
672 if (mEventQueue->write(events.data(), numToWrite)) { in postEventsToMessageQueue()
|
| /hardware/interfaces/sensors/aidl/default/include/sensors-impl/ |
| D | Sensors.h | 98 if (mEventQueue == nullptr) { in postEvents()
101 if (mEventQueue->write(&events.front(), events.size())) { in postEvents()
199 std::unique_ptr<AidlMessageQueue<Event, SynchronizedReadWrite>> mEventQueue;
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/current/fake_impl/GeneratorHub/include/ |
| D | GeneratorHub.h | 73 std::priority_queue<VhalEvent, std::vector<VhalEvent>, GreaterByTime> mEventQueue; variable
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/3/fake_impl/GeneratorHub/include/ |
| D | GeneratorHub.h | 73 std::priority_queue<VhalEvent, std::vector<VhalEvent>, GreaterByTime> mEventQueue; variable
|
| /hardware/interfaces/automotive/vehicle/2.0/default/common/include/vhal_v2_0/ |
| D | VehicleHalManager.h | 150 ConcurrentQueue<VehiclePropValuePtr> mEventQueue; variable
|
| /hardware/interfaces/automotive/vehicle/2.0/default/common/src/ |
| D | VehicleHalManager.cpp | 419 mBatchingConsumer.run(&mEventQueue, in init()
442 mEventQueue.deactivate(); in ~VehicleHalManager()
450 mEventQueue.push(std::move(v)); in onHalEvent()
|
| /hardware/google/aemu/base/include/aemu/base/ |
| D | HealthMonitor.h | 171 std::queue<std::unique_ptr<MonitoredEvent>> mEventQueue; variable
|
| /hardware/interfaces/sensors/common/default/2.X/multihal/include/ |
| D | HalProxy.h | 154 std::unique_ptr<EventMessageQueueWrapperBase> mEventQueue; variable
|