proc.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779
  1. /*
  2. * linux/fs/nfs/proc.c
  3. *
  4. * Copyright (C) 1992, 1993, 1994 Rick Sladkey
  5. *
  6. * OS-independent nfs remote procedure call functions
  7. *
  8. * Tuned by Alan Cox <A.Cox@swansea.ac.uk> for >3K buffers
  9. * so at last we can have decent(ish) throughput off a
  10. * Sun server.
  11. *
  12. * Coding optimized and cleaned up by Florian La Roche.
  13. * Note: Error returns are optimized for NFS_OK, which isn't translated via
  14. * nfs_stat_to_errno(), but happens to be already the right return code.
  15. *
  16. * Also, the code currently doesn't check the size of the packet, when
  17. * it decodes the packet.
  18. *
  19. * Feel free to fix it and mail me the diffs if it worries you.
  20. *
  21. * Completely rewritten to support the new RPC call interface;
  22. * rewrote and moved the entire XDR stuff to xdr.c
  23. * --Olaf Kirch June 1996
  24. *
  25. * The code below initializes all auto variables explicitly, otherwise
  26. * it will fail to work as a module (gcc generates a memset call for an
  27. * incomplete struct).
  28. */
  29. #include <linux/types.h>
  30. #include <linux/param.h>
  31. #include <linux/time.h>
  32. #include <linux/mm.h>
  33. #include <linux/errno.h>
  34. #include <linux/string.h>
  35. #include <linux/in.h>
  36. #include <linux/pagemap.h>
  37. #include <linux/sunrpc/clnt.h>
  38. #include <linux/nfs.h>
  39. #include <linux/nfs2.h>
  40. #include <linux/nfs_fs.h>
  41. #include <linux/nfs_page.h>
  42. #include <linux/lockd/bind.h>
  43. #include <linux/freezer.h>
  44. #include "internal.h"
  45. #define NFSDBG_FACILITY NFSDBG_PROC
  46. /*
  47. * Bare-bones access to getattr: this is for nfs_read_super.
  48. */
  49. static int
  50. nfs_proc_get_root(struct nfs_server *server, struct nfs_fh *fhandle,
  51. struct nfs_fsinfo *info)
  52. {
  53. struct nfs_fattr *fattr = info->fattr;
  54. struct nfs2_fsstat fsinfo;
  55. struct rpc_message msg = {
  56. .rpc_proc = &nfs_procedures[NFSPROC_GETATTR],
  57. .rpc_argp = fhandle,
  58. .rpc_resp = fattr,
  59. };
  60. int status;
  61. dprintk("%s: call getattr\n", __func__);
  62. nfs_fattr_init(fattr);
  63. status = rpc_call_sync(server->client, &msg, 0);
  64. /* Retry with default authentication if different */
  65. if (status && server->nfs_client->cl_rpcclient != server->client)
  66. status = rpc_call_sync(server->nfs_client->cl_rpcclient, &msg, 0);
  67. dprintk("%s: reply getattr: %d\n", __func__, status);
  68. if (status)
  69. return status;
  70. dprintk("%s: call statfs\n", __func__);
  71. msg.rpc_proc = &nfs_procedures[NFSPROC_STATFS];
  72. msg.rpc_resp = &fsinfo;
  73. status = rpc_call_sync(server->client, &msg, 0);
  74. /* Retry with default authentication if different */
  75. if (status && server->nfs_client->cl_rpcclient != server->client)
  76. status = rpc_call_sync(server->nfs_client->cl_rpcclient, &msg, 0);
  77. dprintk("%s: reply statfs: %d\n", __func__, status);
  78. if (status)
  79. return status;
  80. info->rtmax = NFS_MAXDATA;
  81. info->rtpref = fsinfo.tsize;
  82. info->rtmult = fsinfo.bsize;
  83. info->wtmax = NFS_MAXDATA;
  84. info->wtpref = fsinfo.tsize;
  85. info->wtmult = fsinfo.bsize;
  86. info->dtpref = fsinfo.tsize;
  87. info->maxfilesize = 0x7FFFFFFF;
  88. info->lease_time = 0;
  89. return 0;
  90. }
  91. /*
  92. * One function for each procedure in the NFS protocol.
  93. */
  94. static int
  95. nfs_proc_getattr(struct nfs_server *server, struct nfs_fh *fhandle,
  96. struct nfs_fattr *fattr)
  97. {
  98. struct rpc_message msg = {
  99. .rpc_proc = &nfs_procedures[NFSPROC_GETATTR],
  100. .rpc_argp = fhandle,
  101. .rpc_resp = fattr,
  102. };
  103. int status;
  104. dprintk("NFS call getattr\n");
  105. nfs_fattr_init(fattr);
  106. status = rpc_call_sync(server->client, &msg, 0);
  107. dprintk("NFS reply getattr: %d\n", status);
  108. return status;
  109. }
  110. static int
  111. nfs_proc_setattr(struct dentry *dentry, struct nfs_fattr *fattr,
  112. struct iattr *sattr)
  113. {
  114. struct inode *inode = dentry->d_inode;
  115. struct nfs_sattrargs arg = {
  116. .fh = NFS_FH(inode),
  117. .sattr = sattr
  118. };
  119. struct rpc_message msg = {
  120. .rpc_proc = &nfs_procedures[NFSPROC_SETATTR],
  121. .rpc_argp = &arg,
  122. .rpc_resp = fattr,
  123. };
  124. int status;
  125. /* Mask out the non-modebit related stuff from attr->ia_mode */
  126. sattr->ia_mode &= S_IALLUGO;
  127. dprintk("NFS call setattr\n");
  128. if (sattr->ia_valid & ATTR_FILE)
  129. msg.rpc_cred = nfs_file_cred(sattr->ia_file);
  130. nfs_fattr_init(fattr);
  131. status = rpc_call_sync(NFS_CLIENT(inode), &msg, 0);
  132. if (status == 0)
  133. nfs_setattr_update_inode(inode, sattr);
  134. dprintk("NFS reply setattr: %d\n", status);
  135. return status;
  136. }
  137. static int
  138. nfs_proc_lookup(struct inode *dir, struct qstr *name,
  139. struct nfs_fh *fhandle, struct nfs_fattr *fattr)
  140. {
  141. struct nfs_diropargs arg = {
  142. .fh = NFS_FH(dir),
  143. .name = name->name,
  144. .len = name->len
  145. };
  146. struct nfs_diropok res = {
  147. .fh = fhandle,
  148. .fattr = fattr
  149. };
  150. struct rpc_message msg = {
  151. .rpc_proc = &nfs_procedures[NFSPROC_LOOKUP],
  152. .rpc_argp = &arg,
  153. .rpc_resp = &res,
  154. };
  155. int status;
  156. dprintk("NFS call lookup %s\n", name->name);
  157. nfs_fattr_init(fattr);
  158. status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
  159. dprintk("NFS reply lookup: %d\n", status);
  160. return status;
  161. }
  162. static int nfs_proc_readlink(struct inode *inode, struct page *page,
  163. unsigned int pgbase, unsigned int pglen)
  164. {
  165. struct nfs_readlinkargs args = {
  166. .fh = NFS_FH(inode),
  167. .pgbase = pgbase,
  168. .pglen = pglen,
  169. .pages = &page
  170. };
  171. struct rpc_message msg = {
  172. .rpc_proc = &nfs_procedures[NFSPROC_READLINK],
  173. .rpc_argp = &args,
  174. };
  175. int status;
  176. dprintk("NFS call readlink\n");
  177. status = rpc_call_sync(NFS_CLIENT(inode), &msg, 0);
  178. dprintk("NFS reply readlink: %d\n", status);
  179. return status;
  180. }
  181. struct nfs_createdata {
  182. struct nfs_createargs arg;
  183. struct nfs_diropok res;
  184. struct nfs_fh fhandle;
  185. struct nfs_fattr fattr;
  186. };
  187. static struct nfs_createdata *nfs_alloc_createdata(struct inode *dir,
  188. struct dentry *dentry, struct iattr *sattr)
  189. {
  190. struct nfs_createdata *data;
  191. data = kmalloc(sizeof(*data), GFP_KERNEL);
  192. if (data != NULL) {
  193. data->arg.fh = NFS_FH(dir);
  194. data->arg.name = dentry->d_name.name;
  195. data->arg.len = dentry->d_name.len;
  196. data->arg.sattr = sattr;
  197. nfs_fattr_init(&data->fattr);
  198. data->fhandle.size = 0;
  199. data->res.fh = &data->fhandle;
  200. data->res.fattr = &data->fattr;
  201. }
  202. return data;
  203. };
  204. static void nfs_free_createdata(const struct nfs_createdata *data)
  205. {
  206. kfree(data);
  207. }
  208. static int
  209. nfs_proc_create(struct inode *dir, struct dentry *dentry, struct iattr *sattr,
  210. int flags)
  211. {
  212. struct nfs_createdata *data;
  213. struct rpc_message msg = {
  214. .rpc_proc = &nfs_procedures[NFSPROC_CREATE],
  215. };
  216. int status = -ENOMEM;
  217. dprintk("NFS call create %s\n", dentry->d_name.name);
  218. data = nfs_alloc_createdata(dir, dentry, sattr);
  219. if (data == NULL)
  220. goto out;
  221. msg.rpc_argp = &data->arg;
  222. msg.rpc_resp = &data->res;
  223. status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
  224. nfs_mark_for_revalidate(dir);
  225. if (status == 0)
  226. status = nfs_instantiate(dentry, data->res.fh, data->res.fattr);
  227. nfs_free_createdata(data);
  228. out:
  229. dprintk("NFS reply create: %d\n", status);
  230. return status;
  231. }
  232. /*
  233. * In NFSv2, mknod is grafted onto the create call.
  234. */
  235. static int
  236. nfs_proc_mknod(struct inode *dir, struct dentry *dentry, struct iattr *sattr,
  237. dev_t rdev)
  238. {
  239. struct nfs_createdata *data;
  240. struct rpc_message msg = {
  241. .rpc_proc = &nfs_procedures[NFSPROC_CREATE],
  242. };
  243. umode_t mode;
  244. int status = -ENOMEM;
  245. dprintk("NFS call mknod %s\n", dentry->d_name.name);
  246. mode = sattr->ia_mode;
  247. if (S_ISFIFO(mode)) {
  248. sattr->ia_mode = (mode & ~S_IFMT) | S_IFCHR;
  249. sattr->ia_valid &= ~ATTR_SIZE;
  250. } else if (S_ISCHR(mode) || S_ISBLK(mode)) {
  251. sattr->ia_valid |= ATTR_SIZE;
  252. sattr->ia_size = new_encode_dev(rdev);/* get out your barf bag */
  253. }
  254. data = nfs_alloc_createdata(dir, dentry, sattr);
  255. if (data == NULL)
  256. goto out;
  257. msg.rpc_argp = &data->arg;
  258. msg.rpc_resp = &data->res;
  259. status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
  260. nfs_mark_for_revalidate(dir);
  261. if (status == -EINVAL && S_ISFIFO(mode)) {
  262. sattr->ia_mode = mode;
  263. nfs_fattr_init(data->res.fattr);
  264. status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
  265. }
  266. if (status == 0)
  267. status = nfs_instantiate(dentry, data->res.fh, data->res.fattr);
  268. nfs_free_createdata(data);
  269. out:
  270. dprintk("NFS reply mknod: %d\n", status);
  271. return status;
  272. }
  273. static int
  274. nfs_proc_remove(struct inode *dir, struct qstr *name)
  275. {
  276. struct nfs_removeargs arg = {
  277. .fh = NFS_FH(dir),
  278. .name = *name,
  279. };
  280. struct rpc_message msg = {
  281. .rpc_proc = &nfs_procedures[NFSPROC_REMOVE],
  282. .rpc_argp = &arg,
  283. };
  284. int status;
  285. dprintk("NFS call remove %s\n", name->name);
  286. status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
  287. nfs_mark_for_revalidate(dir);
  288. dprintk("NFS reply remove: %d\n", status);
  289. return status;
  290. }
  291. static void
  292. nfs_proc_unlink_setup(struct rpc_message *msg, struct inode *dir)
  293. {
  294. msg->rpc_proc = &nfs_procedures[NFSPROC_REMOVE];
  295. }
  296. static void nfs_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data)
  297. {
  298. rpc_call_start(task);
  299. }
  300. static int nfs_proc_unlink_done(struct rpc_task *task, struct inode *dir)
  301. {
  302. nfs_mark_for_revalidate(dir);
  303. return 1;
  304. }
  305. static void
  306. nfs_proc_rename_setup(struct rpc_message *msg, struct inode *dir)
  307. {
  308. msg->rpc_proc = &nfs_procedures[NFSPROC_RENAME];
  309. }
  310. static void nfs_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data)
  311. {
  312. rpc_call_start(task);
  313. }
  314. static int
  315. nfs_proc_rename_done(struct rpc_task *task, struct inode *old_dir,
  316. struct inode *new_dir)
  317. {
  318. nfs_mark_for_revalidate(old_dir);
  319. nfs_mark_for_revalidate(new_dir);
  320. return 1;
  321. }
  322. static int
  323. nfs_proc_rename(struct inode *old_dir, struct qstr *old_name,
  324. struct inode *new_dir, struct qstr *new_name)
  325. {
  326. struct nfs_renameargs arg = {
  327. .old_dir = NFS_FH(old_dir),
  328. .old_name = old_name,
  329. .new_dir = NFS_FH(new_dir),
  330. .new_name = new_name,
  331. };
  332. struct rpc_message msg = {
  333. .rpc_proc = &nfs_procedures[NFSPROC_RENAME],
  334. .rpc_argp = &arg,
  335. };
  336. int status;
  337. dprintk("NFS call rename %s -> %s\n", old_name->name, new_name->name);
  338. status = rpc_call_sync(NFS_CLIENT(old_dir), &msg, 0);
  339. nfs_mark_for_revalidate(old_dir);
  340. nfs_mark_for_revalidate(new_dir);
  341. dprintk("NFS reply rename: %d\n", status);
  342. return status;
  343. }
  344. static int
  345. nfs_proc_link(struct inode *inode, struct inode *dir, struct qstr *name)
  346. {
  347. struct nfs_linkargs arg = {
  348. .fromfh = NFS_FH(inode),
  349. .tofh = NFS_FH(dir),
  350. .toname = name->name,
  351. .tolen = name->len
  352. };
  353. struct rpc_message msg = {
  354. .rpc_proc = &nfs_procedures[NFSPROC_LINK],
  355. .rpc_argp = &arg,
  356. };
  357. int status;
  358. dprintk("NFS call link %s\n", name->name);
  359. status = rpc_call_sync(NFS_CLIENT(inode), &msg, 0);
  360. nfs_mark_for_revalidate(inode);
  361. nfs_mark_for_revalidate(dir);
  362. dprintk("NFS reply link: %d\n", status);
  363. return status;
  364. }
  365. static int
  366. nfs_proc_symlink(struct inode *dir, struct dentry *dentry, struct page *page,
  367. unsigned int len, struct iattr *sattr)
  368. {
  369. struct nfs_fh *fh;
  370. struct nfs_fattr *fattr;
  371. struct nfs_symlinkargs arg = {
  372. .fromfh = NFS_FH(dir),
  373. .fromname = dentry->d_name.name,
  374. .fromlen = dentry->d_name.len,
  375. .pages = &page,
  376. .pathlen = len,
  377. .sattr = sattr
  378. };
  379. struct rpc_message msg = {
  380. .rpc_proc = &nfs_procedures[NFSPROC_SYMLINK],
  381. .rpc_argp = &arg,
  382. };
  383. int status = -ENAMETOOLONG;
  384. dprintk("NFS call symlink %s\n", dentry->d_name.name);
  385. if (len > NFS2_MAXPATHLEN)
  386. goto out;
  387. fh = nfs_alloc_fhandle();
  388. fattr = nfs_alloc_fattr();
  389. status = -ENOMEM;
  390. if (fh == NULL || fattr == NULL)
  391. goto out_free;
  392. status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
  393. nfs_mark_for_revalidate(dir);
  394. /*
  395. * V2 SYMLINK requests don't return any attributes. Setting the
  396. * filehandle size to zero indicates to nfs_instantiate that it
  397. * should fill in the data with a LOOKUP call on the wire.
  398. */
  399. if (status == 0)
  400. status = nfs_instantiate(dentry, fh, fattr);
  401. out_free:
  402. nfs_free_fattr(fattr);
  403. nfs_free_fhandle(fh);
  404. out:
  405. dprintk("NFS reply symlink: %d\n", status);
  406. return status;
  407. }
  408. static int
  409. nfs_proc_mkdir(struct inode *dir, struct dentry *dentry, struct iattr *sattr)
  410. {
  411. struct nfs_createdata *data;
  412. struct rpc_message msg = {
  413. .rpc_proc = &nfs_procedures[NFSPROC_MKDIR],
  414. };
  415. int status = -ENOMEM;
  416. dprintk("NFS call mkdir %s\n", dentry->d_name.name);
  417. data = nfs_alloc_createdata(dir, dentry, sattr);
  418. if (data == NULL)
  419. goto out;
  420. msg.rpc_argp = &data->arg;
  421. msg.rpc_resp = &data->res;
  422. status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
  423. nfs_mark_for_revalidate(dir);
  424. if (status == 0)
  425. status = nfs_instantiate(dentry, data->res.fh, data->res.fattr);
  426. nfs_free_createdata(data);
  427. out:
  428. dprintk("NFS reply mkdir: %d\n", status);
  429. return status;
  430. }
  431. static int
  432. nfs_proc_rmdir(struct inode *dir, struct qstr *name)
  433. {
  434. struct nfs_diropargs arg = {
  435. .fh = NFS_FH(dir),
  436. .name = name->name,
  437. .len = name->len
  438. };
  439. struct rpc_message msg = {
  440. .rpc_proc = &nfs_procedures[NFSPROC_RMDIR],
  441. .rpc_argp = &arg,
  442. };
  443. int status;
  444. dprintk("NFS call rmdir %s\n", name->name);
  445. status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
  446. nfs_mark_for_revalidate(dir);
  447. dprintk("NFS reply rmdir: %d\n", status);
  448. return status;
  449. }
  450. /*
  451. * The READDIR implementation is somewhat hackish - we pass a temporary
  452. * buffer to the encode function, which installs it in the receive
  453. * the receive iovec. The decode function just parses the reply to make
  454. * sure it is syntactically correct; the entries itself are decoded
  455. * from nfs_readdir by calling the decode_entry function directly.
  456. */
  457. static int
  458. nfs_proc_readdir(struct dentry *dentry, struct rpc_cred *cred,
  459. u64 cookie, struct page **pages, unsigned int count, int plus)
  460. {
  461. struct inode *dir = dentry->d_inode;
  462. struct nfs_readdirargs arg = {
  463. .fh = NFS_FH(dir),
  464. .cookie = cookie,
  465. .count = count,
  466. .pages = pages,
  467. };
  468. struct rpc_message msg = {
  469. .rpc_proc = &nfs_procedures[NFSPROC_READDIR],
  470. .rpc_argp = &arg,
  471. .rpc_cred = cred,
  472. };
  473. int status;
  474. dprintk("NFS call readdir %d\n", (unsigned int)cookie);
  475. status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
  476. nfs_invalidate_atime(dir);
  477. dprintk("NFS reply readdir: %d\n", status);
  478. return status;
  479. }
  480. static int
  481. nfs_proc_statfs(struct nfs_server *server, struct nfs_fh *fhandle,
  482. struct nfs_fsstat *stat)
  483. {
  484. struct nfs2_fsstat fsinfo;
  485. struct rpc_message msg = {
  486. .rpc_proc = &nfs_procedures[NFSPROC_STATFS],
  487. .rpc_argp = fhandle,
  488. .rpc_resp = &fsinfo,
  489. };
  490. int status;
  491. dprintk("NFS call statfs\n");
  492. nfs_fattr_init(stat->fattr);
  493. status = rpc_call_sync(server->client, &msg, 0);
  494. dprintk("NFS reply statfs: %d\n", status);
  495. if (status)
  496. goto out;
  497. stat->tbytes = (u64)fsinfo.blocks * fsinfo.bsize;
  498. stat->fbytes = (u64)fsinfo.bfree * fsinfo.bsize;
  499. stat->abytes = (u64)fsinfo.bavail * fsinfo.bsize;
  500. stat->tfiles = 0;
  501. stat->ffiles = 0;
  502. stat->afiles = 0;
  503. out:
  504. return status;
  505. }
  506. static int
  507. nfs_proc_fsinfo(struct nfs_server *server, struct nfs_fh *fhandle,
  508. struct nfs_fsinfo *info)
  509. {
  510. struct nfs2_fsstat fsinfo;
  511. struct rpc_message msg = {
  512. .rpc_proc = &nfs_procedures[NFSPROC_STATFS],
  513. .rpc_argp = fhandle,
  514. .rpc_resp = &fsinfo,
  515. };
  516. int status;
  517. dprintk("NFS call fsinfo\n");
  518. nfs_fattr_init(info->fattr);
  519. status = rpc_call_sync(server->client, &msg, 0);
  520. dprintk("NFS reply fsinfo: %d\n", status);
  521. if (status)
  522. goto out;
  523. info->rtmax = NFS_MAXDATA;
  524. info->rtpref = fsinfo.tsize;
  525. info->rtmult = fsinfo.bsize;
  526. info->wtmax = NFS_MAXDATA;
  527. info->wtpref = fsinfo.tsize;
  528. info->wtmult = fsinfo.bsize;
  529. info->dtpref = fsinfo.tsize;
  530. info->maxfilesize = 0x7FFFFFFF;
  531. info->lease_time = 0;
  532. out:
  533. return status;
  534. }
  535. static int
  536. nfs_proc_pathconf(struct nfs_server *server, struct nfs_fh *fhandle,
  537. struct nfs_pathconf *info)
  538. {
  539. info->max_link = 0;
  540. info->max_namelen = NFS2_MAXNAMLEN;
  541. return 0;
  542. }
  543. static int nfs_read_done(struct rpc_task *task, struct nfs_read_data *data)
  544. {
  545. struct inode *inode = data->header->inode;
  546. nfs_invalidate_atime(inode);
  547. if (task->tk_status >= 0) {
  548. nfs_refresh_inode(inode, data->res.fattr);
  549. /* Emulate the eof flag, which isn't normally needed in NFSv2
  550. * as it is guaranteed to always return the file attributes
  551. */
  552. if (data->args.offset + data->res.count >= data->res.fattr->size)
  553. data->res.eof = 1;
  554. }
  555. return 0;
  556. }
  557. static void nfs_proc_read_setup(struct nfs_read_data *data, struct rpc_message *msg)
  558. {
  559. msg->rpc_proc = &nfs_procedures[NFSPROC_READ];
  560. }
  561. static void nfs_proc_read_rpc_prepare(struct rpc_task *task, struct nfs_read_data *data)
  562. {
  563. rpc_call_start(task);
  564. }
  565. static int nfs_write_done(struct rpc_task *task, struct nfs_write_data *data)
  566. {
  567. struct inode *inode = data->header->inode;
  568. if (task->tk_status >= 0)
  569. nfs_post_op_update_inode_force_wcc(inode, data->res.fattr);
  570. return 0;
  571. }
  572. static void nfs_proc_write_setup(struct nfs_write_data *data, struct rpc_message *msg)
  573. {
  574. /* Note: NFSv2 ignores @stable and always uses NFS_FILE_SYNC */
  575. data->args.stable = NFS_FILE_SYNC;
  576. msg->rpc_proc = &nfs_procedures[NFSPROC_WRITE];
  577. }
  578. static void nfs_proc_write_rpc_prepare(struct rpc_task *task, struct nfs_write_data *data)
  579. {
  580. rpc_call_start(task);
  581. }
  582. static void nfs_proc_commit_rpc_prepare(struct rpc_task *task, struct nfs_commit_data *data)
  583. {
  584. BUG();
  585. }
  586. static void
  587. nfs_proc_commit_setup(struct nfs_commit_data *data, struct rpc_message *msg)
  588. {
  589. BUG();
  590. }
  591. static int
  592. nfs_proc_lock(struct file *filp, int cmd, struct file_lock *fl)
  593. {
  594. struct inode *inode = file_inode(filp);
  595. return nlmclnt_proc(NFS_SERVER(inode)->nlm_host, cmd, fl);
  596. }
  597. /* Helper functions for NFS lock bounds checking */
  598. #define NFS_LOCK32_OFFSET_MAX ((__s32)0x7fffffffUL)
  599. static int nfs_lock_check_bounds(const struct file_lock *fl)
  600. {
  601. __s32 start, end;
  602. start = (__s32)fl->fl_start;
  603. if ((loff_t)start != fl->fl_start)
  604. goto out_einval;
  605. if (fl->fl_end != OFFSET_MAX) {
  606. end = (__s32)fl->fl_end;
  607. if ((loff_t)end != fl->fl_end)
  608. goto out_einval;
  609. } else
  610. end = NFS_LOCK32_OFFSET_MAX;
  611. if (start < 0 || start > end)
  612. goto out_einval;
  613. return 0;
  614. out_einval:
  615. return -EINVAL;
  616. }
  617. static int nfs_have_delegation(struct inode *inode, fmode_t flags)
  618. {
  619. return 0;
  620. }
  621. static int nfs_return_delegation(struct inode *inode)
  622. {
  623. nfs_wb_all(inode);
  624. return 0;
  625. }
  626. static const struct inode_operations nfs_dir_inode_operations = {
  627. .create = nfs_create,
  628. .lookup = nfs_lookup,
  629. .link = nfs_link,
  630. .unlink = nfs_unlink,
  631. .symlink = nfs_symlink,
  632. .mkdir = nfs_mkdir,
  633. .rmdir = nfs_rmdir,
  634. .mknod = nfs_mknod,
  635. .rename = nfs_rename,
  636. .permission = nfs_permission,
  637. .getattr = nfs_getattr,
  638. .setattr = nfs_setattr,
  639. };
  640. static const struct inode_operations nfs_file_inode_operations = {
  641. .permission = nfs_permission,
  642. .getattr = nfs_getattr,
  643. .setattr = nfs_setattr,
  644. };
  645. const struct nfs_rpc_ops nfs_v2_clientops = {
  646. .version = 2, /* protocol version */
  647. .dentry_ops = &nfs_dentry_operations,
  648. .dir_inode_ops = &nfs_dir_inode_operations,
  649. .file_inode_ops = &nfs_file_inode_operations,
  650. .file_ops = &nfs_file_operations,
  651. .getroot = nfs_proc_get_root,
  652. .submount = nfs_submount,
  653. .try_mount = nfs_try_mount,
  654. .getattr = nfs_proc_getattr,
  655. .setattr = nfs_proc_setattr,
  656. .lookup = nfs_proc_lookup,
  657. .access = NULL, /* access */
  658. .readlink = nfs_proc_readlink,
  659. .create = nfs_proc_create,
  660. .remove = nfs_proc_remove,
  661. .unlink_setup = nfs_proc_unlink_setup,
  662. .unlink_rpc_prepare = nfs_proc_unlink_rpc_prepare,
  663. .unlink_done = nfs_proc_unlink_done,
  664. .rename = nfs_proc_rename,
  665. .rename_setup = nfs_proc_rename_setup,
  666. .rename_rpc_prepare = nfs_proc_rename_rpc_prepare,
  667. .rename_done = nfs_proc_rename_done,
  668. .link = nfs_proc_link,
  669. .symlink = nfs_proc_symlink,
  670. .mkdir = nfs_proc_mkdir,
  671. .rmdir = nfs_proc_rmdir,
  672. .readdir = nfs_proc_readdir,
  673. .mknod = nfs_proc_mknod,
  674. .statfs = nfs_proc_statfs,
  675. .fsinfo = nfs_proc_fsinfo,
  676. .pathconf = nfs_proc_pathconf,
  677. .decode_dirent = nfs2_decode_dirent,
  678. .read_setup = nfs_proc_read_setup,
  679. .read_pageio_init = nfs_pageio_init_read,
  680. .read_rpc_prepare = nfs_proc_read_rpc_prepare,
  681. .read_done = nfs_read_done,
  682. .write_setup = nfs_proc_write_setup,
  683. .write_pageio_init = nfs_pageio_init_write,
  684. .write_rpc_prepare = nfs_proc_write_rpc_prepare,
  685. .write_done = nfs_write_done,
  686. .commit_setup = nfs_proc_commit_setup,
  687. .commit_rpc_prepare = nfs_proc_commit_rpc_prepare,
  688. .lock = nfs_proc_lock,
  689. .lock_check_bounds = nfs_lock_check_bounds,
  690. .close_context = nfs_close_context,
  691. .have_delegation = nfs_have_delegation,
  692. .return_delegation = nfs_return_delegation,
  693. .alloc_client = nfs_alloc_client,
  694. .init_client = nfs_init_client,
  695. .free_client = nfs_free_client,
  696. .create_server = nfs_create_server,
  697. .clone_server = nfs_clone_server,
  698. };