Lines Matching refs:Instance
122 KqueuerObj* ntfy_obj = NtfyObjMgr::Instance()->GetNtfyObj(NTFY_OBJ_THREAD, 0); in mt_tcp_get_keep_conn()
129 …TcpKeepConn* conn = dynamic_cast<TcpKeepConn*>(ConnectionMgr::Instance()->GetConnection(OBJ_TCP_KE… in mt_tcp_get_keep_conn()
133 NtfyObjMgr::Instance()->FreeNtfyObj(ntfy_obj); in mt_tcp_get_keep_conn()
141 ConnectionMgr::Instance()->FreeConnection(conn, true); in mt_tcp_get_keep_conn()
153 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcp_check_recv()
156 utime64_t cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcp_check_recv()
221 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcpsendrcv()
242 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv()
252 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv()
268 ConnectionMgr::Instance()->FreeConnection(conn, (ret < 0)); in mt_tcpsendrcv()
278 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcpsendrcv_short()
305 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv_short()
315 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv_short()
344 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcpsend()
365 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsend()
381 ConnectionMgr::Instance()->FreeConnection(conn, (ret < 0)); in mt_tcpsend()
397 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcpsend_short()
418 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsend_short()
503 MtFrame* mtframe = MtFrame::Instance(); in mt_exec_all_task()
557 MicroThread *msg_thread = MtFrame::Instance()->GetRootThread(); in mt_set_msg_private()
564 MicroThread *msg_thread = MtFrame::Instance()->GetRootThread(); in mt_get_msg_private()
580 return MtFrame::Instance()->InitFrame(); in mt_init_frame()
635 return MtFrame::Instance()->GetLastClock(); in mt_time_ms()
640 return MtFrame::Instance()->WaitEvents(fd, events, timeout); in mt_wait_events()
645 return MtFrame::Instance()->CreateThread((ThreadStart)entry, args, true); in mt_start_thread()
650 return MtFrame::Instance()->GetActiveThread(); in mt_active_thread()
655 MtFrame::Instance()->WaitNotify(ms); in mt_thread_wait()
660 MtFrame::Instance()->NotifyThread((MicroThread *) thread_p); in mt_thread_wakeup_wait()
665 return MtFrame::Instance()->SwapDaemonThread(); in mt_swap_thread()
742 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcp_check_recv()
760 utime64_t cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcp_check_recv()
876 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcpsendrcv()
897 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv()
907 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv()
923 ConnectionMgr::Instance()->FreeConnection(conn, (ret < 0)); in mt_tcpsendrcv()
934 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcpsendrcv_short()
961 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv_short()
971 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv_short()