/external/chromium_org/net/socket/ |
tcp_listen_socket_unittest.h | 107 base::Lock lock_; // Protects |queue_| and |server_port_|. Wraps |cv_|. 109 std::deque<TCPListenSocketTestAction> queue_; member in class:net::TCPListenSocketTester
|
tcp_listen_socket_unittest.cc | 93 queue_.push_back(action); 99 while (queue_.empty()) 101 last_action_ = queue_.front(); 102 queue_.pop_front();
|
/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_org/chrome/browser/resources/file_manager/foreground/js/ |
file_watcher.js | 16 this.queue_ = new AsyncUtil.Queue(); 152 this.queue_.run(function(callback) { 187 this.queue_.run(function(callback) {
|
/external/chromium_org/media/mp4/ |
mp4_stream_parser.cc | 71 queue_.Reset(); 89 queue_.Push(buf, size); 126 queue_.Peek(&buf, &size); 136 moof_head_ = queue_.head(); 140 mdat_tail_ = queue_.head() + reader->size(); 152 queue_.Pop(reader->size()); 415 if (!queue_.Trim(mdat_tail_)) 432 queue_.Peek(&buf, &buf_size); 450 queue_.PeekAt(runs_->aux_info_offset() + moof_head_, &buf, &buf_size); 456 queue_.PeekAt(runs_->sample_offset() + moof_head_, &buf, &buf_size) [all...] |
/external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/server/ |
peer_channel.cc | 140 assert(queue_.size() == 0); 155 queue_.push(qr); 161 if (ds && !queue_.empty()) { 163 const QueuedResponse& response = queue_.front(); 166 queue_.pop();
|
/external/chromium_org/ui/compositor/ |
compositor.cc | 180 return queue_.front(); 184 return !queue_.empty(); 189 for (std::deque<SwapType>::const_iterator it = queue_.begin(); 190 it != queue_.end(); ++it) { 199 queue_.push_back(pending_swap_->type()); 204 queue_.pop_front(); 211 std::deque<SwapType> queue_; member in class:ui::PostedSwapQueue
|
/external/chromium_org/courgette/ |
adjustment_method_2.cc | 260 LabelInfo* top_candidate() const { return queue_.begin()->second; } 270 queue_.erase(ScoreAndLabel(old_score, p->first)); 275 queue_.insert(ScoreAndLabel(new_score, model_info)); 280 queue_.insert(ScoreAndLabel(new_score, model_info)); 282 LOG_ASSERT(queue_.size() == label_to_score_.size()); 288 Queue::const_iterator p = queue_.begin(); 289 if (p != queue_.end()) { 292 if (p != queue_.end()) { 308 // lockstep. Try to batch updates to |queue_|. 327 for (Queue::iterator q = queue_.begin(); q != queue_.end(); ++q) 349 Queue queue_; member in class:courgette::adjustment_method_2::AssignmentCandidates 793 Queue queue_; member in class:courgette::adjustment_method_2::VariableQueue [all...] |
/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/chrome/browser/debugger/ |
devtools_remote_listen_socket_unittest.h | 118 std::deque<ListenSocketTestAction> queue_; member in class:DevToolsRemoteListenSocketTester
|
/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();
|
/external/chromium_org/base/mac/ |
libdispatch_task_runner.h | 72 dispatch_queue_t queue_; member in class:base::mac::LibDispatchTaskRunner
|
/external/chromium_org/chrome/browser/chromeos/drive/ |
job_queue.h | 57 std::vector<std::deque<JobID> > queue_; member in class:drive::JobQueue
|
/external/chromium_org/chrome/browser/printing/ |
print_job_manager.h | 95 scoped_refptr<PrintQueriesQueue> queue_; member in class:printing::PrintJobManager
|
print_view_manager_base.cc | 59 queue_(g_browser_process->print_job_manager()->queue()) { 60 DCHECK(queue_); 482 scoped_refptr<PrinterQuery> queued_query = queue_->PopPrinterQuery(cookie); 514 queue_->SetDestination(NULL); 524 printer_query = queue_->PopPrinterQuery(cookie);
|
printing_message_filter.h | 138 scoped_refptr<printing::PrintQueriesQueue> queue_; member in class:PrintingMessageFilter
|
/external/chromium_org/media/midi/ |
midi_message_queue.h | 64 std::deque<uint8> queue_; member in class:media::MIDIMessageQueue
|
/external/chromium_org/net/spdy/ |
spdy_write_queue.h | 82 std::deque<PendingWrite> queue_[NUM_PRIORITIES]; member in class:net::SpdyWriteQueue
|
/external/chromium_org/net/base/ |
prioritized_dispatcher.h | 72 size_t num_queued_jobs() const { return queue_.size(); } 125 PriorityQueue<Job*> queue_; member in class:net::PrioritizedDispatcher
|
/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/chromium_org/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_org/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/chromium_org/media/mp3/ |
mp3_stream_parser.cc | 141 queue_.Reset(); 157 queue_.Push(buf, size); 164 queue_.Peek(&data, &data_size); 207 queue_.Pop(bytes_read);
|
mp3_stream_parser.h | 55 ByteQueue queue_; member in class:media::MP3StreamParser
|