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>
47 #include <linux/smp_lock.h>
49 #include <linux/namei.h>
50 #include <linux/vfs.h>
51 #include <linux/sunrpc/xdr.h>
52 #include <linux/sunrpc/svc.h>
53 #include <linux/sunrpc/clnt.h>
54 #include <linux/nfsd/nfsd.h>
55 #include <linux/nfsd/state.h>
56 #include <linux/nfsd/xdr4.h>
57 #include <linux/nfsd_idmap.h>
58 #include <linux/nfs4.h>
59 #include <linux/nfs4_acl.h>
61 #define NFSDDBG_FACILITY NFSDDBG_XDR
64 * As per referral draft, the fsid for a referral MUST be different from the fsid of the containing
65 * directory in order to indicate to the client that a filesystem boundary is present
66 * We use a fixed fsid for a referral
68 #define NFS4_REFERRAL_FSID_MAJOR 0x8000000ULL
69 #define NFS4_REFERRAL_FSID_MINOR 0x8000000ULL
72 check_filename(char *str
, int len
, __be32 err
)
78 if (isdotent(str
, len
))
80 for (i
= 0; i
< len
; i
++)
87 * START OF "GENERIC" DECODE ROUTINES.
88 * These may look a little ugly since they are imported from a "generic"
89 * set of XDR encode/decode routines which are intended to be shared by
90 * all of our NFSv4 implementations (OpenBSD, MacOS X...).
92 * If the pain of reading these is too great, it should be a straightforward
93 * task to translate them into Linux-specific versions which are more
94 * consistent with the style used in NFSv2/v3...
104 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); \
105 status = nfserr_bad_xdr; \
108 #define READ32(x) (x) = ntohl(*p++)
109 #define READ64(x) do { \
110 (x) = (u64)ntohl(*p++) << 32; \
111 (x) |= ntohl(*p++); \
113 #define READTIME(x) do { \
118 #define READMEM(x,nbytes) do { \
120 p += XDR_QUADLEN(nbytes); \
122 #define SAVEMEM(x,nbytes) do { \
123 if (!(x = (p==argp->tmp || p == argp->tmpp) ? \
124 savemem(argp, p, nbytes) : \
126 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); \
129 p += XDR_QUADLEN(nbytes); \
131 #define COPYMEM(x,nbytes) do { \
132 memcpy((x), p, nbytes); \
133 p += XDR_QUADLEN(nbytes); \
136 /* READ_BUF, read_buf(): nbytes must be <= PAGE_SIZE */
137 #define READ_BUF(nbytes) do { \
138 if (nbytes <= (u32)((char *)argp->end - (char *)argp->p)) { \
140 argp->p += XDR_QUADLEN(nbytes); \
141 } else if (!(p = read_buf(argp, nbytes))) { \
142 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); \
147 static __be32
*read_buf(struct nfsd4_compoundargs
*argp
, int nbytes
)
149 /* We want more bytes than seem to be available.
150 * Maybe we need a new page, maybe we have just run out
152 int avail
= (char*)argp
->end
- (char*)argp
->p
;
154 if (avail
+ argp
->pagelen
< nbytes
)
156 if (avail
+ PAGE_SIZE
< nbytes
) /* need more than a page !! */
158 /* ok, we can do it with the current plus the next page */
159 if (nbytes
<= sizeof(argp
->tmp
))
163 p
= argp
->tmpp
= kmalloc(nbytes
, GFP_KERNEL
);
168 memcpy(p
, argp
->p
, avail
);
169 /* step to next page */
170 argp
->p
= page_address(argp
->pagelist
[0]);
172 if (argp
->pagelen
< PAGE_SIZE
) {
173 argp
->end
= p
+ (argp
->pagelen
>>2);
176 argp
->end
= p
+ (PAGE_SIZE
>>2);
177 argp
->pagelen
-= PAGE_SIZE
;
179 memcpy(((char*)p
)+avail
, argp
->p
, (nbytes
- avail
));
180 argp
->p
+= XDR_QUADLEN(nbytes
- avail
);
185 defer_free(struct nfsd4_compoundargs
*argp
,
186 void (*release
)(const void *), void *p
)
190 tb
= kmalloc(sizeof(*tb
), GFP_KERNEL
);
194 tb
->release
= release
;
195 tb
->next
= argp
->to_free
;
200 static char *savemem(struct nfsd4_compoundargs
*argp
, __be32
*p
, int nbytes
)
202 if (p
== argp
->tmp
) {
203 p
= kmalloc(nbytes
, GFP_KERNEL
);
206 memcpy(p
, argp
->tmp
, nbytes
);
208 BUG_ON(p
!= argp
->tmpp
);
211 if (defer_free(argp
, kfree
, p
)) {
219 nfsd4_decode_bitmap(struct nfsd4_compoundargs
*argp
, u32
*bmval
)
232 READ_BUF(bmlen
<< 2);
242 nfsd4_decode_fattr(struct nfsd4_compoundargs
*argp
, u32
*bmval
, struct iattr
*iattr
,
243 struct nfs4_acl
**acl
)
245 int expected_len
, len
= 0;
252 if ((status
= nfsd4_decode_bitmap(argp
, bmval
)))
256 * According to spec, unsupported attributes return ERR_ATTRNOTSUPP;
257 * read-only attributes return ERR_INVAL.
259 if ((bmval
[0] & ~NFSD_SUPPORTED_ATTRS_WORD0
) || (bmval
[1] & ~NFSD_SUPPORTED_ATTRS_WORD1
))
260 return nfserr_attrnotsupp
;
261 if ((bmval
[0] & ~NFSD_WRITEABLE_ATTRS_WORD0
) || (bmval
[1] & ~NFSD_WRITEABLE_ATTRS_WORD1
))
265 READ32(expected_len
);
267 if (bmval
[0] & FATTR4_WORD0_SIZE
) {
270 READ64(iattr
->ia_size
);
271 iattr
->ia_valid
|= ATTR_SIZE
;
273 if (bmval
[0] & FATTR4_WORD0_ACL
) {
275 struct nfs4_ace
*ace
;
277 READ_BUF(4); len
+= 4;
280 if (nace
> NFS4_ACL_MAX
)
281 return nfserr_resource
;
283 *acl
= nfs4_acl_new(nace
);
288 defer_free(argp
, kfree
, *acl
);
290 (*acl
)->naces
= nace
;
291 for (ace
= (*acl
)->aces
; ace
< (*acl
)->aces
+ nace
; ace
++) {
292 READ_BUF(16); len
+= 16;
295 READ32(ace
->access_mask
);
298 len
+= XDR_QUADLEN(dummy32
) << 2;
299 READMEM(buf
, dummy32
);
300 ace
->whotype
= nfs4_acl_get_whotype(buf
, dummy32
);
302 if (ace
->whotype
!= NFS4_ACL_WHO_NAMED
)
304 else if (ace
->flag
& NFS4_ACE_IDENTIFIER_GROUP
)
305 host_err
= nfsd_map_name_to_gid(argp
->rqstp
,
306 buf
, dummy32
, &ace
->who
);
308 host_err
= nfsd_map_name_to_uid(argp
->rqstp
,
309 buf
, dummy32
, &ace
->who
);
315 if (bmval
[1] & FATTR4_WORD1_MODE
) {
318 READ32(iattr
->ia_mode
);
319 iattr
->ia_mode
&= (S_IFMT
| S_IALLUGO
);
320 iattr
->ia_valid
|= ATTR_MODE
;
322 if (bmval
[1] & FATTR4_WORD1_OWNER
) {
327 len
+= (XDR_QUADLEN(dummy32
) << 2);
328 READMEM(buf
, dummy32
);
329 if ((host_err
= nfsd_map_name_to_uid(argp
->rqstp
, buf
, dummy32
, &iattr
->ia_uid
)))
331 iattr
->ia_valid
|= ATTR_UID
;
333 if (bmval
[1] & FATTR4_WORD1_OWNER_GROUP
) {
338 len
+= (XDR_QUADLEN(dummy32
) << 2);
339 READMEM(buf
, dummy32
);
340 if ((host_err
= nfsd_map_name_to_gid(argp
->rqstp
, buf
, dummy32
, &iattr
->ia_gid
)))
342 iattr
->ia_valid
|= ATTR_GID
;
344 if (bmval
[1] & FATTR4_WORD1_TIME_ACCESS_SET
) {
349 case NFS4_SET_TO_CLIENT_TIME
:
350 /* We require the high 32 bits of 'seconds' to be 0, and we ignore
351 all 32 bits of 'nseconds'. */
357 READ32(iattr
->ia_atime
.tv_sec
);
358 READ32(iattr
->ia_atime
.tv_nsec
);
359 if (iattr
->ia_atime
.tv_nsec
>= (u32
)1000000000)
361 iattr
->ia_valid
|= (ATTR_ATIME
| ATTR_ATIME_SET
);
363 case NFS4_SET_TO_SERVER_TIME
:
364 iattr
->ia_valid
|= ATTR_ATIME
;
370 if (bmval
[1] & FATTR4_WORD1_TIME_METADATA
) {
371 /* We require the high 32 bits of 'seconds' to be 0, and we ignore
372 all 32 bits of 'nseconds'. */
378 READ32(iattr
->ia_ctime
.tv_sec
);
379 READ32(iattr
->ia_ctime
.tv_nsec
);
380 if (iattr
->ia_ctime
.tv_nsec
>= (u32
)1000000000)
382 iattr
->ia_valid
|= ATTR_CTIME
;
384 if (bmval
[1] & FATTR4_WORD1_TIME_MODIFY_SET
) {
389 case NFS4_SET_TO_CLIENT_TIME
:
390 /* We require the high 32 bits of 'seconds' to be 0, and we ignore
391 all 32 bits of 'nseconds'. */
397 READ32(iattr
->ia_mtime
.tv_sec
);
398 READ32(iattr
->ia_mtime
.tv_nsec
);
399 if (iattr
->ia_mtime
.tv_nsec
>= (u32
)1000000000)
401 iattr
->ia_valid
|= (ATTR_MTIME
| ATTR_MTIME_SET
);
403 case NFS4_SET_TO_SERVER_TIME
:
404 iattr
->ia_valid
|= ATTR_MTIME
;
410 if (len
!= expected_len
)
416 status
= nfserrno(host_err
);
421 nfsd4_decode_access(struct nfsd4_compoundargs
*argp
, struct nfsd4_access
*access
)
426 READ32(access
->ac_req_access
);
432 nfsd4_decode_close(struct nfsd4_compoundargs
*argp
, struct nfsd4_close
*close
)
436 close
->cl_stateowner
= NULL
;
437 READ_BUF(4 + sizeof(stateid_t
));
438 READ32(close
->cl_seqid
);
439 READ32(close
->cl_stateid
.si_generation
);
440 COPYMEM(&close
->cl_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
447 nfsd4_decode_commit(struct nfsd4_compoundargs
*argp
, struct nfsd4_commit
*commit
)
452 READ64(commit
->co_offset
);
453 READ32(commit
->co_count
);
459 nfsd4_decode_create(struct nfsd4_compoundargs
*argp
, struct nfsd4_create
*create
)
464 READ32(create
->cr_type
);
465 switch (create
->cr_type
) {
468 READ32(create
->cr_linklen
);
469 READ_BUF(create
->cr_linklen
);
470 SAVEMEM(create
->cr_linkname
, create
->cr_linklen
);
475 READ32(create
->cr_specdata1
);
476 READ32(create
->cr_specdata2
);
486 READ32(create
->cr_namelen
);
487 READ_BUF(create
->cr_namelen
);
488 SAVEMEM(create
->cr_name
, create
->cr_namelen
);
489 if ((status
= check_filename(create
->cr_name
, create
->cr_namelen
, nfserr_inval
)))
492 if ((status
= nfsd4_decode_fattr(argp
, create
->cr_bmval
, &create
->cr_iattr
, &create
->cr_acl
)))
499 nfsd4_decode_delegreturn(struct nfsd4_compoundargs
*argp
, struct nfsd4_delegreturn
*dr
)
503 READ_BUF(sizeof(stateid_t
));
504 READ32(dr
->dr_stateid
.si_generation
);
505 COPYMEM(&dr
->dr_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
511 nfsd4_decode_getattr(struct nfsd4_compoundargs
*argp
, struct nfsd4_getattr
*getattr
)
513 return nfsd4_decode_bitmap(argp
, getattr
->ga_bmval
);
517 nfsd4_decode_link(struct nfsd4_compoundargs
*argp
, struct nfsd4_link
*link
)
522 READ32(link
->li_namelen
);
523 READ_BUF(link
->li_namelen
);
524 SAVEMEM(link
->li_name
, link
->li_namelen
);
525 if ((status
= check_filename(link
->li_name
, link
->li_namelen
, nfserr_inval
)))
532 nfsd4_decode_lock(struct nfsd4_compoundargs
*argp
, struct nfsd4_lock
*lock
)
536 lock
->lk_replay_owner
= NULL
;
538 * type, reclaim(boolean), offset, length, new_lock_owner(boolean)
541 READ32(lock
->lk_type
);
542 if ((lock
->lk_type
< NFS4_READ_LT
) || (lock
->lk_type
> NFS4_WRITEW_LT
))
544 READ32(lock
->lk_reclaim
);
545 READ64(lock
->lk_offset
);
546 READ64(lock
->lk_length
);
547 READ32(lock
->lk_is_new
);
549 if (lock
->lk_is_new
) {
551 READ32(lock
->lk_new_open_seqid
);
552 READ32(lock
->lk_new_open_stateid
.si_generation
);
554 COPYMEM(&lock
->lk_new_open_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
555 READ32(lock
->lk_new_lock_seqid
);
556 COPYMEM(&lock
->lk_new_clientid
, sizeof(clientid_t
));
557 READ32(lock
->lk_new_owner
.len
);
558 READ_BUF(lock
->lk_new_owner
.len
);
559 READMEM(lock
->lk_new_owner
.data
, lock
->lk_new_owner
.len
);
562 READ32(lock
->lk_old_lock_stateid
.si_generation
);
563 COPYMEM(&lock
->lk_old_lock_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
564 READ32(lock
->lk_old_lock_seqid
);
571 nfsd4_decode_lockt(struct nfsd4_compoundargs
*argp
, struct nfsd4_lockt
*lockt
)
576 READ32(lockt
->lt_type
);
577 if((lockt
->lt_type
< NFS4_READ_LT
) || (lockt
->lt_type
> NFS4_WRITEW_LT
))
579 READ64(lockt
->lt_offset
);
580 READ64(lockt
->lt_length
);
581 COPYMEM(&lockt
->lt_clientid
, 8);
582 READ32(lockt
->lt_owner
.len
);
583 READ_BUF(lockt
->lt_owner
.len
);
584 READMEM(lockt
->lt_owner
.data
, lockt
->lt_owner
.len
);
590 nfsd4_decode_locku(struct nfsd4_compoundargs
*argp
, struct nfsd4_locku
*locku
)
594 locku
->lu_stateowner
= NULL
;
595 READ_BUF(24 + sizeof(stateid_t
));
596 READ32(locku
->lu_type
);
597 if ((locku
->lu_type
< NFS4_READ_LT
) || (locku
->lu_type
> NFS4_WRITEW_LT
))
599 READ32(locku
->lu_seqid
);
600 READ32(locku
->lu_stateid
.si_generation
);
601 COPYMEM(&locku
->lu_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
602 READ64(locku
->lu_offset
);
603 READ64(locku
->lu_length
);
609 nfsd4_decode_lookup(struct nfsd4_compoundargs
*argp
, struct nfsd4_lookup
*lookup
)
614 READ32(lookup
->lo_len
);
615 READ_BUF(lookup
->lo_len
);
616 SAVEMEM(lookup
->lo_name
, lookup
->lo_len
);
617 if ((status
= check_filename(lookup
->lo_name
, lookup
->lo_len
, nfserr_noent
)))
624 nfsd4_decode_open(struct nfsd4_compoundargs
*argp
, struct nfsd4_open
*open
)
628 memset(open
->op_bmval
, 0, sizeof(open
->op_bmval
));
629 open
->op_iattr
.ia_valid
= 0;
630 open
->op_stateowner
= NULL
;
632 /* seqid, share_access, share_deny, clientid, ownerlen */
633 READ_BUF(16 + sizeof(clientid_t
));
634 READ32(open
->op_seqid
);
635 READ32(open
->op_share_access
);
636 READ32(open
->op_share_deny
);
637 COPYMEM(&open
->op_clientid
, sizeof(clientid_t
));
638 READ32(open
->op_owner
.len
);
640 /* owner, open_flag */
641 READ_BUF(open
->op_owner
.len
+ 4);
642 SAVEMEM(open
->op_owner
.data
, open
->op_owner
.len
);
643 READ32(open
->op_create
);
644 switch (open
->op_create
) {
645 case NFS4_OPEN_NOCREATE
:
647 case NFS4_OPEN_CREATE
:
649 READ32(open
->op_createmode
);
650 switch (open
->op_createmode
) {
651 case NFS4_CREATE_UNCHECKED
:
652 case NFS4_CREATE_GUARDED
:
653 if ((status
= nfsd4_decode_fattr(argp
, open
->op_bmval
, &open
->op_iattr
, &open
->op_acl
)))
656 case NFS4_CREATE_EXCLUSIVE
:
658 COPYMEM(open
->op_verf
.data
, 8);
670 READ32(open
->op_claim_type
);
671 switch (open
->op_claim_type
) {
672 case NFS4_OPEN_CLAIM_NULL
:
673 case NFS4_OPEN_CLAIM_DELEGATE_PREV
:
675 READ32(open
->op_fname
.len
);
676 READ_BUF(open
->op_fname
.len
);
677 SAVEMEM(open
->op_fname
.data
, open
->op_fname
.len
);
678 if ((status
= check_filename(open
->op_fname
.data
, open
->op_fname
.len
, nfserr_inval
)))
681 case NFS4_OPEN_CLAIM_PREVIOUS
:
683 READ32(open
->op_delegate_type
);
685 case NFS4_OPEN_CLAIM_DELEGATE_CUR
:
686 READ_BUF(sizeof(stateid_t
) + 4);
687 COPYMEM(&open
->op_delegate_stateid
, sizeof(stateid_t
));
688 READ32(open
->op_fname
.len
);
689 READ_BUF(open
->op_fname
.len
);
690 SAVEMEM(open
->op_fname
.data
, open
->op_fname
.len
);
691 if ((status
= check_filename(open
->op_fname
.data
, open
->op_fname
.len
, nfserr_inval
)))
702 nfsd4_decode_open_confirm(struct nfsd4_compoundargs
*argp
, struct nfsd4_open_confirm
*open_conf
)
706 open_conf
->oc_stateowner
= NULL
;
707 READ_BUF(4 + sizeof(stateid_t
));
708 READ32(open_conf
->oc_req_stateid
.si_generation
);
709 COPYMEM(&open_conf
->oc_req_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
710 READ32(open_conf
->oc_seqid
);
716 nfsd4_decode_open_downgrade(struct nfsd4_compoundargs
*argp
, struct nfsd4_open_downgrade
*open_down
)
720 open_down
->od_stateowner
= NULL
;
721 READ_BUF(12 + sizeof(stateid_t
));
722 READ32(open_down
->od_stateid
.si_generation
);
723 COPYMEM(&open_down
->od_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
724 READ32(open_down
->od_seqid
);
725 READ32(open_down
->od_share_access
);
726 READ32(open_down
->od_share_deny
);
732 nfsd4_decode_putfh(struct nfsd4_compoundargs
*argp
, struct nfsd4_putfh
*putfh
)
737 READ32(putfh
->pf_fhlen
);
738 if (putfh
->pf_fhlen
> NFS4_FHSIZE
)
740 READ_BUF(putfh
->pf_fhlen
);
741 SAVEMEM(putfh
->pf_fhval
, putfh
->pf_fhlen
);
747 nfsd4_decode_read(struct nfsd4_compoundargs
*argp
, struct nfsd4_read
*read
)
751 READ_BUF(sizeof(stateid_t
) + 12);
752 READ32(read
->rd_stateid
.si_generation
);
753 COPYMEM(&read
->rd_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
754 READ64(read
->rd_offset
);
755 READ32(read
->rd_length
);
761 nfsd4_decode_readdir(struct nfsd4_compoundargs
*argp
, struct nfsd4_readdir
*readdir
)
766 READ64(readdir
->rd_cookie
);
767 COPYMEM(readdir
->rd_verf
.data
, sizeof(readdir
->rd_verf
.data
));
768 READ32(readdir
->rd_dircount
); /* just in case you needed a useless field... */
769 READ32(readdir
->rd_maxcount
);
770 if ((status
= nfsd4_decode_bitmap(argp
, readdir
->rd_bmval
)))
777 nfsd4_decode_remove(struct nfsd4_compoundargs
*argp
, struct nfsd4_remove
*remove
)
782 READ32(remove
->rm_namelen
);
783 READ_BUF(remove
->rm_namelen
);
784 SAVEMEM(remove
->rm_name
, remove
->rm_namelen
);
785 if ((status
= check_filename(remove
->rm_name
, remove
->rm_namelen
, nfserr_noent
)))
792 nfsd4_decode_rename(struct nfsd4_compoundargs
*argp
, struct nfsd4_rename
*rename
)
797 READ32(rename
->rn_snamelen
);
798 READ_BUF(rename
->rn_snamelen
+ 4);
799 SAVEMEM(rename
->rn_sname
, rename
->rn_snamelen
);
800 READ32(rename
->rn_tnamelen
);
801 READ_BUF(rename
->rn_tnamelen
);
802 SAVEMEM(rename
->rn_tname
, rename
->rn_tnamelen
);
803 if ((status
= check_filename(rename
->rn_sname
, rename
->rn_snamelen
, nfserr_noent
)))
805 if ((status
= check_filename(rename
->rn_tname
, rename
->rn_tnamelen
, nfserr_inval
)))
812 nfsd4_decode_renew(struct nfsd4_compoundargs
*argp
, clientid_t
*clientid
)
816 READ_BUF(sizeof(clientid_t
));
817 COPYMEM(clientid
, sizeof(clientid_t
));
823 nfsd4_decode_setattr(struct nfsd4_compoundargs
*argp
, struct nfsd4_setattr
*setattr
)
827 READ_BUF(sizeof(stateid_t
));
828 READ32(setattr
->sa_stateid
.si_generation
);
829 COPYMEM(&setattr
->sa_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
830 if ((status
= nfsd4_decode_fattr(argp
, setattr
->sa_bmval
, &setattr
->sa_iattr
, &setattr
->sa_acl
)))
837 nfsd4_decode_setclientid(struct nfsd4_compoundargs
*argp
, struct nfsd4_setclientid
*setclientid
)
842 COPYMEM(setclientid
->se_verf
.data
, 8);
843 READ32(setclientid
->se_namelen
);
845 READ_BUF(setclientid
->se_namelen
+ 8);
846 SAVEMEM(setclientid
->se_name
, setclientid
->se_namelen
);
847 READ32(setclientid
->se_callback_prog
);
848 READ32(setclientid
->se_callback_netid_len
);
850 READ_BUF(setclientid
->se_callback_netid_len
+ 4);
851 SAVEMEM(setclientid
->se_callback_netid_val
, setclientid
->se_callback_netid_len
);
852 READ32(setclientid
->se_callback_addr_len
);
854 READ_BUF(setclientid
->se_callback_addr_len
+ 4);
855 SAVEMEM(setclientid
->se_callback_addr_val
, setclientid
->se_callback_addr_len
);
856 READ32(setclientid
->se_callback_ident
);
862 nfsd4_decode_setclientid_confirm(struct nfsd4_compoundargs
*argp
, struct nfsd4_setclientid_confirm
*scd_c
)
866 READ_BUF(8 + sizeof(nfs4_verifier
));
867 COPYMEM(&scd_c
->sc_clientid
, 8);
868 COPYMEM(&scd_c
->sc_confirm
, sizeof(nfs4_verifier
));
873 /* Also used for NVERIFY */
875 nfsd4_decode_verify(struct nfsd4_compoundargs
*argp
, struct nfsd4_verify
*verify
)
878 struct nfsd4_compoundargs save
= {
881 .rqstp
= argp
->rqstp
,
884 struct iattr ve_iattr
; /* request */
885 struct nfs4_acl
*ve_acl
; /* request */
889 if ((status
= nfsd4_decode_bitmap(argp
, verify
->ve_bmval
)))
892 /* For convenience's sake, we compare raw xdr'd attributes in
893 * nfsd4_proc_verify; however we still decode here just to return
894 * correct error in case of bad xdr. */
896 status
= nfsd4_decode_fattr(ve_bmval
, &ve_iattr
, &ve_acl
);
897 if (status
== nfserr_inval
) {
898 status
= nfserrno(status
);
903 READ32(verify
->ve_attrlen
);
904 READ_BUF(verify
->ve_attrlen
);
905 SAVEMEM(verify
->ve_attrval
, verify
->ve_attrlen
);
911 nfsd4_decode_write(struct nfsd4_compoundargs
*argp
, struct nfsd4_write
*write
)
918 READ_BUF(sizeof(stateid_opaque_t
) + 20);
919 READ32(write
->wr_stateid
.si_generation
);
920 COPYMEM(&write
->wr_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
921 READ64(write
->wr_offset
);
922 READ32(write
->wr_stable_how
);
923 if (write
->wr_stable_how
> 2)
925 READ32(write
->wr_buflen
);
927 /* Sorry .. no magic macros for this.. *
928 * READ_BUF(write->wr_buflen);
929 * SAVEMEM(write->wr_buf, write->wr_buflen);
931 avail
= (char*)argp
->end
- (char*)argp
->p
;
932 if (avail
+ argp
->pagelen
< write
->wr_buflen
) {
933 printk(KERN_NOTICE
"xdr error! (%s:%d)\n", __FILE__
, __LINE__
);
936 argp
->rqstp
->rq_vec
[0].iov_base
= p
;
937 argp
->rqstp
->rq_vec
[0].iov_len
= avail
;
939 len
= write
->wr_buflen
;
940 while (len
> argp
->rqstp
->rq_vec
[v
].iov_len
) {
941 len
-= argp
->rqstp
->rq_vec
[v
].iov_len
;
943 argp
->rqstp
->rq_vec
[v
].iov_base
= page_address(argp
->pagelist
[0]);
945 if (argp
->pagelen
>= PAGE_SIZE
) {
946 argp
->rqstp
->rq_vec
[v
].iov_len
= PAGE_SIZE
;
947 argp
->pagelen
-= PAGE_SIZE
;
949 argp
->rqstp
->rq_vec
[v
].iov_len
= argp
->pagelen
;
950 argp
->pagelen
-= len
;
953 argp
->end
= (__be32
*) (argp
->rqstp
->rq_vec
[v
].iov_base
+ argp
->rqstp
->rq_vec
[v
].iov_len
);
954 argp
->p
= (__be32
*) (argp
->rqstp
->rq_vec
[v
].iov_base
+ (XDR_QUADLEN(len
) << 2));
955 argp
->rqstp
->rq_vec
[v
].iov_len
= len
;
956 write
->wr_vlen
= v
+1;
962 nfsd4_decode_release_lockowner(struct nfsd4_compoundargs
*argp
, struct nfsd4_release_lockowner
*rlockowner
)
967 COPYMEM(&rlockowner
->rl_clientid
, sizeof(clientid_t
));
968 READ32(rlockowner
->rl_owner
.len
);
969 READ_BUF(rlockowner
->rl_owner
.len
);
970 READMEM(rlockowner
->rl_owner
.data
, rlockowner
->rl_owner
.len
);
976 nfsd4_decode_compound(struct nfsd4_compoundargs
*argp
)
983 * XXX: According to spec, we should check the tag
984 * for UTF-8 compliance. I'm postponing this for
985 * now because it seems that some clients do use
989 READ32(argp
->taglen
);
990 READ_BUF(argp
->taglen
+ 8);
991 SAVEMEM(argp
->tag
, argp
->taglen
);
992 READ32(argp
->minorversion
);
995 if (argp
->taglen
> NFSD4_MAX_TAGLEN
)
997 if (argp
->opcnt
> 100)
1000 if (argp
->opcnt
> ARRAY_SIZE(argp
->iops
)) {
1001 argp
->ops
= kmalloc(argp
->opcnt
* sizeof(*argp
->ops
), GFP_KERNEL
);
1003 argp
->ops
= argp
->iops
;
1004 printk(KERN_INFO
"nfsd: couldn't allocate room for COMPOUND\n");
1009 for (i
= 0; i
< argp
->opcnt
; i
++) {
1014 * We can't use READ_BUF() here because we need to handle
1015 * a missing opcode as an OP_WRITE + 1. So we need to check
1016 * to see if we're truly at the end of our buffer or if there
1017 * is another page we need to flip to.
1020 if (argp
->p
== argp
->end
) {
1021 if (argp
->pagelen
< 4) {
1022 /* There isn't an opcode still on the wire */
1023 op
->opnum
= OP_WRITE
+ 1;
1024 op
->status
= nfserr_bad_xdr
;
1030 * False alarm. We just hit a page boundary, but there
1031 * is still data available. Move pointer across page
1032 * boundary. *snip from READ_BUF*
1034 argp
->p
= page_address(argp
->pagelist
[0]);
1036 if (argp
->pagelen
< PAGE_SIZE
) {
1037 argp
->end
= p
+ (argp
->pagelen
>>2);
1040 argp
->end
= p
+ (PAGE_SIZE
>>2);
1041 argp
->pagelen
-= PAGE_SIZE
;
1044 op
->opnum
= ntohl(*argp
->p
++);
1046 switch (op
->opnum
) {
1047 case 2: /* Reserved operation */
1048 op
->opnum
= OP_ILLEGAL
;
1049 if (argp
->minorversion
== 0)
1050 op
->status
= nfserr_op_illegal
;
1052 op
->status
= nfserr_minor_vers_mismatch
;
1055 op
->status
= nfsd4_decode_access(argp
, &op
->u
.access
);
1058 op
->status
= nfsd4_decode_close(argp
, &op
->u
.close
);
1061 op
->status
= nfsd4_decode_commit(argp
, &op
->u
.commit
);
1064 op
->status
= nfsd4_decode_create(argp
, &op
->u
.create
);
1066 case OP_DELEGRETURN
:
1067 op
->status
= nfsd4_decode_delegreturn(argp
, &op
->u
.delegreturn
);
1070 op
->status
= nfsd4_decode_getattr(argp
, &op
->u
.getattr
);
1073 op
->status
= nfs_ok
;
1076 op
->status
= nfsd4_decode_link(argp
, &op
->u
.link
);
1079 op
->status
= nfsd4_decode_lock(argp
, &op
->u
.lock
);
1082 op
->status
= nfsd4_decode_lockt(argp
, &op
->u
.lockt
);
1085 op
->status
= nfsd4_decode_locku(argp
, &op
->u
.locku
);
1088 op
->status
= nfsd4_decode_lookup(argp
, &op
->u
.lookup
);
1091 op
->status
= nfs_ok
;
1094 op
->status
= nfsd4_decode_verify(argp
, &op
->u
.nverify
);
1097 op
->status
= nfsd4_decode_open(argp
, &op
->u
.open
);
1099 case OP_OPEN_CONFIRM
:
1100 op
->status
= nfsd4_decode_open_confirm(argp
, &op
->u
.open_confirm
);
1102 case OP_OPEN_DOWNGRADE
:
1103 op
->status
= nfsd4_decode_open_downgrade(argp
, &op
->u
.open_downgrade
);
1106 op
->status
= nfsd4_decode_putfh(argp
, &op
->u
.putfh
);
1109 op
->status
= nfs_ok
;
1112 op
->status
= nfsd4_decode_read(argp
, &op
->u
.read
);
1115 op
->status
= nfsd4_decode_readdir(argp
, &op
->u
.readdir
);
1118 op
->status
= nfs_ok
;
1121 op
->status
= nfsd4_decode_remove(argp
, &op
->u
.remove
);
1124 op
->status
= nfsd4_decode_rename(argp
, &op
->u
.rename
);
1127 op
->status
= nfs_ok
;
1130 op
->status
= nfsd4_decode_renew(argp
, &op
->u
.renew
);
1133 op
->status
= nfs_ok
;
1136 op
->status
= nfsd4_decode_setattr(argp
, &op
->u
.setattr
);
1138 case OP_SETCLIENTID
:
1139 op
->status
= nfsd4_decode_setclientid(argp
, &op
->u
.setclientid
);
1141 case OP_SETCLIENTID_CONFIRM
:
1142 op
->status
= nfsd4_decode_setclientid_confirm(argp
, &op
->u
.setclientid_confirm
);
1145 op
->status
= nfsd4_decode_verify(argp
, &op
->u
.verify
);
1148 op
->status
= nfsd4_decode_write(argp
, &op
->u
.write
);
1150 case OP_RELEASE_LOCKOWNER
:
1151 op
->status
= nfsd4_decode_release_lockowner(argp
, &op
->u
.release_lockowner
);
1154 op
->opnum
= OP_ILLEGAL
;
1155 op
->status
= nfserr_op_illegal
;
1168 * END OF "GENERIC" DECODE ROUTINES.
1172 * START OF "GENERIC" ENCODE ROUTINES.
1173 * These may look a little ugly since they are imported from a "generic"
1174 * set of XDR encode/decode routines which are intended to be shared by
1175 * all of our NFSv4 implementations (OpenBSD, MacOS X...).
1177 * If the pain of reading these is too great, it should be a straightforward
1178 * task to translate them into Linux-specific versions which are more
1179 * consistent with the style used in NFSv2/v3...
1181 #define ENCODE_HEAD __be32 *p
1183 #define WRITE32(n) *p++ = htonl(n)
1184 #define WRITE64(n) do { \
1185 *p++ = htonl((u32)((n) >> 32)); \
1186 *p++ = htonl((u32)(n)); \
1188 #define WRITEMEM(ptr,nbytes) do { \
1189 *(p + XDR_QUADLEN(nbytes) -1) = 0; \
1190 memcpy(p, ptr, nbytes); \
1191 p += XDR_QUADLEN(nbytes); \
1193 #define WRITECINFO(c) do { \
1194 *p++ = htonl(c.atomic); \
1195 *p++ = htonl(c.before_ctime_sec); \
1196 *p++ = htonl(c.before_ctime_nsec); \
1197 *p++ = htonl(c.after_ctime_sec); \
1198 *p++ = htonl(c.after_ctime_nsec); \
1201 #define RESERVE_SPACE(nbytes) do { \
1203 BUG_ON(p + XDR_QUADLEN(nbytes) > resp->end); \
1205 #define ADJUST_ARGS() resp->p = p
1208 * Header routine to setup seqid operation replay cache
1210 #define ENCODE_SEQID_OP_HEAD \
1217 * Routine for encoding the result of a "seqid-mutating" NFSv4 operation. This
1218 * is where sequence id's are incremented, and the replay cache is filled.
1219 * Note that we increment sequence id's here, at the last moment, so we're sure
1220 * we know whether the error to be returned is a sequence id mutating error.
1223 #define ENCODE_SEQID_OP_TAIL(stateowner) do { \
1224 if (seqid_mutating_err(nfserr) && stateowner) { \
1225 stateowner->so_seqid++; \
1226 stateowner->so_replay.rp_status = nfserr; \
1227 stateowner->so_replay.rp_buflen = \
1228 (((char *)(resp)->p - (char *)save)); \
1229 memcpy(stateowner->so_replay.rp_buf, save, \
1230 stateowner->so_replay.rp_buflen); \
1233 /* Encode as an array of strings the string given with components
1236 static __be32
nfsd4_encode_components(char sep
, char *components
,
1237 __be32
**pp
, int *buflen
)
1241 int strlen
, count
=0;
1244 dprintk("nfsd4_encode_components(%s)\n", components
);
1245 if ((*buflen
-= 4) < 0)
1246 return nfserr_resource
;
1247 WRITE32(0); /* We will fill this in with @count later */
1248 end
= str
= components
;
1250 for (; *end
&& (*end
!= sep
); end
++)
1251 ; /* Point to end of component */
1254 if ((*buflen
-= ((XDR_QUADLEN(strlen
) << 2) + 4)) < 0)
1255 return nfserr_resource
;
1257 WRITEMEM(str
, strlen
);
1271 * encode a location element of a fs_locations structure
1273 static __be32
nfsd4_encode_fs_location4(struct nfsd4_fs_location
*location
,
1274 __be32
**pp
, int *buflen
)
1279 status
= nfsd4_encode_components(':', location
->hosts
, &p
, buflen
);
1282 status
= nfsd4_encode_components('/', location
->path
, &p
, buflen
);
1290 * Return the path to an export point in the pseudo filesystem namespace
1291 * Returned string is safe to use as long as the caller holds a reference
1294 static char *nfsd4_path(struct svc_rqst
*rqstp
, struct svc_export
*exp
, __be32
*stat
)
1296 struct svc_fh tmp_fh
;
1297 char *path
, *rootpath
;
1299 fh_init(&tmp_fh
, NFS4_FHSIZE
);
1300 *stat
= exp_pseudoroot(rqstp
->rq_client
, &tmp_fh
, &rqstp
->rq_chandle
);
1303 rootpath
= tmp_fh
.fh_export
->ex_path
;
1305 path
= exp
->ex_path
;
1307 if (strncmp(path
, rootpath
, strlen(rootpath
))) {
1308 printk("nfsd: fs_locations failed;"
1309 "%s is not contained in %s\n", path
, rootpath
);
1310 *stat
= nfserr_notsupp
;
1314 return path
+ strlen(rootpath
);
1318 * encode a fs_locations structure
1320 static __be32
nfsd4_encode_fs_locations(struct svc_rqst
*rqstp
,
1321 struct svc_export
*exp
,
1322 __be32
**pp
, int *buflen
)
1327 struct nfsd4_fs_locations
*fslocs
= &exp
->ex_fslocs
;
1328 char *root
= nfsd4_path(rqstp
, exp
, &status
);
1332 status
= nfsd4_encode_components('/', root
, &p
, buflen
);
1335 if ((*buflen
-= 4) < 0)
1336 return nfserr_resource
;
1337 WRITE32(fslocs
->locations_count
);
1338 for (i
=0; i
<fslocs
->locations_count
; i
++) {
1339 status
= nfsd4_encode_fs_location4(&fslocs
->locations
[i
],
1348 static u32 nfs4_ftypes
[16] = {
1349 NF4BAD
, NF4FIFO
, NF4CHR
, NF4BAD
,
1350 NF4DIR
, NF4BAD
, NF4BLK
, NF4BAD
,
1351 NF4REG
, NF4BAD
, NF4LNK
, NF4BAD
,
1352 NF4SOCK
, NF4BAD
, NF4LNK
, NF4BAD
,
1356 nfsd4_encode_name(struct svc_rqst
*rqstp
, int whotype
, uid_t id
, int group
,
1357 __be32
**p
, int *buflen
)
1361 if (*buflen
< (XDR_QUADLEN(IDMAP_NAMESZ
) << 2) + 4)
1362 return nfserr_resource
;
1363 if (whotype
!= NFS4_ACL_WHO_NAMED
)
1364 status
= nfs4_acl_write_who(whotype
, (u8
*)(*p
+ 1));
1366 status
= nfsd_map_gid_to_name(rqstp
, id
, (u8
*)(*p
+ 1));
1368 status
= nfsd_map_uid_to_name(rqstp
, id
, (u8
*)(*p
+ 1));
1370 return nfserrno(status
);
1371 *p
= xdr_encode_opaque(*p
, NULL
, status
);
1372 *buflen
-= (XDR_QUADLEN(status
) << 2) + 4;
1373 BUG_ON(*buflen
< 0);
1377 static inline __be32
1378 nfsd4_encode_user(struct svc_rqst
*rqstp
, uid_t uid
, __be32
**p
, int *buflen
)
1380 return nfsd4_encode_name(rqstp
, NFS4_ACL_WHO_NAMED
, uid
, 0, p
, buflen
);
1383 static inline __be32
1384 nfsd4_encode_group(struct svc_rqst
*rqstp
, uid_t gid
, __be32
**p
, int *buflen
)
1386 return nfsd4_encode_name(rqstp
, NFS4_ACL_WHO_NAMED
, gid
, 1, p
, buflen
);
1389 static inline __be32
1390 nfsd4_encode_aclname(struct svc_rqst
*rqstp
, int whotype
, uid_t id
, int group
,
1391 __be32
**p
, int *buflen
)
1393 return nfsd4_encode_name(rqstp
, whotype
, id
, group
, p
, buflen
);
1396 #define WORD0_ABSENT_FS_ATTRS (FATTR4_WORD0_FS_LOCATIONS | FATTR4_WORD0_FSID | \
1397 FATTR4_WORD0_RDATTR_ERROR)
1398 #define WORD1_ABSENT_FS_ATTRS FATTR4_WORD1_MOUNTED_ON_FILEID
1400 static __be32
fattr_handle_absent_fs(u32
*bmval0
, u32
*bmval1
, u32
*rdattr_err
)
1402 /* As per referral draft: */
1403 if (*bmval0
& ~WORD0_ABSENT_FS_ATTRS
||
1404 *bmval1
& ~WORD1_ABSENT_FS_ATTRS
) {
1405 if (*bmval0
& FATTR4_WORD0_RDATTR_ERROR
||
1406 *bmval0
& FATTR4_WORD0_FS_LOCATIONS
)
1407 *rdattr_err
= NFSERR_MOVED
;
1409 return nfserr_moved
;
1411 *bmval0
&= WORD0_ABSENT_FS_ATTRS
;
1412 *bmval1
&= WORD1_ABSENT_FS_ATTRS
;
1417 * Note: @fhp can be NULL; in this case, we might have to compose the filehandle
1420 * @countp is the buffer size in _words_; upon successful return this becomes
1421 * replaced with the number of words written.
1424 nfsd4_encode_fattr(struct svc_fh
*fhp
, struct svc_export
*exp
,
1425 struct dentry
*dentry
, __be32
*buffer
, int *countp
, u32
*bmval
,
1426 struct svc_rqst
*rqstp
)
1428 u32 bmval0
= bmval
[0];
1429 u32 bmval1
= bmval
[1];
1431 struct svc_fh tempfh
;
1432 struct kstatfs statfs
;
1433 int buflen
= *countp
<< 2;
1442 struct nfs4_acl
*acl
= NULL
;
1444 BUG_ON(bmval1
& NFSD_WRITEONLY_ATTRS_WORD1
);
1445 BUG_ON(bmval0
& ~NFSD_SUPPORTED_ATTRS_WORD0
);
1446 BUG_ON(bmval1
& ~NFSD_SUPPORTED_ATTRS_WORD1
);
1448 if (exp
->ex_fslocs
.migrated
) {
1449 status
= fattr_handle_absent_fs(&bmval0
, &bmval1
, &rdattr_err
);
1454 err
= vfs_getattr(exp
->ex_mnt
, dentry
, &stat
);
1457 if ((bmval0
& (FATTR4_WORD0_FILES_FREE
| FATTR4_WORD0_FILES_TOTAL
)) ||
1458 (bmval1
& (FATTR4_WORD1_SPACE_AVAIL
| FATTR4_WORD1_SPACE_FREE
|
1459 FATTR4_WORD1_SPACE_TOTAL
))) {
1460 err
= vfs_statfs(dentry
, &statfs
);
1464 if ((bmval0
& (FATTR4_WORD0_FILEHANDLE
| FATTR4_WORD0_FSID
)) && !fhp
) {
1465 fh_init(&tempfh
, NFS4_FHSIZE
);
1466 status
= fh_compose(&tempfh
, exp
, dentry
, NULL
);
1471 if (bmval0
& (FATTR4_WORD0_ACL
| FATTR4_WORD0_ACLSUPPORT
1472 | FATTR4_WORD0_SUPPORTED_ATTRS
)) {
1473 err
= nfsd4_get_nfs4_acl(rqstp
, dentry
, &acl
);
1474 aclsupport
= (err
== 0);
1475 if (bmval0
& FATTR4_WORD0_ACL
) {
1476 if (err
== -EOPNOTSUPP
)
1477 bmval0
&= ~FATTR4_WORD0_ACL
;
1478 else if (err
== -EINVAL
) {
1479 status
= nfserr_attrnotsupp
;
1481 } else if (err
!= 0)
1485 if (bmval0
& FATTR4_WORD0_FS_LOCATIONS
) {
1486 if (exp
->ex_fslocs
.locations
== NULL
) {
1487 bmval0
&= ~FATTR4_WORD0_FS_LOCATIONS
;
1490 if ((buflen
-= 16) < 0)
1496 attrlenp
= p
++; /* to be backfilled later */
1498 if (bmval0
& FATTR4_WORD0_SUPPORTED_ATTRS
) {
1499 u32 word0
= NFSD_SUPPORTED_ATTRS_WORD0
;
1500 if ((buflen
-= 12) < 0)
1503 word0
&= ~FATTR4_WORD0_ACL
;
1504 if (!exp
->ex_fslocs
.locations
)
1505 word0
&= ~FATTR4_WORD0_FS_LOCATIONS
;
1508 WRITE32(NFSD_SUPPORTED_ATTRS_WORD1
);
1510 if (bmval0
& FATTR4_WORD0_TYPE
) {
1511 if ((buflen
-= 4) < 0)
1513 dummy
= nfs4_ftypes
[(stat
.mode
& S_IFMT
) >> 12];
1514 if (dummy
== NF4BAD
)
1515 goto out_serverfault
;
1518 if (bmval0
& FATTR4_WORD0_FH_EXPIRE_TYPE
) {
1519 if ((buflen
-= 4) < 0)
1521 if (exp
->ex_flags
& NFSEXP_NOSUBTREECHECK
)
1522 WRITE32(NFS4_FH_PERSISTENT
);
1524 WRITE32(NFS4_FH_PERSISTENT
|NFS4_FH_VOL_RENAME
);
1526 if (bmval0
& FATTR4_WORD0_CHANGE
) {
1528 * Note: This _must_ be consistent with the scheme for writing
1529 * change_info, so any changes made here must be reflected there
1530 * as well. (See xdr4.h:set_change_info() and the WRITECINFO()
1533 if ((buflen
-= 8) < 0)
1535 WRITE32(stat
.ctime
.tv_sec
);
1536 WRITE32(stat
.ctime
.tv_nsec
);
1538 if (bmval0
& FATTR4_WORD0_SIZE
) {
1539 if ((buflen
-= 8) < 0)
1543 if (bmval0
& FATTR4_WORD0_LINK_SUPPORT
) {
1544 if ((buflen
-= 4) < 0)
1548 if (bmval0
& FATTR4_WORD0_SYMLINK_SUPPORT
) {
1549 if ((buflen
-= 4) < 0)
1553 if (bmval0
& FATTR4_WORD0_NAMED_ATTR
) {
1554 if ((buflen
-= 4) < 0)
1558 if (bmval0
& FATTR4_WORD0_FSID
) {
1559 if ((buflen
-= 16) < 0)
1561 if (exp
->ex_fslocs
.migrated
) {
1562 WRITE64(NFS4_REFERRAL_FSID_MAJOR
);
1563 WRITE64(NFS4_REFERRAL_FSID_MINOR
);
1564 } else switch(fsid_source(fhp
)) {
1565 case FSIDSOURCE_FSID
:
1566 WRITE64((u64
)exp
->ex_fsid
);
1569 case FSIDSOURCE_DEV
:
1571 WRITE32(MAJOR(stat
.dev
));
1573 WRITE32(MINOR(stat
.dev
));
1575 case FSIDSOURCE_UUID
:
1576 WRITEMEM(exp
->ex_uuid
, 16);
1580 if (bmval0
& FATTR4_WORD0_UNIQUE_HANDLES
) {
1581 if ((buflen
-= 4) < 0)
1585 if (bmval0
& FATTR4_WORD0_LEASE_TIME
) {
1586 if ((buflen
-= 4) < 0)
1588 WRITE32(NFSD_LEASE_TIME
);
1590 if (bmval0
& FATTR4_WORD0_RDATTR_ERROR
) {
1591 if ((buflen
-= 4) < 0)
1593 WRITE32(rdattr_err
);
1595 if (bmval0
& FATTR4_WORD0_ACL
) {
1596 struct nfs4_ace
*ace
;
1599 if ((buflen
-= 4) < 0)
1605 if ((buflen
-= 4) < 0)
1607 WRITE32(acl
->naces
);
1609 for (ace
= acl
->aces
; ace
< acl
->aces
+ acl
->naces
; ace
++) {
1610 if ((buflen
-= 4*3) < 0)
1614 WRITE32(ace
->access_mask
& NFS4_ACE_MASK_ALL
);
1615 status
= nfsd4_encode_aclname(rqstp
, ace
->whotype
,
1616 ace
->who
, ace
->flag
& NFS4_ACE_IDENTIFIER_GROUP
,
1618 if (status
== nfserr_resource
)
1625 if (bmval0
& FATTR4_WORD0_ACLSUPPORT
) {
1626 if ((buflen
-= 4) < 0)
1628 WRITE32(aclsupport
?
1629 ACL4_SUPPORT_ALLOW_ACL
|ACL4_SUPPORT_DENY_ACL
: 0);
1631 if (bmval0
& FATTR4_WORD0_CANSETTIME
) {
1632 if ((buflen
-= 4) < 0)
1636 if (bmval0
& FATTR4_WORD0_CASE_INSENSITIVE
) {
1637 if ((buflen
-= 4) < 0)
1641 if (bmval0
& FATTR4_WORD0_CASE_PRESERVING
) {
1642 if ((buflen
-= 4) < 0)
1646 if (bmval0
& FATTR4_WORD0_CHOWN_RESTRICTED
) {
1647 if ((buflen
-= 4) < 0)
1651 if (bmval0
& FATTR4_WORD0_FILEHANDLE
) {
1652 buflen
-= (XDR_QUADLEN(fhp
->fh_handle
.fh_size
) << 2) + 4;
1655 WRITE32(fhp
->fh_handle
.fh_size
);
1656 WRITEMEM(&fhp
->fh_handle
.fh_base
, fhp
->fh_handle
.fh_size
);
1658 if (bmval0
& FATTR4_WORD0_FILEID
) {
1659 if ((buflen
-= 8) < 0)
1661 WRITE64((u64
) stat
.ino
);
1663 if (bmval0
& FATTR4_WORD0_FILES_AVAIL
) {
1664 if ((buflen
-= 8) < 0)
1666 WRITE64((u64
) statfs
.f_ffree
);
1668 if (bmval0
& FATTR4_WORD0_FILES_FREE
) {
1669 if ((buflen
-= 8) < 0)
1671 WRITE64((u64
) statfs
.f_ffree
);
1673 if (bmval0
& FATTR4_WORD0_FILES_TOTAL
) {
1674 if ((buflen
-= 8) < 0)
1676 WRITE64((u64
) statfs
.f_files
);
1678 if (bmval0
& FATTR4_WORD0_FS_LOCATIONS
) {
1679 status
= nfsd4_encode_fs_locations(rqstp
, exp
, &p
, &buflen
);
1680 if (status
== nfserr_resource
)
1685 if (bmval0
& FATTR4_WORD0_HOMOGENEOUS
) {
1686 if ((buflen
-= 4) < 0)
1690 if (bmval0
& FATTR4_WORD0_MAXFILESIZE
) {
1691 if ((buflen
-= 8) < 0)
1695 if (bmval0
& FATTR4_WORD0_MAXLINK
) {
1696 if ((buflen
-= 4) < 0)
1700 if (bmval0
& FATTR4_WORD0_MAXNAME
) {
1701 if ((buflen
-= 4) < 0)
1705 if (bmval0
& FATTR4_WORD0_MAXREAD
) {
1706 if ((buflen
-= 8) < 0)
1708 WRITE64((u64
) svc_max_payload(rqstp
));
1710 if (bmval0
& FATTR4_WORD0_MAXWRITE
) {
1711 if ((buflen
-= 8) < 0)
1713 WRITE64((u64
) svc_max_payload(rqstp
));
1715 if (bmval1
& FATTR4_WORD1_MODE
) {
1716 if ((buflen
-= 4) < 0)
1718 WRITE32(stat
.mode
& S_IALLUGO
);
1720 if (bmval1
& FATTR4_WORD1_NO_TRUNC
) {
1721 if ((buflen
-= 4) < 0)
1725 if (bmval1
& FATTR4_WORD1_NUMLINKS
) {
1726 if ((buflen
-= 4) < 0)
1728 WRITE32(stat
.nlink
);
1730 if (bmval1
& FATTR4_WORD1_OWNER
) {
1731 status
= nfsd4_encode_user(rqstp
, stat
.uid
, &p
, &buflen
);
1732 if (status
== nfserr_resource
)
1737 if (bmval1
& FATTR4_WORD1_OWNER_GROUP
) {
1738 status
= nfsd4_encode_group(rqstp
, stat
.gid
, &p
, &buflen
);
1739 if (status
== nfserr_resource
)
1744 if (bmval1
& FATTR4_WORD1_RAWDEV
) {
1745 if ((buflen
-= 8) < 0)
1747 WRITE32((u32
) MAJOR(stat
.rdev
));
1748 WRITE32((u32
) MINOR(stat
.rdev
));
1750 if (bmval1
& FATTR4_WORD1_SPACE_AVAIL
) {
1751 if ((buflen
-= 8) < 0)
1753 dummy64
= (u64
)statfs
.f_bavail
* (u64
)statfs
.f_bsize
;
1756 if (bmval1
& FATTR4_WORD1_SPACE_FREE
) {
1757 if ((buflen
-= 8) < 0)
1759 dummy64
= (u64
)statfs
.f_bfree
* (u64
)statfs
.f_bsize
;
1762 if (bmval1
& FATTR4_WORD1_SPACE_TOTAL
) {
1763 if ((buflen
-= 8) < 0)
1765 dummy64
= (u64
)statfs
.f_blocks
* (u64
)statfs
.f_bsize
;
1768 if (bmval1
& FATTR4_WORD1_SPACE_USED
) {
1769 if ((buflen
-= 8) < 0)
1771 dummy64
= (u64
)stat
.blocks
<< 9;
1774 if (bmval1
& FATTR4_WORD1_TIME_ACCESS
) {
1775 if ((buflen
-= 12) < 0)
1778 WRITE32(stat
.atime
.tv_sec
);
1779 WRITE32(stat
.atime
.tv_nsec
);
1781 if (bmval1
& FATTR4_WORD1_TIME_DELTA
) {
1782 if ((buflen
-= 12) < 0)
1788 if (bmval1
& FATTR4_WORD1_TIME_METADATA
) {
1789 if ((buflen
-= 12) < 0)
1792 WRITE32(stat
.ctime
.tv_sec
);
1793 WRITE32(stat
.ctime
.tv_nsec
);
1795 if (bmval1
& FATTR4_WORD1_TIME_MODIFY
) {
1796 if ((buflen
-= 12) < 0)
1799 WRITE32(stat
.mtime
.tv_sec
);
1800 WRITE32(stat
.mtime
.tv_nsec
);
1802 if (bmval1
& FATTR4_WORD1_MOUNTED_ON_FILEID
) {
1803 struct dentry
*mnt_pnt
, *mnt_root
;
1805 if ((buflen
-= 8) < 0)
1807 mnt_root
= exp
->ex_mnt
->mnt_root
;
1808 if (mnt_root
->d_inode
== dentry
->d_inode
) {
1809 mnt_pnt
= exp
->ex_mnt
->mnt_mountpoint
;
1810 WRITE64((u64
) mnt_pnt
->d_inode
->i_ino
);
1812 WRITE64((u64
) stat
.ino
);
1814 *attrlenp
= htonl((char *)p
- (char *)attrlenp
- 4);
1815 *countp
= p
- buffer
;
1824 status
= nfserrno(err
);
1828 status
= nfserr_resource
;
1831 status
= nfserr_serverfault
;
1836 nfsd4_encode_dirent_fattr(struct nfsd4_readdir
*cd
,
1837 const char *name
, int namlen
, __be32
*p
, int *buflen
)
1839 struct svc_export
*exp
= cd
->rd_fhp
->fh_export
;
1840 struct dentry
*dentry
;
1843 dentry
= lookup_one_len(name
, cd
->rd_fhp
->fh_dentry
, namlen
);
1845 return nfserrno(PTR_ERR(dentry
));
1848 if (d_mountpoint(dentry
)) {
1851 err
= nfsd_cross_mnt(cd
->rd_rqstp
, &dentry
, &exp
);
1853 nfserr
= nfserrno(err
);
1858 nfserr
= nfsd4_encode_fattr(NULL
, exp
, dentry
, p
, buflen
, cd
->rd_bmval
,
1867 nfsd4_encode_rdattr_error(__be32
*p
, int buflen
, __be32 nfserr
)
1874 *p
++ = htonl(FATTR4_WORD0_RDATTR_ERROR
); /* bmval0 */
1875 *p
++ = htonl(0); /* bmval1 */
1878 *p
++ = nfserr
; /* no htonl */
1879 *attrlenp
= htonl((char *)p
- (char *)attrlenp
- 4);
1884 nfsd4_encode_dirent(void *ccdv
, const char *name
, int namlen
,
1885 loff_t offset
, u64 ino
, unsigned int d_type
)
1887 struct readdir_cd
*ccd
= ccdv
;
1888 struct nfsd4_readdir
*cd
= container_of(ccd
, struct nfsd4_readdir
, common
);
1890 __be32
*p
= cd
->buffer
;
1891 __be32 nfserr
= nfserr_toosmall
;
1893 /* In nfsv4, "." and ".." never make it onto the wire.. */
1894 if (name
&& isdotent(name
, namlen
)) {
1895 cd
->common
.err
= nfs_ok
;
1900 xdr_encode_hyper(cd
->offset
, (u64
) offset
);
1902 buflen
= cd
->buflen
- 4 - XDR_QUADLEN(namlen
);
1906 *p
++ = xdr_one
; /* mark entry present */
1907 cd
->offset
= p
; /* remember pointer */
1908 p
= xdr_encode_hyper(p
, NFS_OFFSET_MAX
); /* offset of next entry */
1909 p
= xdr_encode_array(p
, name
, namlen
); /* name length & name */
1911 nfserr
= nfsd4_encode_dirent_fattr(cd
, name
, namlen
, p
, &buflen
);
1916 case nfserr_resource
:
1917 nfserr
= nfserr_toosmall
;
1923 * If the client requested the RDATTR_ERROR attribute,
1924 * we stuff the error code into this attribute
1925 * and continue. If this attribute was not requested,
1926 * then in accordance with the spec, we fail the
1927 * entire READDIR operation(!)
1929 if (!(cd
->rd_bmval
[0] & FATTR4_WORD0_RDATTR_ERROR
))
1931 p
= nfsd4_encode_rdattr_error(p
, buflen
, nfserr
);
1933 nfserr
= nfserr_toosmall
;
1937 cd
->buflen
-= (p
- cd
->buffer
);
1939 cd
->common
.err
= nfs_ok
;
1942 cd
->common
.err
= nfserr
;
1947 nfsd4_encode_access(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_access
*access
)
1953 WRITE32(access
->ac_supported
);
1954 WRITE32(access
->ac_resp_access
);
1960 nfsd4_encode_close(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_close
*close
)
1962 ENCODE_SEQID_OP_HEAD
;
1965 RESERVE_SPACE(sizeof(stateid_t
));
1966 WRITE32(close
->cl_stateid
.si_generation
);
1967 WRITEMEM(&close
->cl_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
1970 ENCODE_SEQID_OP_TAIL(close
->cl_stateowner
);
1975 nfsd4_encode_commit(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_commit
*commit
)
1981 WRITEMEM(commit
->co_verf
.data
, 8);
1987 nfsd4_encode_create(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_create
*create
)
1993 WRITECINFO(create
->cr_cinfo
);
1995 WRITE32(create
->cr_bmval
[0]);
1996 WRITE32(create
->cr_bmval
[1]);
2002 nfsd4_encode_getattr(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_getattr
*getattr
)
2004 struct svc_fh
*fhp
= getattr
->ga_fhp
;
2010 buflen
= resp
->end
- resp
->p
- (COMPOUND_ERR_SLACK_SPACE
>> 2);
2011 nfserr
= nfsd4_encode_fattr(fhp
, fhp
->fh_export
, fhp
->fh_dentry
,
2012 resp
->p
, &buflen
, getattr
->ga_bmval
,
2020 nfsd4_encode_getfh(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct svc_fh
*fhp
)
2026 len
= fhp
->fh_handle
.fh_size
;
2027 RESERVE_SPACE(len
+ 4);
2029 WRITEMEM(&fhp
->fh_handle
.fh_base
, len
);
2035 * Including all fields other than the name, a LOCK4denied structure requires
2036 * 8(clientid) + 4(namelen) + 8(offset) + 8(length) + 4(type) = 32 bytes.
2039 nfsd4_encode_lock_denied(struct nfsd4_compoundres
*resp
, struct nfsd4_lock_denied
*ld
)
2043 RESERVE_SPACE(32 + XDR_LEN(ld
->ld_sop
? ld
->ld_sop
->so_owner
.len
: 0));
2044 WRITE64(ld
->ld_start
);
2045 WRITE64(ld
->ld_length
);
2046 WRITE32(ld
->ld_type
);
2048 WRITEMEM(&ld
->ld_clientid
, 8);
2049 WRITE32(ld
->ld_sop
->so_owner
.len
);
2050 WRITEMEM(ld
->ld_sop
->so_owner
.data
, ld
->ld_sop
->so_owner
.len
);
2051 kref_put(&ld
->ld_sop
->so_ref
, nfs4_free_stateowner
);
2052 } else { /* non - nfsv4 lock in conflict, no clientid nor owner */
2053 WRITE64((u64
)0); /* clientid */
2054 WRITE32(0); /* length of owner name */
2060 nfsd4_encode_lock(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_lock
*lock
)
2062 ENCODE_SEQID_OP_HEAD
;
2065 RESERVE_SPACE(4 + sizeof(stateid_t
));
2066 WRITE32(lock
->lk_resp_stateid
.si_generation
);
2067 WRITEMEM(&lock
->lk_resp_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
2069 } else if (nfserr
== nfserr_denied
)
2070 nfsd4_encode_lock_denied(resp
, &lock
->lk_denied
);
2072 ENCODE_SEQID_OP_TAIL(lock
->lk_replay_owner
);
2076 nfsd4_encode_lockt(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_lockt
*lockt
)
2078 if (nfserr
== nfserr_denied
)
2079 nfsd4_encode_lock_denied(resp
, &lockt
->lt_denied
);
2083 nfsd4_encode_locku(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_locku
*locku
)
2085 ENCODE_SEQID_OP_HEAD
;
2088 RESERVE_SPACE(sizeof(stateid_t
));
2089 WRITE32(locku
->lu_stateid
.si_generation
);
2090 WRITEMEM(&locku
->lu_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
2094 ENCODE_SEQID_OP_TAIL(locku
->lu_stateowner
);
2099 nfsd4_encode_link(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_link
*link
)
2105 WRITECINFO(link
->li_cinfo
);
2112 nfsd4_encode_open(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_open
*open
)
2114 ENCODE_SEQID_OP_HEAD
;
2119 RESERVE_SPACE(36 + sizeof(stateid_t
));
2120 WRITE32(open
->op_stateid
.si_generation
);
2121 WRITEMEM(&open
->op_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
2122 WRITECINFO(open
->op_cinfo
);
2123 WRITE32(open
->op_rflags
);
2125 WRITE32(open
->op_bmval
[0]);
2126 WRITE32(open
->op_bmval
[1]);
2127 WRITE32(open
->op_delegate_type
);
2130 switch (open
->op_delegate_type
) {
2131 case NFS4_OPEN_DELEGATE_NONE
:
2133 case NFS4_OPEN_DELEGATE_READ
:
2134 RESERVE_SPACE(20 + sizeof(stateid_t
));
2135 WRITEMEM(&open
->op_delegate_stateid
, sizeof(stateid_t
));
2136 WRITE32(open
->op_recall
);
2139 * TODO: ACE's in delegations
2141 WRITE32(NFS4_ACE_ACCESS_ALLOWED_ACE_TYPE
);
2144 WRITE32(0); /* XXX: is NULL principal ok? */
2147 case NFS4_OPEN_DELEGATE_WRITE
:
2148 RESERVE_SPACE(32 + sizeof(stateid_t
));
2149 WRITEMEM(&open
->op_delegate_stateid
, sizeof(stateid_t
));
2153 * TODO: space_limit's in delegations
2155 WRITE32(NFS4_LIMIT_SIZE
);
2160 * TODO: ACE's in delegations
2162 WRITE32(NFS4_ACE_ACCESS_ALLOWED_ACE_TYPE
);
2165 WRITE32(0); /* XXX: is NULL principal ok? */
2171 /* XXX save filehandle here */
2173 ENCODE_SEQID_OP_TAIL(open
->op_stateowner
);
2177 nfsd4_encode_open_confirm(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_open_confirm
*oc
)
2179 ENCODE_SEQID_OP_HEAD
;
2182 RESERVE_SPACE(sizeof(stateid_t
));
2183 WRITE32(oc
->oc_resp_stateid
.si_generation
);
2184 WRITEMEM(&oc
->oc_resp_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
2188 ENCODE_SEQID_OP_TAIL(oc
->oc_stateowner
);
2192 nfsd4_encode_open_downgrade(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_open_downgrade
*od
)
2194 ENCODE_SEQID_OP_HEAD
;
2197 RESERVE_SPACE(sizeof(stateid_t
));
2198 WRITE32(od
->od_stateid
.si_generation
);
2199 WRITEMEM(&od
->od_stateid
.si_opaque
, sizeof(stateid_opaque_t
));
2203 ENCODE_SEQID_OP_TAIL(od
->od_stateowner
);
2207 nfsd4_encode_read(struct nfsd4_compoundres
*resp
, __be32 nfserr
,
2208 struct nfsd4_read
*read
)
2212 unsigned long maxcount
;
2218 if (resp
->xbuf
->page_len
)
2219 return nfserr_resource
;
2221 RESERVE_SPACE(8); /* eof flag and byte count */
2223 maxcount
= svc_max_payload(resp
->rqstp
);
2224 if (maxcount
> read
->rd_length
)
2225 maxcount
= read
->rd_length
;
2230 pn
= resp
->rqstp
->rq_resused
++;
2231 resp
->rqstp
->rq_vec
[v
].iov_base
=
2232 page_address(resp
->rqstp
->rq_respages
[pn
]);
2233 resp
->rqstp
->rq_vec
[v
].iov_len
=
2234 len
< PAGE_SIZE
? len
: PAGE_SIZE
;
2240 nfserr
= nfsd_read(read
->rd_rqstp
, read
->rd_fhp
, read
->rd_filp
,
2241 read
->rd_offset
, resp
->rqstp
->rq_vec
, read
->rd_vlen
,
2244 if (nfserr
== nfserr_symlink
)
2245 nfserr
= nfserr_inval
;
2248 eof
= (read
->rd_offset
+ maxcount
>=
2249 read
->rd_fhp
->fh_dentry
->d_inode
->i_size
);
2254 resp
->xbuf
->head
[0].iov_len
= (char*)p
2255 - (char*)resp
->xbuf
->head
[0].iov_base
;
2256 resp
->xbuf
->page_len
= maxcount
;
2258 /* Use rest of head for padding and remaining ops: */
2259 resp
->xbuf
->tail
[0].iov_base
= p
;
2260 resp
->xbuf
->tail
[0].iov_len
= 0;
2264 resp
->xbuf
->tail
[0].iov_base
+= maxcount
&3;
2265 resp
->xbuf
->tail
[0].iov_len
= 4 - (maxcount
&3);
2272 nfsd4_encode_readlink(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_readlink
*readlink
)
2280 if (resp
->xbuf
->page_len
)
2281 return nfserr_resource
;
2283 page
= page_address(resp
->rqstp
->rq_respages
[resp
->rqstp
->rq_resused
++]);
2285 maxcount
= PAGE_SIZE
;
2289 * XXX: By default, the ->readlink() VFS op will truncate symlinks
2290 * if they would overflow the buffer. Is this kosher in NFSv4? If
2291 * not, one easy fix is: if ->readlink() precisely fills the buffer,
2292 * assume that truncation occurred, and return NFS4ERR_RESOURCE.
2294 nfserr
= nfsd_readlink(readlink
->rl_rqstp
, readlink
->rl_fhp
, page
, &maxcount
);
2295 if (nfserr
== nfserr_isdir
)
2296 return nfserr_inval
;
2302 resp
->xbuf
->head
[0].iov_len
= (char*)p
2303 - (char*)resp
->xbuf
->head
[0].iov_base
;
2304 resp
->xbuf
->page_len
= maxcount
;
2306 /* Use rest of head for padding and remaining ops: */
2307 resp
->xbuf
->tail
[0].iov_base
= p
;
2308 resp
->xbuf
->tail
[0].iov_len
= 0;
2312 resp
->xbuf
->tail
[0].iov_base
+= maxcount
&3;
2313 resp
->xbuf
->tail
[0].iov_len
= 4 - (maxcount
&3);
2320 nfsd4_encode_readdir(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_readdir
*readdir
)
2324 __be32
*page
, *savep
, *tailbase
;
2329 if (resp
->xbuf
->page_len
)
2330 return nfserr_resource
;
2332 RESERVE_SPACE(8); /* verifier */
2335 /* XXX: Following NFSv3, we ignore the READDIR verifier for now. */
2339 resp
->xbuf
->head
[0].iov_len
= ((char*)resp
->p
) - (char*)resp
->xbuf
->head
[0].iov_base
;
2342 maxcount
= PAGE_SIZE
;
2343 if (maxcount
> readdir
->rd_maxcount
)
2344 maxcount
= readdir
->rd_maxcount
;
2347 * Convert from bytes to words, account for the two words already
2348 * written, make sure to leave two words at the end for the next
2349 * pointer and eof field.
2351 maxcount
= (maxcount
>> 2) - 4;
2353 nfserr
= nfserr_toosmall
;
2357 page
= page_address(resp
->rqstp
->rq_respages
[resp
->rqstp
->rq_resused
++]);
2358 readdir
->common
.err
= 0;
2359 readdir
->buflen
= maxcount
;
2360 readdir
->buffer
= page
;
2361 readdir
->offset
= NULL
;
2363 offset
= readdir
->rd_cookie
;
2364 nfserr
= nfsd_readdir(readdir
->rd_rqstp
, readdir
->rd_fhp
,
2366 &readdir
->common
, nfsd4_encode_dirent
);
2367 if (nfserr
== nfs_ok
&&
2368 readdir
->common
.err
== nfserr_toosmall
&&
2369 readdir
->buffer
== page
)
2370 nfserr
= nfserr_toosmall
;
2371 if (nfserr
== nfserr_symlink
)
2372 nfserr
= nfserr_notdir
;
2376 if (readdir
->offset
)
2377 xdr_encode_hyper(readdir
->offset
, offset
);
2379 p
= readdir
->buffer
;
2380 *p
++ = 0; /* no more entries */
2381 *p
++ = htonl(readdir
->common
.err
== nfserr_eof
);
2382 resp
->xbuf
->page_len
= ((char*)p
) - (char*)page_address(
2383 resp
->rqstp
->rq_respages
[resp
->rqstp
->rq_resused
-1]);
2385 /* Use rest of head for padding and remaining ops: */
2386 resp
->xbuf
->tail
[0].iov_base
= tailbase
;
2387 resp
->xbuf
->tail
[0].iov_len
= 0;
2388 resp
->p
= resp
->xbuf
->tail
[0].iov_base
;
2389 resp
->end
= resp
->p
+ (PAGE_SIZE
- resp
->xbuf
->head
[0].iov_len
)/4;
2399 nfsd4_encode_remove(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_remove
*remove
)
2405 WRITECINFO(remove
->rm_cinfo
);
2411 nfsd4_encode_rename(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_rename
*rename
)
2417 WRITECINFO(rename
->rn_sinfo
);
2418 WRITECINFO(rename
->rn_tinfo
);
2424 * The SETATTR encode routine is special -- it always encodes a bitmap,
2425 * regardless of the error status.
2428 nfsd4_encode_setattr(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_setattr
*setattr
)
2440 WRITE32(setattr
->sa_bmval
[0]);
2441 WRITE32(setattr
->sa_bmval
[1]);
2447 nfsd4_encode_setclientid(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_setclientid
*scd
)
2452 RESERVE_SPACE(8 + sizeof(nfs4_verifier
));
2453 WRITEMEM(&scd
->se_clientid
, 8);
2454 WRITEMEM(&scd
->se_confirm
, sizeof(nfs4_verifier
));
2457 else if (nfserr
== nfserr_clid_inuse
) {
2466 nfsd4_encode_write(struct nfsd4_compoundres
*resp
, __be32 nfserr
, struct nfsd4_write
*write
)
2472 WRITE32(write
->wr_bytes_written
);
2473 WRITE32(write
->wr_how_written
);
2474 WRITEMEM(write
->wr_verifier
.data
, 8);
2480 nfsd4_encode_operation(struct nfsd4_compoundres
*resp
, struct nfsd4_op
*op
)
2487 statp
= p
++; /* to be backfilled at the end */
2490 switch (op
->opnum
) {
2492 nfsd4_encode_access(resp
, op
->status
, &op
->u
.access
);
2495 nfsd4_encode_close(resp
, op
->status
, &op
->u
.close
);
2498 nfsd4_encode_commit(resp
, op
->status
, &op
->u
.commit
);
2501 nfsd4_encode_create(resp
, op
->status
, &op
->u
.create
);
2503 case OP_DELEGRETURN
:
2506 op
->status
= nfsd4_encode_getattr(resp
, op
->status
, &op
->u
.getattr
);
2509 nfsd4_encode_getfh(resp
, op
->status
, op
->u
.getfh
);
2512 nfsd4_encode_link(resp
, op
->status
, &op
->u
.link
);
2515 nfsd4_encode_lock(resp
, op
->status
, &op
->u
.lock
);
2518 nfsd4_encode_lockt(resp
, op
->status
, &op
->u
.lockt
);
2521 nfsd4_encode_locku(resp
, op
->status
, &op
->u
.locku
);
2530 nfsd4_encode_open(resp
, op
->status
, &op
->u
.open
);
2532 case OP_OPEN_CONFIRM
:
2533 nfsd4_encode_open_confirm(resp
, op
->status
, &op
->u
.open_confirm
);
2535 case OP_OPEN_DOWNGRADE
:
2536 nfsd4_encode_open_downgrade(resp
, op
->status
, &op
->u
.open_downgrade
);
2543 op
->status
= nfsd4_encode_read(resp
, op
->status
, &op
->u
.read
);
2546 op
->status
= nfsd4_encode_readdir(resp
, op
->status
, &op
->u
.readdir
);
2549 op
->status
= nfsd4_encode_readlink(resp
, op
->status
, &op
->u
.readlink
);
2552 nfsd4_encode_remove(resp
, op
->status
, &op
->u
.remove
);
2555 nfsd4_encode_rename(resp
, op
->status
, &op
->u
.rename
);
2564 nfsd4_encode_setattr(resp
, op
->status
, &op
->u
.setattr
);
2566 case OP_SETCLIENTID
:
2567 nfsd4_encode_setclientid(resp
, op
->status
, &op
->u
.setclientid
);
2569 case OP_SETCLIENTID_CONFIRM
:
2574 nfsd4_encode_write(resp
, op
->status
, &op
->u
.write
);
2576 case OP_RELEASE_LOCKOWNER
:
2583 * Note: We write the status directly, instead of using WRITE32(),
2584 * since it is already in network byte order.
2586 *statp
= op
->status
;
2590 * Encode the reply stored in the stateowner reply cache
2592 * XDR note: do not encode rp->rp_buflen: the buffer contains the
2593 * previously sent already encoded operation.
2595 * called with nfs4_lock_state() held
2598 nfsd4_encode_replay(struct nfsd4_compoundres
*resp
, struct nfsd4_op
*op
)
2601 struct nfs4_replay
*rp
= op
->replay
;
2607 *p
++ = rp
->rp_status
; /* already xdr'ed */
2610 RESERVE_SPACE(rp
->rp_buflen
);
2611 WRITEMEM(rp
->rp_buf
, rp
->rp_buflen
);
2616 * END OF "GENERIC" ENCODE ROUTINES.
2620 nfs4svc_encode_voidres(struct svc_rqst
*rqstp
, __be32
*p
, void *dummy
)
2622 return xdr_ressize_check(rqstp
, p
);
2625 void nfsd4_release_compoundargs(struct nfsd4_compoundargs
*args
)
2627 if (args
->ops
!= args
->iops
) {
2629 args
->ops
= args
->iops
;
2633 while (args
->to_free
) {
2634 struct tmpbuf
*tb
= args
->to_free
;
2635 args
->to_free
= tb
->next
;
2636 tb
->release(tb
->buf
);
2642 nfs4svc_decode_compoundargs(struct svc_rqst
*rqstp
, __be32
*p
, struct nfsd4_compoundargs
*args
)
2647 args
->end
= rqstp
->rq_arg
.head
[0].iov_base
+ rqstp
->rq_arg
.head
[0].iov_len
;
2648 args
->pagelist
= rqstp
->rq_arg
.pages
;
2649 args
->pagelen
= rqstp
->rq_arg
.page_len
;
2651 args
->to_free
= NULL
;
2652 args
->ops
= args
->iops
;
2653 args
->rqstp
= rqstp
;
2655 status
= nfsd4_decode_compound(args
);
2657 nfsd4_release_compoundargs(args
);
2663 nfs4svc_encode_compoundres(struct svc_rqst
*rqstp
, __be32
*p
, struct nfsd4_compoundres
*resp
)
2666 * All that remains is to write the tag and operation count...
2670 *p
++ = htonl(resp
->taglen
);
2671 memcpy(p
, resp
->tag
, resp
->taglen
);
2672 p
+= XDR_QUADLEN(resp
->taglen
);
2673 *p
++ = htonl(resp
->opcnt
);
2675 if (rqstp
->rq_res
.page_len
)
2676 iov
= &rqstp
->rq_res
.tail
[0];
2678 iov
= &rqstp
->rq_res
.head
[0];
2679 iov
->iov_len
= ((char*)resp
->p
) - (char*)iov
->iov_base
;
2680 BUG_ON(iov
->iov_len
> PAGE_SIZE
);