dir.c
上传用户:jlfgdled
上传日期:2013-04-10
资源大小:33168k
文件大小:29k
源码类别:

Linux/Unix编程

开发平台:

Unix_Linux

  1. /*
  2.  *  linux/fs/nfs/dir.c
  3.  *
  4.  *  Copyright (C) 1992  Rick Sladkey
  5.  *
  6.  *  nfs directory handling functions
  7.  *
  8.  * 10 Apr 1996 Added silly rename for unlink --okir
  9.  * 28 Sep 1996 Improved directory cache --okir
  10.  * 23 Aug 1997  Claus Heine claus@momo.math.rwth-aachen.de 
  11.  *              Re-implemented silly rename for unlink, newly implemented
  12.  *              silly rename for nfs_rename() following the suggestions
  13.  *              of Olaf Kirch (okir) found in this file.
  14.  *              Following Linus comments on my original hack, this version
  15.  *              depends only on the dcache stuff and doesn't touch the inode
  16.  *              layer (iput() and friends).
  17.  *  6 Jun 1999 Cache readdir lookups in the page cache. -DaveM
  18.  */
  19. #include <linux/sched.h>
  20. #include <linux/errno.h>
  21. #include <linux/stat.h>
  22. #include <linux/fcntl.h>
  23. #include <linux/string.h>
  24. #include <linux/kernel.h>
  25. #include <linux/slab.h>
  26. #include <linux/mm.h>
  27. #include <linux/sunrpc/clnt.h>
  28. #include <linux/nfs_fs.h>
  29. #include <linux/nfs_mount.h>
  30. #include <linux/pagemap.h>
  31. #include <linux/smp_lock.h>
  32. #define NFS_PARANOIA 1
  33. /* #define NFS_DEBUG_VERBOSE 1 */
  34. static int nfs_readdir(struct file *, void *, filldir_t);
  35. static struct dentry *nfs_lookup(struct inode *, struct dentry *);
  36. static int nfs_create(struct inode *, struct dentry *, int);
  37. static int nfs_mkdir(struct inode *, struct dentry *, int);
  38. static int nfs_rmdir(struct inode *, struct dentry *);
  39. static int nfs_unlink(struct inode *, struct dentry *);
  40. static int nfs_symlink(struct inode *, struct dentry *, const char *);
  41. static int nfs_link(struct dentry *, struct inode *, struct dentry *);
  42. static int nfs_mknod(struct inode *, struct dentry *, int, int);
  43. static int nfs_rename(struct inode *, struct dentry *,
  44.       struct inode *, struct dentry *);
  45. static int nfs_fsync_dir(struct file *, struct dentry *, int);
  46. struct file_operations nfs_dir_operations = {
  47. read: generic_read_dir,
  48. readdir: nfs_readdir,
  49. open: nfs_open,
  50. release: nfs_release,
  51. fsync: nfs_fsync_dir
  52. };
  53. struct inode_operations nfs_dir_inode_operations = {
  54. create: nfs_create,
  55. lookup: nfs_lookup,
  56. link: nfs_link,
  57. unlink: nfs_unlink,
  58. symlink: nfs_symlink,
  59. mkdir: nfs_mkdir,
  60. rmdir: nfs_rmdir,
  61. mknod: nfs_mknod,
  62. rename: nfs_rename,
  63. permission: nfs_permission,
  64. revalidate: nfs_revalidate,
  65. setattr: nfs_notify_change,
  66. };
  67. typedef u32 * (*decode_dirent_t)(u32 *, struct nfs_entry *, int);
  68. typedef struct {
  69. struct file *file;
  70. struct page *page;
  71. unsigned long page_index;
  72. u32 *ptr;
  73. u64 target;
  74. struct nfs_entry *entry;
  75. decode_dirent_t decode;
  76. int plus;
  77. int error;
  78. } nfs_readdir_descriptor_t;
  79. /* Now we cache directories properly, by stuffing the dirent
  80.  * data directly in the page cache.
  81.  *
  82.  * Inode invalidation due to refresh etc. takes care of
  83.  * _everything_, no sloppy entry flushing logic, no extraneous
  84.  * copying, network direct to page cache, the way it was meant
  85.  * to be.
  86.  *
  87.  * NOTE: Dirent information verification is done always by the
  88.  *  page-in of the RPC reply, nowhere else, this simplies
  89.  *  things substantially.
  90.  */
  91. static
  92. int nfs_readdir_filler(nfs_readdir_descriptor_t *desc, struct page *page)
  93. {
  94. struct file *file = desc->file;
  95. struct inode *inode = file->f_dentry->d_inode;
  96. struct rpc_cred *cred = nfs_file_cred(file);
  97. int error;
  98. dfprintk(VFS, "NFS: nfs_readdir_filler() reading cookie %Lu into page %lu.n", (long long)desc->entry->cookie, page->index);
  99.  again:
  100. error = NFS_PROTO(inode)->readdir(inode, cred, desc->entry->cookie, page,
  101.   NFS_SERVER(inode)->dtsize, desc->plus);
  102. /* We requested READDIRPLUS, but the server doesn't grok it */
  103. if (desc->plus && error == -ENOTSUPP) {
  104. NFS_FLAGS(inode) &= ~NFS_INO_ADVISE_RDPLUS;
  105. desc->plus = 0;
  106. goto again;
  107. }
  108. if (error < 0)
  109. goto error;
  110. SetPageUptodate(page);
  111. /* Ensure consistent page alignment of the data.
  112.  * Note: assumes we have exclusive access to this mapping either
  113.  *  throught inode->i_sem or some other mechanism.
  114.  */
  115. if (page->index == 0)
  116. invalidate_inode_pages(inode);
  117. UnlockPage(page);
  118. return 0;
  119.  error:
  120. SetPageError(page);
  121. UnlockPage(page);
  122. invalidate_inode_pages(inode);
  123. desc->error = error;
  124. return -EIO;
  125. }
  126. static inline
  127. int dir_decode(nfs_readdir_descriptor_t *desc)
  128. {
  129. u32 *p = desc->ptr;
  130. p = desc->decode(p, desc->entry, desc->plus);
  131. if (IS_ERR(p))
  132. return PTR_ERR(p);
  133. desc->ptr = p;
  134. return 0;
  135. }
  136. static inline
  137. void dir_page_release(nfs_readdir_descriptor_t *desc)
  138. {
  139. kunmap(desc->page);
  140. page_cache_release(desc->page);
  141. desc->page = NULL;
  142. desc->ptr = NULL;
  143. }
  144. /*
  145.  * Given a pointer to a buffer that has already been filled by a call
  146.  * to readdir, find the next entry.
  147.  *
  148.  * If the end of the buffer has been reached, return -EAGAIN, if not,
  149.  * return the offset within the buffer of the next entry to be
  150.  * read.
  151.  */
  152. static inline
  153. int find_dirent(nfs_readdir_descriptor_t *desc, struct page *page)
  154. {
  155. struct nfs_entry *entry = desc->entry;
  156. int loop_count = 0,
  157. status;
  158. while((status = dir_decode(desc)) == 0) {
  159. dfprintk(VFS, "NFS: found cookie %Lun", (long long)entry->cookie);
  160. if (entry->prev_cookie == desc->target)
  161. break;
  162. if (loop_count++ > 200) {
  163. loop_count = 0;
  164. schedule();
  165. }
  166. }
  167. dfprintk(VFS, "NFS: find_dirent() returns %dn", status);
  168. return status;
  169. }
  170. /*
  171.  * Find the given page, and call find_dirent() in order to try to
  172.  * return the next entry.
  173.  */
  174. static inline
  175. int find_dirent_page(nfs_readdir_descriptor_t *desc)
  176. {
  177. struct inode *inode = desc->file->f_dentry->d_inode;
  178. struct page *page;
  179. int status;
  180. dfprintk(VFS, "NFS: find_dirent_page() searching directory page %ldn", desc->page_index);
  181. desc->plus = NFS_USE_READDIRPLUS(inode);
  182. page = read_cache_page(&inode->i_data, desc->page_index,
  183.        (filler_t *)nfs_readdir_filler, desc);
  184. if (IS_ERR(page)) {
  185. status = PTR_ERR(page);
  186. goto out;
  187. }
  188. if (!Page_Uptodate(page))
  189. goto read_error;
  190. /* NOTE: Someone else may have changed the READDIRPLUS flag */
  191. desc->page = page;
  192. desc->ptr = kmap(page);
  193. status = find_dirent(desc, page);
  194. if (status < 0)
  195. dir_page_release(desc);
  196.  out:
  197. dfprintk(VFS, "NFS: find_dirent_page() returns %dn", status);
  198. return status;
  199.  read_error:
  200. page_cache_release(page);
  201. return -EIO;
  202. }
  203. /*
  204.  * Recurse through the page cache pages, and return a
  205.  * filled nfs_entry structure of the next directory entry if possible.
  206.  *
  207.  * The target for the search is 'desc->target'.
  208.  */
  209. static inline
  210. int readdir_search_pagecache(nfs_readdir_descriptor_t *desc)
  211. {
  212. int loop_count = 0;
  213. int res;
  214. dfprintk(VFS, "NFS: readdir_search_pagecache() searching for cookie %Lun", (long long)desc->target);
  215. for (;;) {
  216. res = find_dirent_page(desc);
  217. if (res != -EAGAIN)
  218. break;
  219. /* Align to beginning of next page */
  220. desc->page_index ++;
  221. if (loop_count++ > 200) {
  222. loop_count = 0;
  223. schedule();
  224. }
  225. }
  226. dfprintk(VFS, "NFS: readdir_search_pagecache() returned %dn", res);
  227. return res;
  228. }
  229. /*
  230.  * Once we've found the start of the dirent within a page: fill 'er up...
  231.  */
  232. static 
  233. int nfs_do_filldir(nfs_readdir_descriptor_t *desc, void *dirent,
  234.    filldir_t filldir)
  235. {
  236. struct file *file = desc->file;
  237. struct nfs_entry *entry = desc->entry;
  238. unsigned long fileid;
  239. int loop_count = 0,
  240. res;
  241. dfprintk(VFS, "NFS: nfs_do_filldir() filling starting @ cookie %Lun", (long long)desc->target);
  242. for(;;) {
  243. /* Note: entry->prev_cookie contains the cookie for
  244.  *  retrieving the current dirent on the server */
  245. fileid = nfs_fileid_to_ino_t(entry->ino);
  246. res = filldir(dirent, entry->name, entry->len, 
  247.       entry->prev_cookie, fileid, DT_UNKNOWN);
  248. if (res < 0)
  249. break;
  250. file->f_pos = desc->target = entry->cookie;
  251. if (dir_decode(desc) != 0) {
  252. desc->page_index ++;
  253. break;
  254. }
  255. if (loop_count++ > 200) {
  256. loop_count = 0;
  257. schedule();
  258. }
  259. }
  260. dir_page_release(desc);
  261. dfprintk(VFS, "NFS: nfs_do_filldir() filling ended @ cookie %Lu; returning = %dn", (long long)desc->target, res);
  262. return res;
  263. }
  264. /*
  265.  * If we cannot find a cookie in our cache, we suspect that this is
  266.  * because it points to a deleted file, so we ask the server to return
  267.  * whatever it thinks is the next entry. We then feed this to filldir.
  268.  * If all goes well, we should then be able to find our way round the
  269.  * cache on the next call to readdir_search_pagecache();
  270.  *
  271.  * NOTE: we cannot add the anonymous page to the pagecache because
  272.  *  the data it contains might not be page aligned. Besides,
  273.  *  we should already have a complete representation of the
  274.  *  directory in the page cache by the time we get here.
  275.  */
  276. static inline
  277. int uncached_readdir(nfs_readdir_descriptor_t *desc, void *dirent,
  278.      filldir_t filldir)
  279. {
  280. struct file *file = desc->file;
  281. struct inode *inode = file->f_dentry->d_inode;
  282. struct rpc_cred *cred = nfs_file_cred(file);
  283. struct page *page = NULL;
  284. int status;
  285. dfprintk(VFS, "NFS: uncached_readdir() searching for cookie %Lun", (long long)desc->target);
  286. page = alloc_page(GFP_HIGHUSER);
  287. if (!page) {
  288. status = -ENOMEM;
  289. goto out;
  290. }
  291. desc->error = NFS_PROTO(inode)->readdir(inode, cred, desc->target,
  292. page,
  293. NFS_SERVER(inode)->dtsize,
  294. desc->plus);
  295. desc->page = page;
  296. desc->ptr = kmap(page);
  297. if (desc->error >= 0) {
  298. if ((status = dir_decode(desc)) == 0)
  299. desc->entry->prev_cookie = desc->target;
  300. } else
  301. status = -EIO;
  302. if (status < 0)
  303. goto out_release;
  304. status = nfs_do_filldir(desc, dirent, filldir);
  305. /* Reset read descriptor so it searches the page cache from
  306.  * the start upon the next call to readdir_search_pagecache() */
  307. desc->page_index = 0;
  308. memset(desc->entry, 0, sizeof(*desc->entry));
  309.  out:
  310. dfprintk(VFS, "NFS: uncached_readdir() returns %dn", status);
  311. return status;
  312.  out_release:
  313. dir_page_release(desc);
  314. goto out;
  315. }
  316. /* The file offset position is now represented as a true offset into the
  317.  * page cache as is the case in most of the other filesystems.
  318.  */
  319. static int nfs_readdir(struct file *filp, void *dirent, filldir_t filldir)
  320. {
  321. struct dentry *dentry = filp->f_dentry;
  322. struct inode *inode = dentry->d_inode;
  323. nfs_readdir_descriptor_t my_desc,
  324. *desc = &my_desc;
  325. struct nfs_entry my_entry;
  326. long res;
  327. res = nfs_revalidate(dentry);
  328. if (res < 0)
  329. return res;
  330. /*
  331.  * filp->f_pos points to the file offset in the page cache.
  332.  * but if the cache has meanwhile been zapped, we need to
  333.  * read from the last dirent to revalidate f_pos
  334.  * itself.
  335.  */
  336. memset(desc, 0, sizeof(*desc));
  337. memset(&my_entry, 0, sizeof(my_entry));
  338. desc->file = filp;
  339. desc->target = filp->f_pos;
  340. desc->entry = &my_entry;
  341. desc->decode = NFS_PROTO(inode)->decode_dirent;
  342. while(!desc->entry->eof) {
  343. res = readdir_search_pagecache(desc);
  344. if (res == -EBADCOOKIE) {
  345. /* This means either end of directory */
  346. if (desc->entry->cookie != desc->target) {
  347. /* Or that the server has 'lost' a cookie */
  348. res = uncached_readdir(desc, dirent, filldir);
  349. if (res >= 0)
  350. continue;
  351. }
  352. res = 0;
  353. break;
  354. } else if (res < 0)
  355. break;
  356. res = nfs_do_filldir(desc, dirent, filldir);
  357. if (res < 0) {
  358. res = 0;
  359. break;
  360. }
  361. }
  362. if (desc->error < 0)
  363. return desc->error;
  364. if (res < 0)
  365. return res;
  366. return 0;
  367. }
  368. /*
  369.  * All directory operations under NFS are synchronous, so fsync()
  370.  * is a dummy operation.
  371.  */
  372. int nfs_fsync_dir(struct file *filp, struct dentry *dentry, int datasync)
  373. {
  374. return 0;
  375. }
  376. /*
  377.  * A check for whether or not the parent directory has changed.
  378.  * In the case it has, we assume that the dentries are untrustworthy
  379.  * and may need to be looked up again.
  380.  */
  381. static inline
  382. int nfs_check_verifier(struct inode *dir, struct dentry *dentry)
  383. {
  384. if (IS_ROOT(dentry))
  385. return 1;
  386. if (nfs_revalidate_inode(NFS_SERVER(dir), dir))
  387. return 0;
  388. return time_after(dentry->d_time, NFS_MTIME_UPDATE(dir));
  389. }
  390. /*
  391.  * Whenever an NFS operation succeeds, we know that the dentry
  392.  * is valid, so we update the revalidation timestamp.
  393.  */
  394. static inline void nfs_renew_times(struct dentry * dentry)
  395. {
  396. dentry->d_time = jiffies;
  397. }
  398. static inline
  399. int nfs_lookup_verify_inode(struct inode *inode, int flags)
  400. {
  401. struct nfs_server *server = NFS_SERVER(inode);
  402. /*
  403.  * If we're interested in close-to-open cache consistency,
  404.  * then we revalidate the inode upon lookup.
  405.  */
  406. if (!(server->flags & NFS_MOUNT_NOCTO) && !(flags & LOOKUP_CONTINUE))
  407. NFS_CACHEINV(inode);
  408. return nfs_revalidate_inode(server, inode);
  409. }
  410. /*
  411.  * We judge how long we want to trust negative
  412.  * dentries by looking at the parent inode mtime.
  413.  *
  414.  * If parent mtime has changed, we revalidate, else we wait for a
  415.  * period corresponding to the parent's attribute cache timeout value.
  416.  */
  417. static inline int nfs_neg_need_reval(struct inode *dir, struct dentry *dentry)
  418. {
  419. if (!nfs_check_verifier(dir, dentry))
  420. return 1;
  421. return time_after(jiffies, dentry->d_time + NFS_ATTRTIMEO(dir));
  422. }
  423. /*
  424.  * This is called every time the dcache has a lookup hit,
  425.  * and we should check whether we can really trust that
  426.  * lookup.
  427.  *
  428.  * NOTE! The hit can be a negative hit too, don't assume
  429.  * we have an inode!
  430.  *
  431.  * If the parent directory is seen to have changed, we throw out the
  432.  * cached dentry and do a new lookup.
  433.  */
  434. static int nfs_lookup_revalidate(struct dentry * dentry, int flags)
  435. {
  436. struct inode *dir;
  437. struct inode *inode;
  438. int error;
  439. struct nfs_fh fhandle;
  440. struct nfs_fattr fattr;
  441. lock_kernel();
  442. dir = dentry->d_parent->d_inode;
  443. inode = dentry->d_inode;
  444. if (!inode) {
  445. if (nfs_neg_need_reval(dir, dentry))
  446. goto out_bad;
  447. goto out_valid;
  448. }
  449. if (is_bad_inode(inode)) {
  450. dfprintk(VFS, "nfs_lookup_validate: %s/%s has dud inoden",
  451. dentry->d_parent->d_name.name, dentry->d_name.name);
  452. goto out_bad;
  453. }
  454. /* Force a full look up iff the parent directory has changed */
  455. if (nfs_check_verifier(dir, dentry)) {
  456. if (nfs_lookup_verify_inode(inode, flags))
  457. goto out_bad;
  458. goto out_valid;
  459. }
  460. if (NFS_STALE(inode))
  461. goto out_bad;
  462. error = NFS_PROTO(dir)->lookup(dir, &dentry->d_name, &fhandle, &fattr);
  463. if (error)
  464. goto out_bad;
  465. if (memcmp(NFS_FH(inode), &fhandle, sizeof(struct nfs_fh))!= 0)
  466. goto out_bad;
  467. if ((error = nfs_refresh_inode(inode, &fattr)) != 0)
  468. goto out_bad;
  469. nfs_renew_times(dentry);
  470.  out_valid:
  471. unlock_kernel();
  472. return 1;
  473.  out_bad:
  474. NFS_CACHEINV(dir);
  475. if (inode && S_ISDIR(inode->i_mode)) {
  476. /* Purge readdir caches. */
  477. nfs_zap_caches(inode);
  478. /* If we have submounts, don't unhash ! */
  479. if (have_submounts(dentry))
  480. goto out_valid;
  481. shrink_dcache_parent(dentry);
  482. }
  483. d_drop(dentry);
  484. unlock_kernel();
  485. return 0;
  486. }
  487. /*
  488.  * This is called from dput() when d_count is going to 0.
  489.  */
  490. static int nfs_dentry_delete(struct dentry *dentry)
  491. {
  492. dfprintk(VFS, "NFS: dentry_delete(%s/%s, %x)n",
  493. dentry->d_parent->d_name.name, dentry->d_name.name,
  494. dentry->d_flags);
  495. if (dentry->d_flags & DCACHE_NFSFS_RENAMED) {
  496. /* Unhash it, so that ->d_iput() would be called */
  497. return 1;
  498. }
  499. return 0;
  500. }
  501. /*
  502.  * Called when the dentry loses inode.
  503.  * We use it to clean up silly-renamed files.
  504.  */
  505. static void nfs_dentry_iput(struct dentry *dentry, struct inode *inode)
  506. {
  507. if (dentry->d_flags & DCACHE_NFSFS_RENAMED) {
  508. lock_kernel();
  509. nfs_complete_unlink(dentry);
  510. unlock_kernel();
  511. }
  512. if (is_bad_inode(inode))
  513. force_delete(inode);
  514. iput(inode);
  515. }
  516. struct dentry_operations nfs_dentry_operations = {
  517. d_revalidate: nfs_lookup_revalidate,
  518. d_delete: nfs_dentry_delete,
  519. d_iput: nfs_dentry_iput,
  520. };
  521. static struct dentry *nfs_lookup(struct inode *dir, struct dentry * dentry)
  522. {
  523. struct inode *inode;
  524. int error;
  525. struct nfs_fh fhandle;
  526. struct nfs_fattr fattr;
  527. dfprintk(VFS, "NFS: lookup(%s/%s)n",
  528. dentry->d_parent->d_name.name, dentry->d_name.name);
  529. error = -ENAMETOOLONG;
  530. if (dentry->d_name.len > NFS_SERVER(dir)->namelen)
  531. goto out;
  532. error = -ENOMEM;
  533. dentry->d_op = &nfs_dentry_operations;
  534. error = NFS_PROTO(dir)->lookup(dir, &dentry->d_name, &fhandle, &fattr);
  535. inode = NULL;
  536. if (error == -ENOENT)
  537. goto no_entry;
  538. if (!error) {
  539. error = -EACCES;
  540. inode = nfs_fhget(dentry, &fhandle, &fattr);
  541. if (inode) {
  542.     no_entry:
  543. d_add(dentry, inode);
  544. error = 0;
  545. }
  546. nfs_renew_times(dentry);
  547. }
  548. out:
  549. return ERR_PTR(error);
  550. }
  551. /*
  552.  * Code common to create, mkdir, and mknod.
  553.  */
  554. static int nfs_instantiate(struct dentry *dentry, struct nfs_fh *fhandle,
  555. struct nfs_fattr *fattr)
  556. {
  557. struct inode *inode;
  558. int error = -EACCES;
  559. if (fhandle->size == 0 || !(fattr->valid & NFS_ATTR_FATTR)) {
  560. struct inode *dir = dentry->d_parent->d_inode;
  561. error = NFS_PROTO(dir)->lookup(dir, &dentry->d_name, fhandle, fattr);
  562. if (error)
  563. goto out_err;
  564. }
  565. inode = nfs_fhget(dentry, fhandle, fattr);
  566. if (inode) {
  567. d_instantiate(dentry, inode);
  568. nfs_renew_times(dentry);
  569. error = 0;
  570. }
  571. return error;
  572. out_err:
  573. d_drop(dentry);
  574. return error;
  575. }
  576. /*
  577.  * Following a failed create operation, we drop the dentry rather
  578.  * than retain a negative dentry. This avoids a problem in the event
  579.  * that the operation succeeded on the server, but an error in the
  580.  * reply path made it appear to have failed.
  581.  */
  582. static int nfs_create(struct inode *dir, struct dentry *dentry, int mode)
  583. {
  584. struct iattr attr;
  585. struct nfs_fattr fattr;
  586. struct nfs_fh fhandle;
  587. int error;
  588. dfprintk(VFS, "NFS: create(%x/%ld, %sn",
  589. dir->i_dev, dir->i_ino, dentry->d_name.name);
  590. attr.ia_mode = mode;
  591. attr.ia_valid = ATTR_MODE;
  592. /*
  593.  * The 0 argument passed into the create function should one day
  594.  * contain the O_EXCL flag if requested. This allows NFSv3 to
  595.  * select the appropriate create strategy. Currently open_namei
  596.  * does not pass the create flags.
  597.  */
  598. nfs_zap_caches(dir);
  599. error = NFS_PROTO(dir)->create(dir, &dentry->d_name,
  600.  &attr, 0, &fhandle, &fattr);
  601. if (!error)
  602. error = nfs_instantiate(dentry, &fhandle, &fattr);
  603. else
  604. d_drop(dentry);
  605. return error;
  606. }
  607. /*
  608.  * See comments for nfs_proc_create regarding failed operations.
  609.  */
  610. static int nfs_mknod(struct inode *dir, struct dentry *dentry, int mode, int rdev)
  611. {
  612. struct iattr attr;
  613. struct nfs_fattr fattr;
  614. struct nfs_fh fhandle;
  615. int error;
  616. dfprintk(VFS, "NFS: mknod(%x/%ld, %sn",
  617. dir->i_dev, dir->i_ino, dentry->d_name.name);
  618. attr.ia_mode = mode;
  619. attr.ia_valid = ATTR_MODE;
  620. nfs_zap_caches(dir);
  621. error = NFS_PROTO(dir)->mknod(dir, &dentry->d_name, &attr, rdev,
  622. &fhandle, &fattr);
  623. if (!error)
  624. error = nfs_instantiate(dentry, &fhandle, &fattr);
  625. else
  626. d_drop(dentry);
  627. return error;
  628. }
  629. /*
  630.  * See comments for nfs_proc_create regarding failed operations.
  631.  */
  632. static int nfs_mkdir(struct inode *dir, struct dentry *dentry, int mode)
  633. {
  634. struct iattr attr;
  635. struct nfs_fattr fattr;
  636. struct nfs_fh fhandle;
  637. int error;
  638. dfprintk(VFS, "NFS: mkdir(%x/%ld, %sn",
  639. dir->i_dev, dir->i_ino, dentry->d_name.name);
  640. attr.ia_valid = ATTR_MODE;
  641. attr.ia_mode = mode | S_IFDIR;
  642. #if 0
  643. /*
  644.  * Always drop the dentry, we can't always depend on
  645.  * the fattr returned by the server (AIX seems to be
  646.  * broken). We're better off doing another lookup than
  647.  * depending on potentially bogus information.
  648.  */
  649. d_drop(dentry);
  650. #endif
  651. nfs_zap_caches(dir);
  652. error = NFS_PROTO(dir)->mkdir(dir, &dentry->d_name, &attr, &fhandle,
  653. &fattr);
  654. if (!error)
  655. error = nfs_instantiate(dentry, &fhandle, &fattr);
  656. else
  657. d_drop(dentry);
  658. return error;
  659. }
  660. static int nfs_rmdir(struct inode *dir, struct dentry *dentry)
  661. {
  662. int error;
  663. dfprintk(VFS, "NFS: rmdir(%x/%ld, %sn",
  664. dir->i_dev, dir->i_ino, dentry->d_name.name);
  665. nfs_zap_caches(dir);
  666. error = NFS_PROTO(dir)->rmdir(dir, &dentry->d_name);
  667. if (!error)
  668. dentry->d_inode->i_nlink = 0;
  669. return error;
  670. }
  671. static int nfs_sillyrename(struct inode *dir, struct dentry *dentry)
  672. {
  673. static unsigned int sillycounter;
  674. const int      i_inosize  = sizeof(dir->i_ino)*2;
  675. const int      countersize = sizeof(sillycounter)*2;
  676. const int      slen       = strlen(".nfs") + i_inosize + countersize;
  677. char           silly[slen+1];
  678. struct qstr    qsilly;
  679. struct dentry *sdentry;
  680. int            error = -EIO;
  681. dfprintk(VFS, "NFS: silly-rename(%s/%s, ct=%d)n",
  682. dentry->d_parent->d_name.name, dentry->d_name.name, 
  683. atomic_read(&dentry->d_count));
  684. if (atomic_read(&dentry->d_count) == 1)
  685. goto out;  /* No need to silly rename. */
  686. #ifdef NFS_PARANOIA
  687. if (!dentry->d_inode)
  688. printk("NFS: silly-renaming %s/%s, negative dentry??n",
  689. dentry->d_parent->d_name.name, dentry->d_name.name);
  690. #endif
  691. /*
  692.  * We don't allow a dentry to be silly-renamed twice.
  693.  */
  694. error = -EBUSY;
  695. if (dentry->d_flags & DCACHE_NFSFS_RENAMED)
  696. goto out;
  697. sprintf(silly, ".nfs%*.*lx",
  698. i_inosize, i_inosize, dentry->d_inode->i_ino);
  699. sdentry = NULL;
  700. do {
  701. char *suffix = silly + slen - countersize;
  702. dput(sdentry);
  703. sillycounter++;
  704. sprintf(suffix, "%*.*x", countersize, countersize, sillycounter);
  705. dfprintk(VFS, "trying to rename %s to %sn",
  706.  dentry->d_name.name, silly);
  707. sdentry = lookup_one_len(silly, dentry->d_parent, slen);
  708. /*
  709.  * N.B. Better to return EBUSY here ... it could be
  710.  * dangerous to delete the file while it's in use.
  711.  */
  712. if (IS_ERR(sdentry))
  713. goto out;
  714. } while(sdentry->d_inode != NULL); /* need negative lookup */
  715. nfs_zap_caches(dir);
  716. qsilly.name = silly;
  717. qsilly.len  = strlen(silly);
  718. error = NFS_PROTO(dir)->rename(dir, &dentry->d_name, dir, &qsilly);
  719. if (!error) {
  720. nfs_renew_times(dentry);
  721. d_move(dentry, sdentry);
  722. error = nfs_async_unlink(dentry);
  723.   /* If we return 0 we don't unlink */
  724. }
  725. dput(sdentry);
  726. out:
  727. return error;
  728. }
  729. /*
  730.  * Remove a file after making sure there are no pending writes,
  731.  * and after checking that the file has only one user. 
  732.  *
  733.  * We invalidate the attribute cache and free the inode prior to the operation
  734.  * to avoid possible races if the server reuses the inode.
  735.  */
  736. static int nfs_safe_remove(struct dentry *dentry)
  737. {
  738. struct inode *dir = dentry->d_parent->d_inode;
  739. struct inode *inode = dentry->d_inode;
  740. int error = -EBUSY, rehash = 0;
  741. dfprintk(VFS, "NFS: safe_remove(%s/%s)n",
  742. dentry->d_parent->d_name.name, dentry->d_name.name);
  743. /*
  744.  * Unhash the dentry while we remove the file ...
  745.  */
  746. if (!d_unhashed(dentry)) {
  747. d_drop(dentry);
  748. rehash = 1;
  749. }
  750. if (atomic_read(&dentry->d_count) > 1) {
  751. #ifdef NFS_PARANOIA
  752. printk("nfs_safe_remove: %s/%s busy, d_count=%dn",
  753. dentry->d_parent->d_name.name, dentry->d_name.name,
  754. atomic_read(&dentry->d_count));
  755. #endif
  756. goto out;
  757. }
  758. /* If the dentry was sillyrenamed, we simply call d_delete() */
  759. if (dentry->d_flags & DCACHE_NFSFS_RENAMED) {
  760. error = 0;
  761. goto out_delete;
  762. }
  763. nfs_zap_caches(dir);
  764. if (inode)
  765. NFS_CACHEINV(inode);
  766. error = NFS_PROTO(dir)->remove(dir, &dentry->d_name);
  767. if (error < 0)
  768. goto out;
  769. if (inode)
  770. inode->i_nlink--;
  771.  out_delete:
  772. /*
  773.  * Free the inode
  774.  */
  775. d_delete(dentry);
  776. out:
  777. if (rehash)
  778. d_rehash(dentry);
  779. return error;
  780. }
  781. /*  We do silly rename. In case sillyrename() returns -EBUSY, the inode
  782.  *  belongs to an active ".nfs..." file and we return -EBUSY.
  783.  *
  784.  *  If sillyrename() returns 0, we do nothing, otherwise we unlink.
  785.  */
  786. static int nfs_unlink(struct inode *dir, struct dentry *dentry)
  787. {
  788. int error;
  789. dfprintk(VFS, "NFS: unlink(%x/%ld, %s)n",
  790. dir->i_dev, dir->i_ino, dentry->d_name.name);
  791. error = nfs_sillyrename(dir, dentry);
  792. if (error && error != -EBUSY) {
  793. error = nfs_safe_remove(dentry);
  794. if (!error) {
  795. nfs_renew_times(dentry);
  796. }
  797. }
  798. return error;
  799. }
  800. static int
  801. nfs_symlink(struct inode *dir, struct dentry *dentry, const char *symname)
  802. {
  803. struct iattr attr;
  804. struct nfs_fattr sym_attr;
  805. struct nfs_fh sym_fh;
  806. struct qstr qsymname;
  807. unsigned int maxlen;
  808. int error;
  809. dfprintk(VFS, "NFS: symlink(%x/%ld, %s, %s)n",
  810. dir->i_dev, dir->i_ino, dentry->d_name.name, symname);
  811. error = -ENAMETOOLONG;
  812. maxlen = (NFS_PROTO(dir)->version==2) ? NFS2_MAXPATHLEN : NFS3_MAXPATHLEN;
  813. if (strlen(symname) > maxlen)
  814. goto out;
  815. #ifdef NFS_PARANOIA
  816. if (dentry->d_inode)
  817. printk("nfs_proc_symlink: %s/%s not negative!n",
  818. dentry->d_parent->d_name.name, dentry->d_name.name);
  819. #endif
  820. /*
  821.  * Fill in the sattr for the call.
  822.    * Note: SunOS 4.1.2 crashes if the mode isn't initialized!
  823.  */
  824. attr.ia_valid = ATTR_MODE;
  825. attr.ia_mode = S_IFLNK | S_IRWXUGO;
  826. qsymname.name = symname;
  827. qsymname.len  = strlen(symname);
  828. nfs_zap_caches(dir);
  829. error = NFS_PROTO(dir)->symlink(dir, &dentry->d_name, &qsymname,
  830.   &attr, &sym_fh, &sym_attr);
  831. if (!error) {
  832. error = nfs_instantiate(dentry, &sym_fh, &sym_attr);
  833. } else {
  834. if (error == -EEXIST)
  835. printk("nfs_proc_symlink: %s/%s already exists??n",
  836.        dentry->d_parent->d_name.name, dentry->d_name.name);
  837. d_drop(dentry);
  838. }
  839. out:
  840. return error;
  841. }
  842. static int 
  843. nfs_link(struct dentry *old_dentry, struct inode *dir, struct dentry *dentry)
  844. {
  845. struct inode *inode = old_dentry->d_inode;
  846. int error;
  847. dfprintk(VFS, "NFS: link(%s/%s -> %s/%s)n",
  848. old_dentry->d_parent->d_name.name, old_dentry->d_name.name,
  849. dentry->d_parent->d_name.name, dentry->d_name.name);
  850. /*
  851.  * Drop the dentry in advance to force a new lookup.
  852.  * Since nfs_proc_link doesn't return a file handle,
  853.  * we can't use the existing dentry.
  854.  */
  855. d_drop(dentry);
  856. nfs_zap_caches(dir);
  857. NFS_CACHEINV(inode);
  858. error = NFS_PROTO(dir)->link(inode, dir, &dentry->d_name);
  859. return error;
  860. }
  861. /*
  862.  * RENAME
  863.  * FIXME: Some nfsds, like the Linux user space nfsd, may generate a
  864.  * different file handle for the same inode after a rename (e.g. when
  865.  * moving to a different directory). A fail-safe method to do so would
  866.  * be to look up old_dir/old_name, create a link to new_dir/new_name and
  867.  * rename the old file using the sillyrename stuff. This way, the original
  868.  * file in old_dir will go away when the last process iput()s the inode.
  869.  *
  870.  * FIXED.
  871.  * 
  872.  * It actually works quite well. One needs to have the possibility for
  873.  * at least one ".nfs..." file in each directory the file ever gets
  874.  * moved or linked to which happens automagically with the new
  875.  * implementation that only depends on the dcache stuff instead of
  876.  * using the inode layer
  877.  *
  878.  * Unfortunately, things are a little more complicated than indicated
  879.  * above. For a cross-directory move, we want to make sure we can get
  880.  * rid of the old inode after the operation.  This means there must be
  881.  * no pending writes (if it's a file), and the use count must be 1.
  882.  * If these conditions are met, we can drop the dentries before doing
  883.  * the rename.
  884.  */
  885. static int nfs_rename(struct inode *old_dir, struct dentry *old_dentry,
  886.       struct inode *new_dir, struct dentry *new_dentry)
  887. {
  888. struct inode *old_inode = old_dentry->d_inode;
  889. struct inode *new_inode = new_dentry->d_inode;
  890. struct dentry *dentry = NULL, *rehash = NULL;
  891. int error = -EBUSY;
  892. /*
  893.  * To prevent any new references to the target during the rename,
  894.  * we unhash the dentry and free the inode in advance.
  895.  */
  896. if (!d_unhashed(new_dentry)) {
  897. d_drop(new_dentry);
  898. rehash = new_dentry;
  899. }
  900. dfprintk(VFS, "NFS: rename(%s/%s -> %s/%s, ct=%d)n",
  901.  old_dentry->d_parent->d_name.name, old_dentry->d_name.name,
  902.  new_dentry->d_parent->d_name.name, new_dentry->d_name.name,
  903.  atomic_read(&new_dentry->d_count));
  904. /*
  905.  * First check whether the target is busy ... we can't
  906.  * safely do _any_ rename if the target is in use.
  907.  *
  908.  * For files, make a copy of the dentry and then do a 
  909.  * silly-rename. If the silly-rename succeeds, the
  910.  * copied dentry is hashed and becomes the new target.
  911.  */
  912. if (!new_inode)
  913. goto go_ahead;
  914. if (S_ISDIR(new_inode->i_mode))
  915. goto out;
  916. else if (atomic_read(&new_dentry->d_count) > 1) {
  917. int err;
  918. /* copy the target dentry's name */
  919. dentry = d_alloc(new_dentry->d_parent,
  920.  &new_dentry->d_name);
  921. if (!dentry)
  922. goto out;
  923. /* silly-rename the existing target ... */
  924. err = nfs_sillyrename(new_dir, new_dentry);
  925. if (!err) {
  926. new_dentry = rehash = dentry;
  927. new_inode = NULL;
  928. /* instantiate the replacement target */
  929. d_instantiate(new_dentry, NULL);
  930. }
  931. /* dentry still busy? */
  932. if (atomic_read(&new_dentry->d_count) > 1) {
  933. #ifdef NFS_PARANOIA
  934. printk("nfs_rename: target %s/%s busy, d_count=%dn",
  935.        new_dentry->d_parent->d_name.name,
  936.        new_dentry->d_name.name,
  937.        atomic_read(&new_dentry->d_count));
  938. #endif
  939. goto out;
  940. }
  941. }
  942. go_ahead:
  943. /*
  944.  * ... prune child dentries and writebacks if needed.
  945.  */
  946. if (atomic_read(&old_dentry->d_count) > 1) {
  947. nfs_wb_all(old_inode);
  948. shrink_dcache_parent(old_dentry);
  949. }
  950. if (new_inode)
  951. d_delete(new_dentry);
  952. nfs_zap_caches(new_dir);
  953. nfs_zap_caches(old_dir);
  954. error = NFS_PROTO(old_dir)->rename(old_dir, &old_dentry->d_name,
  955.    new_dir, &new_dentry->d_name);
  956. out:
  957. if (rehash)
  958. d_rehash(rehash);
  959. if (!error && !S_ISDIR(old_inode->i_mode))
  960. d_move(old_dentry, new_dentry);
  961. /* new dentry created? */
  962. if (dentry)
  963. dput(dentry);
  964. return error;
  965. }
  966. int
  967. nfs_permission(struct inode *inode, int mask)
  968. {
  969. int error = vfs_permission(inode, mask);
  970. if (!NFS_PROTO(inode)->access)
  971. goto out;
  972. if (error == -EROFS)
  973. goto out;
  974. /*
  975.  * Trust UNIX mode bits except:
  976.  *
  977.  * 1) When override capabilities may have been invoked
  978.  * 2) When root squashing may be involved
  979.  * 3) When ACLs may overturn a negative answer */
  980. if (!capable(CAP_DAC_OVERRIDE) && !capable(CAP_DAC_READ_SEARCH)
  981.     && (current->fsuid != 0) && (current->fsgid != 0)
  982.     && error != -EACCES)
  983. goto out;
  984. error = NFS_PROTO(inode)->access(inode, mask, 0);
  985. if (error == -EACCES && NFS_CLIENT(inode)->cl_droppriv &&
  986.     current->uid != 0 && current->gid != 0 &&
  987.     (current->fsuid != current->uid || current->fsgid != current->gid))
  988. error = NFS_PROTO(inode)->access(inode, mask, 1);
  989.  out:
  990. return error;
  991. }
  992. /*
  993.  * Local variables:
  994.  *  version-control: t
  995.  *  kept-new-versions: 5
  996.  * End:
  997.  */