| /aosp_15_r20/external/cronet/base/task/ |
| H A D | post_job.cc | 37 : task_source_(task_source), in JobDelegate()
39 DCHECK(task_source_); in JobDelegate()
44 task_source_->ReleaseTaskId(task_id_); in ~JobDelegate()
53 task_source_->ShouldYield() || in ShouldYield()
55 pooled_task_runner_delegate_->ShouldYield(task_source_)); in ShouldYield()
68 task_source_->NotifyConcurrencyIncrease(); in NotifyConcurrencyIncrease()
73 task_id_ = task_source_->AcquireTaskId(); in GetTaskId()
80 : task_source_(std::move(task_source)) {} in JobHandle()
83 DCHECK(!task_source_) in ~JobHandle()
91 DCHECK(!task_source_) in operator =()
[all …]
|
| H A D | post_job.h | 75 internal::JobTaskSource* task_source_ = nullptr; variable
103 explicit operator bool() const { return task_source_ != nullptr; }
139 scoped_refptr<internal::JobTaskSource> task_source_; variable
|
| /aosp_15_r20/external/cronet/base/task/thread_pool/ |
| H A D | task_source.cc | 21 : task_source_(task_source) { in Transaction()
26 : task_source_(other.task_source()) { in Transaction()
27 other.task_source_ = nullptr; in Transaction()
31 if (task_source_) { in ~Transaction()
37 task_source_->traits_.UpdatePriority(priority); in UpdatePriority()
38 task_source_->priority_racy_.store(task_source_->traits_.priority(), in UpdatePriority()
43 DCHECK(task_source_); in Release()
44 task_source_->lock_.AssertAcquired(); in Release()
45 task_source_->lock_.Release(); in Release()
46 task_source_ = nullptr; in Release()
[all …]
|
| H A D | priority_queue.cc | 25 : task_source_(std::move(task_source)), sort_key_(sort_key) { in TaskSourceAndSortKey()
26 DCHECK(task_source_); in TaskSourceAndSortKey()
43 DCHECK(task_source_); in take_task_source()
44 task_source_->ClearImmediateHeapHandle(); in take_task_source()
45 return std::move(task_source_); in take_task_source()
56 DCHECK(task_source_); in SetHeapHandle()
57 task_source_->SetImmediateHeapHandle(handle); in SetHeapHandle()
64 if (task_source_) in ClearHeapHandle()
65 task_source_->ClearImmediateHeapHandle(); in ClearHeapHandle()
70 if (task_source_) in GetHeapHandle()
[all …]
|
| H A D | delayed_priority_queue.cc | 24 : task_source_(std::move(task_source)), in TaskSourceAndDelayedSortKey()
26 DCHECK(task_source_); in TaskSourceAndDelayedSortKey()
45 DCHECK(task_source_); in take_task_source()
46 task_source_->ClearDelayedHeapHandle(); in take_task_source()
47 return std::move(task_source_); in take_task_source()
58 DCHECK(task_source_); in SetHeapHandle()
59 task_source_->SetDelayedHeapHandle(handle); in SetHeapHandle()
66 if (task_source_) in ClearHeapHandle()
67 task_source_->ClearDelayedHeapHandle(); in ClearHeapHandle()
72 if (task_source_) in GetHeapHandle()
[all …]
|
| H A D | task_source.h | 140 operator bool() const { return !!task_source_; }
146 TaskTraits traits() const { return task_source_->traits_; } in traits()
148 TaskSource* task_source() const { return task_source_; } in task_source()
158 TaskSource* task_source_ = nullptr; variable
287 operator bool() const { return task_source_ != nullptr; }
288 TaskSource* operator->() const { return task_source_.get(); }
289 TaskSource* get() const { return task_source_.get(); } in get()
347 scoped_refptr<TaskSource> task_source_; variable
|
| H A D | task_tracker_unittest.cc | 104 task_source_(std::move(task_source)), in ThreadPostingAndRunningTask()
107 EXPECT_TRUE(task_source_); in ThreadPostingAndRunningTask()
113 RegisteredTaskSource TakeTaskSource() { return std::move(task_source_); } in TakeTaskSource()
128 task_source_ = tracker_->RegisterTaskSource(std::move(sequence_)); in Run()
130 post_and_queue_succeeded &= !!task_source_; in Run()
136 EXPECT_TRUE(task_source_); in Run()
137 task_source_.WillRunTask(); in Run()
141 EXPECT_FALSE(tracker_->RunAndPopNextTask(std::move(task_source_))); in Run()
148 RegisteredTaskSource task_source_; member in base::internal::__anon8137c29e0111::ThreadPostingAndRunningTask
|
| /aosp_15_r20/external/cronet/base/task/sequence_manager/ |
| H A D | thread_controller_with_message_pump_impl_unittest.cc | 222 task_source_(&clock_) { in ThreadControllerWithMessagePumpTestBase()
230 thread_controller_.SetSequencedTaskSource(&task_source_); in ThreadControllerWithMessagePumpTestBase()
246 FakeSequencedTaskSource task_source_; member in base::sequence_manager::internal::ThreadControllerWithMessagePumpTestBase
267 task_source_.AddTask(FROM_HERE, task1.Get(), FromNow(Seconds(10)), in TEST_F()
270 task_source_.AddTask(FROM_HERE, task2.Get()); in TEST_F()
272 task_source_.AddTask(FROM_HERE, task3.Get(), FromNow(Seconds(20)), in TEST_F()
336 task_source_.AddTask(FROM_HERE, task1.Get(), FromNow(Days(10)), in TEST_F()
345 task_source_.AddTask(FROM_HERE, task1.Get(), FromNow(Seconds(10)), in TEST_F()
379 task_source_.AddTask(FROM_HERE, in TEST_F()
389 task_source_.AddTask(FROM_HERE, in TEST_F()
[all …]
|
| H A D | sequence_manager_perftest.cc | 368 task_source_(std::make_unique<SingleThreadImmediateTaskSource>( in SingleThreadImmediateTestCase()
373 void Start() override { task_source_->Start(); } in Start()
396 const std::unique_ptr<TaskSource> task_source_; member in base::sequence_manager::SingleThreadImmediateTestCase
405 task_source_(std::make_unique<SingleThreadDelayedTaskSource>( in SingleThreadDelayedTestCase()
410 void Start() override { task_source_->Start(); } in Start()
436 const std::unique_ptr<TaskSource> task_source_; member in base::sequence_manager::SingleThreadDelayedTestCase
|