MCPcopy Create free account
hub / github.com/F-Stack/f-stack / WakeupTimeout

Method WakeupTimeout

adapter/micro_thread/micro_thread.cpp:749–768  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

747}
748
749void MtFrame::WakeupTimeout()
750{
751 utime64_t now = GetLastClock();
752 MicroThread* thread = dynamic_cast<MicroThread*>(_sleeplist.HeapTop());
753 while (thread && (thread->GetWakeupTime() <= now))
754 {
755 if (thread->HasFlag(MicroThread::IO_LIST))
756 {
757 RemoveIoWait(thread);
758 }
759 else
760 {
761 RemoveSleep(thread);
762 }
763
764 InsertRunable(thread);
765
766 thread = dynamic_cast<MicroThread*>(_sleeplist.HeapTop());
767 }
768}
769
770int MtFrame::KqueueGetTimeout()
771{

Callers 1

LoopMethod · 0.80

Calls 3

HeapTopMethod · 0.80
GetWakeupTimeMethod · 0.80
HasFlagMethod · 0.80

Tested by

no test coverage detected