| /aosp12/packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/keyboard/internal/ |
| H A D | PointerTrackerQueueTests.java | 84 mQueue.add(mElement1); in testAdd()
87 mQueue.add(mElement2); in testAdd()
90 mQueue.add(mElement3); in testAdd()
93 mQueue.add(mElement4); in testAdd()
102 mQueue.add(mElement1); in testRemove()
103 mQueue.add(mElement2); in testRemove()
104 mQueue.add(mElement3); in testRemove()
105 mQueue.add(mElement4); in testRemove()
137 mQueue.add(mElement1); in testAddAndRemove()
138 mQueue.add(mElement2); in testAddAndRemove()
[all …]
|
| /aosp12/system/libfmq/tests/ |
| H A D | fmq_unit_tests.cpp | 100 delete mQueue; in TearDown()
111 mQueue = new (std::nothrow) in SetUp()
115 ASSERT_NE(nullptr, mQueue); in SetUp()
116 ASSERT_TRUE(mQueue->isValid()); in SetUp()
131 delete mQueue; in TearDown()
146 ASSERT_NE(nullptr, mQueue); in SetUp()
162 delete mQueue; in TearDown()
176 ASSERT_NE(nullptr, mQueue); in SetUp()
186 typename T::MQType* mQueue; member in BlockingReadWrites
210 ASSERT_NE(nullptr, mQueue); in SetUp()
[all …]
|
| H A D | msgq_test_client.cpp | 186 if (mQueue->isValid()) in newQueue()
241 MessageQueueUnsync* mQueue = nullptr; member in ClientUnsyncTestBase
253 delete mQueue; in TearDown()
270 ASSERT_NE(nullptr, mQueue); in SetUp()
271 ASSERT_TRUE(mQueue->isValid()); in SetUp()
278 typename T::MQType* mQueue = nullptr; member in SynchronizedReadWriteClient
292 ASSERT_NE(nullptr, this->mQueue); in SetUp()
418 ret = this->mQueue->writeBlocking( in TYPED_TEST()
625 ret = this->mQueue->readBlocking( in TYPED_TEST()
674 *(writeCntr) = this->mQueue->getQuantumCount() * this->mQueue->getQuantumSize() - 1; in TYPED_TEST()
[all …]
|
| /aosp12/packages/apps/Gallery/src/com/android/camera/ |
| H A D | ImageLoader.java | 54 synchronized (mQueue) { in getBitmap()
56 mQueue.add(w); in getBitmap()
57 mQueue.notifyAll(); in getBitmap()
62 synchronized (mQueue) { in cancel()
65 mQueue.remove(index); in cancel()
85 synchronized (mQueue) { in clearQueue()
86 int n = mQueue.size(); in clearQueue()
91 mQueue.clear(); in clearQueue()
121 synchronized (mQueue) { in run()
159 synchronized (mQueue) { in stop()
[all …]
|
| /aosp12/hardware/interfaces/sensors/common/utils/ |
| H A D | EventMessageQueueWrapper.h | 57 : mQueue(std::move(queue)) {} in EventMessageQueueWrapperV1_0()
60 return mQueue->getDesc(); in getDesc()
64 return mQueue->getEventFlagWord(); in getEventFlagWord()
81 return mQueue->write(oldEvents.data(), oldEvents.size()); in write()
94 std::unique_ptr<EventMessageQueue> mQueue;
102 : mQueue(std::move(queue)) {} in EventMessageQueueWrapperV2_1()
105 return mQueue->getDesc(); in getDesc()
115 return mQueue->read(events, numToRead); in read()
119 return mQueue->write(events, numToWrite); in write()
123 return mQueue->write(events.data(), events.size()); in write()
[all …]
|
| /aosp12/frameworks/native/services/inputflinger/ |
| H A D | BlockingQueue.h | 38 mQueue.reserve(mCapacity); in BlockingQueue()
48 mHasElements.wait(lock, [this]() REQUIRES(mLock) { return !this->mQueue.empty(); }); in pop()
49 T t = std::move(mQueue.front()); in pop()
50 mQueue.erase(mQueue.begin()); in pop()
63 if (mQueue.size() == mCapacity) { in push()
66 mQueue.push_back(std::move(t)); in push()
74 mQueue.erase(std::remove_if(mQueue.begin(), mQueue.end(), in erase()
75 [&lambda](const T& t) { return lambda(t); }), mQueue.end()); in erase()
84 mQueue.clear(); in clear()
94 return mQueue.size(); in size()
[all …]
|
| /aosp12/frameworks/av/media/libheadtracking/ |
| H A D | SensorPoseProvider.cpp | 58 mQueue->looper = Looper_to_ALooper(looper); in EventQueueGuard()
59 mQueue->requestAdditionalInfo = false; in EventQueueGuard()
64 if (mQueue) { in ~EventQueueGuard()
65 ALooper_to_Looper(mQueue->looper)->removeFd(mQueue->getFd()); in ~EventQueueGuard()
75 sp<SensorEventQueue> mQueue; member in android::media::__anon57b4a7480110::EventQueueGuard
84 : mQueue(queue), mSensor(sensor) {} in SensorEnableGuard()
99 SensorEnableGuard(SensorEnableGuard&& other) : mQueue(other.mQueue), mSensor(other.mSensor) { in SensorEnableGuard()
104 sp<SensorEventQueue> const mQueue; member in android::media::__anon57b4a7480110::SensorEnableGuard
177 sp<SensorEventQueue> mQueue; member in android::media::__anon57b4a7480110::SensorPoseProviderImpl
203 if (mQueue == nullptr) { in threadFunc()
[all …]
|
| /aosp12/frameworks/base/libs/WindowManager/Shell/src/com/android/wm/shell/common/ |
| H A D | SyncTransactionQueue.java | 54 synchronized (mQueue) {
76 synchronized (mQueue) { in queue()
78 mQueue.add(cb); in queue()
79 if (mQueue.size() == 1) { in queue()
95 synchronized (mQueue) { in queue()
97 mQueue.add(cb); in queue()
98 if (mQueue.size() == 1) { in queue()
114 synchronized (mQueue) { in queueIfWaiting()
115 if (mQueue.isEmpty()) { in queueIfWaiting()
121 mQueue.add(cb); in queueIfWaiting()
[all …]
|
| /aosp12/system/libhidl/base/ |
| H A D | TaskRunner.cpp | 32 mQueue = std::make_shared<SynchronizedQueue<Task>>(limit); in start()
36 if (mQueue) { in ~TaskRunner()
37 mQueue->push(nullptr); in ~TaskRunner()
42 if (mQueue == nullptr || !t) { in push()
47 std::unique_lock<std::mutex> lock = mQueue->lock(); in push()
49 if (!mQueue->isInitializedLocked()) { in push()
52 std::thread{[q = mQueue] { in push()
61 mQueue->setInitializedLocked(true); in push()
65 return this->mQueue->push(t); in push()
|
| /aosp12/packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ringbuffer/ |
| H A D | DynamicRingBuffer.java | 103 mQueue.discardNext(); in update()
127 mQueue.close(); in close()
132 return mQueue.getNext(); in getNext()
138 return mQueue.getNext(timeout, unit); in getNext()
143 return mQueue.peekNext(); in peekNext()
148 mQueue.discardNext(); in discardNext()
153 return mQueue.isClosed(); in isClosed()
162 while (mQueue.peekNext() != null) { in acquire()
163 mQueue.discardNext(); in acquire()
183 mQueue.discardNext(); in tryAcquire()
[all …]
|
| /aosp12/packages/apps/Camera2/src/com/android/camera/async/ |
| H A D | ConcurrentBufferQueue.java | 82 private final BlockingQueue<Entry<T>> mQueue; field in ConcurrentBufferQueue
96 mQueue = new LinkedBlockingQueue<>(); in ConcurrentBufferQueue()
120 mQueue.drainTo(remainingElements); in close()
130 while (mQueue.peek() == null) { in close()
131 mQueue.add(makeClosingMarker()); in close()
148 mQueue.add(makeEntry(element)); in update()
160 mQueue.add(nextEntry); in doWithNextEntry()
169 Entry<T> nextEntry = mQueue.take(); in getNext()
185 Entry<T> nextEntry = mQueue.peek(); in peekNext()
198 Entry<T> nextEntry = mQueue.remove(); in discardNext()
[all …]
|
| /aosp12/system/chre/util/include/chre/util/ |
| H A D | fixed_size_blocking_queue_impl.h | 31 success = mQueue.push(element); in push()
44 success = mQueue.push(std::move(element)); in push()
55 while (mQueue.empty()) { in pop()
59 ElementType element(std::move(mQueue.front())); in pop()
60 mQueue.pop(); in pop()
67 return mQueue.empty(); in empty()
73 return mQueue.size(); in size()
79 return mQueue.remove(index); in remove()
86 return mQueue[index];
93 return mQueue[index];
|
| /aosp12/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/ |
| H A D | SampleQueue.java | 25 private final LinkedList<SampleHolder> mQueue = new LinkedList<>(); field in SampleQueue
34 mQueue.offer(sample); in queueSample()
39 SampleHolder sampleFromQueue = mQueue.poll(); in dequeueSample()
55 while (!mQueue.isEmpty()) { in clear()
56 mSamplePool.releaseSample(mQueue.poll()); in clear()
66 return !mQueue.isEmpty() && mQueue.getLast().timeUs - mQueue.getFirst().timeUs > durationUs; in isDurationGreaterThan()
70 return mQueue.isEmpty(); in isEmpty()
|
| /aosp12/hardware/interfaces/automotive/vehicle/2.0/default/common/include/vhal_v2_0/ |
| H A D | ConcurrentQueue.h | 33 while (mQueue.empty() && mIsActive) { in waitForItems()
42 if (mQueue.empty() || !mIsActive) { in flush()
45 while (!mQueue.empty()) { in flush()
46 items.push_back(std::move(mQueue.front())); in flush()
47 mQueue.pop(); in flush()
58 mQueue.push(std::move(item)); in push()
84 std::queue<T> mQueue; variable
108 mQueue = queue; in run()
129 mQueue->waitForItems(); in runInternal()
135 std::vector<T> items = mQueue->flush(); in runInternal()
[all …]
|
| /aosp12/frameworks/base/services/tests/servicestests/src/com/android/server/timezonedetector/location/ |
| H A D | TestThreadingDomain.java | 65 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 …]
|
| /aosp12/packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer2/buffer/ |
| H A D | SampleQueue.java | 26 private final LinkedList<DecoderInputBuffer> mQueue = new LinkedList<>(); field in SampleQueue
35 mQueue.offer(sample); in queueSample()
40 DecoderInputBuffer sampleFromQueue = mQueue.poll(); in dequeueSample()
58 while (!mQueue.isEmpty()) { in clear()
59 mInputBufferPool.releaseSample(mQueue.poll()); in clear()
69 return !mQueue.isEmpty() && mQueue.getLast().timeUs - mQueue.getFirst().timeUs > durationUs; in isDurationGreaterThan()
73 return mQueue.isEmpty(); in isEmpty()
|
| /aosp12/frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
| H A D | InputPort.java | 43 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 …]
|
| H A D | OutputPort.java | 39 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()
|
| /aosp12/packages/modules/DnsResolver/ |
| H A D | LockedQueue.h | 35 mQueue.push_front(std::move(item)); in push()
41 mQueue.swap(other); in swap()
46 std::deque<T> mQueue GUARDED_BY(mLock);
56 mQueue.push_back(std::move(record)); in push()
57 if (mQueue.size() > mCapacity) { in push()
58 mQueue.pop_front(); in push()
64 return mQueue; in copy()
70 std::deque<T> mQueue GUARDED_BY(mLock);
|
| /aosp12/packages/apps/Camera2/src/com/android/camera/processing/ |
| H A D | ProcessingServiceManager.java | 52 private final LinkedList<ProcessingTask> mQueue = new LinkedList<ProcessingTask>(); field in ProcessingServiceManager
79 mQueue.add(task); in enqueueTask()
80 Log.d(TAG, "Task added. Queue size now: " + mQueue.size()); in enqueueTask()
96 if (!mQueue.isEmpty() && !mHoldProcessing) { in popNextSession()
97 Log.d(TAG, "Popping a session. Remaining: " + (mQueue.size() - 1)); in popNextSession()
98 return mQueue.remove(); in popNextSession()
111 return mServiceRunning || !mQueue.isEmpty(); in isRunningOrHasItems()
137 Log.d(TAG, "Resume processing. Queue size: " + mQueue.size()); in resumeProcessing()
140 if (!mQueue.isEmpty()) { in resumeProcessing()
|
| /aosp12/packages/apps/Car/LocalMediaPlayer/src/com/android/car/media/localmediaplayer/ |
| H A D | Player.java | 87 private List<QueueItem> mQueue; field in Player
201 if (mQueue == null || mQueue.isEmpty()) { in saveState()
209 for (QueueItem item : mQueue) { in saveState()
286 mQueue = queue; in maybeRebuildQueue()
328 mSession.setQueue(mQueue); in updateSessionQueueState()
380 if (mQueue == null) { in postMediaNotification()
463 if (mQueue != null && !mQueue.isEmpty()) { in advance()
480 if (mQueue != null) { in retreat()
552 if (mQueue != null && mQueue.size() > 2) { in shuffle()
555 mQueue.add(0, current); in shuffle()
[all …]
|
| /aosp12/packages/modules/StatsD/statsd/src/logd/ |
| H A D | LogEventQueue.cpp | 32 if (mQueue.empty()) { in waitPop()
33 mCondition.wait(lock, [this] { return !this->mQueue.empty(); }); in waitPop()
36 unique_ptr<LogEvent> item = std::move(mQueue.front()); in waitPop()
37 mQueue.pop(); in waitPop()
46 if (mQueue.size() < mQueueLimit) { in push()
47 mQueue.push(std::move(item)); in push()
51 *oldestTimestampNs = mQueue.front()->GetElapsedTimestampNs(); in push()
|
| /aosp12/frameworks/av/media/libmediaplayerservice/nuplayer/ |
| H A D | NuPlayerStreamListener.cpp | 61 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()
|
| /aosp12/frameworks/base/core/java/android/os/ |
| H A D | Handler.java | 230 mQueue = mLooper.mQueue; in Handler()
257 mQueue = looper.mQueue; in Handler()
613 mQueue.removeMessages(this, r, null); in removeCallbacks()
622 mQueue.removeMessages(this, r, token); in removeCallbacks()
720 MessageQueue queue = mQueue; in sendMessageAtTime()
743 MessageQueue queue = mQueue; in sendMessageAtFrontOfQueue()
786 mQueue.removeMessages(this, what, null); in removeMessages()
841 return mQueue.hasMessages(this); in hasMessagesOrCallbacks()
867 return mQueue.hasMessages(this, r, null); in hasCallbacks()
907 synchronized (mQueue) { in getIMessenger()
[all …]
|
| /aosp12/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
| H A D | MockExecutor.java | 29 private final LinkedList<Runnable> mQueue = new LinkedList<Runnable>(); field in MockExecutor
35 mQueue.addLast(task); in execute()
39 mQueue.clear(); in cancelPendingTasks()
48 return mQueue.size(); in countPendingTasks()
52 if (mQueue.isEmpty()) { in runNext()
55 Runnable command = mQueue.removeFirst(); in runNext()
|