Lines Matching refs:task_source

423     scoped_refptr<TaskSource> task_source) {  in RegisterTaskSource()  argument
424 DCHECK(task_source); in RegisterTaskSource()
426 TaskShutdownBehavior shutdown_behavior = task_source->shutdown_behavior(); in RegisterTaskSource()
431 return RegisteredTaskSource(std::move(task_source), this); in RegisterTaskSource()
449 RegisteredTaskSource task_source) { in RunAndPopNextTask() argument
450 DCHECK(task_source); in RunAndPopNextTask()
452 const bool should_run_tasks = BeforeRunTask(task_source->shutdown_behavior()); in RunAndPopNextTask()
458 auto transaction = task_source->BeginTransaction(); in RunAndPopNextTask()
459 task = should_run_tasks ? task_source.TakeTask(&transaction) in RunAndPopNextTask()
460 : task_source.Clear(&transaction); in RunAndPopNextTask()
466 RunTask(std::move(task.value()), task_source.get(), traits); in RunAndPopNextTask()
469 AfterRunTask(task_source->shutdown_behavior()); in RunAndPopNextTask()
470 const bool task_source_must_be_queued = task_source.DidProcessTask(); in RunAndPopNextTask()
473 return task_source; in RunAndPopNextTask()
497 TaskSource* task_source, in RunTask() argument
499 DCHECK(task_source); in RunTask()
501 const auto environment = task_source->GetExecutionEnvironment(); in RunTask()
534 switch (task_source->execution_mode()) { in RunTask()
539 DCHECK(task_source->task_runner()); in RunTask()
541 static_cast<SequencedTaskRunner*>(task_source->task_runner())); in RunTask()
543 static_cast<SequencedTaskRunner*>(task_source->task_runner()), in RunTask()
547 DCHECK(task_source->task_runner()); in RunTask()
549 static_cast<SingleThreadTaskRunner*>(task_source->task_runner())); in RunTask()
551 static_cast<SequencedTaskRunner*>(task_source->task_runner()), in RunTask()
552 static_cast<SingleThreadTaskRunner*>(task_source->task_runner()), in RunTask()
566 task_source->execution_mode())], in RunTask()
655 scoped_refptr<TaskSource> task_source) { in UnregisterTaskSource() argument
656 DCHECK(task_source); in UnregisterTaskSource()
657 if (task_source->shutdown_behavior() == in UnregisterTaskSource()
662 return task_source; in UnregisterTaskSource()