net/sunrpc/xprtsock.c

340 xs_alloc_sparse_pages(struct xdr_buf *buf, size_t want, gfp_t gfp)
344 	if (!want || !(buf->flags & XDRBUF_SPARSE_PAGES))
345 		return want;
346 	n = (buf->page_base + want + PAGE_SIZE - 1) >> PAGE_SHIFT;
356 	return want;
484 	size_t want, seek_init = seek, offset = 0;
487 	want = min_t(size_t, count, buf->head[0].iov_len);
488 	if (seek < want) {
489 		ret = xs_read_kvec(sock, msg, flags, &buf->head[0], want, seek);
495 		if (ret != want)
499 		seek -= want;
500 		offset += want;
503 	want = xs_alloc_sparse_pages(
506 	if (seek < want) {
509 				want + buf->page_base,
518 		if (ret != want)
522 		seek -= want;
523 		offset += want;
526 	want = min_t(size_t, count - offset, buf->tail[0].iov_len);
527 	if (seek < want) {
528 		ret = xs_read_kvec(sock, msg, flags, &buf->tail[0], want, seek);
534 		if (ret != want)
578 	size_t want, read;
583 	want = transport->recv.len - transport->recv.offset;
584 	if (want != 0) {
586 				transport->recv.copied + want,
596 	if (want == 0)
622 		int flags, size_t want, size_t seek)
626 		.iov_len = want,
628 	return xs_read_kvec(transport->sock, msg, flags, &kvec, want, seek);
702 	size_t want, read = 0;
706 		want = xs_read_stream_headersize(transport->recv.copied != 0);
707 		ret = xs_read_stream_header(transport, &msg, flags, want,
712 		if (transport->recv.offset != want)
1245  * using the socket, and so we don't want to clear sk->sk_err.
1323  * on the server we want to save.
2084 		 * We want the AF_LOCAL connect to be resolved in the
2088 		 * If we want to support asynchronous AF_LOCAL calls,
2941  * we allocate pages instead doing a kmalloc like rpc_malloc is because we want
3595 	 * we want to keep it around as long as the connection lasts,
3607 	 * Since we don't want connections for the backchannel, we set