nfs3xdr.c 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128
  1. /*
  2. * XDR support for nfsd/protocol version 3.
  3. *
  4. * Copyright (C) 1995, 1996, 1997 Olaf Kirch <okir@monad.swb.de>
  5. *
  6. * 2003-08-09 Jamie Lokier: Use htonl() for nanoseconds, not htons()!
  7. */
  8. #include <linux/namei.h>
  9. #include <linux/sunrpc/svc_xprt.h>
  10. #include "xdr3.h"
  11. #include "auth.h"
  12. #include "netns.h"
  13. #include "vfs.h"
  14. #define NFSDDBG_FACILITY NFSDDBG_XDR
  15. /*
  16. * Mapping of S_IF* types to NFS file types
  17. */
  18. static u32 nfs3_ftypes[] = {
  19. NF3NON, NF3FIFO, NF3CHR, NF3BAD,
  20. NF3DIR, NF3BAD, NF3BLK, NF3BAD,
  21. NF3REG, NF3BAD, NF3LNK, NF3BAD,
  22. NF3SOCK, NF3BAD, NF3LNK, NF3BAD,
  23. };
  24. /*
  25. * XDR functions for basic NFS types
  26. */
  27. static __be32 *
  28. encode_time3(__be32 *p, struct timespec *time)
  29. {
  30. *p++ = htonl((u32) time->tv_sec); *p++ = htonl(time->tv_nsec);
  31. return p;
  32. }
  33. static __be32 *
  34. decode_time3(__be32 *p, struct timespec *time)
  35. {
  36. time->tv_sec = ntohl(*p++);
  37. time->tv_nsec = ntohl(*p++);
  38. return p;
  39. }
  40. static __be32 *
  41. decode_fh(__be32 *p, struct svc_fh *fhp)
  42. {
  43. unsigned int size;
  44. fh_init(fhp, NFS3_FHSIZE);
  45. size = ntohl(*p++);
  46. if (size > NFS3_FHSIZE)
  47. return NULL;
  48. memcpy(&fhp->fh_handle.fh_base, p, size);
  49. fhp->fh_handle.fh_size = size;
  50. return p + XDR_QUADLEN(size);
  51. }
  52. /* Helper function for NFSv3 ACL code */
  53. __be32 *nfs3svc_decode_fh(__be32 *p, struct svc_fh *fhp)
  54. {
  55. return decode_fh(p, fhp);
  56. }
  57. static __be32 *
  58. encode_fh(__be32 *p, struct svc_fh *fhp)
  59. {
  60. unsigned int size = fhp->fh_handle.fh_size;
  61. *p++ = htonl(size);
  62. if (size) p[XDR_QUADLEN(size)-1]=0;
  63. memcpy(p, &fhp->fh_handle.fh_base, size);
  64. return p + XDR_QUADLEN(size);
  65. }
  66. /*
  67. * Decode a file name and make sure that the path contains
  68. * no slashes or null bytes.
  69. */
  70. static __be32 *
  71. decode_filename(__be32 *p, char **namp, unsigned int *lenp)
  72. {
  73. char *name;
  74. unsigned int i;
  75. if ((p = xdr_decode_string_inplace(p, namp, lenp, NFS3_MAXNAMLEN)) != NULL) {
  76. for (i = 0, name = *namp; i < *lenp; i++, name++) {
  77. if (*name == '\0' || *name == '/')
  78. return NULL;
  79. }
  80. }
  81. return p;
  82. }
  83. static __be32 *
  84. decode_sattr3(__be32 *p, struct iattr *iap)
  85. {
  86. u32 tmp;
  87. iap->ia_valid = 0;
  88. if (*p++) {
  89. iap->ia_valid |= ATTR_MODE;
  90. iap->ia_mode = ntohl(*p++);
  91. }
  92. if (*p++) {
  93. iap->ia_uid = make_kuid(&init_user_ns, ntohl(*p++));
  94. if (uid_valid(iap->ia_uid))
  95. iap->ia_valid |= ATTR_UID;
  96. }
  97. if (*p++) {
  98. iap->ia_gid = make_kgid(&init_user_ns, ntohl(*p++));
  99. if (gid_valid(iap->ia_gid))
  100. iap->ia_valid |= ATTR_GID;
  101. }
  102. if (*p++) {
  103. u64 newsize;
  104. iap->ia_valid |= ATTR_SIZE;
  105. p = xdr_decode_hyper(p, &newsize);
  106. if (newsize <= NFS_OFFSET_MAX)
  107. iap->ia_size = newsize;
  108. else
  109. iap->ia_size = NFS_OFFSET_MAX;
  110. }
  111. if ((tmp = ntohl(*p++)) == 1) { /* set to server time */
  112. iap->ia_valid |= ATTR_ATIME;
  113. } else if (tmp == 2) { /* set to client time */
  114. iap->ia_valid |= ATTR_ATIME | ATTR_ATIME_SET;
  115. iap->ia_atime.tv_sec = ntohl(*p++);
  116. iap->ia_atime.tv_nsec = ntohl(*p++);
  117. }
  118. if ((tmp = ntohl(*p++)) == 1) { /* set to server time */
  119. iap->ia_valid |= ATTR_MTIME;
  120. } else if (tmp == 2) { /* set to client time */
  121. iap->ia_valid |= ATTR_MTIME | ATTR_MTIME_SET;
  122. iap->ia_mtime.tv_sec = ntohl(*p++);
  123. iap->ia_mtime.tv_nsec = ntohl(*p++);
  124. }
  125. return p;
  126. }
  127. static __be32 *encode_fsid(__be32 *p, struct svc_fh *fhp)
  128. {
  129. u64 f;
  130. switch(fsid_source(fhp)) {
  131. default:
  132. case FSIDSOURCE_DEV:
  133. p = xdr_encode_hyper(p, (u64)huge_encode_dev
  134. (fhp->fh_dentry->d_inode->i_sb->s_dev));
  135. break;
  136. case FSIDSOURCE_FSID:
  137. p = xdr_encode_hyper(p, (u64) fhp->fh_export->ex_fsid);
  138. break;
  139. case FSIDSOURCE_UUID:
  140. f = ((u64*)fhp->fh_export->ex_uuid)[0];
  141. f ^= ((u64*)fhp->fh_export->ex_uuid)[1];
  142. p = xdr_encode_hyper(p, f);
  143. break;
  144. }
  145. return p;
  146. }
  147. static __be32 *
  148. encode_fattr3(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp,
  149. struct kstat *stat)
  150. {
  151. *p++ = htonl(nfs3_ftypes[(stat->mode & S_IFMT) >> 12]);
  152. *p++ = htonl((u32) (stat->mode & S_IALLUGO));
  153. *p++ = htonl((u32) stat->nlink);
  154. *p++ = htonl((u32) from_kuid(&init_user_ns, stat->uid));
  155. *p++ = htonl((u32) from_kgid(&init_user_ns, stat->gid));
  156. if (S_ISLNK(stat->mode) && stat->size > NFS3_MAXPATHLEN) {
  157. p = xdr_encode_hyper(p, (u64) NFS3_MAXPATHLEN);
  158. } else {
  159. p = xdr_encode_hyper(p, (u64) stat->size);
  160. }
  161. p = xdr_encode_hyper(p, ((u64)stat->blocks) << 9);
  162. *p++ = htonl((u32) MAJOR(stat->rdev));
  163. *p++ = htonl((u32) MINOR(stat->rdev));
  164. p = encode_fsid(p, fhp);
  165. p = xdr_encode_hyper(p, stat->ino);
  166. p = encode_time3(p, &stat->atime);
  167. p = encode_time3(p, &stat->mtime);
  168. p = encode_time3(p, &stat->ctime);
  169. return p;
  170. }
  171. static __be32 *
  172. encode_saved_post_attr(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp)
  173. {
  174. /* Attributes to follow */
  175. *p++ = xdr_one;
  176. return encode_fattr3(rqstp, p, fhp, &fhp->fh_post_attr);
  177. }
  178. /*
  179. * Encode post-operation attributes.
  180. * The inode may be NULL if the call failed because of a stale file
  181. * handle. In this case, no attributes are returned.
  182. */
  183. static __be32 *
  184. encode_post_op_attr(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp)
  185. {
  186. struct dentry *dentry = fhp->fh_dentry;
  187. if (dentry && dentry->d_inode) {
  188. __be32 err;
  189. struct kstat stat;
  190. err = fh_getattr(fhp, &stat);
  191. if (!err) {
  192. *p++ = xdr_one; /* attributes follow */
  193. lease_get_mtime(dentry->d_inode, &stat.mtime);
  194. return encode_fattr3(rqstp, p, fhp, &stat);
  195. }
  196. }
  197. *p++ = xdr_zero;
  198. return p;
  199. }
  200. /* Helper for NFSv3 ACLs */
  201. __be32 *
  202. nfs3svc_encode_post_op_attr(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp)
  203. {
  204. return encode_post_op_attr(rqstp, p, fhp);
  205. }
  206. /*
  207. * Enocde weak cache consistency data
  208. */
  209. static __be32 *
  210. encode_wcc_data(struct svc_rqst *rqstp, __be32 *p, struct svc_fh *fhp)
  211. {
  212. struct dentry *dentry = fhp->fh_dentry;
  213. if (dentry && dentry->d_inode && fhp->fh_post_saved) {
  214. if (fhp->fh_pre_saved) {
  215. *p++ = xdr_one;
  216. p = xdr_encode_hyper(p, (u64) fhp->fh_pre_size);
  217. p = encode_time3(p, &fhp->fh_pre_mtime);
  218. p = encode_time3(p, &fhp->fh_pre_ctime);
  219. } else {
  220. *p++ = xdr_zero;
  221. }
  222. return encode_saved_post_attr(rqstp, p, fhp);
  223. }
  224. /* no pre- or post-attrs */
  225. *p++ = xdr_zero;
  226. return encode_post_op_attr(rqstp, p, fhp);
  227. }
  228. /*
  229. * Fill in the post_op attr for the wcc data
  230. */
  231. void fill_post_wcc(struct svc_fh *fhp)
  232. {
  233. __be32 err;
  234. if (fhp->fh_post_saved)
  235. printk("nfsd: inode locked twice during operation.\n");
  236. err = fh_getattr(fhp, &fhp->fh_post_attr);
  237. fhp->fh_post_change = fhp->fh_dentry->d_inode->i_version;
  238. if (err) {
  239. fhp->fh_post_saved = 0;
  240. /* Grab the ctime anyway - set_change_info might use it */
  241. fhp->fh_post_attr.ctime = fhp->fh_dentry->d_inode->i_ctime;
  242. } else
  243. fhp->fh_post_saved = 1;
  244. }
  245. /*
  246. * XDR decode functions
  247. */
  248. int
  249. nfs3svc_decode_fhandle(struct svc_rqst *rqstp, __be32 *p, struct nfsd_fhandle *args)
  250. {
  251. p = decode_fh(p, &args->fh);
  252. if (!p)
  253. return 0;
  254. return xdr_argsize_check(rqstp, p);
  255. }
  256. int
  257. nfs3svc_decode_sattrargs(struct svc_rqst *rqstp, __be32 *p,
  258. struct nfsd3_sattrargs *args)
  259. {
  260. p = decode_fh(p, &args->fh);
  261. if (!p)
  262. return 0;
  263. p = decode_sattr3(p, &args->attrs);
  264. if ((args->check_guard = ntohl(*p++)) != 0) {
  265. struct timespec time;
  266. p = decode_time3(p, &time);
  267. args->guardtime = time.tv_sec;
  268. }
  269. return xdr_argsize_check(rqstp, p);
  270. }
  271. int
  272. nfs3svc_decode_diropargs(struct svc_rqst *rqstp, __be32 *p,
  273. struct nfsd3_diropargs *args)
  274. {
  275. if (!(p = decode_fh(p, &args->fh))
  276. || !(p = decode_filename(p, &args->name, &args->len)))
  277. return 0;
  278. return xdr_argsize_check(rqstp, p);
  279. }
  280. int
  281. nfs3svc_decode_accessargs(struct svc_rqst *rqstp, __be32 *p,
  282. struct nfsd3_accessargs *args)
  283. {
  284. p = decode_fh(p, &args->fh);
  285. if (!p)
  286. return 0;
  287. args->access = ntohl(*p++);
  288. return xdr_argsize_check(rqstp, p);
  289. }
  290. int
  291. nfs3svc_decode_readargs(struct svc_rqst *rqstp, __be32 *p,
  292. struct nfsd3_readargs *args)
  293. {
  294. unsigned int len;
  295. int v;
  296. u32 max_blocksize = svc_max_payload(rqstp);
  297. p = decode_fh(p, &args->fh);
  298. if (!p)
  299. return 0;
  300. p = xdr_decode_hyper(p, &args->offset);
  301. len = args->count = ntohl(*p++);
  302. if (len > max_blocksize)
  303. len = max_blocksize;
  304. /* set up the kvec */
  305. v=0;
  306. while (len > 0) {
  307. struct page *p = *(rqstp->rq_next_page++);
  308. rqstp->rq_vec[v].iov_base = page_address(p);
  309. rqstp->rq_vec[v].iov_len = len < PAGE_SIZE? len : PAGE_SIZE;
  310. len -= rqstp->rq_vec[v].iov_len;
  311. v++;
  312. }
  313. args->vlen = v;
  314. return xdr_argsize_check(rqstp, p);
  315. }
  316. int
  317. nfs3svc_decode_writeargs(struct svc_rqst *rqstp, __be32 *p,
  318. struct nfsd3_writeargs *args)
  319. {
  320. unsigned int len, v, hdr, dlen;
  321. u32 max_blocksize = svc_max_payload(rqstp);
  322. p = decode_fh(p, &args->fh);
  323. if (!p)
  324. return 0;
  325. p = xdr_decode_hyper(p, &args->offset);
  326. args->count = ntohl(*p++);
  327. args->stable = ntohl(*p++);
  328. len = args->len = ntohl(*p++);
  329. /*
  330. * The count must equal the amount of data passed.
  331. */
  332. if (args->count != args->len)
  333. return 0;
  334. /*
  335. * Check to make sure that we got the right number of
  336. * bytes.
  337. */
  338. hdr = (void*)p - rqstp->rq_arg.head[0].iov_base;
  339. dlen = rqstp->rq_arg.head[0].iov_len + rqstp->rq_arg.page_len
  340. - hdr;
  341. /*
  342. * Round the length of the data which was specified up to
  343. * the next multiple of XDR units and then compare that
  344. * against the length which was actually received.
  345. * Note that when RPCSEC/GSS (for example) is used, the
  346. * data buffer can be padded so dlen might be larger
  347. * than required. It must never be smaller.
  348. */
  349. if (dlen < XDR_QUADLEN(len)*4)
  350. return 0;
  351. if (args->count > max_blocksize) {
  352. args->count = max_blocksize;
  353. len = args->len = max_blocksize;
  354. }
  355. rqstp->rq_vec[0].iov_base = (void*)p;
  356. rqstp->rq_vec[0].iov_len = rqstp->rq_arg.head[0].iov_len - hdr;
  357. v = 0;
  358. while (len > rqstp->rq_vec[v].iov_len) {
  359. len -= rqstp->rq_vec[v].iov_len;
  360. v++;
  361. rqstp->rq_vec[v].iov_base = page_address(rqstp->rq_pages[v]);
  362. rqstp->rq_vec[v].iov_len = PAGE_SIZE;
  363. }
  364. rqstp->rq_vec[v].iov_len = len;
  365. args->vlen = v + 1;
  366. return 1;
  367. }
  368. int
  369. nfs3svc_decode_createargs(struct svc_rqst *rqstp, __be32 *p,
  370. struct nfsd3_createargs *args)
  371. {
  372. if (!(p = decode_fh(p, &args->fh))
  373. || !(p = decode_filename(p, &args->name, &args->len)))
  374. return 0;
  375. switch (args->createmode = ntohl(*p++)) {
  376. case NFS3_CREATE_UNCHECKED:
  377. case NFS3_CREATE_GUARDED:
  378. p = decode_sattr3(p, &args->attrs);
  379. break;
  380. case NFS3_CREATE_EXCLUSIVE:
  381. args->verf = p;
  382. p += 2;
  383. break;
  384. default:
  385. return 0;
  386. }
  387. return xdr_argsize_check(rqstp, p);
  388. }
  389. int
  390. nfs3svc_decode_mkdirargs(struct svc_rqst *rqstp, __be32 *p,
  391. struct nfsd3_createargs *args)
  392. {
  393. if (!(p = decode_fh(p, &args->fh)) ||
  394. !(p = decode_filename(p, &args->name, &args->len)))
  395. return 0;
  396. p = decode_sattr3(p, &args->attrs);
  397. return xdr_argsize_check(rqstp, p);
  398. }
  399. int
  400. nfs3svc_decode_symlinkargs(struct svc_rqst *rqstp, __be32 *p,
  401. struct nfsd3_symlinkargs *args)
  402. {
  403. unsigned int len, avail;
  404. char *old, *new;
  405. struct kvec *vec;
  406. if (!(p = decode_fh(p, &args->ffh)) ||
  407. !(p = decode_filename(p, &args->fname, &args->flen))
  408. )
  409. return 0;
  410. p = decode_sattr3(p, &args->attrs);
  411. /* now decode the pathname, which might be larger than the first page.
  412. * As we have to check for nul's anyway, we copy it into a new page
  413. * This page appears in the rq_res.pages list, but as pages_len is always
  414. * 0, it won't get in the way
  415. */
  416. len = ntohl(*p++);
  417. if (len == 0 || len > NFS3_MAXPATHLEN || len >= PAGE_SIZE)
  418. return 0;
  419. args->tname = new = page_address(*(rqstp->rq_next_page++));
  420. args->tlen = len;
  421. /* first copy and check from the first page */
  422. old = (char*)p;
  423. vec = &rqstp->rq_arg.head[0];
  424. avail = vec->iov_len - (old - (char*)vec->iov_base);
  425. while (len && avail && *old) {
  426. *new++ = *old++;
  427. len--;
  428. avail--;
  429. }
  430. /* now copy next page if there is one */
  431. if (len && !avail && rqstp->rq_arg.page_len) {
  432. avail = rqstp->rq_arg.page_len;
  433. if (avail > PAGE_SIZE)
  434. avail = PAGE_SIZE;
  435. old = page_address(rqstp->rq_arg.pages[0]);
  436. }
  437. while (len && avail && *old) {
  438. *new++ = *old++;
  439. len--;
  440. avail--;
  441. }
  442. *new = '\0';
  443. if (len)
  444. return 0;
  445. return 1;
  446. }
  447. int
  448. nfs3svc_decode_mknodargs(struct svc_rqst *rqstp, __be32 *p,
  449. struct nfsd3_mknodargs *args)
  450. {
  451. if (!(p = decode_fh(p, &args->fh))
  452. || !(p = decode_filename(p, &args->name, &args->len)))
  453. return 0;
  454. args->ftype = ntohl(*p++);
  455. if (args->ftype == NF3BLK || args->ftype == NF3CHR
  456. || args->ftype == NF3SOCK || args->ftype == NF3FIFO)
  457. p = decode_sattr3(p, &args->attrs);
  458. if (args->ftype == NF3BLK || args->ftype == NF3CHR) {
  459. args->major = ntohl(*p++);
  460. args->minor = ntohl(*p++);
  461. }
  462. return xdr_argsize_check(rqstp, p);
  463. }
  464. int
  465. nfs3svc_decode_renameargs(struct svc_rqst *rqstp, __be32 *p,
  466. struct nfsd3_renameargs *args)
  467. {
  468. if (!(p = decode_fh(p, &args->ffh))
  469. || !(p = decode_filename(p, &args->fname, &args->flen))
  470. || !(p = decode_fh(p, &args->tfh))
  471. || !(p = decode_filename(p, &args->tname, &args->tlen)))
  472. return 0;
  473. return xdr_argsize_check(rqstp, p);
  474. }
  475. int
  476. nfs3svc_decode_readlinkargs(struct svc_rqst *rqstp, __be32 *p,
  477. struct nfsd3_readlinkargs *args)
  478. {
  479. p = decode_fh(p, &args->fh);
  480. if (!p)
  481. return 0;
  482. args->buffer = page_address(*(rqstp->rq_next_page++));
  483. return xdr_argsize_check(rqstp, p);
  484. }
  485. int
  486. nfs3svc_decode_linkargs(struct svc_rqst *rqstp, __be32 *p,
  487. struct nfsd3_linkargs *args)
  488. {
  489. if (!(p = decode_fh(p, &args->ffh))
  490. || !(p = decode_fh(p, &args->tfh))
  491. || !(p = decode_filename(p, &args->tname, &args->tlen)))
  492. return 0;
  493. return xdr_argsize_check(rqstp, p);
  494. }
  495. int
  496. nfs3svc_decode_readdirargs(struct svc_rqst *rqstp, __be32 *p,
  497. struct nfsd3_readdirargs *args)
  498. {
  499. p = decode_fh(p, &args->fh);
  500. if (!p)
  501. return 0;
  502. p = xdr_decode_hyper(p, &args->cookie);
  503. args->verf = p; p += 2;
  504. args->dircount = ~0;
  505. args->count = ntohl(*p++);
  506. if (args->count > PAGE_SIZE)
  507. args->count = PAGE_SIZE;
  508. args->buffer = page_address(*(rqstp->rq_next_page++));
  509. return xdr_argsize_check(rqstp, p);
  510. }
  511. int
  512. nfs3svc_decode_readdirplusargs(struct svc_rqst *rqstp, __be32 *p,
  513. struct nfsd3_readdirargs *args)
  514. {
  515. int len;
  516. u32 max_blocksize = svc_max_payload(rqstp);
  517. p = decode_fh(p, &args->fh);
  518. if (!p)
  519. return 0;
  520. p = xdr_decode_hyper(p, &args->cookie);
  521. args->verf = p; p += 2;
  522. args->dircount = ntohl(*p++);
  523. args->count = ntohl(*p++);
  524. len = (args->count > max_blocksize) ? max_blocksize :
  525. args->count;
  526. args->count = len;
  527. while (len > 0) {
  528. struct page *p = *(rqstp->rq_next_page++);
  529. if (!args->buffer)
  530. args->buffer = page_address(p);
  531. len -= PAGE_SIZE;
  532. }
  533. return xdr_argsize_check(rqstp, p);
  534. }
  535. int
  536. nfs3svc_decode_commitargs(struct svc_rqst *rqstp, __be32 *p,
  537. struct nfsd3_commitargs *args)
  538. {
  539. p = decode_fh(p, &args->fh);
  540. if (!p)
  541. return 0;
  542. p = xdr_decode_hyper(p, &args->offset);
  543. args->count = ntohl(*p++);
  544. return xdr_argsize_check(rqstp, p);
  545. }
  546. /*
  547. * XDR encode functions
  548. */
  549. /*
  550. * There must be an encoding function for void results so svc_process
  551. * will work properly.
  552. */
  553. int
  554. nfs3svc_encode_voidres(struct svc_rqst *rqstp, __be32 *p, void *dummy)
  555. {
  556. return xdr_ressize_check(rqstp, p);
  557. }
  558. /* GETATTR */
  559. int
  560. nfs3svc_encode_attrstat(struct svc_rqst *rqstp, __be32 *p,
  561. struct nfsd3_attrstat *resp)
  562. {
  563. if (resp->status == 0) {
  564. lease_get_mtime(resp->fh.fh_dentry->d_inode,
  565. &resp->stat.mtime);
  566. p = encode_fattr3(rqstp, p, &resp->fh, &resp->stat);
  567. }
  568. return xdr_ressize_check(rqstp, p);
  569. }
  570. /* SETATTR, REMOVE, RMDIR */
  571. int
  572. nfs3svc_encode_wccstat(struct svc_rqst *rqstp, __be32 *p,
  573. struct nfsd3_attrstat *resp)
  574. {
  575. p = encode_wcc_data(rqstp, p, &resp->fh);
  576. return xdr_ressize_check(rqstp, p);
  577. }
  578. /* LOOKUP */
  579. int
  580. nfs3svc_encode_diropres(struct svc_rqst *rqstp, __be32 *p,
  581. struct nfsd3_diropres *resp)
  582. {
  583. if (resp->status == 0) {
  584. p = encode_fh(p, &resp->fh);
  585. p = encode_post_op_attr(rqstp, p, &resp->fh);
  586. }
  587. p = encode_post_op_attr(rqstp, p, &resp->dirfh);
  588. return xdr_ressize_check(rqstp, p);
  589. }
  590. /* ACCESS */
  591. int
  592. nfs3svc_encode_accessres(struct svc_rqst *rqstp, __be32 *p,
  593. struct nfsd3_accessres *resp)
  594. {
  595. p = encode_post_op_attr(rqstp, p, &resp->fh);
  596. if (resp->status == 0)
  597. *p++ = htonl(resp->access);
  598. return xdr_ressize_check(rqstp, p);
  599. }
  600. /* READLINK */
  601. int
  602. nfs3svc_encode_readlinkres(struct svc_rqst *rqstp, __be32 *p,
  603. struct nfsd3_readlinkres *resp)
  604. {
  605. p = encode_post_op_attr(rqstp, p, &resp->fh);
  606. if (resp->status == 0) {
  607. *p++ = htonl(resp->len);
  608. xdr_ressize_check(rqstp, p);
  609. rqstp->rq_res.page_len = resp->len;
  610. if (resp->len & 3) {
  611. /* need to pad the tail */
  612. rqstp->rq_res.tail[0].iov_base = p;
  613. *p = 0;
  614. rqstp->rq_res.tail[0].iov_len = 4 - (resp->len&3);
  615. }
  616. return 1;
  617. } else
  618. return xdr_ressize_check(rqstp, p);
  619. }
  620. /* READ */
  621. int
  622. nfs3svc_encode_readres(struct svc_rqst *rqstp, __be32 *p,
  623. struct nfsd3_readres *resp)
  624. {
  625. p = encode_post_op_attr(rqstp, p, &resp->fh);
  626. if (resp->status == 0) {
  627. *p++ = htonl(resp->count);
  628. *p++ = htonl(resp->eof);
  629. *p++ = htonl(resp->count); /* xdr opaque count */
  630. xdr_ressize_check(rqstp, p);
  631. /* now update rqstp->rq_res to reflect data as well */
  632. rqstp->rq_res.page_len = resp->count;
  633. if (resp->count & 3) {
  634. /* need to pad the tail */
  635. rqstp->rq_res.tail[0].iov_base = p;
  636. *p = 0;
  637. rqstp->rq_res.tail[0].iov_len = 4 - (resp->count & 3);
  638. }
  639. return 1;
  640. } else
  641. return xdr_ressize_check(rqstp, p);
  642. }
  643. /* WRITE */
  644. int
  645. nfs3svc_encode_writeres(struct svc_rqst *rqstp, __be32 *p,
  646. struct nfsd3_writeres *resp)
  647. {
  648. struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id);
  649. p = encode_wcc_data(rqstp, p, &resp->fh);
  650. if (resp->status == 0) {
  651. *p++ = htonl(resp->count);
  652. *p++ = htonl(resp->committed);
  653. *p++ = htonl(nn->nfssvc_boot.tv_sec);
  654. *p++ = htonl(nn->nfssvc_boot.tv_usec);
  655. }
  656. return xdr_ressize_check(rqstp, p);
  657. }
  658. /* CREATE, MKDIR, SYMLINK, MKNOD */
  659. int
  660. nfs3svc_encode_createres(struct svc_rqst *rqstp, __be32 *p,
  661. struct nfsd3_diropres *resp)
  662. {
  663. if (resp->status == 0) {
  664. *p++ = xdr_one;
  665. p = encode_fh(p, &resp->fh);
  666. p = encode_post_op_attr(rqstp, p, &resp->fh);
  667. }
  668. p = encode_wcc_data(rqstp, p, &resp->dirfh);
  669. return xdr_ressize_check(rqstp, p);
  670. }
  671. /* RENAME */
  672. int
  673. nfs3svc_encode_renameres(struct svc_rqst *rqstp, __be32 *p,
  674. struct nfsd3_renameres *resp)
  675. {
  676. p = encode_wcc_data(rqstp, p, &resp->ffh);
  677. p = encode_wcc_data(rqstp, p, &resp->tfh);
  678. return xdr_ressize_check(rqstp, p);
  679. }
  680. /* LINK */
  681. int
  682. nfs3svc_encode_linkres(struct svc_rqst *rqstp, __be32 *p,
  683. struct nfsd3_linkres *resp)
  684. {
  685. p = encode_post_op_attr(rqstp, p, &resp->fh);
  686. p = encode_wcc_data(rqstp, p, &resp->tfh);
  687. return xdr_ressize_check(rqstp, p);
  688. }
  689. /* READDIR */
  690. int
  691. nfs3svc_encode_readdirres(struct svc_rqst *rqstp, __be32 *p,
  692. struct nfsd3_readdirres *resp)
  693. {
  694. p = encode_post_op_attr(rqstp, p, &resp->fh);
  695. if (resp->status == 0) {
  696. /* stupid readdir cookie */
  697. memcpy(p, resp->verf, 8); p += 2;
  698. xdr_ressize_check(rqstp, p);
  699. if (rqstp->rq_res.head[0].iov_len + (2<<2) > PAGE_SIZE)
  700. return 1; /*No room for trailer */
  701. rqstp->rq_res.page_len = (resp->count) << 2;
  702. /* add the 'tail' to the end of the 'head' page - page 0. */
  703. rqstp->rq_res.tail[0].iov_base = p;
  704. *p++ = 0; /* no more entries */
  705. *p++ = htonl(resp->common.err == nfserr_eof);
  706. rqstp->rq_res.tail[0].iov_len = 2<<2;
  707. return 1;
  708. } else
  709. return xdr_ressize_check(rqstp, p);
  710. }
  711. static __be32 *
  712. encode_entry_baggage(struct nfsd3_readdirres *cd, __be32 *p, const char *name,
  713. int namlen, u64 ino)
  714. {
  715. *p++ = xdr_one; /* mark entry present */
  716. p = xdr_encode_hyper(p, ino); /* file id */
  717. p = xdr_encode_array(p, name, namlen);/* name length & name */
  718. cd->offset = p; /* remember pointer */
  719. p = xdr_encode_hyper(p, NFS_OFFSET_MAX);/* offset of next entry */
  720. return p;
  721. }
  722. static __be32
  723. compose_entry_fh(struct nfsd3_readdirres *cd, struct svc_fh *fhp,
  724. const char *name, int namlen)
  725. {
  726. struct svc_export *exp;
  727. struct dentry *dparent, *dchild;
  728. __be32 rv = nfserr_noent;
  729. dparent = cd->fh.fh_dentry;
  730. exp = cd->fh.fh_export;
  731. if (isdotent(name, namlen)) {
  732. if (namlen == 2) {
  733. dchild = dget_parent(dparent);
  734. /* filesystem root - cannot return filehandle for ".." */
  735. if (dchild == dparent)
  736. goto out;
  737. } else
  738. dchild = dget(dparent);
  739. } else
  740. dchild = lookup_one_len(name, dparent, namlen);
  741. if (IS_ERR(dchild))
  742. return rv;
  743. if (d_mountpoint(dchild))
  744. goto out;
  745. if (!dchild->d_inode)
  746. goto out;
  747. rv = fh_compose(fhp, exp, dchild, &cd->fh);
  748. out:
  749. dput(dchild);
  750. return rv;
  751. }
  752. static __be32 *encode_entryplus_baggage(struct nfsd3_readdirres *cd, __be32 *p, const char *name, int namlen)
  753. {
  754. struct svc_fh *fh = &cd->scratch;
  755. __be32 err;
  756. fh_init(fh, NFS3_FHSIZE);
  757. err = compose_entry_fh(cd, fh, name, namlen);
  758. if (err) {
  759. *p++ = 0;
  760. *p++ = 0;
  761. goto out;
  762. }
  763. p = encode_post_op_attr(cd->rqstp, p, fh);
  764. *p++ = xdr_one; /* yes, a file handle follows */
  765. p = encode_fh(p, fh);
  766. out:
  767. fh_put(fh);
  768. return p;
  769. }
  770. /*
  771. * Encode a directory entry. This one works for both normal readdir
  772. * and readdirplus.
  773. * The normal readdir reply requires 2 (fileid) + 1 (stringlen)
  774. * + string + 2 (cookie) + 1 (next) words, i.e. 6 + strlen.
  775. *
  776. * The readdirplus baggage is 1+21 words for post_op_attr, plus the
  777. * file handle.
  778. */
  779. #define NFS3_ENTRY_BAGGAGE (2 + 1 + 2 + 1)
  780. #define NFS3_ENTRYPLUS_BAGGAGE (1 + 21 + 1 + (NFS3_FHSIZE >> 2))
  781. static int
  782. encode_entry(struct readdir_cd *ccd, const char *name, int namlen,
  783. loff_t offset, u64 ino, unsigned int d_type, int plus)
  784. {
  785. struct nfsd3_readdirres *cd = container_of(ccd, struct nfsd3_readdirres,
  786. common);
  787. __be32 *p = cd->buffer;
  788. caddr_t curr_page_addr = NULL;
  789. struct page ** page;
  790. int slen; /* string (name) length */
  791. int elen; /* estimated entry length in words */
  792. int num_entry_words = 0; /* actual number of words */
  793. if (cd->offset) {
  794. u64 offset64 = offset;
  795. if (unlikely(cd->offset1)) {
  796. /* we ended up with offset on a page boundary */
  797. *cd->offset = htonl(offset64 >> 32);
  798. *cd->offset1 = htonl(offset64 & 0xffffffff);
  799. cd->offset1 = NULL;
  800. } else {
  801. xdr_encode_hyper(cd->offset, offset64);
  802. }
  803. }
  804. /*
  805. dprintk("encode_entry(%.*s @%ld%s)\n",
  806. namlen, name, (long) offset, plus? " plus" : "");
  807. */
  808. /* truncate filename if too long */
  809. if (namlen > NFS3_MAXNAMLEN)
  810. namlen = NFS3_MAXNAMLEN;
  811. slen = XDR_QUADLEN(namlen);
  812. elen = slen + NFS3_ENTRY_BAGGAGE
  813. + (plus? NFS3_ENTRYPLUS_BAGGAGE : 0);
  814. if (cd->buflen < elen) {
  815. cd->common.err = nfserr_toosmall;
  816. return -EINVAL;
  817. }
  818. /* determine which page in rq_respages[] we are currently filling */
  819. for (page = cd->rqstp->rq_respages + 1;
  820. page < cd->rqstp->rq_next_page; page++) {
  821. curr_page_addr = page_address(*page);
  822. if (((caddr_t)cd->buffer >= curr_page_addr) &&
  823. ((caddr_t)cd->buffer < curr_page_addr + PAGE_SIZE))
  824. break;
  825. }
  826. if ((caddr_t)(cd->buffer + elen) < (curr_page_addr + PAGE_SIZE)) {
  827. /* encode entry in current page */
  828. p = encode_entry_baggage(cd, p, name, namlen, ino);
  829. if (plus)
  830. p = encode_entryplus_baggage(cd, p, name, namlen);
  831. num_entry_words = p - cd->buffer;
  832. } else if (*(page+1) != NULL) {
  833. /* temporarily encode entry into next page, then move back to
  834. * current and next page in rq_respages[] */
  835. __be32 *p1, *tmp;
  836. int len1, len2;
  837. /* grab next page for temporary storage of entry */
  838. p1 = tmp = page_address(*(page+1));
  839. p1 = encode_entry_baggage(cd, p1, name, namlen, ino);
  840. if (plus)
  841. p1 = encode_entryplus_baggage(cd, p1, name, namlen);
  842. /* determine entry word length and lengths to go in pages */
  843. num_entry_words = p1 - tmp;
  844. len1 = curr_page_addr + PAGE_SIZE - (caddr_t)cd->buffer;
  845. if ((num_entry_words << 2) < len1) {
  846. /* the actual number of words in the entry is less
  847. * than elen and can still fit in the current page
  848. */
  849. memmove(p, tmp, num_entry_words << 2);
  850. p += num_entry_words;
  851. /* update offset */
  852. cd->offset = cd->buffer + (cd->offset - tmp);
  853. } else {
  854. unsigned int offset_r = (cd->offset - tmp) << 2;
  855. /* update pointer to offset location.
  856. * This is a 64bit quantity, so we need to
  857. * deal with 3 cases:
  858. * - entirely in first page
  859. * - entirely in second page
  860. * - 4 bytes in each page
  861. */
  862. if (offset_r + 8 <= len1) {
  863. cd->offset = p + (cd->offset - tmp);
  864. } else if (offset_r >= len1) {
  865. cd->offset -= len1 >> 2;
  866. } else {
  867. /* sitting on the fence */
  868. BUG_ON(offset_r != len1 - 4);
  869. cd->offset = p + (cd->offset - tmp);
  870. cd->offset1 = tmp;
  871. }
  872. len2 = (num_entry_words << 2) - len1;
  873. /* move from temp page to current and next pages */
  874. memmove(p, tmp, len1);
  875. memmove(tmp, (caddr_t)tmp+len1, len2);
  876. p = tmp + (len2 >> 2);
  877. }
  878. }
  879. else {
  880. cd->common.err = nfserr_toosmall;
  881. return -EINVAL;
  882. }
  883. cd->buflen -= num_entry_words;
  884. cd->buffer = p;
  885. cd->common.err = nfs_ok;
  886. return 0;
  887. }
  888. int
  889. nfs3svc_encode_entry(void *cd, const char *name,
  890. int namlen, loff_t offset, u64 ino, unsigned int d_type)
  891. {
  892. return encode_entry(cd, name, namlen, offset, ino, d_type, 0);
  893. }
  894. int
  895. nfs3svc_encode_entry_plus(void *cd, const char *name,
  896. int namlen, loff_t offset, u64 ino,
  897. unsigned int d_type)
  898. {
  899. return encode_entry(cd, name, namlen, offset, ino, d_type, 1);
  900. }
  901. /* FSSTAT */
  902. int
  903. nfs3svc_encode_fsstatres(struct svc_rqst *rqstp, __be32 *p,
  904. struct nfsd3_fsstatres *resp)
  905. {
  906. struct kstatfs *s = &resp->stats;
  907. u64 bs = s->f_bsize;
  908. *p++ = xdr_zero; /* no post_op_attr */
  909. if (resp->status == 0) {
  910. p = xdr_encode_hyper(p, bs * s->f_blocks); /* total bytes */
  911. p = xdr_encode_hyper(p, bs * s->f_bfree); /* free bytes */
  912. p = xdr_encode_hyper(p, bs * s->f_bavail); /* user available bytes */
  913. p = xdr_encode_hyper(p, s->f_files); /* total inodes */
  914. p = xdr_encode_hyper(p, s->f_ffree); /* free inodes */
  915. p = xdr_encode_hyper(p, s->f_ffree); /* user available inodes */
  916. *p++ = htonl(resp->invarsec); /* mean unchanged time */
  917. }
  918. return xdr_ressize_check(rqstp, p);
  919. }
  920. /* FSINFO */
  921. int
  922. nfs3svc_encode_fsinfores(struct svc_rqst *rqstp, __be32 *p,
  923. struct nfsd3_fsinfores *resp)
  924. {
  925. *p++ = xdr_zero; /* no post_op_attr */
  926. if (resp->status == 0) {
  927. *p++ = htonl(resp->f_rtmax);
  928. *p++ = htonl(resp->f_rtpref);
  929. *p++ = htonl(resp->f_rtmult);
  930. *p++ = htonl(resp->f_wtmax);
  931. *p++ = htonl(resp->f_wtpref);
  932. *p++ = htonl(resp->f_wtmult);
  933. *p++ = htonl(resp->f_dtpref);
  934. p = xdr_encode_hyper(p, resp->f_maxfilesize);
  935. *p++ = xdr_one;
  936. *p++ = xdr_zero;
  937. *p++ = htonl(resp->f_properties);
  938. }
  939. return xdr_ressize_check(rqstp, p);
  940. }
  941. /* PATHCONF */
  942. int
  943. nfs3svc_encode_pathconfres(struct svc_rqst *rqstp, __be32 *p,
  944. struct nfsd3_pathconfres *resp)
  945. {
  946. *p++ = xdr_zero; /* no post_op_attr */
  947. if (resp->status == 0) {
  948. *p++ = htonl(resp->p_link_max);
  949. *p++ = htonl(resp->p_name_max);
  950. *p++ = htonl(resp->p_no_trunc);
  951. *p++ = htonl(resp->p_chown_restricted);
  952. *p++ = htonl(resp->p_case_insensitive);
  953. *p++ = htonl(resp->p_case_preserving);
  954. }
  955. return xdr_ressize_check(rqstp, p);
  956. }
  957. /* COMMIT */
  958. int
  959. nfs3svc_encode_commitres(struct svc_rqst *rqstp, __be32 *p,
  960. struct nfsd3_commitres *resp)
  961. {
  962. struct nfsd_net *nn = net_generic(SVC_NET(rqstp), nfsd_net_id);
  963. p = encode_wcc_data(rqstp, p, &resp->fh);
  964. /* Write verifier */
  965. if (resp->status == 0) {
  966. *p++ = htonl(nn->nfssvc_boot.tv_sec);
  967. *p++ = htonl(nn->nfssvc_boot.tv_usec);
  968. }
  969. return xdr_ressize_check(rqstp, p);
  970. }
  971. /*
  972. * XDR release functions
  973. */
  974. int
  975. nfs3svc_release_fhandle(struct svc_rqst *rqstp, __be32 *p,
  976. struct nfsd3_attrstat *resp)
  977. {
  978. fh_put(&resp->fh);
  979. return 1;
  980. }
  981. int
  982. nfs3svc_release_fhandle2(struct svc_rqst *rqstp, __be32 *p,
  983. struct nfsd3_fhandle_pair *resp)
  984. {
  985. fh_put(&resp->fh1);
  986. fh_put(&resp->fh2);
  987. return 1;
  988. }