Lines Matching refs:task_source
369 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local
371 task_source = task_tracker_->RegisterTaskSource(sequence); in PostTaskWithSequenceNow()
373 if (!task_source) in PostTaskWithSequenceNow()
379 if (task_source) { in PostTaskWithSequenceNow()
382 {std::move(task_source), std::move(transaction)}); in PostTaskWithSequenceNow()
418 bool ThreadPoolImpl::ShouldYield(const TaskSource* task_source) const { in ShouldYield()
419 const TaskPriority priority = task_source->priority_racy(); in ShouldYield()
421 GetThreadGroupForTraits({priority, task_source->thread_policy()}); in ShouldYield()
426 return GetThreadGroupForTraits({priority, task_source->thread_policy()}) in ShouldYield()
431 scoped_refptr<JobTaskSource> task_source) { in EnqueueJobTaskSource() argument
433 task_tracker_->RegisterTaskSource(std::move(task_source)); in EnqueueJobTaskSource()
444 scoped_refptr<JobTaskSource> task_source) { in RemoveJobTaskSource() argument
445 auto transaction = task_source->BeginTransaction(); in RemoveJobTaskSource()
448 current_thread_group->RemoveTaskSource(*task_source); in RemoveJobTaskSource()
451 void ThreadPoolImpl::UpdatePriority(scoped_refptr<TaskSource> task_source, in UpdatePriority() argument
453 auto transaction = task_source->BeginTransaction(); in UpdatePriority()
479 current_thread_group->RemoveTaskSource(*task_source); in UpdatePriority()
481 DCHECK(task_source); in UpdatePriority()