/dports/www/chromium-legacy/chromium-88.0.4324.182/base/task/thread_pool/ |
H A D | job_task_source_unittest.cc | 54 scoped_refptr<JobTaskSource> task_source = in TEST_F() local 178 task_source->Cancel(); in TEST_F() 255 EXPECT_TRUE(task_source->WillJoin()); in TEST_F() 304 EXPECT_TRUE(task_source->WillJoin()); in TEST_F() 319 task_source->Cancel(); in TEST_F() 320 EXPECT_FALSE(task_source->WillJoin()); in TEST_F() 331 EXPECT_TRUE(task_source->WillJoin()); in TEST_F() 332 task_source->Cancel(); in TEST_F() 350 EXPECT_TRUE(task_source->WillJoin()); in TEST_F() 505 task_source->ReleaseTaskId(1); in TEST_F() [all …]
|
H A D | priority_queue.cc | 23 TaskSourceAndSortKey(RegisteredTaskSource task_source, in TaskSourceAndSortKey() argument 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 119 return task_source_and_sort_key.task_source(); in PeekTaskSource() 132 RegisteredTaskSource task_source = in PopTaskSource() local 135 return task_source; in PopTaskSource() 139 const TaskSource& task_source) { in RemoveTaskSource() argument 143 const HeapHandle heap_handle = task_source.heap_handle(); in RemoveTaskSource() 150 DCHECK_EQ(task_source_and_sort_key.task_source().get(), &task_source); in RemoveTaskSource() [all …]
|
H A D | thread_group.cc | 42 RegisteredTaskSource task_source) { in ScheduleReleaseTaskSource() argument 43 task_sources_to_release_.push_back(std::move(task_source)); in ScheduleReleaseTaskSource() 151 const TaskSource& task_source) { in RemoveTaskSource() argument 153 return priority_queue_.RemoveTaskSource(task_source); in RemoveTaskSource() 214 RegisteredTaskSource task_source = in TakeRegisteredTaskSource() local 216 if (!task_source) in TakeRegisteredTaskSource() 219 std::swap(priority_queue_.PeekTaskSource(), task_source); in TakeRegisteredTaskSource() 221 priority_queue_.UpdateSortKey(*task_source.get(), in TakeRegisteredTaskSource() 224 return task_source; in TakeRegisteredTaskSource() 231 *transaction.task_source(), in UpdateSortKeyImpl() [all …]
|
H A D | test_utils.cc | 61 std::move(task_source)); in PostDelayedTask() 191 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local 195 if (!task_source) in PostTaskWithSequenceNow() 199 if (task_source) { in PostTaskWithSequenceNow() 210 scoped_refptr<JobTaskSource> task_source) { in EnqueueJobTaskSource() argument 214 DCHECK(task_source); in EnqueueJobTaskSource() 227 scoped_refptr<JobTaskSource> task_source) { in RemoveJobTaskSource() argument 228 thread_group_->RemoveTaskSource(*task_source); in RemoveJobTaskSource() 232 scoped_refptr<TaskSource> task_source, in UpdatePriority() argument 240 scoped_refptr<TaskSource> task_source, in UpdateJobPriority() argument [all …]
|
H A D | task_tracker.cc | 423 scoped_refptr<TaskSource> task_source) { in RegisterTaskSource() argument 424 DCHECK(task_source); in RegisterTaskSource() 449 RegisteredTaskSource task_source) { in RunAndPopNextTask() argument 450 DCHECK(task_source); in RunAndPopNextTask() 473 return task_source; in RunAndPopNextTask() 499 DCHECK(task_source); in RunTask() 539 DCHECK(task_source->task_runner()); in RunTask() 547 DCHECK(task_source->task_runner()); in RunTask() 656 DCHECK(task_source); in UnregisterTaskSource() 657 if (task_source->shutdown_behavior() == in UnregisterTaskSource() [all …]
|
H A D | task_source.cc | 18 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() 90 scoped_refptr<TaskSource> task_source, in CreateForTesting() argument 126 DCHECK(!transaction || transaction->task_source() == get()); in TakeTask() 134 DCHECK(!transaction || transaction->task_source() == get()); in Clear() 140 DCHECK(!transaction || transaction->task_source() == get()); in DidProcessTask() 149 scoped_refptr<TaskSource> task_source, in RegisteredTaskSource() argument 156 : task_source(std::move(task_source_in)), in TransactionWithRegisteredTaskSource() [all …]
|
H A D | thread_group_native.cc | 84 RegisteredTaskSource task_source = GetWork(); in RunNextTaskSourceImpl() local 86 if (task_source) { in RunNextTaskSourceImpl() 88 task_source = task_tracker_->RunAndPopNextTask(std::move(task_source)); in RunNextTaskSourceImpl() 91 if (task_source) { in RunNextTaskSourceImpl() 96 std::move(task_source)); in RunNextTaskSourceImpl() 122 RegisteredTaskSource task_source; in GetWork() local 124 while (!task_source && !priority_queue_.IsEmpty()) { in GetWork() 130 task_source = TakeRegisteredTaskSource(&workers_executor); in GetWork() 133 return task_source; in GetWork()
|
H A D | pooled_single_thread_task_runner_manager.cc | 119 if (!task_source) { in GetWork() 126 return task_source; in GetWork() 130 if (task_source) { in DidProcessTask() 132 std::move(task_source))); in DidProcessTask() 148 if (!task_source) in PostTaskNow() 154 if (task_source) { in PostTaskNow() 298 if (task_source) in GetWork() 302 if (!task_source) { in GetWork() 305 if (task_source) in GetWork() 316 if (!task_source) { in GetWork() [all …]
|
H A D | thread_pool_impl.cc | 388 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local 392 if (!task_source) in PostTaskWithSequenceNow() 398 if (task_source) { in PostTaskWithSequenceNow() 401 {std::move(task_source), std::move(transaction)}); in PostTaskWithSequenceNow() 452 scoped_refptr<JobTaskSource> task_source) { in EnqueueJobTaskSource() argument 465 scoped_refptr<JobTaskSource> task_source) { in RemoveJobTaskSource() argument 466 auto transaction = task_source->BeginTransaction(); in RemoveJobTaskSource() 469 current_thread_group->RemoveTaskSource(*task_source); in RemoveJobTaskSource() 474 auto transaction = task_source->BeginTransaction(); in UpdatePriority() 502 DCHECK(task_source); in UpdatePriority() [all …]
|
H A D | pooled_task_runner_delegate.h | 33 virtual bool ShouldYield(const TaskSource* task_source) = 0; 47 scoped_refptr<JobTaskSource> task_source) = 0; 51 scoped_refptr<JobTaskSource> task_source) = 0; 57 virtual void UpdatePriority(scoped_refptr<TaskSource> task_source, 59 virtual void UpdateJobPriority(scoped_refptr<TaskSource> task_source,
|
H A D | thread_group_unittest.cc | 610 task_tracker_.RegisterTaskSource(std::move(task_source)); in TEST_P() 642 task_tracker_.RegisterTaskSource(task_source))); in TEST_P() 648 task_tracker_.RegisterTaskSource(task_source))); in TEST_P() 656 task_tracker_.RegisterTaskSource(task_source))); in TEST_P() 726 auto task_source = job_state->GetJobTaskSource( in TEST_P() local 746 task_source->NotifyConcurrencyIncrease(); in TEST_P() 810 EXPECT_EQ(1U, task_source->HasOneRef()); in TEST_P() 822 auto task_source = MakeRefCounted<JobTaskSource>( in TEST_P() local 847 auto task_source = MakeRefCounted<JobTaskSource>( in TEST_P() local 891 scoped_refptr<JobTaskSource> task_source = in TEST_P() local [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/base/task/thread_pool/ |
H A D | job_task_source_unittest.cc | 50 scoped_refptr<JobTaskSource> task_source = in TEST_F() local 113 EXPECT_FALSE(task_source->ShouldYield()); in TEST_F() 123 EXPECT_TRUE(task_source->ShouldYield()); in TEST_F() 168 task_source->Cancel(); in TEST_F() 169 EXPECT_TRUE(task_source->ShouldYield()); in TEST_F() 237 EXPECT_TRUE(task_source->WillJoin()); in TEST_F() 253 task_source->Cancel(); in TEST_F() 254 EXPECT_FALSE(task_source->WillJoin()); in TEST_F() 265 EXPECT_TRUE(task_source->WillJoin()); in TEST_F() 266 task_source->Cancel(); in TEST_F() [all …]
|
H A D | priority_queue.cc | 23 TaskSourceAndSortKey(RegisteredTaskSource task_source, in TaskSourceAndSortKey() argument 25 : task_source_(std::move(task_source)), sort_key_(sort_key) { in TaskSourceAndSortKey() 74 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() 121 return task_source_and_sort_key.task_source(); in PeekTaskSource() 134 RegisteredTaskSource task_source = in PopTaskSource() local 137 return task_source; in PopTaskSource() 141 const TaskSource& task_source) { in RemoveTaskSource() argument 145 const HeapHandle heap_handle = task_source.heap_handle(); in RemoveTaskSource() [all …]
|
H A D | task_source.cc | 18 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() 94 scoped_refptr<TaskSource> task_source, in CreateForTesting() argument 130 DCHECK(!transaction || transaction->task_source() == get()); in TakeTask() 138 DCHECK(!transaction || transaction->task_source() == get()); in Clear() 144 DCHECK(!transaction || transaction->task_source() == get()); in DidProcessTask() 153 scoped_refptr<TaskSource> task_source, in RegisteredTaskSource() argument 160 : task_source(std::move(task_source_in)), in TransactionWithRegisteredTaskSource() [all …]
|
H A D | test_utils.cc | 60 std::move(task_source)); in PostDelayedTask() 192 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local 196 if (!task_source) in PostTaskWithSequenceNow() 200 if (task_source) { in PostTaskWithSequenceNow() 207 const TaskSource* task_source) const { in ShouldYield() 212 scoped_refptr<JobTaskSource> task_source) { in EnqueueJobTaskSource() argument 216 DCHECK(task_source); in EnqueueJobTaskSource() 229 scoped_refptr<JobTaskSource> task_source) { in RemoveJobTaskSource() argument 230 thread_group_->RemoveTaskSource(*task_source); in RemoveJobTaskSource() 234 scoped_refptr<TaskSource> task_source, in UpdatePriority() argument [all …]
|
H A D | task_tracker.cc | 461 scoped_refptr<TaskSource> task_source) { in RegisterTaskSource() argument 462 DCHECK(task_source); in RegisterTaskSource() 487 RegisteredTaskSource task_source) { in RunAndPopNextTask() argument 488 DCHECK(task_source); in RunAndPopNextTask() 511 return task_source; in RunAndPopNextTask() 560 DCHECK(task_source); in RunTask() 601 DCHECK(task_source->task_runner()); in RunTask() 609 DCHECK(task_source->task_runner()); in RunTask() 719 DCHECK(task_source); in UnregisterTaskSource() 720 if (task_source->shutdown_behavior() == in UnregisterTaskSource() [all …]
|
H A D | thread_group_native.cc | 82 RegisteredTaskSource task_source = GetWork(); in RunNextTaskSourceImpl() local 84 if (task_source) { in RunNextTaskSourceImpl() 86 task_source = task_tracker_->RunAndPopNextTask(std::move(task_source)); in RunNextTaskSourceImpl() 89 if (task_source) { in RunNextTaskSourceImpl() 94 std::move(task_source)); in RunNextTaskSourceImpl() 117 RegisteredTaskSource task_source; in GetWork() local 119 while (!task_source && !priority_queue_.IsEmpty()) { in GetWork() 125 task_source = TakeRegisteredTaskSource(&workers_executor); in GetWork() 128 return task_source; in GetWork()
|
H A D | pooled_single_thread_task_runner_manager.cc | 117 if (!task_source) { in GetWork() 124 return task_source; in GetWork() 128 if (task_source) { in DidProcessTask() 130 std::move(task_source))); in DidProcessTask() 146 if (!task_source) in PostTaskNow() 152 if (task_source) { in PostTaskNow() 293 if (task_source) in GetWork() 297 if (!task_source) { in GetWork() 300 if (task_source) in GetWork() 311 if (!task_source) { in GetWork() [all …]
|
H A D | thread_pool_impl.cc | 369 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local 373 if (!task_source) in PostTaskWithSequenceNow() 379 if (task_source) { in PostTaskWithSequenceNow() 382 {std::move(task_source), std::move(transaction)}); in PostTaskWithSequenceNow() 419 const TaskPriority priority = task_source->priority_racy(); in ShouldYield() 431 scoped_refptr<JobTaskSource> task_source) { in EnqueueJobTaskSource() argument 444 scoped_refptr<JobTaskSource> task_source) { in RemoveJobTaskSource() argument 445 auto transaction = task_source->BeginTransaction(); in RemoveJobTaskSource() 448 current_thread_group->RemoveTaskSource(*task_source); in RemoveJobTaskSource() 453 auto transaction = task_source->BeginTransaction(); in UpdatePriority() [all …]
|
H A D | thread_group.cc | 38 RegisteredTaskSource task_source) { in ScheduleReleaseTaskSource() argument 39 task_sources_to_release_.push_back(std::move(task_source)); in ScheduleReleaseTaskSource() 142 const TaskSource& task_source) { in RemoveTaskSource() argument 144 return priority_queue_.RemoveTaskSource(task_source); in RemoveTaskSource() 159 if (transaction_with_task_source.task_source->heap_handle().IsValid()) { in ReEnqueueTaskSourceLockRequired() 161 std::move(transaction_with_task_source.task_source)); in ReEnqueueTaskSourceLockRequired() 202 RegisteredTaskSource task_source = in TakeRegisteredTaskSource() local 204 if (!task_source) in TakeRegisteredTaskSource() 207 std::move(task_source)); in TakeRegisteredTaskSource() 225 if (transaction_with_task_source.task_source->heap_handle().IsValid()) { in PushTaskSourceAndWakeUpWorkersImpl() [all …]
|
H A D | thread_group_unittest.cc | 602 task_tracker_.RegisterTaskSource(std::move(task_source)); in TEST_P() 634 task_tracker_.RegisterTaskSource(task_source))); in TEST_P() 640 task_tracker_.RegisterTaskSource(task_source))); in TEST_P() 648 task_tracker_.RegisterTaskSource(task_source))); in TEST_P() 718 auto task_source = job_state->GetJobTaskSource( in TEST_P() local 738 task_source->NotifyConcurrencyIncrease(); in TEST_P() 802 EXPECT_EQ(1U, task_source->HasOneRef()); in TEST_P() 814 auto task_source = MakeRefCounted<JobTaskSource>( in TEST_P() local 838 auto task_source = MakeRefCounted<JobTaskSource>( in TEST_P() local 882 scoped_refptr<JobTaskSource> task_source = in TEST_P() local [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/base/task/sequence_manager/ |
H A D | sequence_manager_perftest.cc | 616 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local 627 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local 638 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local 649 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local 655 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local 666 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local 677 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local 696 &task_source); in TEST_P() 707 &task_source); in TEST_P() 718 &task_source); in TEST_P() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/base/task/sequence_manager/ |
H A D | sequence_manager_perftest.cc | 616 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local 627 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local 638 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local 649 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local 655 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local 666 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local 677 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local 696 &task_source); in TEST_P() 707 &task_source); in TEST_P() 718 &task_source); in TEST_P() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/base/task/ |
H A D | post_job.cc | 16 internal::JobTaskSource* task_source, in JobDelegate() argument 18 : task_source_(task_source), in JobDelegate() 60 JobHandle::JobHandle(scoped_refptr<internal::JobTaskSource> task_source) in JobHandle() argument 61 : task_source_(std::move(task_source)) {} in JobHandle() 139 auto task_source = base::MakeRefCounted<internal::JobTaskSource>( in PostJob() local 145 ->EnqueueJobTaskSource(task_source); in PostJob() 147 return internal::JobTaskSource::CreateJobHandle(std::move(task_source)); in PostJob()
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/base/task/ |
H A D | post_job.cc | 16 internal::JobTaskSource* task_source, in JobDelegate() argument 18 : task_source_(task_source), in JobDelegate() 106 JobHandle::JobHandle(scoped_refptr<internal::JobTaskSource> task_source) in JobHandle() argument 107 : task_source_(std::move(task_source)) {} in JobHandle() 176 auto task_source = base::MakeRefCounted<internal::JobTaskSource>( in PostJob() local 182 ->EnqueueJobTaskSource(task_source); in PostJob() 184 return internal::JobTaskSource::CreateJobHandle(std::move(task_source)); in PostJob()
|