Home
last modified time | relevance | path

Searched refs:pending_tasks_ (Results 1 – 25 of 33) sorted by relevance

12

/external/chromium_org/base/test/
Dtest_simple_task_runner.cc22 pending_tasks_.push_back( in PostDelayedTask()
33 pending_tasks_.push_back( in PostNonNestableDelayedTask()
47 return pending_tasks_; in GetPendingTasks()
52 return !pending_tasks_.empty(); in HasPendingTask()
57 return pending_tasks_.front().GetTimeToRun() - base::TimeTicks(); in NextPendingTaskDelay()
62 pending_tasks_.clear(); in ClearPendingTasks()
69 tasks_to_run.swap(pending_tasks_); in RunPendingTasks()
77 while (!pending_tasks_.empty()) { in RunUntilIdle()
Dtest_simple_task_runner.h77 std::deque<TestPendingTask> pending_tasks_; variable
/external/chromium_org/cc/test/
Dordered_simple_task_runner.cc105 pending_tasks_.insert(pt); in PostDelayedTask()
121 pending_tasks_.insert(pt); in PostNonNestableDelayedTask()
131 if (pending_tasks_.size() <= 0) { in NextTaskTime()
135 return pending_tasks_.begin()->GetTimeToRun(); in NextTaskTime()
141 if (pending_tasks_.size() <= 0) { in DelayToNextTaskTime()
191 while (pending_tasks_.size() > 0) { in RunTasksWhile()
205 if (!condition_success || pending_tasks_.size() == 0) { in RunTasksWhile()
210 pending_tasks_.begin(); in RunTasksWhile()
219 pending_tasks_.erase(task_to_run); in RunTasksWhile()
222 return pending_tasks_.size() > 0; in RunTasksWhile()
[all …]
Dordered_simple_task_runner.h146 std::set<TestOrderablePendingTask> pending_tasks_; variable
/external/chromium_org/base/threading/
Dworker_pool_posix.cc135 while (!pending_tasks_.empty()) in ~PosixDynamicThreadPool()
136 pending_tasks_.pop(); in ~PosixDynamicThreadPool()
160 pending_tasks_.push(*pending_task); in AddTask()
164 if (static_cast<size_t>(num_idle_threads_) >= pending_tasks_.size()) { in AddTask()
181 if (pending_tasks_.empty()) { // No work available, wait for work. in WaitForTask()
190 if (pending_tasks_.empty()) { in WaitForTask()
197 PendingTask pending_task = pending_tasks_.front(); in WaitForTask()
198 pending_tasks_.pop(); in WaitForTask()
Dsequenced_worker_pool.cc446 PendingTaskSet pending_tasks_; member in base::SequencedWorkerPool::Inner
611 pending_tasks_.insert(sequenced); in PostTask()
650 if (pending_tasks_.empty() && waiting_thread_count_ == threads_.size()) in CleanupForTesting()
908 static_cast<int>(pending_tasks_.size())); in GetWork()
936 PendingTaskSet::iterator i = pending_tasks_.begin(); in GetWork()
940 while (i != pending_tasks_.end()) { in GetWork()
964 pending_tasks_.erase(i++); in GetWork()
975 pending_tasks_.erase(i); in GetWork()
982 pending_tasks_.erase(i); in GetWork()
1089 for (PendingTaskSet::const_iterator i = pending_tasks_.begin(); in PrepareToStartAdditionalThreadIfHelpful()
[all …]
Dworker_pool_posix.h87 TaskQueue pending_tasks_; variable
/external/chromium_org/chrome/browser/sync_file_system/local/
Dsyncable_file_operation_runner.cc57 for_each(pending_tasks_.begin(), pending_tasks_.end(), in ~SyncableFileOperationRunner()
71 pending_tasks_.push_back(task.release()); in PostOperationTask()
77 for (std::list<Task*>::iterator iter = pending_tasks_.begin(); in RunNextRunnableTask()
78 iter != pending_tasks_.end() && ShouldStartMoreTasks();) { in RunNextRunnableTask()
83 pending_tasks_.erase(iter++); in RunNextRunnableTask()
Dsyncable_file_operation_runner.h82 return static_cast<int64>(pending_tasks_.size()); in num_pending_tasks()
94 std::list<Task*> pending_tasks_; variable
/external/chromium_org/extensions/browser/
Dlazy_background_task_queue.cc74 PendingTasksMap::iterator it = pending_tasks_.find(key); in AddPendingTask()
75 if (it == pending_tasks_.end()) { in AddPendingTask()
77 pending_tasks_[key] = linked_ptr<PendingTasksList>(tasks_list); in AddPendingTask()
112 PendingTasksMap::iterator map_it = pending_tasks_.find(key); in ProcessPendingTasks()
113 if (map_it == pending_tasks_.end()) { in ProcessPendingTasks()
128 pending_tasks_.erase(key); in ProcessPendingTasks()
Dstate_store.cc48 std::vector<base::Closure> pending_tasks_; member in extensions::StateStore::DelayedTaskQueue
55 pending_tasks_.push_back(task); in InvokeWhenReady()
62 for (size_t i = 0; i < pending_tasks_.size(); ++i) in SetReady()
63 pending_tasks_[i].Run(); in SetReady()
64 pending_tasks_.clear(); in SetReady()
Dlazy_background_task_queue.h44 size_t extensions_with_pending_tasks() { return pending_tasks_.size(); } in extensions_with_pending_tasks()
94 PendingTasksMap pending_tasks_; variable
/external/chromium_org/chrome/service/cloud_print/
Dcloud_print_connector.cc70 pending_tasks_.clear(); in Start()
92 pending_tasks_.clear(); in Stop()
492 pending_tasks_.push_back(task); in AddPendingTask()
494 if (pending_tasks_.size() == 1) { in AddPendingTask()
503 if (pending_tasks_.size() == 0) in ProcessPendingTask()
506 PendingTask task = pending_tasks_.front(); in ProcessPendingTask()
524 if (pending_tasks_.size() == 0) in ContinuePendingTaskProcessing()
528 pending_tasks_.pop_front(); in ContinuePendingTaskProcessing()
529 if (pending_tasks_.size() != 0) { in ContinuePendingTaskProcessing()
586 DCHECK(pending_tasks_.size() > 0 && in OnReceivePrinterCaps()
[all …]
/external/chromium_org/components/dom_distiller/standalone/
Dcontent_extractor.cc223 : pending_tasks_(0), in ContentExtractor()
258 while (pending_tasks_ < max_tasks_ && next_request_ < requests_.size()) { in PumpQueue()
264 ++pending_tasks_; in PumpQueue()
286 --pending_tasks_; in FinishRequest()
287 if (next_request_ == requests_.size() && pending_tasks_ == 0) { in FinishRequest()
323 size_t pending_tasks_; member in dom_distiller::ContentExtractor
/external/chromium_org/sync/test/engine/
Dmock_model_type_sync_proxy.cc25 pending_tasks_.push_back(task); in OnCommitCompleted()
39 pending_tasks_.push_back(task); in OnUpdateReceived()
49 for (std::vector<base::Closure>::iterator it = pending_tasks_.begin(); in RunQueuedTasks()
50 it != pending_tasks_.end(); in RunQueuedTasks()
54 pending_tasks_.clear(); in RunQueuedTasks()
Dmock_model_type_sync_proxy.h117 std::vector<base::Closure> pending_tasks_; variable
/external/chromium_org/ppapi/proxy/
Dppb_message_loop_proxy.cc95 for (size_t i = 0; i < pending_tasks_.size(); i++) { in AttachToCurrentThread()
96 const TaskInfo& info = pending_tasks_[i]; in AttachToCurrentThread()
99 pending_tasks_.clear(); in AttachToCurrentThread()
190 pending_tasks_.push_back(info); in PostClosure()
Dppb_message_loop_proxy.h106 std::vector<TaskInfo> pending_tasks_; variable
/external/chromium_org/chrome/browser/media_galleries/win/
Dmtp_device_delegate_impl_win.cc467 while (!pending_tasks_.empty()) in CancelPendingTasksAndDeleteDelegate()
468 pending_tasks_.pop(); in CancelPendingTasksAndDeleteDelegate()
476 DCHECK(pending_tasks_.empty()); in EnsureInitAndRunTask()
486 pending_tasks_.push(task_info); in EnsureInitAndRunTask()
515 if (pending_tasks_.empty()) in ProcessNextPendingRequest()
517 const PendingTaskInfo& task_info = pending_tasks_.front(); in ProcessNextPendingRequest()
523 pending_tasks_.pop(); in ProcessNextPendingRequest()
Dmtp_device_delegate_impl_win.h212 std::queue<PendingTaskInfo> pending_tasks_; variable
/external/chromium_org/chrome/browser/media_galleries/linux/
Dmtp_device_delegate_impl_linux.cc594 pending_tasks_.push_front(task_info); in EnsureInitAndRunTask()
596 pending_tasks_.push_back(task_info); in EnsureInitAndRunTask()
623 pending_tasks_.push_front(task_info); in RunTask()
668 if (pending_tasks_.empty()) in ProcessNextPendingRequest()
671 PendingTaskInfo task_info = pending_tasks_.front(); in ProcessNextPendingRequest()
672 pending_tasks_.pop_front(); in ProcessNextPendingRequest()
842 DCHECK(path.IsParent(pending_tasks_.front().path)); in OnDidFillFileCache()
845 pending_tasks_.front().cached_path = path; in OnDidFillFileCache()
854 pending_tasks_.front().path.clear(); in OnFillFileCacheFailed()
/external/chromium_org/chrome/browser/sync_file_system/drive_backend/
Dsync_task_manager.cc360 pending_tasks_.push(PendingTask(closure, priority, pending_task_seq_++)); in PushPendingTask()
391 if (!pending_tasks_.empty()) { in MaybeStartNextForegroundTask()
392 base::Closure closure = pending_tasks_.top().task; in MaybeStartNextForegroundTask()
393 pending_tasks_.pop(); in MaybeStartNextForegroundTask()
/external/chromium_org/components/sync_driver/
Dnon_ui_data_type_controller_unittest.cc126 for (std::vector<PendingTask>::const_iterator it = pending_tasks_.begin(); in UnblockBackendTasks()
127 it != pending_tasks_.end(); ++it) { in UnblockBackendTasks()
130 pending_tasks_.clear(); in UnblockBackendTasks()
142 pending_tasks_.push_back(PendingTask(from_here, task)); in PostTaskOnBackendThread()
180 std::vector<PendingTask> pending_tasks_; member in sync_driver::__anone9bc02660111::NonUIDataTypeControllerFake
/external/chromium_org/content/browser/appcache/
Dmock_appcache_storage.cc453 pending_tasks_.push_back(task); in ScheduleTask()
461 DCHECK(!pending_tasks_.empty()); in RunOnePendingTask()
462 base::Closure task = pending_tasks_.front(); in RunOnePendingTask()
463 pending_tasks_.pop_front(); in RunOnePendingTask()
/external/chromium_org/chrome/browser/chromeos/drive/
Dchange_list_loader.h70 std::vector<base::Closure> pending_tasks_; variable

12