diff options
Diffstat (limited to 'fs')
-rw-r--r-- | fs/nfsd/nfs2acl.c | 2 | ||||
-rw-r--r-- | fs/nfsd/nfs3acl.c | 2 | ||||
-rw-r--r-- | fs/nfsd/nfs3proc.c | 6 | ||||
-rw-r--r-- | fs/nfsd/nfs3xdr.c | 33 | ||||
-rw-r--r-- | fs/nfsd/nfs4xdr.c | 24 | ||||
-rw-r--r-- | fs/nfsd/nfsxdr.c | 11 | ||||
-rw-r--r-- | fs/nfsd/vfs.c | 18 |
7 files changed, 47 insertions, 49 deletions
diff --git a/fs/nfsd/nfs2acl.c b/fs/nfsd/nfs2acl.c index b314888825d5..9170861c804a 100644 --- a/fs/nfsd/nfs2acl.c +++ b/fs/nfsd/nfs2acl.c | |||
@@ -253,7 +253,7 @@ static int nfsaclsvc_encode_getaclres(struct svc_rqst *rqstp, __be32 *p, | |||
253 | (resp->mask & NFS_ACL) ? resp->acl_access : NULL, | 253 | (resp->mask & NFS_ACL) ? resp->acl_access : NULL, |
254 | (resp->mask & NFS_DFACL) ? resp->acl_default : NULL); | 254 | (resp->mask & NFS_DFACL) ? resp->acl_default : NULL); |
255 | while (w > 0) { | 255 | while (w > 0) { |
256 | if (!rqstp->rq_respages[rqstp->rq_resused++]) | 256 | if (!*(rqstp->rq_next_page++)) |
257 | return 0; | 257 | return 0; |
258 | w -= PAGE_SIZE; | 258 | w -= PAGE_SIZE; |
259 | } | 259 | } |
diff --git a/fs/nfsd/nfs3acl.c b/fs/nfsd/nfs3acl.c index a596e9d987e4..9cbc1a841f87 100644 --- a/fs/nfsd/nfs3acl.c +++ b/fs/nfsd/nfs3acl.c | |||
@@ -184,7 +184,7 @@ static int nfs3svc_encode_getaclres(struct svc_rqst *rqstp, __be32 *p, | |||
184 | (resp->mask & NFS_ACL) ? resp->acl_access : NULL, | 184 | (resp->mask & NFS_ACL) ? resp->acl_access : NULL, |
185 | (resp->mask & NFS_DFACL) ? resp->acl_default : NULL); | 185 | (resp->mask & NFS_DFACL) ? resp->acl_default : NULL); |
186 | while (w > 0) { | 186 | while (w > 0) { |
187 | if (!rqstp->rq_respages[rqstp->rq_resused++]) | 187 | if (!*(rqstp->rq_next_page++)) |
188 | return 0; | 188 | return 0; |
189 | w -= PAGE_SIZE; | 189 | w -= PAGE_SIZE; |
190 | } | 190 | } |
diff --git a/fs/nfsd/nfs3proc.c b/fs/nfsd/nfs3proc.c index 97d90d1c8608..1fc02dfdc5c4 100644 --- a/fs/nfsd/nfs3proc.c +++ b/fs/nfsd/nfs3proc.c | |||
@@ -460,7 +460,7 @@ nfsd3_proc_readdirplus(struct svc_rqst *rqstp, struct nfsd3_readdirargs *argp, | |||
460 | __be32 nfserr; | 460 | __be32 nfserr; |
461 | int count = 0; | 461 | int count = 0; |
462 | loff_t offset; | 462 | loff_t offset; |
463 | int i; | 463 | struct page **p; |
464 | caddr_t page_addr = NULL; | 464 | caddr_t page_addr = NULL; |
465 | 465 | ||
466 | dprintk("nfsd: READDIR+(3) %s %d bytes at %d\n", | 466 | dprintk("nfsd: READDIR+(3) %s %d bytes at %d\n", |
@@ -484,8 +484,8 @@ nfsd3_proc_readdirplus(struct svc_rqst *rqstp, struct nfsd3_readdirargs *argp, | |||
484 | &resp->common, | 484 | &resp->common, |
485 | nfs3svc_encode_entry_plus); | 485 | nfs3svc_encode_entry_plus); |
486 | memcpy(resp->verf, argp->verf, 8); | 486 | memcpy(resp->verf, argp->verf, 8); |
487 | for (i=1; i<rqstp->rq_resused ; i++) { | 487 | for (p = rqstp->rq_respages + 1; p < rqstp->rq_next_page; p++) { |
488 | page_addr = page_address(rqstp->rq_respages[i]); | 488 | page_addr = page_address(*p); |
489 | 489 | ||
490 | if (((caddr_t)resp->buffer >= page_addr) && | 490 | if (((caddr_t)resp->buffer >= page_addr) && |
491 | ((caddr_t)resp->buffer < page_addr + PAGE_SIZE)) { | 491 | ((caddr_t)resp->buffer < page_addr + PAGE_SIZE)) { |
diff --git a/fs/nfsd/nfs3xdr.c b/fs/nfsd/nfs3xdr.c index 2b8618de6c27..324c0baf7cda 100644 --- a/fs/nfsd/nfs3xdr.c +++ b/fs/nfsd/nfs3xdr.c | |||
@@ -325,7 +325,7 @@ nfs3svc_decode_readargs(struct svc_rqst *rqstp, __be32 *p, | |||
325 | struct nfsd3_readargs *args) | 325 | struct nfsd3_readargs *args) |
326 | { | 326 | { |
327 | unsigned int len; | 327 | unsigned int len; |
328 | int v,pn; | 328 | int v; |
329 | u32 max_blocksize = svc_max_payload(rqstp); | 329 | u32 max_blocksize = svc_max_payload(rqstp); |
330 | 330 | ||
331 | if (!(p = decode_fh(p, &args->fh))) | 331 | if (!(p = decode_fh(p, &args->fh))) |
@@ -340,8 +340,9 @@ nfs3svc_decode_readargs(struct svc_rqst *rqstp, __be32 *p, | |||
340 | /* set up the kvec */ | 340 | /* set up the kvec */ |
341 | v=0; | 341 | v=0; |
342 | while (len > 0) { | 342 | while (len > 0) { |
343 | pn = rqstp->rq_resused++; | 343 | struct page *p = *(rqstp->rq_next_page++); |
344 | rqstp->rq_vec[v].iov_base = page_address(rqstp->rq_respages[pn]); | 344 | |
345 | rqstp->rq_vec[v].iov_base = page_address(p); | ||
345 | rqstp->rq_vec[v].iov_len = len < PAGE_SIZE? len : PAGE_SIZE; | 346 | rqstp->rq_vec[v].iov_len = len < PAGE_SIZE? len : PAGE_SIZE; |
346 | len -= rqstp->rq_vec[v].iov_len; | 347 | len -= rqstp->rq_vec[v].iov_len; |
347 | v++; | 348 | v++; |
@@ -463,8 +464,7 @@ nfs3svc_decode_symlinkargs(struct svc_rqst *rqstp, __be32 *p, | |||
463 | len = ntohl(*p++); | 464 | len = ntohl(*p++); |
464 | if (len == 0 || len > NFS3_MAXPATHLEN || len >= PAGE_SIZE) | 465 | if (len == 0 || len > NFS3_MAXPATHLEN || len >= PAGE_SIZE) |
465 | return 0; | 466 | return 0; |
466 | args->tname = new = | 467 | args->tname = new = page_address(*(rqstp->rq_next_page++)); |
467 | page_address(rqstp->rq_respages[rqstp->rq_resused++]); | ||
468 | args->tlen = len; | 468 | args->tlen = len; |
469 | /* first copy and check from the first page */ | 469 | /* first copy and check from the first page */ |
470 | old = (char*)p; | 470 | old = (char*)p; |
@@ -535,8 +535,7 @@ nfs3svc_decode_readlinkargs(struct svc_rqst *rqstp, __be32 *p, | |||
535 | { | 535 | { |
536 | if (!(p = decode_fh(p, &args->fh))) | 536 | if (!(p = decode_fh(p, &args->fh))) |
537 | return 0; | 537 | return 0; |
538 | args->buffer = | 538 | args->buffer = page_address(*(rqstp->rq_next_page++)); |
539 | page_address(rqstp->rq_respages[rqstp->rq_resused++]); | ||
540 | 539 | ||
541 | return xdr_argsize_check(rqstp, p); | 540 | return xdr_argsize_check(rqstp, p); |
542 | } | 541 | } |
@@ -567,8 +566,7 @@ nfs3svc_decode_readdirargs(struct svc_rqst *rqstp, __be32 *p, | |||
567 | if (args->count > PAGE_SIZE) | 566 | if (args->count > PAGE_SIZE) |
568 | args->count = PAGE_SIZE; | 567 | args->count = PAGE_SIZE; |
569 | 568 | ||
570 | args->buffer = | 569 | args->buffer = page_address(*(rqstp->rq_next_page++)); |
571 | page_address(rqstp->rq_respages[rqstp->rq_resused++]); | ||
572 | 570 | ||
573 | return xdr_argsize_check(rqstp, p); | 571 | return xdr_argsize_check(rqstp, p); |
574 | } | 572 | } |
@@ -577,7 +575,7 @@ int | |||
577 | nfs3svc_decode_readdirplusargs(struct svc_rqst *rqstp, __be32 *p, | 575 | nfs3svc_decode_readdirplusargs(struct svc_rqst *rqstp, __be32 *p, |
578 | struct nfsd3_readdirargs *args) | 576 | struct nfsd3_readdirargs *args) |
579 | { | 577 | { |
580 | int len, pn; | 578 | int len; |
581 | u32 max_blocksize = svc_max_payload(rqstp); | 579 | u32 max_blocksize = svc_max_payload(rqstp); |
582 | 580 | ||
583 | if (!(p = decode_fh(p, &args->fh))) | 581 | if (!(p = decode_fh(p, &args->fh))) |
@@ -592,9 +590,9 @@ nfs3svc_decode_readdirplusargs(struct svc_rqst *rqstp, __be32 *p, | |||
592 | args->count = len; | 590 | args->count = len; |
593 | 591 | ||
594 | while (len > 0) { | 592 | while (len > 0) { |
595 | pn = rqstp->rq_resused++; | 593 | struct page *p = *(rqstp->rq_next_page++); |
596 | if (!args->buffer) | 594 | if (!args->buffer) |
597 | args->buffer = page_address(rqstp->rq_respages[pn]); | 595 | args->buffer = page_address(p); |
598 | len -= PAGE_SIZE; | 596 | len -= PAGE_SIZE; |
599 | } | 597 | } |
600 | 598 | ||
@@ -880,7 +878,7 @@ encode_entry(struct readdir_cd *ccd, const char *name, int namlen, | |||
880 | common); | 878 | common); |
881 | __be32 *p = cd->buffer; | 879 | __be32 *p = cd->buffer; |
882 | caddr_t curr_page_addr = NULL; | 880 | caddr_t curr_page_addr = NULL; |
883 | int pn; /* current page number */ | 881 | struct page ** page; |
884 | int slen; /* string (name) length */ | 882 | int slen; /* string (name) length */ |
885 | int elen; /* estimated entry length in words */ | 883 | int elen; /* estimated entry length in words */ |
886 | int num_entry_words = 0; /* actual number of words */ | 884 | int num_entry_words = 0; /* actual number of words */ |
@@ -917,8 +915,9 @@ encode_entry(struct readdir_cd *ccd, const char *name, int namlen, | |||
917 | } | 915 | } |
918 | 916 | ||
919 | /* determine which page in rq_respages[] we are currently filling */ | 917 | /* determine which page in rq_respages[] we are currently filling */ |
920 | for (pn=1; pn < cd->rqstp->rq_resused; pn++) { | 918 | for (page = cd->rqstp->rq_respages + 1; |
921 | curr_page_addr = page_address(cd->rqstp->rq_respages[pn]); | 919 | page < cd->rqstp->rq_next_page; page++) { |
920 | curr_page_addr = page_address(*page); | ||
922 | 921 | ||
923 | if (((caddr_t)cd->buffer >= curr_page_addr) && | 922 | if (((caddr_t)cd->buffer >= curr_page_addr) && |
924 | ((caddr_t)cd->buffer < curr_page_addr + PAGE_SIZE)) | 923 | ((caddr_t)cd->buffer < curr_page_addr + PAGE_SIZE)) |
@@ -933,14 +932,14 @@ encode_entry(struct readdir_cd *ccd, const char *name, int namlen, | |||
933 | if (plus) | 932 | if (plus) |
934 | p = encode_entryplus_baggage(cd, p, name, namlen); | 933 | p = encode_entryplus_baggage(cd, p, name, namlen); |
935 | num_entry_words = p - cd->buffer; | 934 | num_entry_words = p - cd->buffer; |
936 | } else if (cd->rqstp->rq_respages[pn+1] != NULL) { | 935 | } else if (*(page+1) != NULL) { |
937 | /* temporarily encode entry into next page, then move back to | 936 | /* temporarily encode entry into next page, then move back to |
938 | * current and next page in rq_respages[] */ | 937 | * current and next page in rq_respages[] */ |
939 | __be32 *p1, *tmp; | 938 | __be32 *p1, *tmp; |
940 | int len1, len2; | 939 | int len1, len2; |
941 | 940 | ||
942 | /* grab next page for temporary storage of entry */ | 941 | /* grab next page for temporary storage of entry */ |
943 | p1 = tmp = page_address(cd->rqstp->rq_respages[pn+1]); | 942 | p1 = tmp = page_address(*(page+1)); |
944 | 943 | ||
945 | p1 = encode_entry_baggage(cd, p1, name, namlen, ino); | 944 | p1 = encode_entry_baggage(cd, p1, name, namlen, ino); |
946 | 945 | ||
diff --git a/fs/nfsd/nfs4xdr.c b/fs/nfsd/nfs4xdr.c index d7a3be5ab777..0dc11586682f 100644 --- a/fs/nfsd/nfs4xdr.c +++ b/fs/nfsd/nfs4xdr.c | |||
@@ -2906,7 +2906,8 @@ nfsd4_encode_read(struct nfsd4_compoundres *resp, __be32 nfserr, | |||
2906 | struct nfsd4_read *read) | 2906 | struct nfsd4_read *read) |
2907 | { | 2907 | { |
2908 | u32 eof; | 2908 | u32 eof; |
2909 | int v, pn; | 2909 | int v; |
2910 | struct page *page; | ||
2910 | unsigned long maxcount; | 2911 | unsigned long maxcount; |
2911 | long len; | 2912 | long len; |
2912 | __be32 *p; | 2913 | __be32 *p; |
@@ -2925,16 +2926,15 @@ nfsd4_encode_read(struct nfsd4_compoundres *resp, __be32 nfserr, | |||
2925 | len = maxcount; | 2926 | len = maxcount; |
2926 | v = 0; | 2927 | v = 0; |
2927 | while (len > 0) { | 2928 | while (len > 0) { |
2928 | pn = resp->rqstp->rq_resused; | 2929 | page = *(resp->rqstp->rq_next_page); |
2929 | if (!resp->rqstp->rq_respages[pn]) { /* ran out of pages */ | 2930 | if (!page) { /* ran out of pages */ |
2930 | maxcount -= len; | 2931 | maxcount -= len; |
2931 | break; | 2932 | break; |
2932 | } | 2933 | } |
2933 | resp->rqstp->rq_vec[v].iov_base = | 2934 | resp->rqstp->rq_vec[v].iov_base = page_address(page); |
2934 | page_address(resp->rqstp->rq_respages[pn]); | ||
2935 | resp->rqstp->rq_vec[v].iov_len = | 2935 | resp->rqstp->rq_vec[v].iov_len = |
2936 | len < PAGE_SIZE ? len : PAGE_SIZE; | 2936 | len < PAGE_SIZE ? len : PAGE_SIZE; |
2937 | resp->rqstp->rq_resused++; | 2937 | resp->rqstp->rq_next_page++; |
2938 | v++; | 2938 | v++; |
2939 | len -= PAGE_SIZE; | 2939 | len -= PAGE_SIZE; |
2940 | } | 2940 | } |
@@ -2980,10 +2980,10 @@ nfsd4_encode_readlink(struct nfsd4_compoundres *resp, __be32 nfserr, struct nfsd | |||
2980 | return nfserr; | 2980 | return nfserr; |
2981 | if (resp->xbuf->page_len) | 2981 | if (resp->xbuf->page_len) |
2982 | return nfserr_resource; | 2982 | return nfserr_resource; |
2983 | if (!resp->rqstp->rq_respages[resp->rqstp->rq_resused]) | 2983 | if (!*resp->rqstp->rq_next_page) |
2984 | return nfserr_resource; | 2984 | return nfserr_resource; |
2985 | 2985 | ||
2986 | page = page_address(resp->rqstp->rq_respages[resp->rqstp->rq_resused++]); | 2986 | page = page_address(*(resp->rqstp->rq_next_page++)); |
2987 | 2987 | ||
2988 | maxcount = PAGE_SIZE; | 2988 | maxcount = PAGE_SIZE; |
2989 | RESERVE_SPACE(4); | 2989 | RESERVE_SPACE(4); |
@@ -3031,7 +3031,7 @@ nfsd4_encode_readdir(struct nfsd4_compoundres *resp, __be32 nfserr, struct nfsd4 | |||
3031 | return nfserr; | 3031 | return nfserr; |
3032 | if (resp->xbuf->page_len) | 3032 | if (resp->xbuf->page_len) |
3033 | return nfserr_resource; | 3033 | return nfserr_resource; |
3034 | if (!resp->rqstp->rq_respages[resp->rqstp->rq_resused]) | 3034 | if (!*resp->rqstp->rq_next_page) |
3035 | return nfserr_resource; | 3035 | return nfserr_resource; |
3036 | 3036 | ||
3037 | RESERVE_SPACE(NFS4_VERIFIER_SIZE); | 3037 | RESERVE_SPACE(NFS4_VERIFIER_SIZE); |
@@ -3059,7 +3059,7 @@ nfsd4_encode_readdir(struct nfsd4_compoundres *resp, __be32 nfserr, struct nfsd4 | |||
3059 | goto err_no_verf; | 3059 | goto err_no_verf; |
3060 | } | 3060 | } |
3061 | 3061 | ||
3062 | page = page_address(resp->rqstp->rq_respages[resp->rqstp->rq_resused++]); | 3062 | page = page_address(*(resp->rqstp->rq_next_page++)); |
3063 | readdir->common.err = 0; | 3063 | readdir->common.err = 0; |
3064 | readdir->buflen = maxcount; | 3064 | readdir->buflen = maxcount; |
3065 | readdir->buffer = page; | 3065 | readdir->buffer = page; |
@@ -3082,8 +3082,8 @@ nfsd4_encode_readdir(struct nfsd4_compoundres *resp, __be32 nfserr, struct nfsd4 | |||
3082 | p = readdir->buffer; | 3082 | p = readdir->buffer; |
3083 | *p++ = 0; /* no more entries */ | 3083 | *p++ = 0; /* no more entries */ |
3084 | *p++ = htonl(readdir->common.err == nfserr_eof); | 3084 | *p++ = htonl(readdir->common.err == nfserr_eof); |
3085 | resp->xbuf->page_len = ((char*)p) - (char*)page_address( | 3085 | resp->xbuf->page_len = ((char*)p) - |
3086 | resp->rqstp->rq_respages[resp->rqstp->rq_resused-1]); | 3086 | (char*)page_address(*(resp->rqstp->rq_next_page-1)); |
3087 | 3087 | ||
3088 | /* Use rest of head for padding and remaining ops: */ | 3088 | /* Use rest of head for padding and remaining ops: */ |
3089 | resp->xbuf->tail[0].iov_base = tailbase; | 3089 | resp->xbuf->tail[0].iov_base = tailbase; |
diff --git a/fs/nfsd/nfsxdr.c b/fs/nfsd/nfsxdr.c index 65ec595e2226..979b42106979 100644 --- a/fs/nfsd/nfsxdr.c +++ b/fs/nfsd/nfsxdr.c | |||
@@ -246,7 +246,7 @@ nfssvc_decode_readargs(struct svc_rqst *rqstp, __be32 *p, | |||
246 | struct nfsd_readargs *args) | 246 | struct nfsd_readargs *args) |
247 | { | 247 | { |
248 | unsigned int len; | 248 | unsigned int len; |
249 | int v,pn; | 249 | int v; |
250 | if (!(p = decode_fh(p, &args->fh))) | 250 | if (!(p = decode_fh(p, &args->fh))) |
251 | return 0; | 251 | return 0; |
252 | 252 | ||
@@ -262,8 +262,9 @@ nfssvc_decode_readargs(struct svc_rqst *rqstp, __be32 *p, | |||
262 | */ | 262 | */ |
263 | v=0; | 263 | v=0; |
264 | while (len > 0) { | 264 | while (len > 0) { |
265 | pn = rqstp->rq_resused++; | 265 | struct page *p = *(rqstp->rq_next_page++); |
266 | rqstp->rq_vec[v].iov_base = page_address(rqstp->rq_respages[pn]); | 266 | |
267 | rqstp->rq_vec[v].iov_base = page_address(p); | ||
267 | rqstp->rq_vec[v].iov_len = len < PAGE_SIZE?len:PAGE_SIZE; | 268 | rqstp->rq_vec[v].iov_len = len < PAGE_SIZE?len:PAGE_SIZE; |
268 | len -= rqstp->rq_vec[v].iov_len; | 269 | len -= rqstp->rq_vec[v].iov_len; |
269 | v++; | 270 | v++; |
@@ -355,7 +356,7 @@ nfssvc_decode_readlinkargs(struct svc_rqst *rqstp, __be32 *p, struct nfsd_readli | |||
355 | { | 356 | { |
356 | if (!(p = decode_fh(p, &args->fh))) | 357 | if (!(p = decode_fh(p, &args->fh))) |
357 | return 0; | 358 | return 0; |
358 | args->buffer = page_address(rqstp->rq_respages[rqstp->rq_resused++]); | 359 | args->buffer = page_address(*(rqstp->rq_next_page++)); |
359 | 360 | ||
360 | return xdr_argsize_check(rqstp, p); | 361 | return xdr_argsize_check(rqstp, p); |
361 | } | 362 | } |
@@ -396,7 +397,7 @@ nfssvc_decode_readdirargs(struct svc_rqst *rqstp, __be32 *p, | |||
396 | if (args->count > PAGE_SIZE) | 397 | if (args->count > PAGE_SIZE) |
397 | args->count = PAGE_SIZE; | 398 | args->count = PAGE_SIZE; |
398 | 399 | ||
399 | args->buffer = page_address(rqstp->rq_respages[rqstp->rq_resused++]); | 400 | args->buffer = page_address(*(rqstp->rq_next_page++)); |
400 | 401 | ||
401 | return xdr_argsize_check(rqstp, p); | 402 | return xdr_argsize_check(rqstp, p); |
402 | } | 403 | } |
diff --git a/fs/nfsd/vfs.c b/fs/nfsd/vfs.c index b31e46eeb026..f0a6d88d7fff 100644 --- a/fs/nfsd/vfs.c +++ b/fs/nfsd/vfs.c | |||
@@ -886,7 +886,7 @@ nfsd_splice_actor(struct pipe_inode_info *pipe, struct pipe_buffer *buf, | |||
886 | struct splice_desc *sd) | 886 | struct splice_desc *sd) |
887 | { | 887 | { |
888 | struct svc_rqst *rqstp = sd->u.data; | 888 | struct svc_rqst *rqstp = sd->u.data; |
889 | struct page **pp = rqstp->rq_respages + rqstp->rq_resused; | 889 | struct page **pp = rqstp->rq_next_page; |
890 | struct page *page = buf->page; | 890 | struct page *page = buf->page; |
891 | size_t size; | 891 | size_t size; |
892 | 892 | ||
@@ -894,17 +894,15 @@ nfsd_splice_actor(struct pipe_inode_info *pipe, struct pipe_buffer *buf, | |||
894 | 894 | ||
895 | if (rqstp->rq_res.page_len == 0) { | 895 | if (rqstp->rq_res.page_len == 0) { |
896 | get_page(page); | 896 | get_page(page); |
897 | put_page(*pp); | 897 | put_page(*rqstp->rq_next_page); |
898 | *pp = page; | 898 | *(rqstp->rq_next_page++) = page; |
899 | rqstp->rq_resused++; | ||
900 | rqstp->rq_res.page_base = buf->offset; | 899 | rqstp->rq_res.page_base = buf->offset; |
901 | rqstp->rq_res.page_len = size; | 900 | rqstp->rq_res.page_len = size; |
902 | } else if (page != pp[-1]) { | 901 | } else if (page != pp[-1]) { |
903 | get_page(page); | 902 | get_page(page); |
904 | if (*pp) | 903 | if (*rqstp->rq_next_page) |
905 | put_page(*pp); | 904 | put_page(*rqstp->rq_next_page); |
906 | *pp = page; | 905 | *(rqstp->rq_next_page++) = page; |
907 | rqstp->rq_resused++; | ||
908 | rqstp->rq_res.page_len += size; | 906 | rqstp->rq_res.page_len += size; |
909 | } else | 907 | } else |
910 | rqstp->rq_res.page_len += size; | 908 | rqstp->rq_res.page_len += size; |
@@ -936,8 +934,8 @@ nfsd_vfs_read(struct svc_rqst *rqstp, struct svc_fh *fhp, struct file *file, | |||
936 | .u.data = rqstp, | 934 | .u.data = rqstp, |
937 | }; | 935 | }; |
938 | 936 | ||
939 | WARN_ON_ONCE(rqstp->rq_resused != 1); | 937 | WARN_ON_ONCE(rqstp->rq_next_page != rqstp->rq_respages + 1); |
940 | rqstp->rq_resused = 1; | 938 | rqstp->rq_next_page = rqstp->rq_respages + 1; |
941 | host_err = splice_direct_to_actor(file, &sd, nfsd_direct_splice_actor); | 939 | host_err = splice_direct_to_actor(file, &sd, nfsd_direct_splice_actor); |
942 | } else { | 940 | } else { |
943 | oldfs = get_fs(); | 941 | oldfs = get_fs(); |