Home
last modified time | relevance | path

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

123

/external/cronet/tot/base/task/thread_pool/
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 …]
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 …]
Dtask_tracker.cc104 TaskSource* task_source, in EmitThreadPoolTraceEventMetadata() argument
116 task->set_execution_mode(ExecutionModeToProto(task_source->execution_mode())); in EmitThreadPoolTraceEventMetadata()
313 void TaskTracker::WillEnqueueJob(JobTaskSource* task_source) { in WillEnqueueJob() argument
314 task_source->WillEnqueue(sequence_nums_.GetNext(), task_annotator_); in WillEnqueueJob()
368 scoped_refptr<TaskSource> task_source) { in RegisterTaskSource() argument
369 DCHECK(task_source); in RegisterTaskSource()
371 TaskShutdownBehavior shutdown_behavior = task_source->shutdown_behavior(); in RegisterTaskSource()
376 return RegisteredTaskSource(std::move(task_source), this); in RegisterTaskSource()
394 RegisteredTaskSource task_source) { in RunAndPopNextTask() argument
395 DCHECK(task_source); in RunAndPopNextTask()
[all …]
Dpriority_queue.cc24 TaskSourceAndSortKey(RegisteredTaskSource task_source, in TaskSourceAndSortKey() argument
26 : task_source_(std::move(task_source)), sort_key_(sort_key) { in TaskSourceAndSortKey()
76 const RegisteredTaskSource& task_source() const LIFETIME_BOUND { in task_source() function in base::internal::PriorityQueue::TaskSourceAndSortKey
79 RegisteredTaskSource& task_source() LIFETIME_BOUND { return task_source_; } in task_source() function in base::internal::PriorityQueue::TaskSourceAndSortKey
95 auto task_source = PopTaskSource(); in ~PriorityQueue() local
96 auto task = task_source.Clear(); in ~PriorityQueue()
105 void PriorityQueue::Push(RegisteredTaskSource task_source, in Push() argument
108 TaskSourceAndSortKey(std::move(task_source), task_source_sort_key)); in Push()
124 return task_source_and_sort_key.task_source(); in PeekTaskSource()
137 RegisteredTaskSource task_source = in PopTaskSource() local
[all …]
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 …]
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 …]
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,
Dthread_group.cc62 RegisteredTaskSource task_source) { in ScheduleReleaseTaskSource() argument
63 task_sources_to_release_.push_back(std::move(task_source)); in ScheduleReleaseTaskSource()
257 const TaskSource& task_source) { in RemoveTaskSource() argument
259 return priority_queue_.RemoveTaskSource(task_source); in RemoveTaskSource()
271 transaction_with_task_source.task_source.WillReEnqueue( in ReEnqueueTaskSourceLockRequired()
278 if (transaction_with_task_source.task_source->immediate_heap_handle() in ReEnqueueTaskSourceLockRequired()
281 std::move(transaction_with_task_source.task_source)); in ReEnqueueTaskSourceLockRequired()
286 auto sort_key = transaction_with_task_source.task_source->GetSortKey(); in ReEnqueueTaskSourceLockRequired()
293 std::move(transaction_with_task_source.task_source), sort_key); in ReEnqueueTaskSourceLockRequired()
332 RegisteredTaskSource task_source = in TakeRegisteredTaskSource() local
[all …]
Dthread_pool_impl.cc419 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local
421 task_source = task_tracker_->RegisterTaskSource(sequence); in PostTaskWithSequenceNow()
423 if (!task_source) in PostTaskWithSequenceNow()
429 if (task_source) { in PostTaskWithSequenceNow()
432 {std::move(task_source), std::move(transaction)}); in PostTaskWithSequenceNow()
474 bool ThreadPoolImpl::ShouldYield(const TaskSource* task_source) { in ShouldYield() argument
475 const TaskPriority priority = task_source->priority_racy(); in ShouldYield()
477 GetThreadGroupForTraits({priority, task_source->thread_policy()}); in ShouldYield()
482 return GetThreadGroupForTraits({priority, task_source->thread_policy()}) in ShouldYield()
483 ->ShouldYield(task_source->GetSortKey()); in ShouldYield()
[all …]
Dpooled_single_thread_task_runner_manager.cc140 auto task_source = GetWorkLockRequired(worker); in GetWork() local
141 if (!task_source) { in GetWork()
146 auto run_status = task_source.WillRunTask(); in GetWork()
148 return task_source; in GetWork()
151 RegisteredTaskSource SwapProcessedTask(RegisteredTaskSource task_source, in SwapProcessedTask() argument
155 if (task_source) { in SwapProcessedTask()
158 std::move(task_source))); in SwapProcessedTask()
159 task_source_with_transaction->task_source.WillReEnqueue( in SwapProcessedTask()
197 RegisteredTaskSource task_source; in PostTaskNow() local
199 task_source = task_tracker_->RegisterTaskSource(sequence); in PostTaskNow()
[all …]
/external/cronet/stable/base/task/thread_pool/
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 …]
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 …]
Dtask_tracker.cc104 TaskSource* task_source, in EmitThreadPoolTraceEventMetadata() argument
116 task->set_execution_mode(ExecutionModeToProto(task_source->execution_mode())); in EmitThreadPoolTraceEventMetadata()
313 void TaskTracker::WillEnqueueJob(JobTaskSource* task_source) { in WillEnqueueJob() argument
314 task_source->WillEnqueue(sequence_nums_.GetNext(), task_annotator_); in WillEnqueueJob()
368 scoped_refptr<TaskSource> task_source) { in RegisterTaskSource() argument
369 DCHECK(task_source); in RegisterTaskSource()
371 TaskShutdownBehavior shutdown_behavior = task_source->shutdown_behavior(); in RegisterTaskSource()
376 return RegisteredTaskSource(std::move(task_source), this); in RegisterTaskSource()
394 RegisteredTaskSource task_source) { in RunAndPopNextTask() argument
395 DCHECK(task_source); in RunAndPopNextTask()
[all …]
Dpriority_queue.cc24 TaskSourceAndSortKey(RegisteredTaskSource task_source, in TaskSourceAndSortKey() argument
26 : task_source_(std::move(task_source)), sort_key_(sort_key) { in TaskSourceAndSortKey()
76 const RegisteredTaskSource& task_source() const LIFETIME_BOUND { in task_source() function in base::internal::PriorityQueue::TaskSourceAndSortKey
79 RegisteredTaskSource& task_source() LIFETIME_BOUND { return task_source_; } in task_source() function in base::internal::PriorityQueue::TaskSourceAndSortKey
95 auto task_source = PopTaskSource(); in ~PriorityQueue() local
96 auto task = task_source.Clear(); in ~PriorityQueue()
105 void PriorityQueue::Push(RegisteredTaskSource task_source, in Push() argument
108 TaskSourceAndSortKey(std::move(task_source), task_source_sort_key)); in Push()
124 return task_source_and_sort_key.task_source(); in PeekTaskSource()
137 RegisteredTaskSource task_source = in PopTaskSource() local
[all …]
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 …]
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 …]
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,
Dthread_group.cc62 RegisteredTaskSource task_source) { in ScheduleReleaseTaskSource() argument
63 task_sources_to_release_.push_back(std::move(task_source)); in ScheduleReleaseTaskSource()
257 const TaskSource& task_source) { in RemoveTaskSource() argument
259 return priority_queue_.RemoveTaskSource(task_source); in RemoveTaskSource()
271 transaction_with_task_source.task_source.WillReEnqueue( in ReEnqueueTaskSourceLockRequired()
278 if (transaction_with_task_source.task_source->immediate_heap_handle() in ReEnqueueTaskSourceLockRequired()
281 std::move(transaction_with_task_source.task_source)); in ReEnqueueTaskSourceLockRequired()
286 auto sort_key = transaction_with_task_source.task_source->GetSortKey(); in ReEnqueueTaskSourceLockRequired()
293 std::move(transaction_with_task_source.task_source), sort_key); in ReEnqueueTaskSourceLockRequired()
332 RegisteredTaskSource task_source = in TakeRegisteredTaskSource() local
[all …]
Dthread_pool_impl.cc419 RegisteredTaskSource task_source; in PostTaskWithSequenceNow() local
421 task_source = task_tracker_->RegisterTaskSource(sequence); in PostTaskWithSequenceNow()
423 if (!task_source) in PostTaskWithSequenceNow()
429 if (task_source) { in PostTaskWithSequenceNow()
432 {std::move(task_source), std::move(transaction)}); in PostTaskWithSequenceNow()
474 bool ThreadPoolImpl::ShouldYield(const TaskSource* task_source) { in ShouldYield() argument
475 const TaskPriority priority = task_source->priority_racy(); in ShouldYield()
477 GetThreadGroupForTraits({priority, task_source->thread_policy()}); in ShouldYield()
482 return GetThreadGroupForTraits({priority, task_source->thread_policy()}) in ShouldYield()
483 ->ShouldYield(task_source->GetSortKey()); in ShouldYield()
[all …]
Dpooled_single_thread_task_runner_manager.cc140 auto task_source = GetWorkLockRequired(worker); in GetWork() local
141 if (!task_source) { in GetWork()
146 auto run_status = task_source.WillRunTask(); in GetWork()
148 return task_source; in GetWork()
151 RegisteredTaskSource SwapProcessedTask(RegisteredTaskSource task_source, in SwapProcessedTask() argument
155 if (task_source) { in SwapProcessedTask()
158 std::move(task_source))); in SwapProcessedTask()
159 task_source_with_transaction->task_source.WillReEnqueue( in SwapProcessedTask()
197 RegisteredTaskSource task_source; in PostTaskNow() local
199 task_source = task_tracker_->RegisterTaskSource(sequence); in PostTaskNow()
[all …]
/external/cronet/tot/base/task/sequence_manager/
Dsequence_manager_perftest.cc606 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
608 Benchmark("post delayed tasks with one queue", &task_source); in TEST_P()
617 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
619 Benchmark("post delayed tasks with four queues", &task_source); in TEST_P()
628 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
630 Benchmark("post delayed tasks with eight queues", &task_source); in TEST_P()
639 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
641 Benchmark("post delayed tasks with thirty two queues", &task_source); in TEST_P()
645 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local
647 Benchmark("post immediate tasks with one queue", &task_source); in TEST_P()
[all …]
/external/cronet/stable/base/task/sequence_manager/
Dsequence_manager_perftest.cc606 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
608 Benchmark("post delayed tasks with one queue", &task_source); in TEST_P()
617 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
619 Benchmark("post delayed tasks with four queues", &task_source); in TEST_P()
628 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
630 Benchmark("post delayed tasks with eight queues", &task_source); in TEST_P()
639 SingleThreadDelayedTestCase task_source(delegate_.get(), in TEST_P() local
641 Benchmark("post delayed tasks with thirty two queues", &task_source); in TEST_P()
645 SingleThreadImmediateTestCase task_source(delegate_.get(), in TEST_P() local
647 Benchmark("post immediate tasks with one queue", &task_source); in TEST_P()
[all …]
/external/libchrome/base/task/sequence_manager/
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()
/external/cronet/stable/base/task/
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()
/external/cronet/tot/base/task/
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