| /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:__anon3177::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/openfst/src/include/fst/ |
| queue.h | 447 : QueueBase<S>(SCC_QUEUE), queue_(queue), scc_(scc), front_(0),
452 (((*queue_)[front_] && (*queue_)[front_]->Empty())
453 || (((*queue_)[front_] == 0) &&
457 if ((*queue_)[front_])
458 return (*queue_)[front_]->Head();
467 if ((*queue_)[scc_[s]]) {
468 (*queue_)[scc_[s]]->Enqueue(s);
477 if ((*queue_)[front_])
478 (*queue_)[front_]->Dequeue()
511 vector<Queue*> *queue_; member in class:fst::SccQueue
647 QueueBase<StateId> *queue_; member in class:fst::AutoQueue
857 Q *queue_; member in class:fst::PruneQueue
[all...] |
| rmepsilon.h | 407 RmEpsilonOptions<A, FifoQueue<StateId> >(&queue_, delta_, false)) {
422 RmEpsilonOptions<A, FifoQueue<StateId> >(&queue_, delta_, false)) {
496 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/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 | 72 std::priority_queue<SpdyIOBuffer> queue_; local
78 queue_.push(buffer);
86 queue_.push(SpdyIOBuffer(buffers[index], buffers[index]->size(), 0, NULL));
89 EXPECT_EQ(kQueueSize + kNumDuplicates, queue_.size());
93 SpdyIOBuffer buffer = queue_.top();
96 queue_.pop();
100 while (queue_.size()) {
101 SpdyIOBuffer buffer = queue_.top();
103 queue_.pop();
|
| spdy_session.cc | 789 while (in_flight_write_.buffer() || !queue_.empty()) {
792 SpdyIOBuffer next_buffer = queue_.top();
793 queue_.pop();
873 while (queue_.size())
874 queue_.pop();
891 queue_.push(SpdyIOBuffer(buffer, length, priority, stream));
[all...] |
| spdy_session.h | 465 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/openfst/src/include/fst/extensions/pdt/ |
| expand.h | 359 queue_(state_table_, stack_, stack_length_, distance_, fdistance_) {
473 ShortestStackFirstQueue queue_; // Queue used to visit efst_ member in class:fst::PrunedExpand
616 queue_.Enqueue(s);
619 queue_.Update(s);
883 while (!queue_.Empty()) {
884 StateId s = queue_.Head();
885 queue_.Dequeue();
[all...] |
| /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/v8/src/ |
| debug.h | 700 CommandMessageQueue queue_; member in class:v8::internal::BASE_EMBEDDED
[all...] |
