Searched refs:queue_ (Results 1 - 25 of 27) sorted by relevance

12

/external/chromium/base/
H A Dtask_queue.cc14 // 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);
H A Dtask_queue.h41 std::deque<Task*> queue_; member in class:TaskQueue
H A Dtask_queue_unittest.cc42 : queue_(queue),
47 queue_->Push(task_to_queue_);
51 TaskQueue* queue_; member in class:__anon1622::TaskQueuerTask
/external/chromium/base/threading/
H A Dthread_collision_warner_unittest.cc152 : 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_
284 NonThreadSafeQueue& queue_; member in class:QueueUser
362 NonThreadSafeQueue& queue_; member in class:QueueUser
[all...]
/external/chromium/net/websockets/
H A Dwebsocket_throttle.cc53 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();
H A Dwebsocket_throttle.h34 // 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
/external/openfst/src/include/fst/
H A Dqueue.h447 : 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
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...]
H A Drmepsilon.h407 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/srec/tools/thirdparty/OpenFst/fst/lib/
H A Dqueue.h411 : 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
479 vector<Queue*> *queue_; member in class:fst::SccQueue
611 QueueBase<StateId> *queue_; member in class:fst::AutoQueue
[all...]
H A Drmepsilon.h337 RmEpsilonOptions<A, FifoQueue<StateId> >(&queue_, opts.delta,
401 FifoQueue<StateId> queue_; member in class:fst::RmEpsilonFstImpl
/external/chromium/chrome/common/extensions/docs/examples/extensions/benchmark/jst/
H A Dutil.js239 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/
H A Dutil.js239 me.queue_ = [ root ];
240 while (jsLength(me.queue_)) {
241 me.process_(me.queue_.shift());
256 me.queue_.push(c);
/external/chromium/chrome/browser/debugger/
H A Ddevtools_remote_listen_socket_unittest.cc162 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();
H A Ddevtools_remote_listen_socket_unittest.h118 std::deque<ListenSocketTestAction> queue_; member in class:DevToolsRemoteListenSocketTester
/external/chromium/net/base/
H A Dlisten_socket_unittest.cc81 queue_.push_back(action);
87 while (queue_.empty())
89 last_action_ = queue_.front();
90 queue_.pop_front();
H A Dlisten_socket_unittest.h109 base::Lock lock_; // protects |queue_| and wraps |cv_|
111 std::deque<ListenSocketTestAction> queue_; member in class:ListenSocketTester
/external/valgrind/unittest/
H A Dthread_wrappers.h235 : 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/
H A Dextension_host.cc72 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/
H A Dspdy_session_unittest.cc72 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();
H A Dspdy_session.cc789 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));
H A Dspdy_session.h465 OutputQueue queue_; member in class:net::SpdySession
/external/valgrind/main/drd/tests/
H A Dtsan_thread_wrappers_pthread.h505 : 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/
H A Djstemplate_compiled.js858 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/
H A Dexpand.h359 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();
/external/v8/src/
H A Ddebug.cc3520 : logger_(logger), queue_(size) {
3532 return queue_.IsEmpty();
3538 CommandMessage result = queue_.Get();
3546 queue_.Put(message);
3553 queue_.Clear();

Completed in 481 milliseconds

12