| /external/v8/tools/clang/blink_gc_plugin/ |
| RecordInfo.cpp | 114 SmallVector<const CXXRecordDecl*, 8> queue; local
126 queue.push_back(base);
138 if (queue.empty())
140 base_record = queue.pop_back_val(); // not actually a queue.
|
| /frameworks/av/media/libstagefright/rtsp/ |
| AMPEG4AudioAssembler.cpp | 491 List<sp<ABuffer> > *queue = source->queue(); local
493 if (queue->empty()) {
498 List<sp<ABuffer> >::iterator it = queue->begin();
499 while (it != queue->end()) {
504 it = queue->erase(it);
507 if (queue->empty()) {
512 sp<ABuffer> buffer = *queue->begin();
535 queue->erase(queue->begin())
[all...] |
| /frameworks/base/core/java/android/os/ |
| Handler.java | 30 * queue. When you create a new Handler, it is bound to the thread /
31 * message queue of the thread that is creating it -- from that point on,
32 * it will deliver messages and runnables to that message queue and execute
33 * them as they come out of the message queue.
44 * you to enqueue Runnable objects to be called by the message queue when
51 * allow the item to be processed as soon as the message queue is ready
58 * running a message queue that takes care of managing the top-level
64 * in the Handler's message queue and processed when appropriate.
383 * Causes the Runnable r to be added to the message queue.
390 * message queue. Returns false on failure, usually because th
690 MessageQueue queue = mQueue; local
713 MessageQueue queue = mQueue; local
[all...] |
| /frameworks/base/services/backup/java/com/android/server/backup/internal/ |
| BackupHandler.java | 123 ArrayList<BackupRequest> queue = new ArrayList<>(); local
126 // Do we have any work to do? Construct the work queue
131 queue.add(b);
138 // Start a new backup-queue journal file too
150 if (queue.size() > 0) {
159 backupManagerService, transportClient, dirName, queue,
|
| /frameworks/support/samples/Support7Demos/src/main/java/com/example/android/supportv7/media/ |
| SessionManager.java | 30 * SessionManager manages a media session as a queue. It supports common
86 // If queue is empty, don't forget to call onPlaylistReady()!
361 List<PlaylistItem> queue = local
379 queue.add(item);
383 mPlaylist = queue;
415 String result = "Media Queue: ";
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ref/ |
| ReferenceTest.java | 124 ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); local
126 r = newWeakReference(queue);
128 Reference ref = queue.remove();
133 r = newWeakReference(queue);
136 // wait for the reference queue thread to enqueue the newly-finalized object
140 ref = queue.poll();
231 private WeakReference<Object> newWeakReference(ReferenceQueue<Object> queue) {
233 WeakReference<Object> ref = new WeakReference<Object>(o, queue);
|
| /libcore/ojluni/src/main/java/sun/security/util/ |
| Cache.java | 258 private final ReferenceQueue<V> queue; field in class:MemoryCache
268 this.queue = new ReferenceQueue<>();
270 this.queue = null;
277 * Empty the reference queue and remove all corresponding entries
284 if (queue == null) {
290 CacheEntry<K,V> entry = (CacheEntry<K,V>)queue.poll();
347 if (queue != null) {
353 while (queue.poll() != null) {
364 CacheEntry<K,V> newEntry = newEntry(key, value, expirationTime, queue);
460 long expirationTime, ReferenceQueue<V> queue) {
[all...] |
| /packages/apps/Bluetooth/tests/unit/src/com/android/bluetooth/hearingaid/ |
| HearingAidServiceTest.java | 155 LinkedBlockingQueue<Intent> queue = mDeviceQueueMap.get(device); local
156 Assert.assertNotNull(queue);
157 queue.put(intent);
159 Assert.fail("Cannot add Intent to the Connection State queue: "
[all...] |
| /packages/apps/Launcher3/quickstep/src/com/android/quickstep/ |
| MotionEventQueue.java | 109 public void queue(MotionEvent event) { method in class:MotionEventQueue
|
| /packages/apps/TV/tuner/src/com/android/tv/tuner/exoplayer/buffer/ |
| RecordingSampleBuffer.java | 203 private boolean maybeReadSample(SampleQueue queue, int index) {
204 if (queue.getLastQueuedPositionUs() != null
205 && queue.getLastQueuedPositionUs() > mCurrentPlaybackPositionUs + BUFFER_NEEDED_US
206 && queue.isDurationGreaterThan(MIN_SEEK_DURATION_US)) {
208 // If the duration of the samples in the queue is not limited,
216 queue.queueSample(sample);
274 SampleQueue queue = mReadSampleQueues.get(i); local
275 maybeReadSample(queue, i);
276 if (queue.getLastQueuedPositionUs() == null
277 || positionUs > queue.getLastQueuedPositionUs())
[all...] |
| /packages/services/Mms/src/com/android/mms/service/ |
| MmsService.java | 60 import java.util.Queue;
84 // The default number of threads allowed to run MMS requests in each queue
89 // requests will stay in this queue until that SIM finishes its current requests in
92 // blocked in the queue. And a later request for SIM1 will be appended to the queue, ordered
93 // after the request for SIM2, instead of being put into the running queue.
95 private final Queue<MmsRequest> mPendingSimRequestQueue = new ArrayDeque<>();
108 // Running request queues, one thread pool per queue
109 // 0: send queue
110 // 1: download queue
402 final int queue = request.getQueueType(); local
[all...] |
| /prebuilts/jdk/jdk8/darwin-x86/sample/jmx/jmx-scandir/test/com/sun/jmx/examples/scandir/ |
| ScanDirConfigTest.java | 219 final BlockingQueue<Notification> queue = local
224 queue.add(notification);
249 final Notification n = queue.poll(3,TimeUnit.SECONDS);
|
| ScanManagerTest.java | 176 final LinkedBlockingQueue<Notification> queue = local
183 queue.put(notification);
185 System.err.println("Failed to queue notif: "+x);
198 queue.poll(3000,TimeUnit.MILLISECONDS);
|
| /prebuilts/jdk/jdk8/linux-x86/sample/jmx/jmx-scandir/test/com/sun/jmx/examples/scandir/ |
| ScanDirConfigTest.java | 219 final BlockingQueue<Notification> queue = local
224 queue.add(notification);
249 final Notification n = queue.poll(3,TimeUnit.SECONDS);
|
| ScanManagerTest.java | 176 final LinkedBlockingQueue<Notification> queue = local
183 queue.put(notification);
185 System.err.println("Failed to queue notif: "+x);
198 queue.poll(3000,TimeUnit.MILLISECONDS);
|
| /prebuilts/ndk/r16/sources/third_party/vulkan/src/layers/ |
| core_validation.h | 172 VkQueue queue; member in class:QUEUE_NODE
|
| /system/bt/profile/avrcp/ |
| device.cc | 444 DEVICE_VLOG(0) << __func__ << ": Queue next play position update";
1093 << " : play_status= " << play_status << " : queue=" << queue; local
[all...] |
| /system/core/debuggerd/tombstoned/ |
| tombstoned.cpp | 100 static CrashQueue queue("/data/tombstones", "tombstone_" /* file_name_prefix */,
103 return &queue;
107 static CrashQueue queue("/data/anr", "trace_" /* file_name_prefix */,
110 return &queue;
389 CrashQueue* queue = CrashQueue::for_crash(crash); local
393 queue->maybe_dequeue_crashes(perform_request);
|
| /test/vti/dashboard/src/main/java/com/android/vts/job/ |
| VtsPerformanceJobServlet.java | 32 import com.google.appengine.api.taskqueue.Queue;
206 Queue queue = QueueFactory.getDefaultQueue(); local
219 TaskQueueHelper.addToQueue(queue, tasks);
|
| VtsProfilingStatsJobServlet.java | 37 import com.google.appengine.api.taskqueue.Queue;
68 public static final String QUEUE = "profilingStatsQueue";
90 Queue queue = QueueFactory.getQueue(QUEUE); local
99 TaskQueueHelper.addToQueue(queue, tasks);
|
| /art/dexlayout/ |
| dex_writer.cc | 664 void DexWriter::WriteMapItems(Stream* stream, MapItemQueue* queue) {
666 const uint32_t map_list_size = queue->size();
668 while (!queue->empty()) {
669 const MapItem& item = queue->top();
676 queue->pop();
682 MapItemQueue queue; local
685 queue.AddIfNotEmpty(MapItem(DexFile::kDexTypeHeaderItem, 1, 0));
686 queue.AddIfNotEmpty(MapItem(DexFile::kDexTypeStringIdItem,
689 queue.AddIfNotEmpty(MapItem(DexFile::kDexTypeTypeIdItem,
692 queue.AddIfNotEmpty(MapItem(DexFile::kDexTypeProtoIdItem
[all...] |
| /cts/hostsidetests/devicepolicy/app/ManagedProfile/src/com/android/cts/managedprofile/ |
| PhoneAccountTest.java | 165 final LinkedBlockingQueue<Intent> queue = new LinkedBlockingQueue<>(1); local
169 queue.offer(intent);
173 Intent intent = queue.poll(10, TimeUnit.SECONDS);
|
| /development/cmds/monkey/src/com/android/commands/monkey/ |
| MonkeySourceNetwork.java | 42 import java.util.Queue;
100 * @param queue the command queue.
103 MonkeyCommandReturn translateCommand(List<String> command, CommandQueue queue);
113 CommandQueue queue) {
117 queue.enqueueEvent(new MonkeyFlipEvent(true));
120 queue.enqueueEvent(new MonkeyFlipEvent(false));
137 CommandQueue queue) {
165 queue.enqueueEvent(new MonkeyTouchEvent(action)
181 CommandQueue queue) {
[all...] |
| /external/deqp/external/vulkancts/modules/vulkan/api/ |
| vktApiBufferTests.cpp | 181 TCU_THROW(NotSupportedError, "No matching queue found");
431 const VkQueue queue = getDeviceQueue(vk, vkDevice, queueFamilyIndex, 0); local
468 if (vk.queueBindSparse(queue, 1, &bindSparseInfo, *fence) != VK_SUCCESS)
|
| vktApiGetMemoryCommitment.cpp | 63 const VkQueue queue,
561 const VkQueue queue = m_context.getUniversalQueue(); local
562 submitCommandsAndWait(vkd, device, queue, *cmdBuffer);
649 void MemoryCommitmentTestInstance::submitCommandsAndWait (const DeviceInterface& vkd, const VkDevice device, const VkQueue queue, const VkCommandBuffer& cmdBuffer)
666 VK_CHECK(vkd.queueSubmit(queue, 1, &submitInfo, *fence));
|
