HomeSort by relevance Sort by last modified time
    Searched defs:mQueue (Results 1 - 25 of 97) sorted by null

1 2 3 4

  /system/chre/core/include/chre/core/
event_ref_queue.h 62 ArrayQueue<Event *, kMaxPendingEvents> mQueue;
  /packages/apps/Nfc/nci/jni/
DataQueue.h 103 Queue mQueue;
  /system/chre/util/include/chre/util/
fixed_size_blocking_queue.h 68 ArrayQueue<ElementType, kSize> mQueue;
  /system/libhidl/base/include/hidl/
TaskRunner.h 56 return (mQueue != nullptr) && (!!t) && this->mQueue->push(t);
60 std::shared_ptr<SynchronizedQueue<Task>> mQueue;
SynchronizedQueue.h 51 std::queue<T> mQueue;
64 return !this->mQueue.empty();
67 T item = mQueue.front();
68 mQueue.pop();
78 if (mQueue.size() < mQueueLimit) {
79 mQueue.push(item);
94 return mQueue.size();
  /frameworks/base/cmds/incidentd/src/
IncidentService.h 46 deque<sp<ReportRequest> > mQueue;
74 sp<ReportRequestQueue> mQueue;
107 sp<ReportRequestQueue> mQueue;
  /frameworks/hardware/interfaces/sensorservice/libsensorndkbridge/
ASensorEventQueue.h 70 std::vector<sensors_event_t> mQueue;
  /packages/apps/Gallery/src/com/android/camera/
ImageLoader.java 37 private final ArrayList<WorkItem> mQueue = new ArrayList<WorkItem>();
54 synchronized (mQueue) {
56 mQueue.add(w);
57 mQueue.notifyAll();
62 synchronized (mQueue) {
65 mQueue.remove(index);
73 // The caller should hold mQueue lock.
75 for (int i = 0; i < mQueue.size(); i++) {
76 if (mQueue.get(i).mImage == image) {
85 synchronized (mQueue) {
    [all...]
  /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/
MockExecutor.java 29 private final LinkedList<Runnable> mQueue = new LinkedList<Runnable>();
35 mQueue.addLast(task);
39 mQueue.clear();
48 return mQueue.size();
52 if (mQueue.isEmpty()) {
55 Runnable command = mQueue.removeFirst();
  /packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/keyboard/internal/
PointerTrackerQueueTests.java 66 private final PointerTrackerQueue mQueue = new PointerTrackerQueue();
69 assertEquals(0, mQueue.size());
70 assertEquals("[]", mQueue.toString());
74 mQueue.add(mElement1);
75 assertEquals(1, mQueue.size());
76 assertEquals("[1]", mQueue.toString());
77 mQueue.add(mElement2);
78 assertEquals(2, mQueue.size());
79 assertEquals("[1 2]", mQueue.toString());
80 mQueue.add(mElement3)
    [all...]
  /packages/apps/Launcher2/src/com/android/launcher2/
DeferredHandler.java 35 private LinkedList<Pair<Runnable, Integer>> mQueue = new LinkedList<Pair<Runnable, Integer>>();
43 synchronized (mQueue) {
44 if (mQueue.size() == 0) {
47 p = mQueue.removeFirst();
51 synchronized (mQueue) {
82 synchronized (mQueue) {
83 mQueue.add(new Pair<Runnable, Integer>(runnable, type));
84 if (mQueue.size() == 1) {
99 synchronized (mQueue) {
100 while (mQueue.remove(runnable)) {
    [all...]
  /frameworks/base/packages/PrintRecommendationService/src/com/android/printservice/recommendation/plugin/hp/
ServiceResolveQueue.java 29 private final LinkedList<Pair<NsdServiceInfo, ResolveCallback>> mQueue = new LinkedList<>();
64 if (mQueue.contains(newRequest)) return;
65 mQueue.add(newRequest);
73 mQueue.remove(newRequest);
81 if (mQueue.isEmpty()) return;
82 mCurrentRequest = mQueue.removeFirst();
88 if (mCurrentRequest != null) mQueue.add(mCurrentRequest);
  /packages/apps/Launcher3/src/com/android/launcher3/
DeferredHandler.java 36 @Thunk LinkedList<Runnable> mQueue = new LinkedList<>();
43 synchronized (mQueue) {
44 if (mQueue.size() == 0) {
47 r = mQueue.removeFirst();
50 synchronized (mQueue) {
78 synchronized (mQueue) {
79 mQueue.add(runnable);
80 if (mQueue.size() == 1) {
92 synchronized (mQueue) {
93 mQueue.clear()
    [all...]
  /packages/apps/TV/src/com/android/tv/tuner/exoplayer/buffer/
SampleQueue.java 28 private final LinkedList<SampleHolder> mQueue = new LinkedList<>();
37 mQueue.offer(sample);
42 SampleHolder sampleFromQueue = mQueue.poll();
57 while (!mQueue.isEmpty()) {
58 mSamplePool.releaseSample(mQueue.poll());
68 return !mQueue.isEmpty() && mQueue.getLast().timeUs - mQueue.getFirst().timeUs > durationUs;
72 return mQueue.isEmpty();
  /frameworks/av/media/libstagefright/rtsp/
ARTPSource.h 44 List<sp<ABuffer> > *queue() { return &mQueue; }
54 List<sp<ABuffer> > mQueue;
  /frameworks/rs/rsov/driver/
rsovContext.h 34 VkQueue getQueue() const { return mQueue; }
52 VkQueue mQueue;
  /frameworks/support/v7/recyclerview/tests/src/android/support/v7/util/
MessageQueueTest.java 34 MessageThreadUtil.MessageQueue mQueue;
38 mQueue = new MessageThreadUtil.MessageQueue();
44 mQueue.sendMessage(MessageThreadUtil.SyncQueueItem.obtainMessage(
47 MessageThreadUtil.SyncQueueItem msg = mQueue.next();
59 mQueue.sendMessage(obtainMessage(1, 2));
60 mQueue.sendMessage(obtainMessage(3, 4));
61 mQueue.sendMessage(obtainMessage(5, 6));
63 MessageThreadUtil.SyncQueueItem msg = mQueue.next();
67 msg = mQueue.next();
71 msg = mQueue.next()
    [all...]
  /packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ringbuffer/
DynamicRingBuffer.java 62 private final CountableBufferQueue<ImageProxy> mQueue;
75 mQueue = new CountableBufferQueue<>(mQueueSize, new ImageCloser());
90 // mQueue. However, for a brief moment, we acquire a ticket from
91 // mTicketPool, but have yet added it to mQueue. During this period,
103 mQueue.discardNext();
107 mQueue.update(new TicketImageProxy(image, ticket));
127 mQueue.close();
132 return mQueue.getNext();
138 return mQueue.getNext(timeout, unit);
143 return mQueue.peekNext()
    [all...]
  /frameworks/base/core/java/android/speech/tts/
AudioPlaybackHandler.java 27 private final LinkedBlockingQueue<PlaybackQueueItem> mQueue =
51 mQueue.put(item);
80 return (mQueue.peek() != null) || (mCurrentWorkItem != null);
96 mQueue.clear();
103 Iterator<PlaybackQueueItem> it = mQueue.iterator();
123 item = mQueue.take();
129 // If stop() or stopForApp() are called between mQueue.take()
  /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/src/androidx/media/filterfw/
OutputPort.java 39 private FrameQueue mQueue = null;
56 return mQueue == null || mQueue.canPush();
165 return mQueue;
169 mQueue = queue;
180 return mQueue != null;
188 if (mQueue != null) {
189 mQueue.clear();
  /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/
SingleThreadNamedTaskExecutor.java 32 private final LinkedBlockingQueue<NamedTask> mQueue;
37 mQueue = new LinkedBlockingQueue<NamedTask>();
43 if (DBG) Log.d(TAG, "Cancelling " + mQueue.size() + " tasks: " + mWorker.getName());
47 mQueue.clear();
53 mQueue.clear();
60 mQueue.add(task);
78 task = mQueue.take();
  /frameworks/av/media/libmediaplayerservice/nuplayer/
NuPlayerStreamListener.h 65 List<QueueEntry> mQueue;
  /frameworks/native/include/ui/
FenceTime.h 167 std::queue<std::weak_ptr<FenceTime>> mQueue;
  /frameworks/native/services/sensorservice/hidl/
EventQueue.cpp 32 : mQueue(queue), mCallback(callback) {
40 auto internalQueue = mQueue.promote();
55 wp<::android::SensorEventQueue> mQueue;
  /frameworks/native/services/surfaceflinger/
MessageQueue.h 70 MessageQueue& mQueue;
73 explicit Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { }

Completed in 637 milliseconds

1 2 3 4