472 	if (!transport->recv.copied) {  in xs_read_header()
473 		if (buf->head[0].iov_len >= transport->recv.offset)  in xs_read_header()
475 					&transport->recv.xid,  in xs_read_header()
476 					transport->recv.offset);  in xs_read_header()
477 		transport->recv.copied = transport->recv.offset;  in xs_read_header()
484 	return transport->recv.fraghdr & cpu_to_be32(RPC_LAST_STREAM_FRAGMENT);  in xs_read_stream_request_done()
505 	want = transport->recv.len - transport->recv.offset;  in xs_read_stream_request()
508 				transport->recv.copied + want,  in xs_read_stream_request()
509 				transport->recv.copied,  in xs_read_stream_request()
511 		transport->recv.offset += read;  in xs_read_stream_request()
512 		transport->recv.copied += read;  in xs_read_stream_request()
515 	if (transport->recv.offset == transport->recv.len)  in xs_read_stream_request()
547 		.iov_base = &transport->recv.fraghdr,  in xs_read_stream_header()
562 	req = xprt_lookup_bc_request(xprt, transport->recv.xid);  in xs_read_stream_call()
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()
595 	req = xprt_lookup_rqst(xprt, transport->recv.xid);  in xs_read_stream_reply()
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()
623 	if (transport->recv.len == 0) {  in xs_read_stream()
624 		want = xs_read_stream_headersize(transport->recv.copied != 0);  in xs_read_stream()
626 				transport->recv.offset);  in xs_read_stream()
629 		transport->recv.offset = ret;  in xs_read_stream()
630 		if (transport->recv.offset != want)  in xs_read_stream()
631 			return transport->recv.offset;  in xs_read_stream()
632 		transport->recv.len = be32_to_cpu(transport->recv.fraghdr) &  in xs_read_stream()
634 		transport->recv.offset -= sizeof(transport->recv.fraghdr);  in xs_read_stream()
638 	switch (be32_to_cpu(transport->recv.calldir)) {  in xs_read_stream()
649 		transport->recv.calldir = cpu_to_be32(-1);  in xs_read_stream()
650 		transport->recv.copied = -1;  in xs_read_stream()
655 	if (transport->recv.offset < transport->recv.len) {  in xs_read_stream()
660 				transport->recv.len - transport->recv.offset);  in xs_read_stream()
663 		transport->recv.offset += ret;  in xs_read_stream()
665 		if (transport->recv.offset != transport->recv.len)  in xs_read_stream()
670 		transport->recv.copied = 0;  in xs_read_stream()
672 	transport->recv.offset = 0;  in xs_read_stream()
673 	transport->recv.len = 0;  in xs_read_stream()
739 	transport->recv.offset = 0;  in xs_stream_reset_connect()
740 	transport->recv.len = 0;  in xs_stream_reset_connect()
741 	transport->recv.copied = 0;  in xs_stream_reset_connect()