/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) { }
|