530 	if (!transport->recv.copied) {  in xs_read_header()
531 		if (buf->head[0].iov_len >= transport->recv.offset)  in xs_read_header()
533 					&transport->recv.xid,  in xs_read_header()
534 					transport->recv.offset);  in xs_read_header()
535 		transport->recv.copied = transport->recv.offset;  in xs_read_header()
542 	return transport->recv.fraghdr & cpu_to_be32(RPC_LAST_STREAM_FRAGMENT);  in xs_read_stream_request_done()
563 	want = transport->recv.len - transport->recv.offset;  in xs_read_stream_request()
566 				transport->recv.copied + want,  in xs_read_stream_request()
567 				transport->recv.copied,  in xs_read_stream_request()
569 		transport->recv.offset += read;  in xs_read_stream_request()
570 		transport->recv.copied += read;  in xs_read_stream_request()
573 	if (transport->recv.offset == transport->recv.len)  in xs_read_stream_request()
605 		.iov_base = &transport->recv.fraghdr,  in xs_read_stream_header()
624 	req = xprt_lookup_bc_request(xprt, transport->recv.xid);  in xs_read_stream_call()
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()
657 	req = xprt_lookup_rqst(xprt, transport->recv.xid);  in xs_read_stream_reply()
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()
685 	if (transport->recv.len == 0) {  in xs_read_stream()
686 		want = xs_read_stream_headersize(transport->recv.copied != 0);  in xs_read_stream()
688 				transport->recv.offset);  in xs_read_stream()
691 		transport->recv.offset = ret;  in xs_read_stream()
692 		if (transport->recv.offset != want)  in xs_read_stream()
693 			return transport->recv.offset;  in xs_read_stream()
694 		transport->recv.len = be32_to_cpu(transport->recv.fraghdr) &  in xs_read_stream()
696 		transport->recv.offset -= sizeof(transport->recv.fraghdr);  in xs_read_stream()
700 	switch (be32_to_cpu(transport->recv.calldir)) {  in xs_read_stream()
711 		transport->recv.calldir = cpu_to_be32(-1);  in xs_read_stream()
712 		transport->recv.copied = -1;  in xs_read_stream()
717 	if (transport->recv.offset < transport->recv.len) {  in xs_read_stream()
722 				transport->recv.len - transport->recv.offset);  in xs_read_stream()
725 		transport->recv.offset += ret;  in xs_read_stream()
727 		if (transport->recv.offset != transport->recv.len)  in xs_read_stream()
732 		transport->recv.copied = 0;  in xs_read_stream()
734 	transport->recv.offset = 0;  in xs_read_stream()
735 	transport->recv.len = 0;  in xs_read_stream()
805 	transport->recv.offset = 0;  in xs_stream_reset_connect()
806 	transport->recv.len = 0;  in xs_stream_reset_connect()
807 	transport->recv.copied = 0;  in xs_stream_reset_connect()