Lines Matching refs:MtFrame
301 MtFrame* frame = MtFrame::Instance(); in ScheduleThread()
307 MtFrame* frame = MtFrame::Instance(); in ScheduleGetTime()
321 MtFrame* frame = MtFrame::Instance(); in ScheduleSleep()
334 MtFrame* frame = MtFrame::Instance(); in SchedulePend()
347 MtFrame* frame = MtFrame::Instance(); in ScheduleUnpend()
360 MtFrame* frame = MtFrame::Instance(); in ScheduleReclaim()
372 MtFrame* frame = MtFrame::Instance(); in ScheduleStartRun()
504 MtFrame *MtFrame::_instance = NULL;
505 inline MtFrame* MtFrame::Instance () in Instance()
509 _instance = new MtFrame(); in Instance()
515 void MtFrame::SetHookFlag() { in SetHookFlag()
519 bool MtFrame::InitFrame(LogAdapter* logadpt, int max_thread_num) in InitFrame()
557 _daemon->SetSartFunc(MtFrame::DaemonRun, this); in InitFrame()
579 void MtFrame::Destroy(void) in Destroy()
631 char* MtFrame::Version() in Version()
636 MicroThread* MtFrame::CreateThread(ThreadStart entry, void *args, bool runable) in CreateThread()
638 MtFrame* mtframe = MtFrame::Instance(); in CreateThread()
654 int MtFrame::Loop(void* args) in Loop()
656 MtFrame* mtframe = MtFrame::Instance(); in Loop()
668 void MtFrame::DaemonRun(void* args) in DaemonRun()
682 ff_run(MtFrame::Loop, NULL); in DaemonRun()
685 MicroThread *MtFrame::GetRootThread() in GetRootThread()
711 void MtFrame::ThreadSchdule() in ThreadSchdule()
714 MtFrame* mtframe = MtFrame::Instance(); in ThreadSchdule()
731 void MtFrame::CheckExpired() in CheckExpired()
749 void MtFrame::WakeupTimeout() in WakeupTimeout()
770 int MtFrame::KqueueGetTimeout() in KqueueGetTimeout()
788 inline void MtFrame::InsertSleep(MicroThread* thread) in InsertSleep()
802 inline void MtFrame::RemoveSleep(MicroThread* thread) in RemoveSleep()
815 inline void MtFrame::InsertIoWait(MicroThread* thread) in InsertIoWait()
823 void MtFrame::RemoveIoWait(MicroThread* thread) in RemoveIoWait()
832 void MtFrame::InsertRunable(MicroThread* thread) in InsertRunable()
842 inline void MtFrame::RemoveRunable(MicroThread* thread) in RemoveRunable()
852 void MtFrame::InsertPend(MicroThread* thread) in InsertPend()
860 void MtFrame::RemovePend(MicroThread* thread) in RemovePend()
867 void MtFrame::WaitNotify(utime64_t timeout) in WaitNotify()
876 void MtFrame::NotifyThread(MicroThread* thread) in NotifyThread()
898 void MtFrame::SwapDaemonThread() in SwapDaemonThread()
912 bool MtFrame::KqueueSchedule(KqObjList* fdlist, KqueuerObj* fd, int timeout) in KqueueSchedule()
961 int MtFrame::recvfrom(int fd, void *buf, int len, int flags, struct sockaddr *from, socklen_t *from… in recvfrom()
963 MtFrame* mtframe = MtFrame::Instance(); in recvfrom()
1021 int MtFrame::sendto(int fd, const void *msg, int len, int flags, const struct sockaddr *to, int tol… in sendto()
1023 MtFrame* mtframe = MtFrame::Instance(); in sendto()
1067 int MtFrame::connect(int fd, const struct sockaddr *addr, int addrlen, int timeout) in connect()
1069 MtFrame* mtframe = MtFrame::Instance(); in connect()
1118 int MtFrame::accept(int fd, struct sockaddr *addr, socklen_t *addrlen, int timeout) in accept()
1120 MtFrame* mtframe = MtFrame::Instance(); in accept()
1164 ssize_t MtFrame::read(int fd, void *buf, size_t nbyte, int timeout) in read()
1166 MtFrame* mtframe = MtFrame::Instance(); in read()
1210 ssize_t MtFrame::write(int fd, const void *buf, size_t nbyte, int timeout) in write()
1212 MtFrame* mtframe = MtFrame::Instance(); in write()
1268 int MtFrame::recv(int fd, void *buf, int len, int flags, int timeout) in recv()
1270 MtFrame* mtframe = MtFrame::Instance(); in recv()
1328 ssize_t MtFrame::send(int fd, const void *buf, size_t nbyte, int flags, int timeout) in send()
1330 MtFrame* mtframe = MtFrame::Instance(); in send()
1386 void MtFrame::sleep(int ms) in sleep()
1388 MtFrame* frame = MtFrame::Instance(); in sleep()
1396 int MtFrame::WaitEvents(int fd, int events, int timeout) in WaitEvents()
1398 MtFrame* mtframe = MtFrame::Instance(); in WaitEvents()