| /frameworks/opt/net/voip/src/java/com/android/server/sip/ |
| D | SipWakeupTimer.java | 45 private TreeSet<MyEvent> mEventQueue = field in SipWakeupTimer
71 mEventQueue.clear(); in stop()
72 mEventQueue = null; in stop()
76 if (mEventQueue == null) { in stopped()
90 if (mEventQueue.isEmpty()) return; in recalculatePeriods()
92 MyEvent firstEvent = mEventQueue.first(); in recalculatePeriods()
95 for (MyEvent e : mEventQueue) { in recalculatePeriods()
103 mEventQueue.comparator()); in recalculatePeriods()
104 newQueue.addAll(mEventQueue); in recalculatePeriods()
105 mEventQueue.clear(); in recalculatePeriods()
[all …]
|
| /frameworks/native/services/surfaceflinger/tests/unittests/ |
| D | MessageQueueTest.cpp | 80 mEventQueue.initVsyncInternal(mVSyncDispatch, mTokenManager, kDuration)); in SetUp()
86 TestableMessageQueue mEventQueue; member
100 EXPECT_FALSE(mEventQueue.getScheduledFrameResult()); in TEST_F()
105 EXPECT_NO_FATAL_FAILURE(mEventQueue.scheduleFrame()); in TEST_F()
107 const auto scheduledFrameResult = mEventQueue.getScheduledFrameResult(); in TEST_F()
122 EXPECT_NO_FATAL_FAILURE(mEventQueue.scheduleFrame()); in TEST_F()
124 auto scheduledFrameResult = mEventQueue.getScheduledFrameResult(); in TEST_F()
132 EXPECT_NO_FATAL_FAILURE(mEventQueue.scheduleFrame()); in TEST_F()
134 scheduledFrameResult = mEventQueue.getScheduledFrameResult(); in TEST_F()
149 EXPECT_NO_FATAL_FAILURE(mEventQueue.scheduleFrame()); in TEST_F()
[all …]
|
| /frameworks/av/media/module/foundation/ |
| D | ALooper.cpp | 184 List<Event>::iterator it = mEventQueue.begin(); in post()
185 while (it != mEventQueue.end() && (*it).mWhenUs <= whenUs) { in post()
194 if (it == mEventQueue.begin()) { in post()
198 mEventQueue.insert(it, event); in post()
218 bool shouldAwakeLoop = mEventQueue.empty() || whenUs < mEventQueue.begin()->mWhenUs; in postUnique()
221 for (auto i = mEventQueue.begin(); i != mEventQueue.end();) { in postUnique()
223 i = mEventQueue.erase(i); in postUnique()
230 List<Event>::iterator i = mEventQueue.begin(); in postUnique()
231 while (i != mEventQueue.end() && i->mWhenUs <= whenUs) { in postUnique()
239 mEventQueue.insert(i, event); in postUnique()
[all …]
|
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/decoder/ |
| D | MediaDecoder.java | 91 private final LinkedBlockingQueue<Integer> mEventQueue; field in MediaDecoder
141 mEventQueue = new LinkedBlockingQueue<Integer>(MAX_EVENTS); in MediaDecoder()
154 if (mEventQueue.isEmpty()) { in setOpenGLEnabled()
172 mEventQueue.offer(EVENT_START); in start()
182 mEventQueue.offer(EVENT_STOP); in stop()
185 mEventQueue.offer(EVENT_EOF); in stop()
194 event = mEventQueue.poll(); in run()
314 mEventQueue.clear(); in onStop()
|
| /frameworks/av/media/module/service.mediatranscoding/tests/ |
| D | MediaTranscodingServiceTestHelper.h | 161 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 …]
|
| /frameworks/native/services/sensorservice/ |
| D | AidlSensorHalWrapper.cpp | 118 mEventQueue = std::make_unique<AidlMessageQueue< in connect()
128 EventFlag::createEventFlag(mEventQueue->getEventFlagWord(), &mEventQueueFlag); in connect()
134 CHECK(mEventQueue != nullptr && mEventQueueFlag != nullptr && in connect()
138 mSensors->initialize(mEventQueue->dupeDesc(), mWakeLockQueue->dupeDesc(), mCallback); in connect()
162 size_t availableEvents = mEventQueue->availableToRead(); in pollFmq()
176 availableEvents = mEventQueue->availableToRead(); in pollFmq()
191 if (mEventQueue->read(mEventBuffer.data(), eventsToRead)) { in pollFmq()
|
| D | AidlSensorHalWrapper.h | 83 mEventQueue; variable
|
| /frameworks/av/media/module/libmediatranscoding/transcoder/tests/ |
| D | MediaSampleWriterTests.cpp | 40 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
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/statusbar/notification/collection/ |
| D | NotifCollection.java | 171 private Queue<NotifEvent> mEventQueue = new ArrayDeque<>(); field in NotifCollection
487 mEventQueue.add(new RankingUpdatedEvent(rankingMap)); in onNotificationRankingUpdate()
498 mEventQueue.add(new ChannelChangedEvent(pkgName, user, channel, modificationType)); in onNotificationChannelModified()
514 mEventQueue.add(new InitEntryEvent(entry)); in postNotification()
515 mEventQueue.add(new BindEntryEvent(entry, sbn)); in postNotification()
519 mEventQueue.add(new EntryAddedEvent(entry)); in postNotification()
535 mEventQueue.add(new BindEntryEvent(entry, sbn)); in postNotification()
538 mEventQueue.add(new EntryUpdatedEvent(entry, true /* fromSystem */)); in postNotification()
577 mEventQueue.add(new EntryRemovedEvent(entry, entry.mCancellationReason)); in tryRemoveNotification()
578 mEventQueue.add(new CleanUpEntryEvent(entry)); in tryRemoveNotification()
[all …]
|
| /frameworks/opt/net/voip/src/jni/rtp/ |
| D | AudioGroup.cpp | 507 int mEventQueue; member in __anon3727f2a40111::AudioGroup
564 mEventQueue = -1; in AudioGroup()
576 close(mEventQueue); in ~AudioGroup()
588 mEventQueue = epoll_create1(EPOLL_CLOEXEC); in set()
589 if (mEventQueue == -1) { in set()
627 if (epoll_ctl(mEventQueue, EPOLL_CTL_ADD, pair[1], &event)) { in set()
691 if (epoll_ctl(mEventQueue, EPOLL_CTL_ADD, stream->mSocket, &event)) { in add()
714 if (epoll_ctl(mEventQueue, EPOLL_CTL_DEL, stream->mSocket, NULL)) { in remove()
763 count = epoll_wait(mGroup->mEventQueue, events, count, deadline); in threadLoop()
|
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
| D | GraphRunner.java | 117 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()
|
| D | CameraStreamer.java | 772 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()
|
| /frameworks/av/services/mediaresourcemanager/test/ |
| D | ResourceObserverService_test.cpp | 86 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
|
| /frameworks/av/media/module/libmediatranscoding/tests/ |
| D | TranscodingClientManager_tests.cpp | 76 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
|
| D | TranscodingSessionController_tests.cpp | 181 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
|
| /frameworks/base/core/java/android/app/ |
| D | UiAutomation.java | 209 private final ArrayList<AccessibilityEvent> mEventQueue = new ArrayList<AccessibilityEvent>(); field in UiAutomation
1138 mEventQueue.clear(); in executeAndWaitForEvent()
1161 localEvents.addAll(mEventQueue); in executeAndWaitForEvent()
1162 mEventQueue.clear(); in executeAndWaitForEvent()
1184 if (mEventQueue.isEmpty()) { in executeAndWaitForEvent()
1201 mEventQueue.clear(); in executeAndWaitForEvent()
1953 mEventQueue.add(AccessibilityEvent.obtain(event)); in IAccessibilityServiceClientImpl()
|
| /frameworks/av/media/module/foundation/include/media/stagefright/foundation/ |
| D | ALooper.h | 81 List<Event> mEventQueue; member
|
| /frameworks/base/opengl/java/android/opengl/ |
| D | GLSurfaceView.java | 1330 if (! mEventQueue.isEmpty()) { in guardedRun()
1331 event = mEventQueue.remove(0); in guardedRun()
1827 mEventQueue.add(r); in queueEvent()
1851 private ArrayList<Runnable> mEventQueue = new ArrayList<Runnable>(); field in GLSurfaceView.GLThread
|
| /frameworks/base/boot/hiddenapi/ |
| D | hiddenapi-max-target-o.txt | 9125 Landroid/app/UiAutomation;->mEventQueue:Ljava/util/ArrayList;
33920 Landroid/opengl/GLSurfaceView$GLThread;->mEventQueue:Ljava/util/ArrayList;
|