| /external/webkit/Tools/Scripts/webkitpy/layout_tests/layout_package/ |
| message_broker2.py | 37 queues themselves are provided by the caller, as the queue's implementation
63 import Queue
102 Queue interface (put()/get()).
120 queue = self._get_queue_for_topic(topic_name)
121 queue.put(_Message.dumps(message))
135 queue = self._get_queue_for_topic(topic_name)
138 s = queue.get(block, delay_secs)
139 except Queue.Empty:
|
| manager_worker_broker_unittest.py | 30 import Queue
193 starting_queue = self.queue()
194 stopping_queue = self.queue()
244 def queue(self): member in class:InlineBrokerTests.MultiProcessBrokerTests
245 return multiprocessing.Queue()
253 def queue(self): member in class:ThreadedBrokerTests
254 return Queue.Queue()
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/ |
| MockAccessibilityService.java | 28 import java.util.Queue;
40 private final Queue<AccessibilityEvent> mExpectedEvents = new LinkedList<AccessibilityEvent>();
|
| /packages/providers/DownloadProvider/src/com/android/providers/downloads/ |
| SizeLimitActivity.java | 32 import java.util.Queue;
42 private Queue<Intent> mDownloadsToShow = new LinkedList<Intent>();
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| ConnPoolByRoute.java | 36 import java.util.Queue;
77 protected Queue<BasicPoolEntry> freeConnections;
80 protected Queue<WaitingThread> waitingThreads;
114 * Creates the queue for {@link #freeConnections}.
117 * @return a queue
119 protected Queue<BasicPoolEntry> createFreeConnQueue() {
124 * Creates the queue for {@link #waitingThreads}.
127 * @return a queue
129 protected Queue<WaitingThread> createWaitingThreadQueue() {
|
| /external/llvm/lib/CodeGen/ |
| MachineScheduler.cpp | 34 #include <queue>
730 std::vector<SUnit*> Queue;
739 // SU is in this queue if it's NodeQueueID is a superset of this ID.
742 bool empty() const { return Queue.empty(); }
744 unsigned size() const { return Queue.size(); }
748 iterator begin() { return Queue.begin(); }
750 iterator end() { return Queue.end(); }
753 return std::find(Queue.begin(), Queue.end(), SU);
757 Queue.push_back(SU)
[all...] |
| /frameworks/base/tests/touchlag/ |
| touchlag.cpp | 189 struct Queue {
195 Queue() : index(0) { }
251 Queue queue; local
277 queue.push(x, y);
278 queue.get(lag, &lag_x, &lag_y);
|
| /external/dropbear/ |
| session.h | 35 #include "queue.h"
105 struct Queue writequeue; /* A queue of encrypted packets to send */
|
| /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/base/core/java/android/view/accessibility/ |
| AccessibilityNodeInfoCache.java | 26 import java.util.Queue;
288 Queue<AccessibilityNodeInfo> fringe = new LinkedList<AccessibilityNodeInfo>();
|
| /packages/apps/Email/tests/src/com/android/email/activity/ |
| ContactStatusLoaderTest.java | 34 import java.util.Queue;
190 public final Queue<Cursor> mCursors = new LinkedBlockingQueue<Cursor>();
|
| /external/clang/lib/AST/ |
| CXXInheritance.cpp | 128 SmallVector<const CXXRecordDecl*, 8> Queue;
150 Queue.push_back(Base);
158 if (Queue.empty()) break;
159 Record = Queue.back(); // not actually a queue.
160 Queue.pop_back();
|
| /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...] |
| /external/llvm/lib/CodeGen/SelectionDAG/ |
| ScheduleDAGFast.cpp | 39 /// FastPriorityQueue - A degenerate priority queue that considers
43 SmallVector<SUnit *, 16> Queue;
45 bool empty() const { return Queue.empty(); }
48 Queue.push_back(U);
53 SUnit *V = Queue.back();
54 Queue.pop_back();
64 /// AvailableQueue - The priority queue to use for the available SUnits.
176 /// the Available queue.
522 // Add root to Available queue.
530 // While Available queue is not empty, grab the node with the highes
[all...] |
| /frameworks/base/services/input/ |
| InputDispatcher.h | 602 // Generic queue implementation.
604 struct Queue {
608 inline Queue() : head(NULL), tail(NULL) {
809 // Queue of events that need to be published to the connection.
810 Queue<DispatchEntry> outboundQueue;
812 // Queue of events that have been published to the connection but that have not
814 Queue<DispatchEntry> waitQueue;
846 Queue<EventEntry> mInboundQueue;
847 Queue<CommandEntry> mCommandQueue;
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
| test_msgutil.py | 37 import Queue
[all...] |
| /external/jmonkeyengine/engine/src/blender/com/jme3/asset/ |
| BlenderKey.java | 55 import java.util.Queue;
700 protected void breadthFirstTraversal(SceneGraphVisitor visitor, Queue<Spatial> queue) {}
|
| /external/jmonkeyengine/engine/src/core/com/jme3/scene/ |
| Geometry.java | 48 import java.util.Queue;
464 protected void breadthFirstTraversal(SceneGraphVisitor visitor, Queue<Spatial> queue) {
|
| Node.java | 46 import java.util.Queue;
639 protected void breadthFirstTraversal(SceneGraphVisitor visitor, Queue<Spatial> queue) {
640 queue.addAll(children);
|
| /frameworks/base/core/java/android/speech/ |
| SpeechRecognizer.java | 36 import java.util.Queue;
141 * Temporary queue, saving the messages until the connection will be established, afterwards,
144 private final Queue<Message> mPendingTasks = new LinkedList<Message>();
|
