477 	if (!transport->recv.copied) {  in xs_read_header()
478 		if (buf->head[0].iov_len >= transport->recv.offset)  in xs_read_header()
480 					&transport->recv.xid,  in xs_read_header()
481 					transport->recv.offset);  in xs_read_header()
482 		transport->recv.copied = transport->recv.offset;  in xs_read_header()
489 	return transport->recv.fraghdr & cpu_to_be32(RPC_LAST_STREAM_FRAGMENT);  in xs_read_stream_request_done()
510 	want = transport->recv.len - transport->recv.offset;  in xs_read_stream_request()
513 				transport->recv.copied + want,  in xs_read_stream_request()
514 				transport->recv.copied,  in xs_read_stream_request()
516 		transport->recv.offset += read;  in xs_read_stream_request()
517 		transport->recv.copied += read;  in xs_read_stream_request()
520 	if (transport->recv.offset == transport->recv.len)  in xs_read_stream_request()
552 		.iov_base = &transport->recv.fraghdr,  in xs_read_stream_header()
571 	req = xprt_lookup_bc_request(xprt, transport->recv.xid);  in xs_read_stream_call()
576 	if (transport->recv.copied && !req->rq_private_buf.len)  in xs_read_stream_call()
581 		xprt_complete_bc_request(req, transport->recv.copied);  in xs_read_stream_call()
583 		req->rq_private_buf.len = transport->recv.copied;  in xs_read_stream_call()
604 	req = xprt_lookup_rqst(xprt, transport->recv.xid);  in xs_read_stream_reply()
605 	if (!req || (transport->recv.copied && !req->rq_private_buf.len)) {  in xs_read_stream_reply()
616 		xprt_complete_rqst(req->rq_task, transport->recv.copied);  in xs_read_stream_reply()
618 		req->rq_private_buf.len = transport->recv.copied;  in xs_read_stream_reply()
632 	if (transport->recv.len == 0) {  in xs_read_stream()
633 		want = xs_read_stream_headersize(transport->recv.copied != 0);  in xs_read_stream()
635 				transport->recv.offset);  in xs_read_stream()
638 		transport->recv.offset = ret;  in xs_read_stream()
639 		if (transport->recv.offset != want)  in xs_read_stream()
640 			return transport->recv.offset;  in xs_read_stream()
641 		transport->recv.len = be32_to_cpu(transport->recv.fraghdr) &  in xs_read_stream()
643 		transport->recv.offset -= sizeof(transport->recv.fraghdr);  in xs_read_stream()
647 	switch (be32_to_cpu(transport->recv.calldir)) {  in xs_read_stream()
658 		transport->recv.calldir = cpu_to_be32(-1);  in xs_read_stream()
659 		transport->recv.copied = -1;  in xs_read_stream()
664 	if (transport->recv.offset < transport->recv.len) {  in xs_read_stream()
669 				transport->recv.len - transport->recv.offset);  in xs_read_stream()
672 		transport->recv.offset += ret;  in xs_read_stream()
674 		if (transport->recv.offset != transport->recv.len)  in xs_read_stream()
679 		transport->recv.copied = 0;  in xs_read_stream()
681 	transport->recv.offset = 0;  in xs_read_stream()
682 	transport->recv.len = 0;  in xs_read_stream()
748 	transport->recv.offset = 0;  in xs_stream_reset_connect()
749 	transport->recv.len = 0;  in xs_stream_reset_connect()
750 	transport->recv.copied = 0;  in xs_stream_reset_connect()