Home
last modified time | relevance | path

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

123

/aosp_15_r20/external/cronet/base/task/thread_pool/
H A 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 …]
H A Dtask_tracker.cc105 TaskSource* task_source, in EmitThreadPoolTraceEventMetadata() argument
117 task->set_execution_mode(ExecutionModeToProto(task_source->execution_mode())); in EmitThreadPoolTraceEventMetadata()
314 void TaskTracker::WillEnqueueJob(JobTaskSource* task_source) { in WillEnqueueJob() argument
315 task_source->WillEnqueue(sequence_nums_.GetNext(), task_annotator_); in WillEnqueueJob()
369 scoped_refptr<TaskSource> task_source) { in RegisterTaskSource() argument
370 DCHECK(task_source); in RegisterTaskSource()
372 TaskShutdownBehavior shutdown_behavior = task_source->shutdown_behavior(); in RegisterTaskSource()
377 return RegisteredTaskSource(std::move(task_source), this); in RegisterTaskSource()
395 RegisteredTaskSource task_source) { in RunAndPopNextTask() argument
396 DCHECK(task_source); in RunAndPopNextTask()
[all …]
H A 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 …]
H A 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()
102 void PriorityQueue::Push(RegisteredTaskSource task_source, in Push() argument
105 TaskSourceAndSortKey(std::move(task_source), task_source_sort_key)); in Push()
121 return task_source_and_sort_key.task_source(); in PeekTaskSource()
134 RegisteredTaskSource task_source = in PopTaskSource() local
[all …]
H A Dtask_source.cc20 TaskSource::Transaction::Transaction(TaskSource* task_source) in Transaction() argument
21 : task_source_(task_source) { in Transaction()
22 task_source->lock_.Acquire(); in Transaction()
26 : task_source_(other.task_source()) { in Transaction()
111 scoped_refptr<TaskSource> task_source, in CreateForTesting() argument
113 return RegisteredTaskSource(std::move(task_source), task_tracker); in CreateForTesting()
147 DCHECK(!transaction || transaction->task_source() == get()); in TakeTask()
156 DCHECK(!transaction || transaction->task_source() == get()); in Clear()
162 DCHECK(!transaction || transaction->task_source() == get()); in DidProcessTask()
172 DCHECK(!transaction || transaction->task_source() == get()); in WillReEnqueue()
[all …]
H A Dtest_utils.cc65 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in PostDelayedTask() local
68 std::move(task_source)); in PostDelayedTask()
206 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local
208 task_source = task_tracker_->RegisterTaskSource(std::move(sequence)); in PostTaskWithSequenceNow()
210 if (!task_source) in PostTaskWithSequenceNow()
214 if (task_source) { in PostTaskWithSequenceNow()
216 {std::move(task_source), std::move(transaction)}); in PostTaskWithSequenceNow()
220 bool MockPooledTaskRunnerDelegate::ShouldYield(const TaskSource* task_source) { in ShouldYield() argument
221 return thread_group_->ShouldYield(task_source->GetSortKey()); in ShouldYield()
225 scoped_refptr<JobTaskSource> task_source) { in EnqueueJobTaskSource() argument
[all …]
H A Dthread_group_unittest.cc540 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in TEST_F() local
544 task_tracker_.RegisterTaskSource(std::move(task_source)); in TEST_F()
571 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in TEST_F() local
576 task_tracker_.RegisterTaskSource(task_source))); in TEST_F()
582 task_tracker_.RegisterTaskSource(task_source))); in TEST_F()
590 task_tracker_.RegisterTaskSource(task_source))); in TEST_F()
620 scoped_refptr<JobTaskSource> task_source = job_task->GetJobTaskSource( in TEST_F() local
623 mock_pooled_task_runner_delegate_.EnqueueJobTaskSource(task_source); in TEST_F()
624 JobHandle job_handle = internal::JobTaskSource::CreateJobHandle(task_source); in TEST_F()
660 auto task_source = job_state->GetJobTaskSource( in TEST_F() local
[all …]
H A Dpooled_single_thread_task_runner_manager.cc133 auto task_source = GetWorkLockRequired(worker); in GetWork() local
134 if (!task_source) { in GetWork()
139 auto run_status = task_source.WillRunTask(); in GetWork()
141 return task_source; in GetWork()
144 RegisteredTaskSource SwapProcessedTask(RegisteredTaskSource task_source, in SwapProcessedTask() argument
148 if (task_source) { in SwapProcessedTask()
151 std::move(task_source))); in SwapProcessedTask()
152 task_source_with_transaction->task_source.WillReEnqueue( in SwapProcessedTask()
190 RegisteredTaskSource task_source; in PostTaskNow() local
192 task_source = task_tracker_->RegisterTaskSource(sequence); in PostTaskNow()
[all …]
H A Dthread_group.cc65 RegisteredTaskSource task_source) { in ScheduleReleaseTaskSource() argument
66 task_sources_to_release_.push_back(std::move(task_source)); in ScheduleReleaseTaskSource()
266 const TaskSource& task_source) { in RemoveTaskSource() argument
268 return priority_queue_.RemoveTaskSource(task_source); in RemoveTaskSource()
280 transaction_with_task_source.task_source.WillReEnqueue( in ReEnqueueTaskSourceLockRequired()
287 if (transaction_with_task_source.task_source->immediate_heap_handle() in ReEnqueueTaskSourceLockRequired()
290 std::move(transaction_with_task_source.task_source)); in ReEnqueueTaskSourceLockRequired()
295 auto sort_key = transaction_with_task_source.task_source->GetSortKey(); in ReEnqueueTaskSourceLockRequired()
302 std::move(transaction_with_task_source.task_source), sort_key); in ReEnqueueTaskSourceLockRequired()
341 RegisteredTaskSource task_source = in TakeRegisteredTaskSource() local
[all …]
H A Dthread_pool_impl.cc452 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local
454 task_source = task_tracker_->RegisterTaskSource(sequence); in PostTaskWithSequenceNow()
456 if (!task_source) in PostTaskWithSequenceNow()
462 if (task_source) { in PostTaskWithSequenceNow()
465 {std::move(task_source), std::move(transaction)}); in PostTaskWithSequenceNow()
507 bool ThreadPoolImpl::ShouldYield(const TaskSource* task_source) { in ShouldYield() argument
508 const TaskPriority priority = task_source->priority_racy(); in ShouldYield()
510 GetThreadGroupForTraits({priority, task_source->thread_policy()}); in ShouldYield()
515 return GetThreadGroupForTraits({priority, task_source->thread_policy()}) in ShouldYield()
516 ->ShouldYield(task_source->GetSortKey()); in ShouldYield()
[all …]
H A Dtask_tracker.h117 scoped_refptr<TaskSource> task_source);
120 void WillEnqueueJob(JobTaskSource* task_source);
131 RegisteredTaskSource RunAndPopNextTask(RegisteredTaskSource task_source);
161 TaskSource* task_source,
196 scoped_refptr<TaskSource> task_source);
211 TaskSource* task_source,
215 TaskSource* task_source,
219 TaskSource* task_source,
223 TaskSource* task_source,
228 TaskSource* task_source,
H A Dworker_thread.cc425 RegisteredTaskSource task_source = delegate()->GetWork(this); in RunWorker() local
429 if (!task_source && !ShouldExit()) { in RunWorker()
433 while (task_source) { in RunWorker()
435 TaskSource* task_source_before_run = task_source.get(); in RunWorker()
438 task_source = task_tracker_->RunAndPopNextTask(std::move(task_source)); in RunWorker()
440 TaskSource* task_source_before_move = task_source.get(); in RunWorker()
451 delegate()->SwapProcessedTask(std::move(task_source), this); in RunWorker()
458 CHECK(!task_source); in RunWorker()
459 task_source = std::move(new_task_source); in RunWorker()
H A 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,
H A Dtest_utils.h65 bool EnqueueJobTaskSource(scoped_refptr<JobTaskSource> task_source) override;
66 void RemoveJobTaskSource(scoped_refptr<JobTaskSource> task_source) override;
67 bool ShouldYield(const TaskSource* task_source) override;
68 void UpdatePriority(scoped_refptr<TaskSource> task_source,
70 void UpdateJobPriority(scoped_refptr<TaskSource> task_source,
146 scoped_refptr<TaskSource> task_source);
H A Dthread_group_worker_delegate.cc244 RegisteredTaskSource task_source; in GetWorkLockRequired() local
246 while (!task_source && !outer_->priority_queue_.IsEmpty()) { in GetWorkLockRequired()
257 task_source = outer_->TakeRegisteredTaskSource(executor); in GetWorkLockRequired()
259 if (!task_source) { in GetWorkLockRequired()
268 write_worker().current_shutdown_behavior = task_source->shutdown_behavior(); in GetWorkLockRequired()
270 return task_source; in GetWorkLockRequired()
H A Dtask_source.h148 TaskSource* task_source() const { return task_source_; } in task_source() function
153 explicit Transaction(TaskSource* task_source);
292 scoped_refptr<TaskSource> task_source,
334 RegisteredTaskSource(scoped_refptr<TaskSource> task_source,
371 RegisteredTaskSource task_source; member
390 scoped_refptr<TaskSource> task_source; member
H A Dthread_pool_impl.h83 bool EnqueueJobTaskSource(scoped_refptr<JobTaskSource> task_source) override;
84 void RemoveJobTaskSource(scoped_refptr<JobTaskSource> task_source) override;
85 void UpdatePriority(scoped_refptr<TaskSource> task_source,
87 void UpdateJobPriority(scoped_refptr<TaskSource> task_source,
173 bool ShouldYield(const TaskSource* task_source) override;
H A 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);
H A 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);
H A 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()
H A Dthread_group_semaphore.cc86 RegisteredTaskSource SwapProcessedTask(RegisteredTaskSource task_source,
276 RegisteredTaskSource task_source, in SwapProcessedTask() argument
287 if (task_source) { in SwapProcessedTask()
290 std::move(task_source))); in SwapProcessedTask()
/aosp_15_r20/external/cronet/base/task/sequence_manager/
H A Dsequence_manager_perftest.cc607 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
609 Benchmark("post delayed tasks with one queue", &task_source); in TEST_P()
618 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
620 Benchmark("post delayed tasks with four queues", &task_source); in TEST_P()
629 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
631 Benchmark("post delayed tasks with eight queues", &task_source); in TEST_P()
640 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
642 Benchmark("post delayed tasks with thirty two queues", &task_source); in TEST_P()
646 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local
648 Benchmark("post immediate tasks with one queue", &task_source); in TEST_P()
[all …]
H A Dthread_controller_with_message_pump_impl.cc134 SequencedTaskSource* task_source) { in SetSequencedTaskSource() argument
135 DCHECK(task_source); in SetSequencedTaskSource()
136 DCHECK(!main_thread_only().task_source); in SetSequencedTaskSource()
137 main_thread_only().task_source = task_source; in SetSequencedTaskSource()
286 main_thread_only().task_source->OnBeginWork(); in OnBeginWorkItemImpl()
408 DCHECK(main_thread_only().task_source); in DoWorkImpl()
443 main_thread_only().task_source->SelectNextTask(lazy_now_select_task, in DoWorkImpl()
472 SequencedTaskSource* source = main_thread_only().task_source; in DoWorkImpl()
489 main_thread_only().task_source->DidRunTask(lazy_now_after_run_task); in DoWorkImpl()
520 return main_thread_only().task_source->GetPendingWakeUp(continuation_lazy_now, in DoWorkImpl()
[all …]
/aosp_15_r20/external/libchrome/base/task/sequence_manager/
H A 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()
/aosp_15_r20/external/cronet/base/task/
H A 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()
183 auto task_source = in CreateJob() local
186 return internal::JobTaskSource::CreateJobHandle(std::move(task_source)); in CreateJob()

123