471 	if (!transport->recv.copied) {  in xs_read_header()
472 		if (buf->head[0].iov_len >= transport->recv.offset)  in xs_read_header()
474 					&transport->recv.xid,  in xs_read_header()
475 					transport->recv.offset);  in xs_read_header()
476 		transport->recv.copied = transport->recv.offset;  in xs_read_header()
483 	return transport->recv.fraghdr & cpu_to_be32(RPC_LAST_STREAM_FRAGMENT);  in xs_read_stream_request_done()
504 	want = transport->recv.len - transport->recv.offset;  in xs_read_stream_request()
507 				transport->recv.copied + want,  in xs_read_stream_request()
508 				transport->recv.copied,  in xs_read_stream_request()
510 		transport->recv.offset += read;  in xs_read_stream_request()
511 		transport->recv.copied += read;  in xs_read_stream_request()
514 	if (transport->recv.offset == transport->recv.len)  in xs_read_stream_request()
546 		.iov_base = &transport->recv.fraghdr,  in xs_read_stream_header()
561 	req = xprt_lookup_bc_request(xprt, transport->recv.xid);  in xs_read_stream_call()
566 	if (transport->recv.copied && !req->rq_private_buf.len)  in xs_read_stream_call()
571 		xprt_complete_bc_request(req, transport->recv.copied);  in xs_read_stream_call()
573 		req->rq_private_buf.len = transport->recv.copied;  in xs_read_stream_call()
594 	req = xprt_lookup_rqst(xprt, transport->recv.xid);  in xs_read_stream_reply()
595 	if (!req || (transport->recv.copied && !req->rq_private_buf.len)) {  in xs_read_stream_reply()
606 		xprt_complete_rqst(req->rq_task, transport->recv.copied);  in xs_read_stream_reply()
608 		req->rq_private_buf.len = transport->recv.copied;  in xs_read_stream_reply()
622 	if (transport->recv.len == 0) {  in xs_read_stream()
623 		want = xs_read_stream_headersize(transport->recv.copied != 0);  in xs_read_stream()
625 				transport->recv.offset);  in xs_read_stream()
628 		transport->recv.offset = ret;  in xs_read_stream()
629 		if (transport->recv.offset != want)  in xs_read_stream()
630 			return transport->recv.offset;  in xs_read_stream()
631 		transport->recv.len = be32_to_cpu(transport->recv.fraghdr) &  in xs_read_stream()
633 		transport->recv.offset -= sizeof(transport->recv.fraghdr);  in xs_read_stream()
637 	switch (be32_to_cpu(transport->recv.calldir)) {  in xs_read_stream()
648 		transport->recv.calldir = cpu_to_be32(-1);  in xs_read_stream()
649 		transport->recv.copied = -1;  in xs_read_stream()
654 	if (transport->recv.offset < transport->recv.len) {  in xs_read_stream()
659 				transport->recv.len - transport->recv.offset);  in xs_read_stream()
662 		transport->recv.offset += ret;  in xs_read_stream()
664 		if (transport->recv.offset != transport->recv.len)  in xs_read_stream()
669 		transport->recv.copied = 0;  in xs_read_stream()
671 	transport->recv.offset = 0;  in xs_read_stream()
672 	transport->recv.len = 0;  in xs_read_stream()
738 	transport->recv.offset = 0;  in xs_stream_reset_connect()
739 	transport->recv.len = 0;  in xs_stream_reset_connect()
740 	transport->recv.copied = 0;  in xs_stream_reset_connect()