Lines Matching refs:rcv_buf
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()
66 …rc = MtFrame::recvfrom(sock, rcv_buf, buf_size, 0, (struct sockaddr*)&from_addr, (socklen_t*)&addr… 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
164 …int rc = MtFrame::recv(sock, (rcv_buf + recv_len), (len - recv_len), 0, (timeout - (int)cost_time)… in mt_tcp_check_recv()
178 rc = func(rcv_buf, recv_len); in mt_tcp_check_recv()
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()
254 rc = mt_tcp_check_recv(sock, (char*)rcv_buf, buf_size, 0, time_left, func); 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()
317 rc = mt_tcp_check_recv(sock, (char*)rcv_buf, buf_size, 0, time_left, func); in mt_tcpsendrcv_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
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()
461 return mt_tcpsendrcv_short(dst, pkg, len, rcv_buf, *buf_size, timeout, func); in mt_tcpsendrcv_ex()
472 dst, pkg, rcv_buf, func, len, buf_size,type); in mt_tcpsendrcv_ex()
738 static int mt_tcp_check_recv(int sock, void*& rcv_buf, int &len, int flags, in mt_tcp_check_recv() argument
749 ScopedBuf sbuf(rcv_buf, keep_rcv_buf); in mt_tcp_check_recv()
863 int mt_tcpsendrcv(struct sockaddr_in* dst, void* pkg, int len, void*& rcv_buf, int& recv_pkg_size, in mt_tcpsendrcv() argument
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()
929 int mt_tcpsendrcv_short(struct sockaddr_in* dst, void* pkg, int len, void*& rcv_buf, int& recv_pkg_… in mt_tcpsendrcv_short() argument
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()
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
1006 …return mt_tcpsendrcv(dst, pkg, len, rcv_buf, rcv_pkg_size, timeout, check_func, msg_ctx, keep_rcv_… 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()