[PATCH] NFS: Add support for NFSv3 ACLs
[linux-2.6] / fs / nfs / nfs3xdr.c
1 /*
2  * linux/fs/nfs/nfs3xdr.c
3  *
4  * XDR functions to encode/decode NFSv3 RPC arguments and results.
5  *
6  * Copyright (C) 1996, 1997 Olaf Kirch
7  */
8
9 #include <linux/param.h>
10 #include <linux/time.h>
11 #include <linux/mm.h>
12 #include <linux/slab.h>
13 #include <linux/utsname.h>
14 #include <linux/errno.h>
15 #include <linux/string.h>
16 #include <linux/in.h>
17 #include <linux/pagemap.h>
18 #include <linux/proc_fs.h>
19 #include <linux/kdev_t.h>
20 #include <linux/sunrpc/clnt.h>
21 #include <linux/nfs.h>
22 #include <linux/nfs3.h>
23 #include <linux/nfs_fs.h>
24 #include <linux/nfsacl.h>
25
26 #define NFSDBG_FACILITY         NFSDBG_XDR
27
28 /* Mapping from NFS error code to "errno" error code. */
29 #define errno_NFSERR_IO         EIO
30
31 extern int                      nfs_stat_to_errno(int);
32
33 /*
34  * Declare the space requirements for NFS arguments and replies as
35  * number of 32bit-words
36  */
37 #define NFS3_fhandle_sz         (1+16)
38 #define NFS3_fh_sz              (NFS3_fhandle_sz)       /* shorthand */
39 #define NFS3_sattr_sz           (15)
40 #define NFS3_filename_sz        (1+(NFS3_MAXNAMLEN>>2))
41 #define NFS3_path_sz            (1+(NFS3_MAXPATHLEN>>2))
42 #define NFS3_fattr_sz           (21)
43 #define NFS3_wcc_attr_sz                (6)
44 #define NFS3_pre_op_attr_sz     (1+NFS3_wcc_attr_sz)
45 #define NFS3_post_op_attr_sz    (1+NFS3_fattr_sz)
46 #define NFS3_wcc_data_sz                (NFS3_pre_op_attr_sz+NFS3_post_op_attr_sz)
47 #define NFS3_fsstat_sz          
48 #define NFS3_fsinfo_sz          
49 #define NFS3_pathconf_sz                
50 #define NFS3_entry_sz           (NFS3_filename_sz+3)
51
52 #define NFS3_sattrargs_sz       (NFS3_fh_sz+NFS3_sattr_sz+3)
53 #define NFS3_diropargs_sz       (NFS3_fh_sz+NFS3_filename_sz)
54 #define NFS3_accessargs_sz      (NFS3_fh_sz+1)
55 #define NFS3_readlinkargs_sz    (NFS3_fh_sz)
56 #define NFS3_readargs_sz        (NFS3_fh_sz+3)
57 #define NFS3_writeargs_sz       (NFS3_fh_sz+5)
58 #define NFS3_createargs_sz      (NFS3_diropargs_sz+NFS3_sattr_sz)
59 #define NFS3_mkdirargs_sz       (NFS3_diropargs_sz+NFS3_sattr_sz)
60 #define NFS3_symlinkargs_sz     (NFS3_diropargs_sz+NFS3_path_sz+NFS3_sattr_sz)
61 #define NFS3_mknodargs_sz       (NFS3_diropargs_sz+2+NFS3_sattr_sz)
62 #define NFS3_renameargs_sz      (NFS3_diropargs_sz+NFS3_diropargs_sz)
63 #define NFS3_linkargs_sz                (NFS3_fh_sz+NFS3_diropargs_sz)
64 #define NFS3_readdirargs_sz     (NFS3_fh_sz+2)
65 #define NFS3_commitargs_sz      (NFS3_fh_sz+3)
66
67 #define NFS3_attrstat_sz        (1+NFS3_fattr_sz)
68 #define NFS3_wccstat_sz         (1+NFS3_wcc_data_sz)
69 #define NFS3_lookupres_sz       (1+NFS3_fh_sz+(2 * NFS3_post_op_attr_sz))
70 #define NFS3_accessres_sz       (1+NFS3_post_op_attr_sz+1)
71 #define NFS3_readlinkres_sz     (1+NFS3_post_op_attr_sz+1)
72 #define NFS3_readres_sz         (1+NFS3_post_op_attr_sz+3)
73 #define NFS3_writeres_sz        (1+NFS3_wcc_data_sz+4)
74 #define NFS3_createres_sz       (1+NFS3_fh_sz+NFS3_post_op_attr_sz+NFS3_wcc_data_sz)
75 #define NFS3_renameres_sz       (1+(2 * NFS3_wcc_data_sz))
76 #define NFS3_linkres_sz         (1+NFS3_post_op_attr_sz+NFS3_wcc_data_sz)
77 #define NFS3_readdirres_sz      (1+NFS3_post_op_attr_sz+2)
78 #define NFS3_fsstatres_sz       (1+NFS3_post_op_attr_sz+13)
79 #define NFS3_fsinfores_sz       (1+NFS3_post_op_attr_sz+12)
80 #define NFS3_pathconfres_sz     (1+NFS3_post_op_attr_sz+6)
81 #define NFS3_commitres_sz       (1+NFS3_wcc_data_sz+2)
82
83 #define ACL3_getaclargs_sz      (NFS3_fh_sz+1)
84 #define ACL3_setaclargs_sz      (NFS3_fh_sz+1+2*(2+5*3))
85 #define ACL3_getaclres_sz       (1+NFS3_post_op_attr_sz+1+2*(2+5*3))
86 #define ACL3_setaclres_sz       (1+NFS3_post_op_attr_sz)
87
88 /*
89  * Map file type to S_IFMT bits
90  */
91 static struct {
92         unsigned int    mode;
93         unsigned int    nfs2type;
94 } nfs_type2fmt[] = {
95       { 0,              NFNON   },
96       { S_IFREG,        NFREG   },
97       { S_IFDIR,        NFDIR   },
98       { S_IFBLK,        NFBLK   },
99       { S_IFCHR,        NFCHR   },
100       { S_IFLNK,        NFLNK   },
101       { S_IFSOCK,       NFSOCK  },
102       { S_IFIFO,        NFFIFO  },
103       { 0,              NFBAD   }
104 };
105
106 /*
107  * Common NFS XDR functions as inlines
108  */
109 static inline u32 *
110 xdr_encode_fhandle(u32 *p, struct nfs_fh *fh)
111 {
112         return xdr_encode_array(p, fh->data, fh->size);
113 }
114
115 static inline u32 *
116 xdr_decode_fhandle(u32 *p, struct nfs_fh *fh)
117 {
118         if ((fh->size = ntohl(*p++)) <= NFS3_FHSIZE) {
119                 memcpy(fh->data, p, fh->size);
120                 return p + XDR_QUADLEN(fh->size);
121         }
122         return NULL;
123 }
124
125 /*
126  * Encode/decode time.
127  */
128 static inline u32 *
129 xdr_encode_time3(u32 *p, struct timespec *timep)
130 {
131         *p++ = htonl(timep->tv_sec);
132         *p++ = htonl(timep->tv_nsec);
133         return p;
134 }
135
136 static inline u32 *
137 xdr_decode_time3(u32 *p, struct timespec *timep)
138 {
139         timep->tv_sec = ntohl(*p++);
140         timep->tv_nsec = ntohl(*p++);
141         return p;
142 }
143
144 static u32 *
145 xdr_decode_fattr(u32 *p, struct nfs_fattr *fattr)
146 {
147         unsigned int    type, major, minor;
148         int             fmode;
149
150         type = ntohl(*p++);
151         if (type >= NF3BAD)
152                 type = NF3BAD;
153         fmode = nfs_type2fmt[type].mode;
154         fattr->type = nfs_type2fmt[type].nfs2type;
155         fattr->mode = (ntohl(*p++) & ~S_IFMT) | fmode;
156         fattr->nlink = ntohl(*p++);
157         fattr->uid = ntohl(*p++);
158         fattr->gid = ntohl(*p++);
159         p = xdr_decode_hyper(p, &fattr->size);
160         p = xdr_decode_hyper(p, &fattr->du.nfs3.used);
161
162         /* Turn remote device info into Linux-specific dev_t */
163         major = ntohl(*p++);
164         minor = ntohl(*p++);
165         fattr->rdev = MKDEV(major, minor);
166         if (MAJOR(fattr->rdev) != major || MINOR(fattr->rdev) != minor)
167                 fattr->rdev = 0;
168
169         p = xdr_decode_hyper(p, &fattr->fsid_u.nfs3);
170         p = xdr_decode_hyper(p, &fattr->fileid);
171         p = xdr_decode_time3(p, &fattr->atime);
172         p = xdr_decode_time3(p, &fattr->mtime);
173         p = xdr_decode_time3(p, &fattr->ctime);
174
175         /* Update the mode bits */
176         fattr->valid |= (NFS_ATTR_FATTR | NFS_ATTR_FATTR_V3);
177         fattr->timestamp = jiffies;
178         return p;
179 }
180
181 static inline u32 *
182 xdr_encode_sattr(u32 *p, struct iattr *attr)
183 {
184         if (attr->ia_valid & ATTR_MODE) {
185                 *p++ = xdr_one;
186                 *p++ = htonl(attr->ia_mode);
187         } else {
188                 *p++ = xdr_zero;
189         }
190         if (attr->ia_valid & ATTR_UID) {
191                 *p++ = xdr_one;
192                 *p++ = htonl(attr->ia_uid);
193         } else {
194                 *p++ = xdr_zero;
195         }
196         if (attr->ia_valid & ATTR_GID) {
197                 *p++ = xdr_one;
198                 *p++ = htonl(attr->ia_gid);
199         } else {
200                 *p++ = xdr_zero;
201         }
202         if (attr->ia_valid & ATTR_SIZE) {
203                 *p++ = xdr_one;
204                 p = xdr_encode_hyper(p, (__u64) attr->ia_size);
205         } else {
206                 *p++ = xdr_zero;
207         }
208         if (attr->ia_valid & ATTR_ATIME_SET) {
209                 *p++ = xdr_two;
210                 p = xdr_encode_time3(p, &attr->ia_atime);
211         } else if (attr->ia_valid & ATTR_ATIME) {
212                 *p++ = xdr_one;
213         } else {
214                 *p++ = xdr_zero;
215         }
216         if (attr->ia_valid & ATTR_MTIME_SET) {
217                 *p++ = xdr_two;
218                 p = xdr_encode_time3(p, &attr->ia_mtime);
219         } else if (attr->ia_valid & ATTR_MTIME) {
220                 *p++ = xdr_one;
221         } else {
222                 *p++ = xdr_zero;
223         }
224         return p;
225 }
226
227 static inline u32 *
228 xdr_decode_wcc_attr(u32 *p, struct nfs_fattr *fattr)
229 {
230         p = xdr_decode_hyper(p, &fattr->pre_size);
231         p = xdr_decode_time3(p, &fattr->pre_mtime);
232         p = xdr_decode_time3(p, &fattr->pre_ctime);
233         fattr->valid |= NFS_ATTR_WCC;
234         return p;
235 }
236
237 static inline u32 *
238 xdr_decode_post_op_attr(u32 *p, struct nfs_fattr *fattr)
239 {
240         if (*p++)
241                 p = xdr_decode_fattr(p, fattr);
242         return p;
243 }
244
245 static inline u32 *
246 xdr_decode_pre_op_attr(u32 *p, struct nfs_fattr *fattr)
247 {
248         if (*p++)
249                 return xdr_decode_wcc_attr(p, fattr);
250         return p;
251 }
252
253
254 static inline u32 *
255 xdr_decode_wcc_data(u32 *p, struct nfs_fattr *fattr)
256 {
257         p = xdr_decode_pre_op_attr(p, fattr);
258         return xdr_decode_post_op_attr(p, fattr);
259 }
260
261 /*
262  * NFS encode functions
263  */
264
265 /*
266  * Encode file handle argument
267  */
268 static int
269 nfs3_xdr_fhandle(struct rpc_rqst *req, u32 *p, struct nfs_fh *fh)
270 {
271         p = xdr_encode_fhandle(p, fh);
272         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
273         return 0;
274 }
275
276 /*
277  * Encode SETATTR arguments
278  */
279 static int
280 nfs3_xdr_sattrargs(struct rpc_rqst *req, u32 *p, struct nfs3_sattrargs *args)
281 {
282         p = xdr_encode_fhandle(p, args->fh);
283         p = xdr_encode_sattr(p, args->sattr);
284         *p++ = htonl(args->guard);
285         if (args->guard)
286                 p = xdr_encode_time3(p, &args->guardtime);
287         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
288         return 0;
289 }
290
291 /*
292  * Encode directory ops argument
293  */
294 static int
295 nfs3_xdr_diropargs(struct rpc_rqst *req, u32 *p, struct nfs3_diropargs *args)
296 {
297         p = xdr_encode_fhandle(p, args->fh);
298         p = xdr_encode_array(p, args->name, args->len);
299         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
300         return 0;
301 }
302
303 /*
304  * Encode access() argument
305  */
306 static int
307 nfs3_xdr_accessargs(struct rpc_rqst *req, u32 *p, struct nfs3_accessargs *args)
308 {
309         p = xdr_encode_fhandle(p, args->fh);
310         *p++ = htonl(args->access);
311         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
312         return 0;
313 }
314
315 /*
316  * Arguments to a READ call. Since we read data directly into the page
317  * cache, we also set up the reply iovec here so that iov[1] points
318  * exactly to the page we want to fetch.
319  */
320 static int
321 nfs3_xdr_readargs(struct rpc_rqst *req, u32 *p, struct nfs_readargs *args)
322 {
323         struct rpc_auth *auth = req->rq_task->tk_auth;
324         unsigned int replen;
325         u32 count = args->count;
326
327         p = xdr_encode_fhandle(p, args->fh);
328         p = xdr_encode_hyper(p, args->offset);
329         *p++ = htonl(count);
330         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
331
332         /* Inline the page array */
333         replen = (RPC_REPHDRSIZE + auth->au_rslack + NFS3_readres_sz) << 2;
334         xdr_inline_pages(&req->rq_rcv_buf, replen,
335                          args->pages, args->pgbase, count);
336         return 0;
337 }
338
339 /*
340  * Write arguments. Splice the buffer to be written into the iovec.
341  */
342 static int
343 nfs3_xdr_writeargs(struct rpc_rqst *req, u32 *p, struct nfs_writeargs *args)
344 {
345         struct xdr_buf *sndbuf = &req->rq_snd_buf;
346         u32 count = args->count;
347
348         p = xdr_encode_fhandle(p, args->fh);
349         p = xdr_encode_hyper(p, args->offset);
350         *p++ = htonl(count);
351         *p++ = htonl(args->stable);
352         *p++ = htonl(count);
353         sndbuf->len = xdr_adjust_iovec(sndbuf->head, p);
354
355         /* Copy the page array */
356         xdr_encode_pages(sndbuf, args->pages, args->pgbase, count);
357         return 0;
358 }
359
360 /*
361  * Encode CREATE arguments
362  */
363 static int
364 nfs3_xdr_createargs(struct rpc_rqst *req, u32 *p, struct nfs3_createargs *args)
365 {
366         p = xdr_encode_fhandle(p, args->fh);
367         p = xdr_encode_array(p, args->name, args->len);
368
369         *p++ = htonl(args->createmode);
370         if (args->createmode == NFS3_CREATE_EXCLUSIVE) {
371                 *p++ = args->verifier[0];
372                 *p++ = args->verifier[1];
373         } else
374                 p = xdr_encode_sattr(p, args->sattr);
375
376         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
377         return 0;
378 }
379
380 /*
381  * Encode MKDIR arguments
382  */
383 static int
384 nfs3_xdr_mkdirargs(struct rpc_rqst *req, u32 *p, struct nfs3_mkdirargs *args)
385 {
386         p = xdr_encode_fhandle(p, args->fh);
387         p = xdr_encode_array(p, args->name, args->len);
388         p = xdr_encode_sattr(p, args->sattr);
389         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
390         return 0;
391 }
392
393 /*
394  * Encode SYMLINK arguments
395  */
396 static int
397 nfs3_xdr_symlinkargs(struct rpc_rqst *req, u32 *p, struct nfs3_symlinkargs *args)
398 {
399         p = xdr_encode_fhandle(p, args->fromfh);
400         p = xdr_encode_array(p, args->fromname, args->fromlen);
401         p = xdr_encode_sattr(p, args->sattr);
402         p = xdr_encode_array(p, args->topath, args->tolen);
403         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
404         return 0;
405 }
406
407 /*
408  * Encode MKNOD arguments
409  */
410 static int
411 nfs3_xdr_mknodargs(struct rpc_rqst *req, u32 *p, struct nfs3_mknodargs *args)
412 {
413         p = xdr_encode_fhandle(p, args->fh);
414         p = xdr_encode_array(p, args->name, args->len);
415         *p++ = htonl(args->type);
416         p = xdr_encode_sattr(p, args->sattr);
417         if (args->type == NF3CHR || args->type == NF3BLK) {
418                 *p++ = htonl(MAJOR(args->rdev));
419                 *p++ = htonl(MINOR(args->rdev));
420         }
421
422         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
423         return 0;
424 }
425
426 /*
427  * Encode RENAME arguments
428  */
429 static int
430 nfs3_xdr_renameargs(struct rpc_rqst *req, u32 *p, struct nfs3_renameargs *args)
431 {
432         p = xdr_encode_fhandle(p, args->fromfh);
433         p = xdr_encode_array(p, args->fromname, args->fromlen);
434         p = xdr_encode_fhandle(p, args->tofh);
435         p = xdr_encode_array(p, args->toname, args->tolen);
436         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
437         return 0;
438 }
439
440 /*
441  * Encode LINK arguments
442  */
443 static int
444 nfs3_xdr_linkargs(struct rpc_rqst *req, u32 *p, struct nfs3_linkargs *args)
445 {
446         p = xdr_encode_fhandle(p, args->fromfh);
447         p = xdr_encode_fhandle(p, args->tofh);
448         p = xdr_encode_array(p, args->toname, args->tolen);
449         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
450         return 0;
451 }
452
453 /*
454  * Encode arguments to readdir call
455  */
456 static int
457 nfs3_xdr_readdirargs(struct rpc_rqst *req, u32 *p, struct nfs3_readdirargs *args)
458 {
459         struct rpc_auth *auth = req->rq_task->tk_auth;
460         unsigned int replen;
461         u32 count = args->count;
462
463         p = xdr_encode_fhandle(p, args->fh);
464         p = xdr_encode_hyper(p, args->cookie);
465         *p++ = args->verf[0];
466         *p++ = args->verf[1];
467         if (args->plus) {
468                 /* readdirplus: need dircount + buffer size.
469                  * We just make sure we make dircount big enough */
470                 *p++ = htonl(count >> 3);
471         }
472         *p++ = htonl(count);
473         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
474
475         /* Inline the page array */
476         replen = (RPC_REPHDRSIZE + auth->au_rslack + NFS3_readdirres_sz) << 2;
477         xdr_inline_pages(&req->rq_rcv_buf, replen, args->pages, 0, count);
478         return 0;
479 }
480
481 /*
482  * Decode the result of a readdir call.
483  * We just check for syntactical correctness.
484  */
485 static int
486 nfs3_xdr_readdirres(struct rpc_rqst *req, u32 *p, struct nfs3_readdirres *res)
487 {
488         struct xdr_buf *rcvbuf = &req->rq_rcv_buf;
489         struct kvec *iov = rcvbuf->head;
490         struct page **page;
491         int hdrlen, recvd;
492         int status, nr;
493         unsigned int len, pglen;
494         u32 *entry, *end, *kaddr;
495
496         status = ntohl(*p++);
497         /* Decode post_op_attrs */
498         p = xdr_decode_post_op_attr(p, res->dir_attr);
499         if (status)
500                 return -nfs_stat_to_errno(status);
501         /* Decode verifier cookie */
502         if (res->verf) {
503                 res->verf[0] = *p++;
504                 res->verf[1] = *p++;
505         } else {
506                 p += 2;
507         }
508
509         hdrlen = (u8 *) p - (u8 *) iov->iov_base;
510         if (iov->iov_len < hdrlen) {
511                 printk(KERN_WARNING "NFS: READDIR reply header overflowed:"
512                                 "length %d > %Zu\n", hdrlen, iov->iov_len);
513                 return -errno_NFSERR_IO;
514         } else if (iov->iov_len != hdrlen) {
515                 dprintk("NFS: READDIR header is short. iovec will be shifted.\n");
516                 xdr_shift_buf(rcvbuf, iov->iov_len - hdrlen);
517         }
518
519         pglen = rcvbuf->page_len;
520         recvd = rcvbuf->len - hdrlen;
521         if (pglen > recvd)
522                 pglen = recvd;
523         page = rcvbuf->pages;
524         kaddr = p = (u32 *)kmap_atomic(*page, KM_USER0);
525         end = (u32 *)((char *)p + pglen);
526         entry = p;
527         for (nr = 0; *p++; nr++) {
528                 if (p + 3 > end)
529                         goto short_pkt;
530                 p += 2;                         /* inode # */
531                 len = ntohl(*p++);              /* string length */
532                 p += XDR_QUADLEN(len) + 2;      /* name + cookie */
533                 if (len > NFS3_MAXNAMLEN) {
534                         printk(KERN_WARNING "NFS: giant filename in readdir (len %x)!\n",
535                                                 len);
536                         goto err_unmap;
537                 }
538
539                 if (res->plus) {
540                         /* post_op_attr */
541                         if (p + 2 > end)
542                                 goto short_pkt;
543                         if (*p++) {
544                                 p += 21;
545                                 if (p + 1 > end)
546                                         goto short_pkt;
547                         }
548                         /* post_op_fh3 */
549                         if (*p++) {
550                                 if (p + 1 > end)
551                                         goto short_pkt;
552                                 len = ntohl(*p++);
553                                 if (len > NFS3_FHSIZE) {
554                                         printk(KERN_WARNING "NFS: giant filehandle in "
555                                                 "readdir (len %x)!\n", len);
556                                         goto err_unmap;
557                                 }
558                                 p += XDR_QUADLEN(len);
559                         }
560                 }
561
562                 if (p + 2 > end)
563                         goto short_pkt;
564                 entry = p;
565         }
566         if (!nr && (entry[0] != 0 || entry[1] == 0))
567                 goto short_pkt;
568  out:
569         kunmap_atomic(kaddr, KM_USER0);
570         return nr;
571  short_pkt:
572         entry[0] = entry[1] = 0;
573         /* truncate listing ? */
574         if (!nr) {
575                 printk(KERN_NOTICE "NFS: readdir reply truncated!\n");
576                 entry[1] = 1;
577         }
578         goto out;
579 err_unmap:
580         nr = -errno_NFSERR_IO;
581         goto out;
582 }
583
584 u32 *
585 nfs3_decode_dirent(u32 *p, struct nfs_entry *entry, int plus)
586 {
587         struct nfs_entry old = *entry;
588
589         if (!*p++) {
590                 if (!*p)
591                         return ERR_PTR(-EAGAIN);
592                 entry->eof = 1;
593                 return ERR_PTR(-EBADCOOKIE);
594         }
595
596         p = xdr_decode_hyper(p, &entry->ino);
597         entry->len  = ntohl(*p++);
598         entry->name = (const char *) p;
599         p += XDR_QUADLEN(entry->len);
600         entry->prev_cookie = entry->cookie;
601         p = xdr_decode_hyper(p, &entry->cookie);
602
603         if (plus) {
604                 entry->fattr->valid = 0;
605                 p = xdr_decode_post_op_attr(p, entry->fattr);
606                 /* In fact, a post_op_fh3: */
607                 if (*p++) {
608                         p = xdr_decode_fhandle(p, entry->fh);
609                         /* Ugh -- server reply was truncated */
610                         if (p == NULL) {
611                                 dprintk("NFS: FH truncated\n");
612                                 *entry = old;
613                                 return ERR_PTR(-EAGAIN);
614                         }
615                 } else
616                         memset((u8*)(entry->fh), 0, sizeof(*entry->fh));
617         }
618
619         entry->eof = !p[0] && p[1];
620         return p;
621 }
622
623 /*
624  * Encode COMMIT arguments
625  */
626 static int
627 nfs3_xdr_commitargs(struct rpc_rqst *req, u32 *p, struct nfs_writeargs *args)
628 {
629         p = xdr_encode_fhandle(p, args->fh);
630         p = xdr_encode_hyper(p, args->offset);
631         *p++ = htonl(args->count);
632         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
633         return 0;
634 }
635
636 #ifdef CONFIG_NFS_V3_ACL
637 /*
638  * Encode GETACL arguments
639  */
640 static int
641 nfs3_xdr_getaclargs(struct rpc_rqst *req, u32 *p,
642                     struct nfs3_getaclargs *args)
643 {
644         struct rpc_auth *auth = req->rq_task->tk_auth;
645         unsigned int replen;
646
647         p = xdr_encode_fhandle(p, args->fh);
648         *p++ = htonl(args->mask);
649         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
650
651         if (args->mask & (NFS_ACL | NFS_DFACL)) {
652                 /* Inline the page array */
653                 replen = (RPC_REPHDRSIZE + auth->au_rslack +
654                           ACL3_getaclres_sz) << 2;
655                 xdr_inline_pages(&req->rq_rcv_buf, replen, args->pages, 0,
656                                  NFSACL_MAXPAGES << PAGE_SHIFT);
657         }
658         return 0;
659 }
660
661 /*
662  * Encode SETACL arguments
663  */
664 static int
665 nfs3_xdr_setaclargs(struct rpc_rqst *req, u32 *p,
666                    struct nfs3_setaclargs *args)
667 {
668         struct xdr_buf *buf = &req->rq_snd_buf;
669         unsigned int base, len_in_head, len = nfsacl_size(
670                 (args->mask & NFS_ACL)   ? args->acl_access  : NULL,
671                 (args->mask & NFS_DFACL) ? args->acl_default : NULL);
672         int count, err;
673
674         p = xdr_encode_fhandle(p, NFS_FH(args->inode));
675         *p++ = htonl(args->mask);
676         base = (char *)p - (char *)buf->head->iov_base;
677         /* put as much of the acls into head as possible. */
678         len_in_head = min_t(unsigned int, buf->head->iov_len - base, len);
679         len -= len_in_head;
680         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p + len_in_head);
681
682         for (count = 0; (count << PAGE_SHIFT) < len; count++) {
683                 args->pages[count] = alloc_page(GFP_KERNEL);
684                 if (!args->pages[count]) {
685                         while (count)
686                                 __free_page(args->pages[--count]);
687                         return -ENOMEM;
688                 }
689         }
690         xdr_encode_pages(buf, args->pages, 0, len);
691
692         err = nfsacl_encode(buf, base, args->inode,
693                             (args->mask & NFS_ACL) ?
694                             args->acl_access : NULL, 1, 0);
695         if (err > 0)
696                 err = nfsacl_encode(buf, base + err, args->inode,
697                                     (args->mask & NFS_DFACL) ?
698                                     args->acl_default : NULL, 1,
699                                     NFS_ACL_DEFAULT);
700         return (err > 0) ? 0 : err;
701 }
702 #endif  /* CONFIG_NFS_V3_ACL */
703
704 /*
705  * NFS XDR decode functions
706  */
707
708 /*
709  * Decode attrstat reply.
710  */
711 static int
712 nfs3_xdr_attrstat(struct rpc_rqst *req, u32 *p, struct nfs_fattr *fattr)
713 {
714         int     status;
715
716         if ((status = ntohl(*p++)))
717                 return -nfs_stat_to_errno(status);
718         xdr_decode_fattr(p, fattr);
719         return 0;
720 }
721
722 /*
723  * Decode status+wcc_data reply
724  * SATTR, REMOVE, RMDIR
725  */
726 static int
727 nfs3_xdr_wccstat(struct rpc_rqst *req, u32 *p, struct nfs_fattr *fattr)
728 {
729         int     status;
730
731         if ((status = ntohl(*p++)))
732                 status = -nfs_stat_to_errno(status);
733         xdr_decode_wcc_data(p, fattr);
734         return status;
735 }
736
737 /*
738  * Decode LOOKUP reply
739  */
740 static int
741 nfs3_xdr_lookupres(struct rpc_rqst *req, u32 *p, struct nfs3_diropres *res)
742 {
743         int     status;
744
745         if ((status = ntohl(*p++))) {
746                 status = -nfs_stat_to_errno(status);
747         } else {
748                 if (!(p = xdr_decode_fhandle(p, res->fh)))
749                         return -errno_NFSERR_IO;
750                 p = xdr_decode_post_op_attr(p, res->fattr);
751         }
752         xdr_decode_post_op_attr(p, res->dir_attr);
753         return status;
754 }
755
756 /*
757  * Decode ACCESS reply
758  */
759 static int
760 nfs3_xdr_accessres(struct rpc_rqst *req, u32 *p, struct nfs3_accessres *res)
761 {
762         int     status = ntohl(*p++);
763
764         p = xdr_decode_post_op_attr(p, res->fattr);
765         if (status)
766                 return -nfs_stat_to_errno(status);
767         res->access = ntohl(*p++);
768         return 0;
769 }
770
771 static int
772 nfs3_xdr_readlinkargs(struct rpc_rqst *req, u32 *p, struct nfs3_readlinkargs *args)
773 {
774         struct rpc_auth *auth = req->rq_task->tk_auth;
775         unsigned int replen;
776
777         p = xdr_encode_fhandle(p, args->fh);
778         req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
779
780         /* Inline the page array */
781         replen = (RPC_REPHDRSIZE + auth->au_rslack + NFS3_readlinkres_sz) << 2;
782         xdr_inline_pages(&req->rq_rcv_buf, replen, args->pages, args->pgbase, args->pglen);
783         return 0;
784 }
785
786 /*
787  * Decode READLINK reply
788  */
789 static int
790 nfs3_xdr_readlinkres(struct rpc_rqst *req, u32 *p, struct nfs_fattr *fattr)
791 {
792         struct xdr_buf *rcvbuf = &req->rq_rcv_buf;
793         struct kvec *iov = rcvbuf->head;
794         int hdrlen, len, recvd;
795         char    *kaddr;
796         int     status;
797
798         status = ntohl(*p++);
799         p = xdr_decode_post_op_attr(p, fattr);
800
801         if (status != 0)
802                 return -nfs_stat_to_errno(status);
803
804         /* Convert length of symlink */
805         len = ntohl(*p++);
806         if (len >= rcvbuf->page_len || len <= 0) {
807                 dprintk(KERN_WARNING "nfs: server returned giant symlink!\n");
808                 return -ENAMETOOLONG;
809         }
810
811         hdrlen = (u8 *) p - (u8 *) iov->iov_base;
812         if (iov->iov_len < hdrlen) {
813                 printk(KERN_WARNING "NFS: READLINK reply header overflowed:"
814                                 "length %d > %Zu\n", hdrlen, iov->iov_len);
815                 return -errno_NFSERR_IO;
816         } else if (iov->iov_len != hdrlen) {
817                 dprintk("NFS: READLINK header is short. iovec will be shifted.\n");
818                 xdr_shift_buf(rcvbuf, iov->iov_len - hdrlen);
819         }
820         recvd = req->rq_rcv_buf.len - hdrlen;
821         if (recvd < len) {
822                 printk(KERN_WARNING "NFS: server cheating in readlink reply: "
823                                 "count %u > recvd %u\n", len, recvd);
824                 return -EIO;
825         }
826
827         /* NULL terminate the string we got */
828         kaddr = (char*)kmap_atomic(rcvbuf->pages[0], KM_USER0);
829         kaddr[len+rcvbuf->page_base] = '\0';
830         kunmap_atomic(kaddr, KM_USER0);
831         return 0;
832 }
833
834 /*
835  * Decode READ reply
836  */
837 static int
838 nfs3_xdr_readres(struct rpc_rqst *req, u32 *p, struct nfs_readres *res)
839 {
840         struct kvec *iov = req->rq_rcv_buf.head;
841         int     status, count, ocount, recvd, hdrlen;
842
843         status = ntohl(*p++);
844         p = xdr_decode_post_op_attr(p, res->fattr);
845
846         if (status != 0)
847                 return -nfs_stat_to_errno(status);
848
849         /* Decode reply could and EOF flag. NFSv3 is somewhat redundant
850          * in that it puts the count both in the res struct and in the
851          * opaque data count. */
852         count    = ntohl(*p++);
853         res->eof = ntohl(*p++);
854         ocount   = ntohl(*p++);
855
856         if (ocount != count) {
857                 printk(KERN_WARNING "NFS: READ count doesn't match RPC opaque count.\n");
858                 return -errno_NFSERR_IO;
859         }
860
861         hdrlen = (u8 *) p - (u8 *) iov->iov_base;
862         if (iov->iov_len < hdrlen) {
863                 printk(KERN_WARNING "NFS: READ reply header overflowed:"
864                                 "length %d > %Zu\n", hdrlen, iov->iov_len);
865                 return -errno_NFSERR_IO;
866         } else if (iov->iov_len != hdrlen) {
867                 dprintk("NFS: READ header is short. iovec will be shifted.\n");
868                 xdr_shift_buf(&req->rq_rcv_buf, iov->iov_len - hdrlen);
869         }
870
871         recvd = req->rq_rcv_buf.len - hdrlen;
872         if (count > recvd) {
873                 printk(KERN_WARNING "NFS: server cheating in read reply: "
874                         "count %d > recvd %d\n", count, recvd);
875                 count = recvd;
876                 res->eof = 0;
877         }
878
879         if (count < res->count)
880                 res->count = count;
881
882         return count;
883 }
884
885 /*
886  * Decode WRITE response
887  */
888 static int
889 nfs3_xdr_writeres(struct rpc_rqst *req, u32 *p, struct nfs_writeres *res)
890 {
891         int     status;
892
893         status = ntohl(*p++);
894         p = xdr_decode_wcc_data(p, res->fattr);
895
896         if (status != 0)
897                 return -nfs_stat_to_errno(status);
898
899         res->count = ntohl(*p++);
900         res->verf->committed = (enum nfs3_stable_how)ntohl(*p++);
901         res->verf->verifier[0] = *p++;
902         res->verf->verifier[1] = *p++;
903
904         return res->count;
905 }
906
907 /*
908  * Decode a CREATE response
909  */
910 static int
911 nfs3_xdr_createres(struct rpc_rqst *req, u32 *p, struct nfs3_diropres *res)
912 {
913         int     status;
914
915         status = ntohl(*p++);
916         if (status == 0) {
917                 if (*p++) {
918                         if (!(p = xdr_decode_fhandle(p, res->fh)))
919                                 return -errno_NFSERR_IO;
920                         p = xdr_decode_post_op_attr(p, res->fattr);
921                 } else {
922                         memset(res->fh, 0, sizeof(*res->fh));
923                         /* Do decode post_op_attr but set it to NULL */
924                         p = xdr_decode_post_op_attr(p, res->fattr);
925                         res->fattr->valid = 0;
926                 }
927         } else {
928                 status = -nfs_stat_to_errno(status);
929         }
930         p = xdr_decode_wcc_data(p, res->dir_attr);
931         return status;
932 }
933
934 /*
935  * Decode RENAME reply
936  */
937 static int
938 nfs3_xdr_renameres(struct rpc_rqst *req, u32 *p, struct nfs3_renameres *res)
939 {
940         int     status;
941
942         if ((status = ntohl(*p++)) != 0)
943                 status = -nfs_stat_to_errno(status);
944         p = xdr_decode_wcc_data(p, res->fromattr);
945         p = xdr_decode_wcc_data(p, res->toattr);
946         return status;
947 }
948
949 /*
950  * Decode LINK reply
951  */
952 static int
953 nfs3_xdr_linkres(struct rpc_rqst *req, u32 *p, struct nfs3_linkres *res)
954 {
955         int     status;
956
957         if ((status = ntohl(*p++)) != 0)
958                 status = -nfs_stat_to_errno(status);
959         p = xdr_decode_post_op_attr(p, res->fattr);
960         p = xdr_decode_wcc_data(p, res->dir_attr);
961         return status;
962 }
963
964 /*
965  * Decode FSSTAT reply
966  */
967 static int
968 nfs3_xdr_fsstatres(struct rpc_rqst *req, u32 *p, struct nfs_fsstat *res)
969 {
970         int             status;
971
972         status = ntohl(*p++);
973
974         p = xdr_decode_post_op_attr(p, res->fattr);
975         if (status != 0)
976                 return -nfs_stat_to_errno(status);
977
978         p = xdr_decode_hyper(p, &res->tbytes);
979         p = xdr_decode_hyper(p, &res->fbytes);
980         p = xdr_decode_hyper(p, &res->abytes);
981         p = xdr_decode_hyper(p, &res->tfiles);
982         p = xdr_decode_hyper(p, &res->ffiles);
983         p = xdr_decode_hyper(p, &res->afiles);
984
985         /* ignore invarsec */
986         return 0;
987 }
988
989 /*
990  * Decode FSINFO reply
991  */
992 static int
993 nfs3_xdr_fsinfores(struct rpc_rqst *req, u32 *p, struct nfs_fsinfo *res)
994 {
995         int             status;
996
997         status = ntohl(*p++);
998
999         p = xdr_decode_post_op_attr(p, res->fattr);
1000         if (status != 0)
1001                 return -nfs_stat_to_errno(status);
1002
1003         res->rtmax  = ntohl(*p++);
1004         res->rtpref = ntohl(*p++);
1005         res->rtmult = ntohl(*p++);
1006         res->wtmax  = ntohl(*p++);
1007         res->wtpref = ntohl(*p++);
1008         res->wtmult = ntohl(*p++);
1009         res->dtpref = ntohl(*p++);
1010         p = xdr_decode_hyper(p, &res->maxfilesize);
1011
1012         /* ignore time_delta and properties */
1013         res->lease_time = 0;
1014         return 0;
1015 }
1016
1017 /*
1018  * Decode PATHCONF reply
1019  */
1020 static int
1021 nfs3_xdr_pathconfres(struct rpc_rqst *req, u32 *p, struct nfs_pathconf *res)
1022 {
1023         int             status;
1024
1025         status = ntohl(*p++);
1026
1027         p = xdr_decode_post_op_attr(p, res->fattr);
1028         if (status != 0)
1029                 return -nfs_stat_to_errno(status);
1030         res->max_link = ntohl(*p++);
1031         res->max_namelen = ntohl(*p++);
1032
1033         /* ignore remaining fields */
1034         return 0;
1035 }
1036
1037 /*
1038  * Decode COMMIT reply
1039  */
1040 static int
1041 nfs3_xdr_commitres(struct rpc_rqst *req, u32 *p, struct nfs_writeres *res)
1042 {
1043         int             status;
1044
1045         status = ntohl(*p++);
1046         p = xdr_decode_wcc_data(p, res->fattr);
1047         if (status != 0)
1048                 return -nfs_stat_to_errno(status);
1049
1050         res->verf->verifier[0] = *p++;
1051         res->verf->verifier[1] = *p++;
1052         return 0;
1053 }
1054
1055 #ifdef CONFIG_NFS_V3_ACL
1056 /*
1057  * Decode GETACL reply
1058  */
1059 static int
1060 nfs3_xdr_getaclres(struct rpc_rqst *req, u32 *p,
1061                    struct nfs3_getaclres *res)
1062 {
1063         struct xdr_buf *buf = &req->rq_rcv_buf;
1064         int status = ntohl(*p++);
1065         struct posix_acl **acl;
1066         unsigned int *aclcnt;
1067         int err, base;
1068
1069         if (status != 0)
1070                 return -nfs_stat_to_errno(status);
1071         p = xdr_decode_post_op_attr(p, res->fattr);
1072         res->mask = ntohl(*p++);
1073         if (res->mask & ~(NFS_ACL|NFS_ACLCNT|NFS_DFACL|NFS_DFACLCNT))
1074                 return -EINVAL;
1075         base = (char *)p - (char *)req->rq_rcv_buf.head->iov_base;
1076
1077         acl = (res->mask & NFS_ACL) ? &res->acl_access : NULL;
1078         aclcnt = (res->mask & NFS_ACLCNT) ? &res->acl_access_count : NULL;
1079         err = nfsacl_decode(buf, base, aclcnt, acl);
1080
1081         acl = (res->mask & NFS_DFACL) ? &res->acl_default : NULL;
1082         aclcnt = (res->mask & NFS_DFACLCNT) ? &res->acl_default_count : NULL;
1083         if (err > 0)
1084                 err = nfsacl_decode(buf, base + err, aclcnt, acl);
1085         return (err > 0) ? 0 : err;
1086 }
1087
1088 /*
1089  * Decode setacl reply.
1090  */
1091 static int
1092 nfs3_xdr_setaclres(struct rpc_rqst *req, u32 *p, struct nfs_fattr *fattr)
1093 {
1094         int status = ntohl(*p++);
1095
1096         if (status)
1097                 return -nfs_stat_to_errno(status);
1098         xdr_decode_post_op_attr(p, fattr);
1099         return 0;
1100 }
1101 #endif  /* CONFIG_NFS_V3_ACL */
1102
1103 #ifndef MAX
1104 # define MAX(a, b)      (((a) > (b))? (a) : (b))
1105 #endif
1106
1107 #define PROC(proc, argtype, restype, timer)                             \
1108 [NFS3PROC_##proc] = {                                                   \
1109         .p_proc      = NFS3PROC_##proc,                                 \
1110         .p_encode    = (kxdrproc_t) nfs3_xdr_##argtype,                 \
1111         .p_decode    = (kxdrproc_t) nfs3_xdr_##restype,                 \
1112         .p_bufsiz    = MAX(NFS3_##argtype##_sz,NFS3_##restype##_sz) << 2,       \
1113         .p_timer     = timer                                            \
1114         }
1115
1116 struct rpc_procinfo     nfs3_procedures[] = {
1117   PROC(GETATTR,         fhandle,        attrstat, 1),
1118   PROC(SETATTR,         sattrargs,      wccstat, 0),
1119   PROC(LOOKUP,          diropargs,      lookupres, 2),
1120   PROC(ACCESS,          accessargs,     accessres, 1),
1121   PROC(READLINK,        readlinkargs,   readlinkres, 3),
1122   PROC(READ,            readargs,       readres, 3),
1123   PROC(WRITE,           writeargs,      writeres, 4),
1124   PROC(CREATE,          createargs,     createres, 0),
1125   PROC(MKDIR,           mkdirargs,      createres, 0),
1126   PROC(SYMLINK,         symlinkargs,    createres, 0),
1127   PROC(MKNOD,           mknodargs,      createres, 0),
1128   PROC(REMOVE,          diropargs,      wccstat, 0),
1129   PROC(RMDIR,           diropargs,      wccstat, 0),
1130   PROC(RENAME,          renameargs,     renameres, 0),
1131   PROC(LINK,            linkargs,       linkres, 0),
1132   PROC(READDIR,         readdirargs,    readdirres, 3),
1133   PROC(READDIRPLUS,     readdirargs,    readdirres, 3),
1134   PROC(FSSTAT,          fhandle,        fsstatres, 0),
1135   PROC(FSINFO,          fhandle,        fsinfores, 0),
1136   PROC(PATHCONF,        fhandle,        pathconfres, 0),
1137   PROC(COMMIT,          commitargs,     commitres, 5),
1138 };
1139
1140 struct rpc_version              nfs_version3 = {
1141         .number                 = 3,
1142         .nrprocs                = sizeof(nfs3_procedures)/sizeof(nfs3_procedures[0]),
1143         .procs                  = nfs3_procedures
1144 };
1145
1146 #ifdef CONFIG_NFS_V3_ACL
1147 static struct rpc_procinfo      nfs3_acl_procedures[] = {
1148         [ACLPROC3_GETACL] = {
1149                 .p_proc = ACLPROC3_GETACL,
1150                 .p_encode = (kxdrproc_t) nfs3_xdr_getaclargs,
1151                 .p_decode = (kxdrproc_t) nfs3_xdr_getaclres,
1152                 .p_bufsiz = MAX(ACL3_getaclargs_sz, ACL3_getaclres_sz) << 2,
1153                 .p_timer = 1,
1154         },
1155         [ACLPROC3_SETACL] = {
1156                 .p_proc = ACLPROC3_SETACL,
1157                 .p_encode = (kxdrproc_t) nfs3_xdr_setaclargs,
1158                 .p_decode = (kxdrproc_t) nfs3_xdr_setaclres,
1159                 .p_bufsiz = MAX(ACL3_setaclargs_sz, ACL3_setaclres_sz) << 2,
1160                 .p_timer = 0,
1161         },
1162 };
1163
1164 struct rpc_version              nfsacl_version3 = {
1165         .number                 = 3,
1166         .nrprocs                = sizeof(nfs3_acl_procedures)/
1167                                   sizeof(nfs3_acl_procedures[0]),
1168         .procs                  = nfs3_acl_procedures,
1169 };
1170 #endif  /* CONFIG_NFS_V3_ACL */