48     int sock = socket(PF_INET, SOCK_DGRAM, 0);  in mt_udpsendrcv()  local
49     if ((sock < 0) || (ioctl(sock, FIONBIO, &flags) < 0))  in mt_udpsendrcv()
52         MTLOG_ERROR("mt_udpsendrcv new sock failed, sock: %d, errno: %d (%m)", sock, errno);  in mt_udpsendrcv()
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()
78     if (sock > 0)  in mt_udpsendrcv()
80         close(sock);  in mt_udpsendrcv()
81         sock = -1;  in mt_udpsendrcv()
120 static TcpKeepConn* mt_tcp_get_keep_conn(struct sockaddr_in* dst, int& sock)  in mt_tcp_get_keep_conn()  argument
146     sock = osfd;  in mt_tcp_get_keep_conn()
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
160             MTLOG_ERROR("tcp socket[%d] recv not ok, timeout", sock);  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()
167             MTLOG_ERROR("tcp socket[%d] recv failed ret[%d][%m]", sock, rc);  in mt_tcp_check_recv()
173             MTLOG_ERROR("tcp socket[%d] remote close", sock);  in mt_tcp_check_recv()
181             MTLOG_ERROR("tcp socket[%d] user check pkg error[%d]", sock, rc);  in mt_tcp_check_recv()
188                 MTLOG_ERROR("tcp socket[%d] user check pkg not ok, but no more buff", sock);  in mt_tcp_check_recv()
225     int sock = -1;  in mt_tcpsendrcv()  local
226     TcpKeepConn* conn = mt_tcp_get_keep_conn(dst, sock);  in mt_tcpsendrcv()
227     if ((conn == NULL) || (sock < 0))  in mt_tcpsendrcv()
229         MTLOG_ERROR("socket[%d] get conn failed, ret[%m]", sock);  in mt_tcpsendrcv()
234     rc = MtFrame::connect(sock, (struct sockaddr *)dst, addr_len, time_left);  in mt_tcpsendrcv()
237         MTLOG_ERROR("socket[%d] connect failed, ret[%d][%m]", sock, rc);  in mt_tcpsendrcv()
244     rc = MtFrame::send(sock, pkg, len, 0, time_left);  in mt_tcpsendrcv()
247         MTLOG_ERROR("socket[%d] send failed, ret[%d][%m]", sock, rc);  in mt_tcpsendrcv()
254     rc = mt_tcp_check_recv(sock, (char*)rcv_buf, buf_size, 0, time_left, func);  in mt_tcpsendrcv()
257         MTLOG_ERROR("socket[%d] rcv failed, ret[%d][%m]", sock, rc);  in mt_tcpsendrcv()
289     int sock;  in mt_tcpsendrcv_short()  local
290     sock = mt_tcp_create_sock();  in mt_tcpsendrcv_short()
291     if (sock < 0)  in mt_tcpsendrcv_short()
293         MTLOG_ERROR("create tcp socket failed, ret: %d", sock);  in mt_tcpsendrcv_short()
297     rc = MtFrame::connect(sock, (struct sockaddr *)dst, addr_len, time_left);  in mt_tcpsendrcv_short()
300         MTLOG_ERROR("socket[%d] connect failed, ret[%d][%m]", sock, rc);  in mt_tcpsendrcv_short()
307     rc = MtFrame::send(sock, pkg, len, 0, time_left);  in mt_tcpsendrcv_short()
310         MTLOG_ERROR("socket[%d] send failed, ret[%d][%m]", sock, rc);  in mt_tcpsendrcv_short()
317     rc = mt_tcp_check_recv(sock, (char*)rcv_buf, buf_size, 0, time_left, func);  in mt_tcpsendrcv_short()
320         MTLOG_ERROR("socket[%d] rcv failed, ret[%d][%m]", sock, rc);  in mt_tcpsendrcv_short()
328     if (sock >= 0)  in mt_tcpsendrcv_short()
329         ::close(sock);  in mt_tcpsendrcv_short()
348     int sock = -1;  in mt_tcpsend()  local
349     TcpKeepConn* conn = mt_tcp_get_keep_conn(dst, sock);  in mt_tcpsend()
350     if ((conn == NULL) || (sock < 0))  in mt_tcpsend()
352         MTLOG_ERROR("socket[%d] get conn failed, ret[%m]", sock);  in mt_tcpsend()
357     rc = MtFrame::connect(sock, (struct sockaddr *)dst, addr_len, time_left);  in mt_tcpsend()
360         MTLOG_ERROR("socket[%d] connect failed, ret[%d][%m]", sock, rc);  in mt_tcpsend()
367     rc = MtFrame::send(sock, pkg, len, 0, time_left);  in mt_tcpsend()
370         MTLOG_ERROR("socket[%d] send failed, ret[%d][%m]", sock, rc);  in mt_tcpsend()
401     int sock = -1;  in mt_tcpsend_short()  local
402     sock = mt_tcp_create_sock();  in mt_tcpsend_short()
403     if (sock < 0)  in mt_tcpsend_short()
405         MTLOG_ERROR("create tcp socket failed, ret: %d", sock);  in mt_tcpsend_short()
410     rc = MtFrame::connect(sock, (struct sockaddr *)dst, addr_len, time_left);  in mt_tcpsend_short()
413         MTLOG_ERROR("socket[%d] connect failed, ret[%d][%m]", sock, rc);  in mt_tcpsend_short()
420     rc = MtFrame::send(sock, pkg, len, 0, time_left);  in mt_tcpsend_short()
423         MTLOG_ERROR("socket[%d] send failed, ret[%d][%m]", sock, rc);  in mt_tcpsend_short()
432     if (sock >= 0)  in mt_tcpsend_short()
433         ::close(sock);  in mt_tcpsend_short()
738 static int mt_tcp_check_recv(int sock, void*& rcv_buf, int &len, int flags,   in mt_tcp_check_recv()  argument
754         MTLOG_ERROR("tcp socket[%d] recv failed ret[%d], alloc rcv buf failed, [%m]", sock, ret);  in mt_tcp_check_recv()
764             MTLOG_ERROR("tcp socket[%d] recv not ok, timeout", sock);  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()
771             MTLOG_ERROR("tcp socket[%d] recv failed ret[%d][%m]", sock, rc);  in mt_tcp_check_recv()
779                 MTLOG_ERROR("tcp socket[%d] remote close", sock);  in mt_tcp_check_recv()
787                 MTLOG_ERROR("tcp socket[%d] remote close", sock);  in mt_tcp_check_recv()
810             MTLOG_ERROR("tcp socket[%d] user check pkg error[%d]", sock, rc);  in mt_tcp_check_recv()
824 …          MTLOG_ERROR("tcp socket[%d] recv failed ret[%d], alloc rcv buf failed, [%m]", sock, ret);  in mt_tcp_check_recv()
841 …          MTLOG_ERROR("tcp socket[%d] recv failed ret[%d], alloc rcv buf failed, [%m]", sock, ret);  in mt_tcp_check_recv()
852                 MTLOG_ERROR("tcp socket[%d] user check pkg error, pkg len < recv_len", sock);  in mt_tcp_check_recv()
880     int sock = -1;  in mt_tcpsendrcv()  local
881     TcpKeepConn* conn = mt_tcp_get_keep_conn(dst, sock);  in mt_tcpsendrcv()
882     if ((conn == NULL) || (sock < 0))  in mt_tcpsendrcv()
884         MTLOG_ERROR("socket[%d] get conn failed, ret[%m]", sock);  in mt_tcpsendrcv()
889     rc = MtFrame::connect(sock, (struct sockaddr *)dst, addr_len, time_left);  in mt_tcpsendrcv()
892         MTLOG_ERROR("socket[%d] connect failed, ret[%d][%m]", sock, rc);  in mt_tcpsendrcv()
899     rc = MtFrame::send(sock, pkg, len, 0, time_left);  in mt_tcpsendrcv()
902         MTLOG_ERROR("socket[%d] send failed, ret[%d][%m]", sock, rc);  in mt_tcpsendrcv()
910 …rc = mt_tcp_check_recv(sock, rcv_buf, recv_pkg_size, 0, time_left, check_func, msg_ctx, keep_rcv_b…  in mt_tcpsendrcv()
913         MTLOG_ERROR("socket[%d] rcv failed, ret[%d][%m]", sock, rc);  in mt_tcpsendrcv()
945     int sock;  in mt_tcpsendrcv_short()  local
946     sock = mt_tcp_create_sock();  in mt_tcpsendrcv_short()
947     if (sock < 0)  in mt_tcpsendrcv_short()
949         MTLOG_ERROR("create tcp socket failed, ret: %d", sock);  in mt_tcpsendrcv_short()
953     rc = MtFrame::connect(sock, (struct sockaddr *)dst, addr_len, time_left);  in mt_tcpsendrcv_short()
956         MTLOG_ERROR("socket[%d] connect failed, ret[%d][%m]", sock, rc);  in mt_tcpsendrcv_short()
963     rc = MtFrame::send(sock, pkg, len, 0, time_left);  in mt_tcpsendrcv_short()
966         MTLOG_ERROR("socket[%d] send failed, ret[%d][%m]", sock, rc);  in mt_tcpsendrcv_short()
973 …rc = mt_tcp_check_recv(sock, rcv_buf, recv_pkg_size, 0, time_left, check_func, msg_ctx, keep_rcv_b…  in mt_tcpsendrcv_short()
977         MTLOG_ERROR("socket[%d] rcv failed, ret[%d][%m]", sock, rc);  in mt_tcpsendrcv_short()
985     if (sock >= 0)  in mt_tcpsendrcv_short()
986         ::close(sock);  in mt_tcpsendrcv_short()