| /frameworks/native/services/inputflinger/ |
| D | BlockingQueue.h | 38 mQueue.reserve(mCapacity); in BlockingQueue()
50 return !this->mQueue.empty(); in pop()
52 T t = std::move(mQueue.front()); in pop()
53 mQueue.erase(mQueue.begin()); in pop()
66 if (mQueue.size() == mCapacity) { in push()
69 mQueue.push_back(std::move(t)); in push()
77 mQueue.erase(std::remove_if(mQueue.begin(), mQueue.end(), in erase()
78 [&lambda](const T& t) { return lambda(t); }), mQueue.end()); in erase()
87 mQueue.clear(); in clear()
97 return mQueue.size(); in size()
[all …]
|
| /frameworks/base/packages/SystemUI/legacy/recents/src/com/android/systemui/recents/model/ |
| D | TaskResourceLoadQueue.java | 27 private final ConcurrentLinkedQueue<Task> mQueue = new ConcurrentLinkedQueue<>(); field in TaskResourceLoadQueue
31 if (!mQueue.contains(t)) { in addTask()
32 mQueue.add(t); in addTask()
44 return mQueue.poll(); in nextTask()
49 mQueue.remove(t); in removeTask()
54 mQueue.clear(); in clearTasks()
59 return mQueue.isEmpty(); in isEmpty()
|
| /frameworks/base/cmds/statsd/src/logd/ |
| 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()
|
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/ |
| 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 …]
|
| 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()
|
| D | FrameManager.java | 161 private PriorityQueue<Backing> mQueue; field in FrameManager.PriorityBackingCache
164 mQueue = new PriorityQueue<Backing>(4, new Comparator<Backing>() { in PriorityBackingCache()
174 for (Backing backing : mQueue) { in fetchBacking()
181 mQueue.remove(backing); in fetchBacking()
195 mQueue.add(backing); in cacheBacking()
203 mQueue.clear(); in clear()
224 Backing dropped = mQueue.poll(); in reserve()
|
| /frameworks/av/media/libmediaplayerservice/nuplayer/ |
| D | NuPlayerStreamListener.cpp | 63 mQueue.push_back(entry); in queueBuffer()
84 mQueue.push_back(entry); in issueCommand()
107 if (mQueue.empty()) { in read()
113 QueueEntry *entry = &*mQueue.begin(); in read()
119 mQueue.erase(mQueue.begin()); in read()
130 mQueue.erase(mQueue.begin()); in read()
166 mQueue.erase(mQueue.begin()); in read()
|
| /frameworks/base/services/core/jni/BroadcastRadio/ |
| D | NativeCallbackThread.cpp | 57 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/hardware/interfaces/sensorservice/libsensorndkbridge/ |
| D | ASensorEventQueue.cpp | 94 size_t copy = std::min(count, mQueue.size()); in getEvents()
96 reinterpret_cast<sensors_event_t *>(events)[i] = mQueue[i]; in getEvents()
98 mQueue.erase(mQueue.begin(), mQueue.begin() + copy); in getEvents()
106 return !mQueue.empty(); in hasEvents()
128 mQueue.emplace_back(); in onEvent()
129 sensors_event_t* sensorEvent = &mQueue[mQueue.size() - 1]; in onEvent()
|
| /frameworks/base/core/java/android/os/ |
| D | Handler.java | 230 mQueue = mLooper.mQueue; in Handler()
257 mQueue = looper.mQueue; in Handler()
609 mQueue.removeMessages(this, r, null); in removeCallbacks()
618 mQueue.removeMessages(this, r, token); in removeCallbacks()
716 MessageQueue queue = mQueue; in sendMessageAtTime()
739 MessageQueue queue = mQueue; in sendMessageAtFrontOfQueue()
782 mQueue.removeMessages(this, what, null); in removeMessages()
791 mQueue.removeMessages(this, what, object); in removeMessages()
802 mQueue.removeEqualMessages(this, what, object); in removeEqualMessages()
811 mQueue.removeCallbacksAndMessages(this, token); in removeCallbacksAndMessages()
[all …]
|
| D | Looper.java | 78 final MessageQueue mQueue; field in Looper
158 final MessageQueue queue = me.mQueue; in loop()
296 return myLooper().mQueue; in myQueue()
300 mQueue = new MessageQueue(quitAllowed); in Looper()
356 mQueue.quit(false); in quit()
372 mQueue.quit(true); in quitSafely()
390 return mQueue; in getQueue()
401 mQueue.dump(pw, prefix + " ", null); in dump()
414 mQueue.dump(pw, prefix + " ", handler); in dump()
422 if (mQueue != null) { in writeToProto()
[all …]
|
| D | TestLooperManager.java | 35 private final MessageQueue mQueue; field in TestLooperManager
53 mQueue = mLooper.getQueue(); in TestLooperManager()
63 return mQueue; in getMessageQueue()
91 return mQueue.next(); in next()
156 return mQueue.hasMessages(h, what, object); in hasMessages()
168 return mQueue.hasMessages(h, r, object); in hasMessages()
|
| /frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/hp/ |
| D | ServiceResolveQueue.java | 29 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/ |
| D | BenchmarkCommon.h | 52 needsNotify = mQueue.empty(); in push()
53 mQueue.push(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/speech/tts/ |
| D | AudioPlaybackHandler.java | 27 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/thread/ |
| D | ThreadBase.h | 37 , 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/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/xerox/ |
| D | ServiceResolver.java | 105 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/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/policy/ |
| D | BlockingQueueIntentReceiver.java | 27 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/native/libs/renderengine/gl/ |
| D | ImageManager.cpp | 92 mQueue.emplace(entry); in queueOperation()
93 ATRACE_INT("ImageManagerQueueDepth", mQueue.size()); in queueOperation()
110 [&]() REQUIRES(mMutex) { return !mQueue.empty() || !mRunning; }); in threadMain()
119 entry = mQueue.front(); in threadMain()
120 mQueue.pop(); in threadMain()
121 ATRACE_INT("ImageManagerQueueDepth", mQueue.size()); in threadMain()
|
| /frameworks/native/libs/sensor/tests/ |
| D | SensorEventQueue_test.cpp | 37 mQueue = manager.createEventQueue(); in SetUp()
41 mQueue->requestAdditionalInfo = enable; in configureAdditionalInfo()
52 ssize_t filteredCount = mQueue->filterEvents(events, types.size()); in filterEvents()
68 if (events[i] != SENSOR_TYPE_ADDITIONAL_INFO || mQueue->requestAdditionalInfo) { in getExpectedEvents()
83 sp<SensorEventQueue> mQueue; member in android::SensorEventQueueTest
|
| /frameworks/native/libs/gui/ |
| D | BufferQueueConsumer.cpp | 85 if (mCore->mQueue.empty() && !sharedBufferAvailable) { in acquireBuffer()
89 BufferQueueCore::Fifo::iterator front(mCore->mQueue.begin()); in acquireBuffer()
96 if (expectedPresent != 0 && !mCore->mQueue.empty()) { in acquireBuffer()
115 while (mCore->mQueue.size() > 1 && !mCore->mQueue[0].mIsAutoTimestamp) { in acquireBuffer()
116 const BufferItem& bufferItem(mCore->mQueue[1]); in acquireBuffer()
149 desiredPresent, expectedPresent, mCore->mQueue.size()); in acquireBuffer()
175 mCore->mQueue.erase(front); in acquireBuffer()
176 front = mCore->mQueue.begin(); in acquireBuffer()
205 if (sharedBufferAvailable && mCore->mQueue.empty()) { in acquireBuffer()
248 if (mCore->mQueue.empty()) { in acquireBuffer()
[all …]
|
| /frameworks/base/tests/ActivityManagerPerfTests/tests/src/com/android/frameworks/perftests/am/util/ |
| D | TimeReceiver.java | 36 private BlockingQueue<ReceivedMessage> mQueue = new LinkedBlockingQueue<>(); field in TimeReceiver
56 mQueue.add(new ReceivedMessage(type, timeNs)); in addTimeForTypeToQueue()
88 message = mQueue.poll(endTimeNs - curTimeNs, TimeUnit.NANOSECONDS); in getReceivedTimeNs()
108 mQueue.clear(); in clear()
|
| /frameworks/native/libs/ui/ |
| D | FenceTime.cpp | 264 while (mQueue.size() >= MAX_ENTRIES) { in push()
270 std::shared_ptr<FenceTime> front = mQueue.front().lock(); in push()
276 mQueue.pop(); in push()
278 mQueue.push(fence); in push()
283 while (!mQueue.empty()) { in updateSignalTimes()
284 std::shared_ptr<FenceTime> fence = mQueue.front().lock(); in updateSignalTimes()
288 mQueue.pop(); in updateSignalTimes()
292 mQueue.pop(); in updateSignalTimes()
|
| /frameworks/native/services/surfaceflinger/Scheduler/ |
| D | MessageQueue.cpp | 57 mQueue.mLooper->sendMessage(this, Message(MessageQueue::REFRESH)); in dispatchRefresh()
63 mQueue.mLooper->sendMessage(this, Message(MessageQueue::INVALIDATE)); in dispatchInvalidate()
71 mQueue.mFlinger->onMessageReceived(message.what); in handleMessage()
75 mQueue.mFlinger->onMessageReceived(message.what); in handleMessage()
|
| /frameworks/base/services/robotests/src/com/android/server/testing/shadows/ |
| D | ShadowKeyValueBackupTask.java | 52 private List<String> mQueue; field in ShadowKeyValueBackupTask
68 mQueue = queue; in __constructor__()
79 return mQueue; in getQueue()
|