queue_ 13 base/mac/libdispatch_task_runner.cc : queue_(dispatch_queue_create(name, NULL)), queue_ 15 base/mac/libdispatch_task_runner.cc dispatch_set_context(queue_, this); queue_ 16 base/mac/libdispatch_task_runner.cc dispatch_set_finalizer_f(queue_, &LibDispatchTaskRunner::Finalizer); queue_ 23 base/mac/libdispatch_task_runner.cc if (!queue_) queue_ 38 base/mac/libdispatch_task_runner.cc dispatch_after(time, queue_, run_task); queue_ 40 base/mac/libdispatch_task_runner.cc dispatch_async(queue_, run_task); queue_ 46 base/mac/libdispatch_task_runner.cc return queue_ == dispatch_get_current_queue(); queue_ 57 base/mac/libdispatch_task_runner.cc dispatch_release(queue_); queue_ 58 base/mac/libdispatch_task_runner.cc queue_ = NULL; queue_ 63 base/mac/libdispatch_task_runner.cc return queue_; queue_ 67 base/mac/libdispatch_task_runner.cc if (queue_) { queue_ 68 base/mac/libdispatch_task_runner.cc dispatch_set_context(queue_, NULL); queue_ 69 base/mac/libdispatch_task_runner.cc dispatch_set_finalizer_f(queue_, NULL); queue_ 70 base/mac/libdispatch_task_runner.cc dispatch_release(queue_); queue_ 72 base/mac/libdispatch_task_runner.h dispatch_queue_t queue_; queue_ 152 base/threading/thread_collision_warner_unittest.cc : queue_(queue) {} queue_ 155 base/threading/thread_collision_warner_unittest.cc queue_.push(0); queue_ 156 base/threading/thread_collision_warner_unittest.cc queue_.pop(); queue_ 160 base/threading/thread_collision_warner_unittest.cc NonThreadSafeQueue& queue_; queue_ 210 base/threading/thread_collision_warner_unittest.cc : queue_(queue) {} queue_ 213 base/threading/thread_collision_warner_unittest.cc queue_.push(0); queue_ 214 base/threading/thread_collision_warner_unittest.cc queue_.pop(); queue_ 218 base/threading/thread_collision_warner_unittest.cc NonThreadSafeQueue& queue_; queue_ 270 base/threading/thread_collision_warner_unittest.cc : queue_(queue), queue_ 276 base/threading/thread_collision_warner_unittest.cc queue_.push(0); queue_ 280 base/threading/thread_collision_warner_unittest.cc queue_.pop(); queue_ 284 base/threading/thread_collision_warner_unittest.cc NonThreadSafeQueue& queue_; queue_ 344 base/threading/thread_collision_warner_unittest.cc : queue_(queue), queue_ 350 base/threading/thread_collision_warner_unittest.cc queue_.push(0); queue_ 354 base/threading/thread_collision_warner_unittest.cc queue_.bar(); queue_ 358 base/threading/thread_collision_warner_unittest.cc queue_.pop(); queue_ 362 base/threading/thread_collision_warner_unittest.cc NonThreadSafeQueue& queue_; queue_ 100 cc/layers/tiled_layer_unittest.cc queue_(make_scoped_ptr(new ResourceUpdateQueue)), queue_ 157 cc/layers/tiled_layer_unittest.cc DCHECK(queue_); queue_ 161 cc/layers/tiled_layer_unittest.cc queue_.Pass(), queue_ 164 cc/layers/tiled_layer_unittest.cc queue_ = make_scoped_ptr(new ResourceUpdateQueue); queue_ 177 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), occluded); queue_ 222 cc/layers/tiled_layer_unittest.cc layer1->Update(queue_.get(), occlusion_); queue_ 224 cc/layers/tiled_layer_unittest.cc layer2->Update(queue_.get(), occlusion_); queue_ 249 cc/layers/tiled_layer_unittest.cc scoped_ptr<ResourceUpdateQueue> queue_; queue_ 699 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 885 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 895 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 906 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 923 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 932 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 951 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 1005 cc/layers/tiled_layer_unittest.cc layer_tree_host_->UpdateLayers(queue_.get()); queue_ 1016 cc/layers/tiled_layer_unittest.cc layer_tree_host_->UpdateLayers(queue_.get()); queue_ 1037 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 1058 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 1082 cc/layers/tiled_layer_unittest.cc layer_tree_host_->UpdateLayers(queue_.get()); queue_ 1086 cc/layers/tiled_layer_unittest.cc EXPECT_EQ(6u, queue_->FullUploadSize()); queue_ 1087 cc/layers/tiled_layer_unittest.cc EXPECT_EQ(0u, queue_->PartialUploadSize()); queue_ 1090 cc/layers/tiled_layer_unittest.cc EXPECT_FALSE(queue_->HasMoreUpdates()); queue_ 1098 cc/layers/tiled_layer_unittest.cc layer_tree_host_->UpdateLayers(queue_.get()); queue_ 1102 cc/layers/tiled_layer_unittest.cc EXPECT_EQ(3u, queue_->FullUploadSize()); queue_ 1103 cc/layers/tiled_layer_unittest.cc EXPECT_EQ(3u, queue_->PartialUploadSize()); queue_ 1106 cc/layers/tiled_layer_unittest.cc EXPECT_FALSE(queue_->HasMoreUpdates()); queue_ 1117 cc/layers/tiled_layer_unittest.cc layer_tree_host_->UpdateLayers(queue_.get()); queue_ 1118 cc/layers/tiled_layer_unittest.cc EXPECT_EQ(2u, queue_->FullUploadSize()); queue_ 1119 cc/layers/tiled_layer_unittest.cc EXPECT_EQ(4u, queue_->PartialUploadSize()); queue_ 1122 cc/layers/tiled_layer_unittest.cc EXPECT_FALSE(queue_->HasMoreUpdates()); queue_ 1142 cc/layers/tiled_layer_unittest.cc layer_tree_host_->UpdateLayers(queue_.get()); queue_ 1143 cc/layers/tiled_layer_unittest.cc EXPECT_EQ(6u, queue_->FullUploadSize()); queue_ 1144 cc/layers/tiled_layer_unittest.cc EXPECT_EQ(0u, queue_->PartialUploadSize()); queue_ 1147 cc/layers/tiled_layer_unittest.cc EXPECT_FALSE(queue_->HasMoreUpdates()); queue_ 1158 cc/layers/tiled_layer_unittest.cc layer_tree_host_->UpdateLayers(queue_.get()); queue_ 1159 cc/layers/tiled_layer_unittest.cc EXPECT_EQ(0u, queue_->FullUploadSize()); queue_ 1160 cc/layers/tiled_layer_unittest.cc EXPECT_EQ(4u, queue_->PartialUploadSize()); queue_ 1163 cc/layers/tiled_layer_unittest.cc EXPECT_FALSE(queue_->HasMoreUpdates()); queue_ 1188 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 1217 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1227 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1237 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1266 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1280 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1294 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1320 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1331 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1365 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1408 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1424 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1450 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1486 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1498 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1509 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1522 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1535 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), &occluded); queue_ 1588 cc/layers/tiled_layer_unittest.cc layer_tree_host_->UpdateLayers(queue_.get()); queue_ 1594 cc/layers/tiled_layer_unittest.cc EXPECT_FALSE(queue_->HasMoreUpdates()); queue_ 1630 cc/layers/tiled_layer_unittest.cc layer_tree_host_->UpdateLayers(queue_.get()); queue_ 1636 cc/layers/tiled_layer_unittest.cc EXPECT_FALSE(queue_->HasMoreUpdates()); queue_ 1672 cc/layers/tiled_layer_unittest.cc layer_tree_host_->UpdateLayers(queue_.get()); queue_ 1678 cc/layers/tiled_layer_unittest.cc EXPECT_FALSE(queue_->HasMoreUpdates()); queue_ 1775 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 1784 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 1810 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 1819 cc/layers/tiled_layer_unittest.cc layer->Update(queue_.get(), NULL); queue_ 44 cc/resources/resource_update_controller.cc queue_(queue.Pass()), queue_ 83 cc/resources/resource_update_controller.cc queue_->ClearUploadsToEvictedResources(); queue_ 98 cc/resources/resource_update_controller.cc while (queue_->FullUploadSize()) queue_ 99 cc/resources/resource_update_controller.cc UpdateTexture(queue_->TakeFirstFullUpload()); queue_ 101 cc/resources/resource_update_controller.cc while (queue_->PartialUploadSize()) queue_ 102 cc/resources/resource_update_controller.cc UpdateTexture(queue_->TakeFirstPartialUpload()); queue_ 130 cc/resources/resource_update_controller.cc if (!queue_->FullUploadSize()) queue_ 153 cc/resources/resource_update_controller.cc queue_->FullUploadSize(), UpdateMoreTexturesSize()); queue_ 158 cc/resources/resource_update_controller.cc while (queue_->FullUploadSize() && uploads--) queue_ 159 cc/resources/resource_update_controller.cc UpdateTexture(queue_->TakeFirstFullUpload()); queue_ 73 cc/resources/resource_update_controller.h scoped_ptr<ResourceUpdateQueue> queue_; queue_ 58 cc/resources/resource_update_controller_unittest.cc queue_(make_scoped_ptr(new ResourceUpdateQueue)), queue_ 141 cc/resources/resource_update_controller_unittest.cc queue_->AppendFullUpload(upload); queue_ 157 cc/resources/resource_update_controller_unittest.cc queue_->AppendPartialUpload(upload); queue_ 174 cc/resources/resource_update_controller_unittest.cc queue_.Pass(), queue_ 188 cc/resources/resource_update_controller_unittest.cc scoped_ptr<ResourceUpdateQueue> queue_; queue_ 399 cc/resources/resource_update_controller_unittest.cc queue_.Pass(), queue_ 446 cc/resources/resource_update_controller_unittest.cc queue_.Pass(), queue_ 487 cc/resources/resource_update_controller_unittest.cc queue_.Pass(), queue_ 24 chrome/browser/chromeos/drive/job_queue.cc DCHECK_LT(accepted_priority, static_cast<int>(queue_.size())); queue_ 32 chrome/browser/chromeos/drive/job_queue.cc if (!queue_[priority].empty()) { queue_ 33 chrome/browser/chromeos/drive/job_queue.cc *id = queue_[priority].front(); queue_ 34 chrome/browser/chromeos/drive/job_queue.cc queue_[priority].pop_front(); queue_ 43 chrome/browser/chromeos/drive/job_queue.cc DCHECK_LT(priority, static_cast<int>(queue_.size())); queue_ 45 chrome/browser/chromeos/drive/job_queue.cc jobs->assign(queue_[priority].begin(), queue_[priority].end()); queue_ 49 chrome/browser/chromeos/drive/job_queue.cc DCHECK_LT(priority, static_cast<int>(queue_.size())); queue_ 51 chrome/browser/chromeos/drive/job_queue.cc queue_[priority].push_back(id); queue_ 61 chrome/browser/chromeos/drive/job_queue.cc for (size_t i = 0; i < queue_.size(); ++i) queue_ 62 chrome/browser/chromeos/drive/job_queue.cc pending += queue_[i].size(); queue_ 70 chrome/browser/chromeos/drive/job_queue.cc for (size_t i = 0; i < queue_.size(); ++i) queue_ 71 chrome/browser/chromeos/drive/job_queue.cc count += queue_[i].size(); queue_ 76 chrome/browser/chromeos/drive/job_queue.cc for (size_t i = 0; i < queue_.size(); ++i) { queue_ 78 chrome/browser/chromeos/drive/job_queue.cc std::find(queue_[i].begin(), queue_[i].end(), id); queue_ 79 chrome/browser/chromeos/drive/job_queue.cc if (iter != queue_[i].end()) { queue_ 80 chrome/browser/chromeos/drive/job_queue.cc queue_[i].erase(iter); queue_ 57 chrome/browser/chromeos/drive/job_queue.h std::vector<std::deque<JobID> > queue_; queue_ 178 chrome/browser/chromeos/drive/job_scheduler.cc queue_[i].reset(new JobQueue(kMaxJobCount[i], NUM_CONTEXT_TYPES)); queue_ 188 chrome/browser/chromeos/drive/job_scheduler.cc num_queued_jobs += queue_[i]->GetNumberOfJobs(); queue_ 742 chrome/browser/chromeos/drive/job_scheduler.cc queue_[queue_type]->Push(job_id, job_entry->context.type); queue_ 761 chrome/browser/chromeos/drive/job_scheduler.cc queue_[queue_type]->GetQueuedJobs(USER_INITIATED, &jobs); queue_ 783 chrome/browser/chromeos/drive/job_scheduler.cc if (!queue_[queue_type]->PopForRun(accepted_priority, &job_id)) queue_ 851 chrome/browser/chromeos/drive/job_scheduler.cc queue_[queue_type]->MarkFinished(job_id); queue_ 1112 chrome/browser/chromeos/drive/job_scheduler.cc queue_[GetJobQueueType(job->job_info.job_type)]->Remove(job->job_info.job_id); queue_ 1137 chrome/browser/chromeos/drive/job_scheduler.cc return QueueTypeToString(type) + " " + queue_[type]->ToString(); queue_ 383 chrome/browser/chromeos/drive/job_scheduler.h scoped_ptr<JobQueue> queue_[NUM_QUEUES]; queue_ 73 chrome/browser/chromeos/drive/search_metadata.cc bool empty() const { return queue_.empty(); } queue_ 75 chrome/browser/chromeos/drive/search_metadata.cc size_t size() const { return queue_.size(); } queue_ 77 chrome/browser/chromeos/drive/search_metadata.cc const T* top() const { return queue_.top(); } queue_ 79 chrome/browser/chromeos/drive/search_metadata.cc void push(T* x) { queue_.push(x); } queue_ 85 chrome/browser/chromeos/drive/search_metadata.cc T* saved_top = queue_.top(); queue_ 86 chrome/browser/chromeos/drive/search_metadata.cc queue_.pop(); queue_ 91 chrome/browser/chromeos/drive/search_metadata.cc std::priority_queue<T*, std::vector<T*>, Compare> queue_; queue_ 61 chrome/browser/extensions/activity_log/activity_database_unittest.cc std::vector<scoped_refptr<Action> > queue_; queue_ 84 chrome/browser/extensions/activity_log/activity_database_unittest.cc for (i = 0; i < queue_.size(); i++) { queue_ 85 chrome/browser/extensions/activity_log/activity_database_unittest.cc const Action& action = *queue_[i]; queue_ 98 chrome/browser/extensions/activity_log/activity_database_unittest.cc queue_.clear(); queue_ 104 chrome/browser/extensions/activity_log/activity_database_unittest.cc queue_.push_back(action); queue_ 105 chrome/browser/extensions/activity_log/activity_database_unittest.cc db->AdviseFlush(queue_.size()); queue_ 75 chrome/browser/printing/print_job_manager.cc if (!queue_) queue_ 76 chrome/browser/printing/print_job_manager.cc queue_ = new PrintQueriesQueue(); queue_ 77 chrome/browser/printing/print_job_manager.cc return queue_; queue_ 86 chrome/browser/printing/print_job_manager.cc if (queue_) queue_ 87 chrome/browser/printing/print_job_manager.cc queue_->Shutdown(); queue_ 88 chrome/browser/printing/print_job_manager.cc queue_ = NULL; queue_ 95 chrome/browser/printing/print_job_manager.h scoped_refptr<PrintQueriesQueue> queue_; queue_ 60 chrome/browser/printing/print_view_manager_base.cc DCHECK(queue_); queue_ 480 chrome/browser/printing/print_view_manager_base.cc scoped_refptr<PrinterQuery> queued_query = queue_->PopPrinterQuery(cookie); queue_ 512 chrome/browser/printing/print_view_manager_base.cc queue_->SetDestination(NULL); queue_ 522 chrome/browser/printing/print_view_manager_base.cc printer_query = queue_->PopPrinterQuery(cookie); queue_ 159 chrome/browser/printing/print_view_manager_base.h scoped_refptr<printing::PrintQueriesQueue> queue_; queue_ 98 chrome/browser/printing/printing_message_filter.cc DCHECK(queue_); queue_ 314 chrome/browser/printing/printing_message_filter.cc printer_query = queue_->PopPrinterQuery(0); queue_ 316 chrome/browser/printing/printing_message_filter.cc printer_query = queue_->CreatePrinterQuery(); queue_ 351 chrome/browser/printing/printing_message_filter.cc queue_->QueuePrinterQuery(printer_query.get()); queue_ 362 chrome/browser/printing/printing_message_filter.cc queue_->PopPrinterQuery(params.cookie); queue_ 364 chrome/browser/printing/printing_message_filter.cc printer_query = queue_->CreatePrinterQuery(); queue_ 411 chrome/browser/printing/printing_message_filter.cc queue_->QueuePrinterQuery(printer_query.get()); queue_ 438 chrome/browser/printing/printing_message_filter.cc printer_query = queue_->PopPrinterQuery(document_cookie); queue_ 440 chrome/browser/printing/printing_message_filter.cc printer_query = queue_->CreatePrinterQuery(); queue_ 465 chrome/browser/printing/printing_message_filter.cc queue_->QueuePrinterQuery(printer_query.get()); queue_ 138 chrome/browser/printing/printing_message_filter.h scoped_refptr<printing::PrintQueriesQueue> queue_; queue_ 22 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue.cc queue_.push_back(OriginOperation(origin, type)); queue_ 26 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue.cc DCHECK(!queue_.empty()); queue_ 27 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue.cc OriginOperation operation = queue_.front(); queue_ 28 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue.cc queue_.pop_front(); queue_ 33 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue.cc if (queue_.empty()) queue_ 36 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue.cc for (std::deque<OriginOperation>::const_iterator iter = queue_.begin(); queue_ 37 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue.cc iter != queue_.end(); ++iter) { queue_ 42 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue.h size_t size() const { return queue_.size(); } queue_ 43 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue.h bool empty() const { return queue_.empty(); } queue_ 46 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue.h std::deque<OriginOperation> queue_; queue_ 27 content/browser/indexed_db/indexed_db_transaction.cc while (!queue_.empty()) queue_ 28 content/browser/indexed_db/indexed_db_transaction.cc queue_.pop(); queue_ 32 content/browser/indexed_db/indexed_db_transaction.cc DCHECK(!queue_.empty()); queue_ 33 content/browser/indexed_db/indexed_db_transaction.cc Operation task(queue_.front()); queue_ 34 content/browser/indexed_db/indexed_db_transaction.cc queue_.pop(); queue_ 114 content/browser/indexed_db/indexed_db_transaction.h bool empty() const { return queue_.empty(); } queue_ 115 content/browser/indexed_db/indexed_db_transaction.h void push(Operation task) { queue_.push(task); } queue_ 120 content/browser/indexed_db/indexed_db_transaction.h std::queue<Operation> queue_; queue_ 35 content/browser/loader/resource_scheduler.cc Iterator(NetQueue* queue) : queue_(queue) { queue_ 37 content/browser/loader/resource_scheduler.cc current_pointer_ = queue_->FirstMax(); queue_ 41 content/browser/loader/resource_scheduler.cc current_pointer_ = queue_->GetNextTowardsLastMin(current_pointer_); queue_ 60 content/browser/loader/resource_scheduler.cc NetQueue* queue_; queue_ 64 content/browser/loader/resource_scheduler.cc RequestQueue() : queue_(net::NUM_PRIORITIES) {} queue_ 71 content/browser/loader/resource_scheduler.cc NetQueue::Pointer pointer = queue_.Insert(request, priority); queue_ 81 content/browser/loader/resource_scheduler.cc queue_.Erase(it->second); queue_ 87 content/browser/loader/resource_scheduler.cc return queue_.FirstMax().value(); queue_ 91 content/browser/loader/resource_scheduler.cc return Iterator(&queue_); queue_ 100 content/browser/loader/resource_scheduler.cc bool IsEmpty() const { return queue_.size() == 0; } queue_ 105 content/browser/loader/resource_scheduler.cc NetQueue queue_; queue_ 37 content/browser/renderer_host/input/gesture_event_queue_unittest.cc queue_.reset(new GestureEventQueue(this, this)); queue_ 43 content/browser/renderer_host/input/gesture_event_queue_unittest.cc queue_.reset(); queue_ 192 content/browser/renderer_host/input/gesture_event_queue_unittest.cc return queue_.get(); queue_ 196 content/browser/renderer_host/input/gesture_event_queue_unittest.cc scoped_ptr<GestureEventQueue> queue_; queue_ 50 content/browser/renderer_host/input/touch_event_queue_unittest.cc queue_.reset(); queue_ 76 content/browser/renderer_host/input/touch_event_queue_unittest.cc queue_->OnGestureScrollEvent( queue_ 85 content/browser/renderer_host/input/touch_event_queue_unittest.cc queue_->SetAckTimeoutEnabled(true, timeout_delay); queue_ 94 content/browser/renderer_host/input/touch_event_queue_unittest.cc queue_->QueueEvent(TouchEventWithLatencyInfo(event, ui::LatencyInfo())); queue_ 100 content/browser/renderer_host/input/touch_event_queue_unittest.cc queue_->OnGestureScrollEvent( queue_ 105 content/browser/renderer_host/input/touch_event_queue_unittest.cc queue_->ProcessTouchAck(ack_result, ui::LatencyInfo()); queue_ 113 content/browser/renderer_host/input/touch_event_queue_unittest.cc queue_->OnGestureEventAck(event, ack_result); queue_ 172 content/browser/renderer_host/input/touch_event_queue_unittest.cc return queue_->IsPendingAckTouchStart(); queue_ 176 content/browser/renderer_host/input/touch_event_queue_unittest.cc queue_->OnHasTouchEventHandlers(has_handlers); queue_ 180 content/browser/renderer_host/input/touch_event_queue_unittest.cc queue_->SetAckTimeoutEnabled(false, base::TimeDelta()); queue_ 184 content/browser/renderer_host/input/touch_event_queue_unittest.cc return queue_->ack_timeout_enabled(); queue_ 188 content/browser/renderer_host/input/touch_event_queue_unittest.cc return queue_->IsTimeoutRunningForTesting(); queue_ 192 content/browser/renderer_host/input/touch_event_queue_unittest.cc return queue_->size(); queue_ 196 content/browser/renderer_host/input/touch_event_queue_unittest.cc return queue_->GetLatestEventForTesting().event; queue_ 225 content/browser/renderer_host/input/touch_event_queue_unittest.cc queue_.reset(new TouchEventQueue(this, mode, slop_length_dips)); queue_ 226 content/browser/renderer_host/input/touch_event_queue_unittest.cc queue_->OnHasTouchEventHandlers(true); queue_ 229 content/browser/renderer_host/input/touch_event_queue_unittest.cc scoped_ptr<TouchEventQueue> queue_; queue_ 1332 content/shell/renderer/test_runner/test_runner.cc if (!queue_.empty()) { queue_ 1342 content/shell/renderer/test_runner/test_runner.cc while (!queue_.empty()) { queue_ 1343 content/shell/renderer/test_runner/test_runner.cc delete queue_.front(); queue_ 1344 content/shell/renderer/test_runner/test_runner.cc queue_.pop_front(); queue_ 1353 content/shell/renderer/test_runner/test_runner.cc queue_.push_back(work); queue_ 1358 content/shell/renderer/test_runner/test_runner.cc while (!queue_.empty()) { queue_ 1359 content/shell/renderer/test_runner/test_runner.cc bool startedLoad = queue_.front()->Run(controller_->delegate_, queue_ 1361 content/shell/renderer/test_runner/test_runner.cc delete queue_.front(); queue_ 1362 content/shell/renderer/test_runner/test_runner.cc queue_.pop_front(); queue_ 152 content/shell/renderer/test_runner/test_runner.h bool is_empty() { return queue_.empty(); } queue_ 167 content/shell/renderer/test_runner/test_runner.h std::deque<WorkItem*> queue_; queue_ 260 courgette/adjustment_method_2.cc LabelInfo* top_candidate() const { return queue_.begin()->second; } queue_ 270 courgette/adjustment_method_2.cc queue_.erase(ScoreAndLabel(old_score, p->first)); queue_ 275 courgette/adjustment_method_2.cc queue_.insert(ScoreAndLabel(new_score, model_info)); queue_ 280 courgette/adjustment_method_2.cc queue_.insert(ScoreAndLabel(new_score, model_info)); queue_ 282 courgette/adjustment_method_2.cc LOG_ASSERT(queue_.size() == label_to_score_.size()); queue_ 288 courgette/adjustment_method_2.cc Queue::const_iterator p = queue_.begin(); queue_ 289 courgette/adjustment_method_2.cc if (p != queue_.end()) { queue_ 292 courgette/adjustment_method_2.cc if (p != queue_.end()) { queue_ 327 courgette/adjustment_method_2.cc for (Queue::iterator q = queue_.begin(); q != queue_.end(); ++q) { queue_ 349 courgette/adjustment_method_2.cc Queue queue_; queue_ 748 courgette/adjustment_method_2.cc bool empty() const { return queue_.empty(); } queue_ 750 courgette/adjustment_method_2.cc const ScoreAndLabel& first() const { return *queue_.begin(); } queue_ 754 courgette/adjustment_method_2.cc for (Queue::const_iterator p = queue_.begin(); p != queue_.end(); ++p) { queue_ 773 courgette/adjustment_method_2.cc queue_.erase(ScoreAndLabel(old_score, candidates->program_info())); queue_ 777 courgette/adjustment_method_2.cc queue_.insert(ScoreAndLabel(new_score, candidates->program_info())); queue_ 793 courgette/adjustment_method_2.cc Queue queue_; queue_ 64 extensions/browser/extension_host.cc queue_.push_back(host); queue_ 70 extensions/browser/extension_host.cc Queue::iterator it = std::find(queue_.begin(), queue_.end(), host); queue_ 71 extensions/browser/extension_host.cc if (it != queue_.end()) queue_ 72 extensions/browser/extension_host.cc queue_.erase(it); queue_ 95 extensions/browser/extension_host.cc if (queue_.empty()) queue_ 98 extensions/browser/extension_host.cc queue_.front()->CreateRenderViewNow(); queue_ 99 extensions/browser/extension_host.cc queue_.pop_front(); queue_ 101 extensions/browser/extension_host.cc if (!queue_.empty()) queue_ 106 extensions/browser/extension_host.cc Queue queue_; queue_ 24 media/base/decoder_buffer_queue.cc queue_.push_back(buffer); queue_ 55 media/base/decoder_buffer_queue.cc scoped_refptr<DecoderBuffer> buffer = queue_.front(); queue_ 56 media/base/decoder_buffer_queue.cc queue_.pop_front(); queue_ 72 media/base/decoder_buffer_queue.cc queue_.clear(); queue_ 79 media/base/decoder_buffer_queue.cc return queue_.empty(); queue_ 59 media/base/decoder_buffer_queue.h Queue queue_; queue_ 16 media/formats/common/offset_byte_queue.cc queue_.Reset(); queue_ 23 media/formats/common/offset_byte_queue.cc queue_.Push(buf, size); queue_ 34 media/formats/common/offset_byte_queue.cc queue_.Pop(count); queue_ 61 media/formats/common/offset_byte_queue.cc queue_.Peek(&buf_, &size_); queue_ 56 media/formats/common/offset_byte_queue.h ByteQueue queue_; queue_ 21 media/formats/common/offset_byte_queue_unittest.cc queue_.reset(new OffsetByteQueue); queue_ 22 media/formats/common/offset_byte_queue_unittest.cc queue_->Push(buf, sizeof(buf)); queue_ 23 media/formats/common/offset_byte_queue_unittest.cc queue_->Push(buf, sizeof(buf)); queue_ 24 media/formats/common/offset_byte_queue_unittest.cc queue_->Pop(384); queue_ 31 media/formats/common/offset_byte_queue_unittest.cc scoped_ptr<OffsetByteQueue> queue_; queue_ 35 media/formats/common/offset_byte_queue_unittest.cc EXPECT_EQ(384, queue_->head()); queue_ 36 media/formats/common/offset_byte_queue_unittest.cc EXPECT_EQ(512, queue_->tail()); queue_ 41 media/formats/common/offset_byte_queue_unittest.cc queue_->Peek(&buf, &size); queue_ 51 media/formats/common/offset_byte_queue_unittest.cc queue_->PeekAt(400, &buf, &size); queue_ 52 media/formats/common/offset_byte_queue_unittest.cc EXPECT_EQ(queue_->tail() - 400, size); queue_ 55 media/formats/common/offset_byte_queue_unittest.cc queue_->PeekAt(512, &buf, &size); queue_ 61 media/formats/common/offset_byte_queue_unittest.cc EXPECT_TRUE(queue_->Trim(128)); queue_ 62 media/formats/common/offset_byte_queue_unittest.cc EXPECT_TRUE(queue_->Trim(384)); queue_ 63 media/formats/common/offset_byte_queue_unittest.cc EXPECT_EQ(384, queue_->head()); queue_ 64 media/formats/common/offset_byte_queue_unittest.cc EXPECT_EQ(512, queue_->tail()); queue_ 66 media/formats/common/offset_byte_queue_unittest.cc EXPECT_TRUE(queue_->Trim(400)); queue_ 67 media/formats/common/offset_byte_queue_unittest.cc EXPECT_EQ(400, queue_->head()); queue_ 68 media/formats/common/offset_byte_queue_unittest.cc EXPECT_EQ(512, queue_->tail()); queue_ 72 media/formats/common/offset_byte_queue_unittest.cc queue_->PeekAt(400, &buf, &size); queue_ 73 media/formats/common/offset_byte_queue_unittest.cc EXPECT_EQ(queue_->tail() - 400, size); queue_ 78 media/formats/common/offset_byte_queue_unittest.cc EXPECT_TRUE(queue_->Trim(512)); queue_ 79 media/formats/common/offset_byte_queue_unittest.cc EXPECT_EQ(512, queue_->head()); queue_ 80 media/formats/common/offset_byte_queue_unittest.cc queue_->Peek(&buf, &size); queue_ 85 media/formats/common/offset_byte_queue_unittest.cc EXPECT_FALSE(queue_->Trim(513)); queue_ 89 media/formats/common/offset_byte_queue_unittest.cc EXPECT_TRUE(queue_->Trim(512)); queue_ 72 media/formats/mp4/mp4_stream_parser.cc queue_.Reset(); queue_ 90 media/formats/mp4/mp4_stream_parser.cc queue_.Push(buf, size); queue_ 127 media/formats/mp4/mp4_stream_parser.cc queue_.Peek(&buf, &size); queue_ 137 media/formats/mp4/mp4_stream_parser.cc moof_head_ = queue_.head(); queue_ 141 media/formats/mp4/mp4_stream_parser.cc mdat_tail_ = queue_.head() + reader->size(); queue_ 153 media/formats/mp4/mp4_stream_parser.cc queue_.Pop(reader->size()); queue_ 409 media/formats/mp4/mp4_stream_parser.cc if (!queue_.Trim(mdat_tail_)) queue_ 426 media/formats/mp4/mp4_stream_parser.cc queue_.Peek(&buf, &buf_size); queue_ 444 media/formats/mp4/mp4_stream_parser.cc queue_.PeekAt(runs_->aux_info_offset() + moof_head_, &buf, &buf_size); queue_ 450 media/formats/mp4/mp4_stream_parser.cc queue_.PeekAt(runs_->sample_offset() + moof_head_, &buf, &buf_size); queue_ 554 media/formats/mp4/mp4_stream_parser.cc queue_.PeekAt(mdat_tail_, &buf, &size); queue_ 568 media/formats/mp4/mp4_stream_parser.cc queue_.Trim(std::min(mdat_tail_, offset)); queue_ 90 media/formats/mp4/mp4_stream_parser.h OffsetByteQueue queue_; queue_ 78 media/formats/mpeg/mpeg_audio_stream_parser_base.cc queue_.Reset(); queue_ 94 media/formats/mpeg/mpeg_audio_stream_parser_base.cc queue_.Push(buf, size); queue_ 101 media/formats/mpeg/mpeg_audio_stream_parser_base.cc queue_.Peek(&data, &data_size); queue_ 144 media/formats/mpeg/mpeg_audio_stream_parser_base.cc queue_.Pop(bytes_read); queue_ 130 media/formats/mpeg/mpeg_audio_stream_parser_base.h ByteQueue queue_; queue_ 38 media/midi/midi_message_queue.cc queue_.insert(queue_.end(), data.begin(), data.end()); queue_ 42 media/midi/midi_message_queue.cc queue_.insert(queue_.end(), data, data + length); queue_ 49 media/midi/midi_message_queue.cc if (queue_.empty()) queue_ 52 media/midi/midi_message_queue.cc const uint8 next = queue_.front(); queue_ 53 media/midi/midi_message_queue.cc queue_.pop_front(); queue_ 64 media/midi/midi_message_queue.h std::deque<uint8> queue_; queue_ 19 mojo/public/cpp/bindings/lib/message_queue.cc while (!queue_.empty()) queue_ 24 mojo/public/cpp/bindings/lib/message_queue.cc return queue_.empty(); queue_ 28 mojo/public/cpp/bindings/lib/message_queue.cc assert(!queue_.empty()); queue_ 29 mojo/public/cpp/bindings/lib/message_queue.cc return queue_.front(); queue_ 33 mojo/public/cpp/bindings/lib/message_queue.cc queue_.push(new Message()); queue_ 34 mojo/public/cpp/bindings/lib/message_queue.cc queue_.back()->Swap(message); queue_ 38 mojo/public/cpp/bindings/lib/message_queue.cc assert(!queue_.empty()); queue_ 39 mojo/public/cpp/bindings/lib/message_queue.cc queue_.front()->Swap(message); queue_ 44 mojo/public/cpp/bindings/lib/message_queue.cc assert(!queue_.empty()); queue_ 45 mojo/public/cpp/bindings/lib/message_queue.cc delete queue_.front(); queue_ 46 mojo/public/cpp/bindings/lib/message_queue.cc queue_.pop(); queue_ 39 mojo/public/cpp/bindings/lib/message_queue.h std::queue<Message*> queue_; queue_ 26 mojo/public/cpp/bindings/tests/connector_unittest.cc queue_.Push(message); queue_ 36 mojo/public/cpp/bindings/tests/connector_unittest.cc return queue_.IsEmpty(); queue_ 40 mojo/public/cpp/bindings/tests/connector_unittest.cc queue_.Pop(message); queue_ 44 mojo/public/cpp/bindings/tests/connector_unittest.cc internal::MessageQueue queue_; queue_ 37 mojo/public/cpp/bindings/tests/router_unittest.cc explicit MessageAccumulator(internal::MessageQueue* queue) : queue_(queue) { queue_ 41 mojo/public/cpp/bindings/tests/router_unittest.cc queue_->Push(message); queue_ 51 mojo/public/cpp/bindings/tests/router_unittest.cc internal::MessageQueue* queue_; queue_ 18 mojo/system/message_in_transit_queue.cc queue_.swap(other->queue_); queue_ 29 mojo/system/message_in_transit_queue.cc STLDeleteElements(&queue_); queue_ 33 mojo/system/message_in_transit_queue.h return queue_.empty(); queue_ 37 mojo/system/message_in_transit_queue.h queue_.push_back(message.release()); queue_ 41 mojo/system/message_in_transit_queue.h MessageInTransit* rv = queue_.front(); queue_ 42 mojo/system/message_in_transit_queue.h queue_.pop_front(); queue_ 47 mojo/system/message_in_transit_queue.h return queue_.front(); queue_ 51 mojo/system/message_in_transit_queue.h delete queue_.front(); queue_ 52 mojo/system/message_in_transit_queue.h queue_.pop_front(); queue_ 60 mojo/system/message_in_transit_queue.h std::deque<MessageInTransit*> queue_; queue_ 18 net/base/prioritized_dispatcher.cc : queue_(limits.reserved_slots.size()), queue_ 35 net/base/prioritized_dispatcher.cc return queue_.Insert(job, priority); queue_ 47 net/base/prioritized_dispatcher.cc return queue_.InsertAtFront(job, priority); queue_ 51 net/base/prioritized_dispatcher.cc queue_.Erase(handle); queue_ 55 net/base/prioritized_dispatcher.cc Handle handle = queue_.FirstMin(); queue_ 76 net/base/prioritized_dispatcher.cc queue_.Erase(handle); queue_ 77 net/base/prioritized_dispatcher.cc return queue_.Insert(job, priority); queue_ 100 net/base/prioritized_dispatcher.cc DCHECK_EQ(queue_.num_priorities(), limits.reserved_slots.size()); queue_ 121 net/base/prioritized_dispatcher.cc SetLimits(Limits(queue_.num_priorities(), 0)); queue_ 130 net/base/prioritized_dispatcher.cc queue_.Erase(handle); queue_ 137 net/base/prioritized_dispatcher.cc Handle handle = queue_.FirstMax(); queue_ 139 net/base/prioritized_dispatcher.cc DCHECK_EQ(0u, queue_.size()); queue_ 72 net/base/prioritized_dispatcher.h size_t num_queued_jobs() const { return queue_.size(); } queue_ 125 net/base/prioritized_dispatcher.h PriorityQueue<Job*> queue_; queue_ 26 net/base/priority_queue_unittest.cc PriorityQueueTest() : queue_(kNumPriorities) {} queue_ 31 net/base/priority_queue_unittest.cc EXPECT_EQ(i, queue_.size()); queue_ 32 net/base/priority_queue_unittest.cc pointers_[i] = queue_.Insert(static_cast<int>(i), kPriorities[i]); queue_ 33 net/base/priority_queue_unittest.cc EXPECT_FALSE(queue_.empty()); queue_ 35 net/base/priority_queue_unittest.cc EXPECT_EQ(kNumElements, queue_.size()); queue_ 39 net/base/priority_queue_unittest.cc EXPECT_TRUE(queue_.empty()); queue_ 40 net/base/priority_queue_unittest.cc EXPECT_EQ(0u, queue_.size()); queue_ 41 net/base/priority_queue_unittest.cc EXPECT_TRUE(queue_.FirstMin().is_null()); queue_ 42 net/base/priority_queue_unittest.cc EXPECT_TRUE(queue_.LastMin().is_null()); queue_ 43 net/base/priority_queue_unittest.cc EXPECT_TRUE(queue_.FirstMax().is_null()); queue_ 44 net/base/priority_queue_unittest.cc EXPECT_TRUE(queue_.LastMax().is_null()); queue_ 47 net/base/priority_queue_unittest.cc PriorityQueue<int> queue_; queue_ 56 net/base/priority_queue_unittest.cc queue_.Clear(); queue_ 62 net/base/priority_queue_unittest.cc EXPECT_EQ(kNumElements - i, queue_.size()); queue_ 64 net/base/priority_queue_unittest.cc EXPECT_TRUE(queue_.FirstMin().Equals(pointers_[kFirstMinOrder[i]])); queue_ 65 net/base/priority_queue_unittest.cc EXPECT_EQ(kFirstMinOrder[i], queue_.FirstMin().value()); queue_ 66 net/base/priority_queue_unittest.cc queue_.Erase(queue_.FirstMin()); queue_ 73 net/base/priority_queue_unittest.cc EXPECT_EQ(kLastMinOrder[i], queue_.LastMin().value()); queue_ 74 net/base/priority_queue_unittest.cc queue_.Erase(queue_.LastMin()); queue_ 80 net/base/priority_queue_unittest.cc PriorityQueue<int>::Pointer p = queue_.FirstMax(); queue_ 83 net/base/priority_queue_unittest.cc p = queue_.GetNextTowardsLastMin(p), ++i) { queue_ 88 net/base/priority_queue_unittest.cc queue_.Clear(); queue_ 93 net/base/priority_queue_unittest.cc PriorityQueue<int>::Pointer current = queue_.FirstMax(); queue_ 97 net/base/priority_queue_unittest.cc PriorityQueue<int>::Pointer next = queue_.GetNextTowardsLastMin(current); queue_ 98 net/base/priority_queue_unittest.cc queue_.Erase(current); queue_ 107 net/base/priority_queue_unittest.cc EXPECT_EQ(kFirstMaxOrder[i], queue_.FirstMax().value()); queue_ 108 net/base/priority_queue_unittest.cc queue_.Erase(queue_.FirstMax()); queue_ 115 net/base/priority_queue_unittest.cc EXPECT_EQ(kLastMaxOrderErase[i], queue_.LastMax().value()); queue_ 116 net/base/priority_queue_unittest.cc queue_.Erase(queue_.LastMax()); queue_ 122 net/base/priority_queue_unittest.cc queue_.Erase(pointers_[2]); queue_ 123 net/base/priority_queue_unittest.cc queue_.Erase(pointers_[3]); queue_ 128 net/base/priority_queue_unittest.cc EXPECT_EQ(expected_order[i], queue_.FirstMin().value()); queue_ 129 net/base/priority_queue_unittest.cc queue_.Erase(queue_.FirstMin()); queue_ 135 net/base/priority_queue_unittest.cc queue_.InsertAtFront(9, 2); queue_ 136 net/base/priority_queue_unittest.cc queue_.InsertAtFront(10, 0); queue_ 137 net/base/priority_queue_unittest.cc queue_.InsertAtFront(11, 1); queue_ 138 net/base/priority_queue_unittest.cc queue_.InsertAtFront(12, 1); queue_ 143 net/base/priority_queue_unittest.cc EXPECT_EQ(expected_order[i], queue_.FirstMin().value()); queue_ 144 net/base/priority_queue_unittest.cc queue_.Erase(queue_.FirstMin()); queue_ 93 net/socket/tcp_listen_socket_unittest.cc queue_.push_back(action); queue_ 99 net/socket/tcp_listen_socket_unittest.cc while (queue_.empty()) queue_ 101 net/socket/tcp_listen_socket_unittest.cc last_action_ = queue_.front(); queue_ 102 net/socket/tcp_listen_socket_unittest.cc queue_.pop_front(); queue_ 109 net/socket/tcp_listen_socket_unittest.h std::deque<TCPListenSocketTestAction> queue_; queue_ 20 net/spdy/spdy_read_queue.cc DCHECK_EQ(queue_.empty(), total_size_ == 0); queue_ 21 net/spdy/spdy_read_queue.cc return queue_.empty(); queue_ 31 net/spdy/spdy_read_queue.cc queue_.push_back(buffer.release()); queue_ 37 net/spdy/spdy_read_queue.cc while (!queue_.empty() && bytes_copied < len) { queue_ 38 net/spdy/spdy_read_queue.cc SpdyBuffer* buffer = queue_.front(); queue_ 44 net/spdy/spdy_read_queue.cc delete queue_.front(); queue_ 45 net/spdy/spdy_read_queue.cc queue_.pop_front(); queue_ 55 net/spdy/spdy_read_queue.cc STLDeleteElements(&queue_); queue_ 56 net/spdy/spdy_read_queue.cc queue_.clear(); queue_ 43 net/spdy/spdy_read_queue.h std::deque<SpdyBuffer*> queue_; queue_ 37 net/spdy/spdy_write_queue.cc if (!queue_[i].empty()) queue_ 51 net/spdy/spdy_write_queue.cc queue_[priority].push_back( queue_ 59 net/spdy/spdy_write_queue.cc if (!queue_[i].empty()) { queue_ 60 net/spdy/spdy_write_queue.cc PendingWrite pending_write = queue_[i].front(); queue_ 61 net/spdy/spdy_write_queue.cc queue_[i].pop_front(); queue_ 86 net/spdy/spdy_write_queue.cc for (std::deque<PendingWrite>::const_iterator it = queue_[i].begin(); queue_ 87 net/spdy/spdy_write_queue.cc it != queue_[i].end(); ++it) { queue_ 94 net/spdy/spdy_write_queue.cc std::deque<PendingWrite>* queue = &queue_[priority]; queue_ 112 net/spdy/spdy_write_queue.cc std::deque<PendingWrite>* queue = &queue_[i]; queue_ 130 net/spdy/spdy_write_queue.cc for (std::deque<PendingWrite>::iterator it = queue_[i].begin(); queue_ 131 net/spdy/spdy_write_queue.cc it != queue_[i].end(); ++it) { queue_ 134 net/spdy/spdy_write_queue.cc queue_[i].clear(); queue_ 82 net/spdy/spdy_write_queue.h std::deque<PendingWrite> queue_[NUM_PRIORITIES]; queue_ 33 net/websockets/websocket_throttle.cc DCHECK(queue_.empty()); queue_ 43 net/websockets/websocket_throttle.cc if (queue_.size() >= kMaxWebSocketJobsThrottled) queue_ 46 net/websockets/websocket_throttle.cc queue_.push_back(job); queue_ 75 net/websockets/websocket_throttle.cc std::find(queue_.begin(), queue_.end(), job); queue_ 76 net/websockets/websocket_throttle.cc if (queue_iter == queue_.end()) queue_ 78 net/websockets/websocket_throttle.cc queue_.erase(queue_iter); queue_ 68 net/websockets/websocket_throttle.h ConnectingQueue queue_; queue_ 50 remoting/host/screen_capturer_fake.cc queue_.MoveToNextFrame(); queue_ 52 remoting/host/screen_capturer_fake.cc if (!queue_.current_frame()) { queue_ 64 remoting/host/screen_capturer_fake.cc queue_.ReplaceCurrentFrame(frame.release()); queue_ 67 remoting/host/screen_capturer_fake.cc DCHECK(queue_.current_frame()); queue_ 70 remoting/host/screen_capturer_fake.cc queue_.current_frame()->mutable_updated_region()->SetRect( queue_ 72 remoting/host/screen_capturer_fake.cc queue_.current_frame()->set_capture_time_ms( queue_ 75 remoting/host/screen_capturer_fake.cc callback_->OnCaptureCompleted(queue_.current_frame()->Share()); queue_ 96 remoting/host/screen_capturer_fake.cc webrtc::DesktopFrame* frame = queue_.current_frame(); queue_ 134 remoting/host/screen_capturer_fake.cc queue_.Reset(); queue_ 55 remoting/host/screen_capturer_fake.h webrtc::ScreenCaptureFrameQueue queue_; queue_ 54 remoting/protocol/buffered_socket_writer.cc queue_.push_back(new PendingPacket(data, done_task)); queue_ 140 remoting/protocol/buffered_socket_writer.cc STLDeleteElements(&queue_); queue_ 151 remoting/protocol/buffered_socket_writer.cc return queue_.size(); queue_ 163 remoting/protocol/buffered_socket_writer.cc STLDeleteElements(&queue_); queue_ 167 remoting/protocol/buffered_socket_writer.cc base::Closure result = queue_.front()->done_task; queue_ 168 remoting/protocol/buffered_socket_writer.cc delete queue_.front(); queue_ 169 remoting/protocol/buffered_socket_writer.cc queue_.pop_front(); queue_ 179 remoting/protocol/buffered_socket_writer.cc if (queue_.empty()) { queue_ 183 remoting/protocol/buffered_socket_writer.cc current_buf_ = new net::DrainableIOBuffer(queue_.front()->data.get(), queue_ 184 remoting/protocol/buffered_socket_writer.cc queue_.front()->data->size()); queue_ 214 remoting/protocol/buffered_socket_writer.cc if (queue_.empty()) { queue_ 218 remoting/protocol/buffered_socket_writer.cc *buffer = queue_.front()->data.get(); queue_ 219 remoting/protocol/buffered_socket_writer.cc *size = queue_.front()->data->size(); queue_ 223 remoting/protocol/buffered_socket_writer.cc DCHECK_EQ(written, queue_.front()->data->size()); queue_ 224 remoting/protocol/buffered_socket_writer.cc buffer_size_ -= queue_.front()->data->size(); queue_ 65 remoting/protocol/buffered_socket_writer.h DataQueue queue_; queue_ 788 third_party/leveldatabase/env_chromium.cc if (queue_.empty()) { queue_ 793 third_party/leveldatabase/env_chromium.cc queue_.push_back(BGItem()); queue_ 794 third_party/leveldatabase/env_chromium.cc queue_.back().function = function; queue_ 795 third_party/leveldatabase/env_chromium.cc queue_.back().arg = arg; queue_ 806 third_party/leveldatabase/env_chromium.cc while (queue_.empty()) { queue_ 810 third_party/leveldatabase/env_chromium.cc void (*function)(void*) = queue_.front().function; queue_ 811 third_party/leveldatabase/env_chromium.cc void* arg = queue_.front().arg; queue_ 812 third_party/leveldatabase/env_chromium.cc queue_.pop_front(); queue_ 203 third_party/leveldatabase/env_chromium.h BGQueue queue_; queue_ 360 ui/aura/gestures/gesture_recognizer_unittest.cc while(!queue_.empty()) { queue_ 361 ui/aura/gestures/gesture_recognizer_unittest.cc delete queue_.front(); queue_ 362 ui/aura/gestures/gesture_recognizer_unittest.cc queue_.pop(); queue_ 368 ui/aura/gestures/gesture_recognizer_unittest.cc queue_.push(new ui::TouchEvent(*event, window_, window_)); queue_ 386 ui/aura/gestures/gesture_recognizer_unittest.cc scoped_ptr<ui::TouchEvent> event(queue_.front()); queue_ 389 ui/aura/gestures/gesture_recognizer_unittest.cc queue_.pop(); queue_ 392 ui/aura/gestures/gesture_recognizer_unittest.cc std::queue<ui::TouchEvent*> queue_; queue_ 22 ui/events/gesture_detection/touch_disposition_gesture_filter_unittest.cc queue_.reset(new TouchDispositionGestureFilter(this)); queue_ 26 ui/events/gesture_detection/touch_disposition_gesture_filter_unittest.cc queue_.reset(); queue_ 106 ui/events/gesture_detection/touch_disposition_gesture_filter_unittest.cc return queue_->OnGesturePacket(touch_packet); queue_ 111 ui/events/gesture_detection/touch_disposition_gesture_filter_unittest.cc return queue_->OnGesturePacket( queue_ 117 ui/events/gesture_detection/touch_disposition_gesture_filter_unittest.cc return queue_->OnGesturePacket(packet); queue_ 121 ui/events/gesture_detection/touch_disposition_gesture_filter_unittest.cc queue_->OnTouchEventAck(event_consumed); queue_ 161 ui/events/gesture_detection/touch_disposition_gesture_filter_unittest.cc return queue_->IsEmpty(); queue_ 175 ui/events/gesture_detection/touch_disposition_gesture_filter_unittest.cc scoped_ptr<TouchDispositionGestureFilter> queue_;