| /development/tools/axl/ |
| chewie.py | 16 class Queue:
18 self.queue = []
21 self.queue.append([url, time])
24 for x in range(len(self.queue)):
25 rec = self.queue[x]
27 del self.queue[x]
30 ## pull out request lag -- queue to start to done
56 queued = Queue()
|
| /external/chromium_org/media/base/ |
| serial_runner.cc | 42 SerialRunner::Queue::Queue() {}
43 SerialRunner::Queue::~Queue() {}
45 void SerialRunner::Queue::Push(const base::Closure& closure) {
49 void SerialRunner::Queue::Push(
54 void SerialRunner::Queue::Push(
59 SerialRunner::BoundPipelineStatusCB SerialRunner::Queue::Pop() {
65 bool SerialRunner::Queue::empty() {
69 SerialRunner::SerialRunner(const Queue& bound_fns
[all...] |
| decoder_buffer_queue.h | 18 // Maintains a queue of DecoderBuffers in increasing timestamp order.
21 // queue i.e., the queue must have at least 2 in-order buffers to calculate
30 // Push |buffer| to the end of the queue. If |buffer| is queued out of order
36 // Pops a DecoderBuffer from the front of the queue.
38 // It is invalid to call Pop() on an empty queue.
44 // Returns true if this queue is empty.
47 // Returns the duration of encoded data stored in this queue as measured by
51 // Returns zero if the queue is empty.
54 // Returns the total size of buffers inside the queue
[all...] |
| serial_runner.h | 8 #include <queue>
31 // Serial queue of bound functions to run.
32 class MEDIA_EXPORT Queue {
34 Queue();
35 ~Queue();
47 std::queue<BoundPipelineStatusCB> bound_fns_;
65 const Queue& bound_fns, const PipelineStatusCB& done_cb);
70 SerialRunner(const Queue& bound_fns, const PipelineStatusCB& done_cb);
76 Queue bound_fns_;
|
| /external/llvm/include/llvm/CodeGen/ |
| LatencyPriorityQueue.h | 1 //===---- LatencyPriorityQueue.h - A latency-oriented priority queue ------===//
24 /// Sorting functions for the Available queue.
37 /// Queue, the number of nodes that the node is the sole unscheduled
42 /// Queue - The queue.
43 std::vector<SUnit*> Queue;
78 bool empty() const override { return Queue.empty(); }
|
| ResourcePriorityQueue.h | 1 //===----- ResourcePriorityQueue.h - A DFA-oriented priority queue -------===//
30 /// Sorting functions for the Available queue.
43 /// Queue, the number of nodes that the node is the sole unscheduled
48 /// Queue - The queue.
49 std::vector<SUnit*> Queue;
119 bool empty() const override { return Queue.empty(); }
|
| /external/chromium_org/testing/gtest/samples/ |
| sample3-inl.h | 40 // Queue is a simple queue implemented as a singled-linked list.
44 class Queue;
46 // QueueNode is a node in a Queue, which consists of an element of
50 friend class Queue<E>;
56 // Gets the next node in the queue.
74 class Queue {
76 // Creates an empty queue.
77 Queue() : head_(NULL), last_(NULL), size_(0) {}
79 // D'tor. Clears the queue
[all...] |
| /external/chromium_org/chrome/common/extensions/docs/examples/api/nativeMessaging/host/ |
| native-messaging-example-host | 12 import Queue
29 def read_thread_func(queue):
36 if queue:
37 queue.put(None)
46 if queue:
47 queue.put(text)
54 def __init__(self, queue):
55 self.queue = queue
74 while not self.queue.empty()
[all...] |
| /external/chromium_org/third_party/libaddressinput/src/cpp/src/ |
| ondemand_supply_task.cc | 55 void OndemandSupplyTask::Queue(const std::string& key) {
|
| /external/chromium_org/third_party/libaddressinput/src/cpp/test/ |
| ondemand_supply_task_test.cc | 68 void Queue(const std::string& key) { task_->Queue(key); }
107 Queue("data/XA");
118 Queue("data/XA");
145 Queue("data/XA");
146 Queue("data/XA/aa");
147 Queue("data/XA/aa/bb");
148 Queue("data/XA/aa/bb/cc");
180 Queue("data/XA");
192 Queue("data/XA")
[all...] |
| /external/chromium_org/tools/memory_inspector/memory_inspector/frontends/ |
| background_tasks.py | 15 which communicates its progress updates through a Queue. The messages enqueued
21 import Queue
134 self._log_queue = multiprocessing.Queue()
146 except Queue.Empty:
|
| /external/chromium_org/v8/tools/testrunner/local/ |
| pool.py | 6 from multiprocessing import Event, Process, Queue
50 # Factor to calculate the maximum number of items in the work/done queue.
51 # Necessary to not overflow the queue's pipe if a keyboard interrupt happens.
67 self.work_queue = Queue()
68 self.done_queue = Queue()
116 """Adds an item to the work queue. Can be called dynamically while
127 # they empty the queue buffer.
|
| /external/chromium_org/v8/tools/testrunner/network/ |
| endpoint.py | 31 import Queue
|
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/mod_pywebsocket/ |
| msgutil.py | 41 import Queue
127 self._queue = Queue.Queue()
160 except Queue.Empty:
193 self._queue = Queue.Queue()
|
| /external/chromium_org/components/crash/tools/ |
| generate_breakpad_symbols.py | 15 import Queue
143 queue = Queue.Queue()
148 binary = queue.get()
164 queue.task_done()
190 queue.task_done()
193 queue.put(binary)
200 queue.join()
245 queue = [options.binary
[all...] |
| /external/chromium_org/native_client_sdk/src/tools/tests/ |
| httpd_test.py | 7 import Queue
44 def _SubprocessThread(process, queue):
46 queue.put((process.returncode, stdout, stderr))
55 queue = Queue.Queue()
57 args=(self.process, queue))
62 returncode, stdout, stderr = queue.get(False)
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/ |
| msgutil.py | 41 import Queue
127 self._queue = Queue.Queue()
160 except Queue.Empty:
193 self._queue = Queue.Queue()
|
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
| mock.py | 35 import Queue
116 self._queue = Queue.Queue()
|
| test_mock.py | 36 import Queue
87 queue.
90 def __init__(self, conn, queue):
92 self._queue = queue
103 queue = Queue.Queue()
104 reader = LineReader(conn, queue)
105 self.failUnless(queue.empty())
107 read = queue.get(
[all...] |
| /external/chromium_org/build/android/pylib/perf/ |
| surface_stats_collector.py | 5 import Queue
56 self._data_queue = Queue.Queue()
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/breakpad/ |
| dump_reader_multipart.py | 32 import Queue
133 queue = Queue.Queue()
134 thread = threading.Thread(target=_symbolize_keepalive, args=(queue,))
151 queue.put(None)
162 def _symbolize_keepalive(queue):
166 msg = queue.get(block=True, timeout=60)
168 except Queue.Empty:
|
| /external/llvm/lib/CodeGen/ |
| RegAllocBasic.cpp | 39 #include <queue>
70 CompSpillWeight> Queue;
92 Queue.push(LI);
96 if (Queue.empty())
98 LiveInterval *LI = Queue.top();
99 Queue.pop();
|
| /external/openfst/src/include/fst/script/ |
| shortest-path.h | 71 typedef AutoQueue<StateId> Queue;
72 Queue *queue = QueueConstructor<Queue, Arc, local
74 fst::ShortestPathOptions<Arc, Queue, ArcFilter> spopts(
75 queue, ArcFilter(), opts.nshortest, opts.unique,
79 delete queue;
83 typedef FifoQueue<StateId> Queue;
84 Queue *queue = QueueConstructor<Queue, Arc local
96 Queue *queue = QueueConstructor<Queue, Arc, local
108 Queue *queue = QueueConstructor<Queue, Arc, local
120 Queue *queue = QueueConstructor<Queue, Arc, local
132 Queue *queue = QueueConstructor<Queue, Arc, local
[all...] |
| /external/chromium_org/build/android/pylib/symbols/ |
| elf_symbolizer.py | 11 import Queue
59 of the Queue instance in Addr2Line) should be free from mind-blowing
152 # 1. Find an existing instance with the shortest queue.
223 # The request queue (i.e. addresses pushed to addr2line's stdin and not
238 self._out_queue = None # Queue.Queue instance (for buffering a2l stdout).
277 except Queue.Empty:
298 except Queue.Empty:
385 # The only reason of existence of this Queue (and the corresponding
388 self._out_queue = Queue.Queue(
[all...] |
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/common/ |
| message_pool.py | 46 import Queue
75 self._messages_to_worker = Queue.Queue()
76 self._messages_to_manager = Queue.Queue()
78 self._messages_to_worker = multiprocessing.Queue()
79 self._messages_to_manager = multiprocessing.Queue()
180 except Queue.Empty:
261 except Queue.Empty:
262 assert False, '%s: ran out of messages in worker queue.' % self.nam
[all...] |
