Home
last modified time | relevance | path

Searched refs:mEventQueue (Results 1 – 25 of 32) sorted by relevance

12

/aosp12/frameworks/opt/net/voip/src/java/com/android/server/sip/
H A DSipWakeupTimer.java71 mEventQueue.clear(); in stop()
72 mEventQueue = null; in stop()
76 if (mEventQueue == null) { in stopped()
104 newQueue.addAll(mEventQueue); in recalculatePeriods()
105 mEventQueue.clear(); in recalculatePeriods()
106 mEventQueue = newQueue; in recalculatePeriods()
117 if (mEventQueue.isEmpty()) { in insertEvent()
119 mEventQueue.add(event); in insertEvent()
130 mEventQueue.add(event); in insertEvent()
139 mEventQueue.add(event); in insertEvent()
[all …]
/aosp12/frameworks/native/services/surfaceflinger/tests/unittests/
H A DMessageQueueTest.cpp81 EXPECT_NO_FATAL_FAILURE(mEventQueue.initHandler(mHandler)); in SetUp()
89 new TestableMessageQueue::MockHandler(mEventQueue);
92 TestableMessageQueue mEventQueue; member in android::MessageQueueTest
110 EXPECT_NO_FATAL_FAILURE(mEventQueue.invalidate()); in TEST_F()
111 EXPECT_TRUE(mEventQueue.nextExpectedInvalidate().has_value()); in TEST_F()
122 EXPECT_NO_FATAL_FAILURE(mEventQueue.invalidate()); in TEST_F()
123 EXPECT_TRUE(mEventQueue.nextExpectedInvalidate().has_value()); in TEST_F()
127 EXPECT_NO_FATAL_FAILURE(mEventQueue.invalidate()); in TEST_F()
139 EXPECT_NO_FATAL_FAILURE(mEventQueue.invalidate()); in TEST_F()
162 EXPECT_NO_FATAL_FAILURE(mEventQueue.invalidate()); in TEST_F()
[all …]
/aosp12/hardware/interfaces/automotive/vehicle/2.0/default/impl/vhal_v2_0/
H A DGeneratorHub.cpp50 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()
H A DGeneratorHub.h80 std::priority_queue<VhalEvent, std::vector<VhalEvent>, GreaterByTime> mEventQueue;
/aosp12/frameworks/av/media/libstagefright/foundation/
H A DALooper.cpp180 List<Event>::iterator it = mEventQueue.begin(); in post()
181 while (it != mEventQueue.end() && (*it).mWhenUs <= whenUs) { in post()
189 if (it == mEventQueue.begin()) { in post()
193 mEventQueue.insert(it, event); in post()
204 if (mEventQueue.empty()) { in loop()
208 int64_t whenUs = (*mEventQueue.begin()).mWhenUs; in loop()
221 event = *mEventQueue.begin(); in loop()
222 mEventQueue.erase(mEventQueue.begin()); in loop()
/aosp12/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/decoder/
H A DMediaDecoder.java89 private final LinkedBlockingQueue<Integer> mEventQueue; field in MediaDecoder
139 mEventQueue = new LinkedBlockingQueue<Integer>(MAX_EVENTS); in MediaDecoder()
152 if (mEventQueue.isEmpty()) { in setOpenGLEnabled()
170 mEventQueue.offer(EVENT_START); in start()
180 mEventQueue.offer(EVENT_STOP); in stop()
183 mEventQueue.offer(EVENT_EOF); in stop()
192 event = mEventQueue.poll(); in run()
311 mEventQueue.clear(); in onStop()
/aosp12/hardware/interfaces/sensors/common/utils/
H A DISensorsWrapper.h197 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;
/aosp12/frameworks/av/services/mediatranscoding/tests/
H A DMediaTranscodingServiceTestHelper.h161 if (mEventQueue.empty() && timeoutUs > 0) {
165 if (mEventQueue.empty()) {
168 mPoppedEvent = *mEventQueue.begin();
169 mEventQueue.pop_front();
183 while (((it = std::find(mEventQueue.begin(), mEventQueue.end(), target)) ==
184 mEventQueue.end()) &&
195 if (it == mEventQueue.end()) {
198 *outEvents = std::list<Event>(mEventQueue.begin(), std::next(it));
199 mEventQueue.erase(mEventQueue.begin(), std::next(it));
210 mEventQueue.push_back(event);
[all …]
/aosp12/frameworks/base/packages/SystemUI/src/com/android/systemui/statusbar/notification/collection/
H A DNotifCollection.java149 private Queue<NotifEvent> mEventQueue = new ArrayDeque<>(); field in NotifCollection
410 mEventQueue.add(new RankingUpdatedEvent(rankingMap)); in onNotificationRankingUpdate()
427 mEventQueue.add(new InitEntryEvent(entry)); in postNotification()
428 mEventQueue.add(new BindEntryEvent(entry, sbn)); in postNotification()
432 mEventQueue.add(new EntryAddedEvent(entry)); in postNotification()
448 mEventQueue.add(new BindEntryEvent(entry, sbn)); in postNotification()
485 mEventQueue.add(new CleanUpEntryEvent(entry)); in tryRemoveNotification()
518 mEventQueue.add(new RankingAppliedEvent()); in applyRanking()
524 while (!mEventQueue.isEmpty()) { in dispatchEventsAndRebuildList()
525 mEventQueue.remove().dispatchTo(mNotifCollectionListeners); in dispatchEventsAndRebuildList()
[all …]
/aosp12/system/chre/core/include/chre/core/
H A Dnanoapp.h125 mEventQueue.push(event); in postEvent()
134 return !mEventQueue.empty(); in hasPendingEvent()
242 EventRefQueue mEventQueue; variable
/aosp12/hardware/interfaces/sensors/common/default/2.X/
H A DSensors.h129 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
/aosp12/frameworks/av/media/libmediatranscoding/transcoder/tests/
H A DMediaSampleWriterTests.cpp40 mEventQueue.push_back(AddTrack(trackFormat)); in addTrack()
44 mEventQueue.push_back(Start()); in start()
50 mEventQueue.push_back(WriteSample(trackIndex, data, info)); in writeSampleData()
54 mEventQueue.push_back(Stop()); in stop()
87 mEventQueue.push_back(e); in pushEvent()
93 while (wait && mEventQueue.empty()) { in popEvent()
97 if (mEventQueue.empty()) { in popEvent()
100 mPoppedEvent = *mEventQueue.begin(); in popEvent()
101 mEventQueue.pop_front(); in popEvent()
108 std::list<Event> mEventQueue; member in android::TestMuxer
/aosp12/hardware/interfaces/sensors/common/default/2.X/multihal/
H A DHalProxy.cpp221 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()
/aosp12/frameworks/opt/net/voip/src/jni/rtp/
H A DAudioGroup.cpp509 int mEventQueue; member in __anonfc57d5fc0110::AudioGroup
566 mEventQueue = -1; in AudioGroup()
578 close(mEventQueue); in ~AudioGroup()
590 mEventQueue = epoll_create1(EPOLL_CLOEXEC); in set()
591 if (mEventQueue == -1) { in set()
629 if (epoll_ctl(mEventQueue, EPOLL_CTL_ADD, pair[1], &event)) { in set()
693 if (epoll_ctl(mEventQueue, EPOLL_CTL_ADD, stream->mSocket, &event)) { in add()
716 if (epoll_ctl(mEventQueue, EPOLL_CTL_DEL, stream->mSocket, NULL)) { in remove()
765 count = epoll_wait(mGroup->mEventQueue, events, count, deadline); in threadLoop()
/aosp12/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/
H A DGraphRunner.java117 private LinkedBlockingQueue<Event> mEventQueue = new LinkedBlockingQueue<Event>(); field in GraphRunner.GraphRunLoop
179 mEventQueue.clear(); in loop()
207 if (mEventQueue.isEmpty()) { in pushWakeEvent()
213 mEventQueue.offer(event); in pushEvent()
217 mEventQueue.offer(new Event(eventId, object)); in pushEvent()
235 return mEventQueue.take(); in nextEvent()
H A DCameraStreamer.java772 private LinkedBlockingQueue<Event> mEventQueue = new LinkedBlockingQueue<Event>(MAX_EVENTS); field in CameraStreamer.CameraRunnable
941 mEventQueue.put(new Event(eventId)); in pushEvent()
943 mEventQueue.offer(new Event(eventId)); in pushEvent()
1133 return mEventQueue.take(); in nextEvent()
/aosp12/frameworks/base/core/java/android/app/
H A DUiAutomation.java182 private final ArrayList<AccessibilityEvent> mEventQueue = new ArrayList<AccessibilityEvent>(); field in UiAutomation
875 mEventQueue.clear(); in executeAndWaitForEvent()
898 localEvents.addAll(mEventQueue); in executeAndWaitForEvent()
899 mEventQueue.clear(); in executeAndWaitForEvent()
921 if (mEventQueue.isEmpty()) { in executeAndWaitForEvent()
938 mEventQueue.clear(); in executeAndWaitForEvent()
1550 mEventQueue.add(AccessibilityEvent.obtain(event)); in IAccessibilityServiceClientImpl()
/aosp12/frameworks/av/services/mediaresourcemanager/test/
H A DResourceObserverService_test.cpp86 if (mEventQueue.empty() && timeoutUs > 0) { in pop()
90 if (mEventQueue.empty()) { in pop()
93 mPoppedEvent = *mEventQueue.begin(); in pop()
94 mEventQueue.pop_front(); in pop()
106 mEventQueue.push_back(event); in append()
114 std::list<Event> mEventQueue; member
/aosp12/frameworks/av/media/libmediatranscoding/tests/
H A DTranscodingClientManager_tests.cpp76 mEventQueue.push_back(Finished(in_sessionId)); in onTranscodingFinished()
82 mEventQueue.push_back(Failed(in_sessionId)); in onTranscodingFailed()
113 if (mEventQueue.empty()) { in popEvent()
116 mPoppedEvent = *mEventQueue.begin(); in popEvent()
117 mEventQueue.pop_front(); in popEvent()
124 std::list<Event> mEventQueue; member
H A DTranscodingSessionController_tests.cpp181 mEventQueue.push_back(event); in append()
194 if (mEventQueue.empty() && timeoutUs > 0) { in popEvent()
198 if (mEventQueue.empty()) { in popEvent()
201 mPoppedEvent = *mEventQueue.begin(); in popEvent()
202 mEventQueue.pop_front(); in popEvent()
227 std::list<Event> mEventQueue; member in android::TestTranscoder
/aosp12/frameworks/av/media/libstagefright/foundation/include/media/stagefright/foundation/
H A DALooper.h77 List<Event> mEventQueue; member
/aosp12/frameworks/base/opengl/java/android/opengl/
H A DGLSurfaceView.java1330 if (! mEventQueue.isEmpty()) { in guardedRun()
1331 event = mEventQueue.remove(0); in guardedRun()
1819 mEventQueue.add(r); in queueEvent()
1843 private ArrayList<Runnable> mEventQueue = new ArrayList<Runnable>(); field in GLSurfaceView.GLThread
/aosp12/hardware/interfaces/automotive/vehicle/2.0/default/common/src/
H A DVehicleHalManager.cpp419 mBatchingConsumer.run(&mEventQueue, in init()
442 mEventQueue.deactivate(); in ~VehicleHalManager()
450 mEventQueue.push(std::move(v)); in onHalEvent()
/aosp12/hardware/interfaces/automotive/vehicle/2.0/default/common/include/vhal_v2_0/
H A DVehicleHalManager.h150 ConcurrentQueue<VehiclePropValuePtr> mEventQueue; variable
/aosp12/system/chre/core/
H A Dnanoapp.cc126 Event *event = mEventQueue.pop(); in processNextEvent()

12