| /external/smack/src/org/jivesoftware/smack/ |
| PacketWriter.java | 46 private final BlockingQueue<Packet> queue; field in class:PacketWriter
55 this.queue = new ArrayBlockingQueue<Packet>(500, true);
89 queue.put(packet);
95 synchronized (queue) {
96 queue.notifyAll();
124 synchronized (queue) {
125 queue.notifyAll();
141 * Returns the next available packet from the queue for writing.
148 while (!done && (packet = queue.poll()) == null) {
150 synchronized (queue) {
[all...] |
| /frameworks/av/media/libstagefright/rtsp/ |
| AMPEG2TSAssembler.cpp | 55 List<sp<ABuffer> > *queue = source->queue(); local
57 if (queue->empty()) {
62 List<sp<ABuffer> >::iterator it = queue->begin();
63 while (it != queue->end()) {
68 it = queue->erase(it);
71 if (queue->empty()) {
76 sp<ABuffer> buffer = *queue->begin();
90 queue->erase(queue->begin())
[all...] |
| ARTPSource.h | 44 List<sp<ABuffer> > *queue() { return &mQueue; } function in struct:android::ARTPSource
|
| ARawAudioAssembler.cpp | 55 List<sp<ABuffer> > *queue = source->queue(); local
57 if (queue->empty()) {
62 List<sp<ABuffer> >::iterator it = queue->begin();
63 while (it != queue->end()) {
68 it = queue->erase(it);
71 if (queue->empty()) {
76 sp<ABuffer> buffer = *queue->begin();
90 queue->erase(queue->begin())
[all...] |
| /frameworks/base/test-runner/src/android/test/ |
| LoaderTestCase.java | 56 // The test thread blocks on this queue until the loader puts it's result in
57 final ArrayBlockingQueue<T> queue = new ArrayBlockingQueue<T>(1); local
60 // when it puts the result into the blocking queue
70 queue.add(data);
88 // Block on the queue waiting for the result of the load to be inserted
92 result = queue.take();
|
| /hardware/samsung_slsi/exynos5/exynos_omx/openmax/exynos_omx/osal/ |
| Exynos_OSAL_Queue.c | 42 EXYNOS_QUEUE *queue = (EXYNOS_QUEUE *)queueHandle; local
46 if (!queue)
49 ret = Exynos_OSAL_MutexCreate(&queue->qMutex);
53 queue->first = (EXYNOS_QElem *)Exynos_OSAL_Malloc(sizeof(EXYNOS_QElem));
54 if (queue->first == NULL)
57 Exynos_OSAL_Memset(queue->first, 0, sizeof(EXYNOS_QElem));
58 currentqelem = queue->last = queue->first;
59 queue->numElem = 0;
60 queue->maxNumElem = maxNumElem
86 EXYNOS_QUEUE *queue = (EXYNOS_QUEUE *)queueHandle; local
110 EXYNOS_QUEUE *queue = (EXYNOS_QUEUE *)queueHandle; local
131 EXYNOS_QUEUE *queue = (EXYNOS_QUEUE *)queueHandle; local
153 EXYNOS_QUEUE *queue = (EXYNOS_QUEUE *)queueHandle; local
165 EXYNOS_QUEUE *queue = (EXYNOS_QUEUE *)queueHandle; local
177 EXYNOS_QUEUE *queue = (EXYNOS_QUEUE *)queueHandle; local
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/ |
| sched.py | 3 Each instance of this class manages its own queue.
13 function is allowed to modify the queue. Time can be expressed as
18 way the queue can be maintained as a priority queue. Execution of the
47 """Enter a new event in the queue at an absolute time.
67 """Remove an event from the queue.
70 If the event is not in the queue, this raises ValueError.
77 """Check whether the queue is empty."""
81 """Execute events until the queue is empty.
84 delay function is called and the event is left in the queue;
123 def queue(self): member in class:scheduler
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/ |
| sched.py | 3 Each instance of this class manages its own queue.
13 function is allowed to modify the queue. Time can be expressed as
18 way the queue can be maintained as a priority queue. Execution of the
47 """Enter a new event in the queue at an absolute time.
67 """Remove an event from the queue.
70 If the event is not in the queue, this raises ValueError.
77 """Check whether the queue is empty."""
81 """Execute events until the queue is empty.
84 delay function is called and the event is left in the queue;
123 def queue(self): member in class:scheduler
[all...] |
| /external/glide/library/src/main/java/com/bumptech/glide/ |
| ListPreloader.java | 12 import java.util.Queue;
144 private final Queue<PreloadTarget> queue; field in class:ListPreloader.PreloadTargetQueue
149 queue = new ArrayDeque<PreloadTarget>(size);
151 queue = new LinkedList<PreloadTarget>();
155 queue.offer(new PreloadTarget());
160 final PreloadTarget result = queue.poll();
161 queue.offer(result);
|
| /external/guava/guava/src/com/google/common/base/internal/ |
| Finalizer.java | 84 return finalizer.queue;
89 private final ReferenceQueue<Object> queue = new ReferenceQueue<Object>(); field in class:Finalizer
102 this.frqReference = new PhantomReference<Object>(frq, queue);
119 * Loops continuously, pulling references off the queue and cleaning them up.
127 cleanUp(queue.remove());
163 } while ((reference = queue.poll()) != null);
|
| /external/okhttp/samples/crawler/src/main/java/com/squareup/okhttp/sample/ |
| Crawler.java | 47 private final LinkedBlockingQueue<URL> queue = new LinkedBlockingQueue<URL>(); field in class:Crawler
70 for (URL url; (url = queue.take()) != null; ) {
107 if (link != null) queue.add(link);
138 crawler.queue.add(new URL(args[1]));
|
| /libcore/luni/src/test/java/libcore/java/util/ |
| OldPriorityQueueTest.java | 28 PriorityQueue<Object> queue = new PriorityQueue<Object>(100); local
29 assertNotNull(queue);
30 assertEquals(0, queue.size());
31 assertNull(queue.comparator());
42 PriorityQueue<String> queue = new PriorityQueue<String>(10, local
46 queue.offer(array[i]);
48 assertFalse(queue.contains("BB"));
51 assertFalse(queue.remove("BB"));
52 assertTrue(queue.remove("AA"));
|
| /external/chromium_org/chrome/browser/printing/ |
| print_job_manager.cc | 78 scoped_refptr<PrintQueriesQueue> PrintJobManager::queue() { function in class:printing::PrintJobManager
|
| /external/chromium_org/chrome/browser/ui/ |
| browser_tabrestore_browsertest.cc | 85 content::DOMMessageQueue queue; local
90 AwaitTabsReady(&queue, 2);
133 content::DOMMessageQueue queue; local
136 AwaitTabsReady(&queue, 2);
|
| /external/chromium_org/components/keyed_service/core/ |
| dependency_graph.cc | 66 std::deque<DependencyNode*> queue; local
67 std::copy(all_nodes_.begin(), all_nodes_.end(), std::back_inserter(queue));
69 std::deque<DependencyNode*>::iterator queue_end = queue.end();
71 queue_end = std::remove(queue.begin(), queue_end, it->second);
73 queue.erase(queue_end, queue.end());
78 while (!queue.empty()) {
79 DependencyNode* node = queue.front();
80 queue.pop_front();
101 queue.push_back(dest)
[all...] |
| /external/chromium_org/net/spdy/ |
| spdy_write_queue.cc | 87 // |stream| should not have pending writes in a queue not matching
99 // Defer deletion until queue iteration is complete, as
104 std::deque<PendingWrite>* queue = &queue_[priority]; local
105 std::deque<PendingWrite>::iterator out_it = queue->begin();
106 for (std::deque<PendingWrite>::const_iterator it = queue->begin();
107 it != queue->end(); ++it) {
115 queue->erase(out_it, queue->end());
128 std::deque<PendingWrite>* queue = &queue_[i]; local
129 std::deque<PendingWrite>::iterator out_it = queue->begin()
[all...] |
| /external/chromium_org/third_party/mesa/src/src/gallium/state_trackers/clover/core/ |
| event.cpp | 86 pipe_screen *screen = queue()->dev.pipe;
92 pipe_screen *screen = queue()->dev.pipe;
108 hard_event::queue() const { function in class:hard_event
119 pipe_screen *screen = queue()->dev.pipe;
122 queue()->flush();
131 pipe_screen *screen = queue()->dev.pipe;
159 soft_event::queue() const { function in class:soft_event
|
| /external/fio/engines/ |
| fusion-aw.c | 37 static int queue(struct thread_data *td, struct io_u *io_u) function
168 .queue = queue,
|
| /external/guava/guava/src/com/google/common/collect/ |
| Queues.java | 23 import java.util.Queue;
34 * Static utility methods pertaining to {@link Queue}
72 * @param elements the elements that the queue should contain, in order
80 ConcurrentLinkedQueue<E> queue = new ConcurrentLinkedQueue<E>(); local
81 Iterables.addAll(queue, elements);
82 return queue;
101 * @param capacity the capacity of this queue
112 * @param elements the elements that the queue should contain, in order
119 LinkedBlockingQueue<E> queue = new LinkedBlockingQueue<E>(); local
120 Iterables.addAll(queue, elements)
148 PriorityBlockingQueue<E> queue = new PriorityBlockingQueue<E>(); local
174 PriorityQueue<E> queue = new PriorityQueue<E>(); local
[all...] |
| /external/mesa3d/src/gallium/state_trackers/clover/core/ |
| event.cpp | 86 pipe_screen *screen = queue()->dev.pipe;
92 pipe_screen *screen = queue()->dev.pipe;
108 hard_event::queue() const { function in class:hard_event
119 pipe_screen *screen = queue()->dev.pipe;
122 queue()->flush();
131 pipe_screen *screen = queue()->dev.pipe;
159 soft_event::queue() const { function in class:soft_event
|
| /frameworks/native/libs/gui/ |
| SensorManager.cpp | 143 sp<SensorEventQueue> queue; local
154 queue = new SensorEventQueue(connection);
157 return queue;
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/ |
| Engine.java | 83 MessageQueue queue = Looper.myQueue(); local
84 queue.addIdleHandler(new RefQueueIdleHandler(activeResources, resourceReferenceQueue));
153 runner.queue();
214 private ReferenceQueue<Resource> queue; field in class:Engine.RefQueueIdleHandler
216 public RefQueueIdleHandler(Map<Key, WeakReference<Resource>> activeResources, ReferenceQueue<Resource> queue) {
218 this.queue = queue;
223 ResourceWeakReference ref = (ResourceWeakReference) queue.poll();
|
| /frameworks/volley/tests/src/com/android/volley/ |
| RequestQueueTest.java | 73 RequestQueue queue = new RequestQueue(new NoCache(), network, 1, mDelivery); local
76 queue.add(request);
80 queue.start();
82 queue.stop();
101 RequestQueue queue = new RequestQueue(new NoCache(), network, 3, mDelivery); local
102 queue.add(req1);
103 queue.add(req2);
104 queue.start();
106 queue.stop();
111 RequestQueue queue = new RequestQueue(new NoCache(), network, 3, mDelivery) local
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/ |
| PriorityQueueTest.java | 194 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
195 assertNotNull(queue);
196 assertEquals(0, queue.size());
197 assertNull(queue.comparator());
204 PriorityQueue<Object> queue = new PriorityQueue<Object>(100); local
205 assertNotNull(queue);
206 assertEquals(0, queue.size());
207 assertNull(queue.comparator());
214 PriorityQueue<Object> queue = new PriorityQueue<Object>(100, local
216 assertNotNull(queue);
314 PriorityQueue<String> queue = new PriorityQueue<String>(4, local
338 PriorityQueue<Integer> queue = new PriorityQueue<Integer>(c); local
389 PriorityQueue<Integer> queue = new PriorityQueue<Integer>(treeSet); local
412 PriorityQueue<String> queue = new PriorityQueue<String>(10, local
430 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
443 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
483 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
506 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
546 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
559 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
598 PriorityQueue<String> queue = new PriorityQueue<String>(10, local
647 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
657 PriorityQueue<Object> queue = new PriorityQueue<Object>(); local
[all...] |
| /developers/build/prebuilts/gradle/MediaBrowserService/Application/src/main/java/com/example/android/mediabrowserservice/utils/ |
| QueueHelper.java | 31 * Utility class to help on queue related tasks.
45 LogHelper.e(TAG, "Could not build a playing queue for this mediaId: ", mediaId);
50 LogHelper.e(TAG, "Creating playing queue for musics of genre ", categoryValue);
52 List<MediaSession.QueueItem> queue = convertToQueue( local
55 return queue;
61 LogHelper.e(TAG, "Creating playing queue for musics from search ", query);
67 public static final int getMusicIndexOnQueue(Iterable<MediaSession.QueueItem> queue,
70 for (MediaSession.QueueItem item: queue) {
79 public static final int getMusicIndexOnQueue(Iterable<MediaSession.QueueItem> queue,
82 for (MediaSession.QueueItem item: queue) {
93 List<MediaSession.QueueItem> queue = new ArrayList<>(); local
[all...] |
