Lines Matching refs:copied
530 if (!transport->recv.copied) { in xs_read_header()
535 transport->recv.copied = transport->recv.offset; in xs_read_header()
566 transport->recv.copied + want, in xs_read_stream_request()
567 transport->recv.copied, in xs_read_stream_request()
570 transport->recv.copied += read; in xs_read_stream_request()
629 if (transport->recv.copied && !req->rq_private_buf.len) in xs_read_stream_call()
634 xprt_complete_bc_request(req, transport->recv.copied); in xs_read_stream_call()
636 req->rq_private_buf.len = transport->recv.copied; in xs_read_stream_call()
658 if (!req || (transport->recv.copied && !req->rq_private_buf.len)) { in xs_read_stream_reply()
669 xprt_complete_rqst(req->rq_task, transport->recv.copied); in xs_read_stream_reply()
671 req->rq_private_buf.len = transport->recv.copied; in xs_read_stream_reply()
686 want = xs_read_stream_headersize(transport->recv.copied != 0); in xs_read_stream()
712 transport->recv.copied = -1; in xs_read_stream()
732 transport->recv.copied = 0; in xs_read_stream()
807 transport->recv.copied = 0; in xs_stream_reset_connect()
1363 int repsize, copied; in xs_udp_data_read_skb() local
1388 if ((copied = rovr->rq_private_buf.buflen) > repsize) in xs_udp_data_read_skb()
1389 copied = repsize; in xs_udp_data_read_skb()
1400 xprt_adjust_cwnd(xprt, task, copied); in xs_udp_data_read_skb()
1403 xprt_complete_rqst(task, copied); in xs_udp_data_read_skb()