Lines Matching refs:mtframe
638 MtFrame* mtframe = MtFrame::Instance(); in CreateThread() local
639 MicroThread* thread = mtframe->AllocThread(); in CreateThread()
648 mtframe->InsertRunable(thread); in CreateThread()
656 MtFrame* mtframe = MtFrame::Instance(); in Loop() local
657 MicroThread* daemon = mtframe->DaemonThread(); in Loop()
659 mtframe->KqueueDispatch(); in Loop()
660 mtframe->SetLastClock(mtframe->GetSystemMS()); in Loop()
661 mtframe->WakeupTimeout(); in Loop()
662 mtframe->CheckExpired(); in Loop()
714 MtFrame* mtframe = MtFrame::Instance(); in ThreadSchdule() local
716 if (mtframe->_runlist.empty()) in ThreadSchdule()
718 thread = mtframe->DaemonThread(); in ThreadSchdule()
722 thread = mtframe->_runlist.front(); in ThreadSchdule()
723 mtframe->RemoveRunable(thread); in ThreadSchdule()
963 MtFrame* mtframe = MtFrame::Instance(); in recvfrom() local
964 utime64_t start = mtframe->GetLastClock(); in recvfrom()
965 MicroThread* thread = mtframe->GetActiveThread(); in recvfrom()
982 now = mtframe->GetLastClock(); in recvfrom()
993 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) in recvfrom()
1023 MtFrame* mtframe = MtFrame::Instance(); in sendto() local
1024 utime64_t start = mtframe->GetLastClock(); in sendto()
1025 MicroThread* thread = mtframe->GetActiveThread(); in sendto()
1039 now = mtframe->GetLastClock(); in sendto()
1059 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) { in sendto()
1069 MtFrame* mtframe = MtFrame::Instance(); in connect() local
1070 utime64_t start = mtframe->GetLastClock(); in connect()
1071 MicroThread* thread = mtframe->GetActiveThread(); in connect()
1085 now = mtframe->GetLastClock(); in connect()
1110 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) { in connect()
1120 MtFrame* mtframe = MtFrame::Instance(); in accept() local
1121 utime64_t start = mtframe->GetLastClock(); in accept()
1122 MicroThread* thread = mtframe->GetActiveThread(); in accept()
1136 now = mtframe->GetLastClock(); in accept()
1156 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) { in accept()
1166 MtFrame* mtframe = MtFrame::Instance(); in read() local
1167 utime64_t start = mtframe->GetLastClock(); in read()
1168 MicroThread* thread = mtframe->GetActiveThread(); in read()
1182 now = mtframe->GetLastClock(); in read()
1202 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) { in read()
1212 MtFrame* mtframe = MtFrame::Instance(); in write() local
1213 utime64_t start = mtframe->GetLastClock(); in write()
1214 MicroThread* thread = mtframe->GetActiveThread(); in write()
1228 now = mtframe->GetLastClock(); in write()
1260 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) { in write()
1270 MtFrame* mtframe = MtFrame::Instance(); in recv() local
1271 utime64_t start = mtframe->GetLastClock(); in recv()
1272 MicroThread* thread = mtframe->GetActiveThread(); in recv()
1289 now = mtframe->GetLastClock(); in recv()
1300 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) in recv()
1330 MtFrame* mtframe = MtFrame::Instance(); in send() local
1331 utime64_t start = mtframe->GetLastClock(); in send()
1332 MicroThread* thread = mtframe->GetActiveThread(); in send()
1346 now = mtframe->GetLastClock(); in send()
1378 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) { in send()
1398 MtFrame* mtframe = MtFrame::Instance(); in WaitEvents() local
1399 utime64_t start = mtframe->GetLastClock(); in WaitEvents()
1400 MicroThread* thread = mtframe->GetActiveThread(); in WaitEvents()
1410 now = mtframe->GetLastClock(); in WaitEvents()
1429 if (!mtframe->KqueueSchedule(NULL, &epfd, timeout)) in WaitEvents()