HomeSort by relevance Sort by last modified time
    Searched refs:mQueue (Results 51 - 75 of 136) sorted by null

1 23 4 5 6

  /frameworks/base/services/core/jni/BroadcastRadio/
NativeCallbackThread.h 32 std::queue<Task> mQueue;
  /frameworks/native/services/surfaceflinger/
MessageQueue.cpp 57 mQueue.mLooper->sendMessage(this, Message(MessageQueue::REFRESH));
63 mQueue.mLooper->sendMessage(this, Message(MessageQueue::INVALIDATE));
71 mQueue.mFlinger->onMessageReceived(message.what);
75 mQueue.mFlinger->onMessageReceived(message.what);
MessageQueue.h 102 MessageQueue& mQueue;
106 explicit Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) {}
  /packages/apps/Gallery/src/com/android/camera/gallery/
ImageListUber.java 39 private final PriorityQueue<MergeSlot> mQueue;
55 mQueue = new PriorityQueue<MergeSlot>(4,
63 mQueue.clear();
67 if (slot.next()) mQueue.add(slot);
136 if (slot.next()) mQueue.add(slot);
139 if (slot.next()) mQueue.add(slot);
144 MergeSlot slot = mQueue.poll();
234 if (slot.next()) mQueue.add(slot);
237 if (slot.next()) mQueue.add(slot);
  /frameworks/av/media/libstagefright/rtsp/
ARTPSource.h 44 List<sp<ABuffer> > *queue() { return &mQueue; }
57 List<sp<ABuffer> > mQueue;
ARTPSource.cpp 114 mQueue.push_back(buffer);
158 List<sp<ABuffer> >::iterator it = mQueue.begin();
159 while (it != mQueue.end() && (uint32_t)(*it)->int32Data() < seqNum) {
163 if (it != mQueue.end() && (uint32_t)(*it)->int32Data() == seqNum) {
168 mQueue.insert(it, buffer);
  /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/
FrameManager.java 161 private PriorityQueue<Backing> mQueue;
164 mQueue = new PriorityQueue<Backing>(4, new Comparator<Backing>() {
174 for (Backing backing : mQueue) {
181 mQueue.remove(backing);
195 mQueue.add(backing);
203 mQueue.clear();
224 Backing dropped = mQueue.poll();
  /frameworks/base/cmds/incidentd/src/
IncidentService.cpp 105 mQueue.push_back(request);
110 if (mQueue.empty()) {
113 sp<ReportRequest> front(mQueue.front());
114 mQueue.pop_front();
124 mQueue(queue),
141 mQueue->addRequest(request);
163 sp<ReportRequest> request = mQueue->getNextRequest();
202 : mQueue(new ReportRequestQueue()),
204 mHandler = new ReportHandler(handlerLooper, mQueue, mThrottler);
  /art/test/079-phantom/src/
Bitmap.java 136 ReferenceQueue<PhantomWrapper> mQueue;
139 mQueue = queue;
146 PhantomWrapper ref = (PhantomWrapper) mQueue.remove();
  /cts/tests/inputmethod/src/android/view/inputmethod/cts/util/
WindowFocusStealer.java 41 final BlockingQueue<Integer> mQueue = new ArrayBlockingQueue<>(1);
49 mQueue.add(resultCode);
55 result = mQueue.poll(timeout, TimeUnit.MILLISECONDS);
  /external/volley/src/main/java/com/android/volley/
NetworkDispatcher.java 38 private final BlockingQueue<Request<?>> mQueue;
59 mQueue = queue;
104 Request<?> request = mQueue.take();
  /frameworks/base/services/core/java/com/android/server/pm/
ParallelPackageParser.java 52 private final BlockingQueue<ParseResult> mQueue = new ArrayBlockingQueue<>(QUEUE_CAPACITY);
92 return mQueue.take();
124 mQueue.put(pr);
  /frameworks/layoutlib/bridge/src/android/animation/
AnimationThread.java 69 private Queue<MessageBundle> mQueue = new PriorityQueue<MessageBundle>();
95 mQueue.add(new MessageBundle(handler, msg, uptimeMillis));
118 MessageBundle bundle = mQueue.poll();
147 // the next message, so mQueue will have another one.
161 } while (mListener.isCanceled() == false && mQueue.size() > 0);
  /frameworks/native/libs/gui/
BufferQueueConsumer.cpp 84 if (mCore->mQueue.empty() && !sharedBufferAvailable) {
88 BufferQueueCore::Fifo::iterator front(mCore->mQueue.begin());
95 if (expectedPresent != 0 && !mCore->mQueue.empty()) {
116 while (mCore->mQueue.size() > 1 && !mCore->mQueue[0].mIsAutoTimestamp) {
117 const BufferItem& bufferItem(mCore->mQueue[1]);
150 desiredPresent, expectedPresent, mCore->mQueue.size());
174 mCore->mQueue.erase(front);
175 front = mCore->mQueue.begin();
203 if (sharedBufferAvailable && mCore->mQueue.empty())
    [all...]
BufferHubConsumer.cpp 26 consumer->mQueue = queue;
37 consumer->mQueue = ConsumerQueue::Import(parcelable.TakeChannelHandle());
  /frameworks/av/media/libmediaplayerservice/nuplayer/
NuPlayerStreamListener.h 65 List<QueueEntry> mQueue;
  /frameworks/base/services/backup/java/com/android/server/backup/internal/
PerformInitializeTask.java 54 private final String[] mQueue;
83 mQueue = transportNames;
112 List<TransportClient> transportClientsToDisposeOf = new ArrayList<>(mQueue.length);
115 for (String transportName : mQueue) {
  /frameworks/base/services/net/java/android/net/util/
PacketReader.java 77 private final MessageQueue mQueue;
92 mQueue = mHandler.getLooper().getQueue();
180 mQueue.addOnFileDescriptorEventListener(
242 mQueue.removeOnFileDescriptorEventListener(mFd);
  /cts/tests/tests/graphics/jni/
VulkanPreTransformTestHelpers.h 41 VkQueue queue() const { return mQueue; }
50 VkQueue mQueue;
VulkanTestHelpers.h 36 VkQueue queue() { return mQueue; }
51 VkQueue mQueue = VK_NULL_HANDLE;
  /frameworks/native/libs/ui/
FenceTime.cpp 276 while (mQueue.size() >= MAX_ENTRIES) {
282 std::shared_ptr<FenceTime> front = mQueue.front().lock();
288 mQueue.pop();
290 mQueue.push(fence);
294 while (!mQueue.empty()) {
296 std::shared_ptr<FenceTime> fence = mQueue.front().lock();
300 mQueue.pop();
304 mQueue.pop();
  /frameworks/base/tests/OneMedia/src/com/android/onemedia/
PlayerSession.java 48 protected ArrayList<MediaSession.QueueItem> mQueue;
64 mQueue = new ArrayList<MediaSession.QueueItem>();
121 mQueue.clear();
122 mQueue.add(new QueueItem(mMetadataBuilder.build().getDescription(), 11));
132 mSession.setQueue(mUseQueue ? mQueue : null);
155 mQueue.add(new QueueItem(mMetadataBuilder.build().getDescription(), 11));
  /packages/apps/Calendar/src/com/android/calendar/
EventLoader.java 161 LinkedBlockingQueue<LoadRequest> mQueue;
165 mQueue = queue;
171 mQueue.put(new ShutdownRequest());
186 LoadRequest request = mQueue.take();
190 while (!mQueue.isEmpty()) {
195 request = mQueue.take();
  /frameworks/support/media/src/main/java/androidx/media/
MediaPlayer2Impl.java     [all...]
  /frameworks/support/asynclayoutinflater/src/main/java/androidx/asynclayoutinflater/view/
AsyncLayoutInflater.java 171 private ArrayBlockingQueue<InflateRequest> mQueue = new ArrayBlockingQueue<>(10);
180 request = mQueue.take();
225 mQueue.put(request);

Completed in 898 milliseconds

1 23 4 5 6