Searched refs:mtframe (Results 1 – 5 of 5) sorted by relevance
648 mtframe->InsertRunable(thread); in CreateThread()659 mtframe->KqueueDispatch(); in Loop()660 mtframe->SetLastClock(mtframe->GetSystemMS()); in Loop()661 mtframe->WakeupTimeout(); in Loop()662 mtframe->CheckExpired(); in Loop()716 if (mtframe->_runlist.empty()) in ThreadSchdule()982 now = mtframe->GetLastClock(); in recvfrom()1039 now = mtframe->GetLastClock(); in sendto()1085 now = mtframe->GetLastClock(); in connect()1136 now = mtframe->GetLastClock(); in accept()[all …]
77 MtFrame* mtframe = MtFrame::Instance(); in mt_multi_netfd_poll() local78 if (!mtframe || !mtframe->KqueueSchedule(&fdlist, NULL, (int)timeout)) in mt_multi_netfd_poll()83 MTLOG_ERROR("Mtframe %p, epoll schedule failed, errno %d", mtframe, errno); in mt_multi_netfd_poll()
67 MtFrame* mtframe = MtFrame::Instance(); in InitConnEnv() local122 MicroThread* thread = mtframe->GetActiveThread(); in InitConnEnv()
299 MtFrame* mtframe = MtFrame::Instance(); in WaitConnect() local300 mtframe->WaitNotify(timeout); in WaitConnect()347 MtFrame* mtframe = MtFrame::Instance(); in WaitSend() local348 mtframe->WaitNotify(timeout); in WaitSend()387 MtFrame* mtframe = MtFrame::Instance(); in WaitRecv() local388 mtframe->WaitNotify(timeout); in WaitRecv()632 MtFrame* mtframe = MtFrame::Instance(); in RegistSession() local633 this->_thread = mtframe->GetActiveThread(); in RegistSession()
503 MtFrame* mtframe = MtFrame::Instance(); in mt_exec_all_task() local504 MicroThread* thread = mtframe->GetActiveThread(); in mt_exec_all_task()537 mtframe->InsertRunable(sub); in mt_exec_all_task()548 mtframe->FreeThread(sub); in mt_exec_all_task()