Home
last modified time | relevance | path

Searched refs:WorkerThreadWaitableEvent (Results 1 – 10 of 10) sorted by relevance

/aosp_15_r20/external/cronet/base/task/thread_pool/
H A Dworker_thread_waitable_event.cc25 bool WorkerThreadWaitableEvent::Delegate::TimedWait(TimeDelta timeout) { in TimedWait()
29 WorkerThreadWaitableEvent::WorkerThreadWaitableEvent( in WorkerThreadWaitableEvent() function in base::internal::WorkerThreadWaitableEvent
44 WorkerThreadWaitableEvent::~WorkerThreadWaitableEvent() { in ~WorkerThreadWaitableEvent()
48 void WorkerThreadWaitableEvent::JoinForTesting() { in JoinForTesting()
70 void WorkerThreadWaitableEvent::Cleanup() { in Cleanup()
76 bool WorkerThreadWaitableEvent::join_called_for_testing() const { in join_called_for_testing()
80 void WorkerThreadWaitableEvent::WakeUp() { in WakeUp()
95 WorkerThreadWaitableEvent::Delegate* WorkerThreadWaitableEvent::delegate() { in delegate()
H A Dthread_group_impl.cc51 void ScheduleWakeUp(scoped_refptr<WorkerThreadWaitableEvent> worker) { in ScheduleWakeUp()
56 absl::InlinedVector<scoped_refptr<WorkerThreadWaitableEvent>, 2>
62 public WorkerThreadWaitableEvent::Delegate {
192 WorkerThreadWaitableEvent* worker = in OnMainExit()
193 static_cast<WorkerThreadWaitableEvent*>(worker_base); in OnMainExit()
231 WorkerThreadWaitableEvent* worker = in CanGetWorkLockRequired()
232 static_cast<WorkerThreadWaitableEvent*>(worker_base); in CanGetWorkLockRequired()
333 static_cast<WorkerThreadWaitableEvent*>(worker)); in SwapProcessedTask()
353 WorkerThreadWaitableEvent* worker = in CleanupLockRequired()
354 static_cast<WorkerThreadWaitableEvent*>(worker_base); in CleanupLockRequired()
[all …]
H A Dworker_thread_set.cc15 const WorkerThreadWaitableEvent* a, in operator ()()
16 const WorkerThreadWaitableEvent* b) const { in operator ()()
24 void WorkerThreadSet::Insert(WorkerThreadWaitableEvent* worker) { in Insert()
34 WorkerThreadWaitableEvent* WorkerThreadSet::Take() { in Take()
37 WorkerThreadWaitableEvent* const worker = *set_.begin(); in Take()
44 WorkerThreadWaitableEvent* WorkerThreadSet::Peek() const { in Peek()
50 bool WorkerThreadSet::Contains(const WorkerThreadWaitableEvent* worker) const { in Contains()
51 return set_.count(const_cast<WorkerThreadWaitableEvent*>(worker)) > 0; in Contains()
54 void WorkerThreadSet::Remove(const WorkerThreadWaitableEvent* worker) { in Remove()
57 auto it = set_.find(const_cast<WorkerThreadWaitableEvent*>(worker)); in Remove()
H A Dworker_thread_set.h18 class WorkerThreadWaitableEvent; variable
28 bool operator()(const WorkerThreadWaitableEvent* a,
29 const WorkerThreadWaitableEvent* b) const;
41 void Insert(WorkerThreadWaitableEvent* worker);
46 WorkerThreadWaitableEvent* Take();
49 WorkerThreadWaitableEvent* Peek() const;
52 bool Contains(const WorkerThreadWaitableEvent* worker) const;
56 void Remove(const WorkerThreadWaitableEvent* worker);
65 std::set<raw_ptr<WorkerThreadWaitableEvent, SetExperimental>, Compare> set_;
H A Dworker_thread_set_unittest.cc22 class MockWorkerThreadDelegate : public WorkerThreadWaitableEvent::Delegate {
42 worker_a_ = MakeRefCounted<WorkerThreadWaitableEvent>( in SetUp()
46 worker_b_ = MakeRefCounted<WorkerThreadWaitableEvent>( in SetUp()
50 worker_c_ = MakeRefCounted<WorkerThreadWaitableEvent>( in SetUp()
60 scoped_refptr<WorkerThreadWaitableEvent> worker_a_;
61 scoped_refptr<WorkerThreadWaitableEvent> worker_b_;
62 scoped_refptr<WorkerThreadWaitableEvent> worker_c_;
87 WorkerThreadWaitableEvent* idle_worker = set.Take(); in TEST_F()
132 WorkerThreadWaitableEvent* idle_worker = set.Take(); in TEST_F()
172 WorkerThreadWaitableEvent* idle_worker = set.Take(); in TEST_F()
H A Dpooled_single_thread_task_runner_manager.h31 class WorkerThreadWaitableEvent; variable
120 WorkerThreadWaitableEvent* CreateAndRegisterWorkerThread(
126 WorkerThreadWaitableEvent*& GetSharedWorkerThreadForTraits(
129 void UnregisterWorkerThread(WorkerThreadWaitableEvent* worker);
143 std::vector<scoped_refptr<WorkerThreadWaitableEvent>> workers_
152 WorkerThreadWaitableEvent*
156 WorkerThreadWaitableEvent* shared_com_worker_threads_
H A Dpooled_single_thread_task_runner_manager.cc104 class WorkerThreadDelegate : public WorkerThreadWaitableEvent::Delegate {
115 void set_worker(WorkerThreadWaitableEvent* worker) { in set_worker()
290 raw_ptr<WorkerThreadWaitableEvent> worker_ = nullptr;
453 WorkerThreadWaitableEvent* worker, in PooledSingleThreadTaskRunner()
566 const raw_ptr<WorkerThreadWaitableEvent, AcrossTasksDanglingUntriaged>
627 for (scoped_refptr<WorkerThreadWaitableEvent> worker : workers_to_start) { in Start()
691 WorkerThreadWaitableEvent* dedicated_worker = nullptr; in CreateTaskRunnerImpl()
692 WorkerThreadWaitableEvent*& worker = in CreateTaskRunnerImpl()
778 WorkerThreadWaitableEvent*
787 scoped_refptr<WorkerThreadWaitableEvent> worker = in CreateAndRegisterWorkerThread()
[all …]
H A Dworker_thread_waitable_event.h21 class BASE_EXPORT WorkerThreadWaitableEvent : public WorkerThread {
25 friend WorkerThreadWaitableEvent;
34 WorkerThreadWaitableEvent(ThreadType thread_type_hint,
40 WorkerThreadWaitableEvent(const WorkerThread&) = delete;
41 WorkerThreadWaitableEvent& operator=(const WorkerThread&) = delete;
69 ~WorkerThreadWaitableEvent() override;
H A Dthread_group_impl.h109 scoped_refptr<WorkerThreadWaitableEvent> CreateAndRegisterWorkerLockRequired(
118 bool IsOnIdleSetLockRequired(WorkerThreadWaitableEvent* worker) const
H A Dworker_thread_waitable_event_unittest.cc71 concept UsingWaitableEvent = std::is_same<T, WorkerThreadWaitableEvent>::value;
635 std::pair<WorkerThreadWaitableEvent, std::integral_constant<int, 1>>,
636 std::pair<WorkerThreadWaitableEvent, std::integral_constant<int, 2>>,