| /external/mp4parser/isoparser/src/main/java/com/googlecode/mp4parser/authoring/tracks/ |
| ChangeTimeScaleTrack.java | 27 import java.util.Queue;
59 Queue<TimeToSampleBox.Entry> timeQueue = new LinkedList<TimeToSampleBox.Entry>(track.getDecodingTimeEntries());
|
| /external/openfst/src/include/fst/ |
| partition.h | 29 #include <fst/queue.h>
199 // partition, create new once and update the queue of active classes
201 template <class Queue>
202 void FinalizeSplit(Queue* L) {
|
| /external/sonivox/jet_tools/JetCreator/ |
| JetPreview.py | 141 # queue first segment and start playback
143 Queue(self.jet, self.queueSegs[index])
159 # if less than 2 segs queued - queue another one
161 Queue(self.jet, self.queueSegs[index])
|
| /external/srec/tools/thirdparty/OpenFst/fst/lib/ |
| partition.h | 25 #include "fst/lib/queue.h"
194 // partition, create new once and update the queue of active classes
196 template <class Queue>
197 void FinalizeSplit(Queue* L) {
|
| /frameworks/native/services/inputflinger/ |
| InputDispatcher.h | 604 // Generic queue implementation.
606 struct Queue {
610 inline Queue() : head(NULL), tail(NULL) {
811 // Queue of events that need to be published to the connection.
812 Queue<DispatchEntry> outboundQueue;
814 // Queue of events that have been published to the connection but that have not
816 Queue<DispatchEntry> waitQueue;
848 Queue<EventEntry> mInboundQueue;
849 Queue<EventEntry> mRecentQueue;
850 Queue<CommandEntry> mCommandQueue
[all...] |
| /frameworks/opt/bitmap/src/com/android/bitmap/ |
| ContiguousFIFOAggregator.java | 26 import java.util.Queue;
58 private final Queue<T> mExpected;
88 * the expected queue and its callback will be replaced with this one.
284 * additional to the end of the queue. For a first expected key to no longer be the first
|
| /packages/apps/UnifiedEmail/src/com/android/mail/ui/ |
| MiniDrawerView.java | 35 import java.util.Queue;
118 final Queue<View> recycleViews = new ArrayDeque<>(recycleCount);
|
| /external/guava/guava/src/com/google/common/collect/ |
| Iterables.java | 39 import java.util.Queue;
[all...] |
| 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/guava/guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ |
| Iterables.java | 36 import java.util.Queue;
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_telnetlib.py | 4 import Queue
97 self.dataq = Queue.Queue()
387 self.dataq = Queue.Queue()
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_telnetlib.py | 4 import Queue
97 self.dataq = Queue.Queue()
387 self.dataq = Queue.Queue()
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
| pool.py | 42 import Queue
139 self._taskqueue = Queue.Queue()
344 debug('could not put task on queue')
717 self._inqueue = Queue.Queue()
718 self._outqueue = Queue.Queue()
727 inqueue.queue.clear()
728 inqueue.queue.extend([None] * size
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
| pool.py | 42 import Queue
139 self._taskqueue = Queue.Queue()
344 debug('could not put task on queue')
717 self._inqueue = Queue.Queue()
718 self._outqueue = Queue.Queue()
727 inqueue.queue.clear()
728 inqueue.queue.extend([None] * size
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
| test_msgutil.py | 37 import Queue
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ConcurrentLinkedQueueTest.java | 16 import java.util.Queue;
22 * Returns a new queue of given size containing consecutive
36 * new queue is empty
77 * Queue contains all elements of collection used to initialize
209 * Queue contains all elements, in traversal order, of successful addAll
462 assertEquals("queue should be empty again", 0, q.size());
494 * A deserialized serialized queue has same elements in same order
497 Queue x = populatedQueue(SIZE);
498 Queue y = serialClone(x);
|
| PriorityQueueTest.java | 18 import java.util.Queue;
29 * Returns a new queue of given size containing consecutive
45 * A new queue has unbounded capacity
96 * Queue contains all elements of collection used to initialize
245 * Queue contains all elements of successful addAll
478 * A deserialized serialized queue has same elements
481 Queue x = populatedQueue(SIZE);
482 Queue y = serialClone(x);
|
| /external/chromium_org/chrome/browser/devtools/device/usb/ |
| android_usb_device.h | 9 #include <queue>
103 void Queue(scoped_refptr<AdbMessage> message);
153 // Outgoing bulk queue
155 std::queue<BulkMessage> outgoing_queue_;
|
| /external/chromium_org/chrome/common/extensions/docs/server2/ |
| cron_servlet.py | 95 queue = taskqueue.Queue()
97 # GAE documentation specifies that it's bad to add tasks to a queue
100 queue.purge()
115 queue.add(taskqueue.Task(url='/_refresh/%s/%s' % (name, path),
|
| /external/chromium_org/ui/file_manager/file_manager/background/js/ |
| drive_sync_handler.js | 44 * Async queue.
45 * @type {AsyncUtil.Queue}
48 this.queue_ = new AsyncUtil.Queue();
|
| /external/chromium_org/v8/tools/testrunner/network/ |
| endpoint.py | 31 import Queue
|
| /external/clang/lib/AST/ |
| CXXInheritance.cpp | 135 SmallVector<const CXXRecordDecl*, 8> Queue;
158 Queue.push_back(Base);
166 if (Queue.empty())
168 Record = Queue.pop_back_val(); // not actually a queue.
|
| /external/chromium_org/ui/file_manager/file_manager/common/js/ |
| async_util.js | 33 var queue = new AsyncUtil.Queue();
35 queue.run(function(element, index, iterationCompletionCallback) {
39 queue.run(function(iterationCompletionCallback) {
45 * Creates a class for executing several asynchronous closures in a fifo queue.
91 console.error('Queue is calcelled. Cannot add a new task.');
100 * Cancels the queue. It removes all the not-run (yet) tasks. Note that this
109 * @return {boolean} True when the queue have been requested to cancel or is
154 * Creates a class for executing several asynchronous closures in a fifo queue.
160 AsyncUtil.Queue = function()
[all...] |
| /frameworks/base/core/java/android/speech/ |
| SpeechRecognizer.java | 36 import java.util.Queue;
147 * Temporary queue, saving the messages until the connection will be established, afterwards,
150 private final Queue<Message> mPendingTasks = new LinkedList<Message>();
|
| /frameworks/base/core/java/android/view/textservice/ |
| SpellCheckerSession.java | 36 import java.util.Queue;
229 private final Queue<SpellCheckerParams> mPendingTasks =
403 // all close tasks from the queue
|
