nfs2xdr.c 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735
  1. /*
  2. * linux/fs/nfs/nfs2xdr.c
  3. *
  4. * XDR functions to encode/decode NFS RPC arguments and results.
  5. *
  6. * Copyright (C) 1992, 1993, 1994 Rick Sladkey
  7. * Copyright (C) 1996 Olaf Kirch
  8. * 04 Aug 1998 Ion Badulescu <ionut@cs.columbia.edu>
  9. * FIFO's need special handling in NFSv2
  10. */
  11. #include <linux/param.h>
  12. #include <linux/time.h>
  13. #include <linux/mm.h>
  14. #include <linux/slab.h>
  15. #include <linux/utsname.h>
  16. #include <linux/errno.h>
  17. #include <linux/string.h>
  18. #include <linux/in.h>
  19. #include <linux/pagemap.h>
  20. #include <linux/proc_fs.h>
  21. #include <linux/sunrpc/clnt.h>
  22. #include <linux/nfs.h>
  23. #include <linux/nfs2.h>
  24. #include <linux/nfs_fs.h>
  25. #include "internal.h"
  26. #define NFSDBG_FACILITY NFSDBG_XDR
  27. /* Mapping from NFS error code to "errno" error code. */
  28. #define errno_NFSERR_IO EIO
  29. /*
  30. * Declare the space requirements for NFS arguments and replies as
  31. * number of 32bit-words
  32. */
  33. #define NFS_fhandle_sz (8)
  34. #define NFS_sattr_sz (8)
  35. #define NFS_filename_sz (1+(NFS2_MAXNAMLEN>>2))
  36. #define NFS_path_sz (1+(NFS2_MAXPATHLEN>>2))
  37. #define NFS_fattr_sz (17)
  38. #define NFS_info_sz (5)
  39. #define NFS_entry_sz (NFS_filename_sz+3)
  40. #define NFS_diropargs_sz (NFS_fhandle_sz+NFS_filename_sz)
  41. #define NFS_removeargs_sz (NFS_fhandle_sz+NFS_filename_sz)
  42. #define NFS_sattrargs_sz (NFS_fhandle_sz+NFS_sattr_sz)
  43. #define NFS_readlinkargs_sz (NFS_fhandle_sz)
  44. #define NFS_readargs_sz (NFS_fhandle_sz+3)
  45. #define NFS_writeargs_sz (NFS_fhandle_sz+4)
  46. #define NFS_createargs_sz (NFS_diropargs_sz+NFS_sattr_sz)
  47. #define NFS_renameargs_sz (NFS_diropargs_sz+NFS_diropargs_sz)
  48. #define NFS_linkargs_sz (NFS_fhandle_sz+NFS_diropargs_sz)
  49. #define NFS_symlinkargs_sz (NFS_diropargs_sz+1+NFS_sattr_sz)
  50. #define NFS_readdirargs_sz (NFS_fhandle_sz+2)
  51. #define NFS_attrstat_sz (1+NFS_fattr_sz)
  52. #define NFS_diropres_sz (1+NFS_fhandle_sz+NFS_fattr_sz)
  53. #define NFS_readlinkres_sz (2)
  54. #define NFS_readres_sz (1+NFS_fattr_sz+1)
  55. #define NFS_writeres_sz (NFS_attrstat_sz)
  56. #define NFS_stat_sz (1)
  57. #define NFS_readdirres_sz (1)
  58. #define NFS_statfsres_sz (1+NFS_info_sz)
  59. /*
  60. * Common NFS XDR functions as inlines
  61. */
  62. static inline __be32 *
  63. xdr_encode_fhandle(__be32 *p, const struct nfs_fh *fhandle)
  64. {
  65. memcpy(p, fhandle->data, NFS2_FHSIZE);
  66. return p + XDR_QUADLEN(NFS2_FHSIZE);
  67. }
  68. static inline __be32 *
  69. xdr_decode_fhandle(__be32 *p, struct nfs_fh *fhandle)
  70. {
  71. /* NFSv2 handles have a fixed length */
  72. fhandle->size = NFS2_FHSIZE;
  73. memcpy(fhandle->data, p, NFS2_FHSIZE);
  74. return p + XDR_QUADLEN(NFS2_FHSIZE);
  75. }
  76. static inline __be32*
  77. xdr_encode_time(__be32 *p, struct timespec *timep)
  78. {
  79. *p++ = htonl(timep->tv_sec);
  80. /* Convert nanoseconds into microseconds */
  81. *p++ = htonl(timep->tv_nsec ? timep->tv_nsec / 1000 : 0);
  82. return p;
  83. }
  84. static inline __be32*
  85. xdr_encode_current_server_time(__be32 *p, struct timespec *timep)
  86. {
  87. /*
  88. * Passing the invalid value useconds=1000000 is a
  89. * Sun convention for "set to current server time".
  90. * It's needed to make permissions checks for the
  91. * "touch" program across v2 mounts to Solaris and
  92. * Irix boxes work correctly. See description of
  93. * sattr in section 6.1 of "NFS Illustrated" by
  94. * Brent Callaghan, Addison-Wesley, ISBN 0-201-32750-5
  95. */
  96. *p++ = htonl(timep->tv_sec);
  97. *p++ = htonl(1000000);
  98. return p;
  99. }
  100. static inline __be32*
  101. xdr_decode_time(__be32 *p, struct timespec *timep)
  102. {
  103. timep->tv_sec = ntohl(*p++);
  104. /* Convert microseconds into nanoseconds */
  105. timep->tv_nsec = ntohl(*p++) * 1000;
  106. return p;
  107. }
  108. static __be32 *
  109. xdr_decode_fattr(__be32 *p, struct nfs_fattr *fattr)
  110. {
  111. u32 rdev;
  112. fattr->type = (enum nfs_ftype) ntohl(*p++);
  113. fattr->mode = ntohl(*p++);
  114. fattr->nlink = ntohl(*p++);
  115. fattr->uid = ntohl(*p++);
  116. fattr->gid = ntohl(*p++);
  117. fattr->size = ntohl(*p++);
  118. fattr->du.nfs2.blocksize = ntohl(*p++);
  119. rdev = ntohl(*p++);
  120. fattr->du.nfs2.blocks = ntohl(*p++);
  121. fattr->fsid.major = ntohl(*p++);
  122. fattr->fsid.minor = 0;
  123. fattr->fileid = ntohl(*p++);
  124. p = xdr_decode_time(p, &fattr->atime);
  125. p = xdr_decode_time(p, &fattr->mtime);
  126. p = xdr_decode_time(p, &fattr->ctime);
  127. fattr->valid |= NFS_ATTR_FATTR;
  128. fattr->rdev = new_decode_dev(rdev);
  129. if (fattr->type == NFCHR && rdev == NFS2_FIFO_DEV) {
  130. fattr->type = NFFIFO;
  131. fattr->mode = (fattr->mode & ~S_IFMT) | S_IFIFO;
  132. fattr->rdev = 0;
  133. }
  134. return p;
  135. }
  136. static inline __be32 *
  137. xdr_encode_sattr(__be32 *p, struct iattr *attr)
  138. {
  139. const __be32 not_set = __constant_htonl(0xFFFFFFFF);
  140. *p++ = (attr->ia_valid & ATTR_MODE) ? htonl(attr->ia_mode) : not_set;
  141. *p++ = (attr->ia_valid & ATTR_UID) ? htonl(attr->ia_uid) : not_set;
  142. *p++ = (attr->ia_valid & ATTR_GID) ? htonl(attr->ia_gid) : not_set;
  143. *p++ = (attr->ia_valid & ATTR_SIZE) ? htonl(attr->ia_size) : not_set;
  144. if (attr->ia_valid & ATTR_ATIME_SET) {
  145. p = xdr_encode_time(p, &attr->ia_atime);
  146. } else if (attr->ia_valid & ATTR_ATIME) {
  147. p = xdr_encode_current_server_time(p, &attr->ia_atime);
  148. } else {
  149. *p++ = not_set;
  150. *p++ = not_set;
  151. }
  152. if (attr->ia_valid & ATTR_MTIME_SET) {
  153. p = xdr_encode_time(p, &attr->ia_mtime);
  154. } else if (attr->ia_valid & ATTR_MTIME) {
  155. p = xdr_encode_current_server_time(p, &attr->ia_mtime);
  156. } else {
  157. *p++ = not_set;
  158. *p++ = not_set;
  159. }
  160. return p;
  161. }
  162. /*
  163. * NFS encode functions
  164. */
  165. /*
  166. * Encode file handle argument
  167. * GETATTR, READLINK, STATFS
  168. */
  169. static int
  170. nfs_xdr_fhandle(struct rpc_rqst *req, __be32 *p, struct nfs_fh *fh)
  171. {
  172. p = xdr_encode_fhandle(p, fh);
  173. req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
  174. return 0;
  175. }
  176. /*
  177. * Encode SETATTR arguments
  178. */
  179. static int
  180. nfs_xdr_sattrargs(struct rpc_rqst *req, __be32 *p, struct nfs_sattrargs *args)
  181. {
  182. p = xdr_encode_fhandle(p, args->fh);
  183. p = xdr_encode_sattr(p, args->sattr);
  184. req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
  185. return 0;
  186. }
  187. /*
  188. * Encode directory ops argument
  189. * LOOKUP, RMDIR
  190. */
  191. static int
  192. nfs_xdr_diropargs(struct rpc_rqst *req, __be32 *p, struct nfs_diropargs *args)
  193. {
  194. p = xdr_encode_fhandle(p, args->fh);
  195. p = xdr_encode_array(p, args->name, args->len);
  196. req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
  197. return 0;
  198. }
  199. /*
  200. * Encode REMOVE argument
  201. */
  202. static int
  203. nfs_xdr_removeargs(struct rpc_rqst *req, __be32 *p, const struct nfs_removeargs *args)
  204. {
  205. p = xdr_encode_fhandle(p, args->fh);
  206. p = xdr_encode_array(p, args->name.name, args->name.len);
  207. req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
  208. return 0;
  209. }
  210. /*
  211. * Arguments to a READ call. Since we read data directly into the page
  212. * cache, we also set up the reply iovec here so that iov[1] points
  213. * exactly to the page we want to fetch.
  214. */
  215. static int
  216. nfs_xdr_readargs(struct rpc_rqst *req, __be32 *p, struct nfs_readargs *args)
  217. {
  218. struct rpc_auth *auth = req->rq_task->tk_msg.rpc_cred->cr_auth;
  219. unsigned int replen;
  220. u32 offset = (u32)args->offset;
  221. u32 count = args->count;
  222. p = xdr_encode_fhandle(p, args->fh);
  223. *p++ = htonl(offset);
  224. *p++ = htonl(count);
  225. *p++ = htonl(count);
  226. req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
  227. /* Inline the page array */
  228. replen = (RPC_REPHDRSIZE + auth->au_rslack + NFS_readres_sz) << 2;
  229. xdr_inline_pages(&req->rq_rcv_buf, replen,
  230. args->pages, args->pgbase, count);
  231. return 0;
  232. }
  233. /*
  234. * Decode READ reply
  235. */
  236. static int
  237. nfs_xdr_readres(struct rpc_rqst *req, __be32 *p, struct nfs_readres *res)
  238. {
  239. struct kvec *iov = req->rq_rcv_buf.head;
  240. int status, count, recvd, hdrlen;
  241. if ((status = ntohl(*p++)))
  242. return -nfs_stat_to_errno(status);
  243. p = xdr_decode_fattr(p, res->fattr);
  244. count = ntohl(*p++);
  245. res->eof = 0;
  246. hdrlen = (u8 *) p - (u8 *) iov->iov_base;
  247. if (iov->iov_len < hdrlen) {
  248. printk(KERN_WARNING "NFS: READ reply header overflowed:"
  249. "length %d > %Zu\n", hdrlen, iov->iov_len);
  250. return -errno_NFSERR_IO;
  251. } else if (iov->iov_len != hdrlen) {
  252. dprintk("NFS: READ header is short. iovec will be shifted.\n");
  253. xdr_shift_buf(&req->rq_rcv_buf, iov->iov_len - hdrlen);
  254. }
  255. recvd = req->rq_rcv_buf.len - hdrlen;
  256. if (count > recvd) {
  257. printk(KERN_WARNING "NFS: server cheating in read reply: "
  258. "count %d > recvd %d\n", count, recvd);
  259. count = recvd;
  260. }
  261. dprintk("RPC: readres OK count %d\n", count);
  262. if (count < res->count)
  263. res->count = count;
  264. return count;
  265. }
  266. /*
  267. * Write arguments. Splice the buffer to be written into the iovec.
  268. */
  269. static int
  270. nfs_xdr_writeargs(struct rpc_rqst *req, __be32 *p, struct nfs_writeargs *args)
  271. {
  272. struct xdr_buf *sndbuf = &req->rq_snd_buf;
  273. u32 offset = (u32)args->offset;
  274. u32 count = args->count;
  275. p = xdr_encode_fhandle(p, args->fh);
  276. *p++ = htonl(offset);
  277. *p++ = htonl(offset);
  278. *p++ = htonl(count);
  279. *p++ = htonl(count);
  280. sndbuf->len = xdr_adjust_iovec(sndbuf->head, p);
  281. /* Copy the page array */
  282. xdr_encode_pages(sndbuf, args->pages, args->pgbase, count);
  283. return 0;
  284. }
  285. /*
  286. * Encode create arguments
  287. * CREATE, MKDIR
  288. */
  289. static int
  290. nfs_xdr_createargs(struct rpc_rqst *req, __be32 *p, struct nfs_createargs *args)
  291. {
  292. p = xdr_encode_fhandle(p, args->fh);
  293. p = xdr_encode_array(p, args->name, args->len);
  294. p = xdr_encode_sattr(p, args->sattr);
  295. req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
  296. return 0;
  297. }
  298. /*
  299. * Encode RENAME arguments
  300. */
  301. static int
  302. nfs_xdr_renameargs(struct rpc_rqst *req, __be32 *p, struct nfs_renameargs *args)
  303. {
  304. p = xdr_encode_fhandle(p, args->fromfh);
  305. p = xdr_encode_array(p, args->fromname, args->fromlen);
  306. p = xdr_encode_fhandle(p, args->tofh);
  307. p = xdr_encode_array(p, args->toname, args->tolen);
  308. req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
  309. return 0;
  310. }
  311. /*
  312. * Encode LINK arguments
  313. */
  314. static int
  315. nfs_xdr_linkargs(struct rpc_rqst *req, __be32 *p, struct nfs_linkargs *args)
  316. {
  317. p = xdr_encode_fhandle(p, args->fromfh);
  318. p = xdr_encode_fhandle(p, args->tofh);
  319. p = xdr_encode_array(p, args->toname, args->tolen);
  320. req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
  321. return 0;
  322. }
  323. /*
  324. * Encode SYMLINK arguments
  325. */
  326. static int
  327. nfs_xdr_symlinkargs(struct rpc_rqst *req, __be32 *p, struct nfs_symlinkargs *args)
  328. {
  329. struct xdr_buf *sndbuf = &req->rq_snd_buf;
  330. size_t pad;
  331. p = xdr_encode_fhandle(p, args->fromfh);
  332. p = xdr_encode_array(p, args->fromname, args->fromlen);
  333. *p++ = htonl(args->pathlen);
  334. sndbuf->len = xdr_adjust_iovec(sndbuf->head, p);
  335. xdr_encode_pages(sndbuf, args->pages, 0, args->pathlen);
  336. /*
  337. * xdr_encode_pages may have added a few bytes to ensure the
  338. * pathname ends on a 4-byte boundary. Start encoding the
  339. * attributes after the pad bytes.
  340. */
  341. pad = sndbuf->tail->iov_len;
  342. if (pad > 0)
  343. p++;
  344. p = xdr_encode_sattr(p, args->sattr);
  345. sndbuf->len += xdr_adjust_iovec(sndbuf->tail, p) - pad;
  346. return 0;
  347. }
  348. /*
  349. * Encode arguments to readdir call
  350. */
  351. static int
  352. nfs_xdr_readdirargs(struct rpc_rqst *req, __be32 *p, struct nfs_readdirargs *args)
  353. {
  354. struct rpc_task *task = req->rq_task;
  355. struct rpc_auth *auth = task->tk_msg.rpc_cred->cr_auth;
  356. unsigned int replen;
  357. u32 count = args->count;
  358. p = xdr_encode_fhandle(p, args->fh);
  359. *p++ = htonl(args->cookie);
  360. *p++ = htonl(count); /* see above */
  361. req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
  362. /* Inline the page array */
  363. replen = (RPC_REPHDRSIZE + auth->au_rslack + NFS_readdirres_sz) << 2;
  364. xdr_inline_pages(&req->rq_rcv_buf, replen, args->pages, 0, count);
  365. return 0;
  366. }
  367. /*
  368. * Decode the result of a readdir call.
  369. * We're not really decoding anymore, we just leave the buffer untouched
  370. * and only check that it is syntactically correct.
  371. * The real decoding happens in nfs_decode_entry below, called directly
  372. * from nfs_readdir for each entry.
  373. */
  374. static int
  375. nfs_xdr_readdirres(struct rpc_rqst *req, __be32 *p, void *dummy)
  376. {
  377. struct xdr_buf *rcvbuf = &req->rq_rcv_buf;
  378. struct kvec *iov = rcvbuf->head;
  379. struct page **page;
  380. int hdrlen, recvd;
  381. int status, nr;
  382. unsigned int len, pglen;
  383. __be32 *end, *entry, *kaddr;
  384. if ((status = ntohl(*p++)))
  385. return -nfs_stat_to_errno(status);
  386. hdrlen = (u8 *) p - (u8 *) iov->iov_base;
  387. if (iov->iov_len < hdrlen) {
  388. printk(KERN_WARNING "NFS: READDIR reply header overflowed:"
  389. "length %d > %Zu\n", hdrlen, iov->iov_len);
  390. return -errno_NFSERR_IO;
  391. } else if (iov->iov_len != hdrlen) {
  392. dprintk("NFS: READDIR header is short. iovec will be shifted.\n");
  393. xdr_shift_buf(rcvbuf, iov->iov_len - hdrlen);
  394. }
  395. pglen = rcvbuf->page_len;
  396. recvd = rcvbuf->len - hdrlen;
  397. if (pglen > recvd)
  398. pglen = recvd;
  399. page = rcvbuf->pages;
  400. kaddr = p = kmap_atomic(*page, KM_USER0);
  401. end = (__be32 *)((char *)p + pglen);
  402. entry = p;
  403. for (nr = 0; *p++; nr++) {
  404. if (p + 2 > end)
  405. goto short_pkt;
  406. p++; /* fileid */
  407. len = ntohl(*p++);
  408. p += XDR_QUADLEN(len) + 1; /* name plus cookie */
  409. if (len > NFS2_MAXNAMLEN) {
  410. printk(KERN_WARNING "NFS: giant filename in readdir (len 0x%x)!\n",
  411. len);
  412. goto err_unmap;
  413. }
  414. if (p + 2 > end)
  415. goto short_pkt;
  416. entry = p;
  417. }
  418. if (!nr && (entry[0] != 0 || entry[1] == 0))
  419. goto short_pkt;
  420. out:
  421. kunmap_atomic(kaddr, KM_USER0);
  422. return nr;
  423. short_pkt:
  424. entry[0] = entry[1] = 0;
  425. /* truncate listing ? */
  426. if (!nr) {
  427. printk(KERN_NOTICE "NFS: readdir reply truncated!\n");
  428. entry[1] = 1;
  429. }
  430. goto out;
  431. err_unmap:
  432. nr = -errno_NFSERR_IO;
  433. goto out;
  434. }
  435. __be32 *
  436. nfs_decode_dirent(__be32 *p, struct nfs_entry *entry, int plus)
  437. {
  438. if (!*p++) {
  439. if (!*p)
  440. return ERR_PTR(-EAGAIN);
  441. entry->eof = 1;
  442. return ERR_PTR(-EBADCOOKIE);
  443. }
  444. entry->ino = ntohl(*p++);
  445. entry->len = ntohl(*p++);
  446. entry->name = (const char *) p;
  447. p += XDR_QUADLEN(entry->len);
  448. entry->prev_cookie = entry->cookie;
  449. entry->cookie = ntohl(*p++);
  450. entry->eof = !p[0] && p[1];
  451. return p;
  452. }
  453. /*
  454. * NFS XDR decode functions
  455. */
  456. /*
  457. * Decode simple status reply
  458. */
  459. static int
  460. nfs_xdr_stat(struct rpc_rqst *req, __be32 *p, void *dummy)
  461. {
  462. int status;
  463. if ((status = ntohl(*p++)) != 0)
  464. status = -nfs_stat_to_errno(status);
  465. return status;
  466. }
  467. /*
  468. * Decode attrstat reply
  469. * GETATTR, SETATTR, WRITE
  470. */
  471. static int
  472. nfs_xdr_attrstat(struct rpc_rqst *req, __be32 *p, struct nfs_fattr *fattr)
  473. {
  474. int status;
  475. if ((status = ntohl(*p++)))
  476. return -nfs_stat_to_errno(status);
  477. xdr_decode_fattr(p, fattr);
  478. return 0;
  479. }
  480. /*
  481. * Decode diropres reply
  482. * LOOKUP, CREATE, MKDIR
  483. */
  484. static int
  485. nfs_xdr_diropres(struct rpc_rqst *req, __be32 *p, struct nfs_diropok *res)
  486. {
  487. int status;
  488. if ((status = ntohl(*p++)))
  489. return -nfs_stat_to_errno(status);
  490. p = xdr_decode_fhandle(p, res->fh);
  491. xdr_decode_fattr(p, res->fattr);
  492. return 0;
  493. }
  494. /*
  495. * Encode READLINK args
  496. */
  497. static int
  498. nfs_xdr_readlinkargs(struct rpc_rqst *req, __be32 *p, struct nfs_readlinkargs *args)
  499. {
  500. struct rpc_auth *auth = req->rq_task->tk_msg.rpc_cred->cr_auth;
  501. unsigned int replen;
  502. p = xdr_encode_fhandle(p, args->fh);
  503. req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
  504. /* Inline the page array */
  505. replen = (RPC_REPHDRSIZE + auth->au_rslack + NFS_readlinkres_sz) << 2;
  506. xdr_inline_pages(&req->rq_rcv_buf, replen, args->pages, args->pgbase, args->pglen);
  507. return 0;
  508. }
  509. /*
  510. * Decode READLINK reply
  511. */
  512. static int
  513. nfs_xdr_readlinkres(struct rpc_rqst *req, __be32 *p, void *dummy)
  514. {
  515. struct xdr_buf *rcvbuf = &req->rq_rcv_buf;
  516. struct kvec *iov = rcvbuf->head;
  517. int hdrlen, len, recvd;
  518. char *kaddr;
  519. int status;
  520. if ((status = ntohl(*p++)))
  521. return -nfs_stat_to_errno(status);
  522. /* Convert length of symlink */
  523. len = ntohl(*p++);
  524. if (len >= rcvbuf->page_len || len <= 0) {
  525. dprintk(KERN_WARNING "nfs: server returned giant symlink!\n");
  526. return -ENAMETOOLONG;
  527. }
  528. hdrlen = (u8 *) p - (u8 *) iov->iov_base;
  529. if (iov->iov_len < hdrlen) {
  530. printk(KERN_WARNING "NFS: READLINK reply header overflowed:"
  531. "length %d > %Zu\n", hdrlen, iov->iov_len);
  532. return -errno_NFSERR_IO;
  533. } else if (iov->iov_len != hdrlen) {
  534. dprintk("NFS: READLINK header is short. iovec will be shifted.\n");
  535. xdr_shift_buf(rcvbuf, iov->iov_len - hdrlen);
  536. }
  537. recvd = req->rq_rcv_buf.len - hdrlen;
  538. if (recvd < len) {
  539. printk(KERN_WARNING "NFS: server cheating in readlink reply: "
  540. "count %u > recvd %u\n", len, recvd);
  541. return -EIO;
  542. }
  543. /* NULL terminate the string we got */
  544. kaddr = (char *)kmap_atomic(rcvbuf->pages[0], KM_USER0);
  545. kaddr[len+rcvbuf->page_base] = '\0';
  546. kunmap_atomic(kaddr, KM_USER0);
  547. return 0;
  548. }
  549. /*
  550. * Decode WRITE reply
  551. */
  552. static int
  553. nfs_xdr_writeres(struct rpc_rqst *req, __be32 *p, struct nfs_writeres *res)
  554. {
  555. res->verf->committed = NFS_FILE_SYNC;
  556. return nfs_xdr_attrstat(req, p, res->fattr);
  557. }
  558. /*
  559. * Decode STATFS reply
  560. */
  561. static int
  562. nfs_xdr_statfsres(struct rpc_rqst *req, __be32 *p, struct nfs2_fsstat *res)
  563. {
  564. int status;
  565. if ((status = ntohl(*p++)))
  566. return -nfs_stat_to_errno(status);
  567. res->tsize = ntohl(*p++);
  568. res->bsize = ntohl(*p++);
  569. res->blocks = ntohl(*p++);
  570. res->bfree = ntohl(*p++);
  571. res->bavail = ntohl(*p++);
  572. return 0;
  573. }
  574. /*
  575. * We need to translate between nfs status return values and
  576. * the local errno values which may not be the same.
  577. */
  578. static struct {
  579. int stat;
  580. int errno;
  581. } nfs_errtbl[] = {
  582. { NFS_OK, 0 },
  583. { NFSERR_PERM, EPERM },
  584. { NFSERR_NOENT, ENOENT },
  585. { NFSERR_IO, errno_NFSERR_IO },
  586. { NFSERR_NXIO, ENXIO },
  587. /* { NFSERR_EAGAIN, EAGAIN }, */
  588. { NFSERR_ACCES, EACCES },
  589. { NFSERR_EXIST, EEXIST },
  590. { NFSERR_XDEV, EXDEV },
  591. { NFSERR_NODEV, ENODEV },
  592. { NFSERR_NOTDIR, ENOTDIR },
  593. { NFSERR_ISDIR, EISDIR },
  594. { NFSERR_INVAL, EINVAL },
  595. { NFSERR_FBIG, EFBIG },
  596. { NFSERR_NOSPC, ENOSPC },
  597. { NFSERR_ROFS, EROFS },
  598. { NFSERR_MLINK, EMLINK },
  599. { NFSERR_NAMETOOLONG, ENAMETOOLONG },
  600. { NFSERR_NOTEMPTY, ENOTEMPTY },
  601. { NFSERR_DQUOT, EDQUOT },
  602. { NFSERR_STALE, ESTALE },
  603. { NFSERR_REMOTE, EREMOTE },
  604. #ifdef EWFLUSH
  605. { NFSERR_WFLUSH, EWFLUSH },
  606. #endif
  607. { NFSERR_BADHANDLE, EBADHANDLE },
  608. { NFSERR_NOT_SYNC, ENOTSYNC },
  609. { NFSERR_BAD_COOKIE, EBADCOOKIE },
  610. { NFSERR_NOTSUPP, ENOTSUPP },
  611. { NFSERR_TOOSMALL, ETOOSMALL },
  612. { NFSERR_SERVERFAULT, ESERVERFAULT },
  613. { NFSERR_BADTYPE, EBADTYPE },
  614. { NFSERR_JUKEBOX, EJUKEBOX },
  615. { -1, EIO }
  616. };
  617. /*
  618. * Convert an NFS error code to a local one.
  619. * This one is used jointly by NFSv2 and NFSv3.
  620. */
  621. int
  622. nfs_stat_to_errno(int stat)
  623. {
  624. int i;
  625. for (i = 0; nfs_errtbl[i].stat != -1; i++) {
  626. if (nfs_errtbl[i].stat == stat)
  627. return nfs_errtbl[i].errno;
  628. }
  629. printk(KERN_ERR "nfs_stat_to_errno: bad nfs status return value: %d\n", stat);
  630. return nfs_errtbl[i].errno;
  631. }
  632. #define PROC(proc, argtype, restype, timer) \
  633. [NFSPROC_##proc] = { \
  634. .p_proc = NFSPROC_##proc, \
  635. .p_encode = (kxdrproc_t) nfs_xdr_##argtype, \
  636. .p_decode = (kxdrproc_t) nfs_xdr_##restype, \
  637. .p_arglen = NFS_##argtype##_sz, \
  638. .p_replen = NFS_##restype##_sz, \
  639. .p_timer = timer, \
  640. .p_statidx = NFSPROC_##proc, \
  641. .p_name = #proc, \
  642. }
  643. struct rpc_procinfo nfs_procedures[] = {
  644. PROC(GETATTR, fhandle, attrstat, 1),
  645. PROC(SETATTR, sattrargs, attrstat, 0),
  646. PROC(LOOKUP, diropargs, diropres, 2),
  647. PROC(READLINK, readlinkargs, readlinkres, 3),
  648. PROC(READ, readargs, readres, 3),
  649. PROC(WRITE, writeargs, writeres, 4),
  650. PROC(CREATE, createargs, diropres, 0),
  651. PROC(REMOVE, removeargs, stat, 0),
  652. PROC(RENAME, renameargs, stat, 0),
  653. PROC(LINK, linkargs, stat, 0),
  654. PROC(SYMLINK, symlinkargs, stat, 0),
  655. PROC(MKDIR, createargs, diropres, 0),
  656. PROC(RMDIR, diropargs, stat, 0),
  657. PROC(READDIR, readdirargs, readdirres, 3),
  658. PROC(STATFS, fhandle, statfsres, 0),
  659. };
  660. struct rpc_version nfs_version2 = {
  661. .number = 2,
  662. .nrprocs = ARRAY_SIZE(nfs_procedures),
  663. .procs = nfs_procedures
  664. };