Lines Matching refs:copied
472 if (!transport->recv.copied) { in xs_read_header()
477 transport->recv.copied = transport->recv.offset; in xs_read_header()
508 transport->recv.copied + want, in xs_read_stream_request()
509 transport->recv.copied, in xs_read_stream_request()
512 transport->recv.copied += read; in xs_read_stream_request()
567 if (transport->recv.copied && !req->rq_private_buf.len) in xs_read_stream_call()
572 xprt_complete_bc_request(req, transport->recv.copied); in xs_read_stream_call()
574 req->rq_private_buf.len = transport->recv.copied; in xs_read_stream_call()
596 if (!req || (transport->recv.copied && !req->rq_private_buf.len)) { in xs_read_stream_reply()
607 xprt_complete_rqst(req->rq_task, transport->recv.copied); in xs_read_stream_reply()
609 req->rq_private_buf.len = transport->recv.copied; in xs_read_stream_reply()
624 want = xs_read_stream_headersize(transport->recv.copied != 0); in xs_read_stream()
650 transport->recv.copied = -1; in xs_read_stream()
670 transport->recv.copied = 0; in xs_read_stream()
741 transport->recv.copied = 0; in xs_stream_reset_connect()
1297 int repsize, copied; in xs_udp_data_read_skb() local
1322 if ((copied = rovr->rq_private_buf.buflen) > repsize) in xs_udp_data_read_skb()
1323 copied = repsize; in xs_udp_data_read_skb()
1334 xprt_adjust_cwnd(xprt, task, copied); in xs_udp_data_read_skb()
1337 xprt_complete_rqst(task, copied); in xs_udp_data_read_skb()