|
|
@ -20,69 +20,6 @@ public:
|
|
|
|
virtual void CancelWait(KThread* waiting_thread, ResultCode wait_result,
|
|
|
|
virtual void CancelWait(KThread* waiting_thread, ResultCode wait_result,
|
|
|
|
bool cancel_timer_task);
|
|
|
|
bool cancel_timer_task);
|
|
|
|
|
|
|
|
|
|
|
|
// Deprecated, will be removed in subsequent commits.
|
|
|
|
|
|
|
|
public:
|
|
|
|
|
|
|
|
bool IsEmpty() const {
|
|
|
|
|
|
|
|
return wait_list.empty();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
KThread::WaiterList::iterator begin() {
|
|
|
|
|
|
|
|
return wait_list.begin();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
KThread::WaiterList::iterator end() {
|
|
|
|
|
|
|
|
return wait_list.end();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
bool SleepThread(KThread* t) {
|
|
|
|
|
|
|
|
KScopedSchedulerLock sl{kernel};
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// If the thread needs terminating, don't enqueue it.
|
|
|
|
|
|
|
|
if (t->IsTerminationRequested()) {
|
|
|
|
|
|
|
|
return false;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Set the thread's queue and mark it as waiting.
|
|
|
|
|
|
|
|
t->SetSleepingQueue(this);
|
|
|
|
|
|
|
|
t->SetState(ThreadState::Waiting);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Add the thread to the queue.
|
|
|
|
|
|
|
|
wait_list.push_back(*t);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return true;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void WakeupThread(KThread* t) {
|
|
|
|
|
|
|
|
KScopedSchedulerLock sl{kernel};
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Remove the thread from the queue.
|
|
|
|
|
|
|
|
wait_list.erase(wait_list.iterator_to(*t));
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Mark the thread as no longer sleeping.
|
|
|
|
|
|
|
|
t->SetState(ThreadState::Runnable);
|
|
|
|
|
|
|
|
t->SetSleepingQueue(nullptr);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
KThread* WakeupFrontThread() {
|
|
|
|
|
|
|
|
KScopedSchedulerLock sl{kernel};
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (wait_list.empty()) {
|
|
|
|
|
|
|
|
return nullptr;
|
|
|
|
|
|
|
|
} else {
|
|
|
|
|
|
|
|
// Remove the thread from the queue.
|
|
|
|
|
|
|
|
auto it = wait_list.begin();
|
|
|
|
|
|
|
|
KThread* thread = std::addressof(*it);
|
|
|
|
|
|
|
|
wait_list.erase(it);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
ASSERT(thread->GetState() == ThreadState::Waiting);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Mark the thread as no longer sleeping.
|
|
|
|
|
|
|
|
thread->SetState(ThreadState::Runnable);
|
|
|
|
|
|
|
|
thread->SetSleepingQueue(nullptr);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return thread;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private:
|
|
|
|
private:
|
|
|
|
KernelCore& kernel;
|
|
|
|
KernelCore& kernel;
|
|
|
|
KThread::WaiterList wait_list{};
|
|
|
|
KThread::WaiterList wait_list{};
|
|
|
|