blob: dcd673186944a22f48317c3ecf52e889d1357b86 [file] [log] [blame]
Linus Torvalds1da177e2005-04-16 15:20:36 -07001/*
2 * fs/nfs/nfs4xdr.c
3 *
4 * Server-side XDR for NFSv4
5 *
6 * Copyright (c) 2002 The Regents of the University of Michigan.
7 * All rights reserved.
8 *
9 * Kendrick Smith <kmsmith@umich.edu>
10 * Andy Adamson <andros@umich.edu>
11 *
12 * Redistribution and use in source and binary forms, with or without
13 * modification, are permitted provided that the following conditions
14 * are met:
15 *
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.
24 *
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.
36 *
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.
43 */
44
45#include <linux/param.h>
46#include <linux/smp.h>
47#include <linux/smp_lock.h>
48#include <linux/fs.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>
60
61#define NFSDDBG_FACILITY NFSDDBG_XDR
62
63static int
64check_filename(char *str, int len, int err)
65{
66 int i;
67
68 if (len == 0)
69 return nfserr_inval;
70 if (isdotent(str, len))
71 return err;
72 for (i = 0; i < len; i++)
73 if (str[i] == '/')
74 return err;
75 return 0;
76}
77
78/*
79 * START OF "GENERIC" DECODE ROUTINES.
80 * These may look a little ugly since they are imported from a "generic"
81 * set of XDR encode/decode routines which are intended to be shared by
82 * all of our NFSv4 implementations (OpenBSD, MacOS X...).
83 *
84 * If the pain of reading these is too great, it should be a straightforward
85 * task to translate them into Linux-specific versions which are more
86 * consistent with the style used in NFSv2/v3...
87 */
88#define DECODE_HEAD \
89 u32 *p; \
90 int status
91#define DECODE_TAIL \
92 status = 0; \
93out: \
94 return status; \
95xdr_error: \
96 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); \
97 status = nfserr_bad_xdr; \
98 goto out
99
100#define READ32(x) (x) = ntohl(*p++)
101#define READ64(x) do { \
102 (x) = (u64)ntohl(*p++) << 32; \
103 (x) |= ntohl(*p++); \
104} while (0)
105#define READTIME(x) do { \
106 p++; \
107 (x) = ntohl(*p++); \
108 p++; \
109} while (0)
110#define READMEM(x,nbytes) do { \
111 x = (char *)p; \
112 p += XDR_QUADLEN(nbytes); \
113} while (0)
114#define SAVEMEM(x,nbytes) do { \
115 if (!(x = (p==argp->tmp || p == argp->tmpp) ? \
116 savemem(argp, p, nbytes) : \
117 (char *)p)) { \
118 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); \
119 goto xdr_error; \
120 } \
121 p += XDR_QUADLEN(nbytes); \
122} while (0)
123#define COPYMEM(x,nbytes) do { \
124 memcpy((x), p, nbytes); \
125 p += XDR_QUADLEN(nbytes); \
126} while (0)
127
128/* READ_BUF, read_buf(): nbytes must be <= PAGE_SIZE */
129#define READ_BUF(nbytes) do { \
130 if (nbytes <= (u32)((char *)argp->end - (char *)argp->p)) { \
131 p = argp->p; \
132 argp->p += XDR_QUADLEN(nbytes); \
133 } else if (!(p = read_buf(argp, nbytes))) { \
134 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__); \
135 goto xdr_error; \
136 } \
137} while (0)
138
NeilBrownfd39ca92005-06-23 22:04:03 -0700139static u32 *read_buf(struct nfsd4_compoundargs *argp, int nbytes)
Linus Torvalds1da177e2005-04-16 15:20:36 -0700140{
141 /* We want more bytes than seem to be available.
142 * Maybe we need a new page, maybe we have just run out
143 */
144 int avail = (char*)argp->end - (char*)argp->p;
145 u32 *p;
146 if (avail + argp->pagelen < nbytes)
147 return NULL;
148 if (avail + PAGE_SIZE < nbytes) /* need more than a page !! */
149 return NULL;
150 /* ok, we can do it with the current plus the next page */
151 if (nbytes <= sizeof(argp->tmp))
152 p = argp->tmp;
153 else {
Jesper Juhlf99d49a2005-11-07 01:01:34 -0800154 kfree(argp->tmpp);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700155 p = argp->tmpp = kmalloc(nbytes, GFP_KERNEL);
156 if (!p)
157 return NULL;
158
159 }
160 memcpy(p, argp->p, avail);
161 /* step to next page */
162 argp->p = page_address(argp->pagelist[0]);
163 argp->pagelist++;
164 if (argp->pagelen < PAGE_SIZE) {
165 argp->end = p + (argp->pagelen>>2);
166 argp->pagelen = 0;
167 } else {
168 argp->end = p + (PAGE_SIZE>>2);
169 argp->pagelen -= PAGE_SIZE;
170 }
171 memcpy(((char*)p)+avail, argp->p, (nbytes - avail));
172 argp->p += XDR_QUADLEN(nbytes - avail);
173 return p;
174}
175
176static int
177defer_free(struct nfsd4_compoundargs *argp,
178 void (*release)(const void *), void *p)
179{
180 struct tmpbuf *tb;
181
182 tb = kmalloc(sizeof(*tb), GFP_KERNEL);
183 if (!tb)
184 return -ENOMEM;
185 tb->buf = p;
186 tb->release = release;
187 tb->next = argp->to_free;
188 argp->to_free = tb;
189 return 0;
190}
191
NeilBrownfd39ca92005-06-23 22:04:03 -0700192static char *savemem(struct nfsd4_compoundargs *argp, u32 *p, int nbytes)
Linus Torvalds1da177e2005-04-16 15:20:36 -0700193{
194 void *new = NULL;
195 if (p == argp->tmp) {
196 new = kmalloc(nbytes, GFP_KERNEL);
197 if (!new) return NULL;
198 p = new;
199 memcpy(p, argp->tmp, nbytes);
200 } else {
201 if (p != argp->tmpp)
202 BUG();
203 argp->tmpp = NULL;
204 }
205 if (defer_free(argp, kfree, p)) {
206 kfree(new);
207 return NULL;
208 } else
209 return (char *)p;
210}
211
212
213static int
214nfsd4_decode_bitmap(struct nfsd4_compoundargs *argp, u32 *bmval)
215{
216 u32 bmlen;
217 DECODE_HEAD;
218
219 bmval[0] = 0;
220 bmval[1] = 0;
221
222 READ_BUF(4);
223 READ32(bmlen);
224 if (bmlen > 1000)
225 goto xdr_error;
226
227 READ_BUF(bmlen << 2);
228 if (bmlen > 0)
229 READ32(bmval[0]);
230 if (bmlen > 1)
231 READ32(bmval[1]);
232
233 DECODE_TAIL;
234}
235
236static int
237nfsd4_decode_fattr(struct nfsd4_compoundargs *argp, u32 *bmval, struct iattr *iattr,
238 struct nfs4_acl **acl)
239{
240 int expected_len, len = 0;
241 u32 dummy32;
242 char *buf;
243
244 DECODE_HEAD;
245 iattr->ia_valid = 0;
246 if ((status = nfsd4_decode_bitmap(argp, bmval)))
247 return status;
248
249 /*
250 * According to spec, unsupported attributes return ERR_NOTSUPP;
251 * read-only attributes return ERR_INVAL.
252 */
253 if ((bmval[0] & ~NFSD_SUPPORTED_ATTRS_WORD0) || (bmval[1] & ~NFSD_SUPPORTED_ATTRS_WORD1))
254 return nfserr_attrnotsupp;
255 if ((bmval[0] & ~NFSD_WRITEABLE_ATTRS_WORD0) || (bmval[1] & ~NFSD_WRITEABLE_ATTRS_WORD1))
256 return nfserr_inval;
257
258 READ_BUF(4);
259 READ32(expected_len);
260
261 if (bmval[0] & FATTR4_WORD0_SIZE) {
262 READ_BUF(8);
263 len += 8;
264 READ64(iattr->ia_size);
265 iattr->ia_valid |= ATTR_SIZE;
266 }
267 if (bmval[0] & FATTR4_WORD0_ACL) {
268 int nace, i;
269 struct nfs4_ace ace;
270
271 READ_BUF(4); len += 4;
272 READ32(nace);
273
274 *acl = nfs4_acl_new();
275 if (*acl == NULL) {
276 status = -ENOMEM;
277 goto out_nfserr;
278 }
279 defer_free(argp, (void (*)(const void *))nfs4_acl_free, *acl);
280
281 for (i = 0; i < nace; i++) {
282 READ_BUF(16); len += 16;
283 READ32(ace.type);
284 READ32(ace.flag);
285 READ32(ace.access_mask);
286 READ32(dummy32);
287 READ_BUF(dummy32);
288 len += XDR_QUADLEN(dummy32) << 2;
289 READMEM(buf, dummy32);
290 ace.whotype = nfs4_acl_get_whotype(buf, dummy32);
291 status = 0;
292 if (ace.whotype != NFS4_ACL_WHO_NAMED)
293 ace.who = 0;
294 else if (ace.flag & NFS4_ACE_IDENTIFIER_GROUP)
295 status = nfsd_map_name_to_gid(argp->rqstp,
296 buf, dummy32, &ace.who);
297 else
298 status = nfsd_map_name_to_uid(argp->rqstp,
299 buf, dummy32, &ace.who);
300 if (status)
301 goto out_nfserr;
302 if (nfs4_acl_add_ace(*acl, ace.type, ace.flag,
303 ace.access_mask, ace.whotype, ace.who) != 0) {
304 status = -ENOMEM;
305 goto out_nfserr;
306 }
307 }
308 } else
309 *acl = NULL;
310 if (bmval[1] & FATTR4_WORD1_MODE) {
311 READ_BUF(4);
312 len += 4;
313 READ32(iattr->ia_mode);
314 iattr->ia_mode &= (S_IFMT | S_IALLUGO);
315 iattr->ia_valid |= ATTR_MODE;
316 }
317 if (bmval[1] & FATTR4_WORD1_OWNER) {
318 READ_BUF(4);
319 len += 4;
320 READ32(dummy32);
321 READ_BUF(dummy32);
322 len += (XDR_QUADLEN(dummy32) << 2);
323 READMEM(buf, dummy32);
324 if ((status = nfsd_map_name_to_uid(argp->rqstp, buf, dummy32, &iattr->ia_uid)))
325 goto out_nfserr;
326 iattr->ia_valid |= ATTR_UID;
327 }
328 if (bmval[1] & FATTR4_WORD1_OWNER_GROUP) {
329 READ_BUF(4);
330 len += 4;
331 READ32(dummy32);
332 READ_BUF(dummy32);
333 len += (XDR_QUADLEN(dummy32) << 2);
334 READMEM(buf, dummy32);
335 if ((status = nfsd_map_name_to_gid(argp->rqstp, buf, dummy32, &iattr->ia_gid)))
336 goto out_nfserr;
337 iattr->ia_valid |= ATTR_GID;
338 }
339 if (bmval[1] & FATTR4_WORD1_TIME_ACCESS_SET) {
340 READ_BUF(4);
341 len += 4;
342 READ32(dummy32);
343 switch (dummy32) {
344 case NFS4_SET_TO_CLIENT_TIME:
345 /* We require the high 32 bits of 'seconds' to be 0, and we ignore
346 all 32 bits of 'nseconds'. */
347 READ_BUF(12);
348 len += 12;
349 READ32(dummy32);
350 if (dummy32)
351 return nfserr_inval;
352 READ32(iattr->ia_atime.tv_sec);
353 READ32(iattr->ia_atime.tv_nsec);
354 if (iattr->ia_atime.tv_nsec >= (u32)1000000000)
355 return nfserr_inval;
356 iattr->ia_valid |= (ATTR_ATIME | ATTR_ATIME_SET);
357 break;
358 case NFS4_SET_TO_SERVER_TIME:
359 iattr->ia_valid |= ATTR_ATIME;
360 break;
361 default:
362 goto xdr_error;
363 }
364 }
365 if (bmval[1] & FATTR4_WORD1_TIME_METADATA) {
366 /* We require the high 32 bits of 'seconds' to be 0, and we ignore
367 all 32 bits of 'nseconds'. */
368 READ_BUF(12);
369 len += 12;
370 READ32(dummy32);
371 if (dummy32)
372 return nfserr_inval;
373 READ32(iattr->ia_ctime.tv_sec);
374 READ32(iattr->ia_ctime.tv_nsec);
375 if (iattr->ia_ctime.tv_nsec >= (u32)1000000000)
376 return nfserr_inval;
377 iattr->ia_valid |= ATTR_CTIME;
378 }
379 if (bmval[1] & FATTR4_WORD1_TIME_MODIFY_SET) {
380 READ_BUF(4);
381 len += 4;
382 READ32(dummy32);
383 switch (dummy32) {
384 case NFS4_SET_TO_CLIENT_TIME:
385 /* We require the high 32 bits of 'seconds' to be 0, and we ignore
386 all 32 bits of 'nseconds'. */
387 READ_BUF(12);
388 len += 12;
389 READ32(dummy32);
390 if (dummy32)
391 return nfserr_inval;
392 READ32(iattr->ia_mtime.tv_sec);
393 READ32(iattr->ia_mtime.tv_nsec);
394 if (iattr->ia_mtime.tv_nsec >= (u32)1000000000)
395 return nfserr_inval;
396 iattr->ia_valid |= (ATTR_MTIME | ATTR_MTIME_SET);
397 break;
398 case NFS4_SET_TO_SERVER_TIME:
399 iattr->ia_valid |= ATTR_MTIME;
400 break;
401 default:
402 goto xdr_error;
403 }
404 }
405 if (len != expected_len)
406 goto xdr_error;
407
408 DECODE_TAIL;
409
410out_nfserr:
411 status = nfserrno(status);
412 goto out;
413}
414
415static int
416nfsd4_decode_access(struct nfsd4_compoundargs *argp, struct nfsd4_access *access)
417{
418 DECODE_HEAD;
419
420 READ_BUF(4);
421 READ32(access->ac_req_access);
422
423 DECODE_TAIL;
424}
425
426static int
427nfsd4_decode_close(struct nfsd4_compoundargs *argp, struct nfsd4_close *close)
428{
429 DECODE_HEAD;
430
431 close->cl_stateowner = NULL;
432 READ_BUF(4 + sizeof(stateid_t));
433 READ32(close->cl_seqid);
434 READ32(close->cl_stateid.si_generation);
435 COPYMEM(&close->cl_stateid.si_opaque, sizeof(stateid_opaque_t));
436
437 DECODE_TAIL;
438}
439
440
441static int
442nfsd4_decode_commit(struct nfsd4_compoundargs *argp, struct nfsd4_commit *commit)
443{
444 DECODE_HEAD;
445
446 READ_BUF(12);
447 READ64(commit->co_offset);
448 READ32(commit->co_count);
449
450 DECODE_TAIL;
451}
452
453static int
454nfsd4_decode_create(struct nfsd4_compoundargs *argp, struct nfsd4_create *create)
455{
456 DECODE_HEAD;
457
458 READ_BUF(4);
459 READ32(create->cr_type);
460 switch (create->cr_type) {
461 case NF4LNK:
462 READ_BUF(4);
463 READ32(create->cr_linklen);
464 READ_BUF(create->cr_linklen);
465 SAVEMEM(create->cr_linkname, create->cr_linklen);
466 break;
467 case NF4BLK:
468 case NF4CHR:
469 READ_BUF(8);
470 READ32(create->cr_specdata1);
471 READ32(create->cr_specdata2);
472 break;
473 case NF4SOCK:
474 case NF4FIFO:
475 case NF4DIR:
476 default:
477 break;
478 }
479
480 READ_BUF(4);
481 READ32(create->cr_namelen);
482 READ_BUF(create->cr_namelen);
483 SAVEMEM(create->cr_name, create->cr_namelen);
484 if ((status = check_filename(create->cr_name, create->cr_namelen, nfserr_inval)))
485 return status;
486
487 if ((status = nfsd4_decode_fattr(argp, create->cr_bmval, &create->cr_iattr, &create->cr_acl)))
488 goto out;
489
490 DECODE_TAIL;
491}
492
493static inline int
494nfsd4_decode_delegreturn(struct nfsd4_compoundargs *argp, struct nfsd4_delegreturn *dr)
495{
496 DECODE_HEAD;
497
498 READ_BUF(sizeof(stateid_t));
499 READ32(dr->dr_stateid.si_generation);
500 COPYMEM(&dr->dr_stateid.si_opaque, sizeof(stateid_opaque_t));
501
502 DECODE_TAIL;
503}
504
505static inline int
506nfsd4_decode_getattr(struct nfsd4_compoundargs *argp, struct nfsd4_getattr *getattr)
507{
508 return nfsd4_decode_bitmap(argp, getattr->ga_bmval);
509}
510
511static int
512nfsd4_decode_link(struct nfsd4_compoundargs *argp, struct nfsd4_link *link)
513{
514 DECODE_HEAD;
515
516 READ_BUF(4);
517 READ32(link->li_namelen);
518 READ_BUF(link->li_namelen);
519 SAVEMEM(link->li_name, link->li_namelen);
520 if ((status = check_filename(link->li_name, link->li_namelen, nfserr_inval)))
521 return status;
522
523 DECODE_TAIL;
524}
525
526static int
527nfsd4_decode_lock(struct nfsd4_compoundargs *argp, struct nfsd4_lock *lock)
528{
529 DECODE_HEAD;
530
531 lock->lk_stateowner = NULL;
532 /*
533 * type, reclaim(boolean), offset, length, new_lock_owner(boolean)
534 */
535 READ_BUF(28);
536 READ32(lock->lk_type);
537 if ((lock->lk_type < NFS4_READ_LT) || (lock->lk_type > NFS4_WRITEW_LT))
538 goto xdr_error;
539 READ32(lock->lk_reclaim);
540 READ64(lock->lk_offset);
541 READ64(lock->lk_length);
542 READ32(lock->lk_is_new);
543
544 if (lock->lk_is_new) {
545 READ_BUF(36);
546 READ32(lock->lk_new_open_seqid);
547 READ32(lock->lk_new_open_stateid.si_generation);
548
549 COPYMEM(&lock->lk_new_open_stateid.si_opaque, sizeof(stateid_opaque_t));
550 READ32(lock->lk_new_lock_seqid);
551 COPYMEM(&lock->lk_new_clientid, sizeof(clientid_t));
552 READ32(lock->lk_new_owner.len);
553 READ_BUF(lock->lk_new_owner.len);
554 READMEM(lock->lk_new_owner.data, lock->lk_new_owner.len);
555 } else {
556 READ_BUF(20);
557 READ32(lock->lk_old_lock_stateid.si_generation);
558 COPYMEM(&lock->lk_old_lock_stateid.si_opaque, sizeof(stateid_opaque_t));
559 READ32(lock->lk_old_lock_seqid);
560 }
561
562 DECODE_TAIL;
563}
564
565static int
566nfsd4_decode_lockt(struct nfsd4_compoundargs *argp, struct nfsd4_lockt *lockt)
567{
568 DECODE_HEAD;
569
570 READ_BUF(32);
571 READ32(lockt->lt_type);
572 if((lockt->lt_type < NFS4_READ_LT) || (lockt->lt_type > NFS4_WRITEW_LT))
573 goto xdr_error;
574 READ64(lockt->lt_offset);
575 READ64(lockt->lt_length);
576 COPYMEM(&lockt->lt_clientid, 8);
577 READ32(lockt->lt_owner.len);
578 READ_BUF(lockt->lt_owner.len);
579 READMEM(lockt->lt_owner.data, lockt->lt_owner.len);
580
581 DECODE_TAIL;
582}
583
584static int
585nfsd4_decode_locku(struct nfsd4_compoundargs *argp, struct nfsd4_locku *locku)
586{
587 DECODE_HEAD;
588
589 locku->lu_stateowner = NULL;
590 READ_BUF(24 + sizeof(stateid_t));
591 READ32(locku->lu_type);
592 if ((locku->lu_type < NFS4_READ_LT) || (locku->lu_type > NFS4_WRITEW_LT))
593 goto xdr_error;
594 READ32(locku->lu_seqid);
595 READ32(locku->lu_stateid.si_generation);
596 COPYMEM(&locku->lu_stateid.si_opaque, sizeof(stateid_opaque_t));
597 READ64(locku->lu_offset);
598 READ64(locku->lu_length);
599
600 DECODE_TAIL;
601}
602
603static int
604nfsd4_decode_lookup(struct nfsd4_compoundargs *argp, struct nfsd4_lookup *lookup)
605{
606 DECODE_HEAD;
607
608 READ_BUF(4);
609 READ32(lookup->lo_len);
610 READ_BUF(lookup->lo_len);
611 SAVEMEM(lookup->lo_name, lookup->lo_len);
612 if ((status = check_filename(lookup->lo_name, lookup->lo_len, nfserr_noent)))
613 return status;
614
615 DECODE_TAIL;
616}
617
618static int
619nfsd4_decode_open(struct nfsd4_compoundargs *argp, struct nfsd4_open *open)
620{
621 DECODE_HEAD;
622
623 memset(open->op_bmval, 0, sizeof(open->op_bmval));
624 open->op_iattr.ia_valid = 0;
625 open->op_stateowner = NULL;
626
627 /* seqid, share_access, share_deny, clientid, ownerlen */
628 READ_BUF(16 + sizeof(clientid_t));
629 READ32(open->op_seqid);
630 READ32(open->op_share_access);
631 READ32(open->op_share_deny);
632 COPYMEM(&open->op_clientid, sizeof(clientid_t));
633 READ32(open->op_owner.len);
634
635 /* owner, open_flag */
636 READ_BUF(open->op_owner.len + 4);
637 SAVEMEM(open->op_owner.data, open->op_owner.len);
638 READ32(open->op_create);
639 switch (open->op_create) {
640 case NFS4_OPEN_NOCREATE:
641 break;
642 case NFS4_OPEN_CREATE:
643 READ_BUF(4);
644 READ32(open->op_createmode);
645 switch (open->op_createmode) {
646 case NFS4_CREATE_UNCHECKED:
647 case NFS4_CREATE_GUARDED:
648 if ((status = nfsd4_decode_fattr(argp, open->op_bmval, &open->op_iattr, &open->op_acl)))
649 goto out;
650 break;
651 case NFS4_CREATE_EXCLUSIVE:
652 READ_BUF(8);
653 COPYMEM(open->op_verf.data, 8);
654 break;
655 default:
656 goto xdr_error;
657 }
658 break;
659 default:
660 goto xdr_error;
661 }
662
663 /* open_claim */
664 READ_BUF(4);
665 READ32(open->op_claim_type);
666 switch (open->op_claim_type) {
667 case NFS4_OPEN_CLAIM_NULL:
668 case NFS4_OPEN_CLAIM_DELEGATE_PREV:
669 READ_BUF(4);
670 READ32(open->op_fname.len);
671 READ_BUF(open->op_fname.len);
672 SAVEMEM(open->op_fname.data, open->op_fname.len);
673 if ((status = check_filename(open->op_fname.data, open->op_fname.len, nfserr_inval)))
674 return status;
675 break;
676 case NFS4_OPEN_CLAIM_PREVIOUS:
677 READ_BUF(4);
678 READ32(open->op_delegate_type);
679 break;
680 case NFS4_OPEN_CLAIM_DELEGATE_CUR:
681 READ_BUF(sizeof(stateid_t) + 4);
682 COPYMEM(&open->op_delegate_stateid, sizeof(stateid_t));
683 READ32(open->op_fname.len);
684 READ_BUF(open->op_fname.len);
685 SAVEMEM(open->op_fname.data, open->op_fname.len);
686 if ((status = check_filename(open->op_fname.data, open->op_fname.len, nfserr_inval)))
687 return status;
688 break;
689 default:
690 goto xdr_error;
691 }
692
693 DECODE_TAIL;
694}
695
696static int
697nfsd4_decode_open_confirm(struct nfsd4_compoundargs *argp, struct nfsd4_open_confirm *open_conf)
698{
699 DECODE_HEAD;
700
701 open_conf->oc_stateowner = NULL;
702 READ_BUF(4 + sizeof(stateid_t));
703 READ32(open_conf->oc_req_stateid.si_generation);
704 COPYMEM(&open_conf->oc_req_stateid.si_opaque, sizeof(stateid_opaque_t));
705 READ32(open_conf->oc_seqid);
706
707 DECODE_TAIL;
708}
709
710static int
711nfsd4_decode_open_downgrade(struct nfsd4_compoundargs *argp, struct nfsd4_open_downgrade *open_down)
712{
713 DECODE_HEAD;
714
715 open_down->od_stateowner = NULL;
716 READ_BUF(12 + sizeof(stateid_t));
717 READ32(open_down->od_stateid.si_generation);
718 COPYMEM(&open_down->od_stateid.si_opaque, sizeof(stateid_opaque_t));
719 READ32(open_down->od_seqid);
720 READ32(open_down->od_share_access);
721 READ32(open_down->od_share_deny);
722
723 DECODE_TAIL;
724}
725
726static int
727nfsd4_decode_putfh(struct nfsd4_compoundargs *argp, struct nfsd4_putfh *putfh)
728{
729 DECODE_HEAD;
730
731 READ_BUF(4);
732 READ32(putfh->pf_fhlen);
733 if (putfh->pf_fhlen > NFS4_FHSIZE)
734 goto xdr_error;
735 READ_BUF(putfh->pf_fhlen);
736 SAVEMEM(putfh->pf_fhval, putfh->pf_fhlen);
737
738 DECODE_TAIL;
739}
740
741static int
742nfsd4_decode_read(struct nfsd4_compoundargs *argp, struct nfsd4_read *read)
743{
744 DECODE_HEAD;
745
746 READ_BUF(sizeof(stateid_t) + 12);
747 READ32(read->rd_stateid.si_generation);
748 COPYMEM(&read->rd_stateid.si_opaque, sizeof(stateid_opaque_t));
749 READ64(read->rd_offset);
750 READ32(read->rd_length);
751
752 DECODE_TAIL;
753}
754
755static int
756nfsd4_decode_readdir(struct nfsd4_compoundargs *argp, struct nfsd4_readdir *readdir)
757{
758 DECODE_HEAD;
759
760 READ_BUF(24);
761 READ64(readdir->rd_cookie);
762 COPYMEM(readdir->rd_verf.data, sizeof(readdir->rd_verf.data));
763 READ32(readdir->rd_dircount); /* just in case you needed a useless field... */
764 READ32(readdir->rd_maxcount);
765 if ((status = nfsd4_decode_bitmap(argp, readdir->rd_bmval)))
766 goto out;
767
768 DECODE_TAIL;
769}
770
771static int
772nfsd4_decode_remove(struct nfsd4_compoundargs *argp, struct nfsd4_remove *remove)
773{
774 DECODE_HEAD;
775
776 READ_BUF(4);
777 READ32(remove->rm_namelen);
778 READ_BUF(remove->rm_namelen);
779 SAVEMEM(remove->rm_name, remove->rm_namelen);
780 if ((status = check_filename(remove->rm_name, remove->rm_namelen, nfserr_noent)))
781 return status;
782
783 DECODE_TAIL;
784}
785
786static int
787nfsd4_decode_rename(struct nfsd4_compoundargs *argp, struct nfsd4_rename *rename)
788{
789 DECODE_HEAD;
790
791 READ_BUF(4);
792 READ32(rename->rn_snamelen);
793 READ_BUF(rename->rn_snamelen + 4);
794 SAVEMEM(rename->rn_sname, rename->rn_snamelen);
795 READ32(rename->rn_tnamelen);
796 READ_BUF(rename->rn_tnamelen);
797 SAVEMEM(rename->rn_tname, rename->rn_tnamelen);
798 if ((status = check_filename(rename->rn_sname, rename->rn_snamelen, nfserr_noent)))
799 return status;
800 if ((status = check_filename(rename->rn_tname, rename->rn_tnamelen, nfserr_inval)))
801 return status;
802
803 DECODE_TAIL;
804}
805
806static int
807nfsd4_decode_renew(struct nfsd4_compoundargs *argp, clientid_t *clientid)
808{
809 DECODE_HEAD;
810
811 READ_BUF(sizeof(clientid_t));
812 COPYMEM(clientid, sizeof(clientid_t));
813
814 DECODE_TAIL;
815}
816
817static int
818nfsd4_decode_setattr(struct nfsd4_compoundargs *argp, struct nfsd4_setattr *setattr)
819{
820 DECODE_HEAD;
821
822 READ_BUF(sizeof(stateid_t));
823 READ32(setattr->sa_stateid.si_generation);
824 COPYMEM(&setattr->sa_stateid.si_opaque, sizeof(stateid_opaque_t));
825 if ((status = nfsd4_decode_fattr(argp, setattr->sa_bmval, &setattr->sa_iattr, &setattr->sa_acl)))
826 goto out;
827
828 DECODE_TAIL;
829}
830
831static int
832nfsd4_decode_setclientid(struct nfsd4_compoundargs *argp, struct nfsd4_setclientid *setclientid)
833{
834 DECODE_HEAD;
835
836 READ_BUF(12);
837 COPYMEM(setclientid->se_verf.data, 8);
838 READ32(setclientid->se_namelen);
839
840 READ_BUF(setclientid->se_namelen + 8);
841 SAVEMEM(setclientid->se_name, setclientid->se_namelen);
842 READ32(setclientid->se_callback_prog);
843 READ32(setclientid->se_callback_netid_len);
844
845 READ_BUF(setclientid->se_callback_netid_len + 4);
846 SAVEMEM(setclientid->se_callback_netid_val, setclientid->se_callback_netid_len);
847 READ32(setclientid->se_callback_addr_len);
848
849 READ_BUF(setclientid->se_callback_addr_len + 4);
850 SAVEMEM(setclientid->se_callback_addr_val, setclientid->se_callback_addr_len);
851 READ32(setclientid->se_callback_ident);
852
853 DECODE_TAIL;
854}
855
856static int
857nfsd4_decode_setclientid_confirm(struct nfsd4_compoundargs *argp, struct nfsd4_setclientid_confirm *scd_c)
858{
859 DECODE_HEAD;
860
861 READ_BUF(8 + sizeof(nfs4_verifier));
862 COPYMEM(&scd_c->sc_clientid, 8);
863 COPYMEM(&scd_c->sc_confirm, sizeof(nfs4_verifier));
864
865 DECODE_TAIL;
866}
867
868/* Also used for NVERIFY */
869static int
870nfsd4_decode_verify(struct nfsd4_compoundargs *argp, struct nfsd4_verify *verify)
871{
872#if 0
873 struct nfsd4_compoundargs save = {
874 .p = argp->p,
875 .end = argp->end,
876 .rqstp = argp->rqstp,
877 };
878 u32 ve_bmval[2];
879 struct iattr ve_iattr; /* request */
880 struct nfs4_acl *ve_acl; /* request */
881#endif
882 DECODE_HEAD;
883
884 if ((status = nfsd4_decode_bitmap(argp, verify->ve_bmval)))
885 goto out;
886
887 /* For convenience's sake, we compare raw xdr'd attributes in
888 * nfsd4_proc_verify; however we still decode here just to return
889 * correct error in case of bad xdr. */
890#if 0
891 status = nfsd4_decode_fattr(ve_bmval, &ve_iattr, &ve_acl);
892 if (status == nfserr_inval) {
893 status = nfserrno(status);
894 goto out;
895 }
896#endif
897 READ_BUF(4);
898 READ32(verify->ve_attrlen);
899 READ_BUF(verify->ve_attrlen);
900 SAVEMEM(verify->ve_attrval, verify->ve_attrlen);
901
902 DECODE_TAIL;
903}
904
905static int
906nfsd4_decode_write(struct nfsd4_compoundargs *argp, struct nfsd4_write *write)
907{
908 int avail;
909 int v;
910 int len;
911 DECODE_HEAD;
912
913 READ_BUF(sizeof(stateid_opaque_t) + 20);
914 READ32(write->wr_stateid.si_generation);
915 COPYMEM(&write->wr_stateid.si_opaque, sizeof(stateid_opaque_t));
916 READ64(write->wr_offset);
917 READ32(write->wr_stable_how);
918 if (write->wr_stable_how > 2)
919 goto xdr_error;
920 READ32(write->wr_buflen);
921
922 /* Sorry .. no magic macros for this.. *
923 * READ_BUF(write->wr_buflen);
924 * SAVEMEM(write->wr_buf, write->wr_buflen);
925 */
926 avail = (char*)argp->end - (char*)argp->p;
927 if (avail + argp->pagelen < write->wr_buflen) {
928 printk(KERN_NOTICE "xdr error! (%s:%d)\n", __FILE__, __LINE__);
929 goto xdr_error;
930 }
931 write->wr_vec[0].iov_base = p;
932 write->wr_vec[0].iov_len = avail;
933 v = 0;
934 len = write->wr_buflen;
935 while (len > write->wr_vec[v].iov_len) {
936 len -= write->wr_vec[v].iov_len;
937 v++;
938 write->wr_vec[v].iov_base = page_address(argp->pagelist[0]);
939 argp->pagelist++;
940 if (argp->pagelen >= PAGE_SIZE) {
941 write->wr_vec[v].iov_len = PAGE_SIZE;
942 argp->pagelen -= PAGE_SIZE;
943 } else {
944 write->wr_vec[v].iov_len = argp->pagelen;
945 argp->pagelen -= len;
946 }
947 }
948 argp->end = (u32*) (write->wr_vec[v].iov_base + write->wr_vec[v].iov_len);
949 argp->p = (u32*) (write->wr_vec[v].iov_base + (XDR_QUADLEN(len) << 2));
950 write->wr_vec[v].iov_len = len;
951 write->wr_vlen = v+1;
952
953 DECODE_TAIL;
954}
955
956static int
957nfsd4_decode_release_lockowner(struct nfsd4_compoundargs *argp, struct nfsd4_release_lockowner *rlockowner)
958{
959 DECODE_HEAD;
960
961 READ_BUF(12);
962 COPYMEM(&rlockowner->rl_clientid, sizeof(clientid_t));
963 READ32(rlockowner->rl_owner.len);
964 READ_BUF(rlockowner->rl_owner.len);
965 READMEM(rlockowner->rl_owner.data, rlockowner->rl_owner.len);
966
967 DECODE_TAIL;
968}
969
970static int
971nfsd4_decode_compound(struct nfsd4_compoundargs *argp)
972{
973 DECODE_HEAD;
974 struct nfsd4_op *op;
975 int i;
976
977 /*
978 * XXX: According to spec, we should check the tag
979 * for UTF-8 compliance. I'm postponing this for
980 * now because it seems that some clients do use
981 * binary tags.
982 */
983 READ_BUF(4);
984 READ32(argp->taglen);
985 READ_BUF(argp->taglen + 8);
986 SAVEMEM(argp->tag, argp->taglen);
987 READ32(argp->minorversion);
988 READ32(argp->opcnt);
989
990 if (argp->taglen > NFSD4_MAX_TAGLEN)
991 goto xdr_error;
992 if (argp->opcnt > 100)
993 goto xdr_error;
994
995 if (argp->opcnt > sizeof(argp->iops)/sizeof(argp->iops[0])) {
996 argp->ops = kmalloc(argp->opcnt * sizeof(*argp->ops), GFP_KERNEL);
997 if (!argp->ops) {
998 argp->ops = argp->iops;
999 printk(KERN_INFO "nfsd: couldn't allocate room for COMPOUND\n");
1000 goto xdr_error;
1001 }
1002 }
1003
1004 for (i = 0; i < argp->opcnt; i++) {
1005 op = &argp->ops[i];
1006 op->replay = NULL;
1007
1008 /*
1009 * We can't use READ_BUF() here because we need to handle
1010 * a missing opcode as an OP_WRITE + 1. So we need to check
1011 * to see if we're truly at the end of our buffer or if there
1012 * is another page we need to flip to.
1013 */
1014
1015 if (argp->p == argp->end) {
1016 if (argp->pagelen < 4) {
1017 /* There isn't an opcode still on the wire */
1018 op->opnum = OP_WRITE + 1;
1019 op->status = nfserr_bad_xdr;
1020 argp->opcnt = i+1;
1021 break;
1022 }
1023
1024 /*
1025 * False alarm. We just hit a page boundary, but there
1026 * is still data available. Move pointer across page
1027 * boundary. *snip from READ_BUF*
1028 */
1029 argp->p = page_address(argp->pagelist[0]);
1030 argp->pagelist++;
1031 if (argp->pagelen < PAGE_SIZE) {
1032 argp->end = p + (argp->pagelen>>2);
1033 argp->pagelen = 0;
1034 } else {
1035 argp->end = p + (PAGE_SIZE>>2);
1036 argp->pagelen -= PAGE_SIZE;
1037 }
1038 }
1039 op->opnum = ntohl(*argp->p++);
1040
1041 switch (op->opnum) {
1042 case 2: /* Reserved operation */
1043 op->opnum = OP_ILLEGAL;
1044 if (argp->minorversion == 0)
1045 op->status = nfserr_op_illegal;
1046 else
1047 op->status = nfserr_minor_vers_mismatch;
1048 break;
1049 case OP_ACCESS:
1050 op->status = nfsd4_decode_access(argp, &op->u.access);
1051 break;
1052 case OP_CLOSE:
1053 op->status = nfsd4_decode_close(argp, &op->u.close);
1054 break;
1055 case OP_COMMIT:
1056 op->status = nfsd4_decode_commit(argp, &op->u.commit);
1057 break;
1058 case OP_CREATE:
1059 op->status = nfsd4_decode_create(argp, &op->u.create);
1060 break;
1061 case OP_DELEGRETURN:
1062 op->status = nfsd4_decode_delegreturn(argp, &op->u.delegreturn);
1063 break;
1064 case OP_GETATTR:
1065 op->status = nfsd4_decode_getattr(argp, &op->u.getattr);
1066 break;
1067 case OP_GETFH:
1068 op->status = nfs_ok;
1069 break;
1070 case OP_LINK:
1071 op->status = nfsd4_decode_link(argp, &op->u.link);
1072 break;
1073 case OP_LOCK:
1074 op->status = nfsd4_decode_lock(argp, &op->u.lock);
1075 break;
1076 case OP_LOCKT:
1077 op->status = nfsd4_decode_lockt(argp, &op->u.lockt);
1078 break;
1079 case OP_LOCKU:
1080 op->status = nfsd4_decode_locku(argp, &op->u.locku);
1081 break;
1082 case OP_LOOKUP:
1083 op->status = nfsd4_decode_lookup(argp, &op->u.lookup);
1084 break;
1085 case OP_LOOKUPP:
1086 op->status = nfs_ok;
1087 break;
1088 case OP_NVERIFY:
1089 op->status = nfsd4_decode_verify(argp, &op->u.nverify);
1090 break;
1091 case OP_OPEN:
1092 op->status = nfsd4_decode_open(argp, &op->u.open);
1093 break;
1094 case OP_OPEN_CONFIRM:
1095 op->status = nfsd4_decode_open_confirm(argp, &op->u.open_confirm);
1096 break;
1097 case OP_OPEN_DOWNGRADE:
1098 op->status = nfsd4_decode_open_downgrade(argp, &op->u.open_downgrade);
1099 break;
1100 case OP_PUTFH:
1101 op->status = nfsd4_decode_putfh(argp, &op->u.putfh);
1102 break;
1103 case OP_PUTROOTFH:
1104 op->status = nfs_ok;
1105 break;
1106 case OP_READ:
1107 op->status = nfsd4_decode_read(argp, &op->u.read);
1108 break;
1109 case OP_READDIR:
1110 op->status = nfsd4_decode_readdir(argp, &op->u.readdir);
1111 break;
1112 case OP_READLINK:
1113 op->status = nfs_ok;
1114 break;
1115 case OP_REMOVE:
1116 op->status = nfsd4_decode_remove(argp, &op->u.remove);
1117 break;
1118 case OP_RENAME:
1119 op->status = nfsd4_decode_rename(argp, &op->u.rename);
1120 break;
1121 case OP_RESTOREFH:
1122 op->status = nfs_ok;
1123 break;
1124 case OP_RENEW:
1125 op->status = nfsd4_decode_renew(argp, &op->u.renew);
1126 break;
1127 case OP_SAVEFH:
1128 op->status = nfs_ok;
1129 break;
1130 case OP_SETATTR:
1131 op->status = nfsd4_decode_setattr(argp, &op->u.setattr);
1132 break;
1133 case OP_SETCLIENTID:
1134 op->status = nfsd4_decode_setclientid(argp, &op->u.setclientid);
1135 break;
1136 case OP_SETCLIENTID_CONFIRM:
1137 op->status = nfsd4_decode_setclientid_confirm(argp, &op->u.setclientid_confirm);
1138 break;
1139 case OP_VERIFY:
1140 op->status = nfsd4_decode_verify(argp, &op->u.verify);
1141 break;
1142 case OP_WRITE:
1143 op->status = nfsd4_decode_write(argp, &op->u.write);
1144 break;
1145 case OP_RELEASE_LOCKOWNER:
1146 op->status = nfsd4_decode_release_lockowner(argp, &op->u.release_lockowner);
1147 break;
1148 default:
1149 op->opnum = OP_ILLEGAL;
1150 op->status = nfserr_op_illegal;
1151 break;
1152 }
1153
1154 if (op->status) {
1155 argp->opcnt = i+1;
1156 break;
1157 }
1158 }
1159
1160 DECODE_TAIL;
1161}
1162/*
1163 * END OF "GENERIC" DECODE ROUTINES.
1164 */
1165
1166/*
1167 * START OF "GENERIC" ENCODE ROUTINES.
1168 * These may look a little ugly since they are imported from a "generic"
1169 * set of XDR encode/decode routines which are intended to be shared by
1170 * all of our NFSv4 implementations (OpenBSD, MacOS X...).
1171 *
1172 * If the pain of reading these is too great, it should be a straightforward
1173 * task to translate them into Linux-specific versions which are more
1174 * consistent with the style used in NFSv2/v3...
1175 */
1176#define ENCODE_HEAD u32 *p
1177
1178#define WRITE32(n) *p++ = htonl(n)
1179#define WRITE64(n) do { \
1180 *p++ = htonl((u32)((n) >> 32)); \
1181 *p++ = htonl((u32)(n)); \
1182} while (0)
1183#define WRITEMEM(ptr,nbytes) do { \
1184 *(p + XDR_QUADLEN(nbytes) -1) = 0; \
1185 memcpy(p, ptr, nbytes); \
1186 p += XDR_QUADLEN(nbytes); \
1187} while (0)
1188#define WRITECINFO(c) do { \
1189 *p++ = htonl(c.atomic); \
1190 *p++ = htonl(c.before_ctime_sec); \
1191 *p++ = htonl(c.before_ctime_nsec); \
1192 *p++ = htonl(c.after_ctime_sec); \
1193 *p++ = htonl(c.after_ctime_nsec); \
1194} while (0)
1195
1196#define RESERVE_SPACE(nbytes) do { \
1197 p = resp->p; \
1198 BUG_ON(p + XDR_QUADLEN(nbytes) > resp->end); \
1199} while (0)
1200#define ADJUST_ARGS() resp->p = p
1201
1202/*
1203 * Header routine to setup seqid operation replay cache
1204 */
1205#define ENCODE_SEQID_OP_HEAD \
1206 u32 *p; \
1207 u32 *save; \
1208 \
1209 save = resp->p;
1210
1211/*
NeilBrown7fb64ce2005-07-07 17:59:20 -07001212 * Routine for encoding the result of a "seqid-mutating" NFSv4 operation. This
1213 * is where sequence id's are incremented, and the replay cache is filled.
1214 * Note that we increment sequence id's here, at the last moment, so we're sure
1215 * we know whether the error to be returned is a sequence id mutating error.
Linus Torvalds1da177e2005-04-16 15:20:36 -07001216 */
1217
1218#define ENCODE_SEQID_OP_TAIL(stateowner) do { \
1219 if (seqid_mutating_err(nfserr) && stateowner) { \
NeilBrownbd9aac52005-07-07 17:59:19 -07001220 stateowner->so_seqid++; \
Linus Torvalds1da177e2005-04-16 15:20:36 -07001221 stateowner->so_replay.rp_status = nfserr; \
1222 stateowner->so_replay.rp_buflen = \
1223 (((char *)(resp)->p - (char *)save)); \
1224 memcpy(stateowner->so_replay.rp_buf, save, \
1225 stateowner->so_replay.rp_buflen); \
1226 } } while (0);
1227
1228
1229static u32 nfs4_ftypes[16] = {
1230 NF4BAD, NF4FIFO, NF4CHR, NF4BAD,
1231 NF4DIR, NF4BAD, NF4BLK, NF4BAD,
1232 NF4REG, NF4BAD, NF4LNK, NF4BAD,
1233 NF4SOCK, NF4BAD, NF4LNK, NF4BAD,
1234};
1235
1236static int
1237nfsd4_encode_name(struct svc_rqst *rqstp, int whotype, uid_t id, int group,
1238 u32 **p, int *buflen)
1239{
1240 int status;
1241
1242 if (*buflen < (XDR_QUADLEN(IDMAP_NAMESZ) << 2) + 4)
1243 return nfserr_resource;
1244 if (whotype != NFS4_ACL_WHO_NAMED)
1245 status = nfs4_acl_write_who(whotype, (u8 *)(*p + 1));
1246 else if (group)
1247 status = nfsd_map_gid_to_name(rqstp, id, (u8 *)(*p + 1));
1248 else
1249 status = nfsd_map_uid_to_name(rqstp, id, (u8 *)(*p + 1));
1250 if (status < 0)
1251 return nfserrno(status);
1252 *p = xdr_encode_opaque(*p, NULL, status);
1253 *buflen -= (XDR_QUADLEN(status) << 2) + 4;
1254 BUG_ON(*buflen < 0);
1255 return 0;
1256}
1257
1258static inline int
1259nfsd4_encode_user(struct svc_rqst *rqstp, uid_t uid, u32 **p, int *buflen)
1260{
1261 return nfsd4_encode_name(rqstp, NFS4_ACL_WHO_NAMED, uid, 0, p, buflen);
1262}
1263
1264static inline int
1265nfsd4_encode_group(struct svc_rqst *rqstp, uid_t gid, u32 **p, int *buflen)
1266{
1267 return nfsd4_encode_name(rqstp, NFS4_ACL_WHO_NAMED, gid, 1, p, buflen);
1268}
1269
1270static inline int
1271nfsd4_encode_aclname(struct svc_rqst *rqstp, int whotype, uid_t id, int group,
1272 u32 **p, int *buflen)
1273{
1274 return nfsd4_encode_name(rqstp, whotype, id, group, p, buflen);
1275}
1276
1277
1278/*
1279 * Note: @fhp can be NULL; in this case, we might have to compose the filehandle
1280 * ourselves.
1281 *
1282 * @countp is the buffer size in _words_; upon successful return this becomes
1283 * replaced with the number of words written.
1284 */
1285int
1286nfsd4_encode_fattr(struct svc_fh *fhp, struct svc_export *exp,
1287 struct dentry *dentry, u32 *buffer, int *countp, u32 *bmval,
1288 struct svc_rqst *rqstp)
1289{
1290 u32 bmval0 = bmval[0];
1291 u32 bmval1 = bmval[1];
1292 struct kstat stat;
1293 struct svc_fh tempfh;
1294 struct kstatfs statfs;
1295 int buflen = *countp << 2;
1296 u32 *attrlenp;
1297 u32 dummy;
1298 u64 dummy64;
1299 u32 *p = buffer;
1300 int status;
1301 int aclsupport = 0;
1302 struct nfs4_acl *acl = NULL;
1303
1304 BUG_ON(bmval1 & NFSD_WRITEONLY_ATTRS_WORD1);
1305 BUG_ON(bmval0 & ~NFSD_SUPPORTED_ATTRS_WORD0);
1306 BUG_ON(bmval1 & ~NFSD_SUPPORTED_ATTRS_WORD1);
1307
1308 status = vfs_getattr(exp->ex_mnt, dentry, &stat);
1309 if (status)
1310 goto out_nfserr;
1311 if ((bmval0 & (FATTR4_WORD0_FILES_FREE | FATTR4_WORD0_FILES_TOTAL)) ||
1312 (bmval1 & (FATTR4_WORD1_SPACE_AVAIL | FATTR4_WORD1_SPACE_FREE |
1313 FATTR4_WORD1_SPACE_TOTAL))) {
1314 status = vfs_statfs(dentry->d_inode->i_sb, &statfs);
1315 if (status)
1316 goto out_nfserr;
1317 }
1318 if ((bmval0 & (FATTR4_WORD0_FILEHANDLE | FATTR4_WORD0_FSID)) && !fhp) {
1319 fh_init(&tempfh, NFS4_FHSIZE);
1320 status = fh_compose(&tempfh, exp, dentry, NULL);
1321 if (status)
1322 goto out;
1323 fhp = &tempfh;
1324 }
1325 if (bmval0 & (FATTR4_WORD0_ACL | FATTR4_WORD0_ACLSUPPORT
1326 | FATTR4_WORD0_SUPPORTED_ATTRS)) {
1327 status = nfsd4_get_nfs4_acl(rqstp, dentry, &acl);
1328 aclsupport = (status == 0);
1329 if (bmval0 & FATTR4_WORD0_ACL) {
1330 if (status == -EOPNOTSUPP)
1331 bmval0 &= ~FATTR4_WORD0_ACL;
1332 else if (status == -EINVAL) {
1333 status = nfserr_attrnotsupp;
1334 goto out;
1335 } else if (status != 0)
1336 goto out_nfserr;
1337 }
1338 }
1339 if ((buflen -= 16) < 0)
1340 goto out_resource;
1341
1342 WRITE32(2);
1343 WRITE32(bmval0);
1344 WRITE32(bmval1);
1345 attrlenp = p++; /* to be backfilled later */
1346
1347 if (bmval0 & FATTR4_WORD0_SUPPORTED_ATTRS) {
1348 if ((buflen -= 12) < 0)
1349 goto out_resource;
1350 WRITE32(2);
1351 WRITE32(aclsupport ?
1352 NFSD_SUPPORTED_ATTRS_WORD0 :
1353 NFSD_SUPPORTED_ATTRS_WORD0 & ~FATTR4_WORD0_ACL);
1354 WRITE32(NFSD_SUPPORTED_ATTRS_WORD1);
1355 }
1356 if (bmval0 & FATTR4_WORD0_TYPE) {
1357 if ((buflen -= 4) < 0)
1358 goto out_resource;
1359 dummy = nfs4_ftypes[(stat.mode & S_IFMT) >> 12];
1360 if (dummy == NF4BAD)
1361 goto out_serverfault;
1362 WRITE32(dummy);
1363 }
1364 if (bmval0 & FATTR4_WORD0_FH_EXPIRE_TYPE) {
1365 if ((buflen -= 4) < 0)
1366 goto out_resource;
NeilBrown49640002005-06-23 22:02:58 -07001367 if (exp->ex_flags & NFSEXP_NOSUBTREECHECK)
NeilBrowne34ac862005-07-07 17:59:30 -07001368 WRITE32(NFS4_FH_PERSISTENT);
NeilBrown49640002005-06-23 22:02:58 -07001369 else
NeilBrowne34ac862005-07-07 17:59:30 -07001370 WRITE32(NFS4_FH_PERSISTENT|NFS4_FH_VOL_RENAME);
Linus Torvalds1da177e2005-04-16 15:20:36 -07001371 }
1372 if (bmval0 & FATTR4_WORD0_CHANGE) {
1373 /*
1374 * Note: This _must_ be consistent with the scheme for writing
1375 * change_info, so any changes made here must be reflected there
1376 * as well. (See xdr4.h:set_change_info() and the WRITECINFO()
1377 * macro above.)
1378 */
1379 if ((buflen -= 8) < 0)
1380 goto out_resource;
1381 WRITE32(stat.ctime.tv_sec);
1382 WRITE32(stat.ctime.tv_nsec);
1383 }
1384 if (bmval0 & FATTR4_WORD0_SIZE) {
1385 if ((buflen -= 8) < 0)
1386 goto out_resource;
1387 WRITE64(stat.size);
1388 }
1389 if (bmval0 & FATTR4_WORD0_LINK_SUPPORT) {
1390 if ((buflen -= 4) < 0)
1391 goto out_resource;
1392 WRITE32(1);
1393 }
1394 if (bmval0 & FATTR4_WORD0_SYMLINK_SUPPORT) {
1395 if ((buflen -= 4) < 0)
1396 goto out_resource;
1397 WRITE32(1);
1398 }
1399 if (bmval0 & FATTR4_WORD0_NAMED_ATTR) {
1400 if ((buflen -= 4) < 0)
1401 goto out_resource;
1402 WRITE32(0);
1403 }
1404 if (bmval0 & FATTR4_WORD0_FSID) {
1405 if ((buflen -= 16) < 0)
1406 goto out_resource;
1407 if (is_fsid(fhp, rqstp->rq_reffh)) {
1408 WRITE64((u64)exp->ex_fsid);
1409 WRITE64((u64)0);
1410 } else {
1411 WRITE32(0);
1412 WRITE32(MAJOR(stat.dev));
1413 WRITE32(0);
1414 WRITE32(MINOR(stat.dev));
1415 }
1416 }
1417 if (bmval0 & FATTR4_WORD0_UNIQUE_HANDLES) {
1418 if ((buflen -= 4) < 0)
1419 goto out_resource;
1420 WRITE32(0);
1421 }
1422 if (bmval0 & FATTR4_WORD0_LEASE_TIME) {
1423 if ((buflen -= 4) < 0)
1424 goto out_resource;
1425 WRITE32(NFSD_LEASE_TIME);
1426 }
1427 if (bmval0 & FATTR4_WORD0_RDATTR_ERROR) {
1428 if ((buflen -= 4) < 0)
1429 goto out_resource;
1430 WRITE32(0);
1431 }
1432 if (bmval0 & FATTR4_WORD0_ACL) {
1433 struct nfs4_ace *ace;
1434 struct list_head *h;
1435
1436 if (acl == NULL) {
1437 if ((buflen -= 4) < 0)
1438 goto out_resource;
1439
1440 WRITE32(0);
1441 goto out_acl;
1442 }
1443 if ((buflen -= 4) < 0)
1444 goto out_resource;
1445 WRITE32(acl->naces);
1446
1447 list_for_each(h, &acl->ace_head) {
1448 ace = list_entry(h, struct nfs4_ace, l_ace);
1449
1450 if ((buflen -= 4*3) < 0)
1451 goto out_resource;
1452 WRITE32(ace->type);
1453 WRITE32(ace->flag);
1454 WRITE32(ace->access_mask & NFS4_ACE_MASK_ALL);
1455 status = nfsd4_encode_aclname(rqstp, ace->whotype,
1456 ace->who, ace->flag & NFS4_ACE_IDENTIFIER_GROUP,
1457 &p, &buflen);
1458 if (status == nfserr_resource)
1459 goto out_resource;
1460 if (status)
1461 goto out;
1462 }
1463 }
1464out_acl:
1465 if (bmval0 & FATTR4_WORD0_ACLSUPPORT) {
1466 if ((buflen -= 4) < 0)
1467 goto out_resource;
1468 WRITE32(aclsupport ?
1469 ACL4_SUPPORT_ALLOW_ACL|ACL4_SUPPORT_DENY_ACL : 0);
1470 }
1471 if (bmval0 & FATTR4_WORD0_CANSETTIME) {
1472 if ((buflen -= 4) < 0)
1473 goto out_resource;
1474 WRITE32(1);
1475 }
1476 if (bmval0 & FATTR4_WORD0_CASE_INSENSITIVE) {
1477 if ((buflen -= 4) < 0)
1478 goto out_resource;
1479 WRITE32(1);
1480 }
1481 if (bmval0 & FATTR4_WORD0_CASE_PRESERVING) {
1482 if ((buflen -= 4) < 0)
1483 goto out_resource;
1484 WRITE32(1);
1485 }
1486 if (bmval0 & FATTR4_WORD0_CHOWN_RESTRICTED) {
1487 if ((buflen -= 4) < 0)
1488 goto out_resource;
1489 WRITE32(1);
1490 }
1491 if (bmval0 & FATTR4_WORD0_FILEHANDLE) {
1492 buflen -= (XDR_QUADLEN(fhp->fh_handle.fh_size) << 2) + 4;
1493 if (buflen < 0)
1494 goto out_resource;
1495 WRITE32(fhp->fh_handle.fh_size);
1496 WRITEMEM(&fhp->fh_handle.fh_base, fhp->fh_handle.fh_size);
1497 }
1498 if (bmval0 & FATTR4_WORD0_FILEID) {
1499 if ((buflen -= 8) < 0)
1500 goto out_resource;
1501 WRITE64((u64) stat.ino);
1502 }
1503 if (bmval0 & FATTR4_WORD0_FILES_AVAIL) {
1504 if ((buflen -= 8) < 0)
1505 goto out_resource;
1506 WRITE64((u64) statfs.f_ffree);
1507 }
1508 if (bmval0 & FATTR4_WORD0_FILES_FREE) {
1509 if ((buflen -= 8) < 0)
1510 goto out_resource;
1511 WRITE64((u64) statfs.f_ffree);
1512 }
1513 if (bmval0 & FATTR4_WORD0_FILES_TOTAL) {
1514 if ((buflen -= 8) < 0)
1515 goto out_resource;
1516 WRITE64((u64) statfs.f_files);
1517 }
1518 if (bmval0 & FATTR4_WORD0_HOMOGENEOUS) {
1519 if ((buflen -= 4) < 0)
1520 goto out_resource;
1521 WRITE32(1);
1522 }
1523 if (bmval0 & FATTR4_WORD0_MAXFILESIZE) {
1524 if ((buflen -= 8) < 0)
1525 goto out_resource;
1526 WRITE64(~(u64)0);
1527 }
1528 if (bmval0 & FATTR4_WORD0_MAXLINK) {
1529 if ((buflen -= 4) < 0)
1530 goto out_resource;
1531 WRITE32(255);
1532 }
1533 if (bmval0 & FATTR4_WORD0_MAXNAME) {
1534 if ((buflen -= 4) < 0)
1535 goto out_resource;
1536 WRITE32(~(u32) 0);
1537 }
1538 if (bmval0 & FATTR4_WORD0_MAXREAD) {
1539 if ((buflen -= 8) < 0)
1540 goto out_resource;
1541 WRITE64((u64) NFSSVC_MAXBLKSIZE);
1542 }
1543 if (bmval0 & FATTR4_WORD0_MAXWRITE) {
1544 if ((buflen -= 8) < 0)
1545 goto out_resource;
1546 WRITE64((u64) NFSSVC_MAXBLKSIZE);
1547 }
1548 if (bmval1 & FATTR4_WORD1_MODE) {
1549 if ((buflen -= 4) < 0)
1550 goto out_resource;
1551 WRITE32(stat.mode & S_IALLUGO);
1552 }
1553 if (bmval1 & FATTR4_WORD1_NO_TRUNC) {
1554 if ((buflen -= 4) < 0)
1555 goto out_resource;
1556 WRITE32(1);
1557 }
1558 if (bmval1 & FATTR4_WORD1_NUMLINKS) {
1559 if ((buflen -= 4) < 0)
1560 goto out_resource;
1561 WRITE32(stat.nlink);
1562 }
1563 if (bmval1 & FATTR4_WORD1_OWNER) {
1564 status = nfsd4_encode_user(rqstp, stat.uid, &p, &buflen);
1565 if (status == nfserr_resource)
1566 goto out_resource;
1567 if (status)
1568 goto out;
1569 }
1570 if (bmval1 & FATTR4_WORD1_OWNER_GROUP) {
1571 status = nfsd4_encode_group(rqstp, stat.gid, &p, &buflen);
1572 if (status == nfserr_resource)
1573 goto out_resource;
1574 if (status)
1575 goto out;
1576 }
1577 if (bmval1 & FATTR4_WORD1_RAWDEV) {
1578 if ((buflen -= 8) < 0)
1579 goto out_resource;
1580 WRITE32((u32) MAJOR(stat.rdev));
1581 WRITE32((u32) MINOR(stat.rdev));
1582 }
1583 if (bmval1 & FATTR4_WORD1_SPACE_AVAIL) {
1584 if ((buflen -= 8) < 0)
1585 goto out_resource;
1586 dummy64 = (u64)statfs.f_bavail * (u64)statfs.f_bsize;
1587 WRITE64(dummy64);
1588 }
1589 if (bmval1 & FATTR4_WORD1_SPACE_FREE) {
1590 if ((buflen -= 8) < 0)
1591 goto out_resource;
1592 dummy64 = (u64)statfs.f_bfree * (u64)statfs.f_bsize;
1593 WRITE64(dummy64);
1594 }
1595 if (bmval1 & FATTR4_WORD1_SPACE_TOTAL) {
1596 if ((buflen -= 8) < 0)
1597 goto out_resource;
1598 dummy64 = (u64)statfs.f_blocks * (u64)statfs.f_bsize;
1599 WRITE64(dummy64);
1600 }
1601 if (bmval1 & FATTR4_WORD1_SPACE_USED) {
1602 if ((buflen -= 8) < 0)
1603 goto out_resource;
1604 dummy64 = (u64)stat.blocks << 9;
1605 WRITE64(dummy64);
1606 }
1607 if (bmval1 & FATTR4_WORD1_TIME_ACCESS) {
1608 if ((buflen -= 12) < 0)
1609 goto out_resource;
1610 WRITE32(0);
1611 WRITE32(stat.atime.tv_sec);
1612 WRITE32(stat.atime.tv_nsec);
1613 }
1614 if (bmval1 & FATTR4_WORD1_TIME_DELTA) {
1615 if ((buflen -= 12) < 0)
1616 goto out_resource;
1617 WRITE32(0);
1618 WRITE32(1);
1619 WRITE32(0);
1620 }
1621 if (bmval1 & FATTR4_WORD1_TIME_METADATA) {
1622 if ((buflen -= 12) < 0)
1623 goto out_resource;
1624 WRITE32(0);
1625 WRITE32(stat.ctime.tv_sec);
1626 WRITE32(stat.ctime.tv_nsec);
1627 }
1628 if (bmval1 & FATTR4_WORD1_TIME_MODIFY) {
1629 if ((buflen -= 12) < 0)
1630 goto out_resource;
1631 WRITE32(0);
1632 WRITE32(stat.mtime.tv_sec);
1633 WRITE32(stat.mtime.tv_nsec);
1634 }
1635 if (bmval1 & FATTR4_WORD1_MOUNTED_ON_FILEID) {
1636 struct dentry *mnt_pnt, *mnt_root;
1637
1638 if ((buflen -= 8) < 0)
1639 goto out_resource;
1640 mnt_root = exp->ex_mnt->mnt_root;
1641 if (mnt_root->d_inode == dentry->d_inode) {
1642 mnt_pnt = exp->ex_mnt->mnt_mountpoint;
1643 WRITE64((u64) mnt_pnt->d_inode->i_ino);
1644 } else
1645 WRITE64((u64) stat.ino);
1646 }
1647 *attrlenp = htonl((char *)p - (char *)attrlenp - 4);
1648 *countp = p - buffer;
1649 status = nfs_ok;
1650
1651out:
1652 nfs4_acl_free(acl);
1653 if (fhp == &tempfh)
1654 fh_put(&tempfh);
1655 return status;
1656out_nfserr:
1657 status = nfserrno(status);
1658 goto out;
1659out_resource:
1660 *countp = 0;
1661 status = nfserr_resource;
1662 goto out;
1663out_serverfault:
1664 status = nfserr_serverfault;
1665 goto out;
1666}
1667
1668static int
1669nfsd4_encode_dirent_fattr(struct nfsd4_readdir *cd,
1670 const char *name, int namlen, u32 *p, int *buflen)
1671{
1672 struct svc_export *exp = cd->rd_fhp->fh_export;
1673 struct dentry *dentry;
1674 int nfserr;
1675
1676 dentry = lookup_one_len(name, cd->rd_fhp->fh_dentry, namlen);
1677 if (IS_ERR(dentry))
1678 return nfserrno(PTR_ERR(dentry));
1679
1680 exp_get(exp);
1681 if (d_mountpoint(dentry)) {
1682 if (nfsd_cross_mnt(cd->rd_rqstp, &dentry, &exp)) {
1683 /*
1684 * -EAGAIN is the only error returned from
1685 * nfsd_cross_mnt() and it indicates that an
1686 * up-call has been initiated to fill in the export
1687 * options on exp. When the answer comes back,
1688 * this call will be retried.
1689 */
1690 nfserr = nfserr_dropit;
1691 goto out_put;
1692 }
1693
1694 }
1695 nfserr = nfsd4_encode_fattr(NULL, exp, dentry, p, buflen, cd->rd_bmval,
1696 cd->rd_rqstp);
1697out_put:
1698 dput(dentry);
1699 exp_put(exp);
1700 return nfserr;
1701}
1702
1703static u32 *
1704nfsd4_encode_rdattr_error(u32 *p, int buflen, int nfserr)
1705{
1706 u32 *attrlenp;
1707
1708 if (buflen < 6)
1709 return NULL;
1710 *p++ = htonl(2);
1711 *p++ = htonl(FATTR4_WORD0_RDATTR_ERROR); /* bmval0 */
1712 *p++ = htonl(0); /* bmval1 */
1713
1714 attrlenp = p++;
1715 *p++ = nfserr; /* no htonl */
1716 *attrlenp = htonl((char *)p - (char *)attrlenp - 4);
1717 return p;
1718}
1719
1720static int
1721nfsd4_encode_dirent(struct readdir_cd *ccd, const char *name, int namlen,
1722 loff_t offset, ino_t ino, unsigned int d_type)
1723{
1724 struct nfsd4_readdir *cd = container_of(ccd, struct nfsd4_readdir, common);
1725 int buflen;
1726 u32 *p = cd->buffer;
1727 int nfserr = nfserr_toosmall;
1728
1729 /* In nfsv4, "." and ".." never make it onto the wire.. */
1730 if (name && isdotent(name, namlen)) {
1731 cd->common.err = nfs_ok;
1732 return 0;
1733 }
1734
1735 if (cd->offset)
1736 xdr_encode_hyper(cd->offset, (u64) offset);
1737
1738 buflen = cd->buflen - 4 - XDR_QUADLEN(namlen);
1739 if (buflen < 0)
1740 goto fail;
1741
1742 *p++ = xdr_one; /* mark entry present */
1743 cd->offset = p; /* remember pointer */
1744 p = xdr_encode_hyper(p, NFS_OFFSET_MAX); /* offset of next entry */
1745 p = xdr_encode_array(p, name, namlen); /* name length & name */
1746
1747 nfserr = nfsd4_encode_dirent_fattr(cd, name, namlen, p, &buflen);
1748 switch (nfserr) {
1749 case nfs_ok:
1750 p += buflen;
1751 break;
1752 case nfserr_resource:
1753 nfserr = nfserr_toosmall;
1754 goto fail;
1755 case nfserr_dropit:
1756 goto fail;
1757 default:
1758 /*
1759 * If the client requested the RDATTR_ERROR attribute,
1760 * we stuff the error code into this attribute
1761 * and continue. If this attribute was not requested,
1762 * then in accordance with the spec, we fail the
1763 * entire READDIR operation(!)
1764 */
1765 if (!(cd->rd_bmval[0] & FATTR4_WORD0_RDATTR_ERROR))
1766 goto fail;
1767 nfserr = nfserr_toosmall;
1768 p = nfsd4_encode_rdattr_error(p, buflen, nfserr);
1769 if (p == NULL)
1770 goto fail;
1771 }
1772 cd->buflen -= (p - cd->buffer);
1773 cd->buffer = p;
1774 cd->common.err = nfs_ok;
1775 return 0;
1776fail:
1777 cd->common.err = nfserr;
1778 return -EINVAL;
1779}
1780
1781static void
1782nfsd4_encode_access(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_access *access)
1783{
1784 ENCODE_HEAD;
1785
1786 if (!nfserr) {
1787 RESERVE_SPACE(8);
1788 WRITE32(access->ac_supported);
1789 WRITE32(access->ac_resp_access);
1790 ADJUST_ARGS();
1791 }
1792}
1793
1794static void
1795nfsd4_encode_close(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_close *close)
1796{
1797 ENCODE_SEQID_OP_HEAD;
1798
1799 if (!nfserr) {
1800 RESERVE_SPACE(sizeof(stateid_t));
1801 WRITE32(close->cl_stateid.si_generation);
1802 WRITEMEM(&close->cl_stateid.si_opaque, sizeof(stateid_opaque_t));
1803 ADJUST_ARGS();
1804 }
1805 ENCODE_SEQID_OP_TAIL(close->cl_stateowner);
1806}
1807
1808
1809static void
1810nfsd4_encode_commit(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_commit *commit)
1811{
1812 ENCODE_HEAD;
1813
1814 if (!nfserr) {
1815 RESERVE_SPACE(8);
1816 WRITEMEM(commit->co_verf.data, 8);
1817 ADJUST_ARGS();
1818 }
1819}
1820
1821static void
1822nfsd4_encode_create(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_create *create)
1823{
1824 ENCODE_HEAD;
1825
1826 if (!nfserr) {
1827 RESERVE_SPACE(32);
1828 WRITECINFO(create->cr_cinfo);
1829 WRITE32(2);
1830 WRITE32(create->cr_bmval[0]);
1831 WRITE32(create->cr_bmval[1]);
1832 ADJUST_ARGS();
1833 }
1834}
1835
1836static int
1837nfsd4_encode_getattr(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_getattr *getattr)
1838{
1839 struct svc_fh *fhp = getattr->ga_fhp;
1840 int buflen;
1841
1842 if (nfserr)
1843 return nfserr;
1844
1845 buflen = resp->end - resp->p - (COMPOUND_ERR_SLACK_SPACE >> 2);
1846 nfserr = nfsd4_encode_fattr(fhp, fhp->fh_export, fhp->fh_dentry,
1847 resp->p, &buflen, getattr->ga_bmval,
1848 resp->rqstp);
1849
1850 if (!nfserr)
1851 resp->p += buflen;
1852 return nfserr;
1853}
1854
1855static void
1856nfsd4_encode_getfh(struct nfsd4_compoundres *resp, int nfserr, struct svc_fh *fhp)
1857{
1858 unsigned int len;
1859 ENCODE_HEAD;
1860
1861 if (!nfserr) {
1862 len = fhp->fh_handle.fh_size;
1863 RESERVE_SPACE(len + 4);
1864 WRITE32(len);
1865 WRITEMEM(&fhp->fh_handle.fh_base, len);
1866 ADJUST_ARGS();
1867 }
1868}
1869
1870/*
1871* Including all fields other than the name, a LOCK4denied structure requires
1872* 8(clientid) + 4(namelen) + 8(offset) + 8(length) + 4(type) = 32 bytes.
1873*/
1874static void
1875nfsd4_encode_lock_denied(struct nfsd4_compoundres *resp, struct nfsd4_lock_denied *ld)
1876{
1877 ENCODE_HEAD;
1878
1879 RESERVE_SPACE(32 + XDR_LEN(ld->ld_sop ? ld->ld_sop->so_owner.len : 0));
1880 WRITE64(ld->ld_start);
1881 WRITE64(ld->ld_length);
1882 WRITE32(ld->ld_type);
1883 if (ld->ld_sop) {
1884 WRITEMEM(&ld->ld_clientid, 8);
1885 WRITE32(ld->ld_sop->so_owner.len);
1886 WRITEMEM(ld->ld_sop->so_owner.data, ld->ld_sop->so_owner.len);
1887 kref_put(&ld->ld_sop->so_ref, nfs4_free_stateowner);
1888 } else { /* non - nfsv4 lock in conflict, no clientid nor owner */
1889 WRITE64((u64)0); /* clientid */
1890 WRITE32(0); /* length of owner name */
1891 }
1892 ADJUST_ARGS();
1893}
1894
1895static void
1896nfsd4_encode_lock(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_lock *lock)
1897{
1898
1899 ENCODE_SEQID_OP_HEAD;
1900
1901 if (!nfserr) {
1902 RESERVE_SPACE(4 + sizeof(stateid_t));
1903 WRITE32(lock->lk_resp_stateid.si_generation);
1904 WRITEMEM(&lock->lk_resp_stateid.si_opaque, sizeof(stateid_opaque_t));
1905 ADJUST_ARGS();
1906 } else if (nfserr == nfserr_denied)
1907 nfsd4_encode_lock_denied(resp, &lock->lk_denied);
1908
1909 ENCODE_SEQID_OP_TAIL(lock->lk_stateowner);
1910}
1911
1912static void
1913nfsd4_encode_lockt(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_lockt *lockt)
1914{
1915 if (nfserr == nfserr_denied)
1916 nfsd4_encode_lock_denied(resp, &lockt->lt_denied);
1917}
1918
1919static void
1920nfsd4_encode_locku(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_locku *locku)
1921{
1922 ENCODE_SEQID_OP_HEAD;
1923
1924 if (!nfserr) {
1925 RESERVE_SPACE(sizeof(stateid_t));
1926 WRITE32(locku->lu_stateid.si_generation);
1927 WRITEMEM(&locku->lu_stateid.si_opaque, sizeof(stateid_opaque_t));
1928 ADJUST_ARGS();
1929 }
1930
1931 ENCODE_SEQID_OP_TAIL(locku->lu_stateowner);
1932}
1933
1934
1935static void
1936nfsd4_encode_link(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_link *link)
1937{
1938 ENCODE_HEAD;
1939
1940 if (!nfserr) {
1941 RESERVE_SPACE(20);
1942 WRITECINFO(link->li_cinfo);
1943 ADJUST_ARGS();
1944 }
1945}
1946
1947
1948static void
1949nfsd4_encode_open(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_open *open)
1950{
1951 ENCODE_SEQID_OP_HEAD;
1952
1953 if (nfserr)
1954 goto out;
1955
1956 RESERVE_SPACE(36 + sizeof(stateid_t));
1957 WRITE32(open->op_stateid.si_generation);
1958 WRITEMEM(&open->op_stateid.si_opaque, sizeof(stateid_opaque_t));
1959 WRITECINFO(open->op_cinfo);
1960 WRITE32(open->op_rflags);
1961 WRITE32(2);
1962 WRITE32(open->op_bmval[0]);
1963 WRITE32(open->op_bmval[1]);
1964 WRITE32(open->op_delegate_type);
1965 ADJUST_ARGS();
1966
1967 switch (open->op_delegate_type) {
1968 case NFS4_OPEN_DELEGATE_NONE:
1969 break;
1970 case NFS4_OPEN_DELEGATE_READ:
1971 RESERVE_SPACE(20 + sizeof(stateid_t));
1972 WRITEMEM(&open->op_delegate_stateid, sizeof(stateid_t));
NeilBrown7b190fe2005-06-23 22:03:23 -07001973 WRITE32(open->op_recall);
Linus Torvalds1da177e2005-04-16 15:20:36 -07001974
1975 /*
1976 * TODO: ACE's in delegations
1977 */
1978 WRITE32(NFS4_ACE_ACCESS_ALLOWED_ACE_TYPE);
1979 WRITE32(0);
1980 WRITE32(0);
1981 WRITE32(0); /* XXX: is NULL principal ok? */
1982 ADJUST_ARGS();
1983 break;
1984 case NFS4_OPEN_DELEGATE_WRITE:
1985 RESERVE_SPACE(32 + sizeof(stateid_t));
1986 WRITEMEM(&open->op_delegate_stateid, sizeof(stateid_t));
1987 WRITE32(0);
1988
1989 /*
1990 * TODO: space_limit's in delegations
1991 */
1992 WRITE32(NFS4_LIMIT_SIZE);
1993 WRITE32(~(u32)0);
1994 WRITE32(~(u32)0);
1995
1996 /*
1997 * TODO: ACE's in delegations
1998 */
1999 WRITE32(NFS4_ACE_ACCESS_ALLOWED_ACE_TYPE);
2000 WRITE32(0);
2001 WRITE32(0);
2002 WRITE32(0); /* XXX: is NULL principal ok? */
2003 ADJUST_ARGS();
2004 break;
2005 default:
2006 BUG();
2007 }
2008 /* XXX save filehandle here */
2009out:
2010 ENCODE_SEQID_OP_TAIL(open->op_stateowner);
2011}
2012
2013static void
2014nfsd4_encode_open_confirm(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_open_confirm *oc)
2015{
2016 ENCODE_SEQID_OP_HEAD;
2017
2018 if (!nfserr) {
2019 RESERVE_SPACE(sizeof(stateid_t));
2020 WRITE32(oc->oc_resp_stateid.si_generation);
2021 WRITEMEM(&oc->oc_resp_stateid.si_opaque, sizeof(stateid_opaque_t));
2022 ADJUST_ARGS();
2023 }
2024
2025 ENCODE_SEQID_OP_TAIL(oc->oc_stateowner);
2026}
2027
2028static void
2029nfsd4_encode_open_downgrade(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_open_downgrade *od)
2030{
2031 ENCODE_SEQID_OP_HEAD;
2032
2033 if (!nfserr) {
2034 RESERVE_SPACE(sizeof(stateid_t));
2035 WRITE32(od->od_stateid.si_generation);
2036 WRITEMEM(&od->od_stateid.si_opaque, sizeof(stateid_opaque_t));
2037 ADJUST_ARGS();
2038 }
2039
2040 ENCODE_SEQID_OP_TAIL(od->od_stateowner);
2041}
2042
2043static int
2044nfsd4_encode_read(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_read *read)
2045{
2046 u32 eof;
2047 int v, pn;
2048 unsigned long maxcount;
2049 long len;
2050 ENCODE_HEAD;
2051
2052 if (nfserr)
2053 return nfserr;
2054 if (resp->xbuf->page_len)
2055 return nfserr_resource;
2056
2057 RESERVE_SPACE(8); /* eof flag and byte count */
2058
2059 maxcount = NFSSVC_MAXBLKSIZE;
2060 if (maxcount > read->rd_length)
2061 maxcount = read->rd_length;
2062
2063 len = maxcount;
2064 v = 0;
2065 while (len > 0) {
2066 pn = resp->rqstp->rq_resused;
2067 svc_take_page(resp->rqstp);
2068 read->rd_iov[v].iov_base = page_address(resp->rqstp->rq_respages[pn]);
2069 read->rd_iov[v].iov_len = len < PAGE_SIZE ? len : PAGE_SIZE;
2070 v++;
2071 len -= PAGE_SIZE;
2072 }
2073 read->rd_vlen = v;
2074
2075 nfserr = nfsd_read(read->rd_rqstp, read->rd_fhp, read->rd_filp,
2076 read->rd_offset, read->rd_iov, read->rd_vlen,
2077 &maxcount);
2078
2079 if (nfserr == nfserr_symlink)
2080 nfserr = nfserr_inval;
2081 if (nfserr)
2082 return nfserr;
2083 eof = (read->rd_offset + maxcount >= read->rd_fhp->fh_dentry->d_inode->i_size);
2084
2085 WRITE32(eof);
2086 WRITE32(maxcount);
2087 ADJUST_ARGS();
2088 resp->xbuf->head[0].iov_len = ((char*)resp->p) - (char*)resp->xbuf->head[0].iov_base;
2089
2090 resp->xbuf->page_len = maxcount;
2091
2092 /* read zero bytes -> don't set up tail */
2093 if(!maxcount)
2094 return 0;
2095
2096 /* set up page for remaining responses */
2097 svc_take_page(resp->rqstp);
2098 resp->xbuf->tail[0].iov_base =
2099 page_address(resp->rqstp->rq_respages[resp->rqstp->rq_resused-1]);
2100 resp->rqstp->rq_restailpage = resp->rqstp->rq_resused-1;
2101 resp->xbuf->tail[0].iov_len = 0;
2102 resp->p = resp->xbuf->tail[0].iov_base;
2103 resp->end = resp->p + PAGE_SIZE/4;
2104
2105 if (maxcount&3) {
2106 *(resp->p)++ = 0;
2107 resp->xbuf->tail[0].iov_base += maxcount&3;
2108 resp->xbuf->tail[0].iov_len = 4 - (maxcount&3);
2109 }
2110 return 0;
2111}
2112
2113static int
2114nfsd4_encode_readlink(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_readlink *readlink)
2115{
2116 int maxcount;
2117 char *page;
2118 ENCODE_HEAD;
2119
2120 if (nfserr)
2121 return nfserr;
2122 if (resp->xbuf->page_len)
2123 return nfserr_resource;
2124
2125 svc_take_page(resp->rqstp);
2126 page = page_address(resp->rqstp->rq_respages[resp->rqstp->rq_resused-1]);
2127
2128 maxcount = PAGE_SIZE;
2129 RESERVE_SPACE(4);
2130
2131 /*
2132 * XXX: By default, the ->readlink() VFS op will truncate symlinks
2133 * if they would overflow the buffer. Is this kosher in NFSv4? If
2134 * not, one easy fix is: if ->readlink() precisely fills the buffer,
2135 * assume that truncation occurred, and return NFS4ERR_RESOURCE.
2136 */
2137 nfserr = nfsd_readlink(readlink->rl_rqstp, readlink->rl_fhp, page, &maxcount);
2138 if (nfserr == nfserr_isdir)
2139 return nfserr_inval;
2140 if (nfserr)
2141 return nfserr;
2142
2143 WRITE32(maxcount);
2144 ADJUST_ARGS();
2145 resp->xbuf->head[0].iov_len = ((char*)resp->p) - (char*)resp->xbuf->head[0].iov_base;
2146
2147 svc_take_page(resp->rqstp);
2148 resp->xbuf->tail[0].iov_base =
2149 page_address(resp->rqstp->rq_respages[resp->rqstp->rq_resused-1]);
2150 resp->rqstp->rq_restailpage = resp->rqstp->rq_resused-1;
2151 resp->xbuf->tail[0].iov_len = 0;
2152 resp->p = resp->xbuf->tail[0].iov_base;
2153 resp->end = resp->p + PAGE_SIZE/4;
2154
2155 resp->xbuf->page_len = maxcount;
2156 if (maxcount&3) {
2157 *(resp->p)++ = 0;
2158 resp->xbuf->tail[0].iov_base += maxcount&3;
2159 resp->xbuf->tail[0].iov_len = 4 - (maxcount&3);
2160 }
2161 return 0;
2162}
2163
2164static int
2165nfsd4_encode_readdir(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_readdir *readdir)
2166{
2167 int maxcount;
2168 loff_t offset;
2169 u32 *page, *savep;
2170 ENCODE_HEAD;
2171
2172 if (nfserr)
2173 return nfserr;
2174 if (resp->xbuf->page_len)
2175 return nfserr_resource;
2176
2177 RESERVE_SPACE(8); /* verifier */
2178 savep = p;
2179
2180 /* XXX: Following NFSv3, we ignore the READDIR verifier for now. */
2181 WRITE32(0);
2182 WRITE32(0);
2183 ADJUST_ARGS();
2184 resp->xbuf->head[0].iov_len = ((char*)resp->p) - (char*)resp->xbuf->head[0].iov_base;
2185
2186 maxcount = PAGE_SIZE;
2187 if (maxcount > readdir->rd_maxcount)
2188 maxcount = readdir->rd_maxcount;
2189
2190 /*
2191 * Convert from bytes to words, account for the two words already
2192 * written, make sure to leave two words at the end for the next
2193 * pointer and eof field.
2194 */
2195 maxcount = (maxcount >> 2) - 4;
2196 if (maxcount < 0) {
2197 nfserr = nfserr_toosmall;
2198 goto err_no_verf;
2199 }
2200
2201 svc_take_page(resp->rqstp);
2202 page = page_address(resp->rqstp->rq_respages[resp->rqstp->rq_resused-1]);
2203 readdir->common.err = 0;
2204 readdir->buflen = maxcount;
2205 readdir->buffer = page;
2206 readdir->offset = NULL;
2207
2208 offset = readdir->rd_cookie;
2209 nfserr = nfsd_readdir(readdir->rd_rqstp, readdir->rd_fhp,
2210 &offset,
2211 &readdir->common, nfsd4_encode_dirent);
2212 if (nfserr == nfs_ok &&
2213 readdir->common.err == nfserr_toosmall &&
2214 readdir->buffer == page)
2215 nfserr = nfserr_toosmall;
2216 if (nfserr == nfserr_symlink)
2217 nfserr = nfserr_notdir;
2218 if (nfserr)
2219 goto err_no_verf;
2220
2221 if (readdir->offset)
2222 xdr_encode_hyper(readdir->offset, offset);
2223
2224 p = readdir->buffer;
2225 *p++ = 0; /* no more entries */
2226 *p++ = htonl(readdir->common.err == nfserr_eof);
2227 resp->xbuf->page_len = ((char*)p) - (char*)page_address(resp->rqstp->rq_respages[resp->rqstp->rq_resused-1]);
2228
2229 /* allocate a page for the tail */
2230 svc_take_page(resp->rqstp);
2231 resp->xbuf->tail[0].iov_base =
2232 page_address(resp->rqstp->rq_respages[resp->rqstp->rq_resused-1]);
2233 resp->rqstp->rq_restailpage = resp->rqstp->rq_resused-1;
2234 resp->xbuf->tail[0].iov_len = 0;
2235 resp->p = resp->xbuf->tail[0].iov_base;
2236 resp->end = resp->p + PAGE_SIZE/4;
2237
2238 return 0;
2239err_no_verf:
2240 p = savep;
2241 ADJUST_ARGS();
2242 return nfserr;
2243}
2244
2245static void
2246nfsd4_encode_remove(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_remove *remove)
2247{
2248 ENCODE_HEAD;
2249
2250 if (!nfserr) {
2251 RESERVE_SPACE(20);
2252 WRITECINFO(remove->rm_cinfo);
2253 ADJUST_ARGS();
2254 }
2255}
2256
2257static void
2258nfsd4_encode_rename(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_rename *rename)
2259{
2260 ENCODE_HEAD;
2261
2262 if (!nfserr) {
2263 RESERVE_SPACE(40);
2264 WRITECINFO(rename->rn_sinfo);
2265 WRITECINFO(rename->rn_tinfo);
2266 ADJUST_ARGS();
2267 }
2268}
2269
2270/*
2271 * The SETATTR encode routine is special -- it always encodes a bitmap,
2272 * regardless of the error status.
2273 */
2274static void
2275nfsd4_encode_setattr(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_setattr *setattr)
2276{
2277 ENCODE_HEAD;
2278
2279 RESERVE_SPACE(12);
2280 if (nfserr) {
2281 WRITE32(2);
2282 WRITE32(0);
2283 WRITE32(0);
2284 }
2285 else {
2286 WRITE32(2);
2287 WRITE32(setattr->sa_bmval[0]);
2288 WRITE32(setattr->sa_bmval[1]);
2289 }
2290 ADJUST_ARGS();
2291}
2292
2293static void
2294nfsd4_encode_setclientid(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_setclientid *scd)
2295{
2296 ENCODE_HEAD;
2297
2298 if (!nfserr) {
2299 RESERVE_SPACE(8 + sizeof(nfs4_verifier));
2300 WRITEMEM(&scd->se_clientid, 8);
2301 WRITEMEM(&scd->se_confirm, sizeof(nfs4_verifier));
2302 ADJUST_ARGS();
2303 }
2304 else if (nfserr == nfserr_clid_inuse) {
2305 RESERVE_SPACE(8);
2306 WRITE32(0);
2307 WRITE32(0);
2308 ADJUST_ARGS();
2309 }
2310}
2311
2312static void
2313nfsd4_encode_write(struct nfsd4_compoundres *resp, int nfserr, struct nfsd4_write *write)
2314{
2315 ENCODE_HEAD;
2316
2317 if (!nfserr) {
2318 RESERVE_SPACE(16);
2319 WRITE32(write->wr_bytes_written);
2320 WRITE32(write->wr_how_written);
2321 WRITEMEM(write->wr_verifier.data, 8);
2322 ADJUST_ARGS();
2323 }
2324}
2325
2326void
2327nfsd4_encode_operation(struct nfsd4_compoundres *resp, struct nfsd4_op *op)
2328{
2329 u32 *statp;
2330 ENCODE_HEAD;
2331
2332 RESERVE_SPACE(8);
2333 WRITE32(op->opnum);
2334 statp = p++; /* to be backfilled at the end */
2335 ADJUST_ARGS();
2336
2337 switch (op->opnum) {
2338 case OP_ACCESS:
2339 nfsd4_encode_access(resp, op->status, &op->u.access);
2340 break;
2341 case OP_CLOSE:
2342 nfsd4_encode_close(resp, op->status, &op->u.close);
2343 break;
2344 case OP_COMMIT:
2345 nfsd4_encode_commit(resp, op->status, &op->u.commit);
2346 break;
2347 case OP_CREATE:
2348 nfsd4_encode_create(resp, op->status, &op->u.create);
2349 break;
2350 case OP_DELEGRETURN:
2351 break;
2352 case OP_GETATTR:
2353 op->status = nfsd4_encode_getattr(resp, op->status, &op->u.getattr);
2354 break;
2355 case OP_GETFH:
2356 nfsd4_encode_getfh(resp, op->status, op->u.getfh);
2357 break;
2358 case OP_LINK:
2359 nfsd4_encode_link(resp, op->status, &op->u.link);
2360 break;
2361 case OP_LOCK:
2362 nfsd4_encode_lock(resp, op->status, &op->u.lock);
2363 break;
2364 case OP_LOCKT:
2365 nfsd4_encode_lockt(resp, op->status, &op->u.lockt);
2366 break;
2367 case OP_LOCKU:
2368 nfsd4_encode_locku(resp, op->status, &op->u.locku);
2369 break;
2370 case OP_LOOKUP:
2371 break;
2372 case OP_LOOKUPP:
2373 break;
2374 case OP_NVERIFY:
2375 break;
2376 case OP_OPEN:
2377 nfsd4_encode_open(resp, op->status, &op->u.open);
2378 break;
2379 case OP_OPEN_CONFIRM:
2380 nfsd4_encode_open_confirm(resp, op->status, &op->u.open_confirm);
2381 break;
2382 case OP_OPEN_DOWNGRADE:
2383 nfsd4_encode_open_downgrade(resp, op->status, &op->u.open_downgrade);
2384 break;
2385 case OP_PUTFH:
2386 break;
2387 case OP_PUTROOTFH:
2388 break;
2389 case OP_READ:
2390 op->status = nfsd4_encode_read(resp, op->status, &op->u.read);
2391 break;
2392 case OP_READDIR:
2393 op->status = nfsd4_encode_readdir(resp, op->status, &op->u.readdir);
2394 break;
2395 case OP_READLINK:
2396 op->status = nfsd4_encode_readlink(resp, op->status, &op->u.readlink);
2397 break;
2398 case OP_REMOVE:
2399 nfsd4_encode_remove(resp, op->status, &op->u.remove);
2400 break;
2401 case OP_RENAME:
2402 nfsd4_encode_rename(resp, op->status, &op->u.rename);
2403 break;
2404 case OP_RENEW:
2405 break;
2406 case OP_RESTOREFH:
2407 break;
2408 case OP_SAVEFH:
2409 break;
2410 case OP_SETATTR:
2411 nfsd4_encode_setattr(resp, op->status, &op->u.setattr);
2412 break;
2413 case OP_SETCLIENTID:
2414 nfsd4_encode_setclientid(resp, op->status, &op->u.setclientid);
2415 break;
2416 case OP_SETCLIENTID_CONFIRM:
2417 break;
2418 case OP_VERIFY:
2419 break;
2420 case OP_WRITE:
2421 nfsd4_encode_write(resp, op->status, &op->u.write);
2422 break;
2423 case OP_RELEASE_LOCKOWNER:
2424 break;
2425 default:
2426 break;
2427 }
2428
2429 /*
2430 * Note: We write the status directly, instead of using WRITE32(),
2431 * since it is already in network byte order.
2432 */
2433 *statp = op->status;
2434}
2435
2436/*
2437 * Encode the reply stored in the stateowner reply cache
2438 *
2439 * XDR note: do not encode rp->rp_buflen: the buffer contains the
2440 * previously sent already encoded operation.
2441 *
2442 * called with nfs4_lock_state() held
2443 */
2444void
2445nfsd4_encode_replay(struct nfsd4_compoundres *resp, struct nfsd4_op *op)
2446{
2447 ENCODE_HEAD;
2448 struct nfs4_replay *rp = op->replay;
2449
2450 BUG_ON(!rp);
2451
2452 RESERVE_SPACE(8);
2453 WRITE32(op->opnum);
2454 *p++ = rp->rp_status; /* already xdr'ed */
2455 ADJUST_ARGS();
2456
2457 RESERVE_SPACE(rp->rp_buflen);
2458 WRITEMEM(rp->rp_buf, rp->rp_buflen);
2459 ADJUST_ARGS();
2460}
2461
2462/*
2463 * END OF "GENERIC" ENCODE ROUTINES.
2464 */
2465
2466int
2467nfs4svc_encode_voidres(struct svc_rqst *rqstp, u32 *p, void *dummy)
2468{
2469 return xdr_ressize_check(rqstp, p);
2470}
2471
2472void nfsd4_release_compoundargs(struct nfsd4_compoundargs *args)
2473{
2474 if (args->ops != args->iops) {
2475 kfree(args->ops);
2476 args->ops = args->iops;
2477 }
Jesper Juhlf99d49a2005-11-07 01:01:34 -08002478 kfree(args->tmpp);
2479 args->tmpp = NULL;
Linus Torvalds1da177e2005-04-16 15:20:36 -07002480 while (args->to_free) {
2481 struct tmpbuf *tb = args->to_free;
2482 args->to_free = tb->next;
2483 tb->release(tb->buf);
2484 kfree(tb);
2485 }
2486}
2487
2488int
2489nfs4svc_decode_compoundargs(struct svc_rqst *rqstp, u32 *p, struct nfsd4_compoundargs *args)
2490{
2491 int status;
2492
2493 args->p = p;
2494 args->end = rqstp->rq_arg.head[0].iov_base + rqstp->rq_arg.head[0].iov_len;
2495 args->pagelist = rqstp->rq_arg.pages;
2496 args->pagelen = rqstp->rq_arg.page_len;
2497 args->tmpp = NULL;
2498 args->to_free = NULL;
2499 args->ops = args->iops;
2500 args->rqstp = rqstp;
2501
2502 status = nfsd4_decode_compound(args);
2503 if (status) {
2504 nfsd4_release_compoundargs(args);
2505 }
2506 return !status;
2507}
2508
2509int
2510nfs4svc_encode_compoundres(struct svc_rqst *rqstp, u32 *p, struct nfsd4_compoundres *resp)
2511{
2512 /*
2513 * All that remains is to write the tag and operation count...
2514 */
2515 struct kvec *iov;
2516 p = resp->tagp;
2517 *p++ = htonl(resp->taglen);
2518 memcpy(p, resp->tag, resp->taglen);
2519 p += XDR_QUADLEN(resp->taglen);
2520 *p++ = htonl(resp->opcnt);
2521
2522 if (rqstp->rq_res.page_len)
2523 iov = &rqstp->rq_res.tail[0];
2524 else
2525 iov = &rqstp->rq_res.head[0];
2526 iov->iov_len = ((char*)resp->p) - (char*)iov->iov_base;
2527 BUG_ON(iov->iov_len > PAGE_SIZE);
2528 return 1;
2529}
2530
2531/*
2532 * Local variables:
2533 * c-basic-offset: 8
2534 * End:
2535 */