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;
464 	size_t want, seek_init = seek, offset = 0;
467 	want = min_t(size_t, count, buf->head[0].iov_len);
468 	if (seek < want) {
469 		ret = xs_read_kvec(sock, msg, flags, &buf->head[0], want, seek);
475 		if (ret != want)
479 		seek -= want;
480 		offset += want;
483 	want = xs_alloc_sparse_pages(
486 	if (seek < want) {
489 				want + buf->page_base,
498 		if (ret != want)
502 		seek -= want;
503 		offset += want;
506 	want = min_t(size_t, count - offset, buf->tail[0].iov_len);
507 	if (seek < want) {
508 		ret = xs_read_kvec(sock, msg, flags, &buf->tail[0], want, seek);
514 		if (ret != want)
558 	size_t want, read;
563 	want = transport->recv.len - transport->recv.offset;
564 	if (want != 0) {
566 				transport->recv.copied + want,
576 	if (want == 0)
602 		int flags, size_t want, size_t seek)
606 		.iov_len = want,
608 	return xs_read_kvec(transport->sock, msg, flags, &kvec, want, seek);
682 	size_t want, read = 0;
686 		want = xs_read_stream_headersize(transport->recv.copied != 0);
687 		ret = xs_read_stream_header(transport, &msg, flags, want,
692 		if (transport->recv.offset != want)
1224  * using the socket, and so we don't want to clear sk->sk_err.
1301  * on the server we want to save.
2059 		 * We want the AF_LOCAL connect to be resolved in the
2063 		 * If we want to support asynchronous AF_LOCAL calls,
2907  * we allocate pages instead doing a kmalloc like rpc_malloc is because we want
3561 	 * we want to keep it around as long as the connection lasts,
3573 	 * Since we don't want connections for the backchannel, we set