Lines Matching refs:recv_len
152 int recv_len = 0; in mt_tcp_check_recv() local
164 …int rc = MtFrame::recv(sock, (rcv_buf + recv_len), (len - recv_len), 0, (timeout - (int)cost_time)… in mt_tcp_check_recv()
172 len = recv_len; in mt_tcp_check_recv()
176 recv_len += rc; in mt_tcp_check_recv()
178 rc = func(rcv_buf, recv_len); in mt_tcp_check_recv()
186 if (len == recv_len) in mt_tcp_check_recv()
195 if (rc > recv_len) in mt_tcp_check_recv()
741 int recv_len = 0; in mt_tcp_check_recv() local
768 …rc = MtFrame::recv(sock, (sbuf.buf_ + recv_len), (sbuf.len_ - recv_len), 0, (timeout - (int)cost_t… in mt_tcp_check_recv()
777 if(recv_len==0) in mt_tcp_check_recv()
783 rc = check_func(sbuf.buf_, recv_len, true, msg_ctx, msg_len_detected); in mt_tcp_check_recv()
785 if(rc!=recv_len) in mt_tcp_check_recv()
790 len = recv_len; in mt_tcp_check_recv()
793 recv_len += rc; in mt_tcp_check_recv()
795 if((!msg_len_detected)||recv_len==pkg_len) in mt_tcp_check_recv()
797 rc = check_func(sbuf.buf_, recv_len, false, msg_ctx,msg_len_detected); in mt_tcp_check_recv()
815 if(sbuf.len_ > recv_len) in mt_tcp_check_recv()
830 if (rc > recv_len) in mt_tcp_check_recv()
832 if(sbuf.len_ > recv_len) in mt_tcp_check_recv()
845 else if(rc==recv_len) in mt_tcp_check_recv()