Lines Matching refs:self
41 void TaskProcessor::AddTask(Thread* self, HeapTask* task) { in AddTask() argument
42 ScopedThreadStateChange tsc(self, kWaitingForTaskProcessor); in AddTask()
43 MutexLock mu(self, lock_); in AddTask()
45 cond_.Signal(self); in AddTask()
48 HeapTask* TaskProcessor::GetTask(Thread* self) { in GetTask() argument
49 ScopedThreadStateChange tsc(self, kWaitingForTaskProcessor); in GetTask()
50 MutexLock mu(self, lock_); in GetTask()
56 cond_.Wait(self); // Empty queue, wait until we are signalled. in GetTask()
73 cond_.TimedWait(self, static_cast<int64_t>(ms_delta), static_cast<int32_t>(ns_delta)); in GetTask()
79 void TaskProcessor::UpdateTargetRunTime(Thread* self, HeapTask* task, uint64_t new_target_time) { in UpdateTargetRunTime() argument
80 MutexLock mu(self, lock_); in UpdateTargetRunTime()
93 cond_.Signal(self); in UpdateTargetRunTime()
111 void TaskProcessor::Stop(Thread* self) { in Stop() argument
112 MutexLock mu(self, lock_); in Stop()
115 cond_.Broadcast(self); in Stop()
118 void TaskProcessor::Start(Thread* self) { in Start() argument
119 MutexLock mu(self, lock_); in Start()
121 running_thread_ = self; in Start()
124 void TaskProcessor::RunAllTasks(Thread* self) { in RunAllTasks() argument
127 HeapTask* task = GetTask(self); in RunAllTasks()
129 task->Run(self); in RunAllTasks()