Commit 2fd6b7f5 authored by Nick Piggin's avatar Nick Piggin

fs: dcache scale subdirs

Protect d_subdirs and d_child with d_lock, except in filesystems that aren't
using dcache_lock for these anyway (eg. using i_mutex).

Note: if we change the locking rule in future so that ->d_child protection is
provided only with ->d_parent->d_lock, it may allow us to reduce some locking.
But it would be an exception to an otherwise regular locking scheme, so we'd
have to see some good results. Probably not worthwhile.
Signed-off-by: default avatarNick Piggin <npiggin@kernel.dk>
parent da502956
...@@ -63,6 +63,7 @@ smb_invalidate_dircache_entries(struct dentry *parent) ...@@ -63,6 +63,7 @@ smb_invalidate_dircache_entries(struct dentry *parent)
struct dentry *dentry; struct dentry *dentry;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&parent->d_lock);
next = parent->d_subdirs.next; next = parent->d_subdirs.next;
while (next != &parent->d_subdirs) { while (next != &parent->d_subdirs) {
dentry = list_entry(next, struct dentry, d_u.d_child); dentry = list_entry(next, struct dentry, d_u.d_child);
...@@ -70,6 +71,7 @@ smb_invalidate_dircache_entries(struct dentry *parent) ...@@ -70,6 +71,7 @@ smb_invalidate_dircache_entries(struct dentry *parent)
smb_age_dentry(server, dentry); smb_age_dentry(server, dentry);
next = next->next; next = next->next;
} }
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
} }
...@@ -97,6 +99,7 @@ smb_dget_fpos(struct dentry *dentry, struct dentry *parent, unsigned long fpos) ...@@ -97,6 +99,7 @@ smb_dget_fpos(struct dentry *dentry, struct dentry *parent, unsigned long fpos)
/* If a pointer is invalid, we search the dentry. */ /* If a pointer is invalid, we search the dentry. */
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&parent->d_lock);
next = parent->d_subdirs.next; next = parent->d_subdirs.next;
while (next != &parent->d_subdirs) { while (next != &parent->d_subdirs) {
dent = list_entry(next, struct dentry, d_u.d_child); dent = list_entry(next, struct dentry, d_u.d_child);
...@@ -111,6 +114,7 @@ smb_dget_fpos(struct dentry *dentry, struct dentry *parent, unsigned long fpos) ...@@ -111,6 +114,7 @@ smb_dget_fpos(struct dentry *dentry, struct dentry *parent, unsigned long fpos)
} }
dent = NULL; dent = NULL;
out_unlock: out_unlock:
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return dent; return dent;
} }
......
...@@ -344,18 +344,20 @@ static int usbfs_empty (struct dentry *dentry) ...@@ -344,18 +344,20 @@ static int usbfs_empty (struct dentry *dentry)
struct list_head *list; struct list_head *list;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dentry->d_lock);
list_for_each(list, &dentry->d_subdirs) { list_for_each(list, &dentry->d_subdirs) {
struct dentry *de = list_entry(list, struct dentry, d_u.d_child); struct dentry *de = list_entry(list, struct dentry, d_u.d_child);
spin_lock(&de->d_lock);
spin_lock_nested(&de->d_lock, DENTRY_D_LOCK_NESTED);
if (usbfs_positive(de)) { if (usbfs_positive(de)) {
spin_unlock(&de->d_lock); spin_unlock(&de->d_lock);
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return 0; return 0;
} }
spin_unlock(&de->d_lock); spin_unlock(&de->d_lock);
} }
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return 1; return 1;
} }
......
...@@ -254,6 +254,17 @@ static inline int simple_positive(struct dentry *dentry) ...@@ -254,6 +254,17 @@ static inline int simple_positive(struct dentry *dentry)
return dentry->d_inode && !d_unhashed(dentry); return dentry->d_inode && !d_unhashed(dentry);
} }
static inline void __autofs4_add_expiring(struct dentry *dentry)
{
struct autofs_sb_info *sbi = autofs4_sbi(dentry->d_sb);
struct autofs_info *ino = autofs4_dentry_ino(dentry);
if (ino) {
if (list_empty(&ino->expiring))
list_add(&ino->expiring, &sbi->expiring_list);
}
return;
}
static inline void autofs4_add_expiring(struct dentry *dentry) static inline void autofs4_add_expiring(struct dentry *dentry)
{ {
struct autofs_sb_info *sbi = autofs4_sbi(dentry->d_sb); struct autofs_sb_info *sbi = autofs4_sbi(dentry->d_sb);
......
...@@ -91,24 +91,64 @@ static int autofs4_mount_busy(struct vfsmount *mnt, struct dentry *dentry) ...@@ -91,24 +91,64 @@ static int autofs4_mount_busy(struct vfsmount *mnt, struct dentry *dentry)
} }
/* /*
* Calculate next entry in top down tree traversal. * Calculate and dget next entry in top down tree traversal.
* From next_mnt in namespace.c - elegant.
*/ */
static struct dentry *next_dentry(struct dentry *p, struct dentry *root) static struct dentry *get_next_positive_dentry(struct dentry *prev,
struct dentry *root)
{ {
struct list_head *next = p->d_subdirs.next; struct list_head *next;
struct dentry *p, *ret;
if (prev == NULL)
return dget(prev);
spin_lock(&dcache_lock);
relock:
p = prev;
spin_lock(&p->d_lock);
again:
next = p->d_subdirs.next;
if (next == &p->d_subdirs) { if (next == &p->d_subdirs) {
while (1) { while (1) {
if (p == root) struct dentry *parent;
if (p == root) {
spin_unlock(&p->d_lock);
spin_unlock(&dcache_lock);
dput(prev);
return NULL; return NULL;
}
parent = p->d_parent;
if (!spin_trylock(&parent->d_lock)) {
spin_unlock(&p->d_lock);
cpu_relax();
goto relock;
}
spin_unlock(&p->d_lock);
next = p->d_u.d_child.next; next = p->d_u.d_child.next;
if (next != &p->d_parent->d_subdirs) p = parent;
if (next != &parent->d_subdirs)
break; break;
p = p->d_parent;
} }
} }
return list_entry(next, struct dentry, d_u.d_child); ret = list_entry(next, struct dentry, d_u.d_child);
spin_lock_nested(&ret->d_lock, DENTRY_D_LOCK_NESTED);
/* Negative dentry - try next */
if (!simple_positive(ret)) {
spin_unlock(&ret->d_lock);
p = ret;
goto again;
}
dget_dlock(ret);
spin_unlock(&ret->d_lock);
spin_unlock(&p->d_lock);
spin_unlock(&dcache_lock);
dput(prev);
return ret;
} }
/* /*
...@@ -158,22 +198,11 @@ static int autofs4_tree_busy(struct vfsmount *mnt, ...@@ -158,22 +198,11 @@ static int autofs4_tree_busy(struct vfsmount *mnt,
if (!simple_positive(top)) if (!simple_positive(top))
return 1; return 1;
spin_lock(&dcache_lock); p = NULL;
for (p = top; p; p = next_dentry(p, top)) { while ((p = get_next_positive_dentry(p, top))) {
spin_lock(&p->d_lock);
/* Negative dentry - give up */
if (!simple_positive(p)) {
spin_unlock(&p->d_lock);
continue;
}
DPRINTK("dentry %p %.*s", DPRINTK("dentry %p %.*s",
p, (int) p->d_name.len, p->d_name.name); p, (int) p->d_name.len, p->d_name.name);
p = dget_dlock(p);
spin_unlock(&p->d_lock);
spin_unlock(&dcache_lock);
/* /*
* Is someone visiting anywhere in the subtree ? * Is someone visiting anywhere in the subtree ?
* If there's no mount we need to check the usage * If there's no mount we need to check the usage
...@@ -208,10 +237,7 @@ static int autofs4_tree_busy(struct vfsmount *mnt, ...@@ -208,10 +237,7 @@ static int autofs4_tree_busy(struct vfsmount *mnt,
return 1; return 1;
} }
} }
dput(p);
spin_lock(&dcache_lock);
} }
spin_unlock(&dcache_lock);
/* Timeout of a tree mount is ultimately determined by its top dentry */ /* Timeout of a tree mount is ultimately determined by its top dentry */
if (!autofs4_can_expire(top, timeout, do_now)) if (!autofs4_can_expire(top, timeout, do_now))
...@@ -230,36 +256,21 @@ static struct dentry *autofs4_check_leaves(struct vfsmount *mnt, ...@@ -230,36 +256,21 @@ static struct dentry *autofs4_check_leaves(struct vfsmount *mnt,
DPRINTK("parent %p %.*s", DPRINTK("parent %p %.*s",
parent, (int)parent->d_name.len, parent->d_name.name); parent, (int)parent->d_name.len, parent->d_name.name);
spin_lock(&dcache_lock); p = NULL;
for (p = parent; p; p = next_dentry(p, parent)) { while ((p = get_next_positive_dentry(p, parent))) {
spin_lock(&p->d_lock);
/* Negative dentry - give up */
if (!simple_positive(p)) {
spin_unlock(&p->d_lock);
continue;
}
DPRINTK("dentry %p %.*s", DPRINTK("dentry %p %.*s",
p, (int) p->d_name.len, p->d_name.name); p, (int) p->d_name.len, p->d_name.name);
p = dget_dlock(p);
spin_unlock(&p->d_lock);
spin_unlock(&dcache_lock);
if (d_mountpoint(p)) { if (d_mountpoint(p)) {
/* Can we umount this guy */ /* Can we umount this guy */
if (autofs4_mount_busy(mnt, p)) if (autofs4_mount_busy(mnt, p))
goto cont; continue;
/* Can we expire this guy */ /* Can we expire this guy */
if (autofs4_can_expire(p, timeout, do_now)) if (autofs4_can_expire(p, timeout, do_now))
return p; return p;
} }
cont:
dput(p);
spin_lock(&dcache_lock);
} }
spin_unlock(&dcache_lock);
return NULL; return NULL;
} }
...@@ -310,8 +321,8 @@ struct dentry *autofs4_expire_indirect(struct super_block *sb, ...@@ -310,8 +321,8 @@ struct dentry *autofs4_expire_indirect(struct super_block *sb,
{ {
unsigned long timeout; unsigned long timeout;
struct dentry *root = sb->s_root; struct dentry *root = sb->s_root;
struct dentry *dentry;
struct dentry *expired = NULL; struct dentry *expired = NULL;
struct list_head *next;
int do_now = how & AUTOFS_EXP_IMMEDIATE; int do_now = how & AUTOFS_EXP_IMMEDIATE;
int exp_leaves = how & AUTOFS_EXP_LEAVES; int exp_leaves = how & AUTOFS_EXP_LEAVES;
struct autofs_info *ino; struct autofs_info *ino;
...@@ -323,26 +334,8 @@ struct dentry *autofs4_expire_indirect(struct super_block *sb, ...@@ -323,26 +334,8 @@ struct dentry *autofs4_expire_indirect(struct super_block *sb,
now = jiffies; now = jiffies;
timeout = sbi->exp_timeout; timeout = sbi->exp_timeout;
spin_lock(&dcache_lock); dentry = NULL;
next = root->d_subdirs.next; while ((dentry = get_next_positive_dentry(dentry, root))) {
/* On exit from the loop expire is set to a dgot dentry
* to expire or it's NULL */
while ( next != &root->d_subdirs ) {
struct dentry *dentry = list_entry(next, struct dentry, d_u.d_child);
/* Negative dentry - give up */
spin_lock(&dentry->d_lock);
if (!simple_positive(dentry)) {
next = next->next;
spin_unlock(&dentry->d_lock);
continue;
}
dentry = dget_dlock(dentry);
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock);
spin_lock(&sbi->fs_lock); spin_lock(&sbi->fs_lock);
ino = autofs4_dentry_ino(dentry); ino = autofs4_dentry_ino(dentry);
...@@ -405,11 +398,7 @@ struct dentry *autofs4_expire_indirect(struct super_block *sb, ...@@ -405,11 +398,7 @@ struct dentry *autofs4_expire_indirect(struct super_block *sb,
} }
next: next:
spin_unlock(&sbi->fs_lock); spin_unlock(&sbi->fs_lock);
dput(dentry);
spin_lock(&dcache_lock);
next = next->next;
} }
spin_unlock(&dcache_lock);
return NULL; return NULL;
found: found:
...@@ -420,7 +409,11 @@ struct dentry *autofs4_expire_indirect(struct super_block *sb, ...@@ -420,7 +409,11 @@ struct dentry *autofs4_expire_indirect(struct super_block *sb,
init_completion(&ino->expire_complete); init_completion(&ino->expire_complete);
spin_unlock(&sbi->fs_lock); spin_unlock(&sbi->fs_lock);
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&expired->d_parent->d_lock);
spin_lock_nested(&expired->d_lock, DENTRY_D_LOCK_NESTED);
list_move(&expired->d_parent->d_subdirs, &expired->d_u.d_child); list_move(&expired->d_parent->d_subdirs, &expired->d_u.d_child);
spin_unlock(&expired->d_lock);
spin_unlock(&expired->d_parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return expired; return expired;
} }
......
...@@ -143,10 +143,13 @@ static int autofs4_dir_open(struct inode *inode, struct file *file) ...@@ -143,10 +143,13 @@ static int autofs4_dir_open(struct inode *inode, struct file *file)
* it. * it.
*/ */
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dentry->d_lock);
if (!d_mountpoint(dentry) && list_empty(&dentry->d_subdirs)) { if (!d_mountpoint(dentry) && list_empty(&dentry->d_subdirs)) {
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return -ENOENT; return -ENOENT;
} }
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
out: out:
...@@ -253,7 +256,9 @@ static void *autofs4_follow_link(struct dentry *dentry, struct nameidata *nd) ...@@ -253,7 +256,9 @@ static void *autofs4_follow_link(struct dentry *dentry, struct nameidata *nd)
lookup_type = autofs4_need_mount(nd->flags); lookup_type = autofs4_need_mount(nd->flags);
spin_lock(&sbi->fs_lock); spin_lock(&sbi->fs_lock);
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dentry->d_lock);
if (!(lookup_type || ino->flags & AUTOFS_INF_PENDING)) { if (!(lookup_type || ino->flags & AUTOFS_INF_PENDING)) {
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
spin_unlock(&sbi->fs_lock); spin_unlock(&sbi->fs_lock);
goto follow; goto follow;
...@@ -266,6 +271,7 @@ static void *autofs4_follow_link(struct dentry *dentry, struct nameidata *nd) ...@@ -266,6 +271,7 @@ static void *autofs4_follow_link(struct dentry *dentry, struct nameidata *nd)
*/ */
if (ino->flags & AUTOFS_INF_PENDING || if (ino->flags & AUTOFS_INF_PENDING ||
(!d_mountpoint(dentry) && list_empty(&dentry->d_subdirs))) { (!d_mountpoint(dentry) && list_empty(&dentry->d_subdirs))) {
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
spin_unlock(&sbi->fs_lock); spin_unlock(&sbi->fs_lock);
...@@ -275,6 +281,7 @@ static void *autofs4_follow_link(struct dentry *dentry, struct nameidata *nd) ...@@ -275,6 +281,7 @@ static void *autofs4_follow_link(struct dentry *dentry, struct nameidata *nd)
goto follow; goto follow;
} }
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
spin_unlock(&sbi->fs_lock); spin_unlock(&sbi->fs_lock);
follow: follow:
...@@ -347,10 +354,12 @@ static int autofs4_revalidate(struct dentry *dentry, struct nameidata *nd) ...@@ -347,10 +354,12 @@ static int autofs4_revalidate(struct dentry *dentry, struct nameidata *nd)
/* Check for a non-mountpoint directory with no contents */ /* Check for a non-mountpoint directory with no contents */
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dentry->d_lock);
if (S_ISDIR(dentry->d_inode->i_mode) && if (S_ISDIR(dentry->d_inode->i_mode) &&
!d_mountpoint(dentry) && list_empty(&dentry->d_subdirs)) { !d_mountpoint(dentry) && list_empty(&dentry->d_subdirs)) {
DPRINTK("dentry=%p %.*s, emptydir", DPRINTK("dentry=%p %.*s, emptydir",
dentry, dentry->d_name.len, dentry->d_name.name); dentry, dentry->d_name.len, dentry->d_name.name);
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
/* The daemon never causes a mount to trigger */ /* The daemon never causes a mount to trigger */
...@@ -367,6 +376,7 @@ static int autofs4_revalidate(struct dentry *dentry, struct nameidata *nd) ...@@ -367,6 +376,7 @@ static int autofs4_revalidate(struct dentry *dentry, struct nameidata *nd)
return status; return status;
} }
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return 1; return 1;
...@@ -776,12 +786,16 @@ static int autofs4_dir_rmdir(struct inode *dir, struct dentry *dentry) ...@@ -776,12 +786,16 @@ static int autofs4_dir_rmdir(struct inode *dir, struct dentry *dentry)
return -EACCES; return -EACCES;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&sbi->lookup_lock);
spin_lock(&dentry->d_lock);
if (!list_empty(&dentry->d_subdirs)) { if (!list_empty(&dentry->d_subdirs)) {
spin_unlock(&dentry->d_lock);
spin_unlock(&sbi->lookup_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return -ENOTEMPTY; return -ENOTEMPTY;
} }
autofs4_add_expiring(dentry); __autofs4_add_expiring(dentry);
spin_lock(&dentry->d_lock); spin_unlock(&sbi->lookup_lock);
__d_drop(dentry); __d_drop(dentry);
spin_unlock(&dentry->d_lock); spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
......
...@@ -113,6 +113,7 @@ static int __dcache_readdir(struct file *filp, ...@@ -113,6 +113,7 @@ static int __dcache_readdir(struct file *filp,
last); last);
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&parent->d_lock);
/* start at beginning? */ /* start at beginning? */
if (filp->f_pos == 2 || last == NULL || if (filp->f_pos == 2 || last == NULL ||
...@@ -136,7 +137,7 @@ static int __dcache_readdir(struct file *filp, ...@@ -136,7 +137,7 @@ static int __dcache_readdir(struct file *filp,
fi->at_end = 1; fi->at_end = 1;
goto out_unlock; goto out_unlock;
} }
spin_lock(&dentry->d_lock); spin_lock_nested(&dentry->d_lock, DENTRY_D_LOCK_NESTED);
if (!d_unhashed(dentry) && dentry->d_inode && if (!d_unhashed(dentry) && dentry->d_inode &&
ceph_snap(dentry->d_inode) != CEPH_SNAPDIR && ceph_snap(dentry->d_inode) != CEPH_SNAPDIR &&
ceph_ino(dentry->d_inode) != CEPH_INO_CEPH && ceph_ino(dentry->d_inode) != CEPH_INO_CEPH &&
...@@ -154,6 +155,7 @@ static int __dcache_readdir(struct file *filp, ...@@ -154,6 +155,7 @@ static int __dcache_readdir(struct file *filp,
dget_dlock(dentry); dget_dlock(dentry);
spin_unlock(&dentry->d_lock); spin_unlock(&dentry->d_lock);
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
dout(" %llu (%llu) dentry %p %.*s %p\n", di->offset, filp->f_pos, dout(" %llu (%llu) dentry %p %.*s %p\n", di->offset, filp->f_pos,
...@@ -188,10 +190,12 @@ static int __dcache_readdir(struct file *filp, ...@@ -188,10 +190,12 @@ static int __dcache_readdir(struct file *filp,
} }
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&parent->d_lock);
p = p->prev; /* advance to next dentry */ p = p->prev; /* advance to next dentry */
goto more; goto more;
out_unlock: out_unlock:
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
out: out:
if (last) if (last)
......
...@@ -842,11 +842,13 @@ static void ceph_set_dentry_offset(struct dentry *dn) ...@@ -842,11 +842,13 @@ static void ceph_set_dentry_offset(struct dentry *dn)
spin_unlock(&inode->i_lock); spin_unlock(&inode->i_lock);
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dn->d_lock); spin_lock(&dir->d_lock);
spin_lock_nested(&dn->d_lock, DENTRY_D_LOCK_NESTED);
list_move(&dn->d_u.d_child, &dir->d_subdirs); list_move(&dn->d_u.d_child, &dir->d_subdirs);
dout("set_dentry_offset %p %lld (%p %p)\n", dn, di->offset, dout("set_dentry_offset %p %lld (%p %p)\n", dn, di->offset,
dn->d_u.d_child.prev, dn->d_u.d_child.next); dn->d_u.d_child.prev, dn->d_u.d_child.next);
spin_unlock(&dn->d_lock); spin_unlock(&dn->d_lock);
spin_unlock(&dir->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
} }
...@@ -1232,9 +1234,11 @@ int ceph_readdir_prepopulate(struct ceph_mds_request *req, ...@@ -1232,9 +1234,11 @@ int ceph_readdir_prepopulate(struct ceph_mds_request *req,
} else { } else {
/* reorder parent's d_subdirs */ /* reorder parent's d_subdirs */
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dn->d_lock); spin_lock(&parent->d_lock);
spin_lock_nested(&dn->d_lock, DENTRY_D_LOCK_NESTED);
list_move(&dn->d_u.d_child, &parent->d_subdirs); list_move(&dn->d_u.d_child, &parent->d_subdirs);
spin_unlock(&dn->d_lock); spin_unlock(&dn->d_lock);
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
} }
......
...@@ -94,6 +94,7 @@ static void coda_flag_children(struct dentry *parent, int flag) ...@@ -94,6 +94,7 @@ static void coda_flag_children(struct dentry *parent, int flag)
struct dentry *de; struct dentry *de;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&parent->d_lock);
list_for_each(child, &parent->d_subdirs) list_for_each(child, &parent->d_subdirs)
{ {
de = list_entry(child, struct dentry, d_u.d_child); de = list_entry(child, struct dentry, d_u.d_child);
...@@ -102,6 +103,7 @@ static void coda_flag_children(struct dentry *parent, int flag) ...@@ -102,6 +103,7 @@ static void coda_flag_children(struct dentry *parent, int flag)
continue; continue;
coda_flag_inode(de->d_inode, flag); coda_flag_inode(de->d_inode, flag);
} }
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return; return;
} }
......
...@@ -47,6 +47,8 @@ ...@@ -47,6 +47,8 @@
* - d_lru * - d_lru
* - d_count * - d_count
* - d_unhashed() * - d_unhashed()
* - d_parent and d_subdirs
* - childrens' d_child and d_parent
* *
* Ordering: * Ordering:
* dcache_lock * dcache_lock
...@@ -223,24 +225,22 @@ static void dentry_lru_move_tail(struct dentry *dentry) ...@@ -223,24 +225,22 @@ static void dentry_lru_move_tail(struct dentry *dentry)
* *
* If this is the root of the dentry tree, return NULL. * If this is the root of the dentry tree, return NULL.
* *
* dcache_lock and d_lock must be held by caller, are dropped by d_kill. * dcache_lock and d_lock and d_parent->d_lock must be held by caller, and
* are dropped by d_kill.
*/ */
static struct dentry *d_kill(struct dentry *dentry) static struct dentry *d_kill(struct dentry *dentry, struct dentry *parent)
__releases(dentry->d_lock) __releases(dentry->d_lock)
__releases(parent->d_lock)
__releases(dcache_lock) __releases(dcache_lock)
{ {
struct dentry *parent;
list_del(&dentry->d_u.d_child); list_del(&dentry->d_u.d_child);
if (parent)
spin_unlock(&parent->d_lock);
dentry_iput(dentry); dentry_iput(dentry);
/* /*
* dentry_iput drops the locks, at which point nobody (except * dentry_iput drops the locks, at which point nobody (except
* transient RCU lookups) can reach this dentry. * transient RCU lookups) can reach this dentry.
*/ */
if (IS_ROOT(dentry))
parent = NULL;
else
parent = dentry->d_parent;
d_free(dentry); d_free(dentry);
return parent; return parent;
} }
...@@ -312,6 +312,7 @@ EXPORT_SYMBOL(d_drop); ...@@ -312,6 +312,7 @@ EXPORT_SYMBOL(d_drop);
void dput(struct dentry *dentry) void dput(struct dentry *dentry)
{ {
struct dentry *parent;
if (!dentry) if (!dentry)
return; return;
...@@ -319,6 +320,10 @@ void dput(struct dentry *dentry) ...@@ -319,6 +320,10 @@ void dput(struct dentry *dentry)
if (dentry->d_count == 1) if (dentry->d_count == 1)
might_sleep(); might_sleep();
spin_lock(&dentry->d_lock); spin_lock(&dentry->d_lock);
if (IS_ROOT(dentry))
parent = NULL;
else
parent = dentry->d_parent;
if (dentry->d_count == 1) { if (dentry->d_count == 1) {
if (!spin_trylock(&dcache_lock)) { if (!spin_trylock(&dcache_lock)) {
/* /*
...@@ -330,10 +335,17 @@ void dput(struct dentry *dentry) ...@@ -330,10 +335,17 @@ void dput(struct dentry *dentry)
spin_unlock(&dentry->d_lock); spin_unlock(&dentry->d_lock);
goto repeat; goto repeat;
} }
if (parent && !spin_trylock(&parent->d_lock)) {
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock);
goto repeat;
}
} }
dentry->d_count--; dentry->d_count--;
if (dentry->d_count) { if (dentry->d_count) {
spin_unlock(&dentry->d_lock); spin_unlock(&dentry->d_lock);
if (parent)
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return; return;
} }
...@@ -355,6 +367,8 @@ void dput(struct dentry *dentry) ...@@ -355,6 +367,8 @@ void dput(struct dentry *dentry)
dentry_lru_add(dentry); dentry_lru_add(dentry);
spin_unlock(&dentry->d_lock); spin_unlock(&dentry->d_lock);
if (parent)
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return; return;
...@@ -363,7 +377,7 @@ void dput(struct dentry *dentry) ...@@ -363,7 +377,7 @@ void dput(struct dentry *dentry)
kill_it: kill_it:
/* if dentry was on the d_lru list delete it from there */ /* if dentry was on the d_lru list delete it from there */
dentry_lru_del(dentry); dentry_lru_del(dentry);
dentry = d_kill(dentry); dentry = d_kill(dentry, parent);
if (dentry) if (dentry)
goto repeat; goto repeat;
} }
...@@ -584,12 +598,13 @@ EXPORT_SYMBOL(d_prune_aliases); ...@@ -584,12 +598,13 @@ EXPORT_SYMBOL(d_prune_aliases);
* quadratic behavior of shrink_dcache_parent(), but is also expected * quadratic behavior of shrink_dcache_parent(), but is also expected
* to be beneficial in reducing dentry cache fragmentation. * to be beneficial in reducing dentry cache fragmentation.
*/ */
static void prune_one_dentry(struct dentry * dentry) static void prune_one_dentry(struct dentry *dentry, struct dentry *parent)
__releases(dentry->d_lock) __releases(dentry->d_lock)
__releases(parent->d_lock)
__releases(dcache_lock) __releases(dcache_lock)
{ {
__d_drop(dentry); __d_drop(dentry);
dentry = d_kill(dentry); dentry = d_kill(dentry, parent);
/* /*
* Prune ancestors. Locking is simpler than in dput(), * Prune ancestors. Locking is simpler than in dput(),
...@@ -597,9 +612,20 @@ static void prune_one_dentry(struct dentry * dentry) ...@@ -597,9 +612,20 @@ static void prune_one_dentry(struct dentry * dentry)
*/ */
while (dentry) { while (dentry) {
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
again:
spin_lock(&dentry->d_lock); spin_lock(&dentry->d_lock);
if (IS_ROOT(dentry))
parent = NULL;
else
parent = dentry->d_parent;
if (parent && !spin_trylock(&parent->d_lock)) {
spin_unlock(&dentry->d_lock);
goto again;
}
dentry->d_count--; dentry->d_count--;
if (dentry->d_count) { if (dentry->d_count) {
if (parent)
spin_unlock(&parent->d_lock);
spin_unlock(&dentry->d_lock); spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return; return;
...@@ -607,7 +633,7 @@ static void prune_one_dentry(struct dentry * dentry) ...@@ -607,7 +633,7 @@ static void prune_one_dentry(struct dentry * dentry)
dentry_lru_del(dentry); dentry_lru_del(dentry);
__d_drop(dentry); __d_drop(dentry);
dentry = d_kill(dentry); dentry = d_kill(dentry, parent);
} }
} }
...@@ -616,29 +642,40 @@ static void shrink_dentry_list(struct list_head *list) ...@@ -616,29 +642,40 @@ static void shrink_dentry_list(struct list_head *list)
struct dentry *dentry; struct dentry *dentry;
while (!list_empty(list)) { while (!list_empty(list)) {
struct dentry *parent;
dentry = list_entry(list->prev, struct dentry, d_lru); dentry = list_entry(list->prev, struct dentry, d_lru);
if (!spin_trylock(&dentry->d_lock)) { if (!spin_trylock(&dentry->d_lock)) {
relock:
spin_unlock(&dcache_lru_lock); spin_unlock(&dcache_lru_lock);
cpu_relax(); cpu_relax();
spin_lock(&dcache_lru_lock); spin_lock(&dcache_lru_lock);
continue; continue;
} }
__dentry_lru_del(dentry);
/* /*
* We found an inuse dentry which was not removed from * We found an inuse dentry which was not removed from
* the LRU because of laziness during lookup. Do not free * the LRU because of laziness during lookup. Do not free
* it - just keep it off the LRU list. * it - just keep it off the LRU list.
*/ */
if (dentry->d_count) { if (dentry->d_count) {
__dentry_lru_del(dentry);
spin_unlock(&dentry->d_lock); spin_unlock(&dentry->d_lock);
continue; continue;
} }
if (IS_ROOT(dentry))
parent = NULL;
else
parent = dentry->d_parent;
if (parent && !spin_trylock(&parent->d_lock)) {
spin_unlock(&dentry->d_lock);
goto relock;
}
__dentry_lru_del(dentry);
spin_unlock(&dcache_lru_lock); spin_unlock(&dcache_lru_lock);
prune_one_dentry(dentry); prune_one_dentry(dentry, parent);
/* dcache_lock and dentry->d_lock dropped */ /* dcache_lock and dentry->d_lock dropped */
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dcache_lru_lock); spin_lock(&dcache_lru_lock);
...@@ -833,14 +870,16 @@ static void shrink_dcache_for_umount_subtree(struct dentry *dentry) ...@@ -833,14 +870,16 @@ static void shrink_dcache_for_umount_subtree(struct dentry *dentry)
/* this is a branch with children - detach all of them /* this is a branch with children - detach all of them
* from the system in one go */ * from the system in one go */
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dentry->d_lock);
list_for_each_entry(loop, &dentry->d_subdirs, list_for_each_entry(loop, &dentry->d_subdirs,
d_u.d_child) { d_u.d_child) {
spin_lock(&loop->d_lock); spin_lock_nested(&loop->d_lock,
DENTRY_D_LOCK_NESTED);
dentry_lru_del(loop); dentry_lru_del(loop);
__d_drop(loop); __d_drop(loop);
spin_unlock(&loop->d_lock); spin_unlock(&loop->d_lock);
cond_resched_lock(&dcache_lock);
} }
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
/* move to the first child */ /* move to the first child */
...@@ -868,16 +907,17 @@ static void shrink_dcache_for_umount_subtree(struct dentry *dentry) ...@@ -868,16 +907,17 @@ static void shrink_dcache_for_umount_subtree(struct dentry *dentry)
BUG(); BUG();
} }
if (IS_ROOT(dentry)) if (IS_ROOT(dentry)) {
parent = NULL; parent = NULL;
else { list_del(&dentry->d_u.d_child);
} else {
parent = dentry->d_parent; parent = dentry->d_parent;
spin_lock(&parent->d_lock); spin_lock(&parent->d_lock);
parent->d_count--; parent->d_count--;
list_del(&dentry->d_u.d_child);
spin_unlock(&parent->d_lock); spin_unlock(&parent->d_lock);
} }
list_del(&dentry->d_u.d_child);
detached++; detached++;
inode = dentry->d_inode; inode = dentry->d_inode;
...@@ -958,6 +998,7 @@ int have_submounts(struct dentry *parent) ...@@ -958,6 +998,7 @@ int have_submounts(struct dentry *parent)
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
if (d_mountpoint(parent)) if (d_mountpoint(parent))
goto positive; goto positive;
spin_lock(&this_parent->d_lock);
repeat: repeat:
next = this_parent->d_subdirs.next; next = this_parent->d_subdirs.next;
resume: resume:
...@@ -965,22 +1006,34 @@ int have_submounts(struct dentry *parent) ...@@ -965,22 +1006,34 @@ int have_submounts(struct dentry *parent)
struct list_head *tmp = next; struct list_head *tmp = next;
struct dentry *dentry = list_entry(tmp, struct dentry, d_u.d_child); struct dentry *dentry = list_entry(tmp, struct dentry, d_u.d_child);
next = tmp->next; next = tmp->next;
spin_lock_nested(&dentry->d_lock, DENTRY_D_LOCK_NESTED);
/* Have we found a mount point ? */ /* Have we found a mount point ? */
if (d_mountpoint(dentry)) if (d_mountpoint(dentry)) {
spin_unlock(&dentry->d_lock);
spin_unlock(&this_parent->d_lock);
goto positive; goto positive;
}
if (!list_empty(&dentry->d_subdirs)) { if (!list_empty(&dentry->d_subdirs)) {
spin_unlock(&this_parent->d_lock);
spin_release(&dentry->d_lock.dep_map, 1, _RET_IP_);
this_parent = dentry; this_parent = dentry;
spin_acquire(&this_parent->d_lock.dep_map, 0, 1, _RET_IP_);
goto repeat; goto repeat;
} }
spin_unlock(&dentry->d_lock);
} }
/* /*
* All done at this level ... ascend and resume the search. * All done at this level ... ascend and resume the search.
*/ */
if (this_parent != parent) { if (this_parent != parent) {
next = this_parent->d_u.d_child.next; next = this_parent->d_u.d_child.next;
spin_unlock(&this_parent->d_lock);
this_parent = this_parent->d_parent; this_parent = this_parent->d_parent;
spin_lock(&this_parent->d_lock);
goto resume; goto resume;
} }
spin_unlock(&this_parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return 0; /* No mount points found in tree */ return 0; /* No mount points found in tree */
positive: positive:
...@@ -1010,6 +1063,7 @@ static int select_parent(struct dentry * parent) ...@@ -1010,6 +1063,7 @@ static int select_parent(struct dentry * parent)
int found = 0; int found = 0;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&this_parent->d_lock);
repeat: repeat:
next = this_parent->d_subdirs.next; next = this_parent->d_subdirs.next;
resume: resume:
...@@ -1017,8 +1071,9 @@ static int select_parent(struct dentry * parent) ...@@ -1017,8 +1071,9 @@ static int select_parent(struct dentry * parent)
struct list_head *tmp = next; struct list_head *tmp = next;
struct dentry *dentry = list_entry(tmp, struct dentry, d_u.d_child); struct dentry *dentry = list_entry(tmp, struct dentry, d_u.d_child);
next = tmp->next; next = tmp->next;
BUG_ON(this_parent == dentry);
spin_lock(&dentry->d_lock); spin_lock_nested(&dentry->d_lock, DENTRY_D_LOCK_NESTED);
/* /*
* move only zero ref count dentries to the end * move only zero ref count dentries to the end
...@@ -1031,33 +1086,44 @@ static int select_parent(struct dentry * parent) ...@@ -1031,33 +1086,44 @@ static int select_parent(struct dentry * parent)
dentry_lru_del(dentry); dentry_lru_del(dentry);
} }
spin_unlock(&dentry->d_lock);
/* /*
* We can return to the caller if we have found some (this * We can return to the caller if we have found some (this
* ensures forward progress). We'll be coming back to find * ensures forward progress). We'll be coming back to find
* the rest. * the rest.
*/ */
if (found && need_resched()) if (found && need_resched()) {
spin_unlock(&dentry->d_lock);
goto out; goto out;
}
/* /*
* Descend a level if the d_subdirs list is non-empty. * Descend a level if the d_subdirs list is non-empty.
*/ */
if (!list_empty(&dentry->d_subdirs)) { if (!list_empty(&dentry->d_subdirs)) {
spin_unlock(&this_parent->d_lock);
spin_release(&dentry->d_lock.dep_map, 1, _RET_IP_);
this_parent = dentry; this_parent = dentry;
spin_acquire(&this_parent->d_lock.dep_map, 0, 1, _RET_IP_);
goto repeat; goto repeat;
} }
spin_unlock(&dentry->d_lock);
} }
/* /*
* All done at this level ... ascend and resume the search. * All done at this level ... ascend and resume the search.
*/ */
if (this_parent != parent) { if (this_parent != parent) {
struct dentry *tmp;
next = this_parent->d_u.d_child.next; next = this_parent->d_u.d_child.next;
this_parent = this_parent->d_parent; tmp = this_parent->d_parent;
spin_unlock(&this_parent->d_lock);
BUG_ON(tmp == this_parent);
this_parent = tmp;
spin_lock(&this_parent->d_lock);
goto resume; goto resume;
} }
out: out:
spin_unlock(&this_parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return found; return found;
} }
...@@ -1155,18 +1221,19 @@ struct dentry *d_alloc(struct dentry * parent, const struct qstr *name) ...@@ -1155,18 +1221,19 @@ struct dentry *d_alloc(struct dentry * parent, const struct qstr *name)
INIT_LIST_HEAD(&dentry->d_lru); INIT_LIST_HEAD(&dentry->d_lru);
INIT_LIST_HEAD(&dentry->d_subdirs); INIT_LIST_HEAD(&dentry->d_subdirs);
INIT_LIST_HEAD(&dentry->d_alias); INIT_LIST_HEAD(&dentry->d_alias);
INIT_LIST_HEAD(&dentry->d_u.d_child);
if (parent) { if (parent) {
dentry->d_parent = dget(parent); spin_lock(&dcache_lock);
spin_lock(&parent->d_lock);
spin_lock_nested(&dentry->d_lock, DENTRY_D_LOCK_NESTED);
dentry->d_parent = dget_dlock(parent);
dentry->d_sb = parent->d_sb; dentry->d_sb = parent->d_sb;
} else {
INIT_LIST_HEAD(&dentry->d_u.d_child);
}
spin_lock(&dcache_lock);
if (parent)
list_add(&dentry->d_u.d_child, &parent->d_subdirs); list_add(&dentry->d_u.d_child, &parent->d_subdirs);
spin_unlock(&dcache_lock); spin_unlock(&dentry->d_lock);
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock);
}
this_cpu_inc(nr_dentry); this_cpu_inc(nr_dentry);
...@@ -1684,13 +1751,18 @@ int d_validate(struct dentry *dentry, struct dentry *dparent) ...@@ -1684,13 +1751,18 @@ int d_validate(struct dentry *dentry, struct dentry *dparent)
struct dentry *child; struct dentry *child;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dparent->d_lock);
list_for_each_entry(child, &dparent->d_subdirs, d_u.d_child) { list_for_each_entry(child, &dparent->d_subdirs, d_u.d_child) {
if (dentry == child) { if (dentry == child) {
__dget_locked(dentry); spin_lock_nested(&dentry->d_lock, DENTRY_D_LOCK_NESTED);
__dget_locked_dlock(dentry);
spin_unlock(&dentry->d_lock);
spin_unlock(&dparent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return 1; return 1;
} }
} }
spin_unlock(&dparent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return 0; return 0;
...@@ -1802,17 +1874,6 @@ void dentry_update_name_case(struct dentry *dentry, struct qstr *name) ...@@ -1802,17 +1874,6 @@ void dentry_update_name_case(struct dentry *dentry, struct qstr *name)
} }
EXPORT_SYMBOL(dentry_update_name_case); EXPORT_SYMBOL(dentry_update_name_case);
/*
* When switching names, the actual string doesn't strictly have to
* be preserved in the target - because we're dropping the target
* anyway. As such, we can just do a simple memcpy() to copy over
* the new name before we switch.
*
* Note that we have to be a lot more careful about getting the hash
* switched - we have to switch the hash value properly even if it
* then no longer matches the actual (corrupted) string of the target.
* The hash value has to match the hash queue that the dentry is on..
*/
static void switch_names(struct dentry *dentry, struct dentry *target) static void switch_names(struct dentry *dentry, struct dentry *target)
{ {
if (dname_external(target)) { if (dname_external(target)) {
...@@ -1854,18 +1915,53 @@ static void switch_names(struct dentry *dentry, struct dentry *target) ...@@ -1854,18 +1915,53 @@ static void switch_names(struct dentry *dentry, struct dentry *target)
swap(dentry->d_name.len, target->d_name.len); swap(dentry->d_name.len, target->d_name.len);
} }
static void dentry_lock_for_move(struct dentry *dentry, struct dentry *target)
{
/*
* XXXX: do we really need to take target->d_lock?
*/
if (IS_ROOT(dentry) || dentry->d_parent == target->d_parent)
spin_lock(&target->d_parent->d_lock);
else {
if (d_ancestor(dentry->d_parent, target->d_parent)) {
spin_lock(&dentry->d_parent->d_lock);
spin_lock_nested(&target->d_parent->d_lock,
DENTRY_D_LOCK_NESTED);
} else {
spin_lock(&target->d_parent->d_lock);
spin_lock_nested(&dentry->d_parent->d_lock,
DENTRY_D_LOCK_NESTED);
}
}
if (target < dentry) {
spin_lock_nested(&target->d_lock, 2);
spin_lock_nested(&dentry->d_lock, 3);
} else {
spin_lock_nested(&dentry->d_lock, 2);
spin_lock_nested(&target->d_lock, 3);
}
}
static void dentry_unlock_parents_for_move(struct dentry *dentry,
struct dentry *target)
{
if (target->d_parent != dentry->d_parent)
spin_unlock(&dentry->d_parent->d_lock);
if (target->d_parent != target)
spin_unlock(&target->d_parent->d_lock);
}
/* /*
* We cannibalize "target" when moving dentry on top of it, * When switching names, the actual string doesn't strictly have to
* because it's going to be thrown away anyway. We could be more * be preserved in the target - because we're dropping the target
* polite about it, though. * anyway. As such, we can just do a simple memcpy() to copy over
* * the new name before we switch.
* This forceful removal will result in ugly /proc output if *
* somebody holds a file open that got deleted due to a rename. * Note that we have to be a lot more careful about getting the hash
* We could be nicer about the deleted file, and let it show * switched - we have to switch the hash value properly even if it
* up under the name it had before it was deleted rather than * then no longer matches the actual (corrupted) string of the target.
* under the original name of the file that was moved on top of it. * The hash value has to match the hash queue that the dentry is on..
*/ */
/* /*
* d_move_locked - move a dentry * d_move_locked - move a dentry
* @dentry: entry to move * @dentry: entry to move
...@@ -1879,20 +1975,12 @@ static void d_move_locked(struct dentry * dentry, struct dentry * target) ...@@ -1879,20 +1975,12 @@ static void d_move_locked(struct dentry * dentry, struct dentry * target)
if (!dentry->d_inode) if (!dentry->d_inode)
printk(KERN_WARNING "VFS: moving negative dcache entry\n"); printk(KERN_WARNING "VFS: moving negative dcache entry\n");
BUG_ON(d_ancestor(dentry, target));
BUG_ON(d_ancestor(target, dentry));
write_seqlock(&rename_lock); write_seqlock(&rename_lock);
/*
* XXXX: do we really need to take target->d_lock? dentry_lock_for_move(dentry, target);
*/
if (d_ancestor(dentry, target)) {
spin_lock(&dentry->d_lock);
spin_lock_nested(&target->d_lock, DENTRY_D_LOCK_NESTED);
} else if (d_ancestor(target, dentry) || target < dentry) {
spin_lock(&target->d_lock);
spin_lock_nested(&dentry->d_lock, DENTRY_D_LOCK_NESTED);
} else {
spin_lock(&dentry->d_lock);
spin_lock_nested(&target->d_lock, DENTRY_D_LOCK_NESTED);
}
/* Move the dentry to the target hash queue, if on different bucket */ /* Move the dentry to the target hash queue, if on different bucket */
spin_lock(&dcache_hash_lock); spin_lock(&dcache_hash_lock);
...@@ -1924,6 +2012,8 @@ static void d_move_locked(struct dentry * dentry, struct dentry * target) ...@@ -1924,6 +2012,8 @@ static void d_move_locked(struct dentry * dentry, struct dentry * target)
} }
list_add(&dentry->d_u.d_child, &dentry->d_parent->d_subdirs); list_add(&dentry->d_u.d_child, &dentry->d_parent->d_subdirs);
dentry_unlock_parents_for_move(dentry, target);
spin_unlock(&target->d_lock); spin_unlock(&target->d_lock);
fsnotify_d_move(dentry); fsnotify_d_move(dentry);
spin_unlock(&dentry->d_lock); spin_unlock(&dentry->d_lock);
...@@ -2013,17 +2103,20 @@ static struct dentry *__d_unalias(struct dentry *dentry, struct dentry *alias) ...@@ -2013,17 +2103,20 @@ static struct dentry *__d_unalias(struct dentry *dentry, struct dentry *alias)
/* /*
* Prepare an anonymous dentry for life in the superblock's dentry tree as a * Prepare an anonymous dentry for life in the superblock's dentry tree as a
* named dentry in place of the dentry to be replaced. * named dentry in place of the dentry to be replaced.
* returns with anon->d_lock held!
*/ */
static void __d_materialise_dentry(struct dentry *dentry, struct dentry *anon) static void __d_materialise_dentry(struct dentry *dentry, struct dentry *anon)
{ {
struct dentry *dparent, *aparent; struct dentry *dparent, *aparent;
switch_names(dentry, anon); dentry_lock_for_move(anon, dentry);
swap(dentry->d_name.hash, anon->d_name.hash);
dparent = dentry->d_parent; dparent = dentry->d_parent;
aparent = anon->d_parent; aparent = anon->d_parent;
switch_names(dentry, anon);
swap(dentry->d_name.hash, anon->d_name.hash);
dentry->d_parent = (aparent == anon) ? dentry : aparent; dentry->d_parent = (aparent == anon) ? dentry : aparent;
list_del(&dentry->d_u.d_child); list_del(&dentry->d_u.d_child);
if (!IS_ROOT(dentry)) if (!IS_ROOT(dentry))
...@@ -2038,6 +2131,10 @@ static void __d_materialise_dentry(struct dentry *dentry, struct dentry *anon) ...@@ -2038,6 +2131,10 @@ static void __d_materialise_dentry(struct dentry *dentry, struct dentry *anon)
else else
INIT_LIST_HEAD(&anon->d_u.d_child); INIT_LIST_HEAD(&anon->d_u.d_child);
dentry_unlock_parents_for_move(anon, dentry);
spin_unlock(&dentry->d_lock);
/* anon->d_lock still locked, returns locked */
anon->d_flags &= ~DCACHE_DISCONNECTED; anon->d_flags &= ~DCACHE_DISCONNECTED;
} }
...@@ -2073,7 +2170,6 @@ struct dentry *d_materialise_unique(struct dentry *dentry, struct inode *inode) ...@@ -2073,7 +2170,6 @@ struct dentry *d_materialise_unique(struct dentry *dentry, struct inode *inode)
/* Is this an anonymous mountpoint that we could splice /* Is this an anonymous mountpoint that we could splice
* into our tree? */ * into our tree? */
if (IS_ROOT(alias)) { if (IS_ROOT(alias)) {
spin_lock(&alias->d_lock);
__d_materialise_dentry(dentry, alias); __d_materialise_dentry(dentry, alias);
__d_drop(alias); __d_drop(alias);
goto found; goto found;
...@@ -2558,6 +2654,7 @@ void d_genocide(struct dentry *root) ...@@ -2558,6 +2654,7 @@ void d_genocide(struct dentry *root)
struct list_head *next; struct list_head *next;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&this_parent->d_lock);
repeat: repeat:
next = this_parent->d_subdirs.next; next = this_parent->d_subdirs.next;
resume: resume:
...@@ -2571,8 +2668,10 @@ void d_genocide(struct dentry *root) ...@@ -2571,8 +2668,10 @@ void d_genocide(struct dentry *root)
continue; continue;
} }
if (!list_empty(&dentry->d_subdirs)) { if (!list_empty(&dentry->d_subdirs)) {
spin_unlock(&dentry->d_lock); spin_unlock(&this_parent->d_lock);
spin_release(&dentry->d_lock.dep_map, 1, _RET_IP_);
this_parent = dentry; this_parent = dentry;
spin_acquire(&this_parent->d_lock.dep_map, 0, 1, _RET_IP_);
goto repeat; goto repeat;
} }
dentry->d_count--; dentry->d_count--;
...@@ -2580,12 +2679,13 @@ void d_genocide(struct dentry *root) ...@@ -2580,12 +2679,13 @@ void d_genocide(struct dentry *root)
} }
if (this_parent != root) { if (this_parent != root) {
next = this_parent->d_u.d_child.next; next = this_parent->d_u.d_child.next;
spin_lock(&this_parent->d_lock);
this_parent->d_count--; this_parent->d_count--;
spin_unlock(&this_parent->d_lock); spin_unlock(&this_parent->d_lock);
this_parent = this_parent->d_parent; this_parent = this_parent->d_parent;
spin_lock(&this_parent->d_lock);
goto resume; goto resume;
} }
spin_unlock(&this_parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
} }
......
...@@ -81,7 +81,8 @@ int dcache_dir_close(struct inode *inode, struct file *file) ...@@ -81,7 +81,8 @@ int dcache_dir_close(struct inode *inode, struct file *file)
loff_t dcache_dir_lseek(struct file *file, loff_t offset, int origin) loff_t dcache_dir_lseek(struct file *file, loff_t offset, int origin)
{ {
mutex_lock(&file->f_path.dentry->d_inode->i_mutex); struct dentry *dentry = file->f_path.dentry;
mutex_lock(&dentry->d_inode->i_mutex);
switch (origin) { switch (origin) {
case 1: case 1:
offset += file->f_pos; offset += file->f_pos;
...@@ -89,7 +90,7 @@ loff_t dcache_dir_lseek(struct file *file, loff_t offset, int origin) ...@@ -89,7 +90,7 @@ loff_t dcache_dir_lseek(struct file *file, loff_t offset, int origin)
if (offset >= 0) if (offset >= 0)
break; break;
default: default:
mutex_unlock(&file->f_path.dentry->d_inode->i_mutex); mutex_unlock(&dentry->d_inode->i_mutex);
return -EINVAL; return -EINVAL;
} }
if (offset != file->f_pos) { if (offset != file->f_pos) {
...@@ -100,22 +101,25 @@ loff_t dcache_dir_lseek(struct file *file, loff_t offset, int origin) ...@@ -100,22 +101,25 @@ loff_t dcache_dir_lseek(struct file *file, loff_t offset, int origin)
loff_t n = file->f_pos - 2; loff_t n = file->f_pos - 2;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dentry->d_lock);
/* d_lock not required for cursor */
list_del(&cursor->d_u.d_child); list_del(&cursor->d_u.d_child);
p = file->f_path.dentry->d_subdirs.next; p = dentry->d_subdirs.next;
while (n && p != &file->f_path.dentry->d_subdirs) { while (n && p != &dentry->d_subdirs) {
struct dentry *next; struct dentry *next;
next = list_entry(p, struct dentry, d_u.d_child); next = list_entry(p, struct dentry, d_u.d_child);
spin_lock(&next->d_lock); spin_lock_nested(&next->d_lock, DENTRY_D_LOCK_NESTED);
if (simple_positive(next)) if (simple_positive(next))
n--; n--;
spin_unlock(&next->d_lock); spin_unlock(&next->d_lock);
p = p->next; p = p->next;
} }
list_add_tail(&cursor->d_u.d_child, p); list_add_tail(&cursor->d_u.d_child, p);
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
} }
} }
mutex_unlock(&file->f_path.dentry->d_inode->i_mutex); mutex_unlock(&dentry->d_inode->i_mutex);
return offset; return offset;
} }
...@@ -156,6 +160,7 @@ int dcache_readdir(struct file * filp, void * dirent, filldir_t filldir) ...@@ -156,6 +160,7 @@ int dcache_readdir(struct file * filp, void * dirent, filldir_t filldir)
/* fallthrough */ /* fallthrough */
default: default:
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dentry->d_lock);
if (filp->f_pos == 2) if (filp->f_pos == 2)
list_move(q, &dentry->d_subdirs); list_move(q, &dentry->d_subdirs);
...@@ -169,6 +174,7 @@ int dcache_readdir(struct file * filp, void * dirent, filldir_t filldir) ...@@ -169,6 +174,7 @@ int dcache_readdir(struct file * filp, void * dirent, filldir_t filldir)
} }
spin_unlock(&next->d_lock); spin_unlock(&next->d_lock);
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
if (filldir(dirent, next->d_name.name, if (filldir(dirent, next->d_name.name,
next->d_name.len, filp->f_pos, next->d_name.len, filp->f_pos,
...@@ -176,11 +182,15 @@ int dcache_readdir(struct file * filp, void * dirent, filldir_t filldir) ...@@ -176,11 +182,15 @@ int dcache_readdir(struct file * filp, void * dirent, filldir_t filldir)
dt_type(next->d_inode)) < 0) dt_type(next->d_inode)) < 0)
return 0; return 0;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dentry->d_lock);
spin_lock_nested(&next->d_lock, DENTRY_D_LOCK_NESTED);
/* next is still alive */ /* next is still alive */
list_move(q, p); list_move(q, p);
spin_unlock(&next->d_lock);
p = q; p = q;
filp->f_pos++; filp->f_pos++;
} }
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
} }
return 0; return 0;
...@@ -276,6 +286,7 @@ int simple_empty(struct dentry *dentry) ...@@ -276,6 +286,7 @@ int simple_empty(struct dentry *dentry)
int ret = 0; int ret = 0;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dentry->d_lock);
list_for_each_entry(child, &dentry->d_subdirs, d_u.d_child) { list_for_each_entry(child, &dentry->d_subdirs, d_u.d_child) {
spin_lock_nested(&child->d_lock, DENTRY_D_LOCK_NESTED); spin_lock_nested(&child->d_lock, DENTRY_D_LOCK_NESTED);
if (simple_positive(child)) { if (simple_positive(child)) {
...@@ -286,6 +297,7 @@ int simple_empty(struct dentry *dentry) ...@@ -286,6 +297,7 @@ int simple_empty(struct dentry *dentry)
} }
ret = 1; ret = 1;
out: out:
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return ret; return ret;
} }
......
...@@ -392,6 +392,7 @@ ncp_dget_fpos(struct dentry *dentry, struct dentry *parent, unsigned long fpos) ...@@ -392,6 +392,7 @@ ncp_dget_fpos(struct dentry *dentry, struct dentry *parent, unsigned long fpos)
/* If a pointer is invalid, we search the dentry. */ /* If a pointer is invalid, we search the dentry. */
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&parent->d_lock);
next = parent->d_subdirs.next; next = parent->d_subdirs.next;
while (next != &parent->d_subdirs) { while (next != &parent->d_subdirs) {
dent = list_entry(next, struct dentry, d_u.d_child); dent = list_entry(next, struct dentry, d_u.d_child);
...@@ -400,11 +401,13 @@ ncp_dget_fpos(struct dentry *dentry, struct dentry *parent, unsigned long fpos) ...@@ -400,11 +401,13 @@ ncp_dget_fpos(struct dentry *dentry, struct dentry *parent, unsigned long fpos)
dget_locked(dent); dget_locked(dent);
else else
dent = NULL; dent = NULL;
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
goto out; goto out;
} }
next = next->next; next = next->next;
} }
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
return NULL; return NULL;
......
...@@ -194,6 +194,7 @@ ncp_renew_dentries(struct dentry *parent) ...@@ -194,6 +194,7 @@ ncp_renew_dentries(struct dentry *parent)
struct dentry *dentry; struct dentry *dentry;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&parent->d_lock);
next = parent->d_subdirs.next; next = parent->d_subdirs.next;
while (next != &parent->d_subdirs) { while (next != &parent->d_subdirs) {
dentry = list_entry(next, struct dentry, d_u.d_child); dentry = list_entry(next, struct dentry, d_u.d_child);
...@@ -205,6 +206,7 @@ ncp_renew_dentries(struct dentry *parent) ...@@ -205,6 +206,7 @@ ncp_renew_dentries(struct dentry *parent)
next = next->next; next = next->next;
} }
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
} }
...@@ -216,6 +218,7 @@ ncp_invalidate_dircache_entries(struct dentry *parent) ...@@ -216,6 +218,7 @@ ncp_invalidate_dircache_entries(struct dentry *parent)
struct dentry *dentry; struct dentry *dentry;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&parent->d_lock);
next = parent->d_subdirs.next; next = parent->d_subdirs.next;
while (next != &parent->d_subdirs) { while (next != &parent->d_subdirs) {
dentry = list_entry(next, struct dentry, d_u.d_child); dentry = list_entry(next, struct dentry, d_u.d_child);
...@@ -223,6 +226,7 @@ ncp_invalidate_dircache_entries(struct dentry *parent) ...@@ -223,6 +226,7 @@ ncp_invalidate_dircache_entries(struct dentry *parent)
ncp_age_dentry(server, dentry); ncp_age_dentry(server, dentry);
next = next->next; next = next->next;
} }
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
} }
......
...@@ -68,17 +68,19 @@ void __fsnotify_update_child_dentry_flags(struct inode *inode) ...@@ -68,17 +68,19 @@ void __fsnotify_update_child_dentry_flags(struct inode *inode)
/* run all of the children of the original inode and fix their /* run all of the children of the original inode and fix their
* d_flags to indicate parental interest (their parent is the * d_flags to indicate parental interest (their parent is the
* original inode) */ * original inode) */
spin_lock(&alias->d_lock);
list_for_each_entry(child, &alias->d_subdirs, d_u.d_child) { list_for_each_entry(child, &alias->d_subdirs, d_u.d_child) {
if (!child->d_inode) if (!child->d_inode)
continue; continue;
spin_lock(&child->d_lock); spin_lock_nested(&child->d_lock, DENTRY_D_LOCK_NESTED);
if (watched) if (watched)
child->d_flags |= DCACHE_FSNOTIFY_PARENT_WATCHED; child->d_flags |= DCACHE_FSNOTIFY_PARENT_WATCHED;
else else
child->d_flags &= ~DCACHE_FSNOTIFY_PARENT_WATCHED; child->d_flags &= ~DCACHE_FSNOTIFY_PARENT_WATCHED;
spin_unlock(&child->d_lock); spin_unlock(&child->d_lock);
} }
spin_unlock(&alias->d_lock);
} }
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
} }
......
...@@ -305,6 +305,7 @@ static inline struct dentry *dget_dlock(struct dentry *dentry) ...@@ -305,6 +305,7 @@ static inline struct dentry *dget_dlock(struct dentry *dentry)
} }
return dentry; return dentry;
} }
static inline struct dentry *dget(struct dentry *dentry) static inline struct dentry *dget(struct dentry *dentry)
{ {
if (dentry) { if (dentry) {
......
...@@ -877,23 +877,31 @@ static void cgroup_clear_directory(struct dentry *dentry) ...@@ -877,23 +877,31 @@ static void cgroup_clear_directory(struct dentry *dentry)
BUG_ON(!mutex_is_locked(&dentry->d_inode->i_mutex)); BUG_ON(!mutex_is_locked(&dentry->d_inode->i_mutex));
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&dentry->d_lock);
node = dentry->d_subdirs.next; node = dentry->d_subdirs.next;
while (node != &dentry->d_subdirs) { while (node != &dentry->d_subdirs) {
struct dentry *d = list_entry(node, struct dentry, d_u.d_child); struct dentry *d = list_entry(node, struct dentry, d_u.d_child);
spin_lock_nested(&d->d_lock, DENTRY_D_LOCK_NESTED);
list_del_init(node); list_del_init(node);
if (d->d_inode) { if (d->d_inode) {
/* This should never be called on a cgroup /* This should never be called on a cgroup
* directory with child cgroups */ * directory with child cgroups */
BUG_ON(d->d_inode->i_mode & S_IFDIR); BUG_ON(d->d_inode->i_mode & S_IFDIR);
d = dget_locked(d); dget_locked_dlock(d);
spin_unlock(&d->d_lock);
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
d_delete(d); d_delete(d);
simple_unlink(dentry->d_inode, d); simple_unlink(dentry->d_inode, d);
dput(d); dput(d);
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
} spin_lock(&dentry->d_lock);
} else
spin_unlock(&d->d_lock);
node = dentry->d_subdirs.next; node = dentry->d_subdirs.next;
} }
spin_unlock(&dentry->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
} }
...@@ -902,10 +910,17 @@ static void cgroup_clear_directory(struct dentry *dentry) ...@@ -902,10 +910,17 @@ static void cgroup_clear_directory(struct dentry *dentry)
*/ */
static void cgroup_d_remove_dir(struct dentry *dentry) static void cgroup_d_remove_dir(struct dentry *dentry)
{ {
struct dentry *parent;
cgroup_clear_directory(dentry); cgroup_clear_directory(dentry);
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
parent = dentry->d_parent;
spin_lock(&parent->d_lock);
spin_lock(&dentry->d_lock);
list_del_init(&dentry->d_u.d_child); list_del_init(&dentry->d_u.d_child);
spin_unlock(&dentry->d_lock);
spin_unlock(&parent->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
remove_dir(dentry); remove_dir(dentry);
} }
......
...@@ -1146,22 +1146,30 @@ static void sel_remove_entries(struct dentry *de) ...@@ -1146,22 +1146,30 @@ static void sel_remove_entries(struct dentry *de)
struct list_head *node; struct list_head *node;
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
spin_lock(&de->d_lock);
node = de->d_subdirs.next; node = de->d_subdirs.next;
while (node != &de->d_subdirs) { while (node != &de->d_subdirs) {
struct dentry *d = list_entry(node, struct dentry, d_u.d_child); struct dentry *d = list_entry(node, struct dentry, d_u.d_child);
spin_lock_nested(&d->d_lock, DENTRY_D_LOCK_NESTED);
list_del_init(node); list_del_init(node);
if (d->d_inode) { if (d->d_inode) {
d = dget_locked(d); dget_locked_dlock(d);
spin_unlock(&de->d_lock);
spin_unlock(&d->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
d_delete(d); d_delete(d);
simple_unlink(de->d_inode, d); simple_unlink(de->d_inode, d);
dput(d); dput(d);
spin_lock(&dcache_lock); spin_lock(&dcache_lock);
} spin_lock(&de->d_lock);
} else
spin_unlock(&d->d_lock);
node = de->d_subdirs.next; node = de->d_subdirs.next;
} }
spin_unlock(&de->d_lock);
spin_unlock(&dcache_lock); spin_unlock(&dcache_lock);
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment