/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);
|