Lines Matching refs:MtFrame
57 rc = MtFrame::sendto(sock, pkg, len, 0, (struct sockaddr*)dst, (int)sizeof(*dst), timeout); in mt_udpsendrcv()
66 …rc = MtFrame::recvfrom(sock, rcv_buf, buf_size, 0, (struct sockaddr*)&from_addr, (socklen_t*)&addr… in mt_udpsendrcv()
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()
164 …int rc = MtFrame::recv(sock, (rcv_buf + recv_len), (len - recv_len), 0, (timeout - (int)cost_time)… in mt_tcp_check_recv()
221 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcpsendrcv()
234 rc = MtFrame::connect(sock, (struct sockaddr *)dst, addr_len, time_left); in mt_tcpsendrcv()
242 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv()
244 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsendrcv()
252 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv()
278 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcpsendrcv_short()
297 rc = MtFrame::connect(sock, (struct sockaddr *)dst, addr_len, time_left); in mt_tcpsendrcv_short()
305 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv_short()
307 rc = MtFrame::send(sock, pkg, len, 0, time_left); 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()
357 rc = MtFrame::connect(sock, (struct sockaddr *)dst, addr_len, time_left); in mt_tcpsend()
365 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsend()
367 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsend()
397 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcpsend_short()
410 rc = MtFrame::connect(sock, (struct sockaddr *)dst, addr_len, time_left); in mt_tcpsend_short()
418 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsend_short()
420 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsend_short()
503 MtFrame* mtframe = MtFrame::Instance(); in mt_exec_all_task()
522 sub = MtFrame::CreateThread(mt_task_process, task, false); 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()
590 return MtFrame::recvfrom(fd, buf, len, flags, from, fromlen, timeout); in mt_recvfrom()
595 return MtFrame::sendto(fd, msg, len, flags, to, tolen, timeout); in mt_sendto()
600 return MtFrame::connect(fd, addr, addrlen, timeout); in mt_connect()
605 return MtFrame::accept(fd, addr, addrlen, timeout); in mt_accept()
610 return MtFrame::read(fd, buf, nbyte, timeout); in mt_read()
615 return MtFrame::write(fd, buf, nbyte, timeout); in mt_write()
620 return MtFrame::recv(fd, buf, len, flags, timeout); in mt_recv()
625 return MtFrame::send(fd, buf, nbyte, flags, timeout); in mt_send()
630 MtFrame::sleep(ms); in mt_sleep()
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()
768 …rc = MtFrame::recv(sock, (sbuf.buf_ + recv_len), (sbuf.len_ - recv_len), 0, (timeout - (int)cost_t… in mt_tcp_check_recv()
876 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcpsendrcv()
889 rc = MtFrame::connect(sock, (struct sockaddr *)dst, addr_len, time_left); in mt_tcpsendrcv()
897 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv()
899 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsendrcv()
907 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv()
934 utime64_t start_ms = MtFrame::Instance()->GetLastClock(); in mt_tcpsendrcv_short()
953 rc = MtFrame::connect(sock, (struct sockaddr *)dst, addr_len, time_left); in mt_tcpsendrcv_short()
961 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv_short()
963 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsendrcv_short()
971 cost_time = MtFrame::Instance()->GetLastClock() - start_ms; in mt_tcpsendrcv_short()