| /frameworks/av/media/libstagefright/rtsp/ |
| AAVCAssembler.cpp | 48 List<sp<ABuffer> > *queue = source->queue(); local
50 if (queue->empty()) {
55 List<sp<ABuffer> >::iterator it = queue->begin();
56 while (it != queue->end()) {
61 it = queue->erase(it);
64 if (queue->empty()) {
69 sp<ABuffer> buffer = *queue->begin();
87 queue->erase(queue->begin())
[all...] |
| /frameworks/base/core/java/android/hardware/camera2/legacy/ |
| RequestHandlerThread.java | 28 * Ensure that the MessageQueue's idle handler gets run by poking the message queue;
29 * normally if the message queue is already idle, the idle handler won't get invoked.
99 MessageQueue queue = handler.getLooper().getQueue(); local
100 if (queue.isIdle()) {
104 queue.addIdleHandler(mIdleHandler);
107 if (queue.isIdle()) {
|
| /frameworks/base/libs/hwui/renderthread/ |
| RenderThread.h | 80 WorkQueue& queue() { return ThreadBase::queue(); } function in class:android::uirenderer::renderthread::RenderThread
|
| /frameworks/native/libs/gui/include/gui/ |
| BufferSlot.h | 127 inline void queue() { function in struct:android::BufferState
|
| /frameworks/native/libs/sensor/ |
| SensorManager.cpp | 229 sp<SensorEventQueue> queue; local
240 queue = new SensorEventQueue(connection);
243 return queue;
|
| /frameworks/native/services/sensorservice/hidl/ |
| SensorManager.cpp | 227 sp<IEventQueue> queue = new EventQueue(callback, looper, internalQueue); local
228 _hidl_cb(queue, Result::OK);
|
| /frameworks/support/samples/Support4Demos/src/main/java/com/example/android/supportv4/media/utils/ |
| QueueHelper.java | 34 * Utility class to help on queue related tasks.
47 Log.e(TAG, "Could not build a playing queue for this mediaId: " + mediaId);
53 Log.d(TAG, "Creating playing queue for " + categoryType + ", " + categoryValue);
74 Log.d(TAG, "Creating playing queue for musics from search " + query);
80 public static int getMusicIndexOnQueue(Iterable<MediaSessionCompat.QueueItem> queue,
83 for (MediaSessionCompat.QueueItem item : queue) {
92 public static int getMusicIndexOnQueue(Iterable<MediaSessionCompat.QueueItem> queue,
95 for (MediaSessionCompat.QueueItem item : queue) {
106 List<MediaSessionCompat.QueueItem> queue = new ArrayList<>(); local
110 // We create a hierarchy-aware mediaID, so we know what the queue is about by lookin
[all...] |
| /frameworks/support/work/workmanager/src/androidTest/java/androidx/work/impl/ |
| WorkManagerImplLargeExecutorTest.java | 104 BlockingQueue<Runnable> queue = new LinkedBlockingQueue<>(); local
106 MIN_POOL_SIZE, MAX_POOL_SIZE, KEEP_ALIVE_TIME, SECONDS, queue);
|
| /libcore/luni/src/main/java/java/lang/ref/ |
| FinalizerReference.java | 25 // This queue contains those objects eligible for finalization.
26 public static final ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); field in class:FinalizerReference
28 // Guards the list (not the queue).
56 FinalizerReference<?> reference = new FinalizerReference<Object>(referent, queue);
103 // and then put it on the queue so that it can be finalized.
113 // list. This is required instead of enqueuing directly on the finalizer queue
115 // yet on the finalizer queue. This could cause the sentinel to run before the
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| FileLockTable.java | 92 ReferenceQueue<FileLock> queue,
94 super(referent, queue);
109 // reference queue for cleared refs
110 private static ReferenceQueue<FileLock> queue = new ReferenceQueue<FileLock>(); field in class:SharedFileLockTable
137 list.add(new FileLockReference(fl, queue, fileKey));
153 list.add(new FileLockReference(fl, queue, fileKey));
161 // process any stale entries pending in the reference queue
240 list.set(index, new FileLockReference(toLock, queue, fileKey));
259 // Process the reference queue
262 while ((ref = (FileLockReference)queue.poll()) != null)
[all...] |
| /packages/apps/Launcher2/src/com/android/launcher2/ |
| DeferredHandler.java | 28 * Queue of things to run on a looper thread. Items posted with {@link #post} will not
77 /** Schedule runnable to run after everything that's on the queue right now. */
90 /** Schedule runnable to run when the queue goes idle. */
124 LinkedList<Pair<Runnable, Integer>> queue = new LinkedList<Pair<Runnable, Integer>>(); local
126 queue.addAll(mQueue);
129 for (Pair<Runnable, Integer> p : queue) {
|
| /packages/apps/Music/src/com/android/music/utils/ |
| QueueHelper.java | 36 * Utility class to help on queue related tasks.
47 LogHelper.e(TAG, "Could not build a playing queue for this mediaId: ", mediaId);
53 LogHelper.d(TAG, "Creating playing queue for ", categoryType, ", ", categoryValue);
82 LogHelper.d(TAG, "Creating playing queue for musics from search ", query);
87 public static int getMusicIndexOnQueue(Iterable<MediaSession.QueueItem> queue, String mediaId) {
89 for (MediaSession.QueueItem item : queue) {
98 public static int getMusicIndexOnQueue(Iterable<MediaSession.QueueItem> queue, long queueId) {
100 for (MediaSession.QueueItem item : queue) {
111 List<MediaSession.QueueItem> queue = new ArrayList<>(); local
114 // We create a hierarchy-aware mediaID, so we know what the queue is about by lookin
[all...] |
| /packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/ |
| SimpleSampleBuffer.java | 92 for (SampleQueue queue : mPlayingSampleQueues) {
93 if (queue == null) {
96 Long lastQueuedSamplePositionUs = queue.getLastQueuedPositionUs();
114 SampleQueue queue = mPlayingSampleQueues[track]; local
115 SoftPreconditions.checkNotNull(queue);
116 int result = queue == null ? SampleSource.NOTHING_READ : queue.dequeueSample(sampleHolder);
155 for (SampleQueue queue : mPlayingSampleQueues) {
156 if (queue == null) {
159 if (queue.getLastQueuedPositionUs() == nul
[all...] |
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.15-4.8/x86_64-linux/include/c++/4.8/bits/ |
| stl_queue.h | 0 // Queue implementation -*- C++ -*-
53 * Do not attempt to use it directly. @headername{queue}
81 * wrapper is what enforces strict first-in-first-out %queue behavior.
90 * @c pop, which are standard %queue/FIFO operations.
93 class queue class
104 operator==(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&);
108 operator<(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&);
134 queue(const _Sequence& __c = _Sequence() function in class:queue
138 queue(const _Sequence& __c) function in class:queue
142 queue(_Sequence&& __c = _Sequence()) function in class:queue
[all...] |
| /prebuilts/gcc/linux-x86/host/x86_64-w64-mingw32-4.8/x86_64-w64-mingw32/include/c++/4.8.3/bits/ |
| stl_queue.h | 0 // Queue implementation -*- C++ -*-
53 * Do not attempt to use it directly. @headername{queue}
81 * wrapper is what enforces strict first-in-first-out %queue behavior.
90 * @c pop, which are standard %queue/FIFO operations.
93 class queue class
104 operator==(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&);
108 operator<(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&);
134 queue(const _Sequence& __c = _Sequence() function in class:queue
138 queue(const _Sequence& __c) function in class:queue
142 queue(_Sequence&& __c = _Sequence()) function in class:queue
[all...] |
| /prebuilts/go/darwin-x86/src/runtime/ |
| sema.go | 143 root.queue(addr, s, lifo)
214 // queue adds s to the blocked goroutines in semaRoot.
215 func (root *semaRoot) queue(addr *uint32, s *sudog, lifo bool) { func
291 panic("semaRoot queue")
575 // Because g's queue separately from taking numbers,
|
| /prebuilts/go/linux-x86/src/runtime/ |
| sema.go | 143 root.queue(addr, s, lifo)
214 // queue adds s to the blocked goroutines in semaRoot.
215 func (root *semaRoot) queue(addr *uint32, s *sudog, lifo bool) { func
291 panic("semaRoot queue")
575 // Because g's queue separately from taking numbers,
|
| /prebuilts/jdk/jdk8/darwin-x86/sample/nio/chatserver/ |
| Client.java | 46 import java.util.Queue;
65 private final Queue<ByteBuffer> queue = new LinkedList<ByteBuffer>(); field in class:Client
83 synchronized(queue) {
84 queue.add(buffer);
100 synchronized (queue) {
101 buffer = queue.poll();
|
| /prebuilts/jdk/jdk8/linux-x86/sample/nio/chatserver/ |
| Client.java | 46 import java.util.Queue;
65 private final Queue<ByteBuffer> queue = new LinkedList<ByteBuffer>(); field in class:Client
83 synchronized(queue) {
84 queue.add(buffer);
100 synchronized (queue) {
101 buffer = queue.poll();
|
| /system/bt/btif/avrcp/ |
| avrcp_service.cc | 341 bool queue) {
345 << " queue=" << queue; local
352 track_changed, play_state, queue));
|
| /system/bt/osi/src/ |
| fixed_queue.cc | 68 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) {
69 if (!queue) return;
71 fixed_queue_unregister_dequeue(queue);
74 for (const list_node_t* node = list_begin(queue->list);
75 node != list_end(queue->list); node = list_next(node))
78 list_free(queue->list);
79 semaphore_free(queue->enqueue_sem);
80 semaphore_free(queue->dequeue_sem);
81 delete queue->mutex;
82 osi_free(queue);
260 fixed_queue_t* queue = static_cast<fixed_queue_t*>(context); local
[all...] |
| thread.cc | 131 // of queue space, we should abort this operation, otherwise we'll
134 // Queue item is freed either when the queue itself is destroyed
135 // or when the item is removed from the queue for dispatch.
239 LOG_DEBUG(LOG_TAG, "%s growing event queue on shutdown.", __func__);
249 fixed_queue_t* queue = (fixed_queue_t*)context; local
250 work_item_t* item = static_cast<work_item_t*>(fixed_queue_dequeue(queue));
|
| /system/extras/simpleperf/ |
| callchain.h | 25 #include <queue>
91 std::queue<std::vector<std::unique_ptr<NodeT>>*> queue; local
92 queue.push(&children);
93 while (!queue.empty()) {
94 std::vector<std::unique_ptr<NodeT>>* v = queue.front();
95 queue.pop();
99 queue.push(&node->children);
|
| /system/libfmq/tests/ |
| msgq_test_client.cpp | 119 * Utility function to verify data read from the fast message queue.
148 MessageQueueUnsync* queue = nullptr; local
149 getQueue(&queue, &testService, true /* setupQueue */);
152 ASSERT_NE(queue, nullptr);
153 ASSERT_TRUE(queue->isValid());
155 size_t numMessagesMax = queue->getQuantumCount();
168 ASSERT_FALSE(queue->read(&readData[0], numMessagesMax));
180 ASSERT_TRUE(queue->read(&readData[0], dataLen));
183 delete queue;
196 MessageQueueUnsync* queue = nullptr local
[all...] |
| /test/vti/dashboard/src/main/java/com/android/vts/job/ |
| VtsInactivityJobServlet.java | 36 import com.google.appengine.api.taskqueue.Queue;
126 Queue queue = QueueFactory.getDefaultQueue(); local
136 TaskQueueHelper.addToQueue(queue, tasks);
|
