ich777/linux_media
1
0
Fork 0
mirror of https://github.com/tbsdtv/linux_media.git synced 2025-07-23 12:43:29 +02:00
Code Issues Packages Projects Releases Wiki Activity

NFSD: Update the NFSv3 READ3res encode to use struct xdr_stream

Browse Source 
Signed-off-by: Chuck Lever <chuck.lever@oracle.com>
This commit is contained in:
Chuck Lever
2020-10-22 15:23:50 -04:00
parent 9a9c8923b3
commit cc9bcdad77
4 changed files with 45 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
fs/nfsd/nfs3proc.c
View File

@@ -159,6 +159,7 @@ nfsd3_proc_read(struct svc_rqst *rqstp)
v = 0; v = 0;
len = argp->count; len = argp->count;
resp->pages = rqstp->rq_next_page;
while (len > 0) { while (len > 0) {
struct page *page = *(rqstp->rq_next_page++); struct page *page = *(rqstp->rq_next_page++);

43
fs/nfsd/nfs3xdr.c
View File

@@ -1005,30 +1005,33 @@ nfs3svc_encode_readlinkres(struct svc_rqst *rqstp, __be32 *p)
int int
nfs3svc_encode_readres(struct svc_rqst *rqstp, __be32 *p) nfs3svc_encode_readres(struct svc_rqst *rqstp, __be32 *p)
{ {
struct xdr_stream *xdr = &rqstp->rq_res_stream;
struct nfsd3_readres *resp = rqstp->rq_resp; struct nfsd3_readres *resp = rqstp->rq_resp;
struct kvec *head = rqstp->rq_res.head; struct kvec *head = rqstp->rq_res.head;
*p++ = resp->status; if (!svcxdr_encode_nfsstat3(xdr, resp->status))
p = encode_post_op_attr(rqstp, p, &resp->fh); return 0;
if (resp->status == 0) { switch (resp->status) {
*p++ = htonl(resp->count); case nfs_ok:
*p++ = htonl(resp->eof); if (!svcxdr_encode_post_op_attr(rqstp, xdr, &resp->fh))
*p++ = htonl(resp->count); /* xdr opaque count */
xdr_ressize_check(rqstp, p);
/* now update rqstp->rq_res to reflect data as well */
rqstp->rq_res.page_len = resp->count;
if (resp->count & 3) {
/* need to pad the tail */
rqstp->rq_res.tail[0].iov_base = p;
*p = 0;
rqstp->rq_res.tail[0].iov_len = 4 - (resp->count & 3);
}
if (svc_encode_result_payload(rqstp, head->iov_len,
resp->count))
return 0; return 0;
return 1; if (xdr_stream_encode_u32(xdr, resp->count) < 0)
} else return 0;
return xdr_ressize_check(rqstp, p); if (xdr_stream_encode_bool(xdr, resp->eof) < 0)
return 0;
if (xdr_stream_encode_u32(xdr, resp->count) < 0)
return 0;
xdr_write_pages(xdr, resp->pages, rqstp->rq_res.page_base,
resp->count);
if (svc_encode_result_payload(rqstp, head->iov_len, resp->count) < 0)
return 0;
break;
default:
if (!svcxdr_encode_post_op_attr(rqstp, xdr, &resp->fh))
return 0;
}
return 1;
} }
/* WRITE */ /* WRITE */

1
fs/nfsd/xdr3.h
View File

@@ -145,6 +145,7 @@ struct nfsd3_readres {
struct svc_fh fh; struct svc_fh fh;
unsigned long count; unsigned long count;
__u32 eof; __u32 eof;
struct page **pages;
}; };
struct nfsd3_writeres { struct nfsd3_writeres {

20
include/linux/sunrpc/xdr.h
View File

@@ -394,6 +394,26 @@ static inline int xdr_stream_encode_item_absent(struct xdr_stream *xdr)
return len; return len;
} }
/**
* xdr_stream_encode_bool - Encode a "not present" list item
* @xdr: pointer to xdr_stream
* @n: boolean value to encode
*
* Return values:
* On success, returns length in bytes of XDR buffer consumed
* %-EMSGSIZE on XDR buffer overflow
*/
static inline int xdr_stream_encode_bool(struct xdr_stream *xdr, __u32 n)
{
const size_t len = XDR_UNIT;
__be32 *p = xdr_reserve_space(xdr, len);
if (unlikely(!p))
return -EMSGSIZE;
*p = n ? xdr_one : xdr_zero;
return len;
}
/** /**
* xdr_stream_encode_u32 - Encode a 32-bit integer * xdr_stream_encode_u32 - Encode a 32-bit integer
* @xdr: pointer to xdr_stream * @xdr: pointer to xdr_stream