Home
last modified time | relevance | path

Searched refs:registered_task_source (Results 1 – 7 of 7) sorted by relevance

/external/cronet/base/task/thread_pool/
Dsequence_unittest.cc75 auto registered_task_source = in TEST() local
77 registered_task_source.WillRunTask(); in TEST()
79 registered_task_source.TakeTask(&sequence_transaction); in TEST()
84 EXPECT_TRUE(registered_task_source.DidProcessTask(&sequence_transaction)); in TEST()
85 EXPECT_TRUE(registered_task_source.WillReEnqueue(TimeTicks::Now(), in TEST()
88 registered_task_source.WillRunTask(); in TEST()
90 task = registered_task_source.TakeTask(&sequence_transaction); in TEST()
95 EXPECT_TRUE(registered_task_source.DidProcessTask(&sequence_transaction)); in TEST()
96 EXPECT_TRUE(registered_task_source.WillReEnqueue(TimeTicks::Now(), in TEST()
99 registered_task_source.WillRunTask(); in TEST()
[all …]
Djob_task_source_unittest.cc84 auto registered_task_source = in TEST_P() local
89 EXPECT_EQ(registered_task_source.WillRunTask(), in TEST_P()
93 auto task = registered_task_source.TakeTask(); in TEST_P()
95 EXPECT_TRUE(registered_task_source.DidProcessTask()); in TEST_P()
99 EXPECT_EQ(registered_task_source.WillRunTask(), in TEST_P()
107 auto task = registered_task_source.TakeTask(); in TEST_P()
115 EXPECT_FALSE(registered_task_source.DidProcessTask()); in TEST_P()
299 auto registered_task_source = in TEST_P() local
302 EXPECT_EQ(registered_task_source.WillRunTask(), in TEST_P()
304 auto task = registered_task_source.TakeTask(); in TEST_P()
[all …]
Dworker_thread_waitable_event_unittest.cc212 auto registered_task_source = in GetWork() local
214 EXPECT_TRUE(registered_task_source); in GetWork()
223 auto run_status = registered_task_source.WillRunTask(); in GetWork()
225 return registered_task_source; in GetWork()
229 RegisteredTaskSource registered_task_source, in SwapProcessedTask() argument
241 EXPECT_FALSE(registered_task_source); in SwapProcessedTask()
243 EXPECT_TRUE(registered_task_source); in SwapProcessedTask()
244 EXPECT_TRUE(registered_task_source.WillReEnqueue(TimeTicks::Now())); in SwapProcessedTask()
248 registered_task_source.WillRunTask(); in SwapProcessedTask()
249 IgnoreResult(registered_task_source.TakeTask()); in SwapProcessedTask()
[all …]
Dtest_utils.cc230 auto registered_task_source = in EnqueueJobTaskSource() local
232 if (!registered_task_source) in EnqueueJobTaskSource()
234 auto transaction = registered_task_source->BeginTransaction(); in EnqueueJobTaskSource()
236 {std::move(registered_task_source), std::move(transaction)}); in EnqueueJobTaskSource()
324 auto registered_task_source = in QueueAndRunTaskSource() local
326 EXPECT_TRUE(registered_task_source); in QueueAndRunTaskSource()
327 EXPECT_NE(registered_task_source.WillRunTask(), in QueueAndRunTaskSource()
329 return task_tracker->RunAndPopNextTask(std::move(registered_task_source)); in QueueAndRunTaskSource()
Dthread_pool_impl.cc473 auto registered_task_source = in EnqueueJobTaskSource() local
475 if (!registered_task_source) in EnqueueJobTaskSource()
478 static_cast<JobTaskSource*>(registered_task_source.get())); in EnqueueJobTaskSource()
479 auto transaction = registered_task_source->BeginTransaction(); in EnqueueJobTaskSource()
482 {std::move(registered_task_source), std::move(transaction)}); in EnqueueJobTaskSource()
521 auto registered_task_source = in UpdatePriority() local
523 if (registered_task_source) { in UpdatePriority()
526 {std::move(registered_task_source), std::move(transaction)}); in UpdatePriority()
Dpriority_queue.cc153 RegisteredTaskSource registered_task_source = in RemoveTaskSource() local
159 return registered_task_source; in RemoveTaskSource()
172 auto registered_task_source = in UpdateSortKey() local
182 TaskSourceAndSortKey(std::move(registered_task_source), sort_key)); in UpdateSortKey()
Dpooled_single_thread_task_runner_manager.cc413 auto registered_task_source = task_tracker_->RegisterTaskSource( in GetWorkFromWindowsMessageQueue() local
415 if (!registered_task_source) in GetWorkFromWindowsMessageQueue()
418 return registered_task_source; in GetWorkFromWindowsMessageQueue()