queue 95 android_webview/browser/hardware_renderer.h std::queue<base::Closure> tasks_; queue 265 apps/launcher.cc extensions::LazyBackgroundTaskQueue* queue = queue 267 apps/launcher.cc if (queue->ShouldEnqueueTask(profile_, extension_)) { queue 268 apps/launcher.cc queue->AddPendingTask(profile_, extension_->id(), base::Bind( queue 487 ash/root_window_controller.cc std::queue<aura::Window*> non_toplevel_windows; queue 56 base/pending_task.cc void TaskQueue::Swap(TaskQueue* queue) { queue 57 base/pending_task.cc c.swap(queue->c); // Calls std::deque::swap. queue 50 base/pending_task.h class BASE_EXPORT TaskQueue : public std::queue<PendingTask> { queue 52 base/pending_task.h void Swap(TaskQueue* queue); queue 254 base/synchronization/condition_variable_unittest.cc WorkQueue queue(kThreadCount); // Start the threads. queue 261 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 262 base/synchronization/condition_variable_unittest.cc while (!queue.EveryIdWasAllocated()) queue 263 base/synchronization/condition_variable_unittest.cc queue.all_threads_have_ids()->Wait(); queue 268 base/synchronization/condition_variable_unittest.cc queue.SpinUntilAllThreadsAreWaiting(); queue 272 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 273 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.GetNumThreadsTakingAssignments()); queue 274 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.GetNumThreadsCompletingTasks()); queue 275 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.task_count()); queue 276 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.GetMaxCompletionsByWorkerThread()); queue 277 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.GetMinCompletionsByWorkerThread()); queue 278 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.GetNumberOfCompletedTasks()); queue 282 base/synchronization/condition_variable_unittest.cc queue.ResetHistory(); queue 283 base/synchronization/condition_variable_unittest.cc queue.SetTaskCount(kTaskCount); queue 284 base/synchronization/condition_variable_unittest.cc queue.SetWorkTime(kThirtyMs); queue 285 base/synchronization/condition_variable_unittest.cc queue.SetAllowHelp(true); queue 290 base/synchronization/condition_variable_unittest.cc queue.work_is_available()->Signal(); // But each worker can signal another. queue 292 base/synchronization/condition_variable_unittest.cc queue.SpinUntilTaskCountLessThan(kTaskCount); queue 294 base/synchronization/condition_variable_unittest.cc queue.SpinUntilAllThreadsAreWaiting(); queue 298 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 299 base/synchronization/condition_variable_unittest.cc while (queue.task_count()) queue 300 base/synchronization/condition_variable_unittest.cc queue.no_more_tasks()->Wait(); queue 305 base/synchronization/condition_variable_unittest.cc EXPECT_LE(2, queue.GetNumThreadsTakingAssignments()); queue 306 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(kTaskCount, queue.GetNumberOfCompletedTasks()); queue 309 base/synchronization/condition_variable_unittest.cc queue.ResetHistory(); queue 310 base/synchronization/condition_variable_unittest.cc queue.SetTaskCount(3); queue 311 base/synchronization/condition_variable_unittest.cc queue.SetWorkTime(kThirtyMs); queue 312 base/synchronization/condition_variable_unittest.cc queue.SetAllowHelp(false); queue 314 base/synchronization/condition_variable_unittest.cc queue.work_is_available()->Broadcast(); // Make them all try. queue 316 base/synchronization/condition_variable_unittest.cc queue.SpinUntilTaskCountLessThan(3); queue 318 base/synchronization/condition_variable_unittest.cc queue.SpinUntilAllThreadsAreWaiting(); queue 321 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 322 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(3, queue.GetNumThreadsTakingAssignments()); queue 323 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(3, queue.GetNumThreadsCompletingTasks()); queue 324 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.task_count()); queue 325 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(1, queue.GetMaxCompletionsByWorkerThread()); queue 326 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.GetMinCompletionsByWorkerThread()); queue 327 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(3, queue.GetNumberOfCompletedTasks()); queue 330 base/synchronization/condition_variable_unittest.cc queue.ResetHistory(); queue 331 base/synchronization/condition_variable_unittest.cc queue.SetTaskCount(3); queue 332 base/synchronization/condition_variable_unittest.cc queue.SetWorkTime(kThirtyMs); queue 333 base/synchronization/condition_variable_unittest.cc queue.SetAllowHelp(true); // Allow (unnecessary) help requests. queue 335 base/synchronization/condition_variable_unittest.cc queue.work_is_available()->Broadcast(); // Signal all threads. queue 337 base/synchronization/condition_variable_unittest.cc queue.SpinUntilTaskCountLessThan(3); queue 339 base/synchronization/condition_variable_unittest.cc queue.SpinUntilAllThreadsAreWaiting(); queue 342 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 343 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(3, queue.GetNumThreadsTakingAssignments()); queue 344 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(3, queue.GetNumThreadsCompletingTasks()); queue 345 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.task_count()); queue 346 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(1, queue.GetMaxCompletionsByWorkerThread()); queue 347 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.GetMinCompletionsByWorkerThread()); queue 348 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(3, queue.GetNumberOfCompletedTasks()); queue 351 base/synchronization/condition_variable_unittest.cc queue.ResetHistory(); queue 352 base/synchronization/condition_variable_unittest.cc queue.SetTaskCount(20); // 2 tasks per thread. queue 353 base/synchronization/condition_variable_unittest.cc queue.SetWorkTime(kThirtyMs); queue 354 base/synchronization/condition_variable_unittest.cc queue.SetAllowHelp(true); queue 356 base/synchronization/condition_variable_unittest.cc queue.work_is_available()->Signal(); // But each worker can signal another. queue 358 base/synchronization/condition_variable_unittest.cc queue.SpinUntilTaskCountLessThan(20); queue 360 base/synchronization/condition_variable_unittest.cc queue.SpinUntilAllThreadsAreWaiting(); // Should take about 60 ms. queue 363 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 364 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(10, queue.GetNumThreadsTakingAssignments()); queue 365 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(10, queue.GetNumThreadsCompletingTasks()); queue 366 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.task_count()); queue 367 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(20, queue.GetNumberOfCompletedTasks()); queue 370 base/synchronization/condition_variable_unittest.cc queue.ResetHistory(); queue 371 base/synchronization/condition_variable_unittest.cc queue.SetTaskCount(20); // 2 tasks per thread. queue 372 base/synchronization/condition_variable_unittest.cc queue.SetWorkTime(kThirtyMs); queue 373 base/synchronization/condition_variable_unittest.cc queue.SetAllowHelp(true); queue 375 base/synchronization/condition_variable_unittest.cc queue.work_is_available()->Broadcast(); queue 377 base/synchronization/condition_variable_unittest.cc queue.SpinUntilTaskCountLessThan(20); queue 379 base/synchronization/condition_variable_unittest.cc queue.SpinUntilAllThreadsAreWaiting(); // Should take about 60 ms. queue 382 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 383 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(10, queue.GetNumThreadsTakingAssignments()); queue 384 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(10, queue.GetNumThreadsCompletingTasks()); queue 385 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.task_count()); queue 386 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(20, queue.GetNumberOfCompletedTasks()); queue 388 base/synchronization/condition_variable_unittest.cc queue.SetShutdown(); queue 390 base/synchronization/condition_variable_unittest.cc queue.work_is_available()->Broadcast(); // Force check for shutdown. queue 393 base/synchronization/condition_variable_unittest.cc queue.ThreadSafeCheckShutdown(kThreadCount)); queue 398 base/synchronization/condition_variable_unittest.cc WorkQueue queue(kThreadCount); // Start the threads. queue 405 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 406 base/synchronization/condition_variable_unittest.cc while (!queue.EveryIdWasAllocated()) queue 407 base/synchronization/condition_variable_unittest.cc queue.all_threads_have_ids()->Wait(); queue 411 base/synchronization/condition_variable_unittest.cc queue.SpinUntilAllThreadsAreWaiting(); queue 415 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 416 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.GetNumThreadsTakingAssignments()); queue 417 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.GetNumThreadsCompletingTasks()); queue 418 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.task_count()); queue 419 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.GetMaxCompletionsByWorkerThread()); queue 420 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.GetMinCompletionsByWorkerThread()); queue 421 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.GetNumberOfCompletedTasks()); queue 424 base/synchronization/condition_variable_unittest.cc queue.ResetHistory(); queue 425 base/synchronization/condition_variable_unittest.cc queue.SetTaskCount(20 * kThreadCount); queue 426 base/synchronization/condition_variable_unittest.cc queue.SetWorkTime(kFortyFiveMs); queue 427 base/synchronization/condition_variable_unittest.cc queue.SetAllowHelp(false); queue 429 base/synchronization/condition_variable_unittest.cc queue.work_is_available()->Broadcast(); // Start up all threads. queue 432 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 433 base/synchronization/condition_variable_unittest.cc while (queue.task_count() != 0) queue 434 base/synchronization/condition_variable_unittest.cc queue.no_more_tasks()->Wait(); queue 438 base/synchronization/condition_variable_unittest.cc queue.SpinUntilAllThreadsAreWaiting(); queue 443 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 444 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(kThreadCount, queue.GetNumThreadsTakingAssignments()); queue 445 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(kThreadCount, queue.GetNumThreadsCompletingTasks()); queue 446 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.task_count()); queue 447 base/synchronization/condition_variable_unittest.cc EXPECT_LE(20, queue.GetMaxCompletionsByWorkerThread()); queue 448 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(20 * kThreadCount, queue.GetNumberOfCompletedTasks()); queue 451 base/synchronization/condition_variable_unittest.cc queue.ResetHistory(); queue 452 base/synchronization/condition_variable_unittest.cc queue.SetTaskCount(kThreadCount * 4); queue 453 base/synchronization/condition_variable_unittest.cc queue.SetWorkTime(kFortyFiveMs); queue 454 base/synchronization/condition_variable_unittest.cc queue.SetAllowHelp(true); // Might outperform Broadcast(). queue 456 base/synchronization/condition_variable_unittest.cc queue.work_is_available()->Signal(); // Start up one thread. queue 460 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 461 base/synchronization/condition_variable_unittest.cc while (queue.task_count() != 0) queue 462 base/synchronization/condition_variable_unittest.cc queue.no_more_tasks()->Wait(); queue 466 base/synchronization/condition_variable_unittest.cc queue.SpinUntilAllThreadsAreWaiting(); queue 471 base/synchronization/condition_variable_unittest.cc base::AutoLock auto_lock(*queue.lock()); queue 472 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(kThreadCount, queue.GetNumThreadsTakingAssignments()); queue 473 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(kThreadCount, queue.GetNumThreadsCompletingTasks()); queue 474 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(0, queue.task_count()); queue 475 base/synchronization/condition_variable_unittest.cc EXPECT_LE(4, queue.GetMaxCompletionsByWorkerThread()); queue 476 base/synchronization/condition_variable_unittest.cc EXPECT_EQ(4 * kThreadCount, queue.GetNumberOfCompletedTasks()); queue 478 base/synchronization/condition_variable_unittest.cc queue.SetShutdown(); queue 480 base/synchronization/condition_variable_unittest.cc queue.work_is_available()->Broadcast(); // Force check for shutdown. queue 484 base/synchronization/condition_variable_unittest.cc queue.ThreadSafeCheckShutdown(kThreadCount)); queue 183 base/threading/simple_thread.h std::queue<Delegate*> delegates_; queue 151 base/threading/thread_collision_warner_unittest.cc explicit QueueUser(NonThreadSafeQueue& queue) queue 152 base/threading/thread_collision_warner_unittest.cc : queue_(queue) {} queue 165 base/threading/thread_collision_warner_unittest.cc NonThreadSafeQueue queue(local_reporter); queue 167 base/threading/thread_collision_warner_unittest.cc QueueUser queue_user_a(queue); queue 168 base/threading/thread_collision_warner_unittest.cc QueueUser queue_user_b(queue); queue 209 base/threading/thread_collision_warner_unittest.cc explicit QueueUser(NonThreadSafeQueue& queue) queue 210 base/threading/thread_collision_warner_unittest.cc : queue_(queue) {} queue 223 base/threading/thread_collision_warner_unittest.cc NonThreadSafeQueue queue(local_reporter); queue 225 base/threading/thread_collision_warner_unittest.cc QueueUser queue_user_a(queue); queue 226 base/threading/thread_collision_warner_unittest.cc QueueUser queue_user_b(queue); queue 269 base/threading/thread_collision_warner_unittest.cc QueueUser(NonThreadSafeQueue& queue, base::Lock& lock) queue 270 base/threading/thread_collision_warner_unittest.cc : queue_(queue), queue 290 base/threading/thread_collision_warner_unittest.cc NonThreadSafeQueue queue(local_reporter); queue 294 base/threading/thread_collision_warner_unittest.cc QueueUser queue_user_a(queue, lock); queue 295 base/threading/thread_collision_warner_unittest.cc QueueUser queue_user_b(queue, lock); queue 343 base/threading/thread_collision_warner_unittest.cc QueueUser(NonThreadSafeQueue& queue, base::Lock& lock) queue 344 base/threading/thread_collision_warner_unittest.cc : queue_(queue), queue 368 base/threading/thread_collision_warner_unittest.cc NonThreadSafeQueue queue(local_reporter); queue 372 base/threading/thread_collision_warner_unittest.cc QueueUser queue_user_a(queue, lock); queue 373 base/threading/thread_collision_warner_unittest.cc QueueUser queue_user_b(queue, lock); queue 29 base/threading/worker_pool_posix_unittest.cc const std::queue<PendingTask>& pending_tasks() const { queue 73 cc/debug/micro_benchmark_controller_unittest.cc scoped_ptr<ResourceUpdateQueue> queue(new ResourceUpdateQueue); queue 75 cc/debug/micro_benchmark_controller_unittest.cc layer_tree_host_->UpdateLayers(queue.get()); queue 93 cc/debug/micro_benchmark_controller_unittest.cc scoped_ptr<ResourceUpdateQueue> queue(new ResourceUpdateQueue); queue 95 cc/debug/micro_benchmark_controller_unittest.cc layer_tree_host_->UpdateLayers(queue.get()); queue 110 cc/debug/micro_benchmark_controller_unittest.cc layer_tree_host_->UpdateLayers(queue.get()); queue 113 cc/debug/micro_benchmark_controller_unittest.cc layer_tree_host_->UpdateLayers(queue.get()); queue 90 cc/layers/content_layer.cc bool ContentLayer::Update(ResourceUpdateQueue* queue, queue 100 cc/layers/content_layer.cc bool updated = TiledLayer::Update(queue, occlusion); queue 47 cc/layers/content_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 38 cc/layers/contents_scaling_layer.cc bool ContentsScalingLayer::Update(ResourceUpdateQueue* queue, queue 40 cc/layers/contents_scaling_layer.cc bool updated = Layer::Update(queue, occlusion); queue 26 cc/layers/contents_scaling_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 115 cc/layers/delegated_renderer_layer.cc bool DelegatedRendererLayer::Update(ResourceUpdateQueue* queue, queue 117 cc/layers/delegated_renderer_layer.cc bool updated = Layer::Update(queue, occlusion); queue 28 cc/layers/delegated_renderer_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 43 cc/layers/image_layer.cc bool ImageLayer::Update(ResourceUpdateQueue* queue, queue 51 cc/layers/image_layer.cc return TiledLayer::Update(queue, occlusion); queue 25 cc/layers/image_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 43 cc/layers/io_surface_layer.cc bool IOSurfaceLayer::Update(ResourceUpdateQueue* queue, queue 45 cc/layers/io_surface_layer.cc bool updated = Layer::Update(queue, occlusion); queue 23 cc/layers/io_surface_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 1044 cc/layers/layer.cc bool Layer::Update(ResourceUpdateQueue* queue, queue 359 cc/layers/layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 59 cc/layers/nine_patch_layer_unittest.cc ResourceUpdateQueue queue; queue 63 cc/layers/nine_patch_layer_unittest.cc test_layer->Update(&queue, &occlusion_tracker); queue 75 cc/layers/nine_patch_layer_unittest.cc test_layer->Update(&queue, &occlusion_tracker); queue 204 cc/layers/painted_scrollbar_layer.cc bool PaintedScrollbarLayer::Update(ResourceUpdateQueue* queue, queue 218 cc/layers/painted_scrollbar_layer.cc ContentsScalingLayer::Update(queue, occlusion); queue 40 cc/layers/painted_scrollbar_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 84 cc/layers/picture_layer.cc bool PictureLayer::Update(ResourceUpdateQueue* queue, queue 87 cc/layers/picture_layer.cc bool updated = Layer::Update(queue, occlusion); queue 33 cc/layers/picture_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 43 cc/layers/picture_layer_unittest.cc scoped_ptr<ResourceUpdateQueue> queue(new ResourceUpdateQueue); queue 44 cc/layers/picture_layer_unittest.cc layer->Update(queue.get(), &occlusion); queue 656 cc/layers/scrollbar_layer_unittest.cc ResourceUpdateQueue queue; queue 662 cc/layers/scrollbar_layer_unittest.cc scrollbar_layer->Update(&queue, &occlusion_tracker); queue 743 cc/layers/scrollbar_layer_unittest.cc ResourceUpdateQueue queue; queue 747 cc/layers/scrollbar_layer_unittest.cc scrollbar_layer->Update(&queue, &occlusion_tracker); queue 820 cc/layers/scrollbar_layer_unittest.cc ResourceUpdateQueue queue; queue 825 cc/layers/scrollbar_layer_unittest.cc scrollbar_layer->Update(&queue, &occlusion_tracker); queue 234 cc/layers/texture_layer.cc bool TextureLayer::Update(ResourceUpdateQueue* queue, queue 236 cc/layers/texture_layer.cc bool updated = Layer::Update(queue, occlusion); queue 152 cc/layers/texture_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 328 cc/layers/tiled_layer.cc ResourceUpdateQueue* queue, queue 349 cc/layers/tiled_layer.cc update_rect, paint_rect, left, top, right, bottom, queue, occlusion); queue 464 cc/layers/tiled_layer.cc ResourceUpdateQueue* queue, queue 553 cc/layers/tiled_layer.cc queue, source_rect, dest_offset, tile->partial_update); queue 715 cc/layers/tiled_layer.cc bool TiledLayer::Update(ResourceUpdateQueue* queue, queue 729 cc/layers/tiled_layer.cc updated |= ContentsScalingLayer::Update(queue, occlusion); queue 746 cc/layers/tiled_layer.cc UpdateTiles(left, top, right, bottom, queue, NULL, &updated); queue 764 cc/layers/tiled_layer.cc left, top, right, bottom, queue, occlusion, &updated); queue 777 cc/layers/tiled_layer.cc if (!UpdateTiles(left, top, right, bottom, queue, NULL, &updated) || queue 807 cc/layers/tiled_layer.cc left, bottom, right, bottom, queue, NULL, &updated) || queue 816 cc/layers/tiled_layer.cc left, top, right, top, queue, NULL, &updated) || queue 825 cc/layers/tiled_layer.cc left, top, left, bottom, queue, NULL, &updated) || queue 834 cc/layers/tiled_layer.cc right, top, right, bottom, queue, NULL, &updated) || queue 37 cc/layers/tiled_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 99 cc/layers/tiled_layer.h ResourceUpdateQueue* queue, queue 120 cc/layers/tiled_layer.h ResourceUpdateQueue* queue, queue 59 cc/layers/ui_resource_layer_unittest.cc ResourceUpdateQueue queue; queue 63 cc/layers/ui_resource_layer_unittest.cc test_layer->Update(&queue, &occlusion_tracker); queue 72 cc/layers/ui_resource_layer_unittest.cc test_layer->Update(&queue, &occlusion_tracker); queue 87 cc/layers/ui_resource_layer_unittest.cc ResourceUpdateQueue queue; queue 91 cc/layers/ui_resource_layer_unittest.cc test_layer->Update(&queue, &occlusion_tracker); queue 99 cc/layers/ui_resource_layer_unittest.cc test_layer->Update(&queue, &occlusion_tracker); queue 25 cc/layers/video_layer.cc bool VideoLayer::Update(ResourceUpdateQueue* queue, queue 27 cc/layers/video_layer.cc bool updated = Layer::Update(queue, occlusion); queue 27 cc/layers/video_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 25 cc/resources/bitmap_content_layer_updater.cc ResourceUpdateQueue* queue, queue 30 cc/resources/bitmap_content_layer_updater.cc queue, texture(), source_rect, dest_offset, partial_update); queue 89 cc/resources/bitmap_content_layer_updater.cc void BitmapContentLayerUpdater::UpdateTexture(ResourceUpdateQueue* queue, queue 101 cc/resources/bitmap_content_layer_updater.cc queue->AppendPartialUpload(upload); queue 103 cc/resources/bitmap_content_layer_updater.cc queue->AppendFullUpload(upload); queue 32 cc/resources/bitmap_content_layer_updater.h virtual void Update(ResourceUpdateQueue* queue, queue 55 cc/resources/bitmap_content_layer_updater.h void UpdateTexture(ResourceUpdateQueue* queue, queue 22 cc/resources/bitmap_skpicture_content_layer_updater.cc ResourceUpdateQueue* queue, queue 36 cc/resources/bitmap_skpicture_content_layer_updater.cc queue->AppendPartialUpload(upload); queue 38 cc/resources/bitmap_skpicture_content_layer_updater.cc queue->AppendFullUpload(upload); queue 23 cc/resources/bitmap_skpicture_content_layer_updater.h virtual void Update(ResourceUpdateQueue* queue, queue 40 cc/resources/direct_raster_worker_pool.cc void DirectRasterWorkerPool::ScheduleTasks(RasterTaskQueue* queue) { queue 43 cc/resources/direct_raster_worker_pool.cc DCHECK_EQ(queue->required_for_activation_count, queue 45 cc/resources/direct_raster_worker_pool.cc std::count_if(queue->items.begin(), queue 46 cc/resources/direct_raster_worker_pool.cc queue->items.end(), queue 55 cc/resources/direct_raster_worker_pool.cc queue->required_for_activation_count)); queue 70 cc/resources/direct_raster_worker_pool.cc if (std::find_if(queue->items.begin(), queue 71 cc/resources/direct_raster_worker_pool.cc queue->items.end(), queue 73 cc/resources/direct_raster_worker_pool.cc queue->items.end()) queue 80 cc/resources/direct_raster_worker_pool.cc raster_tasks_.Swap(queue); queue 24 cc/resources/direct_raster_worker_pool.h virtual void ScheduleTasks(RasterTaskQueue* queue) OVERRIDE; queue 17 cc/resources/image_layer_updater.cc void ImageLayerUpdater::Resource::Update(ResourceUpdateQueue* queue, queue 22 cc/resources/image_layer_updater.cc queue, texture(), source_rect, dest_offset, partial_update); queue 36 cc/resources/image_layer_updater.cc void ImageLayerUpdater::UpdateTexture(ResourceUpdateQueue* queue, queue 54 cc/resources/image_layer_updater.cc queue->AppendPartialUpload(upload); queue 56 cc/resources/image_layer_updater.cc queue->AppendFullUpload(upload); queue 24 cc/resources/image_layer_updater.h virtual void Update(ResourceUpdateQueue* queue, queue 40 cc/resources/image_layer_updater.h void UpdateTexture(ResourceUpdateQueue* queue, queue 34 cc/resources/image_raster_worker_pool.cc void ImageRasterWorkerPool::ScheduleTasks(RasterTaskQueue* queue) { queue 37 cc/resources/image_raster_worker_pool.cc DCHECK_EQ(queue->required_for_activation_count, queue 39 cc/resources/image_raster_worker_pool.cc std::count_if(queue->items.begin(), queue 40 cc/resources/image_raster_worker_pool.cc queue->items.end(), queue 56 cc/resources/image_raster_worker_pool.cc queue->required_for_activation_count)); queue 60 cc/resources/image_raster_worker_pool.cc for (RasterTaskQueue::Item::Vector::const_iterator it = queue->items.begin(); queue 61 cc/resources/image_raster_worker_pool.cc it != queue->items.end(); queue 81 cc/resources/image_raster_worker_pool.cc queue->required_for_activation_count); queue 85 cc/resources/image_raster_worker_pool.cc queue->items.size()); queue 24 cc/resources/image_raster_worker_pool.h virtual void ScheduleTasks(RasterTaskQueue* queue) OVERRIDE; queue 31 cc/resources/layer_updater.h virtual void Update(ResourceUpdateQueue* queue, queue 92 cc/resources/pixel_buffer_raster_worker_pool.cc void PixelBufferRasterWorkerPool::ScheduleTasks(RasterTaskQueue* queue) { queue 95 cc/resources/pixel_buffer_raster_worker_pool.cc DCHECK_EQ(queue->required_for_activation_count, queue 97 cc/resources/pixel_buffer_raster_worker_pool.cc std::count_if(queue->items.begin(), queue 98 cc/resources/pixel_buffer_raster_worker_pool.cc queue->items.end(), queue 110 cc/resources/pixel_buffer_raster_worker_pool.cc for (RasterTaskQueue::Item::Vector::const_iterator it = queue->items.begin(); queue 111 cc/resources/pixel_buffer_raster_worker_pool.cc it != queue->items.end(); queue 185 cc/resources/pixel_buffer_raster_worker_pool.cc raster_tasks_.Swap(queue); queue 26 cc/resources/pixel_buffer_raster_worker_pool.h virtual void ScheduleTasks(RasterTaskQueue* queue) OVERRIDE; queue 1003 cc/resources/prioritized_resource_unittest.cc ResourceUpdateQueue queue; queue 1009 cc/resources/prioritized_resource_unittest.cc queue.AppendFullUpload(upload); queue 1016 cc/resources/prioritized_resource_unittest.cc queue.ClearUploadsToEvictedResources(); queue 1017 cc/resources/prioritized_resource_unittest.cc EXPECT_EQ(4u, queue.FullUploadSize()); queue 1023 cc/resources/prioritized_resource_unittest.cc queue.ClearUploadsToEvictedResources(); queue 1024 cc/resources/prioritized_resource_unittest.cc EXPECT_EQ(1u, queue.FullUploadSize()); queue 1028 cc/resources/prioritized_resource_unittest.cc queue.ClearUploadsToEvictedResources(); queue 1029 cc/resources/prioritized_resource_unittest.cc EXPECT_EQ(0u, queue.FullUploadSize()); queue 158 cc/resources/raster_worker_pool.h virtual void ScheduleTasks(RasterTaskQueue* queue) = 0; queue 221 cc/resources/raster_worker_pool_perftest.cc void BuildRasterTaskQueue(RasterTaskQueue* queue, queue 225 cc/resources/raster_worker_pool_perftest.cc queue->items.push_back(RasterTaskQueue::Item(raster_tasks[i].get(), queue 227 cc/resources/raster_worker_pool_perftest.cc queue->required_for_activation_count += required_for_activation; queue 297 cc/resources/raster_worker_pool_perftest.cc RasterTaskQueue queue; queue 301 cc/resources/raster_worker_pool_perftest.cc queue.Reset(); queue 302 cc/resources/raster_worker_pool_perftest.cc BuildRasterTaskQueue(&queue, raster_tasks); queue 303 cc/resources/raster_worker_pool_perftest.cc raster_worker_pool_->ScheduleTasks(&queue); queue 333 cc/resources/raster_worker_pool_perftest.cc RasterTaskQueue queue; queue 338 cc/resources/raster_worker_pool_perftest.cc queue.Reset(); queue 339 cc/resources/raster_worker_pool_perftest.cc BuildRasterTaskQueue(&queue, raster_tasks[count % kNumVersions]); queue 340 cc/resources/raster_worker_pool_perftest.cc raster_worker_pool_->ScheduleTasks(&queue); queue 367 cc/resources/raster_worker_pool_perftest.cc RasterTaskQueue queue; queue 371 cc/resources/raster_worker_pool_perftest.cc queue.Reset(); queue 372 cc/resources/raster_worker_pool_perftest.cc BuildRasterTaskQueue(&queue, raster_tasks); queue 373 cc/resources/raster_worker_pool_perftest.cc raster_worker_pool_->ScheduleTasks(&queue); queue 453 cc/resources/raster_worker_pool_perftest.cc RasterTaskQueue queue; queue 457 cc/resources/raster_worker_pool_perftest.cc queue.Reset(); queue 458 cc/resources/raster_worker_pool_perftest.cc BuildRasterTaskQueue(&queue, raster_tasks); queue 200 cc/resources/raster_worker_pool_unittest.cc RasterTaskQueue queue; queue 205 cc/resources/raster_worker_pool_unittest.cc queue.items.push_back(RasterTaskQueue::Item(*it, false)); queue 207 cc/resources/raster_worker_pool_unittest.cc raster_worker_pool_->ScheduleTasks(&queue); queue 41 cc/resources/resource_update_controller.cc scoped_ptr<ResourceUpdateQueue> queue, queue 44 cc/resources/resource_update_controller.cc queue_(queue.Pass()), queue 34 cc/resources/resource_update_controller.h scoped_ptr<ResourceUpdateQueue> queue, queue 37 cc/resources/resource_update_controller.h client, task_runner, queue.Pass(), resource_provider)); queue 57 cc/resources/resource_update_controller.h scoped_ptr<ResourceUpdateQueue> queue, queue 339 cc/resources/resource_update_controller_unittest.cc scoped_ptr<ResourceUpdateQueue> queue, queue 342 cc/resources/resource_update_controller_unittest.cc client, task_runner, queue.Pass(), resource_provider)); queue 365 cc/resources/resource_update_controller_unittest.cc scoped_ptr<ResourceUpdateQueue> queue, queue 368 cc/resources/resource_update_controller_unittest.cc client, task_runner, queue.Pass(), resource_provider), queue 39 cc/test/fake_content_layer.cc bool FakeContentLayer::Update(ResourceUpdateQueue* queue, queue 41 cc/test/fake_content_layer.cc bool updated = ContentLayer::Update(queue, occlusion); queue 28 cc/test/fake_content_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 43 cc/test/fake_layer_tree_host.h void UpdateLayers(ResourceUpdateQueue* queue) { queue 44 cc/test/fake_layer_tree_host.h LayerTreeHost::UpdateLayers(queue); queue 39 cc/test/fake_painted_scrollbar_layer.cc ResourceUpdateQueue* queue, queue 41 cc/test/fake_painted_scrollbar_layer.cc bool updated = PaintedScrollbarLayer::Update(queue, occlusion); queue 23 cc/test/fake_painted_scrollbar_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 28 cc/test/fake_picture_layer.cc bool FakePictureLayer::Update(ResourceUpdateQueue* queue, queue 30 cc/test/fake_picture_layer.cc bool updated = PictureLayer::Update(queue, occlusion); queue 33 cc/test/fake_picture_layer.h virtual bool Update(ResourceUpdateQueue* queue, queue 21 cc/test/fake_tile_manager.cc virtual void ScheduleTasks(RasterTaskQueue* queue) OVERRIDE { queue 23 cc/test/fake_tile_manager.cc queue->items.begin(); queue 24 cc/test/fake_tile_manager.cc it != queue->items.end(); queue 17 cc/test/tiled_layer_test_common.cc void FakeLayerUpdater::Resource::Update(ResourceUpdateQueue* queue, queue 25 cc/test/tiled_layer_test_common.cc queue->AppendPartialUpload(upload); queue 27 cc/test/tiled_layer_test_common.cc queue->AppendFullUpload(upload); queue 30 cc/test/tiled_layer_test_common.h virtual void Update(ResourceUpdateQueue* queue, queue 728 cc/trees/layer_tree_host.cc bool LayerTreeHost::UpdateLayers(ResourceUpdateQueue* queue) { queue 736 cc/trees/layer_tree_host.cc bool result = UpdateLayers(root_layer(), queue); queue 776 cc/trees/layer_tree_host.cc ResourceUpdateQueue* queue) { queue 840 cc/trees/layer_tree_host.cc update_list, queue, &did_paint_content, &need_more_updates); queue 952 cc/trees/layer_tree_host.cc ResourceUpdateQueue* queue, queue 962 cc/trees/layer_tree_host.cc *did_paint_content |= mask_layer->Update(queue, NULL); queue 970 cc/trees/layer_tree_host.cc *did_paint_content |= replica_mask_layer->Update(queue, NULL); queue 977 cc/trees/layer_tree_host.cc ResourceUpdateQueue* queue, queue 1001 cc/trees/layer_tree_host.cc *it, queue, did_paint_content, need_more_updates); queue 1004 cc/trees/layer_tree_host.cc *did_paint_content |= it->Update(queue, &occlusion_tracker); queue 137 cc/trees/layer_tree_host.h bool UpdateLayers(ResourceUpdateQueue* queue); queue 329 cc/trees/layer_tree_host.h ResourceUpdateQueue* queue, queue 333 cc/trees/layer_tree_host.h ResourceUpdateQueue* queue, queue 336 cc/trees/layer_tree_host.h bool UpdateLayers(Layer* root_layer, ResourceUpdateQueue* queue); queue 1332 cc/trees/layer_tree_host_unittest.cc virtual bool Update(ResourceUpdateQueue* queue, queue 1334 cc/trees/layer_tree_host_unittest.cc bool updated = ContentLayer::Update(queue, occlusion); queue 2083 cc/trees/layer_tree_host_unittest.cc bool EvictionTestLayer::Update(ResourceUpdateQueue* queue, queue 2092 cc/trees/layer_tree_host_unittest.cc queue->AppendFullUpload(upload); queue 4681 cc/trees/layer_tree_host_unittest.cc virtual bool Update(ResourceUpdateQueue* queue, queue 4683 cc/trees/layer_tree_host_unittest.cc bool updated = Layer::Update(queue, occlusion); queue 878 cc/trees/layer_tree_impl.cc const UIResourceRequestQueue& queue) { queue 879 cc/trees/layer_tree_impl.cc ui_resource_request_queue_ = queue; queue 179 cc/trees/layer_tree_impl.h void set_ui_resource_request_queue(const UIResourceRequestQueue& queue); queue 189 cc/trees/single_thread_proxy.cc void SingleThreadProxy::DoCommit(scoped_ptr<ResourceUpdateQueue> queue) { queue 214 cc/trees/single_thread_proxy.cc queue.Pass(), queue 466 cc/trees/single_thread_proxy.cc scoped_ptr<ResourceUpdateQueue> queue = queue 468 cc/trees/single_thread_proxy.cc layer_tree_host_->UpdateLayers(queue.get()); queue 485 cc/trees/single_thread_proxy.cc DoCommit(queue.Pass()); queue 97 cc/trees/single_thread_proxy.h void DoCommit(scoped_ptr<ResourceUpdateQueue> queue); queue 914 cc/trees/thread_proxy.cc scoped_ptr<ResourceUpdateQueue> queue = queue 917 cc/trees/thread_proxy.cc bool updated = layer_tree_host()->UpdateLayers(queue.get()); queue 982 cc/trees/thread_proxy.cc queue.release(), queue 1018 cc/trees/thread_proxy.cc scoped_ptr<ResourceUpdateQueue> queue(raw_queue); queue 1038 cc/trees/thread_proxy.cc queue->ClearUploadsToEvictedResources(); queue 1051 cc/trees/thread_proxy.cc queue.Pass(), queue 91 cc/trees/thread_proxy.h scoped_ptr<AnimationEventsVector> queue) OVERRIDE; queue 147 cc/trees/thread_proxy.h void SetAnimationEvents(scoped_ptr<AnimationEventsVector> queue); queue 165 cc/trees/thread_proxy.h ResourceUpdateQueue* queue, queue 151 chrome/browser/chromeos/accessibility/accessibility_manager.cc std::queue<extensions::ExtensionResource> resources_; queue 17 chrome/browser/chromeos/drive/job_queue_unittest.cc JobQueue queue(kNumMaxConcurrentJobs, kNumPriorityLevels); queue 18 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_EQ(0U, queue.GetNumberOfJobs()); queue 21 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.Push(101, LOW_PRIORITY); queue 22 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.Push(102, HIGH_PRIORITY); queue 23 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.Push(103, LOW_PRIORITY); queue 24 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.Push(104, HIGH_PRIORITY); queue 28 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_TRUE(queue.PopForRun(LOW_PRIORITY, &id)); queue 30 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_TRUE(queue.PopForRun(LOW_PRIORITY, &id)); queue 34 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_TRUE(queue.PopForRun(LOW_PRIORITY, &id)); queue 38 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_FALSE(queue.PopForRun(LOW_PRIORITY, &id)); queue 41 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_EQ(4U, queue.GetNumberOfJobs()); queue 44 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.MarkFinished(104); queue 45 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_EQ(3U, queue.GetNumberOfJobs()); queue 48 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_TRUE(queue.PopForRun(LOW_PRIORITY, &id)); queue 52 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.Push(105, LOW_PRIORITY); queue 55 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.MarkFinished(101); queue 56 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.MarkFinished(102); queue 57 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.MarkFinished(103); queue 58 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_EQ(1U, queue.GetNumberOfJobs()); queue 62 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_FALSE(queue.PopForRun(HIGH_PRIORITY, &id)); queue 65 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_TRUE(queue.PopForRun(LOW_PRIORITY, &id)); queue 75 chrome/browser/chromeos/drive/job_queue_unittest.cc JobQueue queue(kNumMaxConcurrentJobs, kNumPriorityLevels); queue 76 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_EQ(0U, queue.GetNumberOfJobs()); queue 79 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.Push(101, LOW_PRIORITY); queue 80 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.Push(102, HIGH_PRIORITY); queue 81 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.Push(103, LOW_PRIORITY); queue 82 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.Push(104, HIGH_PRIORITY); queue 83 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_EQ(4U, queue.GetNumberOfJobs()); queue 86 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.Remove(101); queue 87 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.Remove(104); queue 88 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_EQ(2U, queue.GetNumberOfJobs()); queue 92 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_TRUE(queue.PopForRun(LOW_PRIORITY, &id)); queue 94 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_TRUE(queue.PopForRun(LOW_PRIORITY, &id)); queue 96 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.MarkFinished(102); queue 97 chrome/browser/chromeos/drive/job_queue_unittest.cc queue.MarkFinished(103); queue 100 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_EQ(0U, queue.GetNumberOfJobs()); queue 101 chrome/browser/chromeos/drive/job_queue_unittest.cc EXPECT_FALSE(queue.PopForRun(LOW_PRIORITY, &id)); queue 121 chrome/browser/chromeos/extensions/file_manager/private_api_drive.h std::queue<base::FilePath> remaining_drive_paths_; queue 52 chrome/browser/chromeos/extensions/install_limiter.h typedef std::queue<DeferredInstall> DeferredInstallList; queue 330 chrome/browser/chromeos/file_manager/file_browser_handlers.cc extensions::LazyBackgroundTaskQueue* queue = queue 333 chrome/browser/chromeos/file_manager/file_browser_handlers.cc if (!queue->ShouldEnqueueTask(profile_, extension_.get())) { queue 337 chrome/browser/chromeos/file_manager/file_browser_handlers.cc queue->AddPendingTask( queue 84 chrome/browser/component_updater/test/url_request_post_interceptor.h mutable std::queue<Expectation> expectations_; queue 153 chrome/browser/devtools/adb/android_usb_device.h std::queue<BulkMessage> outgoing_queue_; queue 236 chrome/browser/extensions/activity_log/counting_policy.cc ActionQueue queue; queue 237 chrome/browser/extensions/activity_log/counting_policy.cc queue.swap(queued_actions_); queue 247 chrome/browser/extensions/activity_log/counting_policy.cc if (queue.empty() && !clean_database) queue 285 chrome/browser/extensions/activity_log/counting_policy.cc for (ActionQueue::iterator i = queue.begin(); i != queue.end(); ++i) { queue 138 chrome/browser/extensions/api/alarms/alarm_manager.h typedef std::queue<ReadyAction> ReadyQueue; queue 346 chrome/browser/extensions/api/cast_channel/cast_socket.h std::queue<WriteRequest> write_queue_; queue 34 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc IdentityMintRequestQueue queue; queue 40 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestStart(type, *key, &request1); queue 41 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestComplete(type, *key, &request1); queue 44 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestStart(type, *key, &request2); queue 45 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestComplete(type, *key, &request2); queue 51 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc IdentityMintRequestQueue queue; queue 56 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestStart(type, *key, &request1); queue 57 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestComplete(type, *key, &request1); queue 63 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc IdentityMintRequestQueue queue; queue 70 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestStart(type, *key, &request1); queue 71 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestStart(type, *key, &request2); queue 72 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestStart(type, *key, &request3); queue 75 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestComplete(type, *key, &request1); queue 78 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestComplete(type, *key, &request2); queue 80 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestComplete(type, *key, &request3); queue 86 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc IdentityMintRequestQueue queue; queue 94 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestStart(type, *key1, &request1); queue 95 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestStart(type, *key2, &request2); queue 97 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestComplete(type, *key1, &request1); queue 98 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestComplete(type, *key2, &request2); queue 104 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc IdentityMintRequestQueue queue; queue 108 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc EXPECT_TRUE(queue.empty(type, *key)); queue 110 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestStart(type, *key, &request1); queue 111 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc EXPECT_FALSE(queue.empty(type, *key)); queue 112 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestComplete(type, *key, &request1); queue 113 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc EXPECT_TRUE(queue.empty(type, *key)); queue 119 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc IdentityMintRequestQueue queue; queue 127 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestStart(type, *key, &request1); queue 128 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestStart(type, *key, &request2); queue 129 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestStart(type, *key, &request3); queue 135 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestCancel(*key, &request1); queue 136 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestCancel(*key, &request3); queue 137 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestCancel(*key, &request2); queue 138 chrome/browser/extensions/api/identity/identity_mint_queue_unittest.cc queue.RequestCancel(*key, &request4); queue 173 chrome/browser/extensions/api/messaging/native_message_process_host.h std::queue<scoped_refptr<net::IOBufferWithSize> > write_queue_; queue 39 chrome/browser/extensions/api/system_info/system_info_provider.h typedef std::queue<QueryInfoCompletionCallback> CallbackQueue; queue 170 chrome/browser/extensions/api/web_request/web_request_api_unittest.cc std::queue<base::Closure> task_queue_; queue 105 chrome/browser/extensions/api/web_request/web_request_time_tracker.h std::queue<int64> request_ids_; queue 155 chrome/browser/extensions/install_verifier.h std::queue<linked_ptr<PendingOperation> > operation_queue_; queue 141 chrome/browser/guestview/guestview.h std::queue<Event*> pending_events_; queue 276 chrome/browser/history/expire_history_backend.h std::queue<const ExpiringVisitsReader*> work_queue_; queue 599 chrome/browser/media/media_capture_devices_dispatcher.cc RequestsQueue& queue = pending_requests_[web_contents]; queue 600 chrome/browser/media/media_capture_devices_dispatcher.cc queue.push_back(PendingAccessRequest(request, callback)); queue 603 chrome/browser/media/media_capture_devices_dispatcher.cc if (queue.size() == 1) queue 656 chrome/browser/media/media_capture_devices_dispatcher.cc RequestsQueue& queue(it->second); queue 657 chrome/browser/media/media_capture_devices_dispatcher.cc if (queue.empty()) queue 660 chrome/browser/media/media_capture_devices_dispatcher.cc content::MediaResponseCallback callback = queue.front().callback; queue 661 chrome/browser/media/media_capture_devices_dispatcher.cc queue.pop_front(); queue 663 chrome/browser/media/media_capture_devices_dispatcher.cc if (!queue.empty()) { queue 887 chrome/browser/media/media_capture_devices_dispatcher.cc RequestsQueue& queue = rqs_it->second; queue 888 chrome/browser/media/media_capture_devices_dispatcher.cc for (RequestsQueue::iterator it = queue.begin(); queue 889 chrome/browser/media/media_capture_devices_dispatcher.cc it != queue.end(); ++it) { queue 893 chrome/browser/media/media_capture_devices_dispatcher.cc queue.erase(it); queue 50 chrome/browser/media_galleries/fileapi/readahead_file_stream_reader.h std::queue<scoped_refptr<net::DrainableIOBuffer> > buffers_; queue 71 chrome/browser/media_galleries/fileapi/safe_picasa_albums_indexer.h std::queue<base::FilePath> folders_queue_; queue 192 chrome/browser/media_galleries/linux/mtp_device_delegate_impl_linux.h std::queue<PendingTaskInfo> pending_tasks_; queue 211 chrome/browser/media_galleries/win/mtp_device_delegate_impl_win.h std::queue<PendingTaskInfo> pending_tasks_; queue 1370 chrome/browser/net/predictor.cc std::queue<GURL> *queue(rush_queue_.empty() ? &background_queue_ queue 1372 chrome/browser/net/predictor.cc GURL url(queue->front()); queue 1373 chrome/browser/net/predictor.cc queue->pop(); queue 351 chrome/browser/net/predictor.h std::queue<GURL> rush_queue_; queue 354 chrome/browser/net/predictor.h std::queue<GURL> background_queue_; queue 574 chrome/browser/net/predictor_unittest.cc Predictor::HostNameQueue queue; queue 579 chrome/browser/net/predictor_unittest.cc EXPECT_TRUE(queue.IsEmpty()); queue 580 chrome/browser/net/predictor_unittest.cc queue.Push(first, UrlInfo::LEARNED_REFERAL_MOTIVATED); queue 581 chrome/browser/net/predictor_unittest.cc EXPECT_FALSE(queue.IsEmpty()); queue 582 chrome/browser/net/predictor_unittest.cc queue.Push(second, UrlInfo::MOUSE_OVER_MOTIVATED); queue 583 chrome/browser/net/predictor_unittest.cc EXPECT_FALSE(queue.IsEmpty()); queue 584 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), first); queue 585 chrome/browser/net/predictor_unittest.cc EXPECT_FALSE(queue.IsEmpty()); queue 586 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), second); queue 587 chrome/browser/net/predictor_unittest.cc EXPECT_TRUE(queue.IsEmpty()); queue 590 chrome/browser/net/predictor_unittest.cc queue.Push(first, UrlInfo::PAGE_SCAN_MOTIVATED); queue 591 chrome/browser/net/predictor_unittest.cc EXPECT_FALSE(queue.IsEmpty()); queue 592 chrome/browser/net/predictor_unittest.cc queue.Push(second, UrlInfo::OMNIBOX_MOTIVATED); queue 593 chrome/browser/net/predictor_unittest.cc EXPECT_FALSE(queue.IsEmpty()); queue 594 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), first); queue 595 chrome/browser/net/predictor_unittest.cc EXPECT_FALSE(queue.IsEmpty()); queue 596 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), second); queue 597 chrome/browser/net/predictor_unittest.cc EXPECT_TRUE(queue.IsEmpty()); queue 601 chrome/browser/net/predictor_unittest.cc Predictor::HostNameQueue queue; queue 613 chrome/browser/net/predictor_unittest.cc EXPECT_TRUE(queue.IsEmpty()); queue 614 chrome/browser/net/predictor_unittest.cc queue.Push(low1, UrlInfo::PAGE_SCAN_MOTIVATED); queue 615 chrome/browser/net/predictor_unittest.cc queue.Push(low2, UrlInfo::UNIT_TEST_MOTIVATED); queue 616 chrome/browser/net/predictor_unittest.cc queue.Push(low3, UrlInfo::LINKED_MAX_MOTIVATED); queue 617 chrome/browser/net/predictor_unittest.cc queue.Push(low4, UrlInfo::OMNIBOX_MOTIVATED); queue 618 chrome/browser/net/predictor_unittest.cc queue.Push(low5, UrlInfo::STARTUP_LIST_MOTIVATED); queue 619 chrome/browser/net/predictor_unittest.cc queue.Push(low4, UrlInfo::OMNIBOX_MOTIVATED); queue 622 chrome/browser/net/predictor_unittest.cc queue.Push(hi1, UrlInfo::LEARNED_REFERAL_MOTIVATED); queue 623 chrome/browser/net/predictor_unittest.cc queue.Push(hi2, UrlInfo::STATIC_REFERAL_MOTIVATED); queue 624 chrome/browser/net/predictor_unittest.cc queue.Push(hi3, UrlInfo::MOUSE_OVER_MOTIVATED); queue 627 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), hi1); queue 628 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), hi2); queue 629 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), hi3); queue 632 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), low1); queue 633 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), low2); queue 634 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), low3); queue 635 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), low4); queue 636 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), low5); queue 637 chrome/browser/net/predictor_unittest.cc EXPECT_EQ(queue.Pop(), low4); queue 639 chrome/browser/net/predictor_unittest.cc EXPECT_TRUE(queue.IsEmpty()); queue 63 chrome/browser/net/sdch_dictionary_fetcher.h std::queue<GURL> fetch_queue_; queue 309 chrome/browser/net/url_info.cc MinMaxAverage queue, when; queue 313 chrome/browser/net/url_info.cc queue.sample((it->queue_duration_.InMilliseconds())); queue 328 chrome/browser/net/url_info.cc queue.minimum(), queue.average(), queue.maximum()); queue 170 chrome/browser/policy/cloud/test_request_interceptor.cc mutable std::queue<JobCallback> pending_job_callbacks_; queue 77 chrome/browser/printing/print_job_manager.h scoped_refptr<PrintQueriesQueue> queue(); queue 37 chrome/browser/printing/print_preview_message_handler.cc scoped_refptr<printing::PrintQueriesQueue> queue = queue 38 chrome/browser/printing/print_preview_message_handler.cc g_browser_process->print_job_manager()->queue(); queue 40 chrome/browser/printing/print_preview_message_handler.cc queue->PopPrinterQuery(document_cookie); queue 78 chrome/browser/printing/print_view_manager.cc g_browser_process->print_job_manager()->queue()->SetDestination( queue 59 chrome/browser/printing/print_view_manager_base.cc queue_(g_browser_process->print_job_manager()->queue()) { queue 97 chrome/browser/printing/printing_message_filter.cc queue_(g_browser_process->print_job_manager()->queue()) { queue 343 chrome/browser/profile_resetter/automatic_profile_resetter.cc std::queue<base::Closure> task_queue_; queue 583 chrome/browser/safe_browsing/client_side_detection_service.cc std::queue<base::Time>* report_times) { queue 260 chrome/browser/safe_browsing/client_side_detection_service.h int GetNumReports(std::queue<base::Time>* report_times); queue 317 chrome/browser/safe_browsing/client_side_detection_service.h std::queue<base::Time> phishing_report_times_; queue 321 chrome/browser/safe_browsing/client_side_detection_service.h std::queue<base::Time> malware_report_times_; queue 134 chrome/browser/safe_browsing/client_side_detection_service_unittest.cc int GetNumReports(std::queue<base::Time>* report_times) { queue 138 chrome/browser/safe_browsing/client_side_detection_service_unittest.cc std::queue<base::Time>& GetPhishingReportTimes() { queue 142 chrome/browser/safe_browsing/client_side_detection_service_unittest.cc std::queue<base::Time>& GetMalwareReportTimes() { queue 423 chrome/browser/safe_browsing/client_side_detection_service_unittest.cc std::queue<base::Time>& report_times = GetPhishingReportTimes(); queue 483 chrome/browser/safe_browsing/client_side_detection_service_unittest.cc std::queue<base::Time>& report_times = GetMalwareReportTimes(); queue 504 chrome/browser/safe_browsing/client_side_detection_service_unittest.cc std::queue<base::Time>& report_times = GetPhishingReportTimes(); queue 69 chrome/browser/service_process/service_process_control.h typedef std::queue<IPC::Message> MessageQueue; queue 340 chrome/browser/speech/tts_controller.h std::queue<Utterance*> utterance_queue_; queue 233 chrome/browser/sync/glue/data_type_manager_impl.cc association_types_queue_ = std::queue<AssociationTypesInfo>(); queue 444 chrome/browser/sync/glue/data_type_manager_impl.cc association_types_queue_ = std::queue<AssociationTypesInfo>(); queue 36 chrome/browser/sync/glue/data_type_manager_impl.h typedef std::queue<syncer::ModelTypeSet> TypeSetPriorityList; queue 178 chrome/browser/sync/glue/data_type_manager_impl.h std::queue<AssociationTypesInfo> association_types_queue_; queue 2006 chrome/browser/sync/profile_sync_service_bookmark_unittest.cc std::queue<const BookmarkNode*> nodes; queue 15 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc OriginOperationQueue* queue) { queue 16 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc ASSERT_FALSE(queue->empty()); queue 18 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc op = queue->Pop(); queue 28 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc OriginOperationQueue queue; queue 30 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc queue.Push(origin1, OriginOperation::REGISTERING); queue 31 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc queue.Push(origin2, OriginOperation::DISABLING); queue 32 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc queue.Push(origin1, OriginOperation::UNINSTALLING); queue 34 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc ASSERT_EQ(3U, queue.size()); queue 35 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc ASSERT_TRUE(queue.HasPendingOperation(origin1)); queue 36 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc ASSERT_TRUE(queue.HasPendingOperation(origin2)); queue 38 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc PopAndVerify(origin1, OriginOperation::REGISTERING, &queue); queue 39 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc PopAndVerify(origin2, OriginOperation::DISABLING, &queue); queue 41 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc ASSERT_TRUE(queue.HasPendingOperation(origin1)); queue 42 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc ASSERT_FALSE(queue.HasPendingOperation(origin2)); queue 44 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc PopAndVerify(origin1, OriginOperation::UNINSTALLING, &queue); queue 46 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc ASSERT_TRUE(queue.empty()); queue 47 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc ASSERT_FALSE(queue.HasPendingOperation(origin1)); queue 48 chrome/browser/sync_file_system/drive_backend_v1/origin_operation_queue_unittest.cc ASSERT_FALSE(queue.HasPendingOperation(origin2)); queue 48 chrome/browser/sync_file_system/local/local_file_change_tracker.cc std::queue<FileSystemURL>* dirty_files); queue 333 chrome/browser/sync_file_system/local/local_file_change_tracker.cc std::queue<FileSystemURL> dirty_files; queue 540 chrome/browser/sync_file_system/local/local_file_change_tracker.cc std::queue<FileSystemURL>* dirty_files) { queue 288 chrome/browser/ui/app_modal_dialogs/javascript_dialog_manager.cc AppModalDialogQueue* queue = AppModalDialogQueue::GetInstance(); queue 289 chrome/browser/ui/app_modal_dialogs/javascript_dialog_manager.cc AppModalDialog* active_dialog = queue->active_dialog(); queue 292 chrome/browser/ui/app_modal_dialogs/javascript_dialog_manager.cc for (AppModalDialogQueue::iterator i = queue->begin(); queue 293 chrome/browser/ui/app_modal_dialogs/javascript_dialog_manager.cc i != queue->end(); ++i) { queue 677 chrome/browser/ui/panels/docked_panel_collection.cc std::queue<PanelBoundsInfo> moving_left; queue 54 chrome/renderer/extensions/user_script_scheduler.cc std::queue<linked_ptr<ExtensionMsg_ExecuteCode_Params> >(); queue 57 chrome/renderer/extensions/user_script_scheduler.h std::queue<linked_ptr<ExtensionMsg_ExecuteCode_Params> > queue 71 chromeos/dbus/fake_update_engine_client.h std::queue<UpdateEngineClient::Status> status_queue_; queue 166 chromeos/ime/xkeyboard.cc std::queue<std::string> execute_queue_; queue 293 chromeos/ime/xkeyboard.cc execute_queue_ = std::queue<std::string>(); // clear the queue. queue 66 components/keyed_service/core/dependency_graph.cc std::deque<DependencyNode*> queue; queue 67 components/keyed_service/core/dependency_graph.cc std::copy(all_nodes_.begin(), all_nodes_.end(), std::back_inserter(queue)); queue 69 components/keyed_service/core/dependency_graph.cc std::deque<DependencyNode*>::iterator queue_end = queue.end(); queue 71 components/keyed_service/core/dependency_graph.cc queue_end = std::remove(queue.begin(), queue_end, it->second); queue 73 components/keyed_service/core/dependency_graph.cc queue.erase(queue_end, queue.end()); queue 78 components/keyed_service/core/dependency_graph.cc while (!queue.empty()) { queue 79 components/keyed_service/core/dependency_graph.cc DependencyNode* node = queue.front(); queue 80 components/keyed_service/core/dependency_graph.cc queue.pop_front(); queue 101 components/keyed_service/core/dependency_graph.cc queue.push_back(dest); queue 128 components/nacl/loader/nacl_ipc_adapter.h std::queue< scoped_refptr<RewrittenMessage> > to_be_received_; queue 112 components/policy/core/common/cloud/external_policy_data_updater.h std::queue<base::WeakPtr<FetchJob> > job_queue_; queue 52 components/policy/core/common/cloud/rate_limiter.h std::queue<base::TimeTicks> invocation_times_; queue 85 components/rappor/log_uploader.h std::queue<std::string> queued_logs_; queue 193 components/url_matcher/substring_set_matcher.cc std::queue<uint32> queue; queue 202 components/url_matcher/substring_set_matcher.cc queue.push(leads_to); queue 205 components/url_matcher/substring_set_matcher.cc while (!queue.empty()) { queue 206 components/url_matcher/substring_set_matcher.cc AhoCorasickNode& current_node = tree_[queue.front()]; queue 207 components/url_matcher/substring_set_matcher.cc queue.pop(); queue 212 components/url_matcher/substring_set_matcher.cc queue.push(leads_to); queue 615 content/browser/browser_plugin/browser_plugin_guest.h std::queue<IPC::Message*> pending_messages_; queue 261 content/browser/download/save_package.h typedef std::queue<SaveItem*> SaveItemQueue; queue 315 content/browser/fileapi/copy_or_move_operation_delegate_unittest.cc std::queue<FileSystemURL> directories; queue 202 content/browser/fileapi/dragged_file_util_unittest.cc std::queue<FileSystemURL> directories; queue 435 content/browser/fileapi/dragged_file_util_unittest.cc std::queue<FileSystemURL> directories; queue 96 content/browser/frame_host/frame_tree.cc std::queue<FrameTreeNode*> queue; queue 97 content/browser/frame_host/frame_tree.cc queue.push(root_.get()); queue 99 content/browser/frame_host/frame_tree.cc while (!queue.empty()) { queue 100 content/browser/frame_host/frame_tree.cc FrameTreeNode* node = queue.front(); queue 101 content/browser/frame_host/frame_tree.cc queue.pop(); queue 106 content/browser/frame_host/frame_tree.cc queue.push(node->child_at(i)); queue 200 content/browser/gpu/gpu_process_host.h std::queue<EstablishChannelCallback> channel_requests_; queue 203 content/browser/gpu/gpu_process_host.h std::queue<CreateCommandBufferCallback> create_command_buffer_requests_; queue 206 content/browser/gpu/gpu_process_host.h std::queue<CreateImageCallback> create_image_requests_; queue 210 content/browser/gpu/gpu_process_host.h std::queue<IPC::Message*> queued_messages_; queue 144 content/browser/gpu/shader_disk_cache.h typedef std::queue<scoped_refptr<ShaderClearHelper> > ShaderClearQueue; queue 120 content/browser/indexed_db/indexed_db_transaction.h std::queue<Operation> queue_; queue 121 content/browser/loader/resource_buffer.h std::queue<int> alloc_sizes_; queue 35 content/browser/loader/resource_scheduler.cc Iterator(NetQueue* queue) : queue_(queue) { queue 36 content/browser/loader/resource_scheduler.cc DCHECK(queue != NULL); queue 156 content/browser/ppapi_plugin_process_host.h std::queue<Client*> sent_requests_; queue 141 content/browser/renderer_host/backing_store_gtk.cc std::queue<BackingStoreEvents*> backing_store_events_; queue 76 content/browser/renderer_host/input/gesture_event_queue_unittest.cc if (queue()->ShouldForward(gesture_with_latency)) { queue 117 content/browser/renderer_host/input/gesture_event_queue_unittest.cc queue()->ProcessGestureAck(ack, type, ui::LatencyInfo()); queue 141 content/browser/renderer_host/input/gesture_event_queue_unittest.cc queue()->set_debounce_enabled_for_testing(false); queue 145 content/browser/renderer_host/input/gesture_event_queue_unittest.cc queue()->set_debounce_interval_time_ms_for_testing(ms); queue 159 content/browser/renderer_host/input/gesture_event_queue_unittest.cc return queue()->coalesced_gesture_events_.size(); queue 163 content/browser/renderer_host/input/gesture_event_queue_unittest.cc return queue()->coalesced_gesture_events_.at( queue 168 content/browser/renderer_host/input/gesture_event_queue_unittest.cc return queue()->coalesced_gesture_events_.back().event; queue 172 content/browser/renderer_host/input/gesture_event_queue_unittest.cc return queue()->debouncing_deferral_queue_.size(); queue 176 content/browser/renderer_host/input/gesture_event_queue_unittest.cc return queue()->coalesced_gesture_events_.at(i).event; queue 180 content/browser/renderer_host/input/gesture_event_queue_unittest.cc return queue()->scrolling_in_progress_; queue 184 content/browser/renderer_host/input/gesture_event_queue_unittest.cc return queue()->fling_in_progress_; queue 188 content/browser/renderer_host/input/gesture_event_queue_unittest.cc return queue()->ignore_next_ack_; queue 81 content/browser/renderer_host/input/synthetic_gesture_controller.h std::queue<OnGestureCompleteCallback> callbacks_; queue 200 content/browser/renderer_host/media/media_stream_dispatcher_host_unittest.cc std::queue<base::Closure> quit_closures_; queue 89 content/browser/renderer_host/p2p/socket_host_tcp.h std::queue<scoped_refptr<net::DrainableIOBuffer> > write_queue_; queue 91 content/browser/renderer_host/pepper/pepper_network_proxy_host.h std::queue<UnsentRequest> unsent_requests_; queue 95 content/browser/renderer_host/pepper/pepper_network_proxy_host.h std::queue<net::ProxyService::PacRequest*> pending_requests_; queue 365 content/browser/renderer_host/render_process_host_impl.h std::queue<IPC::Message*> queued_messages_; queue 151 content/browser/renderer_host/render_widget_helper.cc BackingStoreMsgProxyQueue &queue = it->second; queue 152 content/browser/renderer_host/render_widget_helper.cc DCHECK(!queue.empty()); queue 153 content/browser/renderer_host/render_widget_helper.cc proxy = queue.front(); queue 159 content/browser/renderer_host/render_widget_helper.cc queue.pop_front(); queue 160 content/browser/renderer_host/render_widget_helper.cc if (queue.empty()) queue 224 content/browser/renderer_host/render_widget_helper.cc BackingStoreMsgProxyQueue &queue = it->second; queue 225 content/browser/renderer_host/render_widget_helper.cc DCHECK(queue.front() == proxy); queue 227 content/browser/renderer_host/render_widget_helper.cc queue.pop_front(); queue 228 content/browser/renderer_host/render_widget_helper.cc if (queue.empty()) queue 931 content/browser/renderer_host/render_widget_host_impl.h std::queue<base::Callback<void(bool, const SkBitmap&)> > pending_snapshots_; queue 335 content/browser/renderer_host/render_widget_host_view_android.h std::queue<base::Closure> ack_callbacks_; queue 88 content/browser/speech/google_streaming_remote_engine_unittest.cc std::queue<SpeechRecognitionResults> results_; queue 114 content/browser/web_contents/touch_editable_impl_aura.h std::queue<int> tap_gesture_tap_count_queue_; queue 802 content/child/resource_dispatcher.cc void ResourceDispatcher::ReleaseResourcesInMessageQueue(MessageQueue* queue) { queue 803 content/child/resource_dispatcher.cc while (!queue->empty()) { queue 804 content/child/resource_dispatcher.cc IPC::Message* message = queue->front(); queue 806 content/child/resource_dispatcher.cc queue->pop_front(); queue 201 content/child/resource_dispatcher.h static void ReleaseResourcesInMessageQueue(MessageQueue* queue); queue 81 content/child/webmessageportchannel_impl.h typedef std::queue<Message> MessageQueue; queue 189 content/common/gpu/client/command_buffer_proxy_impl.h std::queue<base::Closure> echo_tasks_; queue 339 content/common/gpu/client/gl_helper.cc std::queue<Request*> request_queue_; queue 378 content/common/gpu/gpu_channel.cc std::queue<PendingMessage> pending_messages_; queue 482 content/common/gpu/media/android_video_decode_accelerator.cc std::queue<int32> empty; queue 122 content/common/gpu/media/android_video_decode_accelerator.h std::queue<int32> free_picture_ids_; queue 147 content/common/gpu/media/android_video_decode_accelerator.h typedef std::queue<std::pair<media::BitstreamBuffer, base::Time> > queue 89 content/common/gpu/media/android_video_encode_accelerator.h typedef std::queue< queue 360 content/common/gpu/media/v4l2_video_decode_accelerator.h std::queue<linked_ptr<BitstreamBufferRef> > decoder_input_queue_; queue 377 content/common/gpu/media/v4l2_video_decode_accelerator.h std::queue<int> input_ready_queue_; queue 394 content/common/gpu/media/v4l2_video_decode_accelerator.h std::queue<int> free_output_buffers_; queue 405 content/common/gpu/media/v4l2_video_decode_accelerator.h std::queue<PictureRecord> pending_picture_ready_; queue 187 content/common/gpu/media/vaapi_video_decode_accelerator.h typedef std::queue<linked_ptr<InputBuffer> > InputBuffers; queue 196 content/common/gpu/media/vaapi_video_decode_accelerator.h typedef std::queue<int32> OutputBuffers; queue 224 content/common/gpu/media/vaapi_video_decode_accelerator.h std::queue<OutputCB> pending_output_cbs_; queue 35 content/common/gpu/media/video_accelerator_unittest_helpers.h std::queue<StateEnum> pending_states_for_notification_; queue 38 content/gpu/gpu_child_thread.h typedef std::queue<IPC::Message*> DeferredMessages; queue 44 content/public/test/android/javatests/src/org/chromium/content/browser/test/NestedSystemMessageHandler.java MessageQueue queue = Looper.myQueue(); queue 45 content/public/test/android/javatests/src/org/chromium/content/browser/test/NestedSystemMessageHandler.java queue.addIdleHandler(new MessageQueue.IdleHandler() { queue 53 content/public/test/android/javatests/src/org/chromium/content/browser/test/NestedSystemMessageHandler.java Class<?> messageQueueClazz = queue.getClass(); queue 69 content/public/test/android/javatests/src/org/chromium/content/browser/test/NestedSystemMessageHandler.java msg = (Message) nextMethod.invoke(queue); queue 665 content/public/test/browser_test_utils.cc message_queue_ = std::queue<std::string>(); queue 290 content/public/test/browser_test_utils.h std::queue<std::string> message_queue_; queue 230 content/renderer/accessibility/renderer_accessibility_complete.cc std::queue<WebAXObject> objs_to_explore; queue 65 content/renderer/gpu/mailbox_output_surface.h std::queue<TransferableFrame> returned_textures_; queue 210 content/renderer/pepper/content_decryptor_delegate.h std::queue<uint32_t> free_buffers_; queue 752 content/renderer/render_widget.h std::queue<SyntheticGestureCompletionCallback> queue 85 device/bluetooth/bluetooth_adapter_chromeos.h typedef std::queue<DiscoveryCallbackPair> DiscoveryCallbackQueue; queue 50 device/hid/hid_connection_linux.h std::queue<PendingHidReport> pending_reports_; queue 51 device/hid/hid_connection_linux.h std::queue<PendingHidRead> pending_reads_; queue 70 device/hid/hid_connection_mac.h std::queue<PendingHidReport> pending_reports_; queue 71 device/hid/hid_connection_mac.h std::queue<PendingHidRead> pending_reads_; queue 272 device/media_transfer_protocol/media_transfer_protocol_manager.cc typedef std::queue<OpenStorageCallback> OpenStorageCallbackQueue; queue 274 device/media_transfer_protocol/media_transfer_protocol_manager.cc typedef std::queue<std::pair<CloseStorageCallback, std::string> queue 276 device/media_transfer_protocol/media_transfer_protocol_manager.cc typedef std::queue<ReadDirectoryCallback> ReadDirectoryCallbackQueue; queue 277 device/media_transfer_protocol/media_transfer_protocol_manager.cc typedef std::queue<ReadFileCallback> ReadFileCallbackQueue; queue 278 device/media_transfer_protocol/media_transfer_protocol_manager.cc typedef std::queue<GetFileInfoCallback> GetFileInfoCallbackQueue; queue 120 extensions/browser/api/socket/socket.h std::queue<WriteRequest> write_queue_; queue 584 extensions/browser/event_router.cc LazyBackgroundTaskQueue* queue = ExtensionSystem::Get( queue 586 extensions/browser/event_router.cc if (queue->ShouldEnqueueTask(context, extension)) { queue 600 extensions/browser/event_router.cc queue->AddPendingTask(context, extension->id(), queue 686 extensions/browser/event_router.cc LazyBackgroundTaskQueue* queue = ExtensionSystem::Get( queue 688 extensions/browser/event_router.cc queue->AddPendingTask(browser_context_, extension->id(), queue 100 extensions/browser/lazy_background_task_queue_unittest.cc LazyBackgroundTaskQueue queue(profile_.get()); queue 104 extensions/browser/lazy_background_task_queue_unittest.cc EXPECT_FALSE(queue.ShouldEnqueueTask(profile_.get(), no_background.get())); queue 108 extensions/browser/lazy_background_task_queue_unittest.cc EXPECT_TRUE(queue.ShouldEnqueueTask(profile_.get(), with_background.get())); queue 124 extensions/browser/lazy_background_task_queue_unittest.cc LazyBackgroundTaskQueue queue(profile_.get()); queue 131 extensions/browser/lazy_background_task_queue_unittest.cc queue.AddPendingTask(profile_.get(), queue 135 extensions/browser/lazy_background_task_queue_unittest.cc EXPECT_EQ(1u, queue.extensions_with_pending_tasks()); queue 140 extensions/browser/lazy_background_task_queue_unittest.cc queue.AddPendingTask(profile_.get(), queue 144 extensions/browser/lazy_background_task_queue_unittest.cc EXPECT_EQ(1u, queue.extensions_with_pending_tasks()); queue 150 extensions/browser/lazy_background_task_queue_unittest.cc queue.AddPendingTask(profile_.get(), queue 154 extensions/browser/lazy_background_task_queue_unittest.cc EXPECT_EQ(2u, queue.extensions_with_pending_tasks()); queue 165 extensions/browser/lazy_background_task_queue_unittest.cc LazyBackgroundTaskQueue queue(profile_.get()); queue 169 extensions/browser/lazy_background_task_queue_unittest.cc queue.ProcessPendingTasks(NULL, profile_.get(), extension); queue 173 extensions/browser/lazy_background_task_queue_unittest.cc queue.AddPendingTask(profile_.get(), queue 178 extensions/browser/lazy_background_task_queue_unittest.cc EXPECT_EQ(1u, queue.extensions_with_pending_tasks()); queue 182 extensions/browser/lazy_background_task_queue_unittest.cc queue.ProcessPendingTasks(NULL, &profile2, extension); queue 184 extensions/browser/lazy_background_task_queue_unittest.cc EXPECT_EQ(1u, queue.extensions_with_pending_tasks()); queue 188 extensions/browser/lazy_background_task_queue_unittest.cc queue.ProcessPendingTasks(NULL, profile_.get(), extension); queue 190 extensions/browser/lazy_background_task_queue_unittest.cc EXPECT_EQ(0u, queue.extensions_with_pending_tasks()); queue 655 gpu/command_buffer/client/gles2_implementation.h std::queue<int32> swap_buffers_tokens_; queue 656 gpu/command_buffer/client/gles2_implementation.h std::queue<int32> rate_limit_tokens_; queue 1792 gpu/command_buffer/service/gles2_cmd_decoder.cc std::queue<linked_ptr<FenceCallback> > pending_readpixel_fences_; queue 153 gpu/command_buffer/service/gpu_scheduler.h std::queue<linked_ptr<UnscheduleFence> > unschedule_fences_; queue 42 gpu/tools/compositor_model_bench/compositor_model_bench.cc using std::queue; queue 341 gpu/tools/compositor_model_bench/compositor_model_bench.cc queue<SimulationSpecification> sims_remaining_; queue 342 gpu/tools/compositor_model_bench/compositor_model_bench.cc queue<SimulationSpecification> sims_completed_; queue 160 ipc/ipc_channel_posix.h std::queue<Message*> output_queue_; queue 75 ipc/ipc_channel_win.h std::queue<Message*> output_queue_; queue 119 media/base/android/java/src/org/chromium/media/UsbMidiDeviceAndroid.java request.queue(buffer, buffer.remaining()); queue 149 media/base/android/java/src/org/chromium/media/UsbMidiDeviceAndroid.java request.queue(buffer, buffer.capacity()); queue 197 media/base/android/java/src/org/chromium/media/UsbMidiDeviceAndroid.java request.queue(ByteBuffer.wrap(bs), bs.length); queue 36 media/base/decoder_buffer_queue_unittest.cc DecoderBufferQueue queue; queue 37 media/base/decoder_buffer_queue_unittest.cc EXPECT_TRUE(queue.IsEmpty()); queue 39 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(0)); queue 40 media/base/decoder_buffer_queue_unittest.cc EXPECT_FALSE(queue.IsEmpty()); queue 44 media/base/decoder_buffer_queue_unittest.cc DecoderBufferQueue queue; queue 45 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(0)); queue 46 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(1)); queue 47 media/base/decoder_buffer_queue_unittest.cc EXPECT_FALSE(queue.IsEmpty()); queue 48 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(1, queue.Duration().InSeconds()); queue 50 media/base/decoder_buffer_queue_unittest.cc queue.Clear(); queue 51 media/base/decoder_buffer_queue_unittest.cc EXPECT_TRUE(queue.IsEmpty()); queue 52 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(0, queue.Duration().InSeconds()); queue 56 media/base/decoder_buffer_queue_unittest.cc DecoderBufferQueue queue; queue 57 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(0, queue.Duration().InSeconds()); queue 59 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(0)); queue 60 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(0, queue.Duration().InSeconds()); queue 62 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(1)); queue 63 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(1, queue.Duration().InSeconds()); queue 65 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(2)); queue 66 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(2, queue.Duration().InSeconds()); queue 68 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(4)); queue 69 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(4, queue.Duration().InSeconds()); queue 71 media/base/decoder_buffer_queue_unittest.cc queue.Pop(); queue 72 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(3, queue.Duration().InSeconds()); queue 74 media/base/decoder_buffer_queue_unittest.cc queue.Pop(); queue 75 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(2, queue.Duration().InSeconds()); queue 77 media/base/decoder_buffer_queue_unittest.cc queue.Pop(); queue 78 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(0, queue.Duration().InSeconds()); queue 80 media/base/decoder_buffer_queue_unittest.cc queue.Pop(); queue 81 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(0, queue.Duration().InSeconds()); queue 85 media/base/decoder_buffer_queue_unittest.cc DecoderBufferQueue queue; queue 86 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(10)); queue 87 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(12)); queue 88 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(2, queue.Duration().InSeconds()); queue 91 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(8)); queue 92 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(2, queue.Duration().InSeconds()); queue 96 media/base/decoder_buffer_queue_unittest.cc queue.Pop(); queue 97 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(0, queue.Duration().InSeconds()); queue 101 media/base/decoder_buffer_queue_unittest.cc queue.Pop(); queue 102 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(0, queue.Duration().InSeconds()); queue 106 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(11)); queue 107 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(0, queue.Duration().InSeconds()); queue 111 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(14)); queue 112 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(0, queue.Duration().InSeconds()); queue 115 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(17)); queue 116 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(3, queue.Duration().InSeconds()); queue 121 media/base/decoder_buffer_queue_unittest.cc DecoderBufferQueue queue; queue 122 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(0)); queue 123 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(4)); queue 124 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(4, queue.Duration().InSeconds()); queue 126 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(-1)); queue 127 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(4, queue.Duration().InSeconds()); queue 129 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(6)); queue 130 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(6, queue.Duration().InSeconds()); queue 132 media/base/decoder_buffer_queue_unittest.cc queue.Pop(); queue 133 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(2, queue.Duration().InSeconds()); queue 135 media/base/decoder_buffer_queue_unittest.cc queue.Pop(); queue 136 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(0, queue.Duration().InSeconds()); queue 138 media/base/decoder_buffer_queue_unittest.cc queue.Pop(); queue 139 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(0, queue.Duration().InSeconds()); queue 141 media/base/decoder_buffer_queue_unittest.cc queue.Pop(); queue 142 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(0, queue.Duration().InSeconds()); queue 146 media/base/decoder_buffer_queue_unittest.cc DecoderBufferQueue queue; queue 147 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(queue.data_size(), 0u); queue 149 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(0, 1200u)); queue 150 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(queue.data_size(), 1200u); queue 152 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(1, 1000u)); queue 153 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(queue.data_size(), 2200u); queue 155 media/base/decoder_buffer_queue_unittest.cc queue.Pop(); queue 156 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(queue.data_size(), 1000u); queue 158 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(2, 999u)); queue 159 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(3, 999u)); queue 160 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(queue.data_size(), 2998u); queue 162 media/base/decoder_buffer_queue_unittest.cc queue.Clear(); queue 163 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(queue.data_size(), 0u); queue 165 media/base/decoder_buffer_queue_unittest.cc queue.Push(CreateBuffer(4, 1400u)); queue 166 media/base/decoder_buffer_queue_unittest.cc EXPECT_EQ(queue.data_size(), 1400u); queue 46 media/base/serial_runner.h std::queue<BoundPipelineStatusCB> bound_fns_; queue 46 media/base/stream_parser_unittest.cc BufferQueue* queue) { queue 48 media/base/stream_parser_unittest.cc DCHECK(queue); queue 57 media/base/stream_parser_unittest.cc queue->push_back(buffer); queue 38 media/cast/rtcp/rtcp.h typedef std::queue<RtcpSendTimePair> RtcpSendTimeQueue; queue 127 media/cast/rtcp/rtcp_receiver.h std::queue<size_t> receiver_event_hash_queue_; queue 122 media/cdm/ppapi/cdm_wrapper.h std::queue<uint32_t> pending_key_request_session_ids_; queue 74 media/ffmpeg/ffmpeg_unittest.cc std::queue<AVPacket*> packets_; queue 27 media/filters/chunk_demuxer.cc static TimeDelta EndTimestamp(const StreamParser::BufferQueue& queue) { queue 28 media/filters/chunk_demuxer.cc return queue.back()->timestamp() + queue.back()->duration(); queue 335 media/filters/source_buffer_stream_unittest.cc BufferQueue queue; queue 366 media/filters/source_buffer_stream_unittest.cc queue.push_back(buffer); queue 368 media/filters/source_buffer_stream_unittest.cc if (!queue.empty()) queue 369 media/filters/source_buffer_stream_unittest.cc EXPECT_EQ(expect_success, stream_->Append(queue)); queue 31 media/midi/midi_message_queue_unittest.cc void Add(MidiMessageQueue* queue, const T(&array)[N]) { queue 32 media/midi/midi_message_queue_unittest.cc queue->Add(array, N); queue 58 media/midi/midi_message_queue_unittest.cc MidiMessageQueue queue(false); queue 60 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 65 media/midi/midi_message_queue_unittest.cc MidiMessageQueue queue(false); queue 66 media/midi/midi_message_queue_unittest.cc Add(&queue, kGMOn); queue 67 media/midi/midi_message_queue_unittest.cc Add(&queue, kBrokenData1); queue 68 media/midi/midi_message_queue_unittest.cc Add(&queue, kNoteOnWithRunningStatus); queue 69 media/midi/midi_message_queue_unittest.cc Add(&queue, kBrokenData2); queue 70 media/midi/midi_message_queue_unittest.cc Add(&queue, kChannelPressureWithRunningStatus); queue 71 media/midi/midi_message_queue_unittest.cc Add(&queue, kBrokenData3); queue 72 media/midi/midi_message_queue_unittest.cc Add(&queue, kNoteOn); queue 73 media/midi/midi_message_queue_unittest.cc Add(&queue, kBrokenData1); queue 74 media/midi/midi_message_queue_unittest.cc Add(&queue, kGSOn); queue 75 media/midi/midi_message_queue_unittest.cc Add(&queue, kBrokenData2); queue 76 media/midi/midi_message_queue_unittest.cc Add(&queue, kTimingClock); queue 77 media/midi/midi_message_queue_unittest.cc Add(&queue, kBrokenData3); queue 80 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 82 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 84 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 87 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 89 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 91 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 93 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 98 media/midi/midi_message_queue_unittest.cc MidiMessageQueue queue(true); queue 99 media/midi/midi_message_queue_unittest.cc Add(&queue, kGMOn); queue 100 media/midi/midi_message_queue_unittest.cc Add(&queue, kBrokenData1); queue 101 media/midi/midi_message_queue_unittest.cc Add(&queue, kNoteOnWithRunningStatus); queue 102 media/midi/midi_message_queue_unittest.cc Add(&queue, kBrokenData2); queue 103 media/midi/midi_message_queue_unittest.cc Add(&queue, kChannelPressureWithRunningStatus); queue 104 media/midi/midi_message_queue_unittest.cc Add(&queue, kBrokenData3); queue 105 media/midi/midi_message_queue_unittest.cc Add(&queue, kNoteOn); queue 106 media/midi/midi_message_queue_unittest.cc Add(&queue, kBrokenData1); queue 107 media/midi/midi_message_queue_unittest.cc Add(&queue, kGSOn); queue 108 media/midi/midi_message_queue_unittest.cc Add(&queue, kBrokenData2); queue 109 media/midi/midi_message_queue_unittest.cc Add(&queue, kTimingClock); queue 110 media/midi/midi_message_queue_unittest.cc Add(&queue, kDataByte0); queue 113 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 115 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 117 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 120 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 123 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 125 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 128 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 131 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 133 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 135 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 137 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 143 media/midi/midi_message_queue_unittest.cc MidiMessageQueue queue(true); queue 148 media/midi/midi_message_queue_unittest.cc Add(&queue, kNoteOnWithRunningStatusWithkTimingClock); queue 150 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 152 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 154 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 156 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 158 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 160 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 162 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 164 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 166 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 168 media/midi/midi_message_queue_unittest.cc queue.Get(&message); queue 150 media/video/capture/mac/avfoundation_glue.h queue:(dispatch_queue_t)sampleBufferCallbackQueue; queue 39 mojo/public/cpp/bindings/lib/message_queue.h std::queue<Message*> queue_; queue 37 mojo/public/cpp/bindings/tests/router_unittest.cc explicit MessageAccumulator(internal::MessageQueue* queue) : queue_(queue) { queue 644 net/cookies/cookie_monster.h std::queue<scoped_refptr<CookieMonsterTask> > tasks_pending_; queue 860 net/cookies/cookie_monster_unittest.cc std::queue<CookieMonster::PersistentCookieStore::LoadedCallback> queue 352 net/disk_cache/simple/simple_entry_impl.h std::queue<SimpleEntryOperation> pending_operations_; queue 78 net/ftp/ftp_ctrl_response_buffer.h std::queue<ParsedLine> lines_; queue 92 net/ftp/ftp_ctrl_response_buffer.h std::queue<FtpCtrlResponse> responses_; queue 314 net/http/http_pipelined_connection_impl.h std::queue<int> request_order_; queue 316 net/http/http_pipelined_connection_impl.h std::queue<PendingSendRequest*> pending_send_request_queue_; queue 141 net/socket/ssl_server_socket_unittest.cc std::queue<scoped_refptr<net::DrainableIOBuffer> > data_; queue 36 net/socket/unix_domain_socket_posix_unittest.cc using std::queue; queue 93 net/socket/unix_domain_socket_posix_unittest.cc queue<EventType> events_; queue 27 net/spdy/spdy_read_queue_unittest.cc SpdyReadQueue* queue) { queue 30 net/spdy/spdy_read_queue_unittest.cc size_t old_total_size = queue->GetTotalSize(); queue 33 net/spdy/spdy_read_queue_unittest.cc queue->Enqueue( queue 36 net/spdy/spdy_read_queue_unittest.cc EXPECT_FALSE(queue->IsEmpty()); queue 37 net/spdy/spdy_read_queue_unittest.cc EXPECT_EQ(old_total_size + i, queue->GetTotalSize()); queue 43 net/spdy/spdy_read_queue_unittest.cc std::string DrainToString(size_t max_buffer_size, SpdyReadQueue* queue) { queue 47 net/spdy/spdy_read_queue_unittest.cc size_t padding = std::max(static_cast<size_t>(4096), queue->GetTotalSize()); queue 53 net/spdy/spdy_read_queue_unittest.cc while (!queue->IsEmpty()) { queue 54 net/spdy/spdy_read_queue_unittest.cc size_t old_total_size = queue->GetTotalSize(); queue 56 net/spdy/spdy_read_queue_unittest.cc size_t dequeued_bytes = queue->Dequeue(buffer_data, max_buffer_size); queue 69 net/spdy/spdy_read_queue_unittest.cc EXPECT_EQ(queue->GetTotalSize(), old_total_size - dequeued_bytes); queue 71 net/spdy/spdy_read_queue_unittest.cc EXPECT_TRUE(queue->IsEmpty()); queue 768 net/spdy/spdy_session.cc PendingStreamRequestQueue* queue = &pending_create_stream_queues_[i]; queue 769 net/spdy/spdy_session.cc DCHECK(std::find_if(queue->begin(), queue 770 net/spdy/spdy_session.cc queue->end(), queue 771 net/spdy/spdy_session.cc RequestEquals(request)) == queue->end()); queue 775 net/spdy/spdy_session.cc PendingStreamRequestQueue* queue = queue 780 net/spdy/spdy_session.cc std::find_if(queue->begin(), queue->end(), RequestEquals(request)); queue 783 net/spdy/spdy_session.cc if (it != queue->end()) { queue 784 net/spdy/spdy_session.cc it = queue->erase(it); queue 787 net/spdy/spdy_session.cc DCHECK(std::find_if(it, queue->end(), RequestEquals(request)) == queue 788 net/spdy/spdy_session.cc queue->end()); queue 3049 net/spdy/spdy_session.cc std::deque<SpdyStreamId>* queue = &stream_send_unstall_queue_[i]; queue 3050 net/spdy/spdy_session.cc if (!queue->empty()) { queue 3051 net/spdy/spdy_session.cc SpdyStreamId stream_id = queue->front(); queue 3052 net/spdy/spdy_session.cc queue->pop_front(); queue 94 net/spdy/spdy_write_queue.cc std::deque<PendingWrite>* queue = &queue_[priority]; queue 95 net/spdy/spdy_write_queue.cc std::deque<PendingWrite>::iterator out_it = queue->begin(); queue 96 net/spdy/spdy_write_queue.cc for (std::deque<PendingWrite>::const_iterator it = queue->begin(); queue 97 net/spdy/spdy_write_queue.cc it != queue->end(); ++it) { queue 105 net/spdy/spdy_write_queue.cc queue->erase(out_it, queue->end()); queue 112 net/spdy/spdy_write_queue.cc std::deque<PendingWrite>* queue = &queue_[i]; queue 113 net/spdy/spdy_write_queue.cc std::deque<PendingWrite>::iterator out_it = queue->begin(); queue 114 net/spdy/spdy_write_queue.cc for (std::deque<PendingWrite>::const_iterator it = queue->begin(); queue 115 net/spdy/spdy_write_queue.cc it != queue->end(); ++it) { queue 124 net/spdy/spdy_write_queue.cc queue->erase(out_it, queue->end()); queue 151 net/url_request/url_request_throttler_entry.h std::queue<base::TimeTicks> send_log_; queue 341 net/websockets/websocket_channel.h std::queue<PendingReceivedFrame> pending_received_frames_; queue 75 ppapi/proxy/file_chooser_resource.h std::queue<PP_Resource> file_queue_; queue 94 ppapi/proxy/file_system_resource.h std::queue<QuotaRequest> pending_quota_requests_; queue 128 ppapi/proxy/tcp_socket_resource_base.h std::queue<scoped_refptr<TrackedCallback> > set_option_callbacks_; queue 109 ppapi/proxy/websocket_resource.h std::queue<scoped_refptr<Var> > received_messages_; queue 50 remoting/base/rate_counter.h std::queue<DataPoint> data_points_; queue 90 remoting/host/oauth_token_getter.cc std::queue<TokenCallback> callbacks(pending_callbacks_); queue 91 remoting/host/oauth_token_getter.cc pending_callbacks_ = std::queue<TokenCallback>(); queue 88 remoting/host/oauth_token_getter.h std::queue<OAuthTokenGetter::TokenCallback> pending_callbacks_; queue 261 remoting/host/setup/daemon_controller.h std::queue<base::Closure> pending_requests_; queue 69 remoting/host/setup/oauth_client.h std::queue<Request> pending_requests_; queue 59 remoting/jingle_glue/fake_signal_strategy.h std::queue<buzz::XmlElement*> pending_messages_; queue 196 remoting/protocol/pairing_registry.h std::queue<base::Closure> pending_requests_; queue 71 remoting/protocol/v2_authenticator.h std::queue<std::string> pending_messages_; queue 19 sync/internal_api/change_reorder_buffer.cc using std::queue; queue 185 sync/internal_api/change_reorder_buffer.cc queue<int64> to_visit; queue 802 sync/internal_api/sync_encryption_handler_impl.cc std::queue<int64> to_visit; queue 110 sync/syncable/nigori_util.cc std::queue<Id> to_visit; queue 73 third_party/libaddressinput/chromium/cpp/src/util/trie.cc std::queue<const Trie<T>*> node_queue; queue 924 third_party/libevent/event.c event_queue_remove(struct event_base *base, struct event *ev, int queue) queue 926 third_party/libevent/event.c if (!(ev->ev_flags & queue)) queue 928 third_party/libevent/event.c ev, ev->ev_fd, queue); queue 933 third_party/libevent/event.c ev->ev_flags &= ~queue; queue 934 third_party/libevent/event.c switch (queue) { queue 947 third_party/libevent/event.c event_errx(1, "%s: unknown queue %x", __func__, queue); queue 952 third_party/libevent/event.c event_queue_insert(struct event_base *base, struct event *ev, int queue) queue 954 third_party/libevent/event.c if (ev->ev_flags & queue) { queue 956 third_party/libevent/event.c if (queue & EVLIST_ACTIVE) queue 960 third_party/libevent/event.c ev, ev->ev_fd, queue); queue 966 third_party/libevent/event.c ev->ev_flags |= queue; queue 967 third_party/libevent/event.c switch (queue) { queue 981 third_party/libevent/event.c event_errx(1, "%s: unknown queue %x", __func__, queue); queue 378 third_party/v4l2capture/v4l2capture.c static PyObject *Video_device_read_internal(Video_device *self, int queue) queue 404 third_party/v4l2capture/v4l2capture.c if(queue && my_ioctl(self->fd, VIDIOC_QBUF, &buffer)) queue 382 ui/aura/gestures/gesture_recognizer_unittest.cc void set_queue_events(bool queue) { queue_events_ = queue; } queue 392 ui/aura/gestures/gesture_recognizer_unittest.cc std::queue<ui::TouchEvent*> queue_; queue 1787 ui/aura/gestures/gesture_recognizer_unittest.cc scoped_ptr<aura::Window> queue(CreateTestWindowWithDelegate( queue 1790 ui/aura/gestures/gesture_recognizer_unittest.cc queued_delegate->set_window(queue.get()); queue 55 ui/events/gesture_detection/touch_disposition_gesture_filter.h typedef std::queue<GestureEventDataPacket> GestureSequence; queue 88 ui/events/gesture_detection/touch_disposition_gesture_filter.h std::queue<GestureSequence> sequences_; queue 43 ui/events/ozone/evdev/touch_event_converter_evdev_unittest.cc void ConfigureReadMock(struct input_event* queue, queue 95 ui/events/ozone/evdev/touch_event_converter_evdev_unittest.cc void MockTouchEventConverterEvdev::ConfigureReadMock(struct input_event* queue, queue 99 ui/events/ozone/evdev/touch_event_converter_evdev_unittest.cc queue + queue_index, queue 40 ui/gl/sync_control_vsync_provider.h std::queue<base::TimeDelta> last_computed_intervals_; queue 27 webkit/browser/appcache/appcache_quota_client.cc void RunFront(appcache::AppCacheQuotaClient::RequestQueue* queue) { queue 28 webkit/browser/appcache/appcache_quota_client.cc base::Closure request = queue->front(); queue 29 webkit/browser/appcache/appcache_quota_client.cc queue->pop_front(); queue 202 webkit/browser/fileapi/obfuscated_file_util.cc std::queue<FileRecord> recurse_queue_; queue 68 webkit/browser/fileapi/recursive_operation_delegate.cc pending_directory_stack_.push(std::queue<FileSystemURL>()); queue 102 webkit/browser/fileapi/recursive_operation_delegate.cc pending_directory_stack_.push(std::queue<FileSystemURL>()); queue 142 webkit/browser/fileapi/recursive_operation_delegate.h std::stack<std::queue<FileSystemURL> > pending_directory_stack_; queue 143 webkit/browser/fileapi/recursive_operation_delegate.h std::queue<FileSystemURL> pending_files_; queue 112 webkit/browser/quota/quota_callbacks.h CallbackQueueType& queue = callback_map_[key]; queue 113 webkit/browser/quota/quota_callbacks.h queue.Run(args);