Home
last modified time | relevance | path

Searched refs:task_source (Results 1 – 25 of 40) sorted by relevance

12

/external/cronet/base/task/thread_pool/
Djob_task_source_unittest.cc30 MOCK_METHOD1(ShouldYield, bool(const TaskSource* task_source));
32 bool(scoped_refptr<JobTaskSource> task_source));
34 void(scoped_refptr<JobTaskSource> task_source));
37 void(scoped_refptr<TaskSource> task_source,
40 void(scoped_refptr<TaskSource> task_source,
54 scoped_refptr<JobTaskSource> task_source = in TEST_F() local
57 RegisteredTaskSource::CreateForTesting(task_source); in TEST_F()
59 EXPECT_EQ(2U, task_source->GetRemainingConcurrency()); in TEST_F()
63 EXPECT_EQ(1U, task_source->GetWorkerCount()); in TEST_F()
68 EXPECT_EQ(0U, task_source->GetWorkerCount()); in TEST_F()
[all …]
Ddelayed_priority_queue.cc22 TaskSourceAndDelayedSortKey(scoped_refptr<TaskSource> task_source, in TaskSourceAndDelayedSortKey() argument
24 : task_source_(std::move(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
94 task_source->ClearForTesting(); // IN-TEST in ~DelayedPriorityQueue()
101 void DelayedPriorityQueue::Push(scoped_refptr<TaskSource> task_source, in Push() argument
103 container_.insert(TaskSourceAndDelayedSortKey(std::move(task_source), in Push()
116 return task_source_and_delayed_sort_key.task_source(); in PeekTaskSource()
123 scoped_refptr<TaskSource> task_source = in PopTaskSource() local
125 return task_source; in PopTaskSource()
[all …]
Dtask_tracker.cc103 TaskSource* task_source, in EmitThreadPoolTraceEventMetadata() argument
115 task->set_execution_mode(ExecutionModeToProto(task_source->execution_mode())); in EmitThreadPoolTraceEventMetadata()
353 scoped_refptr<TaskSource> task_source) { in RegisterTaskSource() argument
354 DCHECK(task_source); in RegisterTaskSource()
356 TaskShutdownBehavior shutdown_behavior = task_source->shutdown_behavior(); in RegisterTaskSource()
361 return RegisteredTaskSource(std::move(task_source), this); in RegisterTaskSource()
379 RegisteredTaskSource task_source) { in RunAndPopNextTask() argument
380 DCHECK(task_source); in RunAndPopNextTask()
382 const bool should_run_tasks = BeforeRunTask(task_source->shutdown_behavior()); in RunAndPopNextTask()
388 auto transaction = task_source->BeginTransaction(); in RunAndPopNextTask()
[all …]
Dpriority_queue.cc23 TaskSourceAndSortKey(RegisteredTaskSource task_source, in TaskSourceAndSortKey() argument
25 : task_source_(std::move(task_source)), sort_key_(sort_key) { 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
93 auto task = task_source.Clear(); in ~PriorityQueue()
100 void PriorityQueue::Push(RegisteredTaskSource task_source, in Push() argument
103 TaskSourceAndSortKey(std::move(task_source), task_source_sort_key)); in Push()
119 return task_source_and_sort_key.task_source(); in PeekTaskSource()
132 RegisteredTaskSource task_source = in PopTaskSource() local
[all …]
Dthread_group.cc35 RegisteredTaskSource task_source) { in ScheduleReleaseTaskSource() argument
36 task_sources_to_release_.push_back(std::move(task_source)); in ScheduleReleaseTaskSource()
143 const TaskSource& task_source) { in RemoveTaskSource() argument
145 return priority_queue_.RemoveTaskSource(task_source); in RemoveTaskSource()
157 transaction_with_task_source.task_source.WillReEnqueue( in ReEnqueueTaskSourceLockRequired()
164 if (transaction_with_task_source.task_source->immediate_heap_handle() in ReEnqueueTaskSourceLockRequired()
167 std::move(transaction_with_task_source.task_source)); in ReEnqueueTaskSourceLockRequired()
172 auto sort_key = transaction_with_task_source.task_source->GetSortKey(); in ReEnqueueTaskSourceLockRequired()
179 std::move(transaction_with_task_source.task_source), sort_key); in ReEnqueueTaskSourceLockRequired()
217 RegisteredTaskSource task_source = in TakeRegisteredTaskSource() local
[all …]
Dtask_source.cc18 TaskSource::Transaction::Transaction(TaskSource* task_source) in Transaction() argument
19 : task_source_(task_source) { in Transaction()
20 task_source->lock_.Acquire(); in Transaction()
24 : task_source_(other.task_source()) { in Transaction()
113 scoped_refptr<TaskSource> task_source, in CreateForTesting() argument
115 return RegisteredTaskSource(std::move(task_source), task_tracker); in CreateForTesting()
149 DCHECK(!transaction || transaction->task_source() == get()); in TakeTask()
157 DCHECK(!transaction || transaction->task_source() == get()); in Clear()
163 DCHECK(!transaction || transaction->task_source() == get()); in DidProcessTask()
173 DCHECK(!transaction || transaction->task_source() == get()); in WillReEnqueue()
[all …]
Dtest_utils.cc62 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in PostDelayedTask() local
65 std::move(task_source)); in PostDelayedTask()
203 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local
205 task_source = task_tracker_->RegisterTaskSource(std::move(sequence)); in PostTaskWithSequenceNow()
207 if (!task_source) in PostTaskWithSequenceNow()
211 if (task_source) { in PostTaskWithSequenceNow()
213 {std::move(task_source), std::move(transaction)}); in PostTaskWithSequenceNow()
217 bool MockPooledTaskRunnerDelegate::ShouldYield(const TaskSource* task_source) { in ShouldYield() argument
218 return thread_group_->ShouldYield(task_source->GetSortKey()); in ShouldYield()
222 scoped_refptr<JobTaskSource> task_source) { in EnqueueJobTaskSource() argument
[all …]
Dtask_tracker.h114 scoped_refptr<TaskSource> task_source);
125 RegisteredTaskSource RunAndPopNextTask(RegisteredTaskSource task_source);
155 TaskSource* task_source,
190 scoped_refptr<TaskSource> task_source);
205 TaskSource* task_source,
209 TaskSource* task_source,
213 TaskSource* task_source,
217 TaskSource* task_source,
222 TaskSource* task_source,
Dthread_pool_impl.cc393 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local
395 task_source = task_tracker_->RegisterTaskSource(sequence); in PostTaskWithSequenceNow()
397 if (!task_source) in PostTaskWithSequenceNow()
403 if (task_source) { in PostTaskWithSequenceNow()
406 {std::move(task_source), std::move(transaction)}); in PostTaskWithSequenceNow()
457 bool ThreadPoolImpl::ShouldYield(const TaskSource* task_source) { in ShouldYield() argument
458 const TaskPriority priority = task_source->priority_racy(); in ShouldYield()
460 GetThreadGroupForTraits({priority, task_source->thread_policy()}); in ShouldYield()
465 return GetThreadGroupForTraits({priority, task_source->thread_policy()}) in ShouldYield()
466 ->ShouldYield(task_source->GetSortKey()); in ShouldYield()
[all …]
Dpooled_single_thread_task_runner_manager.cc132 auto task_source = GetWorkLockRequired(worker); in GetWork() local
133 if (!task_source) { in GetWork()
138 auto run_status = task_source.WillRunTask(); in GetWork()
140 return task_source; in GetWork()
143 void DidProcessTask(RegisteredTaskSource task_source) override { in DidProcessTask() argument
144 if (task_source) { in DidProcessTask()
147 std::move(task_source)); in DidProcessTask()
148 task_source_with_transaction.task_source.WillReEnqueue( in DidProcessTask()
162 RegisteredTaskSource task_source; in PostTaskNow() local
164 task_source = task_tracker_->RegisterTaskSource(sequence); in PostTaskNow()
[all …]
Dthread_group_unittest.cc538 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in TEST_F() local
542 task_tracker_.RegisterTaskSource(std::move(task_source)); in TEST_F()
569 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in TEST_F() local
574 task_tracker_.RegisterTaskSource(task_source))); in TEST_F()
580 task_tracker_.RegisterTaskSource(task_source))); in TEST_F()
588 task_tracker_.RegisterTaskSource(task_source))); in TEST_F()
618 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in TEST_F() local
621 mock_pooled_task_runner_delegate_.EnqueueJobTaskSource(task_source); in TEST_F()
622 JobHandle job_handle = internal::JobTaskSource::CreateJobHandle(task_source); in TEST_F()
658 auto task_source = job_state->GetJobTaskSource( in TEST_F() local
[all …]
Dpooled_task_runner_delegate.h35 virtual bool ShouldYield(const TaskSource* task_source) = 0;
49 scoped_refptr<JobTaskSource> task_source) = 0;
53 scoped_refptr<JobTaskSource> task_source) = 0;
59 virtual void UpdatePriority(scoped_refptr<TaskSource> task_source,
61 virtual void UpdateJobPriority(scoped_refptr<TaskSource> task_source,
Dtest_utils.h66 bool EnqueueJobTaskSource(scoped_refptr<JobTaskSource> task_source) override;
67 void RemoveJobTaskSource(scoped_refptr<JobTaskSource> task_source) override;
68 bool ShouldYield(const TaskSource* task_source) override;
69 void UpdatePriority(scoped_refptr<TaskSource> task_source,
71 void UpdateJobPriority(scoped_refptr<TaskSource> task_source,
149 scoped_refptr<TaskSource> task_source);
Dthread_pool_impl.h84 bool EnqueueJobTaskSource(scoped_refptr<JobTaskSource> task_source) override;
85 void RemoveJobTaskSource(scoped_refptr<JobTaskSource> task_source) override;
86 void UpdatePriority(scoped_refptr<TaskSource> task_source,
88 void UpdateJobPriority(scoped_refptr<TaskSource> task_source,
174 bool ShouldYield(const TaskSource* task_source) override;
Dworker_thread.cc451 RegisteredTaskSource task_source = delegate_->GetWork(this); in RunWorker() local
452 if (!task_source) { in RunWorker()
477 TaskSource* task_source_before_run = task_source.get(); in RunWorker()
480 task_source = task_tracker_->RunAndPopNextTask(std::move(task_source)); in RunWorker()
483 TaskSource* task_source_before_move = task_source.get(); in RunWorker()
486 delegate_->DidProcessTask(std::move(task_source)); in RunWorker()
491 CHECK(!task_source); in RunWorker()
Dtask_source.h124 TaskSource* task_source() const { return task_source_; } in task_source() function
129 explicit Transaction(TaskSource* task_source);
290 scoped_refptr<TaskSource> task_source,
331 RegisteredTaskSource(scoped_refptr<TaskSource> task_source,
369 RegisteredTaskSource task_source; member
386 scoped_refptr<TaskSource> task_source; member
Ddelayed_priority_queue.h29 void Push(scoped_refptr<TaskSource> task_source, TimeTicks delayed_sort_key);
48 scoped_refptr<TaskSource> task_source);
54 void UpdateDelayedSortKey(scoped_refptr<TaskSource> task_source);
Dpriority_queue.h33 void Push(RegisteredTaskSource task_source,
55 RegisteredTaskSource RemoveTaskSource(const TaskSource& task_source);
60 void UpdateSortKey(const TaskSource& task_source, TaskSourceSortKey sort_key);
Ddelayed_priority_queue_unittest.cc38 void Push(scoped_refptr<Sequence> task_source) { in Push() argument
39 auto delayed_sort_key = task_source->GetDelayedSortKey(); in Push()
40 pq.Push(std::move(task_source), delayed_sort_key); in Push()
Dthread_group_impl.cc214 void DidProcessTask(RegisteredTaskSource task_source) override;
588 RegisteredTaskSource task_source; in GetWork() local
590 while (!task_source && !outer_->priority_queue_.IsEmpty()) { in GetWork()
601 task_source = outer_->TakeRegisteredTaskSource(&executor); in GetWork()
603 if (!task_source) { in GetWork()
612 write_worker().current_shutdown_behavior = task_source->shutdown_behavior(); in GetWork()
614 return task_source; in GetWork()
618 RegisteredTaskSource task_source) { in DidProcessTask() argument
628 if (task_source) { in DidProcessTask()
631 std::move(task_source))); in DidProcessTask()
/external/cronet/base/task/sequence_manager/
Dsequence_manager_perftest.cc606 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
608 Benchmark("post delayed tasks with one queue", &task_source); in TEST_P()
617 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
619 Benchmark("post delayed tasks with four queues", &task_source); in TEST_P()
628 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
630 Benchmark("post delayed tasks with eight queues", &task_source); in TEST_P()
639 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
641 Benchmark("post delayed tasks with thirty two queues", &task_source); in TEST_P()
645 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local
647 Benchmark("post immediate tasks with one queue", &task_source); in TEST_P()
[all …]
Dthread_controller_with_message_pump_impl.cc159 SequencedTaskSource* task_source) { in SetSequencedTaskSource() argument
160 DCHECK(task_source); in SetSequencedTaskSource()
161 DCHECK(!main_thread_only().task_source); in SetSequencedTaskSource()
162 main_thread_only().task_source = task_source; in SetSequencedTaskSource()
421 DCHECK(main_thread_only().task_source); in DoWorkImpl()
456 main_thread_only().task_source->SelectNextTask(lazy_now_select_task, in DoWorkImpl()
485 SequencedTaskSource* source = main_thread_only().task_source; in DoWorkImpl()
502 main_thread_only().task_source->DidRunTask(lazy_now_after_run_task); in DoWorkImpl()
533 main_thread_only().task_source->RemoveAllCanceledDelayedTasksFromFront( in DoWorkImpl()
535 return main_thread_only().task_source->GetPendingWakeUp(continuation_lazy_now, in DoWorkImpl()
[all …]
/external/libchrome/base/task/sequence_manager/
Dthread_controller_with_message_pump_impl.cc35 SequencedTaskSource* task_source) { in SetSequencedTaskSource() argument
36 DCHECK(task_source); in SetSequencedTaskSource()
37 DCHECK(!main_thread_only().task_source); in SetSequencedTaskSource()
38 main_thread_only().task_source = task_source; in SetSequencedTaskSource()
113 DCHECK(main_thread_only().task_source); in DoWork()
121 Optional<PendingTask> task = main_thread_only().task_source->TakeTask(); in DoWork()
129 main_thread_only().task_source->DidRunTask(); in DoWork()
142 main_thread_only().task_source->DelayTillNextTask(&lazy_now); in DoWork()
Dthread_controller_with_message_pump_impl.h31 void SetSequencedTaskSource(SequencedTaskSource* task_source) override;
62 SequencedTaskSource* task_source = nullptr; // Not owned. member
/external/cronet/base/task/
Dpost_job.cc35 internal::JobTaskSource* task_source, in JobDelegate() argument
37 : task_source_(task_source), in JobDelegate()
79 JobHandle::JobHandle(scoped_refptr<internal::JobTaskSource> task_source) in JobHandle() argument
80 : task_source_(std::move(task_source)) {} in JobHandle()
167 auto task_source = in PostJob() local
172 ->EnqueueJobTaskSource(task_source); in PostJob()
174 return internal::JobTaskSource::CreateJobHandle(std::move(task_source)); in PostJob()
182 auto task_source = in CreateJob() local
185 return internal::JobTaskSource::CreateJobHandle(std::move(task_source)); in CreateJob()

12