| /external/chromium/base/ |
| task_queue.cc | 14 // We own all the pointes in |queue_|. It is our job to delete them.
15 STLDeleteElements(&queue_);
22 queue_.push_back(task);
27 STLDeleteElements(&queue_);
31 return queue_.empty();
36 if (queue_.empty())
40 queue_.swap(ready);
|
| task_queue.h | 41 std::deque<Task*> queue_; member in class:TaskQueue
|
| task_queue_unittest.cc | 42 : queue_(queue),
47 queue_->Push(task_to_queue_);
51 TaskQueue* queue_; member in class:__anon2294::TaskQueuerTask
|
| /external/chromium/base/threading/ |
| thread_collision_warner_unittest.cc | 152 : queue_(queue) {}
155 queue_.push(0);
156 queue_.pop();
160 NonThreadSafeQueue& queue_; member in class:QueueUser
210 : queue_(queue) {}
213 queue_.push(0);
214 queue_.pop();
218 NonThreadSafeQueue& queue_; member in class:QueueUser
270 : queue_(queue),
276 queue_.push(0)
284 NonThreadSafeQueue& queue_; member in class:QueueUser
362 NonThreadSafeQueue& queue_; member in class:QueueUser
[all...] |
| /external/chromium/net/websockets/ |
| websocket_throttle.h | 34 // Puts |job| in |queue_| and queues for the destination addresses
39 // Removes |job| from |queue_| and queues for the destination addresses
43 // Checks sockets waiting in |queue_| and check the socket is the front of
61 ConnectingQueue queue_; member in class:net::WebSocketThrottle
|
| websocket_throttle.cc | 53 DCHECK(queue_.empty());
63 queue_.push_back(job);
91 for (ConnectingQueue::iterator iter = queue_.begin();
92 iter != queue_.end();
95 queue_.erase(iter);
134 for (ConnectingQueue::iterator iter = queue_.begin();
135 iter != queue_.end();
|
| /external/srec/tools/thirdparty/OpenFst/fst/lib/ |
| queue.h | 411 : QueueBase<S>(SCC_QUEUE), queue_(queue), scc_(scc), front_(0),
416 (((*queue_)[front_] && (*queue_)[front_]->Empty())
417 || (((*queue_)[front_] == 0) &&
423 if ((*queue_)[front_])
424 return (*queue_)[front_]->Head();
433 if ((*queue_)[scc_[s]]) {
434 (*queue_)[scc_[s]]->Enqueue(s);
445 if ((*queue_)[front_])
446 (*queue_)[front_]->Dequeue()
479 vector<Queue*> *queue_; member in class:fst::SccQueue
611 QueueBase<StateId> *queue_; member in class:fst::AutoQueue
[all...] |
| rmepsilon.h | 337 RmEpsilonOptions<A, FifoQueue<StateId> >(&queue_, opts.delta,
401 FifoQueue<StateId> queue_; member in class:fst::RmEpsilonFstImpl
|
| /external/chromium/chrome/browser/debugger/ |
| devtools_remote_listen_socket_unittest.cc | 162 queue_.push_back(action);
167 queue_.push_back(action);
179 if (queue_.empty()) {
183 last_action_ = queue_.front();
184 queue_.pop_front();
200 if (queue_.empty()) {
204 last_action_ = queue_.front();
205 queue_.pop_front();
|
| devtools_remote_listen_socket_unittest.h | 118 std::deque<ListenSocketTestAction> queue_; member in class:DevToolsRemoteListenSocketTester
|
| /external/v8/src/ |
| data-flow.h | 303 : capacity_(size + 1), head_(0), tail_(0), queue_(capacity_) {
304 for (int i = 0; i < capacity_; i++) queue_.Add(NULL);
320 queue_[tail_++] = item;
326 T* item = queue_[head_++];
335 List<T*> queue_; member in class:v8::internal::BASE_EMBEDDED
|
| debug.cc | [all...] |
| debug.h | 686 CommandMessageQueue queue_; member in class:v8::internal::BASE_EMBEDDED
[all...] |
| /external/chromium/net/base/ |
| listen_socket_unittest.cc | 81 queue_.push_back(action);
87 while (queue_.empty())
89 last_action_ = queue_.front();
90 queue_.pop_front();
|
| listen_socket_unittest.h | 109 base::Lock lock_; // protects |queue_| and wraps |cv_|
111 std::deque<ListenSocketTestAction> queue_; member in class:ListenSocketTester
|
| /external/valgrind/unittest/ |
| thread_wrappers.h | 235 : queue_(INT_MAX) {
251 queue_.Put(closure);
268 ProducerConsumerQueue queue_; member in class:ThreadPool
273 Closure *closure = reinterpret_cast<Closure*>(pool->queue_.Get());
|
| /external/chromium/chrome/browser/extensions/ |
| extension_host.cc | 72 queue_.push_back(host);
78 Queue::iterator it = std::find(queue_.begin(), queue_.end(), host);
79 if (it != queue_.end())
80 queue_.erase(it);
103 if (queue_.empty())
106 queue_.front()->CreateRenderViewNow();
107 queue_.pop_front();
109 if (!queue_.empty())
114 Queue queue_; member in class:ExtensionHost::ProcessCreationQueue
[all...] |
| /external/chromium/net/spdy/ |
| spdy_session_unittest.cc | 28 std::priority_queue<SpdyIOBuffer> queue_; local
34 queue_.push(buffer);
42 queue_.push(SpdyIOBuffer(buffers[index], buffers[index]->size(), 0, NULL));
45 EXPECT_EQ(kQueueSize + kNumDuplicates, queue_.size());
49 SpdyIOBuffer buffer = queue_.top();
52 queue_.pop();
56 while (queue_.size()) {
57 SpdyIOBuffer buffer = queue_.top();
59 queue_.pop();
|
| spdy_session.cc | 743 while (in_flight_write_.buffer() || !queue_.empty()) {
746 SpdyIOBuffer next_buffer = queue_.top();
747 queue_.pop();
827 while (queue_.size())
828 queue_.pop();
845 queue_.push(SpdyIOBuffer(buffer, length, priority, stream));
[all...] |
| spdy_session.h | 388 OutputQueue queue_; member in class:net::SpdySession
|
| /external/valgrind/main/drd/tests/ |
| tsan_thread_wrappers_pthread.h | 505 : queue_(INT_MAX) {
521 queue_.Put(closure);
538 ProducerConsumerQueue queue_; member in class:ThreadPool
543 Closure *closure = reinterpret_cast<Closure*>(pool->queue_.Get());
|
| /external/chromium/chrome/common/extensions/docs/examples/api/tabs/inspector/ |
| jstemplate_compiled.js | 858 me.queue_ = [ start ];
859 while (jsLength(me.queue_)) {
860 var f = me.queue_.shift();
874 this.queue_.push(f);
|
| /external/chromium/chrome/common/extensions/docs/examples/extensions/benchmark/jst/ |
| util.js | 239 me.queue_ = [ root ];
240 while (jsLength(me.queue_)) {
241 me.process_(me.queue_.shift());
256 me.queue_.push(c);
|
| /external/chromium/chrome/common/extensions/docs/examples/extensions/irc/servlet/jstemplate/ |
| util.js | 239 me.queue_ = [ root ];
240 while (jsLength(me.queue_)) {
241 me.process_(me.queue_.shift());
256 me.queue_.push(c);
|
| /external/valgrind/tsan/ |
| thread_sanitizer.cc | [all...] |
