| 747 | } |
| 748 | |
| 749 | void 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 | |
| 770 | int MtFrame::KqueueGetTimeout() |
| 771 | { |
no test coverage detected