| /external/chromium_org/third_party/webrtc/modules/remote_bitrate_estimator/test/ |
| bwe_test.cc | 194 queue_.merge(*batch);
195 if (queue_.empty()) {
199 Packets::iterator it = queue_.begin();
200 for (; it != queue_.end(); ++it) {
205 to_transfer.splice(to_transfer.begin(), queue_, queue_.begin(), it);
210 Packets queue_; member in class:webrtc::testing::bwe::PacketProcessorRunner
|
| /external/chromium_org/content/browser/indexed_db/ |
| indexed_db_transaction.cc | 27 while (!queue_.empty())
28 queue_.pop();
32 DCHECK(!queue_.empty());
33 Operation task(queue_.front());
34 queue_.pop();
|
| /external/chromium_org/extensions/browser/ |
| content_verify_job.cc | 62 queue_.append(data, count);
142 if (!queue_.empty()) {
144 queue_.swap(tmp);
|
| content_verify_job.h | 107 std::string queue_; member in class:extensions::ContentVerifyJob
|
| /external/chromium_org/mojo/public/cpp/bindings/tests/ |
| router_unittest.cc | 37 explicit MessageAccumulator(internal::MessageQueue* queue) : queue_(queue) {
41 queue_->Push(message);
46 internal::MessageQueue* queue_; member in class:mojo::test::__anon12835::MessageAccumulator
|
| connector_unittest.cc | 26 queue_.Push(message);
31 return queue_.IsEmpty();
35 queue_.Pop(message);
39 internal::MessageQueue queue_; member in class:mojo::test::__anon12831::MessageAccumulator
|
| /external/chromium_org/chrome/browser/extensions/activity_log/ |
| activity_database_unittest.cc | 61 std::vector<scoped_refptr<Action> > queue_; member in class:extensions::ActivityDatabaseTestPolicy
84 for (i = 0; i < queue_.size(); i++) {
85 const Action& action = *queue_[i];
98 queue_.clear();
104 queue_.push_back(action);
105 db->AdviseFlush(queue_.size());
|
| /art/runtime/mirror/ |
| reference.h | 56 return OFFSET_OF_OBJECT_MEMBER(Reference, queue_);
113 HeapReference<Object> queue_; // Note this is Java volatile: member in class:art::mirror::Reference
|
| /external/chromium_org/cc/resources/ |
| resource_update_controller_unittest.cc | 58 queue_(make_scoped_ptr(new ResourceUpdateQueue)),
142 queue_->AppendFullUpload(upload);
158 queue_->AppendPartialUpload(upload);
175 queue_.Pass(),
189 scoped_ptr<ResourceUpdateQueue> queue_; member in class:cc::__anon7344::ResourceUpdateControllerTest
400 queue_.Pass(),
447 queue_.Pass(),
488 queue_.Pass(),
|
| resource_update_controller.h | 73 scoped_ptr<ResourceUpdateQueue> queue_; member in class:cc::ResourceUpdateController
|
| /external/chromium_org/chrome/browser/printing/ |
| printing_message_filter.cc | 96 queue_(g_browser_process->print_job_manager()->queue()) {
97 DCHECK(queue_);
312 printer_query = queue_->PopPrinterQuery(0);
314 printer_query = queue_->CreatePrinterQuery();
349 queue_->QueuePrinterQuery(printer_query.get());
360 queue_->PopPrinterQuery(params.cookie);
362 printer_query = queue_->CreatePrinterQuery();
409 queue_->QueuePrinterQuery(printer_query.get());
436 printer_query = queue_->PopPrinterQuery(document_cookie);
438 printer_query = queue_->CreatePrinterQuery()
[all...] |
| print_job_manager.h | 95 scoped_refptr<PrintQueriesQueue> queue_; member in class:printing::PrintJobManager
|
| print_view_manager_base.h | 173 scoped_refptr<printing::PrintQueriesQueue> queue_; member in class:printing::PrintViewManagerBase
|
| printing_message_filter.h | 137 scoped_refptr<printing::PrintQueriesQueue> queue_; member in class:PrintingMessageFilter
|
| /external/chromium_org/media/formats/mpeg/ |
| mpeg_audio_stream_parser_base.h | 142 ByteQueue queue_; member in class:media::MPEGAudioStreamParserBase
|
| mpeg_audio_stream_parser_base.cc | 80 queue_.Reset();
96 queue_.Push(buf, size);
103 queue_.Peek(&data, &data_size);
146 queue_.Pop(bytes_read);
|
| /external/chromium_org/remoting/protocol/ |
| buffered_socket_writer.h | 65 DataQueue queue_; member in class:remoting::protocol::BufferedSocketWriterBase
|
| /external/chromium_org/third_party/webrtc/modules/desktop_capture/ |
| screen_capturer_mac.mm | 248 ScreenCaptureFrameQueue queue_;
373 queue_.Reset();
401 queue_.MoveToNextFrame();
422 if (!queue_.current_frame())
423 queue_.ReplaceCurrentFrame(CreateFrame());
425 DesktopFrame* current_frame = queue_.current_frame();
448 DesktopFrame* new_frame = queue_.current_frame()->Share();
579 if (queue_.previous_frame()) {
594 CopyRect(queue_.previous_frame()->data() + y_offset,
663 if (queue_.previous_frame())
[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/third_party/leveldatabase/src/util/ |
| env_posix.cc | 521 BGQueue queue_; member in class:leveldb::__anon16118::PosixEnv
545 if (queue_.empty()) {
550 queue_.push_back(BGItem());
551 queue_.back().function = function;
552 queue_.back().arg = arg;
561 while (queue_.empty()) {
565 void (*function)(void*) = queue_.front().function;
566 void* arg = queue_.front().arg;
567 queue_.pop_front();
|
| /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_org/ui/file_manager/file_manager/background/js/ |
| drive_sync_handler.js | 40 this.queue_ = new AsyncUtil.Queue();
111 this.queue_.run(function(callback) {
131 this.queue_.run(function(callback) {
150 this.queue_.run(function(callback) {
|
| /external/chromium_org/media/formats/mp4/ |
| mp4_stream_parser.h | 62 // is the upper bound on what can be removed from |queue_|. Anything below
84 // Checks to see if we have enough data in |queue_| to transition to
102 OffsetByteQueue queue_; member in class:media::mp4::MP4StreamParser
|
| /external/chromium_org/net/socket/ |
| tcp_listen_socket_unittest.cc | 93 queue_.push_back(action);
99 while (queue_.empty())
101 last_action_ = queue_.front();
102 queue_.pop_front();
|
| 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
|
