| /tools/tradefederation/core/src/com/android/tradefed/util/sl4a/ |
| Sl4aEventDispatcher.java | 42 private Map<String, LinkedList<EventSl4aObject>> mEventQueue = new HashMap<>();
79 synchronized(mEventQueue) {
80 if (mEventQueue.containsKey(event.getName())) {
81 mEventQueue.get(event.getName()).add(event);
85 mEventQueue.put(event.getName(), queue);
120 synchronized (mEventQueue) {
121 if (mEventQueue.get(name) != null) {
123 EventSl4aObject res = mEventQueue.get(name).poll();
146 synchronized (mEventQueue) {
147 if (mEventQueue.get(name) != null)
[all...] |
| /frameworks/opt/net/voip/src/java/com/android/server/sip/ |
| SipWakeupTimer.java | 45 private TreeSet<MyEvent> mEventQueue =
71 mEventQueue.clear();
72 mEventQueue = null;
76 if (mEventQueue == null) {
90 if (mEventQueue.isEmpty()) return;
92 MyEvent firstEvent = mEventQueue.first();
95 for (MyEvent e : mEventQueue) {
103 mEventQueue.comparator());
104 newQueue.addAll(mEventQueue);
105 mEventQueue.clear()
[all...] |
| /frameworks/av/media/libstagefright/foundation/ |
| ALooper.cpp | 178 List<Event>::iterator it = mEventQueue.begin();
179 while (it != mEventQueue.end() && (*it).mWhenUs <= whenUs) {
187 if (it == mEventQueue.begin()) {
191 mEventQueue.insert(it, event);
202 if (mEventQueue.empty()) {
206 int64_t whenUs = (*mEventQueue.begin()).mWhenUs;
216 event = *mEventQueue.begin();
217 mEventQueue.erase(mEventQueue.begin());
|
| /system/chre/core/ |
| nanoapp.cc | 54 mEventQueue.push(event);
58 return !mEventQueue.empty();
82 Event *event = mEventQueue.pop();
|
| /packages/apps/Launcher3/quickstep/src/com/android/quickstep/ |
| TouchInteractionService.java | 89 mEventQueue.queue(ev);
106 mEventQueue.onQuickScrubStart();
112 mEventQueue.onQuickScrubProgress(progress);
117 mEventQueue.onQuickScrubEnd();
130 mEventQueue.onOverviewShownFromAltTab();
140 mEventQueue.onQuickScrubEnd();
146 mEventQueue.onQuickStep(motionEvent);
167 private MotionEventQueue mEventQueue;
186 mEventQueue = new MotionEventQueue(mMainThreadChoreographer, mNoOpTouchConsumer);
211 mEventQueue.reset()
[all...] |
| OtherActivityTouchConsumer.java | 95 private MotionEventQueue mEventQueue;
224 handler.setGestureEndCallback(mEventQueue::reset);
324 mEventQueue = queue;
367 mEventQueue.setInterimChoreographer(null);
415 mEventQueue.onCommand(id);
421 mEventQueue.onCommand(id);
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/ |
| EventFacade.java | 72 private final Queue<Event> mEventQueue = new ConcurrentLinkedQueue<Event>();
95 mEventQueue.clear();
165 Event event = mEventQueue.poll();
185 synchronized (mEventQueue) { // First check to make sure it isn't already there
186 for (Event event : mEventQueue) {
190 mEventQueue.remove(event);
209 mEventQueue.remove(event);
233 synchronized (mEventQueue) { // Anything in queue?
234 if (mEventQueue.size() > 0) {
235 return mEventQueue.poll(); // return it
[all...] |
| /system/chre/core/include/chre/core/ |
| nanoapp.h | 139 EventRefQueue mEventQueue;
|
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/decoder/ |
| MediaDecoder.java | 89 private final LinkedBlockingQueue<Integer> mEventQueue;
139 mEventQueue = new LinkedBlockingQueue<Integer>(MAX_EVENTS);
152 if (mEventQueue.isEmpty()) {
170 mEventQueue.offer(EVENT_START);
180 mEventQueue.offer(EVENT_STOP);
183 mEventQueue.offer(EVENT_EOF);
192 event = mEventQueue.poll();
311 mEventQueue.clear();
|
| /frameworks/base/services/accessibility/java/com/android/server/accessibility/ |
| AccessibilityInputFilter.java | 118 if (mEventQueue != null) {
150 private MotionEventHolder mEventQueue;
297 if (mEventQueue == null) {
298 mEventQueue = MotionEventHolder.obtain(event, policyFlags);
302 if (mEventQueue.event.addBatch(event)) {
306 holder.next = mEventQueue;
307 mEventQueue.previous = holder;
308 mEventQueue = holder;
312 MotionEventHolder current = mEventQueue;
321 mEventQueue = null
[all...] |
| /frameworks/av/media/libstagefright/foundation/include/media/stagefright/foundation/ |
| ALooper.h | 77 List<Event> mEventQueue;
|
| /hardware/interfaces/automotive/vehicle/2.0/default/common/include/vhal_v2_0/ |
| VehicleHalManager.h | 112 ConcurrentQueue<VehiclePropValuePtr> mEventQueue;
|
| /frameworks/base/core/java/android/app/ |
| UiAutomation.java | 122 private final ArrayList<AccessibilityEvent> mEventQueue = new ArrayList<AccessibilityEvent>();
583 mEventQueue.clear();
606 localEvents.addAll(mEventQueue);
607 mEventQueue.clear();
629 if (mEventQueue.isEmpty()) {
646 mEventQueue.clear();
[all...] |
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
| GraphRunner.java | 117 private LinkedBlockingQueue<Event> mEventQueue = new LinkedBlockingQueue<Event>();
179 mEventQueue.clear();
207 if (mEventQueue.isEmpty()) {
213 mEventQueue.offer(event);
217 mEventQueue.offer(new Event(eventId, object));
235 return mEventQueue.take();
[all...] |
| CameraStreamer.java | 772 private LinkedBlockingQueue<Event> mEventQueue = new LinkedBlockingQueue<Event>(MAX_EVENTS);
[all...] |
| /hardware/interfaces/automotive/vehicle/2.0/default/common/src/ |
| VehicleHalManager.cpp | 181 mBatchingConsumer.run(&mEventQueue,
204 mEventQueue.deactivate();
212 mEventQueue.push(std::move(v));
|
| /frameworks/opt/net/voip/src/jni/rtp/ |
| AudioGroup.cpp | 498 int mEventQueue;
555 mEventQueue = -1;
567 close(mEventQueue);
579 mEventQueue = epoll_create(2);
580 if (mEventQueue == -1) {
618 if (epoll_ctl(mEventQueue, EPOLL_CTL_ADD, pair[1], &event)) {
682 if (epoll_ctl(mEventQueue, EPOLL_CTL_ADD, stream->mSocket, &event)) {
705 if (epoll_ctl(mEventQueue, EPOLL_CTL_DEL, stream->mSocket, NULL)) {
754 count = epoll_wait(mGroup->mEventQueue, events, count, deadline);
|
| /frameworks/av/services/soundtrigger/ |
| SoundTriggerHwService.cpp | 415 while (!mEventQueue.isEmpty()) {
416 mEventQueue[0]->mMemory.clear();
417 mEventQueue.removeAt(0);
433 while (mEventQueue.isEmpty() && !exitPending()) {
441 event = mEventQueue[0];
442 mEventQueue.removeAt(0);
463 mEventQueue.add(event);
[all...] |
| SoundTriggerHwService.h | 213 Vector< sp<CallbackEvent> > mEventQueue;
|
| /development/samples/JetBoy/src/com/example/android/jetboy/ |
| JetBoyView.java | 144 protected ConcurrentLinkedQueue<GameEvent> mEventQueue = new ConcurrentLinkedQueue<GameEvent>();
689 GameEvent event = mEventQueue.poll();
[all...] |
| /cts/tests/tests/openglperf/src/android/openglperf/cts/ |
| GLSurfaceViewCustom.java | [all...] |
| /external/replicaisland/src/com/replica/replicaisland/ |
| GLSurfaceView.java | [all...] |
| /frameworks/base/opengl/java/android/opengl/ |
| GLSurfaceView.java | [all...] |
| /frameworks/native/services/surfaceflinger/tests/unittests/ |
| TestableSurfaceFlinger.h | 120 auto& mutableEventQueue() { return mFlinger->mEventQueue; }
|
| /frameworks/native/services/surfaceflinger/ |
| SurfaceFlinger.cpp | 357 mEventQueue->init(this);
664 mEventQueue->setEventThread(mSFEventThread.get());
[all...] |
