Home
last modified time | relevance | path

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

12345

/dports/www/chromium-legacy/chromium-88.0.4324.182/base/task/thread_pool/
H A Djob_task_source_unittest.cc54 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 Dpriority_queue.cc23 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 Dthread_group.cc42 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 Dtest_utils.cc61 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 Dtask_tracker.cc423 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 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()
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 Dthread_group_native.cc84 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 Dpooled_single_thread_task_runner_manager.cc119 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 Dthread_pool_impl.cc388 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 Dpooled_task_runner_delegate.h33 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 Dthread_group_unittest.cc610 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 Djob_task_source_unittest.cc50 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 Dpriority_queue.cc23 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 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()
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 Dtest_utils.cc60 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 Dtask_tracker.cc461 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 Dthread_group_native.cc82 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 Dpooled_single_thread_task_runner_manager.cc117 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 Dthread_pool_impl.cc369 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 Dthread_group.cc38 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 Dthread_group_unittest.cc602 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 Dsequence_manager_perftest.cc616 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 Dsequence_manager_perftest.cc616 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 Dpost_job.cc16 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 Dpost_job.cc16 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()

12345