Home
last modified time | relevance | path

Searched defs:task_source (Results 1 – 25 of 27) sorted by relevance

12

/external/cronet/base/task/thread_pool/
Dpriority_queue.cc23 TaskSourceAndSortKey(RegisteredTaskSource task_source, in TaskSourceAndSortKey()
75 const RegisteredTaskSource& task_source() const { return task_source_; } in task_source() function in base::internal::PriorityQueue::TaskSourceAndSortKey
76 RegisteredTaskSource& task_source() { return task_source_; } in task_source() function in base::internal::PriorityQueue::TaskSourceAndSortKey
92 auto task_source = PopTaskSource(); in ~PriorityQueue() local
102 void PriorityQueue::Push(RegisteredTaskSource task_source, in Push()
134 RegisteredTaskSource task_source = in PopTaskSource() local
141 const TaskSource& task_source) { in RemoveTaskSource()
162 void PriorityQueue::UpdateSortKey(const TaskSource& task_source, in UpdateSortKey()
Ddelayed_priority_queue.cc22 TaskSourceAndDelayedSortKey(scoped_refptr<TaskSource> task_source, in TaskSourceAndDelayedSortKey()
77 scoped_refptr<TaskSource> task_source() const { return task_source_; } in task_source() function in base::internal::DelayedPriorityQueue::TaskSourceAndDelayedSortKey
93 auto task_source = PopTaskSource(); in ~DelayedPriorityQueue() local
101 void DelayedPriorityQueue::Push(scoped_refptr<TaskSource> task_source, in Push()
123 scoped_refptr<TaskSource> task_source = in PopTaskSource() local
129 scoped_refptr<TaskSource> task_source) { in RemoveTaskSource()
148 scoped_refptr<TaskSource> task_source) { in UpdateDelayedSortKey()
Dtask_tracker.cc104 TaskSource* task_source, in EmitThreadPoolTraceEventMetadata()
308 void TaskTracker::WillEnqueueJob(JobTaskSource* task_source) { in WillEnqueueJob()
359 scoped_refptr<TaskSource> task_source) { in RegisterTaskSource()
385 RegisteredTaskSource task_source) { in RunAndPopNextTask()
435 TaskSource* task_source, in RunTask()
577 scoped_refptr<TaskSource> task_source) { in UnregisterTaskSource()
623 TaskSource* task_source, in RunContinueOnShutdown()
631 TaskSource* task_source, in RunSkipOnShutdown()
639 TaskSource* task_source, in RunBlockShutdown()
647 TaskSource* task_source, in RunTaskImpl()
[all …]
Dtest_utils.cc65 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in PostDelayedTask() local
205 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local
219 bool MockPooledTaskRunnerDelegate::ShouldYield(const TaskSource* task_source) { in ShouldYield()
224 scoped_refptr<JobTaskSource> task_source) { in EnqueueJobTaskSource()
241 scoped_refptr<JobTaskSource> task_source) { in RemoveJobTaskSource()
246 scoped_refptr<TaskSource> task_source, in UpdatePriority()
254 scoped_refptr<TaskSource> task_source, in UpdateJobPriority()
323 scoped_refptr<TaskSource> task_source) { in QueueAndRunTaskSource()
Djob_task_source_unittest.cc65 auto task_source = job_task->GetJobTaskSource( in StartJob() local
274 scoped_refptr<JobTaskSource> task_source = in TEST_P() local
289 scoped_refptr<JobTaskSource> task_source = internal::CreateJobTaskSource( in TEST_P() local
316 scoped_refptr<JobTaskSource> task_source = internal::CreateJobTaskSource( in TEST_P() local
336 scoped_refptr<JobTaskSource> task_source = in TEST_P() local
348 scoped_refptr<JobTaskSource> task_source = in TEST_P() local
441 scoped_refptr<JobTaskSource> task_source = internal::CreateJobTaskSource( in TEST_P() local
492 scoped_refptr<JobTaskSource> task_source = in TEST_P() local
506 scoped_refptr<JobTaskSource> task_source = in TEST_P() local
Dthread_pool_impl.cc395 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local
459 bool ThreadPoolImpl::ShouldYield(const TaskSource* task_source) { in ShouldYield()
472 scoped_refptr<JobTaskSource> task_source) { in EnqueueJobTaskSource()
487 scoped_refptr<JobTaskSource> task_source) { in RemoveJobTaskSource()
494 void ThreadPoolImpl::UpdatePriority(scoped_refptr<TaskSource> task_source, in UpdatePriority()
531 void ThreadPoolImpl::UpdateJobPriority(scoped_refptr<TaskSource> task_source, in UpdateJobPriority()
Dthread_group_unittest.cc554 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in TEST_P() local
579 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in TEST_P() local
621 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in TEST_P() local
661 auto task_source = job_state->GetJobTaskSource( in TEST_P() local
695 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in TEST_P() local
725 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in TEST_P() local
747 auto task_source = CreateJobTaskSource( in TEST_P() local
772 auto task_source = CreateJobTaskSource( in TEST_P() local
816 scoped_refptr<JobTaskSource> task_source = in TEST_P() local
Dtask_source.h124 TaskSource* task_source() const { return task_source_; } in task_source() function
369 RegisteredTaskSource task_source; member
386 scoped_refptr<TaskSource> task_source; member
Dthread_group.cc36 RegisteredTaskSource task_source) { in ScheduleReleaseTaskSource()
140 const TaskSource& task_source) { in RemoveTaskSource()
214 RegisteredTaskSource task_source = in TakeRegisteredTaskSource() local
Dtask_source.cc18 TaskSource::Transaction::Transaction(TaskSource* task_source) in Transaction()
115 scoped_refptr<TaskSource> task_source, in CreateForTesting()
184 scoped_refptr<TaskSource> task_source, in RegisteredTaskSource()
Djob_task_source_interface.h27 scoped_refptr<internal::JobTaskSource> task_source) { in CreateJobHandle()
Dpooled_single_thread_task_runner_manager.cc133 auto task_source = GetWorkLockRequired(worker); in GetWork() local
144 RegisteredTaskSource SwapProcessedTask(RegisteredTaskSource task_source, in SwapProcessedTask()
186 RegisteredTaskSource task_source; in PostTaskNow() local
349 RegisteredTaskSource task_source; in GetWork() local
Ddelayed_priority_queue_unittest.cc38 void Push(scoped_refptr<Sequence> task_source) { in Push()
Dpriority_queue_unittest.cc53 void Push(scoped_refptr<TaskSource> task_source) { in Push()
Dworker_thread_set_unittest.cc31 RegisteredTaskSource SwapProcessedTask(RegisteredTaskSource task_source, in SwapProcessedTask()
Dworker_thread.cc410 RegisteredTaskSource task_source = delegate()->GetWork(this); in RunWorker() local
Dworker_thread_waitable_event_unittest.cc76 RegisteredTaskSource SwapProcessedTask(RegisteredTaskSource task_source, in SwapProcessedTask()
257 scoped_refptr<TaskSource> task_source = in SwapProcessedTask() local
505 …RegisteredTaskSource SwapProcessedTask(RegisteredTaskSource task_source, WorkerThread* worker) ove… in SwapProcessedTask()
Dthread_group_impl.cc597 RegisteredTaskSource task_source; in GetWorkLockRequired() local
661 RegisteredTaskSource task_source, in SwapProcessedTask()
Dthread_pool_impl_unittest.cc1333 scoped_refptr<JobTaskSource> task_source = in TEST_P() local
1394 auto task_source = internal::CreateJobTaskSource( in TEST_P() local
1424 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in TEST_P() local
/external/cronet/base/task/sequence_manager/
Dsequence_manager_perftest.cc606 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
617 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
628 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
639 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
645 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local
656 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local
667 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local
678 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local
684 TwoThreadTestCase task_source(delegate_.get(), CreateTaskRunners(1)); in TEST_P() local
695 TwoThreadTestCase task_source(delegate_.get(), CreateTaskRunners(4)); in TEST_P() local
[all …]
Dthread_controller_with_message_pump_impl.h113 raw_ptr<SequencedTaskSource> task_source = nullptr; // Not owned. member
Dthread_controller_with_message_pump_impl.cc139 SequencedTaskSource* task_source) { in SetSequencedTaskSource()
/external/cronet/base/task/
Dpost_job.cc38 internal::JobTaskSource* task_source, in JobDelegate()
82 JobHandle::JobHandle(scoped_refptr<internal::JobTaskSource> task_source) in JobHandle()
169 auto task_source = in PostJob() local
180 auto task_source = in CreateJob() local
/external/libchrome/base/task/sequence_manager/
Dthread_controller_with_message_pump_impl.h62 SequencedTaskSource* task_source = nullptr; // Not owned. member
Dthread_controller_with_message_pump_impl.cc35 SequencedTaskSource* task_source) { in SetSequencedTaskSource()

12