33 …_udpsendrcv(struct sockaddr_in* dst, void* pkg, int len, void* rcv_buf, int& buf_size, int timeout)  in mt_udpsendrcv()  argument
57     rc = MtFrame::sendto(sock, pkg, len, 0, (struct sockaddr*)dst, (int)sizeof(*dst), timeout);  in mt_udpsendrcv()
66 …recvfrom(sock, rcv_buf, buf_size, 0, (struct sockaddr*)&from_addr, (socklen_t*)&addr_len, timeout);  in mt_udpsendrcv()
150 static int mt_tcp_check_recv(int sock, char* rcv_buf, int &len, int flags, int timeout, MtFuncTcpMs…  in mt_tcp_check_recv()  argument
157         if (cost_time > (utime64_t)timeout)  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()
210 … sockaddr_in* dst, void* pkg, int len, void* rcv_buf, int& buf_size, int timeout, MtFuncTcpMsgLen …  in mt_tcpsendrcv()  argument
223     int time_left = timeout;  in mt_tcpsendrcv()
243     time_left = (timeout > (int)cost_time) ? (timeout - (int)cost_time) : 0;  in mt_tcpsendrcv()
253     time_left = (timeout > (int)cost_time) ? (timeout - (int)cost_time) : 0;  in mt_tcpsendrcv()
274 … sockaddr_in* dst, void* pkg, int len, void* rcv_buf, int& buf_size, int timeout, MtFuncTcpMsgLen …  in mt_tcpsendrcv_short()  argument
280     int time_left = timeout;  in mt_tcpsendrcv_short()
306     time_left = (timeout > (int)cost_time) ? (timeout - (int)cost_time) : 0;  in mt_tcpsendrcv_short()
316     time_left = (timeout > (int)cost_time) ? (timeout - (int)cost_time) : 0;  in mt_tcpsendrcv_short()
334 int mt_tcpsend(struct sockaddr_in* dst, void* pkg, int len, int timeout)  in mt_tcpsend()  argument
346     int time_left = timeout;  in mt_tcpsend()
366     time_left = (timeout > (int)cost_time) ? (timeout - (int)cost_time) : 0;  in mt_tcpsend()
387 int mt_tcpsend_short(struct sockaddr_in* dst, void* pkg, int len, int timeout)  in mt_tcpsend_short()  argument
399     int time_left = timeout;  in mt_tcpsend_short()
419     time_left = (timeout > (int)cost_time) ? (timeout - (int)cost_time) : 0;  in mt_tcpsend_short()
438 … sockaddr_in* dst, void* pkg, int len, void* rcv_buf, int* buf_size, int timeout, MtFuncTcpMsgLen …  in mt_tcpsendrcv_ex()  argument
451             return mt_tcpsendrcv(dst, pkg, len, rcv_buf, *buf_size, timeout, func);  in mt_tcpsendrcv_ex()
456             return mt_tcpsend(dst, pkg, len, timeout);  in mt_tcpsendrcv_ex()
461             return mt_tcpsendrcv_short(dst, pkg, len, rcv_buf, *buf_size, timeout, func);  in mt_tcpsendrcv_ex()
466             return mt_tcpsend_short(dst, pkg, len, timeout);  in mt_tcpsendrcv_ex()
588 …from(int fd, void *buf, int len, int flags, struct sockaddr *from, socklen_t *fromlen, int timeout)  in mt_recvfrom()  argument
590     return MtFrame::recvfrom(fd, buf, len, flags, from, fromlen, timeout);  in mt_recvfrom()
593 …dto(int fd, const void *msg, int len, int flags, const struct sockaddr *to, int tolen, int timeout)  in mt_sendto()  argument
595     return MtFrame::sendto(fd, msg, len, flags, to, tolen, timeout);  in mt_sendto()
598 int mt_connect(int fd, const struct sockaddr *addr, int addrlen, int timeout)  in mt_connect()  argument
600     return MtFrame::connect(fd, addr, addrlen, timeout);  in mt_connect()
603 int mt_accept(int fd, struct sockaddr *addr, socklen_t *addrlen, int timeout)  in mt_accept()  argument
605     return MtFrame::accept(fd, addr, addrlen, timeout);  in mt_accept()
608 ssize_t mt_read(int fd, void *buf, size_t nbyte, int timeout)  in mt_read()  argument
610     return MtFrame::read(fd, buf, nbyte, timeout);  in mt_read()
613 ssize_t mt_write(int fd, const void *buf, size_t nbyte, int timeout)  in mt_write()  argument
615     return MtFrame::write(fd, buf, nbyte, timeout);  in mt_write()
618 ssize_t mt_recv(int fd, void *buf, int len, int flags, int timeout)  in mt_recv()  argument
620     return MtFrame::recv(fd, buf, len, flags, timeout);  in mt_recv()
623 ssize_t mt_send(int fd, const void *buf, size_t nbyte, int flags, int timeout)  in mt_send()  argument
625     return MtFrame::send(fd, buf, nbyte, flags, timeout);  in mt_send()
638 int mt_wait_events(int fd, int events, int timeout)  in mt_wait_events()  argument
640     return MtFrame::Instance()->WaitEvents(fd, events, timeout);  in mt_wait_events()
739                      int timeout, MtFuncTcpMsgChecker check_func, void* msg_ctx, bool keep_rcv_buf)  in mt_tcp_check_recv()  argument
761         if (cost_time > (utime64_t)timeout)  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()
864                      int timeout, MtFuncTcpMsgChecker check_func, void* msg_ctx, bool keep_rcv_buf)  in mt_tcpsendrcv()  argument
878     int time_left = timeout;  in mt_tcpsendrcv()
898     time_left = (timeout > (int)cost_time) ? (timeout - (int)cost_time) : 0;  in mt_tcpsendrcv()
908     time_left = (timeout > (int)cost_time) ? (timeout - (int)cost_time) : 0;  in mt_tcpsendrcv()
930                      int timeout, MtFuncTcpMsgChecker check_func, void* msg_ctx, bool keep_rcv_buf)  in mt_tcpsendrcv_short()  argument
936     int time_left = timeout;  in mt_tcpsendrcv_short()
962     time_left = (timeout > (int)cost_time) ? (timeout - (int)cost_time) : 0;  in mt_tcpsendrcv_short()
972     time_left = (timeout > (int)cost_time) ? (timeout - (int)cost_time) : 0;  in mt_tcpsendrcv_short()
992                      int timeout, MtFuncTcpMsgChecker check_func, void* msg_ctx,   in mt_tcpsendrcv_ex()  argument
1006 …return mt_tcpsendrcv(dst, pkg, len, rcv_buf, rcv_pkg_size, timeout, check_func, msg_ctx, keep_rcv_…  in mt_tcpsendrcv_ex()
1011             return mt_tcpsend(dst, pkg, len, timeout);  in mt_tcpsendrcv_ex()
1016 …return mt_tcpsendrcv_short(dst, pkg, len, rcv_buf, rcv_pkg_size, timeout, check_func, msg_ctx, kee…  in mt_tcpsendrcv_ex()
1021             return mt_tcpsend_short(dst, pkg, len, timeout);  in mt_tcpsendrcv_ex()