Lines Matching refs:pkg
33 int mt_udpsendrcv(struct sockaddr_in* dst, void* pkg, int len, void* rcv_buf, int& buf_size, int ti… in mt_udpsendrcv() argument
41 if(len<1 || buf_size<1 ||!dst || !pkg || !rcv_buf) in mt_udpsendrcv()
44 dst, pkg, rcv_buf, len, buf_size); in mt_udpsendrcv()
57 rc = MtFrame::sendto(sock, pkg, len, 0, (struct sockaddr*)dst, (int)sizeof(*dst), timeout); in mt_udpsendrcv()
210 int mt_tcpsendrcv(struct sockaddr_in* dst, void* pkg, int len, void* rcv_buf, int& buf_size, int ti… in mt_tcpsendrcv() argument
212 if (!dst || !pkg || !rcv_buf || !func || len<1 || buf_size<1) in mt_tcpsendrcv()
215 dst, pkg, rcv_buf, func, len, buf_size); in mt_tcpsendrcv()
244 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsendrcv()
274 int mt_tcpsendrcv_short(struct sockaddr_in* dst, void* pkg, int len, void* rcv_buf, int& buf_size, … in mt_tcpsendrcv_short() argument
282 if (!dst || !pkg || !rcv_buf || !func || len<1 || buf_size<1) in mt_tcpsendrcv_short()
285 dst, pkg, rcv_buf, func, len, buf_size); in mt_tcpsendrcv_short()
307 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsendrcv_short()
334 int mt_tcpsend(struct sockaddr_in* dst, void* pkg, int len, int timeout) in mt_tcpsend() argument
336 if (!dst || !pkg || len<1) in mt_tcpsend()
338 MTLOG_ERROR("input params invalid, dst[%p], pkg[%p], len[%d]", dst, pkg, len); in mt_tcpsend()
367 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsend()
387 int mt_tcpsend_short(struct sockaddr_in* dst, void* pkg, int len, int timeout) in mt_tcpsend_short() argument
389 if (!dst || !pkg || len<1) in mt_tcpsend_short()
391 MTLOG_ERROR("input params invalid, dst[%p], pkg[%p], len[%d]", dst, pkg, len); in mt_tcpsend_short()
420 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsend_short()
438 int mt_tcpsendrcv_ex(struct sockaddr_in* dst, void* pkg, int len, void* rcv_buf, int* buf_size, int… in mt_tcpsendrcv_ex() argument
440 if(!dst || !pkg || len<1) in mt_tcpsendrcv_ex()
443 dst, pkg, rcv_buf, func, len, buf_size,type); in mt_tcpsendrcv_ex()
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()
472 dst, pkg, rcv_buf, func, len, buf_size,type); in mt_tcpsendrcv_ex()
863 int mt_tcpsendrcv(struct sockaddr_in* dst, void* pkg, int len, void*& rcv_buf, int& recv_pkg_size, in mt_tcpsendrcv() argument
866 if(!dst || !pkg || len<1) in mt_tcpsendrcv()
869 dst, pkg, len, check_func); in mt_tcpsendrcv()
899 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsendrcv()
929 int mt_tcpsendrcv_short(struct sockaddr_in* dst, void* pkg, int len, void*& rcv_buf, int& recv_pkg_… in mt_tcpsendrcv_short() argument
938 if(!dst || !pkg || len<1) in mt_tcpsendrcv_short()
941 dst, pkg, len, check_func); in mt_tcpsendrcv_short()
963 rc = MtFrame::send(sock, pkg, len, 0, time_left); in mt_tcpsendrcv_short()
991 int mt_tcpsendrcv_ex(struct sockaddr_in* dst, void* pkg, int len, void*& rcv_buf, int& rcv_pkg_size… in mt_tcpsendrcv_ex() argument
995 if(!dst || !pkg || len<1) in mt_tcpsendrcv_ex()
998 dst, pkg, len, check_func, msg_ctx, type); in mt_tcpsendrcv_ex()
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()
1027 dst, pkg, len, check_func, msg_ctx, type); in mt_tcpsendrcv_ex()