| /external/chromium/base/threading/ |
| D | thread_collision_warner_unittest.cc | 152 : queue_(queue) {} in TEST()
155 queue_.push(0); in TEST()
156 queue_.pop(); in TEST()
160 NonThreadSafeQueue& queue_; in TEST() member in TEST::QueueUser
210 : queue_(queue) {} in TEST()
213 queue_.push(0); in TEST()
214 queue_.pop(); in TEST()
218 NonThreadSafeQueue& queue_; in TEST() member in TEST::QueueUser
270 : queue_(queue), in TEST()
276 queue_.push(0); in TEST()
[all …]
|
| /external/chromium/base/ |
| D | task_queue.cc | 15 STLDeleteElements(&queue_); in ~TaskQueue()
22 queue_.push_back(task); in Push()
27 STLDeleteElements(&queue_); in Clear()
31 return queue_.empty(); in IsEmpty()
36 if (queue_.empty()) in Run()
40 queue_.swap(ready); in Run()
|
| D | task_queue_unittest.cc | 42 : queue_(queue), in TaskQueuerTask()
47 queue_->Push(task_to_queue_); in Run()
51 TaskQueue* queue_; member in __anon475b0dfb0111::TaskQueuerTask
|
| D | task_queue.h | 41 std::deque<Task*> queue_;
|
| /external/srec/tools/thirdparty/OpenFst/fst/lib/ |
| D | queue.h | 411 : QueueBase<S>(SCC_QUEUE), queue_(queue), scc_(scc), front_(0), in SccQueue()
416 (((*queue_)[front_] && (*queue_)[front_]->Empty()) in Head()
417 || (((*queue_)[front_] == 0) && in Head()
423 if ((*queue_)[front_]) in Head()
424 return (*queue_)[front_]->Head(); in Head()
433 if ((*queue_)[scc_[s]]) { in Enqueue()
434 (*queue_)[scc_[s]]->Enqueue(s); in Enqueue()
445 if ((*queue_)[front_]) in Dequeue()
446 (*queue_)[front_]->Dequeue(); in Dequeue()
452 if ((*queue_)[scc_[s]]) in Update()
[all …]
|
| D | rmepsilon.h | 337 RmEpsilonOptions<A, FifoQueue<StateId> >(&queue_, opts.delta, in RmEpsilonFstImpl()
401 FifoQueue<StateId> queue_; variable
|
| /external/chromium/net/websockets/ |
| D | websocket_throttle.cc | 53 DCHECK(queue_.empty()); in ~WebSocketThrottle()
63 queue_.push_back(job); in PutInQueue()
91 for (ConnectingQueue::iterator iter = queue_.begin(); in RemoveFromQueue()
92 iter != queue_.end(); in RemoveFromQueue()
95 queue_.erase(iter); in RemoveFromQueue()
134 for (ConnectingQueue::iterator iter = queue_.begin(); in WakeupSocketIfNecessary()
135 iter != queue_.end(); in WakeupSocketIfNecessary()
|
| D | websocket_throttle.h | 61 ConnectingQueue queue_;
|
| /external/chromium/chrome/browser/debugger/ |
| D | devtools_remote_listen_socket_unittest.cc | 162 queue_.push_back(action); in ReportAction()
167 queue_.push_back(action); in ReportAction()
179 if (queue_.empty()) { in NextAction()
183 last_action_ = queue_.front(); in NextAction()
184 queue_.pop_front(); in NextAction()
200 if (queue_.empty()) { in NextAction()
204 last_action_ = queue_.front(); in NextAction()
205 queue_.pop_front(); in NextAction()
|
| D | devtools_remote_listen_socket_unittest.h | 118 std::deque<ListenSocketTestAction> queue_; variable
|
| /external/chromium/chrome/common/extensions/docs/examples/extensions/benchmark/jst/ |
| D | 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/ |
| D | 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/browser/extensions/ |
| D | extension_host.cc | 72 queue_.push_back(host); in CreateSoon()
78 Queue::iterator it = std::find(queue_.begin(), queue_.end(), host); in Remove()
79 if (it != queue_.end()) in Remove()
80 queue_.erase(it); in Remove()
103 if (queue_.empty()) in ProcessOneHost()
106 queue_.front()->CreateRenderViewNow(); in ProcessOneHost()
107 queue_.pop_front(); in ProcessOneHost()
109 if (!queue_.empty()) in ProcessOneHost()
114 Queue queue_; member in ExtensionHost::ProcessCreationQueue
|
| /external/chromium/net/spdy/ |
| D | spdy_session_unittest.cc | 28 std::priority_queue<SpdyIOBuffer> queue_; in TEST_F() local
34 queue_.push(buffer); in TEST_F()
42 queue_.push(SpdyIOBuffer(buffers[index], buffers[index]->size(), 0, NULL)); in TEST_F()
45 EXPECT_EQ(kQueueSize + kNumDuplicates, queue_.size()); in TEST_F()
49 SpdyIOBuffer buffer = queue_.top(); in TEST_F()
52 queue_.pop(); in TEST_F()
56 while (queue_.size()) { in TEST_F()
57 SpdyIOBuffer buffer = queue_.top(); in TEST_F()
59 queue_.pop(); in TEST_F()
|
| D | spdy_session.cc | 743 while (in_flight_write_.buffer() || !queue_.empty()) { in WriteSocket()
746 SpdyIOBuffer next_buffer = queue_.top(); in WriteSocket()
747 queue_.pop(); in WriteSocket()
827 while (queue_.size()) in CloseAllStreams()
828 queue_.pop(); in CloseAllStreams()
845 queue_.push(SpdyIOBuffer(buffer, length, priority, stream)); in QueueFrame()
|
| D | spdy_session.h | 388 OutputQueue queue_; variable
|
| /external/valgrind/unittest/ |
| D | thread_wrappers.h | 235 : queue_(INT_MAX) { in ThreadPool()
251 queue_.Put(closure); in Add()
268 ProducerConsumerQueue queue_; variable
273 Closure *closure = reinterpret_cast<Closure*>(pool->queue_.Get()); in Worker()
|
| /external/v8/src/ |
| D | data-flow.h | 303 : capacity_(size + 1), head_(0), tail_(0), queue_(capacity_) { in WorkList()
304 for (int i = 0; i < capacity_; i++) queue_.Add(NULL); in WorkList()
320 queue_[tail_++] = item; in Insert()
326 T* item = queue_[head_++]; in Remove()
335 List<T*> queue_; variable
|
| D | debug.cc | 3108 : queue_(size) { in LockingCommandMessageQueue()
3120 return queue_.IsEmpty(); in IsEmpty()
3126 CommandMessage result = queue_.Get(); in Get()
3134 queue_.Put(message); in Put()
3141 queue_.Clear(); in Clear()
|
| D | debug.h | 686 CommandMessageQueue queue_;
|
| /external/chromium/net/base/ |
| D | listen_socket_unittest.cc | 81 queue_.push_back(action); in ReportAction()
87 while (queue_.empty()) in NextAction()
89 last_action_ = queue_.front(); in NextAction()
90 queue_.pop_front(); in NextAction()
|
| D | listen_socket_unittest.h | 111 std::deque<ListenSocketTestAction> queue_; variable
|
| /external/valgrind/main/drd/tests/ |
| D | tsan_thread_wrappers_pthread.h | 505 : queue_(INT_MAX) { in ThreadPool()
521 queue_.Put(closure); in Add()
538 ProducerConsumerQueue queue_; variable
543 Closure *closure = reinterpret_cast<Closure*>(pool->queue_.Get()); in Worker()
|
| /external/chromium/chrome/common/extensions/docs/examples/api/tabs/inspector/ |
| D | jstemplate_compiled.js | 858 me.queue_ = [ start ];
859 while (jsLength(me.queue_)) {
860 var f = me.queue_.shift();
874 this.queue_.push(f);
|
| /external/valgrind/tsan/ |
| D | thread_sanitizer.cc | 4030 queue_.push_front(sid); in Push()
4036 queue_.clear(); // Don't unref - the segments are already dead. in ForgetAllState()
4044 deque<SID>::iterator it = queue_.begin(); in Search()
4045 for (; it != queue_.end(); it++) { in Search()
4083 while(queue_.size() > flush_to_length) { in ShortenQueue()
4084 SID sid = queue_.back(); in ShortenQueue()
4086 queue_.pop_back(); in ShortenQueue()
4090 deque<SID> queue_; member
|