Home
last modified time | relevance | path

Searched refs:mQueue (Results 1 – 25 of 97) sorted by relevance

1234

/frameworks/base/services/tests/mockingservicestests/src/com/android/server/
DCircularQueueTest.java29 private CircularQueue<Integer, String> mQueue; field in CircularQueueTest
34 mQueue = new CircularQueue<>(LIMIT); in testQueueInsertionAndDeletion()
35 mQueue.put(1, "A"); in testQueueInsertionAndDeletion()
36 assertEquals(mQueue.getElement(1), "A"); in testQueueInsertionAndDeletion()
37 mQueue.removeElement(1); in testQueueInsertionAndDeletion()
38 assertNull(mQueue.getElement(1)); in testQueueInsertionAndDeletion()
43 mQueue = new CircularQueue<>(LIMIT); in testQueueLimit()
44 mQueue.put(1, "A"); in testQueueLimit()
45 mQueue.put(2, "B"); in testQueueLimit()
46 String removedElement = mQueue.put(3, "C"); in testQueueLimit()
[all …]
/frameworks/native/include/input/
DBlockingQueue.h50 mHasElements.wait(lock, [this]() REQUIRES(mLock) { return !this->mQueue.empty(); }); in pop()
51 T t = std::move(mQueue.front()); in pop()
52 mQueue.erase(mQueue.begin()); in pop()
65 [this]() REQUIRES(mLock) { return !this->mQueue.empty(); })) { in popWithTimeout()
68 T t = std::move(mQueue.front()); in popWithTimeout()
69 mQueue.erase(mQueue.begin()); in popWithTimeout()
82 if (mCapacity && mQueue.size() == mCapacity) { in push()
85 mQueue.push_back(std::move(t)); in push()
101 if (mCapacity && mQueue.size() == mCapacity) { in emplace()
104 mQueue.emplace_back(args...); in emplace()
[all …]
/frameworks/base/libs/WindowManager/Shell/src/com/android/wm/shell/common/
DSyncTransactionQueue.java51 private final ArrayList<SyncCallback> mQueue = new ArrayList<>(); field in SyncTransactionQueue
57 synchronized (mQueue) {
58 if (mInFlight != null && mQueue.contains(mInFlight)) {
79 synchronized (mQueue) { in queue()
81 mQueue.add(cb); in queue()
82 if (mQueue.size() == 1) { in queue()
98 synchronized (mQueue) { in queue()
100 mQueue.add(cb); in queue()
101 if (mQueue.size() == 1) { in queue()
117 synchronized (mQueue) { in queueIfWaiting()
[all …]
/frameworks/base/services/tests/timetests/src/com/android/server/timezonedetector/location/
DTestThreadingDomain.java65 private ArrayList<QueuedRunnable> mQueue = new ArrayList<>(); field in TestThreadingDomain
94 mQueue.add(new QueuedRunnable(r, token, mCurrentTimeMillis + delayMillis)); in postDelayed()
95 mQueue.sort(QueuedRunnable.COMPARATOR); in postDelayed()
100 mQueue.removeIf(runnable -> runnable.token != null && runnable.token == token); in removeQueuedRunnables()
104 mQueue.clear(); in removeAllQueuedRunnables()
118 assertEquals(expectedLength, mQueue.size()); in assertQueueLength()
130 assertTrue(mQueue.isEmpty()); in assertQueueEmpty()
134 assertFalse(mQueue.isEmpty()); in getNextQueueItemDelayMillis()
135 return mQueue.get(0).executionTimeMillis - mCurrentTimeMillis; in getNextQueueItemDelayMillis()
139 assertFalse(mQueue.isEmpty()); in executeNext()
[all …]
/frameworks/native/services/inputflinger/
DSyncQueue.h37 if (mQueue.empty()) { in pop()
40 T t = std::move(mQueue.front()); in pop()
41 mQueue.erase(mQueue.begin()); in pop()
53 if (mCapacity && mQueue.size() == mCapacity) { in push()
56 mQueue.emplace_back(args...); in push()
63 std::list<T> mQueue GUARDED_BY(mLock);
/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/
DInputPort.java43 private FrameQueue mQueue = null; field in InputPort
178 if (mQueue == null) { in pullFrame()
181 Frame frame = mQueue.pullFrame(); in pullFrame()
197 if (mQueue == null) { in peek()
200 return mQueue.peek(); in peek()
208 return mQueue != null; in isConnected()
216 return mQueue != null && mQueue.canPull(); in hasFrame()
292 mQueue = queue; in setQueue()
297 return mQueue; in getQueue()
301 if (mQueue != null) { in clear()
[all …]
DOutputPort.java39 private FrameQueue mQueue = null; field in OutputPort
56 return mQueue == null || mQueue.canPush(); in isAvailable()
165 return mQueue; in getQueue()
169 mQueue = queue; in setQueue()
180 return mQueue != null; in isOpen()
188 if (mQueue != null) { in clear()
189 mQueue.clear(); in clear()
/frameworks/av/media/libheadtracking/
DSensorPoseProvider.cpp61 EventQueueGuard(const sp<SensorEventQueue>& queue, Looper* looper) : mQueue(queue) { in EventQueueGuard()
62 mQueue->looper = Looper_to_ALooper(looper); in EventQueueGuard()
63 mQueue->requestAdditionalInfo = false; in EventQueueGuard()
64 looper->addFd(mQueue->getFd(), kIdent, ALOOPER_EVENT_INPUT, in EventQueueGuard()
69 if (mQueue) { in ~EventQueueGuard()
70 ALooper_to_Looper(mQueue->looper)->removeFd(mQueue->getFd()); in ~EventQueueGuard()
77 [[nodiscard]] SensorEventQueue* get() const { return mQueue.get(); } in get()
80 const sp<SensorEventQueue> mQueue; member in android::media::__anonbad7a65c0111::EventQueueGuard
89 : mQueue(queue), mSensor(sensor) {} in SensorEnableGuard()
93 int ret = mQueue->disableSensor(mSensor); in ~SensorEnableGuard()
[all …]
/frameworks/native/services/vibratorservice/
DVibratorCallbackScheduler.cpp70 mQueue.emplace(DelayedCallback(callback, delay)); in schedule()
82 while (!mQueue.empty() && mQueue.top().isExpired()) { in loop()
83 DelayedCallback callback = mQueue.top(); in loop()
84 mQueue.pop(); in loop()
89 if (mQueue.empty()) { in loop()
91 mCondition.wait(lock, [this] { return mFinished || !mQueue.empty(); }); in loop()
96 mCondition.wait_for(lock, mQueue.top().getWaitForExpirationDuration()); in loop()
/frameworks/av/media/libmediaplayerservice/nuplayer/
DNuPlayerStreamListener.cpp61 mQueue.push_back(entry); in queueBuffer()
82 mQueue.push_back(entry); in issueCommand()
105 if (mQueue.empty()) { in read()
111 QueueEntry *entry = &*mQueue.begin(); in read()
117 mQueue.erase(mQueue.begin()); in read()
128 mQueue.erase(mQueue.begin()); in read()
164 mQueue.erase(mQueue.begin()); in read()
/frameworks/hardware/interfaces/sensorservice/libsensorndkbridge/
DASensorEventQueue.cpp91 size_t copy = std::min(count, mQueue.size()); in getEvents()
93 reinterpret_cast<sensors_event_t *>(events)[i] = mQueue[i]; in getEvents()
95 mQueue.erase(mQueue.begin(), mQueue.begin() + copy); in getEvents()
103 return !mQueue.empty(); in hasEvents()
125 mQueue.emplace_back(); in onEvent()
126 sensors_event_t* sensorEvent = &mQueue[mQueue.size() - 1]; in onEvent()
/frameworks/base/services/core/jni/BroadcastRadio/
DNativeCallbackThread.cpp57 if (mQueue.empty()) { in threadLoop()
61 if (mQueue.empty()) continue; in threadLoop()
64 task = mQueue.front(); in threadLoop()
65 mQueue.pop(); in threadLoop()
81 ALOGD_IF(!mQueue.empty(), "Skipped execution of %zu tasks", mQueue.size()); in threadLoop()
93 mQueue.push(task); in enqueue()
/frameworks/native/libs/gui/
DFenceMonitor.cpp48 mQueue.push_back(fence); in queueFence()
51 ATRACE_INT(mName, int32_t(mQueue.size())); in queueFence()
65 while (mQueue.empty()) { in threadLoop()
68 fence = mQueue[0]; in threadLoop()
83 mQueue.pop_front(); in threadLoop()
85 ATRACE_INT(mName, int32_t(mQueue.size())); in threadLoop()
/frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/hp/
DServiceResolveQueue.java29 private final LinkedList<Pair<NsdServiceInfo, ResolveCallback>> mQueue = new LinkedList<>(); field in ServiceResolveQueue
64 if (mQueue.contains(newRequest)) return; in queueRequest()
65 mQueue.add(newRequest); in queueRequest()
73 mQueue.remove(newRequest); in removeRequest()
81 if (mQueue.isEmpty()) return; in makeNextRequest()
82 mCurrentRequest = mQueue.removeFirst(); in makeNextRequest()
88 if (mCurrentRequest != null) mQueue.add(mCurrentRequest); in makeNextRequest()
/frameworks/av/media/tests/benchmark/src/native/common/
DBenchmarkCommon.h52 needsNotify = mQueue.empty(); in push()
53 mQueue.push(std::move(elem)); in push()
60 if (mQueue.empty()) { in pop()
61 mQueueNotEmptyCondition.wait(lock, [this]() { return !mQueue.empty(); }); in pop()
63 auto result = mQueue.front(); in pop()
64 mQueue.pop(); in pop()
70 queue<T> mQueue; variable
/frameworks/base/core/java/android/os/
DHandler.java231 mQueue = mLooper.mQueue; in Handler()
265 mQueue = looper.mQueue; in Handler()
622 mQueue.removeMessages(this, r, null); in removeCallbacks()
631 mQueue.removeMessages(this, r, token); in removeCallbacks()
729 MessageQueue queue = mQueue; in sendMessageAtTime()
752 MessageQueue queue = mQueue; in sendMessageAtFrontOfQueue()
803 mQueue.removeMessages(this, what, null); in removeMessages()
812 mQueue.removeMessages(this, what, disallowNullArgumentIfShared(object)); in removeMessages()
827 mQueue.removeEqualMessages(this, what, disallowNullArgumentIfShared(object)); in removeEqualMessages()
836 mQueue.removeCallbacksAndMessages(this, disallowNullArgumentIfShared(token)); in removeCallbacksAndMessages()
[all …]
DTestLooperManager.java36 private final MessageQueue mQueue; field in TestLooperManager
54 mQueue = mLooper.getQueue(); in TestLooperManager()
64 return mQueue; in getMessageQueue()
92 return mQueue.next(); in next()
157 return mQueue.hasMessages(h, what, object); in hasMessages()
169 return mQueue.hasMessages(h, r, object); in hasMessages()
DLooper.java81 final MessageQueue mQueue; field in Looper
189 Message msg = me.mQueue.next(); // might block in loopOnce()
362 return myLooper().mQueue; in myQueue()
366 mQueue = new MessageQueue(quitAllowed); in Looper()
422 mQueue.quit(false); in quit()
438 mQueue.quit(true); in quitSafely()
456 return mQueue; in getQueue()
467 mQueue.dump(pw, prefix + " ", null); in dump()
480 mQueue.dump(pw, prefix + " ", handler); in dump()
488 if (mQueue != null) { in dumpDebug()
[all …]
/frameworks/base/core/java/android/speech/tts/
DAudioPlaybackHandler.java27 private final LinkedBlockingQueue<PlaybackQueueItem> mQueue = field in AudioPlaybackHandler
51 mQueue.put(item); in enqueue()
80 return (mQueue.peek() != null) || (mCurrentWorkItem != null); in isSpeaking()
96 mQueue.clear(); in removeAllMessages()
103 Iterator<PlaybackQueueItem> it = mQueue.iterator(); in removeWorkItemsFor()
124 item = mQueue.take(); in run()
/frameworks/base/libs/hwui/platform/host/thread/
DThreadBase.h33 ThreadBase() : Thread(false), mQueue([this]() { mCondition.notify_all(); }, mLock) {} in ThreadBase()
35 WorkQueue& queue() { return mQueue; } in queue()
48 nsecs_t nextWakeup = mQueue.nextWakeup(lock); in waitForWork()
58 void processQueue() { mQueue.process(); } in processQueue()
69 WorkQueue mQueue;
/frameworks/base/libs/hwui/platform/android/thread/
DThreadBase.h37 , mQueue([this]() { mLooper->wake(); }, mLock) {} in ThreadBase()
39 WorkQueue& queue() { return mQueue; } in queue()
57 nextWakeup = mQueue.nextWakeup(lock); in waitForWork()
68 void processQueue() { mQueue.process(); } in processQueue()
83 WorkQueue mQueue;
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/policy/
DBlockingQueueIntentReceiver.java27 private final BlockingQueue<Intent> mQueue = new ArrayBlockingQueue<Intent>(1); field in BlockingQueueIntentReceiver
31 mQueue.add(intent); in onReceive()
35 return mQueue.poll(10, TimeUnit.SECONDS); in waitForIntent()
39 return mQueue.poll(3, TimeUnit.SECONDS); in waitForIntentShortDelay()
/frameworks/opt/telephony/src/java/com/android/internal/telephony/imsphone/
DImsCallInfoTracker.java47 private final List<ImsCallInfo> mQueue = new ArrayList<>(); field in ImsCallInfoTracker
65 if (mQueue.isEmpty()) { in addImsCallStatus()
66 mQueue.add(new ImsCallInfo(mNextIndex++)); in addImsCallStatus()
69 Iterator<ImsCallInfo> it = mQueue.iterator(); in addImsCallStatus()
71 mQueue.remove(imsCallInfo); in addImsCallStatus()
127 mQueue.add(info); in updateImsCallStatus()
128 sort(mQueue); in updateImsCallStatus()
165 mQueue.clear(); in clearAllCallInfo()
/frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/xerox/
DServiceResolver.java105 private final LinkedList<NsdServiceInfo> mQueue = new LinkedList<>(); field in ServiceResolver
111 if (mQueue.contains(serviceInfo)) return; in queueRequest()
112 mQueue.add(serviceInfo); in queueRequest()
119 mQueue.remove(serviceInfo); in removeRequest()
127 mQueue.clear(); in clearRequests()
134 if (mQueue.isEmpty()) return; in makeNextRequest()
135 mCurrentRequest = mQueue.removeFirst(); in makeNextRequest()
140 if (mCurrentRequest != null) mQueue.add(mCurrentRequest); in makeNextRequest()
/frameworks/native/services/inputflinger/dispatcher/trace/
DThreadedBackend.cpp59 mQueue.emplace_back(event, metadata); in traceMotionEvent()
68 mQueue.emplace_back(event, metadata); in traceKeyEvent()
77 mQueue.emplace_back(dispatchArgs, metadata); in traceWindowDispatch()
90 if (mQueue.empty()) { in threadLoop()
96 [&]() REQUIRES(mLock) { return mThreadExit || !mQueue.empty(); }); in threadLoop()
102 mQueue.swap(entries); in threadLoop()

1234