fsnotify: unify inode and mount marks handling
authorJan Kara <jack@suse.cz>
Sat, 13 Dec 2014 00:58:36 +0000 (16:58 -0800)
committerLinus Torvalds <torvalds@linux-foundation.org>
Sat, 13 Dec 2014 20:42:53 +0000 (12:42 -0800)
There's a lot of common code in inode and mount marks handling.  Factor it
out to a common helper function.

Signed-off-by: Jan Kara <jack@suse.cz>
Cc: Eric Paris <eparis@redhat.com>
Cc: Heinrich Schuchardt <xypron.glpk@gmx.de>
Signed-off-by: Andrew Morton <akpm@linux-foundation.org>
Signed-off-by: Linus Torvalds <torvalds@linux-foundation.org>
fs/notify/dnotify/dnotify.c
fs/notify/fdinfo.c
fs/notify/fsnotify.c
fs/notify/fsnotify.h
fs/notify/inode_mark.c
fs/notify/inotify/inotify_fsnotify.c
fs/notify/inotify/inotify_user.c
fs/notify/mark.c
fs/notify/vfsmount_mark.c
include/linux/fsnotify_backend.h
kernel/audit_tree.c

index caaaf9d..44523f4 100644 (file)
@@ -69,8 +69,8 @@ static void dnotify_recalc_inode_mask(struct fsnotify_mark *fsn_mark)
        if (old_mask == new_mask)
                return;
 
-       if (fsn_mark->i.inode)
-               fsnotify_recalc_inode_mask(fsn_mark->i.inode);
+       if (fsn_mark->inode)
+               fsnotify_recalc_inode_mask(fsn_mark->inode);
 }
 
 /*
index 6ffd220..58b7cdb 100644 (file)
@@ -80,7 +80,7 @@ static void inotify_fdinfo(struct seq_file *m, struct fsnotify_mark *mark)
                return;
 
        inode_mark = container_of(mark, struct inotify_inode_mark, fsn_mark);
-       inode = igrab(mark->i.inode);
+       inode = igrab(mark->inode);
        if (inode) {
                seq_printf(m, "inotify wd:%x ino:%lx sdev:%x mask:%x ignored_mask:%x ",
                           inode_mark->wd, inode->i_ino, inode->i_sb->s_dev,
@@ -112,7 +112,7 @@ static void fanotify_fdinfo(struct seq_file *m, struct fsnotify_mark *mark)
                mflags |= FAN_MARK_IGNORED_SURV_MODIFY;
 
        if (mark->flags & FSNOTIFY_MARK_FLAG_INODE) {
-               inode = igrab(mark->i.inode);
+               inode = igrab(mark->inode);
                if (!inode)
                        return;
                seq_printf(m, "fanotify ino:%lx sdev:%x mflags:%x mask:%x ignored_mask:%x ",
@@ -122,7 +122,7 @@ static void fanotify_fdinfo(struct seq_file *m, struct fsnotify_mark *mark)
                seq_putc(m, '\n');
                iput(inode);
        } else if (mark->flags & FSNOTIFY_MARK_FLAG_VFSMOUNT) {
-               struct mount *mnt = real_mount(mark->m.mnt);
+               struct mount *mnt = real_mount(mark->mnt);
 
                seq_printf(m, "fanotify mnt_id:%x mflags:%x mask:%x ignored_mask:%x\n",
                           mnt->mnt_id, mflags, mark->mask, mark->ignored_mask);
index 41e3910..dd3fb0b 100644 (file)
@@ -242,13 +242,13 @@ int fsnotify(struct inode *to_tell, __u32 mask, void *data, int data_is,
 
                if (inode_node) {
                        inode_mark = hlist_entry(srcu_dereference(inode_node, &fsnotify_mark_srcu),
-                                                struct fsnotify_mark, i.i_list);
+                                                struct fsnotify_mark, obj_list);
                        inode_group = inode_mark->group;
                }
 
                if (vfsmount_node) {
                        vfsmount_mark = hlist_entry(srcu_dereference(vfsmount_node, &fsnotify_mark_srcu),
-                                                       struct fsnotify_mark, m.m_list);
+                                                   struct fsnotify_mark, obj_list);
                        vfsmount_group = vfsmount_mark->group;
                }
 
index 3b68b0a..13a00be 100644 (file)
@@ -12,12 +12,19 @@ extern void fsnotify_flush_notify(struct fsnotify_group *group);
 /* protects reads of inode and vfsmount marks list */
 extern struct srcu_struct fsnotify_mark_srcu;
 
+/* Calculate mask of events for a list of marks */
+extern u32 fsnotify_recalc_mask(struct hlist_head *head);
+
 /* compare two groups for sorting of marks lists */
 extern int fsnotify_compare_groups(struct fsnotify_group *a,
                                   struct fsnotify_group *b);
 
 extern void fsnotify_set_inode_mark_mask_locked(struct fsnotify_mark *fsn_mark,
                                                __u32 mask);
+/* Add mark to a proper place in mark list */
+extern int fsnotify_add_mark_list(struct hlist_head *head,
+                                 struct fsnotify_mark *mark,
+                                 int allow_dups);
 /* add a mark to an inode */
 extern int fsnotify_add_inode_mark(struct fsnotify_mark *mark,
                                   struct fsnotify_group *group, struct inode *inode,
@@ -31,6 +38,11 @@ extern int fsnotify_add_vfsmount_mark(struct fsnotify_mark *mark,
 extern void fsnotify_destroy_vfsmount_mark(struct fsnotify_mark *mark);
 /* inode specific destruction of a mark */
 extern void fsnotify_destroy_inode_mark(struct fsnotify_mark *mark);
+/* Destroy all marks in the given list */
+extern void fsnotify_destroy_marks(struct list_head *to_free);
+/* Find mark belonging to given group in the list of marks */
+extern struct fsnotify_mark *fsnotify_find_mark(struct hlist_head *head,
+                                               struct fsnotify_group *group);
 /* run the list of all marks associated with inode and flag them to be freed */
 extern void fsnotify_clear_marks_by_inode(struct inode *inode);
 /* run the list of all marks associated with vfsmount and flag them to be freed */
index dfbf544..3daf513 100644 (file)
 #include "../internal.h"
 
 /*
- * Recalculate the mask of events relevant to a given inode locked.
- */
-static void fsnotify_recalc_inode_mask_locked(struct inode *inode)
-{
-       struct fsnotify_mark *mark;
-       __u32 new_mask = 0;
-
-       assert_spin_locked(&inode->i_lock);
-
-       hlist_for_each_entry(mark, &inode->i_fsnotify_marks, i.i_list)
-               new_mask |= mark->mask;
-       inode->i_fsnotify_mask = new_mask;
-}
-
-/*
  * Recalculate the inode->i_fsnotify_mask, or the mask of all FS_* event types
  * any notifier is interested in hearing for this inode.
  */
 void fsnotify_recalc_inode_mask(struct inode *inode)
 {
        spin_lock(&inode->i_lock);
-       fsnotify_recalc_inode_mask_locked(inode);
+       inode->i_fsnotify_mask = fsnotify_recalc_mask(&inode->i_fsnotify_marks);
        spin_unlock(&inode->i_lock);
 
        __fsnotify_update_child_dentry_flags(inode);
@@ -60,23 +45,22 @@ void fsnotify_recalc_inode_mask(struct inode *inode)
 
 void fsnotify_destroy_inode_mark(struct fsnotify_mark *mark)
 {
-       struct inode *inode = mark->i.inode;
+       struct inode *inode = mark->inode;
 
        BUG_ON(!mutex_is_locked(&mark->group->mark_mutex));
        assert_spin_locked(&mark->lock);
 
        spin_lock(&inode->i_lock);
 
-       hlist_del_init_rcu(&mark->i.i_list);
-       mark->i.inode = NULL;
+       hlist_del_init_rcu(&mark->obj_list);
+       mark->inode = NULL;
 
        /*
         * this mark is now off the inode->i_fsnotify_marks list and we
         * hold the inode->i_lock, so this is the perfect time to update the
         * inode->i_fsnotify_mask
         */
-       fsnotify_recalc_inode_mask_locked(inode);
-
+       inode->i_fsnotify_mask = fsnotify_recalc_mask(&inode->i_fsnotify_marks);
        spin_unlock(&inode->i_lock);
 }
 
@@ -85,30 +69,19 @@ void fsnotify_destroy_inode_mark(struct fsnotify_mark *mark)
  */
 void fsnotify_clear_marks_by_inode(struct inode *inode)
 {
-       struct fsnotify_mark *mark, *lmark;
+       struct fsnotify_mark *mark;
        struct hlist_node *n;
        LIST_HEAD(free_list);
 
        spin_lock(&inode->i_lock);
-       hlist_for_each_entry_safe(mark, n, &inode->i_fsnotify_marks, i.i_list) {
-               list_add(&mark->i.free_i_list, &free_list);
-               hlist_del_init_rcu(&mark->i.i_list);
+       hlist_for_each_entry_safe(mark, n, &inode->i_fsnotify_marks, obj_list) {
+               list_add(&mark->free_list, &free_list);
+               hlist_del_init_rcu(&mark->obj_list);
                fsnotify_get_mark(mark);
        }
        spin_unlock(&inode->i_lock);
 
-       list_for_each_entry_safe(mark, lmark, &free_list, i.free_i_list) {
-               struct fsnotify_group *group;
-
-               spin_lock(&mark->lock);
-               fsnotify_get_group(mark->group);
-               group = mark->group;
-               spin_unlock(&mark->lock);
-
-               fsnotify_destroy_mark(mark, group);
-               fsnotify_put_mark(mark);
-               fsnotify_put_group(group);
-       }
+       fsnotify_destroy_marks(&free_list);
 }
 
 /*
@@ -123,34 +96,13 @@ void fsnotify_clear_inode_marks_by_group(struct fsnotify_group *group)
  * given a group and inode, find the mark associated with that combination.
  * if found take a reference to that mark and return it, else return NULL
  */
-static struct fsnotify_mark *fsnotify_find_inode_mark_locked(
-               struct fsnotify_group *group,
-               struct inode *inode)
-{
-       struct fsnotify_mark *mark;
-
-       assert_spin_locked(&inode->i_lock);
-
-       hlist_for_each_entry(mark, &inode->i_fsnotify_marks, i.i_list) {
-               if (mark->group == group) {
-                       fsnotify_get_mark(mark);
-                       return mark;
-               }
-       }
-       return NULL;
-}
-
-/*
- * given a group and inode, find the mark associated with that combination.
- * if found take a reference to that mark and return it, else return NULL
- */
 struct fsnotify_mark *fsnotify_find_inode_mark(struct fsnotify_group *group,
                                               struct inode *inode)
 {
        struct fsnotify_mark *mark;
 
        spin_lock(&inode->i_lock);
-       mark = fsnotify_find_inode_mark_locked(group, inode);
+       mark = fsnotify_find_mark(&inode->i_fsnotify_marks, group);
        spin_unlock(&inode->i_lock);
 
        return mark;
@@ -168,10 +120,10 @@ void fsnotify_set_inode_mark_mask_locked(struct fsnotify_mark *mark,
        assert_spin_locked(&mark->lock);
 
        if (mask &&
-           mark->i.inode &&
+           mark->inode &&
            !(mark->flags & FSNOTIFY_MARK_FLAG_OBJECT_PINNED)) {
                mark->flags |= FSNOTIFY_MARK_FLAG_OBJECT_PINNED;
-               inode = igrab(mark->i.inode);
+               inode = igrab(mark->inode);
                /*
                 * we shouldn't be able to get here if the inode wasn't
                 * already safely held in memory.  But bug in case it
@@ -192,9 +144,7 @@ int fsnotify_add_inode_mark(struct fsnotify_mark *mark,
                            struct fsnotify_group *group, struct inode *inode,
                            int allow_dups)
 {
-       struct fsnotify_mark *lmark, *last = NULL;
-       int ret = 0;
-       int cmp;
+       int ret;
 
        mark->flags |= FSNOTIFY_MARK_FLAG_INODE;
 
@@ -202,37 +152,10 @@ int fsnotify_add_inode_mark(struct fsnotify_mark *mark,
        assert_spin_locked(&mark->lock);
 
        spin_lock(&inode->i_lock);
-
-       mark->i.inode = inode;
-
-       /* is mark the first mark? */
-       if (hlist_empty(&inode->i_fsnotify_marks)) {
-               hlist_add_head_rcu(&mark->i.i_list, &inode->i_fsnotify_marks);
-               goto out;
-       }
-
-       /* should mark be in the middle of the current list? */
-       hlist_for_each_entry(lmark, &inode->i_fsnotify_marks, i.i_list) {
-               last = lmark;
-
-               if ((lmark->group == group) && !allow_dups) {
-                       ret = -EEXIST;
-                       goto out;
-               }
-
-               cmp = fsnotify_compare_groups(lmark->group, mark->group);
-               if (cmp < 0)
-                       continue;
-
-               hlist_add_before_rcu(&mark->i.i_list, &lmark->i.i_list);
-               goto out;
-       }
-
-       BUG_ON(last == NULL);
-       /* mark should be the last entry.  last is the current last entry */
-       hlist_add_behind_rcu(&mark->i.i_list, &last->i.i_list);
-out:
-       fsnotify_recalc_inode_mask_locked(inode);
+       mark->inode = inode;
+       ret = fsnotify_add_mark_list(&inode->i_fsnotify_marks, mark,
+                                    allow_dups);
+       inode->i_fsnotify_mask = fsnotify_recalc_mask(&inode->i_fsnotify_marks);
        spin_unlock(&inode->i_lock);
 
        return ret;
index 7d888d7..2cd900c 100644 (file)
@@ -156,7 +156,7 @@ static int idr_callback(int id, void *p, void *data)
         */
        if (fsn_mark)
                printk(KERN_WARNING "fsn_mark->group=%p inode=%p wd=%d\n",
-                       fsn_mark->group, fsn_mark->i.inode, i_mark->wd);
+                       fsn_mark->group, fsn_mark->inode, i_mark->wd);
        return 0;
 }
 
index 283aa31..4506486 100644 (file)
@@ -433,7 +433,7 @@ static void inotify_remove_from_idr(struct fsnotify_group *group,
        if (wd == -1) {
                WARN_ONCE(1, "%s: i_mark=%p i_mark->wd=%d i_mark->group=%p"
                        " i_mark->inode=%p\n", __func__, i_mark, i_mark->wd,
-                       i_mark->fsn_mark.group, i_mark->fsn_mark.i.inode);
+                       i_mark->fsn_mark.group, i_mark->fsn_mark.inode);
                goto out;
        }
 
@@ -442,7 +442,7 @@ static void inotify_remove_from_idr(struct fsnotify_group *group,
        if (unlikely(!found_i_mark)) {
                WARN_ONCE(1, "%s: i_mark=%p i_mark->wd=%d i_mark->group=%p"
                        " i_mark->inode=%p\n", __func__, i_mark, i_mark->wd,
-                       i_mark->fsn_mark.group, i_mark->fsn_mark.i.inode);
+                       i_mark->fsn_mark.group, i_mark->fsn_mark.inode);
                goto out;
        }
 
@@ -456,9 +456,9 @@ static void inotify_remove_from_idr(struct fsnotify_group *group,
                        "mark->inode=%p found_i_mark=%p found_i_mark->wd=%d "
                        "found_i_mark->group=%p found_i_mark->inode=%p\n",
                        __func__, i_mark, i_mark->wd, i_mark->fsn_mark.group,
-                       i_mark->fsn_mark.i.inode, found_i_mark, found_i_mark->wd,
+                       i_mark->fsn_mark.inode, found_i_mark, found_i_mark->wd,
                        found_i_mark->fsn_mark.group,
-                       found_i_mark->fsn_mark.i.inode);
+                       found_i_mark->fsn_mark.inode);
                goto out;
        }
 
@@ -470,7 +470,7 @@ static void inotify_remove_from_idr(struct fsnotify_group *group,
        if (unlikely(atomic_read(&i_mark->fsn_mark.refcnt) < 3)) {
                printk(KERN_ERR "%s: i_mark=%p i_mark->wd=%d i_mark->group=%p"
                        " i_mark->inode=%p\n", __func__, i_mark, i_mark->wd,
-                       i_mark->fsn_mark.group, i_mark->fsn_mark.i.inode);
+                       i_mark->fsn_mark.group, i_mark->fsn_mark.inode);
                /* we can't really recover with bad ref cnting.. */
                BUG();
        }
index 34c38fa..3942d5c 100644 (file)
@@ -110,6 +110,17 @@ void fsnotify_put_mark(struct fsnotify_mark *mark)
        }
 }
 
+/* Calculate mask of events for a list of marks */
+u32 fsnotify_recalc_mask(struct hlist_head *head)
+{
+       u32 new_mask = 0;
+       struct fsnotify_mark *mark;
+
+       hlist_for_each_entry(mark, head, obj_list)
+               new_mask |= mark->mask;
+       return new_mask;
+}
+
 /*
  * Any time a mark is getting freed we end up here.
  * The caller had better be holding a reference to this mark so we don't actually
@@ -133,7 +144,7 @@ void fsnotify_destroy_mark_locked(struct fsnotify_mark *mark,
        mark->flags &= ~FSNOTIFY_MARK_FLAG_ALIVE;
 
        if (mark->flags & FSNOTIFY_MARK_FLAG_INODE) {
-               inode = mark->i.inode;
+               inode = mark->inode;
                fsnotify_destroy_inode_mark(mark);
        } else if (mark->flags & FSNOTIFY_MARK_FLAG_VFSMOUNT)
                fsnotify_destroy_vfsmount_mark(mark);
@@ -192,6 +203,27 @@ void fsnotify_destroy_mark(struct fsnotify_mark *mark,
        mutex_unlock(&group->mark_mutex);
 }
 
+/*
+ * Destroy all marks in the given list. The marks must be already detached from
+ * the original inode / vfsmount.
+ */
+void fsnotify_destroy_marks(struct list_head *to_free)
+{
+       struct fsnotify_mark *mark, *lmark;
+       struct fsnotify_group *group;
+
+       list_for_each_entry_safe(mark, lmark, to_free, free_list) {
+               spin_lock(&mark->lock);
+               fsnotify_get_group(mark->group);
+               group = mark->group;
+               spin_unlock(&mark->lock);
+
+               fsnotify_destroy_mark(mark, group);
+               fsnotify_put_mark(mark);
+               fsnotify_put_group(group);
+       }
+}
+
 void fsnotify_set_mark_mask_locked(struct fsnotify_mark *mark, __u32 mask)
 {
        assert_spin_locked(&mark->lock);
@@ -245,6 +277,39 @@ int fsnotify_compare_groups(struct fsnotify_group *a, struct fsnotify_group *b)
        return -1;
 }
 
+/* Add mark into proper place in given list of marks */
+int fsnotify_add_mark_list(struct hlist_head *head, struct fsnotify_mark *mark,
+                          int allow_dups)
+{
+       struct fsnotify_mark *lmark, *last = NULL;
+       int cmp;
+
+       /* is mark the first mark? */
+       if (hlist_empty(head)) {
+               hlist_add_head_rcu(&mark->obj_list, head);
+               return 0;
+       }
+
+       /* should mark be in the middle of the current list? */
+       hlist_for_each_entry(lmark, head, obj_list) {
+               last = lmark;
+
+               if ((lmark->group == mark->group) && !allow_dups)
+                       return -EEXIST;
+
+               cmp = fsnotify_compare_groups(lmark->group, mark->group);
+               if (cmp >= 0) {
+                       hlist_add_before_rcu(&mark->obj_list, &lmark->obj_list);
+                       return 0;
+               }
+       }
+
+       BUG_ON(last == NULL);
+       /* mark should be the last entry.  last is the current last entry */
+       hlist_add_behind_rcu(&mark->obj_list, &last->obj_list);
+       return 0;
+}
+
 /*
  * Attach an initialized mark to a given group and fs object.
  * These marks may be used for the fsnotify backend to determine which
@@ -323,6 +388,24 @@ int fsnotify_add_mark(struct fsnotify_mark *mark, struct fsnotify_group *group,
 }
 
 /*
+ * Given a list of marks, find the mark associated with given group. If found
+ * take a reference to that mark and return it, else return NULL.
+ */
+struct fsnotify_mark *fsnotify_find_mark(struct hlist_head *head,
+                                        struct fsnotify_group *group)
+{
+       struct fsnotify_mark *mark;
+
+       hlist_for_each_entry(mark, head, obj_list) {
+               if (mark->group == group) {
+                       fsnotify_get_mark(mark);
+                       return mark;
+               }
+       }
+       return NULL;
+}
+
+/*
  * clear any marks in a group in which mark->flags & flags is true
  */
 void fsnotify_clear_marks_by_group_flags(struct fsnotify_group *group,
@@ -352,8 +435,8 @@ void fsnotify_clear_marks_by_group(struct fsnotify_group *group)
 void fsnotify_duplicate_mark(struct fsnotify_mark *new, struct fsnotify_mark *old)
 {
        assert_spin_locked(&old->lock);
-       new->i.inode = old->i.inode;
-       new->m.mnt = old->m.mnt;
+       new->inode = old->inode;
+       new->mnt = old->mnt;
        if (old->group)
                fsnotify_get_group(old->group);
        new->group = old->group;
index faefa72..326b148 100644 (file)
 
 void fsnotify_clear_marks_by_mount(struct vfsmount *mnt)
 {
-       struct fsnotify_mark *mark, *lmark;
+       struct fsnotify_mark *mark;
        struct hlist_node *n;
        struct mount *m = real_mount(mnt);
        LIST_HEAD(free_list);
 
        spin_lock(&mnt->mnt_root->d_lock);
-       hlist_for_each_entry_safe(mark, n, &m->mnt_fsnotify_marks, m.m_list) {
-               list_add(&mark->m.free_m_list, &free_list);
-               hlist_del_init_rcu(&mark->m.m_list);
+       hlist_for_each_entry_safe(mark, n, &m->mnt_fsnotify_marks, obj_list) {
+               list_add(&mark->free_list, &free_list);
+               hlist_del_init_rcu(&mark->obj_list);
                fsnotify_get_mark(mark);
        }
        spin_unlock(&mnt->mnt_root->d_lock);
 
-       list_for_each_entry_safe(mark, lmark, &free_list, m.free_m_list) {
-               struct fsnotify_group *group;
-
-               spin_lock(&mark->lock);
-               fsnotify_get_group(mark->group);
-               group = mark->group;
-               spin_unlock(&mark->lock);
-
-               fsnotify_destroy_mark(mark, group);
-               fsnotify_put_mark(mark);
-               fsnotify_put_group(group);
-       }
+       fsnotify_destroy_marks(&free_list);
 }
 
 void fsnotify_clear_vfsmount_marks_by_group(struct fsnotify_group *group)
@@ -65,66 +54,35 @@ void fsnotify_clear_vfsmount_marks_by_group(struct fsnotify_group *group)
 }
 
 /*
- * Recalculate the mask of events relevant to a given vfsmount locked.
- */
-static void fsnotify_recalc_vfsmount_mask_locked(struct vfsmount *mnt)
-{
-       struct mount *m = real_mount(mnt);
-       struct fsnotify_mark *mark;
-       __u32 new_mask = 0;
-
-       assert_spin_locked(&mnt->mnt_root->d_lock);
-
-       hlist_for_each_entry(mark, &m->mnt_fsnotify_marks, m.m_list)
-               new_mask |= mark->mask;
-       m->mnt_fsnotify_mask = new_mask;
-}
-
-/*
  * Recalculate the mnt->mnt_fsnotify_mask, or the mask of all FS_* event types
  * any notifier is interested in hearing for this mount point
  */
 void fsnotify_recalc_vfsmount_mask(struct vfsmount *mnt)
 {
+       struct mount *m = real_mount(mnt);
+
        spin_lock(&mnt->mnt_root->d_lock);
-       fsnotify_recalc_vfsmount_mask_locked(mnt);
+       m->mnt_fsnotify_mask = fsnotify_recalc_mask(&m->mnt_fsnotify_marks);
        spin_unlock(&mnt->mnt_root->d_lock);
 }
 
 void fsnotify_destroy_vfsmount_mark(struct fsnotify_mark *mark)
 {
-       struct vfsmount *mnt = mark->m.mnt;
+       struct vfsmount *mnt = mark->mnt;
+       struct mount *m = real_mount(mnt);
 
        BUG_ON(!mutex_is_locked(&mark->group->mark_mutex));
        assert_spin_locked(&mark->lock);
 
        spin_lock(&mnt->mnt_root->d_lock);
 
-       hlist_del_init_rcu(&mark->m.m_list);
-       mark->m.mnt = NULL;
-
-       fsnotify_recalc_vfsmount_mask_locked(mnt);
+       hlist_del_init_rcu(&mark->obj_list);
+       mark->mnt = NULL;
 
+       m->mnt_fsnotify_mask = fsnotify_recalc_mask(&m->mnt_fsnotify_marks);
        spin_unlock(&mnt->mnt_root->d_lock);
 }
 
-static struct fsnotify_mark *fsnotify_find_vfsmount_mark_locked(struct fsnotify_group *group,
-                                                               struct vfsmount *mnt)
-{
-       struct mount *m = real_mount(mnt);
-       struct fsnotify_mark *mark;
-
-       assert_spin_locked(&mnt->mnt_root->d_lock);
-
-       hlist_for_each_entry(mark, &m->mnt_fsnotify_marks, m.m_list) {
-               if (mark->group == group) {
-                       fsnotify_get_mark(mark);
-                       return mark;
-               }
-       }
-       return NULL;
-}
-
 /*
  * given a group and vfsmount, find the mark associated with that combination.
  * if found take a reference to that mark and return it, else return NULL
@@ -132,10 +90,11 @@ static struct fsnotify_mark *fsnotify_find_vfsmount_mark_locked(struct fsnotify_
 struct fsnotify_mark *fsnotify_find_vfsmount_mark(struct fsnotify_group *group,
                                                  struct vfsmount *mnt)
 {
+       struct mount *m = real_mount(mnt);
        struct fsnotify_mark *mark;
 
        spin_lock(&mnt->mnt_root->d_lock);
-       mark = fsnotify_find_vfsmount_mark_locked(group, mnt);
+       mark = fsnotify_find_mark(&m->mnt_fsnotify_marks, group);
        spin_unlock(&mnt->mnt_root->d_lock);
 
        return mark;
@@ -151,9 +110,7 @@ int fsnotify_add_vfsmount_mark(struct fsnotify_mark *mark,
                               int allow_dups)
 {
        struct mount *m = real_mount(mnt);
-       struct fsnotify_mark *lmark, *last = NULL;
-       int ret = 0;
-       int cmp;
+       int ret;
 
        mark->flags |= FSNOTIFY_MARK_FLAG_VFSMOUNT;
 
@@ -161,37 +118,9 @@ int fsnotify_add_vfsmount_mark(struct fsnotify_mark *mark,
        assert_spin_locked(&mark->lock);
 
        spin_lock(&mnt->mnt_root->d_lock);
-
-       mark->m.mnt = mnt;
-
-       /* is mark the first mark? */
-       if (hlist_empty(&m->mnt_fsnotify_marks)) {
-               hlist_add_head_rcu(&mark->m.m_list, &m->mnt_fsnotify_marks);
-               goto out;
-       }
-
-       /* should mark be in the middle of the current list? */
-       hlist_for_each_entry(lmark, &m->mnt_fsnotify_marks, m.m_list) {
-               last = lmark;
-
-               if ((lmark->group == group) && !allow_dups) {
-                       ret = -EEXIST;
-                       goto out;
-               }
-
-               cmp = fsnotify_compare_groups(lmark->group, mark->group);
-               if (cmp < 0)
-                       continue;
-
-               hlist_add_before_rcu(&mark->m.m_list, &lmark->m.m_list);
-               goto out;
-       }
-
-       BUG_ON(last == NULL);
-       /* mark should be the last entry.  last is the current last entry */
-       hlist_add_behind_rcu(&mark->m.m_list, &last->m.m_list);
-out:
-       fsnotify_recalc_vfsmount_mask_locked(mnt);
+       mark->mnt = mnt;
+       ret = fsnotify_add_mark_list(&m->mnt_fsnotify_marks, mark, allow_dups);
+       m->mnt_fsnotify_mask = fsnotify_recalc_mask(&m->mnt_fsnotify_marks);
        spin_unlock(&mnt->mnt_root->d_lock);
 
        return ret;
index ca060d7..442847a 100644 (file)
@@ -197,24 +197,6 @@ struct fsnotify_group {
 #define FSNOTIFY_EVENT_INODE   2
 
 /*
- * Inode specific fields in an fsnotify_mark
- */
-struct fsnotify_inode_mark {
-       struct inode *inode;            /* inode this mark is associated with */
-       struct hlist_node i_list;       /* list of marks by inode->i_fsnotify_marks */
-       struct list_head free_i_list;   /* tmp list used when freeing this mark */
-};
-
-/*
- * Mount point specific fields in an fsnotify_mark
- */
-struct fsnotify_vfsmount_mark {
-       struct vfsmount *mnt;           /* vfsmount this mark is associated with */
-       struct hlist_node m_list;       /* list of marks by inode->i_fsnotify_marks */
-       struct list_head free_m_list;   /* tmp list used when freeing this mark */
-};
-
-/*
  * a mark is simply an object attached to an in core inode which allows an
  * fsnotify listener to indicate they are either no longer interested in events
  * of a type matching mask or only interested in those events.
@@ -232,9 +214,11 @@ struct fsnotify_mark {
        struct fsnotify_group *group;   /* group this mark is for */
        struct list_head g_list;        /* list of marks by group->i_fsnotify_marks */
        spinlock_t lock;                /* protect group and inode */
+       struct hlist_node obj_list;     /* list of marks for inode / vfsmount */
+       struct list_head free_list;     /* tmp list used when freeing this mark */
        union {
-               struct fsnotify_inode_mark i;
-               struct fsnotify_vfsmount_mark m;
+               struct inode *inode;    /* inode this mark is associated with */
+               struct vfsmount *mnt;   /* vfsmount this mark is associated with */
        };
        __u32 ignored_mask;             /* events types to ignore */
 #define FSNOTIFY_MARK_FLAG_INODE               0x01
index 80f29e0..2e0c974 100644 (file)
@@ -174,9 +174,9 @@ static void insert_hash(struct audit_chunk *chunk)
        struct fsnotify_mark *entry = &chunk->mark;
        struct list_head *list;
 
-       if (!entry->i.inode)
+       if (!entry->inode)
                return;
-       list = chunk_hash(entry->i.inode);
+       list = chunk_hash(entry->inode);
        list_add_rcu(&chunk->hash, list);
 }
 
@@ -188,7 +188,7 @@ struct audit_chunk *audit_tree_lookup(const struct inode *inode)
 
        list_for_each_entry_rcu(p, list, hash) {
                /* mark.inode may have gone NULL, but who cares? */
-               if (p->mark.i.inode == inode) {
+               if (p->mark.inode == inode) {
                        atomic_long_inc(&p->refs);
                        return p;
                }
@@ -231,7 +231,7 @@ static void untag_chunk(struct node *p)
                new = alloc_chunk(size);
 
        spin_lock(&entry->lock);
-       if (chunk->dead || !entry->i.inode) {
+       if (chunk->dead || !entry->inode) {
                spin_unlock(&entry->lock);
                if (new)
                        free_chunk(new);
@@ -258,7 +258,7 @@ static void untag_chunk(struct node *p)
                goto Fallback;
 
        fsnotify_duplicate_mark(&new->mark, entry);
-       if (fsnotify_add_mark(&new->mark, new->mark.group, new->mark.i.inode, NULL, 1)) {
+       if (fsnotify_add_mark(&new->mark, new->mark.group, new->mark.inode, NULL, 1)) {
                fsnotify_put_mark(&new->mark);
                goto Fallback;
        }
@@ -386,7 +386,7 @@ static int tag_chunk(struct inode *inode, struct audit_tree *tree)
        chunk_entry = &chunk->mark;
 
        spin_lock(&old_entry->lock);
-       if (!old_entry->i.inode) {
+       if (!old_entry->inode) {
                /* old_entry is being shot, lets just lie */
                spin_unlock(&old_entry->lock);
                fsnotify_put_mark(old_entry);
@@ -395,7 +395,7 @@ static int tag_chunk(struct inode *inode, struct audit_tree *tree)
        }
 
        fsnotify_duplicate_mark(chunk_entry, old_entry);
-       if (fsnotify_add_mark(chunk_entry, chunk_entry->group, chunk_entry->i.inode, NULL, 1)) {
+       if (fsnotify_add_mark(chunk_entry, chunk_entry->group, chunk_entry->inode, NULL, 1)) {
                spin_unlock(&old_entry->lock);
                fsnotify_put_mark(chunk_entry);
                fsnotify_put_mark(old_entry);
@@ -611,7 +611,7 @@ void audit_trim_trees(void)
                list_for_each_entry(node, &tree->chunks, list) {
                        struct audit_chunk *chunk = find_chunk(node);
                        /* this could be NULL if the watch is dying else where... */
-                       struct inode *inode = chunk->mark.i.inode;
+                       struct inode *inode = chunk->mark.inode;
                        node->index |= 1U<<31;
                        if (iterate_mounts(compare_root, inode, root_mnt))
                                node->index &= ~(1U<<31);