| /external/cronet/base/task/ |
| D | post_job.h | 28 class BASE_EXPORT JobDelegate {
35 JobDelegate(internal::JobTaskSource* task_source,
38 JobDelegate(const JobDelegate&) = delete;
39 JobDelegate& operator=(const JobDelegate&) = delete;
41 ~JobDelegate();
197 RepeatingCallback<void(JobDelegate*)> worker_task,
207 RepeatingCallback<void(JobDelegate*)> worker_task,
|
| D | post_job.cc | 20 RepeatingCallback<void(JobDelegate*)> worker_task, in CreateJobTaskSource()
34 JobDelegate::JobDelegate( in JobDelegate() function in base::JobDelegate
42 JobDelegate::~JobDelegate() { in ~JobDelegate()
47 bool JobDelegate::ShouldYield() { in ShouldYield()
63 void JobDelegate::YieldIfNeeded() { in YieldIfNeeded()
67 void JobDelegate::NotifyConcurrencyIncrease() { in NotifyConcurrencyIncrease()
71 uint8_t JobDelegate::GetTaskId() { in GetTaskId()
165 RepeatingCallback<void(JobDelegate*)> worker_task, in PostJob()
180 RepeatingCallback<void(JobDelegate*)> worker_task, in CreateJob()
|
| D | post_job_unittest.cc | 28 BindLambdaForTesting([&](JobDelegate* delegate) { --num_tasks_to_run; }), in TEST()
45 CreateJob(FROM_HERE, {}, BindLambdaForTesting([&](JobDelegate* delegate) { in TEST()
73 FROM_HERE, {}, BindLambdaForTesting([&](base::JobDelegate* job) { in TEST()
|
| D | job_perftest.cc | 207 JobDelegate* delegate) { in RunJobWithNaiveAssignment()
255 std::atomic_size_t* index, JobDelegate* delegate) { in RunJobWithAtomicAssignment()
301 WaitableEvent* complete, JobDelegate* delegate) { in RunJobWithDynamicAssignment()
360 WaitableEvent* complete, JobDelegate* delegate) { in RunJobWithLoopAround()
|
| /external/cronet/base/task/thread_pool/ |
| D | test_utils.h | 89 MockJobTask(base::RepeatingCallback<void(JobDelegate*)> worker_task,
105 void Run(JobDelegate* delegate);
117 base::RepeatingCallback<void(JobDelegate*)> worker_task_;
|
| D | job_task_source.cc | 35 std::invoke_result<decltype(&JobDelegate::GetTaskId),
36 JobDelegate>::type>::max(),
92 RepeatingCallback<void(JobDelegate*)> worker_task, in JobTaskSource()
103 JobDelegate job_delegate{self, self->delegate_}; in JobTaskSource()
140 JobDelegate job_delegate{this, nullptr}; in RunJoinTask()
|
| D | thread_group_unittest.cc | 533 [&threads_running_barrier, &threads_continue](JobDelegate*) { in TEST_F() argument
563 BindLambdaForTesting([&thread_running, &thread_continue](JobDelegate*) { in TEST_F() argument
607 BindLambdaForTesting([&](JobDelegate* delegate) { in TEST_F()
653 [&threads_running_barrier, &threads_continue](JobDelegate*) { in TEST_F() argument
695 BindRepeating([](JobDelegate*) { ShouldNotRun(); }), in TEST_F() argument
728 BindLambdaForTesting([&](JobDelegate*) { in TEST_F() argument
757 BindLambdaForTesting([&](JobDelegate*) { thread_running.Signal(); }), in TEST_F() argument
782 BindLambdaForTesting([&](JobDelegate*) { thread_running.Signal(); }), in TEST_F() argument
810 BindLambdaForTesting([&](JobDelegate*) { in TEST_F() argument
|
| D | job_task_source.h | 38 RepeatingCallback<void(JobDelegate*)> worker_task,
220 RepeatingCallback<void(JobDelegate*)> worker_task_;
|
| D | job_task_source_unittest.cc | 271 [&](JobDelegate* delegate) { --max_concurrency; }), in TEST_F()
298 [&](JobDelegate* delegate) { --max_concurrency; }), in TEST_F()
400 BindLambdaForTesting([](JobDelegate* delegate) { in TEST_F()
431 FROM_HERE, TaskTraits(), BindRepeating([](JobDelegate* delegate) { in TEST_F()
515 FROM_HERE, TaskTraits{}, BindRepeating([](JobDelegate* delegate) { in TEST_F()
|
| D | test_utils.cc | 264 base::RepeatingCallback<void(JobDelegate*)> worker_task, in MockJobTask()
271 [](base::OnceClosure&& worker_task, JobDelegate*) mutable { in MockJobTask() argument
281 void MockJobTask::Run(JobDelegate* delegate) { in Run()
|
| D | thread_pool_impl_unittest.cc | 1313 [&threads_running](JobDelegate*) { threads_running.Signal(); }), in TEST_P() argument
1332 [&threads_running, &threads_continue](JobDelegate* delegate) { in TEST_P()
|
| D | thread_group_impl_unittest.cc | 314 [&threads_running_barrier, &threads_continue](JobDelegate* delegate) { in TEST_F()
|
| /external/cronet/base/test/launcher/ |
| D | test_launcher.cc | 799 base::JobDelegate* delegate);
880 base::JobDelegate* delegate) { in WorkerTask()
|