Home
last modified time | relevance | path

Searched refs:queue_ (Results 1 – 12 of 12) sorted by relevance

/external/chromium/base/
Dthread_collision_warner_unittest.cc152 : 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/net/flip/
Dflip_session_unittest.cc21 std::priority_queue<FlipIOBuffer> queue_; in TEST_F() local
27 queue_.push(buffer); in TEST_F()
35 queue_.push(FlipIOBuffer(buffers[index], buffers[index]->size(), 0, NULL)); in TEST_F()
38 EXPECT_EQ(kQueueSize + kNumDuplicates, queue_.size()); in TEST_F()
42 FlipIOBuffer buffer = queue_.top(); in TEST_F()
45 queue_.pop(); in TEST_F()
49 while (queue_.size()) { in TEST_F()
50 FlipIOBuffer buffer = queue_.top(); in TEST_F()
52 queue_.pop(); in TEST_F()
Dflip_session.cc361 queue_.push(FlipIOBuffer(buffer, length, request.priority, stream)); in GetOrCreateStream()
417 queue_.push(FlipIOBuffer(buffer, length, stream->priority(), stream)); in WriteStreamData()
673 while (in_flight_write_.buffer() || queue_.size()) { in WriteSocket()
676 FlipIOBuffer next_buffer = queue_.top(); in WriteSocket()
677 queue_.pop(); in WriteSocket()
Dflip_session.h205 OutputQueue queue_; variable
/external/srec/tools/thirdparty/OpenFst/fst/lib/
Dqueue.h411 : 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 …]
Drmepsilon.h337 RmEpsilonOptions<A, FifoQueue<StateId> >(&queue_, opts.delta, in RmEpsilonFstImpl()
401 FifoQueue<StateId> queue_; variable
/external/chromium/net/base/
Dlisten_socket_unittest.cc106 queue_.push_back(action); in ReportAction()
111 queue_.push_back(action); in ReportAction()
123 if (queue_.size() == 0) { in NextAction()
127 last_action_ = queue_.front(); in NextAction()
128 queue_.pop_front(); in NextAction()
144 if (queue_.size() == 0) { in NextAction()
148 last_action_ = queue_.front(); in NextAction()
149 queue_.pop_front(); in NextAction()
Dlisten_socket_unittest.h120 std::deque<ListenSocketTestAction> queue_; variable
/external/chromium/net/websockets/
Dwebsocket_throttle.cc160 DCHECK(queue_.empty()); in ~WebSocketThrottle()
207 queue_.push_back(state); in PutInQueue()
242 for (ConnectingQueue::iterator iter = queue_.begin(); in RemoveFromQueue()
243 iter != queue_.end(); in RemoveFromQueue()
246 queue_.erase(iter); in RemoveFromQueue()
254 for (ConnectingQueue::iterator iter = queue_.begin(); in WakeupSocketIfNecessary()
255 iter != queue_.end(); in WakeupSocketIfNecessary()
Dwebsocket_throttle.h62 ConnectingQueue queue_;
/external/v8/src/
Ddebug.cc2725 : queue_(size) { in LockingCommandMessageQueue()
2737 return queue_.IsEmpty(); in IsEmpty()
2743 CommandMessage result = queue_.Get(); in Get()
2751 queue_.Put(message); in Put()
2758 queue_.Clear(); in Clear()
Ddebug.h576 CommandMessageQueue queue_;