4 * Server-side XDR for NFSv4
6 * Copyright (c) 2002 The Regents of the University of Michigan.
9 * Kendrick Smith <kmsmith@umich.edu>
10 * Andy Adamson <andros@umich.edu>
12 * Redistribution and use in source and binary forms, with or without
13 * modification, are permitted provided that the following conditions
16 * 1. Redistributions of source code must retain the above copyright
17 * notice, this list of conditions and the following disclaimer.
18 * 2. Redistributions in binary form must reproduce the above copyright
19 * notice, this list of conditions and the following disclaimer in the
20 * documentation and/or other materials provided with the distribution.
21 * 3. Neither the name of the University nor the names of its
22 * contributors may be used to endorse or promote products derived
23 * from this software without specific prior written permission.
25 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED
26 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
27 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
28 * DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
29 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
30 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
31 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
32 * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
33 * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
34 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
35 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
37 * TODO: Neil Brown made the following observation: We currently
38 * initially reserve NFSD_BUFSIZE space on the transmit queue and
39 * never release any of that until the request is complete.
40 * It would be good to calculate a new maximum response size while
41 * decoding the COMPOUND, and call svc_reserve with this number
42 * at the end of nfs4svc_decode_compoundargs.
45 #include <linux/param.h>
46 #include <linux/smp.h>
48 #include <linux/namei.h>
49 #include <linux/vfs.h>
50 #include <linux/sunrpc/xdr.h>
51 #include <linux/sunrpc/svc.h>
52 #include <linux/sunrpc/clnt.h>
53 #include <linux/nfsd/nfsd.h>
54 #include <linux/nfsd/state.h>
55 #include <linux/nfsd/xdr4.h>
56 #include <linux/nfsd_idmap.h>
57 #include <linux/nfs4.h>
58 #include <linux/nfs4_acl.h>
60 #define NFSDDBG_FACILITY NFSDDBG_XDR
63 * As per referral draft, the fsid for a referral MUST be different from the fsid of the containing
64 * directory in order to indicate to the client that a filesystem boundary is present
65 * We use a fixed fsid for a referral
67 #define NFS4_REFERRAL_FSID_MAJOR 0x8000000ULL
68 #define NFS4_REFERRAL_FSID_MINOR 0x8000000ULL
71 check_filename(char *str
, int len
, __be32 err
)
77 if (isdotent(str
, len
))
79 for (i
= 0; i
< len
; i
++)
86 * START OF "GENERIC" DECODE ROUTINES.
87 * These may look a little ugly since they are imported from a "generic"
88 * set of XDR encode/decode routines which are intended to be shared by
89 * all of our NFSv4 implementations (OpenBSD, MacOS X...).
91 * If the pain of reading these is too great, it should be a straightforward
92 * task to translate them into Linux-specific versions which are more
93 * consistent with the style used in NFSv2/v3...
103 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); \
104 status = nfserr_bad_xdr; \
107 #define READ32(x) (x) = ntohl(*p++)
108 #define READ64(x) do { \
109 (x) = (u64)ntohl(*p++) << 32; \
110 (x) |= ntohl(*p++); \
112 #define READTIME(x) do { \
117 #define READMEM(x,nbytes) do { \
119 p += XDR_QUADLEN(nbytes); \
121 #define SAVEMEM(x,nbytes) do { \
122 if (!(x = (p==argp->tmp || p == argp->tmpp) ? \
123 savemem(argp, p, nbytes) : \
125 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); \
128 p += XDR_QUADLEN(nbytes); \
130 #define COPYMEM(x,nbytes) do { \
131 memcpy((x), p, nbytes); \
132 p += XDR_QUADLEN(nbytes); \
135 /* READ_BUF, read_buf(): nbytes must be <= PAGE_SIZE */
136 #define READ_BUF(nbytes) do { \
137 if (nbytes <= (u32)((char *)argp->end - (char *)argp->p)) { \
139 argp->p += XDR_QUADLEN(nbytes); \
140 } else if (!(p = read_buf(argp, nbytes))) { \
141 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); \
146 static __be32
*read_buf(struct nfsd4_compoundargs
*argp
, int nbytes
)
148 /* We want more bytes than seem to be available.
149 * Maybe we need a new page, maybe we have just run out
151 int avail
= (char*)argp
->end
- (char*)argp
->p
;
153 if (avail
+ argp
->pagelen
< nbytes
)
155 if (avail
+ PAGE_SIZE
< nbytes
) /* need more than a page !! */
157 /* ok, we can do it with the current plus the next page */
158 if (nbytes
<= sizeof(argp
->tmp
))
162 p
= argp
->tmpp
= kmalloc(nbytes
, GFP_KERNEL
);
167 memcpy(p
, argp
->p
, avail
);
168 /* step to next page */
169 argp
->p
= page_address(argp
->pagelist
[0]);
171 if (argp
->pagelen
< PAGE_SIZE
) {
172 argp
->end
= p
+ (argp
->pagelen
>>2);
175 argp
->end
= p
+ (PAGE_SIZE
>>2);
176 argp
->pagelen
-= PAGE_SIZE
;
178 memcpy(((char*)p
)+avail
, argp
->p
, (nbytes
- avail
));
179 argp
->p
+= XDR_QUADLEN(nbytes
- avail
);
184 defer_free(struct nfsd4_compoundargs
*argp
,
185 void (*release
)(const void *), void *p
)
189 tb
= kmalloc(sizeof(*tb
), GFP_KERNEL
);
193 tb
->release
= release
;
194 tb
->next
= argp
->to_free
;
199 static char *savemem(struct nfsd4_compoundargs
*argp
, __be32
*p
, int nbytes
)
201 if (p
== argp
->tmp
) {
202 p
= kmalloc(nbytes
, GFP_KERNEL
);
205 memcpy(p
, argp
->tmp
, nbytes
);
207 BUG_ON(p
!= argp
->tmpp
);
210 if (defer_free(argp
, kfree
, p
)) {
218 nfsd4_decode_bitmap(struct nfsd4_compoundargs
*argp
, u32
*bmval
)
231 READ_BUF(bmlen
<< 2);
241 nfsd4_decode_fattr(struct nfsd4_compoundargs
*argp
, u32
*bmval
, struct iattr
*iattr
,
242 struct nfs4_acl
**acl
)
244 int expected_len
, len
= 0;
251 if ((status
= nfsd4_decode_bitmap(argp
, bmval
)))
255 * According to spec, unsupported attributes return ERR_ATTRNOTSUPP;
256 * read-only attributes return ERR_INVAL.
258 if ((bmval
[0] & ~NFSD_SUPPORTED_ATTRS_WORD0
) || (bmval
[1] & ~NFSD_SUPPORTED_ATTRS_WORD1
))
259 return nfserr_attrnotsupp
;
260 if ((bmval
[0] & ~NFSD_WRITEABLE_ATTRS_WORD0
) || (bmval
[1] & ~NFSD_WRITEABLE_ATTRS_WORD1
))
264 READ32(expected_len
);
266 if (bmval
[0] & FATTR4_WORD0_SIZE
) {
269 READ64(iattr
->ia_size
);
270 iattr
->ia_valid
|= ATTR_SIZE
;
272 if (bmval
[0] & FATTR4_WORD0_ACL
) {
274 struct nfs4_ace
*ace
;
276 READ_BUF(4); len
+= 4;
279 if (nace
> NFS4_ACL_MAX
)
280 return nfserr_resource
;
282 *acl
= nfs4_acl_new(nace
);
287 defer_free(argp
, kfree
, *acl
);
289 (*acl
)->naces
= nace
;
290 for (ace
= (*acl
)->aces
; ace
< (*acl
)->aces
+ nace
; ace
++) {
291 READ_BUF(16); len
+= 16;
294 READ32(ace
->access_mask
);
297 len
+= XDR_QUADLEN(dummy32
) << 2;
298 READMEM(buf
, dummy32
);
299 ace
->whotype
= nfs4_acl_get_whotype(buf
, dummy32
);
301 if (ace
->whotype
!= NFS4_ACL_WHO_NAMED
)
303 else if (ace
->flag
& NFS4_ACE_IDENTIFIER_GROUP
)
304 host_err
= nfsd_map_name_to_gid(argp
->rqstp
,
305 buf
, dummy32
, &ace
->who
);
307 host_err
= nfsd_map_name_to_uid(argp
->rqstp
,
308 buf
, dummy32
, &ace
->who
);
314 if (bmval
[1] & FATTR4_WORD1_MODE
) {
317 READ32(iattr
->ia_mode
);
318 iattr
->ia_mode
&= (S_IFMT
| S_IALLUGO
);
319 iattr
->ia_valid
|= ATTR_MODE
;
321 if (bmval
[1] & FATTR4_WORD1_OWNER
) {
326 len
+= (XDR_QUADLEN(dummy32
) << 2);
327 READMEM(buf
, dummy32
);
328 if ((host_err
= nfsd_map_name_to_uid(argp
->rqstp
, buf
, dummy32
, &iattr
->ia_uid
)))
330 iattr
->ia_valid
|= ATTR_UID
;
332 if (bmval
[1] & FATTR4_WORD1_OWNER_GROUP
) {
337 len
+= (XDR_QUADLEN(dummy32
) << 2);
338 READMEM(buf
, dummy32
);
339 if ((host_err
= nfsd_map_name_to_gid(argp
->rqstp
, buf
, dummy32
, &iattr
->ia_gid
)))
341 iattr
->ia_valid
|= ATTR_GID
;
343 if (bmval
[1] & FATTR4_WORD1_TIME_ACCESS_SET
) {
348 case NFS4_SET_TO_CLIENT_TIME
:
349 /* We require the high 32 bits of 'seconds' to be 0, and we ignore
350 all 32 bits of 'nseconds'. */
356 READ32(iattr
->ia_atime
.tv_sec
);
357 READ32(iattr
->ia_atime
.tv_nsec
);
358 if (iattr
->ia_atime
.tv_nsec
>= (u32
)1000000000)
360 iattr
->ia_valid
|= (ATTR_ATIME
| ATTR_ATIME_SET
);
362 case NFS4_SET_TO_SERVER_TIME
:
363 iattr
->ia_valid
|= ATTR_ATIME
;
369 if (bmval
[1] & FATTR4_WORD1_TIME_METADATA
) {
370 /* We require the high 32 bits of 'seconds' to be 0, and we ignore
371 all 32 bits of 'nseconds'. */
377 READ32(iattr
->ia_ctime
.tv_sec
);
378 READ32(iattr
->ia_ctime
.tv_nsec
);
379 if (iattr
->ia_ctime
.tv_nsec
>= (u32
)1000000000)
381 iattr
->ia_valid
|= ATTR_CTIME
;
383 if (bmval
[1] & FATTR4_WORD1_TIME_MODIFY_SET
) {
388 case NFS4_SET_TO_CLIENT_TIME
:
389 /* We require the high 32 bits of 'seconds' to be 0, and we ignore
390 all 32 bits of 'nseconds'. */
396 READ32(iattr
->ia_mtime
.tv_sec
);
397 READ32(iattr
->ia_mtime
.tv_nsec
);
398 if (iattr
->ia_mtime
.tv_nsec
>= (u32
)1000000000)
400 iattr
->ia_valid
|= (ATTR_MTIME
| ATTR_MTIME_SET
);
402 case NFS4_SET_TO_SERVER_TIME
:
403 iattr
->ia_valid
|= ATTR_MTIME
;
409 if (len
!= expected_len
)
415 status
= nfserrno(host_err
);
420 nfsd4_decode_access(struct nfsd4_compoundargs
*argp
, struct nfsd4_access
*access
)
425 READ32(access
->ac_req_access
);
431 nfsd4_decode_close(struct nfsd4_compoundargs
*argp
, struct nfsd4_close
*close
)
435 close
->cl_stateowner
= NULL
;
436 READ_BUF(4 + sizeof(stateid_t
));
437 READ32(close
->cl_seqid
);
438 READ32(close
->cl_stateid
.si_generation
);
439 COPYMEM(&close
->cl_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
446 nfsd4_decode_commit(struct nfsd4_compoundargs
*argp
, struct nfsd4_commit
*commit
)
451 READ64(commit
->co_offset
);
452 READ32(commit
->co_count
);
458 nfsd4_decode_create(struct nfsd4_compoundargs
*argp
, struct nfsd4_create
*create
)
463 READ32(create
->cr_type
);
464 switch (create
->cr_type
) {
467 READ32(create
->cr_linklen
);
468 READ_BUF(create
->cr_linklen
);
469 SAVEMEM(create
->cr_linkname
, create
->cr_linklen
);
474 READ32(create
->cr_specdata1
);
475 READ32(create
->cr_specdata2
);
485 READ32(create
->cr_namelen
);
486 READ_BUF(create
->cr_namelen
);
487 SAVEMEM(create
->cr_name
, create
->cr_namelen
);
488 if ((status
= check_filename(create
->cr_name
, create
->cr_namelen
, nfserr_inval
)))
491 if ((status
= nfsd4_decode_fattr(argp
, create
->cr_bmval
, &create
->cr_iattr
, &create
->cr_acl
)))
498 nfsd4_decode_delegreturn(struct nfsd4_compoundargs
*argp
, struct nfsd4_delegreturn
*dr
)
502 READ_BUF(sizeof(stateid_t
));
503 READ32(dr
->dr_stateid
.si_generation
);
504 COPYMEM(&dr
->dr_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
510 nfsd4_decode_getattr(struct nfsd4_compoundargs
*argp
, struct nfsd4_getattr
*getattr
)
512 return nfsd4_decode_bitmap(argp
, getattr
->ga_bmval
);
516 nfsd4_decode_link(struct nfsd4_compoundargs
*argp
, struct nfsd4_link
*link
)
521 READ32(link
->li_namelen
);
522 READ_BUF(link
->li_namelen
);
523 SAVEMEM(link
->li_name
, link
->li_namelen
);
524 if ((status
= check_filename(link
->li_name
, link
->li_namelen
, nfserr_inval
)))
531 nfsd4_decode_lock(struct nfsd4_compoundargs
*argp
, struct nfsd4_lock
*lock
)
535 lock
->lk_replay_owner
= NULL
;
537 * type, reclaim(boolean), offset, length, new_lock_owner(boolean)
540 READ32(lock
->lk_type
);
541 if ((lock
->lk_type
< NFS4_READ_LT
) || (lock
->lk_type
> NFS4_WRITEW_LT
))
543 READ32(lock
->lk_reclaim
);
544 READ64(lock
->lk_offset
);
545 READ64(lock
->lk_length
);
546 READ32(lock
->lk_is_new
);
548 if (lock
->lk_is_new
) {
550 READ32(lock
->lk_new_open_seqid
);
551 READ32(lock
->lk_new_open_stateid
.si_generation
);
553 COPYMEM(&lock
->lk_new_open_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
554 READ32(lock
->lk_new_lock_seqid
);
555 COPYMEM(&lock
->lk_new_clientid
, sizeof(clientid_t
));
556 READ32(lock
->lk_new_owner
.len
);
557 READ_BUF(lock
->lk_new_owner
.len
);
558 READMEM(lock
->lk_new_owner
.data
, lock
->lk_new_owner
.len
);
561 READ32(lock
->lk_old_lock_stateid
.si_generation
);
562 COPYMEM(&lock
->lk_old_lock_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
563 READ32(lock
->lk_old_lock_seqid
);
570 nfsd4_decode_lockt(struct nfsd4_compoundargs
*argp
, struct nfsd4_lockt
*lockt
)
575 READ32(lockt
->lt_type
);
576 if((lockt
->lt_type
< NFS4_READ_LT
) || (lockt
->lt_type
> NFS4_WRITEW_LT
))
578 READ64(lockt
->lt_offset
);
579 READ64(lockt
->lt_length
);
580 COPYMEM(&lockt
->lt_clientid
, 8);
581 READ32(lockt
->lt_owner
.len
);
582 READ_BUF(lockt
->lt_owner
.len
);
583 READMEM(lockt
->lt_owner
.data
, lockt
->lt_owner
.len
);
589 nfsd4_decode_locku(struct nfsd4_compoundargs
*argp
, struct nfsd4_locku
*locku
)
593 locku
->lu_stateowner
= NULL
;
594 READ_BUF(24 + sizeof(stateid_t
));
595 READ32(locku
->lu_type
);
596 if ((locku
->lu_type
< NFS4_READ_LT
) || (locku
->lu_type
> NFS4_WRITEW_LT
))
598 READ32(locku
->lu_seqid
);
599 READ32(locku
->lu_stateid
.si_generation
);
600 COPYMEM(&locku
->lu_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
601 READ64(locku
->lu_offset
);
602 READ64(locku
->lu_length
);
608 nfsd4_decode_lookup(struct nfsd4_compoundargs
*argp
, struct nfsd4_lookup
*lookup
)
613 READ32(lookup
->lo_len
);
614 READ_BUF(lookup
->lo_len
);
615 SAVEMEM(lookup
->lo_name
, lookup
->lo_len
);
616 if ((status
= check_filename(lookup
->lo_name
, lookup
->lo_len
, nfserr_noent
)))
623 nfsd4_decode_open(struct nfsd4_compoundargs
*argp
, struct nfsd4_open
*open
)
627 memset(open
->op_bmval
, 0, sizeof(open
->op_bmval
));
628 open
->op_iattr
.ia_valid
= 0;
629 open
->op_stateowner
= NULL
;
631 /* seqid, share_access, share_deny, clientid, ownerlen */
632 READ_BUF(16 + sizeof(clientid_t
));
633 READ32(open
->op_seqid
);
634 READ32(open
->op_share_access
);
635 READ32(open
->op_share_deny
);
636 COPYMEM(&open
->op_clientid
, sizeof(clientid_t
));
637 READ32(open
->op_owner
.len
);
639 /* owner, open_flag */
640 READ_BUF(open
->op_owner
.len
+ 4);
641 SAVEMEM(open
->op_owner
.data
, open
->op_owner
.len
);
642 READ32(open
->op_create
);
643 switch (open
->op_create
) {
644 case NFS4_OPEN_NOCREATE
:
646 case NFS4_OPEN_CREATE
:
648 READ32(open
->op_createmode
);
649 switch (open
->op_createmode
) {
650 case NFS4_CREATE_UNCHECKED
:
651 case NFS4_CREATE_GUARDED
:
652 if ((status
= nfsd4_decode_fattr(argp
, open
->op_bmval
, &open
->op_iattr
, &open
->op_acl
)))
655 case NFS4_CREATE_EXCLUSIVE
:
657 COPYMEM(open
->op_verf
.data
, 8);
669 READ32(open
->op_claim_type
);
670 switch (open
->op_claim_type
) {
671 case NFS4_OPEN_CLAIM_NULL
:
672 case NFS4_OPEN_CLAIM_DELEGATE_PREV
:
674 READ32(open
->op_fname
.len
);
675 READ_BUF(open
->op_fname
.len
);
676 SAVEMEM(open
->op_fname
.data
, open
->op_fname
.len
);
677 if ((status
= check_filename(open
->op_fname
.data
, open
->op_fname
.len
, nfserr_inval
)))
680 case NFS4_OPEN_CLAIM_PREVIOUS
:
682 READ32(open
->op_delegate_type
);
684 case NFS4_OPEN_CLAIM_DELEGATE_CUR
:
685 READ_BUF(sizeof(stateid_t
) + 4);
686 COPYMEM(&open
->op_delegate_stateid
, sizeof(stateid_t
));
687 READ32(open
->op_fname
.len
);
688 READ_BUF(open
->op_fname
.len
);
689 SAVEMEM(open
->op_fname
.data
, open
->op_fname
.len
);
690 if ((status
= check_filename(open
->op_fname
.data
, open
->op_fname
.len
, nfserr_inval
)))
701 nfsd4_decode_open_confirm(struct nfsd4_compoundargs
*argp
, struct nfsd4_open_confirm
*open_conf
)
705 open_conf
->oc_stateowner
= NULL
;
706 READ_BUF(4 + sizeof(stateid_t
));
707 READ32(open_conf
->oc_req_stateid
.si_generation
);
708 COPYMEM(&open_conf
->oc_req_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
709 READ32(open_conf
->oc_seqid
);
715 nfsd4_decode_open_downgrade(struct nfsd4_compoundargs
*argp
, struct nfsd4_open_downgrade
*open_down
)
719 open_down
->od_stateowner
= NULL
;
720 READ_BUF(12 + sizeof(stateid_t
));
721 READ32(open_down
->od_stateid
.si_generation
);
722 COPYMEM(&open_down
->od_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
723 READ32(open_down
->od_seqid
);
724 READ32(open_down
->od_share_access
);
725 READ32(open_down
->od_share_deny
);
731 nfsd4_decode_putfh(struct nfsd4_compoundargs
*argp
, struct nfsd4_putfh
*putfh
)
736 READ32(putfh
->pf_fhlen
);
737 if (putfh
->pf_fhlen
> NFS4_FHSIZE
)
739 READ_BUF(putfh
->pf_fhlen
);
740 SAVEMEM(putfh
->pf_fhval
, putfh
->pf_fhlen
);
746 nfsd4_decode_read(struct nfsd4_compoundargs
*argp
, struct nfsd4_read
*read
)
750 READ_BUF(sizeof(stateid_t
) + 12);
751 READ32(read
->rd_stateid
.si_generation
);
752 COPYMEM(&read
->rd_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
753 READ64(read
->rd_offset
);
754 READ32(read
->rd_length
);
760 nfsd4_decode_readdir(struct nfsd4_compoundargs
*argp
, struct nfsd4_readdir
*readdir
)
765 READ64(readdir
->rd_cookie
);
766 COPYMEM(readdir
->rd_verf
.data
, sizeof(readdir
->rd_verf
.data
));
767 READ32(readdir
->rd_dircount
); /* just in case you needed a useless field... */
768 READ32(readdir
->rd_maxcount
);
769 if ((status
= nfsd4_decode_bitmap(argp
, readdir
->rd_bmval
)))
776 nfsd4_decode_remove(struct nfsd4_compoundargs
*argp
, struct nfsd4_remove
*remove
)
781 READ32(remove
->rm_namelen
);
782 READ_BUF(remove
->rm_namelen
);
783 SAVEMEM(remove
->rm_name
, remove
->rm_namelen
);
784 if ((status
= check_filename(remove
->rm_name
, remove
->rm_namelen
, nfserr_noent
)))
791 nfsd4_decode_rename(struct nfsd4_compoundargs
*argp
, struct nfsd4_rename
*rename
)
796 READ32(rename
->rn_snamelen
);
797 READ_BUF(rename
->rn_snamelen
+ 4);
798 SAVEMEM(rename
->rn_sname
, rename
->rn_snamelen
);
799 READ32(rename
->rn_tnamelen
);
800 READ_BUF(rename
->rn_tnamelen
);
801 SAVEMEM(rename
->rn_tname
, rename
->rn_tnamelen
);
802 if ((status
= check_filename(rename
->rn_sname
, rename
->rn_snamelen
, nfserr_noent
)))
804 if ((status
= check_filename(rename
->rn_tname
, rename
->rn_tnamelen
, nfserr_inval
)))
811 nfsd4_decode_renew(struct nfsd4_compoundargs
*argp
, clientid_t
*clientid
)
815 READ_BUF(sizeof(clientid_t
));
816 COPYMEM(clientid
, sizeof(clientid_t
));
822 nfsd4_decode_setattr(struct nfsd4_compoundargs
*argp
, struct nfsd4_setattr
*setattr
)
826 READ_BUF(sizeof(stateid_t
));
827 READ32(setattr
->sa_stateid
.si_generation
);
828 COPYMEM(&setattr
->sa_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
829 if ((status
= nfsd4_decode_fattr(argp
, setattr
->sa_bmval
, &setattr
->sa_iattr
, &setattr
->sa_acl
)))
836 nfsd4_decode_setclientid(struct nfsd4_compoundargs
*argp
, struct nfsd4_setclientid
*setclientid
)
841 COPYMEM(setclientid
->se_verf
.data
, 8);
842 READ32(setclientid
->se_namelen
);
844 READ_BUF(setclientid
->se_namelen
+ 8);
845 SAVEMEM(setclientid
->se_name
, setclientid
->se_namelen
);
846 READ32(setclientid
->se_callback_prog
);
847 READ32(setclientid
->se_callback_netid_len
);
849 READ_BUF(setclientid
->se_callback_netid_len
+ 4);
850 SAVEMEM(setclientid
->se_callback_netid_val
, setclientid
->se_callback_netid_len
);
851 READ32(setclientid
->se_callback_addr_len
);
853 READ_BUF(setclientid
->se_callback_addr_len
+ 4);
854 SAVEMEM(setclientid
->se_callback_addr_val
, setclientid
->se_callback_addr_len
);
855 READ32(setclientid
->se_callback_ident
);
861 nfsd4_decode_setclientid_confirm(struct nfsd4_compoundargs
*argp
, struct nfsd4_setclientid_confirm
*scd_c
)
865 READ_BUF(8 + sizeof(nfs4_verifier
));
866 COPYMEM(&scd_c
->sc_clientid
, 8);
867 COPYMEM(&scd_c
->sc_confirm
, sizeof(nfs4_verifier
));
872 /* Also used for NVERIFY */
874 nfsd4_decode_verify(struct nfsd4_compoundargs
*argp
, struct nfsd4_verify
*verify
)
877 struct nfsd4_compoundargs save
= {
880 .rqstp
= argp
->rqstp
,
883 struct iattr ve_iattr
; /* request */
884 struct nfs4_acl
*ve_acl
; /* request */
888 if ((status
= nfsd4_decode_bitmap(argp
, verify
->ve_bmval
)))
891 /* For convenience's sake, we compare raw xdr'd attributes in
892 * nfsd4_proc_verify; however we still decode here just to return
893 * correct error in case of bad xdr. */
895 status
= nfsd4_decode_fattr(ve_bmval
, &ve_iattr
, &ve_acl
);
896 if (status
== nfserr_inval
) {
897 status
= nfserrno(status
);
902 READ32(verify
->ve_attrlen
);
903 READ_BUF(verify
->ve_attrlen
);
904 SAVEMEM(verify
->ve_attrval
, verify
->ve_attrlen
);
910 nfsd4_decode_write(struct nfsd4_compoundargs
*argp
, struct nfsd4_write
*write
)
917 READ_BUF(sizeof(stateid_opaque_t
) + 20);
918 READ32(write
->wr_stateid
.si_generation
);
919 COPYMEM(&write
->wr_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
920 READ64(write
->wr_offset
);
921 READ32(write
->wr_stable_how
);
922 if (write
->wr_stable_how
> 2)
924 READ32(write
->wr_buflen
);
926 /* Sorry .. no magic macros for this.. *
927 * READ_BUF(write->wr_buflen);
928 * SAVEMEM(write->wr_buf, write->wr_buflen);
930 avail
= (char*)argp
->end
- (char*)argp
->p
;
931 if (avail
+ argp
->pagelen
< write
->wr_buflen
) {
932 printk(KERN_NOTICE
"xdr error! (%s:%d)\n", __FILE__
, __LINE__
);
935 argp
->rqstp
->rq_vec
[0].iov_base
= p
;
936 argp
->rqstp
->rq_vec
[0].iov_len
= avail
;
938 len
= write
->wr_buflen
;
939 while (len
> argp
->rqstp
->rq_vec
[v
].iov_len
) {
940 len
-= argp
->rqstp
->rq_vec
[v
].iov_len
;
942 argp
->rqstp
->rq_vec
[v
].iov_base
= page_address(argp
->pagelist
[0]);
944 if (argp
->pagelen
>= PAGE_SIZE
) {
945 argp
->rqstp
->rq_vec
[v
].iov_len
= PAGE_SIZE
;
946 argp
->pagelen
-= PAGE_SIZE
;
948 argp
->rqstp
->rq_vec
[v
].iov_len
= argp
->pagelen
;
949 argp
->pagelen
-= len
;
952 argp
->end
= (__be32
*) (argp
->rqstp
->rq_vec
[v
].iov_base
+ argp
->rqstp
->rq_vec
[v
].iov_len
);
953 argp
->p
= (__be32
*) (argp
->rqstp
->rq_vec
[v
].iov_base
+ (XDR_QUADLEN(len
) << 2));
954 argp
->rqstp
->rq_vec
[v
].iov_len
= len
;
955 write
->wr_vlen
= v
+1;
961 nfsd4_decode_release_lockowner(struct nfsd4_compoundargs
*argp
, struct nfsd4_release_lockowner
*rlockowner
)
966 COPYMEM(&rlockowner
->rl_clientid
, sizeof(clientid_t
));
967 READ32(rlockowner
->rl_owner
.len
);
968 READ_BUF(rlockowner
->rl_owner
.len
);
969 READMEM(rlockowner
->rl_owner
.data
, rlockowner
->rl_owner
.len
);
975 nfsd4_decode_compound(struct nfsd4_compoundargs
*argp
)
982 * XXX: According to spec, we should check the tag
983 * for UTF-8 compliance. I'm postponing this for
984 * now because it seems that some clients do use
988 READ32(argp
->taglen
);
989 READ_BUF(argp
->taglen
+ 8);
990 SAVEMEM(argp
->tag
, argp
->taglen
);
991 READ32(argp
->minorversion
);
994 if (argp
->taglen
> NFSD4_MAX_TAGLEN
)
996 if (argp
->opcnt
> 100)
999 if (argp
->opcnt
> ARRAY_SIZE(argp
->iops
)) {
1000 argp
->ops
= kmalloc(argp
->opcnt
* sizeof(*argp
->ops
), GFP_KERNEL
);
1002 argp
->ops
= argp
->iops
;
1003 printk(KERN_INFO
"nfsd: couldn't allocate room for COMPOUND\n");
1008 for (i
= 0; i
< argp
->opcnt
; i
++) {
1013 * We can't use READ_BUF() here because we need to handle
1014 * a missing opcode as an OP_WRITE + 1. So we need to check
1015 * to see if we're truly at the end of our buffer or if there
1016 * is another page we need to flip to.
1019 if (argp
->p
== argp
->end
) {
1020 if (argp
->pagelen
< 4) {
1021 /* There isn't an opcode still on the wire */
1022 op
->opnum
= OP_WRITE
+ 1;
1023 op
->status
= nfserr_bad_xdr
;
1029 * False alarm. We just hit a page boundary, but there
1030 * is still data available. Move pointer across page
1031 * boundary. *snip from READ_BUF*
1033 argp
->p
= page_address(argp
->pagelist
[0]);
1035 if (argp
->pagelen
< PAGE_SIZE
) {
1036 argp
->end
= p
+ (argp
->pagelen
>>2);
1039 argp
->end
= p
+ (PAGE_SIZE
>>2);
1040 argp
->pagelen
-= PAGE_SIZE
;
1043 op
->opnum
= ntohl(*argp
->p
++);
1045 switch (op
->opnum
) {
1046 case 2: /* Reserved operation */
1047 op
->opnum
= OP_ILLEGAL
;
1048 if (argp
->minorversion
== 0)
1049 op
->status
= nfserr_op_illegal
;
1051 op
->status
= nfserr_minor_vers_mismatch
;
1054 op
->status
= nfsd4_decode_access(argp
, &op
->u
.access
);
1057 op
->status
= nfsd4_decode_close(argp
, &op
->u
.close
);
1060 op
->status
= nfsd4_decode_commit(argp
, &op
->u
.commit
);
1063 op
->status
= nfsd4_decode_create(argp
, &op
->u
.create
);
1065 case OP_DELEGRETURN
:
1066 op
->status
= nfsd4_decode_delegreturn(argp
, &op
->u
.delegreturn
);
1069 op
->status
= nfsd4_decode_getattr(argp
, &op
->u
.getattr
);
1072 op
->status
= nfs_ok
;
1075 op
->status
= nfsd4_decode_link(argp
, &op
->u
.link
);
1078 op
->status
= nfsd4_decode_lock(argp
, &op
->u
.lock
);
1081 op
->status
= nfsd4_decode_lockt(argp
, &op
->u
.lockt
);
1084 op
->status
= nfsd4_decode_locku(argp
, &op
->u
.locku
);
1087 op
->status
= nfsd4_decode_lookup(argp
, &op
->u
.lookup
);
1090 op
->status
= nfs_ok
;
1093 op
->status
= nfsd4_decode_verify(argp
, &op
->u
.nverify
);
1096 op
->status
= nfsd4_decode_open(argp
, &op
->u
.open
);
1098 case OP_OPEN_CONFIRM
:
1099 op
->status
= nfsd4_decode_open_confirm(argp
, &op
->u
.open_confirm
);
1101 case OP_OPEN_DOWNGRADE
:
1102 op
->status
= nfsd4_decode_open_downgrade(argp
, &op
->u
.open_downgrade
);
1105 op
->status
= nfsd4_decode_putfh(argp
, &op
->u
.putfh
);
1108 op
->status
= nfs_ok
;
1111 op
->status
= nfsd4_decode_read(argp
, &op
->u
.read
);
1114 op
->status
= nfsd4_decode_readdir(argp
, &op
->u
.readdir
);
1117 op
->status
= nfs_ok
;
1120 op
->status
= nfsd4_decode_remove(argp
, &op
->u
.remove
);
1123 op
->status
= nfsd4_decode_rename(argp
, &op
->u
.rename
);
1126 op
->status
= nfs_ok
;
1129 op
->status
= nfsd4_decode_renew(argp
, &op
->u
.renew
);
1132 op
->status
= nfs_ok
;
1135 op
->status
= nfsd4_decode_setattr(argp
, &op
->u
.setattr
);
1137 case OP_SETCLIENTID
:
1138 op
->status
= nfsd4_decode_setclientid(argp
, &op
->u
.setclientid
);
1140 case OP_SETCLIENTID_CONFIRM
:
1141 op
->status
= nfsd4_decode_setclientid_confirm(argp
, &op
->u
.setclientid_confirm
);
1144 op
->status
= nfsd4_decode_verify(argp
, &op
->u
.verify
);
1147 op
->status
= nfsd4_decode_write(argp
, &op
->u
.write
);
1149 case OP_RELEASE_LOCKOWNER
:
1150 op
->status
= nfsd4_decode_release_lockowner(argp
, &op
->u
.release_lockowner
);
1153 op
->opnum
= OP_ILLEGAL
;
1154 op
->status
= nfserr_op_illegal
;
1167 * END OF "GENERIC" DECODE ROUTINES.
1171 * START OF "GENERIC" ENCODE ROUTINES.
1172 * These may look a little ugly since they are imported from a "generic"
1173 * set of XDR encode/decode routines which are intended to be shared by
1174 * all of our NFSv4 implementations (OpenBSD, MacOS X...).
1176 * If the pain of reading these is too great, it should be a straightforward
1177 * task to translate them into Linux-specific versions which are more
1178 * consistent with the style used in NFSv2/v3...
1180 #define ENCODE_HEAD __be32 *p
1182 #define WRITE32(n) *p++ = htonl(n)
1183 #define WRITE64(n) do { \
1184 *p++ = htonl((u32)((n) >> 32)); \
1185 *p++ = htonl((u32)(n)); \
1187 #define WRITEMEM(ptr,nbytes) do { \
1188 *(p + XDR_QUADLEN(nbytes) -1) = 0; \
1189 memcpy(p, ptr, nbytes); \
1190 p += XDR_QUADLEN(nbytes); \
1192 #define WRITECINFO(c) do { \
1193 *p++ = htonl(c.atomic); \
1194 *p++ = htonl(c.before_ctime_sec); \
1195 *p++ = htonl(c.before_ctime_nsec); \
1196 *p++ = htonl(c.after_ctime_sec); \
1197 *p++ = htonl(c.after_ctime_nsec); \
1200 #define RESERVE_SPACE(nbytes) do { \
1202 BUG_ON(p + XDR_QUADLEN(nbytes) > resp->end); \
1204 #define ADJUST_ARGS() resp->p = p
1207 * Header routine to setup seqid operation replay cache
1209 #define ENCODE_SEQID_OP_HEAD \
1216 * Routine for encoding the result of a "seqid-mutating" NFSv4 operation. This
1217 * is where sequence id's are incremented, and the replay cache is filled.
1218 * Note that we increment sequence id's here, at the last moment, so we're sure
1219 * we know whether the error to be returned is a sequence id mutating error.
1222 #define ENCODE_SEQID_OP_TAIL(stateowner) do { \
1223 if (seqid_mutating_err(nfserr) && stateowner) { \
1224 stateowner->so_seqid++; \
1225 stateowner->so_replay.rp_status = nfserr; \
1226 stateowner->so_replay.rp_buflen = \
1227 (((char *)(resp)->p - (char *)save)); \
1228 memcpy(stateowner->so_replay.rp_buf, save, \
1229 stateowner->so_replay.rp_buflen); \
1232 /* Encode as an array of strings the string given with components
1235 static __be32
nfsd4_encode_components(char sep
, char *components
,
1236 __be32
**pp
, int *buflen
)
1240 int strlen
, count
=0;
1243 dprintk("nfsd4_encode_components(%s)\n", components
);
1244 if ((*buflen
-= 4) < 0)
1245 return nfserr_resource
;
1246 WRITE32(0); /* We will fill this in with @count later */
1247 end
= str
= components
;
1249 for (; *end
&& (*end
!= sep
); end
++)
1250 ; /* Point to end of component */
1253 if ((*buflen
-= ((XDR_QUADLEN(strlen
) << 2) + 4)) < 0)
1254 return nfserr_resource
;
1256 WRITEMEM(str
, strlen
);
1270 * encode a location element of a fs_locations structure
1272 static __be32
nfsd4_encode_fs_location4(struct nfsd4_fs_location
*location
,
1273 __be32
**pp
, int *buflen
)
1278 status
= nfsd4_encode_components(':', location
->hosts
, &p
, buflen
);
1281 status
= nfsd4_encode_components('/', location
->path
, &p
, buflen
);
1289 * Return the path to an export point in the pseudo filesystem namespace
1290 * Returned string is safe to use as long as the caller holds a reference
1293 static char *nfsd4_path(struct svc_rqst
*rqstp
, struct svc_export
*exp
, __be32
*stat
)
1295 struct svc_fh tmp_fh
;
1296 char *path
, *rootpath
;
1298 fh_init(&tmp_fh
, NFS4_FHSIZE
);
1299 *stat
= exp_pseudoroot(rqstp
->rq_client
, &tmp_fh
, &rqstp
->rq_chandle
);
1302 rootpath
= tmp_fh
.fh_export
->ex_path
;
1304 path
= exp
->ex_path
;
1306 if (strncmp(path
, rootpath
, strlen(rootpath
))) {
1307 printk("nfsd: fs_locations failed;"
1308 "%s is not contained in %s\n", path
, rootpath
);
1309 *stat
= nfserr_notsupp
;
1313 return path
+ strlen(rootpath
);
1317 * encode a fs_locations structure
1319 static __be32
nfsd4_encode_fs_locations(struct svc_rqst
*rqstp
,
1320 struct svc_export
*exp
,
1321 __be32
**pp
, int *buflen
)
1326 struct nfsd4_fs_locations
*fslocs
= &exp
->ex_fslocs
;
1327 char *root
= nfsd4_path(rqstp
, exp
, &status
);
1331 status
= nfsd4_encode_components('/', root
, &p
, buflen
);
1334 if ((*buflen
-= 4) < 0)
1335 return nfserr_resource
;
1336 WRITE32(fslocs
->locations_count
);
1337 for (i
=0; i
<fslocs
->locations_count
; i
++) {
1338 status
= nfsd4_encode_fs_location4(&fslocs
->locations
[i
],
1347 static u32 nfs4_ftypes
[16] = {
1348 NF4BAD
, NF4FIFO
, NF4CHR
, NF4BAD
,
1349 NF4DIR
, NF4BAD
, NF4BLK
, NF4BAD
,
1350 NF4REG
, NF4BAD
, NF4LNK
, NF4BAD
,
1351 NF4SOCK
, NF4BAD
, NF4LNK
, NF4BAD
,
1355 nfsd4_encode_name(struct svc_rqst
*rqstp
, int whotype
, uid_t id
, int group
,
1356 __be32
**p
, int *buflen
)
1360 if (*buflen
< (XDR_QUADLEN(IDMAP_NAMESZ
) << 2) + 4)
1361 return nfserr_resource
;
1362 if (whotype
!= NFS4_ACL_WHO_NAMED
)
1363 status
= nfs4_acl_write_who(whotype
, (u8
*)(*p
+ 1));
1365 status
= nfsd_map_gid_to_name(rqstp
, id
, (u8
*)(*p
+ 1));
1367 status
= nfsd_map_uid_to_name(rqstp
, id
, (u8
*)(*p
+ 1));
1369 return nfserrno(status
);
1370 *p
= xdr_encode_opaque(*p
, NULL
, status
);
1371 *buflen
-= (XDR_QUADLEN(status
) << 2) + 4;
1372 BUG_ON(*buflen
< 0);
1376 static inline __be32
1377 nfsd4_encode_user(struct svc_rqst
*rqstp
, uid_t uid
, __be32
**p
, int *buflen
)
1379 return nfsd4_encode_name(rqstp
, NFS4_ACL_WHO_NAMED
, uid
, 0, p
, buflen
);
1382 static inline __be32
1383 nfsd4_encode_group(struct svc_rqst
*rqstp
, uid_t gid
, __be32
**p
, int *buflen
)
1385 return nfsd4_encode_name(rqstp
, NFS4_ACL_WHO_NAMED
, gid
, 1, p
, buflen
);
1388 static inline __be32
1389 nfsd4_encode_aclname(struct svc_rqst
*rqstp
, int whotype
, uid_t id
, int group
,
1390 __be32
**p
, int *buflen
)
1392 return nfsd4_encode_name(rqstp
, whotype
, id
, group
, p
, buflen
);
1395 #define WORD0_ABSENT_FS_ATTRS (FATTR4_WORD0_FS_LOCATIONS | FATTR4_WORD0_FSID | \
1396 FATTR4_WORD0_RDATTR_ERROR)
1397 #define WORD1_ABSENT_FS_ATTRS FATTR4_WORD1_MOUNTED_ON_FILEID
1399 static __be32
fattr_handle_absent_fs(u32
*bmval0
, u32
*bmval1
, u32
*rdattr_err
)
1401 /* As per referral draft: */
1402 if (*bmval0
& ~WORD0_ABSENT_FS_ATTRS
||
1403 *bmval1
& ~WORD1_ABSENT_FS_ATTRS
) {
1404 if (*bmval0
& FATTR4_WORD0_RDATTR_ERROR
||
1405 *bmval0
& FATTR4_WORD0_FS_LOCATIONS
)
1406 *rdattr_err
= NFSERR_MOVED
;
1408 return nfserr_moved
;
1410 *bmval0
&= WORD0_ABSENT_FS_ATTRS
;
1411 *bmval1
&= WORD1_ABSENT_FS_ATTRS
;
1416 * Note: @fhp can be NULL; in this case, we might have to compose the filehandle
1419 * @countp is the buffer size in _words_; upon successful return this becomes
1420 * replaced with the number of words written.
1423 nfsd4_encode_fattr(struct svc_fh
*fhp
, struct svc_export
*exp
,
1424 struct dentry
*dentry
, __be32
*buffer
, int *countp
, u32
*bmval
,
1425 struct svc_rqst
*rqstp
)
1427 u32 bmval0
= bmval
[0];
1428 u32 bmval1
= bmval
[1];
1430 struct svc_fh tempfh
;
1431 struct kstatfs statfs
;
1432 int buflen
= *countp
<< 2;
1441 struct nfs4_acl
*acl
= NULL
;
1443 BUG_ON(bmval1
& NFSD_WRITEONLY_ATTRS_WORD1
);
1444 BUG_ON(bmval0
& ~NFSD_SUPPORTED_ATTRS_WORD0
);
1445 BUG_ON(bmval1
& ~NFSD_SUPPORTED_ATTRS_WORD1
);
1447 if (exp
->ex_fslocs
.migrated
) {
1448 status
= fattr_handle_absent_fs(&bmval0
, &bmval1
, &rdattr_err
);
1453 err
= vfs_getattr(exp
->ex_mnt
, dentry
, &stat
);
1456 if ((bmval0
& (FATTR4_WORD0_FILES_FREE
| FATTR4_WORD0_FILES_TOTAL
)) ||
1457 (bmval1
& (FATTR4_WORD1_SPACE_AVAIL
| FATTR4_WORD1_SPACE_FREE
|
1458 FATTR4_WORD1_SPACE_TOTAL
))) {
1459 err
= vfs_statfs(dentry
, &statfs
);
1463 if ((bmval0
& (FATTR4_WORD0_FILEHANDLE
| FATTR4_WORD0_FSID
)) && !fhp
) {
1464 fh_init(&tempfh
, NFS4_FHSIZE
);
1465 status
= fh_compose(&tempfh
, exp
, dentry
, NULL
);
1470 if (bmval0
& (FATTR4_WORD0_ACL
| FATTR4_WORD0_ACLSUPPORT
1471 | FATTR4_WORD0_SUPPORTED_ATTRS
)) {
1472 err
= nfsd4_get_nfs4_acl(rqstp
, dentry
, &acl
);
1473 aclsupport
= (err
== 0);
1474 if (bmval0
& FATTR4_WORD0_ACL
) {
1475 if (err
== -EOPNOTSUPP
)
1476 bmval0
&= ~FATTR4_WORD0_ACL
;
1477 else if (err
== -EINVAL
) {
1478 status
= nfserr_attrnotsupp
;
1480 } else if (err
!= 0)
1484 if (bmval0
& FATTR4_WORD0_FS_LOCATIONS
) {
1485 if (exp
->ex_fslocs
.locations
== NULL
) {
1486 bmval0
&= ~FATTR4_WORD0_FS_LOCATIONS
;
1489 if ((buflen
-= 16) < 0)
1495 attrlenp
= p
++; /* to be backfilled later */
1497 if (bmval0
& FATTR4_WORD0_SUPPORTED_ATTRS
) {
1498 u32 word0
= NFSD_SUPPORTED_ATTRS_WORD0
;
1499 if ((buflen
-= 12) < 0)
1502 word0
&= ~FATTR4_WORD0_ACL
;
1503 if (!exp
->ex_fslocs
.locations
)
1504 word0
&= ~FATTR4_WORD0_FS_LOCATIONS
;
1507 WRITE32(NFSD_SUPPORTED_ATTRS_WORD1
);
1509 if (bmval0
& FATTR4_WORD0_TYPE
) {
1510 if ((buflen
-= 4) < 0)
1512 dummy
= nfs4_ftypes
[(stat
.mode
& S_IFMT
) >> 12];
1513 if (dummy
== NF4BAD
)
1514 goto out_serverfault
;
1517 if (bmval0
& FATTR4_WORD0_FH_EXPIRE_TYPE
) {
1518 if ((buflen
-= 4) < 0)
1520 if (exp
->ex_flags
& NFSEXP_NOSUBTREECHECK
)
1521 WRITE32(NFS4_FH_PERSISTENT
);
1523 WRITE32(NFS4_FH_PERSISTENT
|NFS4_FH_VOL_RENAME
);
1525 if (bmval0
& FATTR4_WORD0_CHANGE
) {
1527 * Note: This _must_ be consistent with the scheme for writing
1528 * change_info, so any changes made here must be reflected there
1529 * as well. (See xdr4.h:set_change_info() and the WRITECINFO()
1532 if ((buflen
-= 8) < 0)
1534 WRITE32(stat
.ctime
.tv_sec
);
1535 WRITE32(stat
.ctime
.tv_nsec
);
1537 if (bmval0
& FATTR4_WORD0_SIZE
) {
1538 if ((buflen
-= 8) < 0)
1542 if (bmval0
& FATTR4_WORD0_LINK_SUPPORT
) {
1543 if ((buflen
-= 4) < 0)
1547 if (bmval0
& FATTR4_WORD0_SYMLINK_SUPPORT
) {
1548 if ((buflen
-= 4) < 0)
1552 if (bmval0
& FATTR4_WORD0_NAMED_ATTR
) {
1553 if ((buflen
-= 4) < 0)
1557 if (bmval0
& FATTR4_WORD0_FSID
) {
1558 if ((buflen
-= 16) < 0)
1560 if (exp
->ex_fslocs
.migrated
) {
1561 WRITE64(NFS4_REFERRAL_FSID_MAJOR
);
1562 WRITE64(NFS4_REFERRAL_FSID_MINOR
);
1563 } else switch(fsid_source(fhp
)) {
1564 case FSIDSOURCE_FSID
:
1565 WRITE64((u64
)exp
->ex_fsid
);
1568 case FSIDSOURCE_DEV
:
1570 WRITE32(MAJOR(stat
.dev
));
1572 WRITE32(MINOR(stat
.dev
));
1574 case FSIDSOURCE_UUID
:
1575 WRITEMEM(exp
->ex_uuid
, 16);
1579 if (bmval0
& FATTR4_WORD0_UNIQUE_HANDLES
) {
1580 if ((buflen
-= 4) < 0)
1584 if (bmval0
& FATTR4_WORD0_LEASE_TIME
) {
1585 if ((buflen
-= 4) < 0)
1587 WRITE32(NFSD_LEASE_TIME
);
1589 if (bmval0
& FATTR4_WORD0_RDATTR_ERROR
) {
1590 if ((buflen
-= 4) < 0)
1592 WRITE32(rdattr_err
);
1594 if (bmval0
& FATTR4_WORD0_ACL
) {
1595 struct nfs4_ace
*ace
;
1598 if ((buflen
-= 4) < 0)
1604 if ((buflen
-= 4) < 0)
1606 WRITE32(acl
->naces
);
1608 for (ace
= acl
->aces
; ace
< acl
->aces
+ acl
->naces
; ace
++) {
1609 if ((buflen
-= 4*3) < 0)
1613 WRITE32(ace
->access_mask
& NFS4_ACE_MASK_ALL
);
1614 status
= nfsd4_encode_aclname(rqstp
, ace
->whotype
,
1615 ace
->who
, ace
->flag
& NFS4_ACE_IDENTIFIER_GROUP
,
1617 if (status
== nfserr_resource
)
1624 if (bmval0
& FATTR4_WORD0_ACLSUPPORT
) {
1625 if ((buflen
-= 4) < 0)
1627 WRITE32(aclsupport
?
1628 ACL4_SUPPORT_ALLOW_ACL
|ACL4_SUPPORT_DENY_ACL
: 0);
1630 if (bmval0
& FATTR4_WORD0_CANSETTIME
) {
1631 if ((buflen
-= 4) < 0)
1635 if (bmval0
& FATTR4_WORD0_CASE_INSENSITIVE
) {
1636 if ((buflen
-= 4) < 0)
1640 if (bmval0
& FATTR4_WORD0_CASE_PRESERVING
) {
1641 if ((buflen
-= 4) < 0)
1645 if (bmval0
& FATTR4_WORD0_CHOWN_RESTRICTED
) {
1646 if ((buflen
-= 4) < 0)
1650 if (bmval0
& FATTR4_WORD0_FILEHANDLE
) {
1651 buflen
-= (XDR_QUADLEN(fhp
->fh_handle
.fh_size
) << 2) + 4;
1654 WRITE32(fhp
->fh_handle
.fh_size
);
1655 WRITEMEM(&fhp
->fh_handle
.fh_base
, fhp
->fh_handle
.fh_size
);
1657 if (bmval0
& FATTR4_WORD0_FILEID
) {
1658 if ((buflen
-= 8) < 0)
1660 WRITE64((u64
) stat
.ino
);
1662 if (bmval0
& FATTR4_WORD0_FILES_AVAIL
) {
1663 if ((buflen
-= 8) < 0)
1665 WRITE64((u64
) statfs
.f_ffree
);
1667 if (bmval0
& FATTR4_WORD0_FILES_FREE
) {
1668 if ((buflen
-= 8) < 0)
1670 WRITE64((u64
) statfs
.f_ffree
);
1672 if (bmval0
& FATTR4_WORD0_FILES_TOTAL
) {
1673 if ((buflen
-= 8) < 0)
1675 WRITE64((u64
) statfs
.f_files
);
1677 if (bmval0
& FATTR4_WORD0_FS_LOCATIONS
) {
1678 status
= nfsd4_encode_fs_locations(rqstp
, exp
, &p
, &buflen
);
1679 if (status
== nfserr_resource
)
1684 if (bmval0
& FATTR4_WORD0_HOMOGENEOUS
) {
1685 if ((buflen
-= 4) < 0)
1689 if (bmval0
& FATTR4_WORD0_MAXFILESIZE
) {
1690 if ((buflen
-= 8) < 0)
1694 if (bmval0
& FATTR4_WORD0_MAXLINK
) {
1695 if ((buflen
-= 4) < 0)
1699 if (bmval0
& FATTR4_WORD0_MAXNAME
) {
1700 if ((buflen
-= 4) < 0)
1704 if (bmval0
& FATTR4_WORD0_MAXREAD
) {
1705 if ((buflen
-= 8) < 0)
1707 WRITE64((u64
) svc_max_payload(rqstp
));
1709 if (bmval0
& FATTR4_WORD0_MAXWRITE
) {
1710 if ((buflen
-= 8) < 0)
1712 WRITE64((u64
) svc_max_payload(rqstp
));
1714 if (bmval1
& FATTR4_WORD1_MODE
) {
1715 if ((buflen
-= 4) < 0)
1717 WRITE32(stat
.mode
& S_IALLUGO
);
1719 if (bmval1
& FATTR4_WORD1_NO_TRUNC
) {
1720 if ((buflen
-= 4) < 0)
1724 if (bmval1
& FATTR4_WORD1_NUMLINKS
) {
1725 if ((buflen
-= 4) < 0)
1727 WRITE32(stat
.nlink
);
1729 if (bmval1
& FATTR4_WORD1_OWNER
) {
1730 status
= nfsd4_encode_user(rqstp
, stat
.uid
, &p
, &buflen
);
1731 if (status
== nfserr_resource
)
1736 if (bmval1
& FATTR4_WORD1_OWNER_GROUP
) {
1737 status
= nfsd4_encode_group(rqstp
, stat
.gid
, &p
, &buflen
);
1738 if (status
== nfserr_resource
)
1743 if (bmval1
& FATTR4_WORD1_RAWDEV
) {
1744 if ((buflen
-= 8) < 0)
1746 WRITE32((u32
) MAJOR(stat
.rdev
));
1747 WRITE32((u32
) MINOR(stat
.rdev
));
1749 if (bmval1
& FATTR4_WORD1_SPACE_AVAIL
) {
1750 if ((buflen
-= 8) < 0)
1752 dummy64
= (u64
)statfs
.f_bavail
* (u64
)statfs
.f_bsize
;
1755 if (bmval1
& FATTR4_WORD1_SPACE_FREE
) {
1756 if ((buflen
-= 8) < 0)
1758 dummy64
= (u64
)statfs
.f_bfree
* (u64
)statfs
.f_bsize
;
1761 if (bmval1
& FATTR4_WORD1_SPACE_TOTAL
) {
1762 if ((buflen
-= 8) < 0)
1764 dummy64
= (u64
)statfs
.f_blocks
* (u64
)statfs
.f_bsize
;
1767 if (bmval1
& FATTR4_WORD1_SPACE_USED
) {
1768 if ((buflen
-= 8) < 0)
1770 dummy64
= (u64
)stat
.blocks
<< 9;
1773 if (bmval1
& FATTR4_WORD1_TIME_ACCESS
) {
1774 if ((buflen
-= 12) < 0)
1777 WRITE32(stat
.atime
.tv_sec
);
1778 WRITE32(stat
.atime
.tv_nsec
);
1780 if (bmval1
& FATTR4_WORD1_TIME_DELTA
) {
1781 if ((buflen
-= 12) < 0)
1787 if (bmval1
& FATTR4_WORD1_TIME_METADATA
) {
1788 if ((buflen
-= 12) < 0)
1791 WRITE32(stat
.ctime
.tv_sec
);
1792 WRITE32(stat
.ctime
.tv_nsec
);
1794 if (bmval1
& FATTR4_WORD1_TIME_MODIFY
) {
1795 if ((buflen
-= 12) < 0)
1798 WRITE32(stat
.mtime
.tv_sec
);
1799 WRITE32(stat
.mtime
.tv_nsec
);
1801 if (bmval1
& FATTR4_WORD1_MOUNTED_ON_FILEID
) {
1802 struct dentry
*mnt_pnt
, *mnt_root
;
1804 if ((buflen
-= 8) < 0)
1806 mnt_root
= exp
->ex_mnt
->mnt_root
;
1807 if (mnt_root
->d_inode
== dentry
->d_inode
) {
1808 mnt_pnt
= exp
->ex_mnt
->mnt_mountpoint
;
1809 WRITE64((u64
) mnt_pnt
->d_inode
->i_ino
);
1811 WRITE64((u64
) stat
.ino
);
1813 *attrlenp
= htonl((char *)p
- (char *)attrlenp
- 4);
1814 *countp
= p
- buffer
;
1823 status
= nfserrno(err
);
1827 status
= nfserr_resource
;
1830 status
= nfserr_serverfault
;
1835 nfsd4_encode_dirent_fattr(struct nfsd4_readdir
*cd
,
1836 const char *name
, int namlen
, __be32
*p
, int *buflen
)
1838 struct svc_export
*exp
= cd
->rd_fhp
->fh_export
;
1839 struct dentry
*dentry
;
1842 dentry
= lookup_one_len(name
, cd
->rd_fhp
->fh_dentry
, namlen
);
1844 return nfserrno(PTR_ERR(dentry
));
1847 if (d_mountpoint(dentry
)) {
1850 err
= nfsd_cross_mnt(cd
->rd_rqstp
, &dentry
, &exp
);
1852 nfserr
= nfserrno(err
);
1857 nfserr
= nfsd4_encode_fattr(NULL
, exp
, dentry
, p
, buflen
, cd
->rd_bmval
,
1866 nfsd4_encode_rdattr_error(__be32
*p
, int buflen
, __be32 nfserr
)
1873 *p
++ = htonl(FATTR4_WORD0_RDATTR_ERROR
); /* bmval0 */
1874 *p
++ = htonl(0); /* bmval1 */
1877 *p
++ = nfserr
; /* no htonl */
1878 *attrlenp
= htonl((char *)p
- (char *)attrlenp
- 4);
1883 nfsd4_encode_dirent(void *ccdv
, const char *name
, int namlen
,
1884 loff_t offset
, u64 ino
, unsigned int d_type
)
1886 struct readdir_cd
*ccd
= ccdv
;
1887 struct nfsd4_readdir
*cd
= container_of(ccd
, struct nfsd4_readdir
, common
);
1889 __be32
*p
= cd
->buffer
;
1890 __be32 nfserr
= nfserr_toosmall
;
1892 /* In nfsv4, "." and ".." never make it onto the wire.. */
1893 if (name
&& isdotent(name
, namlen
)) {
1894 cd
->common
.err
= nfs_ok
;
1899 xdr_encode_hyper(cd
->offset
, (u64
) offset
);
1901 buflen
= cd
->buflen
- 4 - XDR_QUADLEN(namlen
);
1905 *p
++ = xdr_one
; /* mark entry present */
1906 cd
->offset
= p
; /* remember pointer */
1907 p
= xdr_encode_hyper(p
, NFS_OFFSET_MAX
); /* offset of next entry */
1908 p
= xdr_encode_array(p
, name
, namlen
); /* name length & name */
1910 nfserr
= nfsd4_encode_dirent_fattr(cd
, name
, namlen
, p
, &buflen
);
1915 case nfserr_resource
:
1916 nfserr
= nfserr_toosmall
;
1922 * If the client requested the RDATTR_ERROR attribute,
1923 * we stuff the error code into this attribute
1924 * and continue. If this attribute was not requested,
1925 * then in accordance with the spec, we fail the
1926 * entire READDIR operation(!)
1928 if (!(cd
->rd_bmval
[0] & FATTR4_WORD0_RDATTR_ERROR
))
1930 p
= nfsd4_encode_rdattr_error(p
, buflen
, nfserr
);
1932 nfserr
= nfserr_toosmall
;
1936 cd
->buflen
-= (p
- cd
->buffer
);
1938 cd
->common
.err
= nfs_ok
;
1941 cd
->common
.err
= nfserr
;
1946 nfsd4_encode_access(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_access
*access
)
1952 WRITE32(access
->ac_supported
);
1953 WRITE32(access
->ac_resp_access
);
1959 nfsd4_encode_close(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_close
*close
)
1961 ENCODE_SEQID_OP_HEAD
;
1964 RESERVE_SPACE(sizeof(stateid_t
));
1965 WRITE32(close
->cl_stateid
.si_generation
);
1966 WRITEMEM(&close
->cl_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
1969 ENCODE_SEQID_OP_TAIL(close
->cl_stateowner
);
1974 nfsd4_encode_commit(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_commit
*commit
)
1980 WRITEMEM(commit
->co_verf
.data
, 8);
1986 nfsd4_encode_create(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_create
*create
)
1992 WRITECINFO(create
->cr_cinfo
);
1994 WRITE32(create
->cr_bmval
[0]);
1995 WRITE32(create
->cr_bmval
[1]);
2001 nfsd4_encode_getattr(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_getattr
*getattr
)
2003 struct svc_fh
*fhp
= getattr
->ga_fhp
;
2009 buflen
= resp
->end
- resp
->p
- (COMPOUND_ERR_SLACK_SPACE
>> 2);
2010 nfserr
= nfsd4_encode_fattr(fhp
, fhp
->fh_export
, fhp
->fh_dentry
,
2011 resp
->p
, &buflen
, getattr
->ga_bmval
,
2019 nfsd4_encode_getfh(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct svc_fh
*fhp
)
2025 len
= fhp
->fh_handle
.fh_size
;
2026 RESERVE_SPACE(len
+ 4);
2028 WRITEMEM(&fhp
->fh_handle
.fh_base
, len
);
2034 * Including all fields other than the name, a LOCK4denied structure requires
2035 * 8(clientid) + 4(namelen) + 8(offset) + 8(length) + 4(type) = 32 bytes.
2038 nfsd4_encode_lock_denied(struct nfsd4_compoundres
*resp
, struct nfsd4_lock_denied
*ld
)
2042 RESERVE_SPACE(32 + XDR_LEN(ld
->ld_sop
? ld
->ld_sop
->so_owner
.len
: 0));
2043 WRITE64(ld
->ld_start
);
2044 WRITE64(ld
->ld_length
);
2045 WRITE32(ld
->ld_type
);
2047 WRITEMEM(&ld
->ld_clientid
, 8);
2048 WRITE32(ld
->ld_sop
->so_owner
.len
);
2049 WRITEMEM(ld
->ld_sop
->so_owner
.data
, ld
->ld_sop
->so_owner
.len
);
2050 kref_put(&ld
->ld_sop
->so_ref
, nfs4_free_stateowner
);
2051 } else { /* non - nfsv4 lock in conflict, no clientid nor owner */
2052 WRITE64((u64
)0); /* clientid */
2053 WRITE32(0); /* length of owner name */
2059 nfsd4_encode_lock(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_lock
*lock
)
2061 ENCODE_SEQID_OP_HEAD
;
2064 RESERVE_SPACE(4 + sizeof(stateid_t
));
2065 WRITE32(lock
->lk_resp_stateid
.si_generation
);
2066 WRITEMEM(&lock
->lk_resp_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
2068 } else if (nfserr
== nfserr_denied
)
2069 nfsd4_encode_lock_denied(resp
, &lock
->lk_denied
);
2071 ENCODE_SEQID_OP_TAIL(lock
->lk_replay_owner
);
2075 nfsd4_encode_lockt(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_lockt
*lockt
)
2077 if (nfserr
== nfserr_denied
)
2078 nfsd4_encode_lock_denied(resp
, &lockt
->lt_denied
);
2082 nfsd4_encode_locku(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_locku
*locku
)
2084 ENCODE_SEQID_OP_HEAD
;
2087 RESERVE_SPACE(sizeof(stateid_t
));
2088 WRITE32(locku
->lu_stateid
.si_generation
);
2089 WRITEMEM(&locku
->lu_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
2093 ENCODE_SEQID_OP_TAIL(locku
->lu_stateowner
);
2098 nfsd4_encode_link(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_link
*link
)
2104 WRITECINFO(link
->li_cinfo
);
2111 nfsd4_encode_open(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_open
*open
)
2113 ENCODE_SEQID_OP_HEAD
;
2118 RESERVE_SPACE(36 + sizeof(stateid_t
));
2119 WRITE32(open
->op_stateid
.si_generation
);
2120 WRITEMEM(&open
->op_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
2121 WRITECINFO(open
->op_cinfo
);
2122 WRITE32(open
->op_rflags
);
2124 WRITE32(open
->op_bmval
[0]);
2125 WRITE32(open
->op_bmval
[1]);
2126 WRITE32(open
->op_delegate_type
);
2129 switch (open
->op_delegate_type
) {
2130 case NFS4_OPEN_DELEGATE_NONE
:
2132 case NFS4_OPEN_DELEGATE_READ
:
2133 RESERVE_SPACE(20 + sizeof(stateid_t
));
2134 WRITEMEM(&open
->op_delegate_stateid
, sizeof(stateid_t
));
2135 WRITE32(open
->op_recall
);
2138 * TODO: ACE's in delegations
2140 WRITE32(NFS4_ACE_ACCESS_ALLOWED_ACE_TYPE
);
2143 WRITE32(0); /* XXX: is NULL principal ok? */
2146 case NFS4_OPEN_DELEGATE_WRITE
:
2147 RESERVE_SPACE(32 + sizeof(stateid_t
));
2148 WRITEMEM(&open
->op_delegate_stateid
, sizeof(stateid_t
));
2152 * TODO: space_limit's in delegations
2154 WRITE32(NFS4_LIMIT_SIZE
);
2159 * TODO: ACE's in delegations
2161 WRITE32(NFS4_ACE_ACCESS_ALLOWED_ACE_TYPE
);
2164 WRITE32(0); /* XXX: is NULL principal ok? */
2170 /* XXX save filehandle here */
2172 ENCODE_SEQID_OP_TAIL(open
->op_stateowner
);
2176 nfsd4_encode_open_confirm(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_open_confirm
*oc
)
2178 ENCODE_SEQID_OP_HEAD
;
2181 RESERVE_SPACE(sizeof(stateid_t
));
2182 WRITE32(oc
->oc_resp_stateid
.si_generation
);
2183 WRITEMEM(&oc
->oc_resp_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
2187 ENCODE_SEQID_OP_TAIL(oc
->oc_stateowner
);
2191 nfsd4_encode_open_downgrade(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_open_downgrade
*od
)
2193 ENCODE_SEQID_OP_HEAD
;
2196 RESERVE_SPACE(sizeof(stateid_t
));
2197 WRITE32(od
->od_stateid
.si_generation
);
2198 WRITEMEM(&od
->od_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
2202 ENCODE_SEQID_OP_TAIL(od
->od_stateowner
);
2206 nfsd4_encode_read(struct nfsd4_compoundres
*resp
, __be32 nfserr
,
2207 struct nfsd4_read
*read
)
2211 unsigned long maxcount
;
2217 if (resp
->xbuf
->page_len
)
2218 return nfserr_resource
;
2220 RESERVE_SPACE(8); /* eof flag and byte count */
2222 maxcount
= svc_max_payload(resp
->rqstp
);
2223 if (maxcount
> read
->rd_length
)
2224 maxcount
= read
->rd_length
;
2229 pn
= resp
->rqstp
->rq_resused
++;
2230 resp
->rqstp
->rq_vec
[v
].iov_base
=
2231 page_address(resp
->rqstp
->rq_respages
[pn
]);
2232 resp
->rqstp
->rq_vec
[v
].iov_len
=
2233 len
< PAGE_SIZE
? len
: PAGE_SIZE
;
2239 nfserr
= nfsd_read(read
->rd_rqstp
, read
->rd_fhp
, read
->rd_filp
,
2240 read
->rd_offset
, resp
->rqstp
->rq_vec
, read
->rd_vlen
,
2243 if (nfserr
== nfserr_symlink
)
2244 nfserr
= nfserr_inval
;
2247 eof
= (read
->rd_offset
+ maxcount
>=
2248 read
->rd_fhp
->fh_dentry
->d_inode
->i_size
);
2253 resp
->xbuf
->head
[0].iov_len
= (char*)p
2254 - (char*)resp
->xbuf
->head
[0].iov_base
;
2255 resp
->xbuf
->page_len
= maxcount
;
2257 /* Use rest of head for padding and remaining ops: */
2258 resp
->xbuf
->tail
[0].iov_base
= p
;
2259 resp
->xbuf
->tail
[0].iov_len
= 0;
2263 resp
->xbuf
->tail
[0].iov_base
+= maxcount
&3;
2264 resp
->xbuf
->tail
[0].iov_len
= 4 - (maxcount
&3);
2271 nfsd4_encode_readlink(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_readlink
*readlink
)
2279 if (resp
->xbuf
->page_len
)
2280 return nfserr_resource
;
2282 page
= page_address(resp
->rqstp
->rq_respages
[resp
->rqstp
->rq_resused
++]);
2284 maxcount
= PAGE_SIZE
;
2288 * XXX: By default, the ->readlink() VFS op will truncate symlinks
2289 * if they would overflow the buffer. Is this kosher in NFSv4? If
2290 * not, one easy fix is: if ->readlink() precisely fills the buffer,
2291 * assume that truncation occurred, and return NFS4ERR_RESOURCE.
2293 nfserr
= nfsd_readlink(readlink
->rl_rqstp
, readlink
->rl_fhp
, page
, &maxcount
);
2294 if (nfserr
== nfserr_isdir
)
2295 return nfserr_inval
;
2301 resp
->xbuf
->head
[0].iov_len
= (char*)p
2302 - (char*)resp
->xbuf
->head
[0].iov_base
;
2303 resp
->xbuf
->page_len
= maxcount
;
2305 /* Use rest of head for padding and remaining ops: */
2306 resp
->xbuf
->tail
[0].iov_base
= p
;
2307 resp
->xbuf
->tail
[0].iov_len
= 0;
2311 resp
->xbuf
->tail
[0].iov_base
+= maxcount
&3;
2312 resp
->xbuf
->tail
[0].iov_len
= 4 - (maxcount
&3);
2319 nfsd4_encode_readdir(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_readdir
*readdir
)
2323 __be32
*page
, *savep
, *tailbase
;
2328 if (resp
->xbuf
->page_len
)
2329 return nfserr_resource
;
2331 RESERVE_SPACE(8); /* verifier */
2334 /* XXX: Following NFSv3, we ignore the READDIR verifier for now. */
2338 resp
->xbuf
->head
[0].iov_len
= ((char*)resp
->p
) - (char*)resp
->xbuf
->head
[0].iov_base
;
2341 maxcount
= PAGE_SIZE
;
2342 if (maxcount
> readdir
->rd_maxcount
)
2343 maxcount
= readdir
->rd_maxcount
;
2346 * Convert from bytes to words, account for the two words already
2347 * written, make sure to leave two words at the end for the next
2348 * pointer and eof field.
2350 maxcount
= (maxcount
>> 2) - 4;
2352 nfserr
= nfserr_toosmall
;
2356 page
= page_address(resp
->rqstp
->rq_respages
[resp
->rqstp
->rq_resused
++]);
2357 readdir
->common
.err
= 0;
2358 readdir
->buflen
= maxcount
;
2359 readdir
->buffer
= page
;
2360 readdir
->offset
= NULL
;
2362 offset
= readdir
->rd_cookie
;
2363 nfserr
= nfsd_readdir(readdir
->rd_rqstp
, readdir
->rd_fhp
,
2365 &readdir
->common
, nfsd4_encode_dirent
);
2366 if (nfserr
== nfs_ok
&&
2367 readdir
->common
.err
== nfserr_toosmall
&&
2368 readdir
->buffer
== page
)
2369 nfserr
= nfserr_toosmall
;
2370 if (nfserr
== nfserr_symlink
)
2371 nfserr
= nfserr_notdir
;
2375 if (readdir
->offset
)
2376 xdr_encode_hyper(readdir
->offset
, offset
);
2378 p
= readdir
->buffer
;
2379 *p
++ = 0; /* no more entries */
2380 *p
++ = htonl(readdir
->common
.err
== nfserr_eof
);
2381 resp
->xbuf
->page_len
= ((char*)p
) - (char*)page_address(
2382 resp
->rqstp
->rq_respages
[resp
->rqstp
->rq_resused
-1]);
2384 /* Use rest of head for padding and remaining ops: */
2385 resp
->xbuf
->tail
[0].iov_base
= tailbase
;
2386 resp
->xbuf
->tail
[0].iov_len
= 0;
2387 resp
->p
= resp
->xbuf
->tail
[0].iov_base
;
2388 resp
->end
= resp
->p
+ (PAGE_SIZE
- resp
->xbuf
->head
[0].iov_len
)/4;
2398 nfsd4_encode_remove(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_remove
*remove
)
2404 WRITECINFO(remove
->rm_cinfo
);
2410 nfsd4_encode_rename(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_rename
*rename
)
2416 WRITECINFO(rename
->rn_sinfo
);
2417 WRITECINFO(rename
->rn_tinfo
);
2423 * The SETATTR encode routine is special -- it always encodes a bitmap,
2424 * regardless of the error status.
2427 nfsd4_encode_setattr(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_setattr
*setattr
)
2439 WRITE32(setattr
->sa_bmval
[0]);
2440 WRITE32(setattr
->sa_bmval
[1]);
2446 nfsd4_encode_setclientid(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_setclientid
*scd
)
2451 RESERVE_SPACE(8 + sizeof(nfs4_verifier
));
2452 WRITEMEM(&scd
->se_clientid
, 8);
2453 WRITEMEM(&scd
->se_confirm
, sizeof(nfs4_verifier
));
2456 else if (nfserr
== nfserr_clid_inuse
) {
2465 nfsd4_encode_write(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_write
*write
)
2471 WRITE32(write
->wr_bytes_written
);
2472 WRITE32(write
->wr_how_written
);
2473 WRITEMEM(write
->wr_verifier
.data
, 8);
2479 nfsd4_encode_operation(struct nfsd4_compoundres
*resp
, struct nfsd4_op
*op
)
2486 statp
= p
++; /* to be backfilled at the end */
2489 switch (op
->opnum
) {
2491 nfsd4_encode_access(resp
, op
->status
, &op
->u
.access
);
2494 nfsd4_encode_close(resp
, op
->status
, &op
->u
.close
);
2497 nfsd4_encode_commit(resp
, op
->status
, &op
->u
.commit
);
2500 nfsd4_encode_create(resp
, op
->status
, &op
->u
.create
);
2502 case OP_DELEGRETURN
:
2505 op
->status
= nfsd4_encode_getattr(resp
, op
->status
, &op
->u
.getattr
);
2508 nfsd4_encode_getfh(resp
, op
->status
, op
->u
.getfh
);
2511 nfsd4_encode_link(resp
, op
->status
, &op
->u
.link
);
2514 nfsd4_encode_lock(resp
, op
->status
, &op
->u
.lock
);
2517 nfsd4_encode_lockt(resp
, op
->status
, &op
->u
.lockt
);
2520 nfsd4_encode_locku(resp
, op
->status
, &op
->u
.locku
);
2529 nfsd4_encode_open(resp
, op
->status
, &op
->u
.open
);
2531 case OP_OPEN_CONFIRM
:
2532 nfsd4_encode_open_confirm(resp
, op
->status
, &op
->u
.open_confirm
);
2534 case OP_OPEN_DOWNGRADE
:
2535 nfsd4_encode_open_downgrade(resp
, op
->status
, &op
->u
.open_downgrade
);
2542 op
->status
= nfsd4_encode_read(resp
, op
->status
, &op
->u
.read
);
2545 op
->status
= nfsd4_encode_readdir(resp
, op
->status
, &op
->u
.readdir
);
2548 op
->status
= nfsd4_encode_readlink(resp
, op
->status
, &op
->u
.readlink
);
2551 nfsd4_encode_remove(resp
, op
->status
, &op
->u
.remove
);
2554 nfsd4_encode_rename(resp
, op
->status
, &op
->u
.rename
);
2563 nfsd4_encode_setattr(resp
, op
->status
, &op
->u
.setattr
);
2565 case OP_SETCLIENTID
:
2566 nfsd4_encode_setclientid(resp
, op
->status
, &op
->u
.setclientid
);
2568 case OP_SETCLIENTID_CONFIRM
:
2573 nfsd4_encode_write(resp
, op
->status
, &op
->u
.write
);
2575 case OP_RELEASE_LOCKOWNER
:
2582 * Note: We write the status directly, instead of using WRITE32(),
2583 * since it is already in network byte order.
2585 *statp
= op
->status
;
2589 * Encode the reply stored in the stateowner reply cache
2591 * XDR note: do not encode rp->rp_buflen: the buffer contains the
2592 * previously sent already encoded operation.
2594 * called with nfs4_lock_state() held
2597 nfsd4_encode_replay(struct nfsd4_compoundres
*resp
, struct nfsd4_op
*op
)
2600 struct nfs4_replay
*rp
= op
->replay
;
2606 *p
++ = rp
->rp_status
; /* already xdr'ed */
2609 RESERVE_SPACE(rp
->rp_buflen
);
2610 WRITEMEM(rp
->rp_buf
, rp
->rp_buflen
);
2615 * END OF "GENERIC" ENCODE ROUTINES.
2619 nfs4svc_encode_voidres(struct svc_rqst
*rqstp
, __be32
*p
, void *dummy
)
2621 return xdr_ressize_check(rqstp
, p
);
2624 void nfsd4_release_compoundargs(struct nfsd4_compoundargs
*args
)
2626 if (args
->ops
!= args
->iops
) {
2628 args
->ops
= args
->iops
;
2632 while (args
->to_free
) {
2633 struct tmpbuf
*tb
= args
->to_free
;
2634 args
->to_free
= tb
->next
;
2635 tb
->release(tb
->buf
);
2641 nfs4svc_decode_compoundargs(struct svc_rqst
*rqstp
, __be32
*p
, struct nfsd4_compoundargs
*args
)
2646 args
->end
= rqstp
->rq_arg
.head
[0].iov_base
+ rqstp
->rq_arg
.head
[0].iov_len
;
2647 args
->pagelist
= rqstp
->rq_arg
.pages
;
2648 args
->pagelen
= rqstp
->rq_arg
.page_len
;
2650 args
->to_free
= NULL
;
2651 args
->ops
= args
->iops
;
2652 args
->rqstp
= rqstp
;
2654 status
= nfsd4_decode_compound(args
);
2656 nfsd4_release_compoundargs(args
);
2662 nfs4svc_encode_compoundres(struct svc_rqst
*rqstp
, __be32
*p
, struct nfsd4_compoundres
*resp
)
2665 * All that remains is to write the tag and operation count...
2669 *p
++ = htonl(resp
->taglen
);
2670 memcpy(p
, resp
->tag
, resp
->taglen
);
2671 p
+= XDR_QUADLEN(resp
->taglen
);
2672 *p
++ = htonl(resp
->opcnt
);
2674 if (rqstp
->rq_res
.page_len
)
2675 iov
= &rqstp
->rq_res
.tail
[0];
2677 iov
= &rqstp
->rq_res
.head
[0];
2678 iov
->iov_len
= ((char*)resp
->p
) - (char*)iov
->iov_base
;
2679 BUG_ON(iov
->iov_len
> PAGE_SIZE
);