nfs3xdr.c 27 KB

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