diff options
-rw-r--r-- | fs/inode.c | 9 | ||||
-rw-r--r-- | fs/notify/Makefile | 2 | ||||
-rw-r--r-- | fs/notify/fsnotify.c | 13 | ||||
-rw-r--r-- | fs/notify/fsnotify.h | 5 | ||||
-rw-r--r-- | fs/notify/group.c | 49 | ||||
-rw-r--r-- | fs/notify/inode_mark.c | 329 | ||||
-rw-r--r-- | include/linux/fs.h | 5 | ||||
-rw-r--r-- | include/linux/fsnotify.h | 9 | ||||
-rw-r--r-- | include/linux/fsnotify_backend.h | 65 |
9 files changed, 483 insertions, 3 deletions
diff --git a/fs/inode.c b/fs/inode.c index bca0c618fdb3..54c63ce3de25 100644 --- a/fs/inode.c +++ b/fs/inode.c | |||
@@ -22,6 +22,7 @@ | |||
22 | #include <linux/cdev.h> | 22 | #include <linux/cdev.h> |
23 | #include <linux/bootmem.h> | 23 | #include <linux/bootmem.h> |
24 | #include <linux/inotify.h> | 24 | #include <linux/inotify.h> |
25 | #include <linux/fsnotify.h> | ||
25 | #include <linux/mount.h> | 26 | #include <linux/mount.h> |
26 | #include <linux/async.h> | 27 | #include <linux/async.h> |
27 | 28 | ||
@@ -189,6 +190,10 @@ struct inode *inode_init_always(struct super_block *sb, struct inode *inode) | |||
189 | inode->i_private = NULL; | 190 | inode->i_private = NULL; |
190 | inode->i_mapping = mapping; | 191 | inode->i_mapping = mapping; |
191 | 192 | ||
193 | #ifdef CONFIG_FSNOTIFY | ||
194 | inode->i_fsnotify_mask = 0; | ||
195 | #endif | ||
196 | |||
192 | return inode; | 197 | return inode; |
193 | 198 | ||
194 | out_free_security: | 199 | out_free_security: |
@@ -221,6 +226,7 @@ void destroy_inode(struct inode *inode) | |||
221 | BUG_ON(inode_has_buffers(inode)); | 226 | BUG_ON(inode_has_buffers(inode)); |
222 | ima_inode_free(inode); | 227 | ima_inode_free(inode); |
223 | security_inode_free(inode); | 228 | security_inode_free(inode); |
229 | fsnotify_inode_delete(inode); | ||
224 | if (inode->i_sb->s_op->destroy_inode) | 230 | if (inode->i_sb->s_op->destroy_inode) |
225 | inode->i_sb->s_op->destroy_inode(inode); | 231 | inode->i_sb->s_op->destroy_inode(inode); |
226 | else | 232 | else |
@@ -252,6 +258,9 @@ void inode_init_once(struct inode *inode) | |||
252 | INIT_LIST_HEAD(&inode->inotify_watches); | 258 | INIT_LIST_HEAD(&inode->inotify_watches); |
253 | mutex_init(&inode->inotify_mutex); | 259 | mutex_init(&inode->inotify_mutex); |
254 | #endif | 260 | #endif |
261 | #ifdef CONFIG_FSNOTIFY | ||
262 | INIT_HLIST_HEAD(&inode->i_fsnotify_mark_entries); | ||
263 | #endif | ||
255 | } | 264 | } |
256 | EXPORT_SYMBOL(inode_init_once); | 265 | EXPORT_SYMBOL(inode_init_once); |
257 | 266 | ||
diff --git a/fs/notify/Makefile b/fs/notify/Makefile index db5467b5b58d..0922cc826c46 100644 --- a/fs/notify/Makefile +++ b/fs/notify/Makefile | |||
@@ -1,4 +1,4 @@ | |||
1 | obj-$(CONFIG_FSNOTIFY) += fsnotify.o notification.o group.o | 1 | obj-$(CONFIG_FSNOTIFY) += fsnotify.o notification.o group.o inode_mark.o |
2 | 2 | ||
3 | obj-y += dnotify/ | 3 | obj-y += dnotify/ |
4 | obj-y += inotify/ | 4 | obj-y += inotify/ |
diff --git a/fs/notify/fsnotify.c b/fs/notify/fsnotify.c index 56bee0f10c38..d5654629c659 100644 --- a/fs/notify/fsnotify.c +++ b/fs/notify/fsnotify.c | |||
@@ -26,6 +26,15 @@ | |||
26 | #include "fsnotify.h" | 26 | #include "fsnotify.h" |
27 | 27 | ||
28 | /* | 28 | /* |
29 | * Clear all of the marks on an inode when it is being evicted from core | ||
30 | */ | ||
31 | void __fsnotify_inode_delete(struct inode *inode) | ||
32 | { | ||
33 | fsnotify_clear_marks_by_inode(inode); | ||
34 | } | ||
35 | EXPORT_SYMBOL_GPL(__fsnotify_inode_delete); | ||
36 | |||
37 | /* | ||
29 | * This is the main call to fsnotify. The VFS calls into hook specific functions | 38 | * This is the main call to fsnotify. The VFS calls into hook specific functions |
30 | * in linux/fsnotify.h. Those functions then in turn call here. Here will call | 39 | * in linux/fsnotify.h. Those functions then in turn call here. Here will call |
31 | * out to all of the registered fsnotify_group. Those groups can then use the | 40 | * out to all of the registered fsnotify_group. Those groups can then use the |
@@ -43,6 +52,8 @@ void fsnotify(struct inode *to_tell, __u32 mask, void *data, int data_is) | |||
43 | if (!(mask & fsnotify_mask)) | 52 | if (!(mask & fsnotify_mask)) |
44 | return; | 53 | return; |
45 | 54 | ||
55 | if (!(mask & to_tell->i_fsnotify_mask)) | ||
56 | return; | ||
46 | /* | 57 | /* |
47 | * SRCU!! the groups list is very very much read only and the path is | 58 | * SRCU!! the groups list is very very much read only and the path is |
48 | * very hot. The VAST majority of events are not going to need to do | 59 | * very hot. The VAST majority of events are not going to need to do |
@@ -51,6 +62,8 @@ void fsnotify(struct inode *to_tell, __u32 mask, void *data, int data_is) | |||
51 | idx = srcu_read_lock(&fsnotify_grp_srcu); | 62 | idx = srcu_read_lock(&fsnotify_grp_srcu); |
52 | list_for_each_entry_rcu(group, &fsnotify_groups, group_list) { | 63 | list_for_each_entry_rcu(group, &fsnotify_groups, group_list) { |
53 | if (mask & group->mask) { | 64 | if (mask & group->mask) { |
65 | if (!group->ops->should_send_event(group, to_tell, mask)) | ||
66 | continue; | ||
54 | if (!event) { | 67 | if (!event) { |
55 | event = fsnotify_create_event(to_tell, mask, data, data_is); | 68 | event = fsnotify_create_event(to_tell, mask, data, data_is); |
56 | /* shit, we OOM'd and now we can't tell, maybe | 69 | /* shit, we OOM'd and now we can't tell, maybe |
diff --git a/fs/notify/fsnotify.h b/fs/notify/fsnotify.h index c6a8bd476572..8ebcbe893c91 100644 --- a/fs/notify/fsnotify.h +++ b/fs/notify/fsnotify.h | |||
@@ -12,4 +12,9 @@ extern struct srcu_struct fsnotify_grp_srcu; | |||
12 | extern struct list_head fsnotify_groups; | 12 | extern struct list_head fsnotify_groups; |
13 | /* all bitwise OR of all event types (FS_*) for all fsnotify_groups */ | 13 | /* all bitwise OR of all event types (FS_*) for all fsnotify_groups */ |
14 | extern __u32 fsnotify_mask; | 14 | extern __u32 fsnotify_mask; |
15 | |||
16 | /* final kfree of a group */ | ||
17 | extern void fsnotify_final_destroy_group(struct fsnotify_group *group); | ||
18 | /* run the list of all marks associated with inode and flag them to be freed */ | ||
19 | extern void fsnotify_clear_marks_by_inode(struct inode *inode); | ||
15 | #endif /* __FS_NOTIFY_FSNOTIFY_H_ */ | 20 | #endif /* __FS_NOTIFY_FSNOTIFY_H_ */ |
diff --git a/fs/notify/group.c b/fs/notify/group.c index c6812953b968..a29d2fa67927 100644 --- a/fs/notify/group.c +++ b/fs/notify/group.c | |||
@@ -55,6 +55,29 @@ void fsnotify_recalc_global_mask(void) | |||
55 | } | 55 | } |
56 | 56 | ||
57 | /* | 57 | /* |
58 | * Update the group->mask by running all of the marks associated with this | ||
59 | * group and finding the bitwise | of all of the mark->mask. If we change | ||
60 | * the group->mask we need to update the global mask of events interesting | ||
61 | * to the system. | ||
62 | */ | ||
63 | void fsnotify_recalc_group_mask(struct fsnotify_group *group) | ||
64 | { | ||
65 | __u32 mask = 0; | ||
66 | __u32 old_mask = group->mask; | ||
67 | struct fsnotify_mark_entry *entry; | ||
68 | |||
69 | spin_lock(&group->mark_lock); | ||
70 | list_for_each_entry(entry, &group->mark_entries, g_list) | ||
71 | mask |= entry->mask; | ||
72 | spin_unlock(&group->mark_lock); | ||
73 | |||
74 | group->mask = mask; | ||
75 | |||
76 | if (old_mask != mask) | ||
77 | fsnotify_recalc_global_mask(); | ||
78 | } | ||
79 | |||
80 | /* | ||
58 | * Take a reference to a group so things found under the fsnotify_grp_mutex | 81 | * Take a reference to a group so things found under the fsnotify_grp_mutex |
59 | * can't get freed under us | 82 | * can't get freed under us |
60 | */ | 83 | */ |
@@ -66,7 +89,7 @@ static void fsnotify_get_group(struct fsnotify_group *group) | |||
66 | /* | 89 | /* |
67 | * Final freeing of a group | 90 | * Final freeing of a group |
68 | */ | 91 | */ |
69 | static void fsnotify_destroy_group(struct fsnotify_group *group) | 92 | void fsnotify_final_destroy_group(struct fsnotify_group *group) |
70 | { | 93 | { |
71 | if (group->ops->free_group_priv) | 94 | if (group->ops->free_group_priv) |
72 | group->ops->free_group_priv(group); | 95 | group->ops->free_group_priv(group); |
@@ -75,6 +98,24 @@ static void fsnotify_destroy_group(struct fsnotify_group *group) | |||
75 | } | 98 | } |
76 | 99 | ||
77 | /* | 100 | /* |
101 | * Trying to get rid of a group. We need to first get rid of any outstanding | ||
102 | * allocations and then free the group. Remember that fsnotify_clear_marks_by_group | ||
103 | * could miss marks that are being freed by inode and those marks could still | ||
104 | * hold a reference to this group (via group->num_marks) If we get into that | ||
105 | * situtation, the fsnotify_final_destroy_group will get called when that final | ||
106 | * mark is freed. | ||
107 | */ | ||
108 | static void fsnotify_destroy_group(struct fsnotify_group *group) | ||
109 | { | ||
110 | /* clear all inode mark entries for this group */ | ||
111 | fsnotify_clear_marks_by_group(group); | ||
112 | |||
113 | /* past the point of no return, matches the initial value of 1 */ | ||
114 | if (atomic_dec_and_test(&group->num_marks)) | ||
115 | fsnotify_final_destroy_group(group); | ||
116 | } | ||
117 | |||
118 | /* | ||
78 | * Remove this group from the global list of groups that will get events | 119 | * Remove this group from the global list of groups that will get events |
79 | * this can be done even if there are still references and things still using | 120 | * this can be done even if there are still references and things still using |
80 | * this group. This just stops the group from getting new events. | 121 | * this group. This just stops the group from getting new events. |
@@ -173,6 +214,10 @@ struct fsnotify_group *fsnotify_obtain_group(unsigned int group_num, __u32 mask, | |||
173 | group->group_num = group_num; | 214 | group->group_num = group_num; |
174 | group->mask = mask; | 215 | group->mask = mask; |
175 | 216 | ||
217 | spin_lock_init(&group->mark_lock); | ||
218 | atomic_set(&group->num_marks, 0); | ||
219 | INIT_LIST_HEAD(&group->mark_entries); | ||
220 | |||
176 | group->ops = ops; | 221 | group->ops = ops; |
177 | 222 | ||
178 | mutex_lock(&fsnotify_grp_mutex); | 223 | mutex_lock(&fsnotify_grp_mutex); |
@@ -188,6 +233,8 @@ struct fsnotify_group *fsnotify_obtain_group(unsigned int group_num, __u32 mask, | |||
188 | /* group not found, add a new one */ | 233 | /* group not found, add a new one */ |
189 | list_add_rcu(&group->group_list, &fsnotify_groups); | 234 | list_add_rcu(&group->group_list, &fsnotify_groups); |
190 | group->on_group_list = 1; | 235 | group->on_group_list = 1; |
236 | /* being on the fsnotify_groups list holds one num_marks */ | ||
237 | atomic_inc(&group->num_marks); | ||
191 | 238 | ||
192 | mutex_unlock(&fsnotify_grp_mutex); | 239 | mutex_unlock(&fsnotify_grp_mutex); |
193 | 240 | ||
diff --git a/fs/notify/inode_mark.c b/fs/notify/inode_mark.c new file mode 100644 index 000000000000..cdc154146974 --- /dev/null +++ b/fs/notify/inode_mark.c | |||
@@ -0,0 +1,329 @@ | |||
1 | /* | ||
2 | * Copyright (C) 2008 Red Hat, Inc., Eric Paris <eparis@redhat.com> | ||
3 | * | ||
4 | * This program is free software; you can redistribute it and/or modify | ||
5 | * it under the terms of the GNU General Public License as published by | ||
6 | * the Free Software Foundation; either version 2, or (at your option) | ||
7 | * any later version. | ||
8 | * | ||
9 | * This program is distributed in the hope that it will be useful, | ||
10 | * but WITHOUT ANY WARRANTY; without even the implied warranty of | ||
11 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | ||
12 | * GNU General Public License for more details. | ||
13 | * | ||
14 | * You should have received a copy of the GNU General Public License | ||
15 | * along with this program; see the file COPYING. If not, write to | ||
16 | * the Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA. | ||
17 | */ | ||
18 | |||
19 | /* | ||
20 | * fsnotify inode mark locking/lifetime/and refcnting | ||
21 | * | ||
22 | * REFCNT: | ||
23 | * The mark->refcnt tells how many "things" in the kernel currently are | ||
24 | * referencing this object. The object typically will live inside the kernel | ||
25 | * with a refcnt of 2, one for each list it is on (i_list, g_list). Any task | ||
26 | * which can find this object holding the appropriete locks, can take a reference | ||
27 | * and the object itself is guarenteed to survive until the reference is dropped. | ||
28 | * | ||
29 | * LOCKING: | ||
30 | * There are 3 spinlocks involved with fsnotify inode marks and they MUST | ||
31 | * be taken in order as follows: | ||
32 | * | ||
33 | * entry->lock | ||
34 | * group->mark_lock | ||
35 | * inode->i_lock | ||
36 | * | ||
37 | * entry->lock protects 2 things, entry->group and entry->inode. You must hold | ||
38 | * that lock to dereference either of these things (they could be NULL even with | ||
39 | * the lock) | ||
40 | * | ||
41 | * group->mark_lock protects the mark_entries list anchored inside a given group | ||
42 | * and each entry is hooked via the g_list. It also sorta protects the | ||
43 | * free_g_list, which when used is anchored by a private list on the stack of the | ||
44 | * task which held the group->mark_lock. | ||
45 | * | ||
46 | * inode->i_lock protects the i_fsnotify_mark_entries list anchored inside a | ||
47 | * given inode and each entry is hooked via the i_list. (and sorta the | ||
48 | * free_i_list) | ||
49 | * | ||
50 | * | ||
51 | * LIFETIME: | ||
52 | * Inode marks survive between when they are added to an inode and when their | ||
53 | * refcnt==0. | ||
54 | * | ||
55 | * The inode mark can be cleared for a number of different reasons including: | ||
56 | * - The inode is unlinked for the last time. (fsnotify_inode_remove) | ||
57 | * - The inode is being evicted from cache. (fsnotify_inode_delete) | ||
58 | * - The fs the inode is on is unmounted. (fsnotify_inode_delete/fsnotify_unmount_inodes) | ||
59 | * - Something explicitly requests that it be removed. (fsnotify_destroy_mark_by_entry) | ||
60 | * - The fsnotify_group associated with the mark is going away and all such marks | ||
61 | * need to be cleaned up. (fsnotify_clear_marks_by_group) | ||
62 | * | ||
63 | * Worst case we are given an inode and need to clean up all the marks on that | ||
64 | * inode. We take i_lock and walk the i_fsnotify_mark_entries safely. For each | ||
65 | * mark on the list we take a reference (so the mark can't disappear under us). | ||
66 | * We remove that mark form the inode's list of marks and we add this mark to a | ||
67 | * private list anchored on the stack using i_free_list; At this point we no | ||
68 | * longer fear anything finding the mark using the inode's list of marks. | ||
69 | * | ||
70 | * We can safely and locklessly run the private list on the stack of everything | ||
71 | * we just unattached from the original inode. For each mark on the private list | ||
72 | * we grab the mark-> and can thus dereference mark->group and mark->inode. If | ||
73 | * we see the group and inode are not NULL we take those locks. Now holding all | ||
74 | * 3 locks we can completely remove the mark from other tasks finding it in the | ||
75 | * future. Remember, 10 things might already be referencing this mark, but they | ||
76 | * better be holding a ref. We drop our reference we took before we unhooked it | ||
77 | * from the inode. When the ref hits 0 we can free the mark. | ||
78 | * | ||
79 | * Very similarly for freeing by group, except we use free_g_list. | ||
80 | * | ||
81 | * This has the very interesting property of being able to run concurrently with | ||
82 | * any (or all) other directions. | ||
83 | */ | ||
84 | |||
85 | #include <linux/fs.h> | ||
86 | #include <linux/init.h> | ||
87 | #include <linux/kernel.h> | ||
88 | #include <linux/module.h> | ||
89 | #include <linux/mutex.h> | ||
90 | #include <linux/slab.h> | ||
91 | #include <linux/spinlock.h> | ||
92 | |||
93 | #include <asm/atomic.h> | ||
94 | |||
95 | #include <linux/fsnotify_backend.h> | ||
96 | #include "fsnotify.h" | ||
97 | |||
98 | void fsnotify_get_mark(struct fsnotify_mark_entry *entry) | ||
99 | { | ||
100 | atomic_inc(&entry->refcnt); | ||
101 | } | ||
102 | |||
103 | void fsnotify_put_mark(struct fsnotify_mark_entry *entry) | ||
104 | { | ||
105 | if (atomic_dec_and_test(&entry->refcnt)) | ||
106 | entry->free_mark(entry); | ||
107 | } | ||
108 | |||
109 | /* | ||
110 | * Recalculate the mask of events relevant to a given inode locked. | ||
111 | */ | ||
112 | static void fsnotify_recalc_inode_mask_locked(struct inode *inode) | ||
113 | { | ||
114 | struct fsnotify_mark_entry *entry; | ||
115 | struct hlist_node *pos; | ||
116 | __u32 new_mask = 0; | ||
117 | |||
118 | assert_spin_locked(&inode->i_lock); | ||
119 | |||
120 | hlist_for_each_entry(entry, pos, &inode->i_fsnotify_mark_entries, i_list) | ||
121 | new_mask |= entry->mask; | ||
122 | inode->i_fsnotify_mask = new_mask; | ||
123 | } | ||
124 | |||
125 | /* | ||
126 | * Recalculate the inode->i_fsnotify_mask, or the mask of all FS_* event types | ||
127 | * any notifier is interested in hearing for this inode. | ||
128 | */ | ||
129 | void fsnotify_recalc_inode_mask(struct inode *inode) | ||
130 | { | ||
131 | spin_lock(&inode->i_lock); | ||
132 | fsnotify_recalc_inode_mask_locked(inode); | ||
133 | spin_unlock(&inode->i_lock); | ||
134 | } | ||
135 | |||
136 | /* | ||
137 | * Any time a mark is getting freed we end up here. | ||
138 | * The caller had better be holding a reference to this mark so we don't actually | ||
139 | * do the final put under the entry->lock | ||
140 | */ | ||
141 | void fsnotify_destroy_mark_by_entry(struct fsnotify_mark_entry *entry) | ||
142 | { | ||
143 | struct fsnotify_group *group; | ||
144 | struct inode *inode; | ||
145 | |||
146 | spin_lock(&entry->lock); | ||
147 | |||
148 | group = entry->group; | ||
149 | inode = entry->inode; | ||
150 | |||
151 | BUG_ON(group && !inode); | ||
152 | BUG_ON(!group && inode); | ||
153 | |||
154 | /* if !group something else already marked this to die */ | ||
155 | if (!group) { | ||
156 | spin_unlock(&entry->lock); | ||
157 | return; | ||
158 | } | ||
159 | |||
160 | /* 1 from caller and 1 for being on i_list/g_list */ | ||
161 | BUG_ON(atomic_read(&entry->refcnt) < 2); | ||
162 | |||
163 | spin_lock(&group->mark_lock); | ||
164 | spin_lock(&inode->i_lock); | ||
165 | |||
166 | hlist_del_init(&entry->i_list); | ||
167 | entry->inode = NULL; | ||
168 | |||
169 | list_del_init(&entry->g_list); | ||
170 | entry->group = NULL; | ||
171 | |||
172 | fsnotify_put_mark(entry); /* for i_list and g_list */ | ||
173 | |||
174 | /* | ||
175 | * this mark is now off the inode->i_fsnotify_mark_entries list and we | ||
176 | * hold the inode->i_lock, so this is the perfect time to update the | ||
177 | * inode->i_fsnotify_mask | ||
178 | */ | ||
179 | fsnotify_recalc_inode_mask_locked(inode); | ||
180 | |||
181 | spin_unlock(&inode->i_lock); | ||
182 | spin_unlock(&group->mark_lock); | ||
183 | spin_unlock(&entry->lock); | ||
184 | |||
185 | /* | ||
186 | * Some groups like to know that marks are being freed. This is a | ||
187 | * callback to the group function to let it know that this entry | ||
188 | * is being freed. | ||
189 | */ | ||
190 | group->ops->freeing_mark(entry, group); | ||
191 | |||
192 | /* | ||
193 | * it's possible that this group tried to destroy itself, but this | ||
194 | * this mark was simultaneously being freed by inode. If that's the | ||
195 | * case, we finish freeing the group here. | ||
196 | */ | ||
197 | if (unlikely(atomic_dec_and_test(&group->num_marks))) | ||
198 | fsnotify_final_destroy_group(group); | ||
199 | } | ||
200 | |||
201 | /* | ||
202 | * Given a group, destroy all of the marks associated with that group. | ||
203 | */ | ||
204 | void fsnotify_clear_marks_by_group(struct fsnotify_group *group) | ||
205 | { | ||
206 | struct fsnotify_mark_entry *lentry, *entry; | ||
207 | LIST_HEAD(free_list); | ||
208 | |||
209 | spin_lock(&group->mark_lock); | ||
210 | list_for_each_entry_safe(entry, lentry, &group->mark_entries, g_list) { | ||
211 | list_add(&entry->free_g_list, &free_list); | ||
212 | list_del_init(&entry->g_list); | ||
213 | fsnotify_get_mark(entry); | ||
214 | } | ||
215 | spin_unlock(&group->mark_lock); | ||
216 | |||
217 | list_for_each_entry_safe(entry, lentry, &free_list, free_g_list) { | ||
218 | fsnotify_destroy_mark_by_entry(entry); | ||
219 | fsnotify_put_mark(entry); | ||
220 | } | ||
221 | } | ||
222 | |||
223 | /* | ||
224 | * Given an inode, destroy all of the marks associated with that inode. | ||
225 | */ | ||
226 | void fsnotify_clear_marks_by_inode(struct inode *inode) | ||
227 | { | ||
228 | struct fsnotify_mark_entry *entry, *lentry; | ||
229 | struct hlist_node *pos, *n; | ||
230 | LIST_HEAD(free_list); | ||
231 | |||
232 | spin_lock(&inode->i_lock); | ||
233 | hlist_for_each_entry_safe(entry, pos, n, &inode->i_fsnotify_mark_entries, i_list) { | ||
234 | list_add(&entry->free_i_list, &free_list); | ||
235 | hlist_del_init(&entry->i_list); | ||
236 | fsnotify_get_mark(entry); | ||
237 | } | ||
238 | spin_unlock(&inode->i_lock); | ||
239 | |||
240 | list_for_each_entry_safe(entry, lentry, &free_list, free_i_list) { | ||
241 | fsnotify_destroy_mark_by_entry(entry); | ||
242 | fsnotify_put_mark(entry); | ||
243 | } | ||
244 | } | ||
245 | |||
246 | /* | ||
247 | * given a group and inode, find the mark associated with that combination. | ||
248 | * if found take a reference to that mark and return it, else return NULL | ||
249 | */ | ||
250 | struct fsnotify_mark_entry *fsnotify_find_mark_entry(struct fsnotify_group *group, | ||
251 | struct inode *inode) | ||
252 | { | ||
253 | struct fsnotify_mark_entry *entry; | ||
254 | struct hlist_node *pos; | ||
255 | |||
256 | assert_spin_locked(&inode->i_lock); | ||
257 | |||
258 | hlist_for_each_entry(entry, pos, &inode->i_fsnotify_mark_entries, i_list) { | ||
259 | if (entry->group == group) { | ||
260 | fsnotify_get_mark(entry); | ||
261 | return entry; | ||
262 | } | ||
263 | } | ||
264 | return NULL; | ||
265 | } | ||
266 | |||
267 | /* | ||
268 | * Nothing fancy, just initialize lists and locks and counters. | ||
269 | */ | ||
270 | void fsnotify_init_mark(struct fsnotify_mark_entry *entry, | ||
271 | void (*free_mark)(struct fsnotify_mark_entry *entry)) | ||
272 | |||
273 | { | ||
274 | spin_lock_init(&entry->lock); | ||
275 | atomic_set(&entry->refcnt, 1); | ||
276 | INIT_HLIST_NODE(&entry->i_list); | ||
277 | entry->group = NULL; | ||
278 | entry->mask = 0; | ||
279 | entry->inode = NULL; | ||
280 | entry->free_mark = free_mark; | ||
281 | } | ||
282 | |||
283 | /* | ||
284 | * Attach an initialized mark entry to a given group and inode. | ||
285 | * These marks may be used for the fsnotify backend to determine which | ||
286 | * event types should be delivered to which group and for which inodes. | ||
287 | */ | ||
288 | int fsnotify_add_mark(struct fsnotify_mark_entry *entry, | ||
289 | struct fsnotify_group *group, struct inode *inode) | ||
290 | { | ||
291 | struct fsnotify_mark_entry *lentry; | ||
292 | int ret = 0; | ||
293 | |||
294 | /* | ||
295 | * LOCKING ORDER!!!! | ||
296 | * entry->lock | ||
297 | * group->mark_lock | ||
298 | * inode->i_lock | ||
299 | */ | ||
300 | spin_lock(&entry->lock); | ||
301 | spin_lock(&group->mark_lock); | ||
302 | spin_lock(&inode->i_lock); | ||
303 | |||
304 | entry->group = group; | ||
305 | entry->inode = inode; | ||
306 | |||
307 | lentry = fsnotify_find_mark_entry(group, inode); | ||
308 | if (!lentry) { | ||
309 | hlist_add_head(&entry->i_list, &inode->i_fsnotify_mark_entries); | ||
310 | list_add(&entry->g_list, &group->mark_entries); | ||
311 | |||
312 | fsnotify_get_mark(entry); /* for i_list and g_list */ | ||
313 | |||
314 | atomic_inc(&group->num_marks); | ||
315 | |||
316 | fsnotify_recalc_inode_mask_locked(inode); | ||
317 | } | ||
318 | |||
319 | spin_unlock(&inode->i_lock); | ||
320 | spin_unlock(&group->mark_lock); | ||
321 | spin_unlock(&entry->lock); | ||
322 | |||
323 | if (lentry) { | ||
324 | ret = -EEXIST; | ||
325 | fsnotify_put_mark(lentry); | ||
326 | } | ||
327 | |||
328 | return ret; | ||
329 | } | ||
diff --git a/include/linux/fs.h b/include/linux/fs.h index 83d6b4397245..275b0860044c 100644 --- a/include/linux/fs.h +++ b/include/linux/fs.h | |||
@@ -755,6 +755,11 @@ struct inode { | |||
755 | 755 | ||
756 | __u32 i_generation; | 756 | __u32 i_generation; |
757 | 757 | ||
758 | #ifdef CONFIG_FSNOTIFY | ||
759 | __u32 i_fsnotify_mask; /* all events this inode cares about */ | ||
760 | struct hlist_head i_fsnotify_mark_entries; /* fsnotify mark entries */ | ||
761 | #endif | ||
762 | |||
758 | #ifdef CONFIG_DNOTIFY | 763 | #ifdef CONFIG_DNOTIFY |
759 | unsigned long i_dnotify_mask; /* Directory notify events */ | 764 | unsigned long i_dnotify_mask; /* Directory notify events */ |
760 | struct dnotify_struct *i_dnotify; /* for directory notifications */ | 765 | struct dnotify_struct *i_dnotify; /* for directory notifications */ |
diff --git a/include/linux/fsnotify.h b/include/linux/fsnotify.h index 6c9ebefdac8e..3856eb6e5973 100644 --- a/include/linux/fsnotify.h +++ b/include/linux/fsnotify.h | |||
@@ -100,6 +100,14 @@ static inline void fsnotify_move(struct inode *old_dir, struct inode *new_dir, | |||
100 | } | 100 | } |
101 | 101 | ||
102 | /* | 102 | /* |
103 | * fsnotify_inode_delete - and inode is being evicted from cache, clean up is needed | ||
104 | */ | ||
105 | static inline void fsnotify_inode_delete(struct inode *inode) | ||
106 | { | ||
107 | __fsnotify_inode_delete(inode); | ||
108 | } | ||
109 | |||
110 | /* | ||
103 | * fsnotify_nameremove - a filename was removed from a directory | 111 | * fsnotify_nameremove - a filename was removed from a directory |
104 | */ | 112 | */ |
105 | static inline void fsnotify_nameremove(struct dentry *dentry, int isdir) | 113 | static inline void fsnotify_nameremove(struct dentry *dentry, int isdir) |
@@ -121,6 +129,7 @@ static inline void fsnotify_inoderemove(struct inode *inode) | |||
121 | inotify_inode_is_dead(inode); | 129 | inotify_inode_is_dead(inode); |
122 | 130 | ||
123 | fsnotify(inode, FS_DELETE_SELF, inode, FSNOTIFY_EVENT_INODE); | 131 | fsnotify(inode, FS_DELETE_SELF, inode, FSNOTIFY_EVENT_INODE); |
132 | __fsnotify_inode_delete(inode); | ||
124 | } | 133 | } |
125 | 134 | ||
126 | /* | 135 | /* |
diff --git a/include/linux/fsnotify_backend.h b/include/linux/fsnotify_backend.h index 1a55718b38aa..cad5c4d75c1d 100644 --- a/include/linux/fsnotify_backend.h +++ b/include/linux/fsnotify_backend.h | |||
@@ -48,17 +48,25 @@ | |||
48 | 48 | ||
49 | struct fsnotify_group; | 49 | struct fsnotify_group; |
50 | struct fsnotify_event; | 50 | struct fsnotify_event; |
51 | struct fsnotify_mark_entry; | ||
51 | 52 | ||
52 | /* | 53 | /* |
53 | * Each group much define these ops. The fsnotify infrastructure will call | 54 | * Each group much define these ops. The fsnotify infrastructure will call |
54 | * these operations for each relevant group. | 55 | * these operations for each relevant group. |
55 | * | 56 | * |
57 | * should_send_event - given a group, inode, and mask this function determines | ||
58 | * if the group is interested in this event. | ||
56 | * handle_event - main call for a group to handle an fs event | 59 | * handle_event - main call for a group to handle an fs event |
57 | * free_group_priv - called when a group refcnt hits 0 to clean up the private union | 60 | * free_group_priv - called when a group refcnt hits 0 to clean up the private union |
61 | * freeing-mark - this means that a mark has been flagged to die when everything | ||
62 | * finishes using it. The function is supplied with what must be a | ||
63 | * valid group and inode to use to clean up. | ||
58 | */ | 64 | */ |
59 | struct fsnotify_ops { | 65 | struct fsnotify_ops { |
66 | bool (*should_send_event)(struct fsnotify_group *group, struct inode *inode, __u32 mask); | ||
60 | int (*handle_event)(struct fsnotify_group *group, struct fsnotify_event *event); | 67 | int (*handle_event)(struct fsnotify_group *group, struct fsnotify_event *event); |
61 | void (*free_group_priv)(struct fsnotify_group *group); | 68 | void (*free_group_priv)(struct fsnotify_group *group); |
69 | void (*freeing_mark)(struct fsnotify_mark_entry *entry, struct fsnotify_group *group); | ||
62 | }; | 70 | }; |
63 | 71 | ||
64 | /* | 72 | /* |
@@ -97,7 +105,14 @@ struct fsnotify_group { | |||
97 | 105 | ||
98 | const struct fsnotify_ops *ops; /* how this group handles things */ | 106 | const struct fsnotify_ops *ops; /* how this group handles things */ |
99 | 107 | ||
100 | /* prevents double list_del of group_list. protected by global fsnotify_gr_mutex */ | 108 | /* stores all fastapth entries assoc with this group so they can be cleaned on unregister */ |
109 | spinlock_t mark_lock; /* protect mark_entries list */ | ||
110 | atomic_t num_marks; /* 1 for each mark entry and 1 for not being | ||
111 | * past the point of no return when freeing | ||
112 | * a group */ | ||
113 | struct list_head mark_entries; /* all inode mark entries for this group */ | ||
114 | |||
115 | /* prevents double list_del of group_list. protected by global fsnotify_grp_mutex */ | ||
101 | bool on_group_list; | 116 | bool on_group_list; |
102 | 117 | ||
103 | /* groups can define private fields here or use the void *private */ | 118 | /* groups can define private fields here or use the void *private */ |
@@ -137,12 +152,38 @@ struct fsnotify_event { | |||
137 | __u32 mask; /* the type of access, bitwise OR for FS_* event types */ | 152 | __u32 mask; /* the type of access, bitwise OR for FS_* event types */ |
138 | }; | 153 | }; |
139 | 154 | ||
155 | /* | ||
156 | * a mark is simply an entry attached to an in core inode which allows an | ||
157 | * fsnotify listener to indicate they are either no longer interested in events | ||
158 | * of a type matching mask or only interested in those events. | ||
159 | * | ||
160 | * these are flushed when an inode is evicted from core and may be flushed | ||
161 | * when the inode is modified (as seen by fsnotify_access). Some fsnotify users | ||
162 | * (such as dnotify) will flush these when the open fd is closed and not at | ||
163 | * inode eviction or modification. | ||
164 | */ | ||
165 | struct fsnotify_mark_entry { | ||
166 | __u32 mask; /* mask this mark entry is for */ | ||
167 | /* we hold ref for each i_list and g_list. also one ref for each 'thing' | ||
168 | * in kernel that found and may be using this mark. */ | ||
169 | atomic_t refcnt; /* active things looking at this mark */ | ||
170 | struct inode *inode; /* inode this entry is associated with */ | ||
171 | struct fsnotify_group *group; /* group this mark entry is for */ | ||
172 | struct hlist_node i_list; /* list of mark_entries by inode->i_fsnotify_mark_entries */ | ||
173 | struct list_head g_list; /* list of mark_entries by group->i_fsnotify_mark_entries */ | ||
174 | spinlock_t lock; /* protect group, inode, and killme */ | ||
175 | struct list_head free_i_list; /* tmp list used when freeing this mark */ | ||
176 | struct list_head free_g_list; /* tmp list used when freeing this mark */ | ||
177 | void (*free_mark)(struct fsnotify_mark_entry *entry); /* called on final put+free */ | ||
178 | }; | ||
179 | |||
140 | #ifdef CONFIG_FSNOTIFY | 180 | #ifdef CONFIG_FSNOTIFY |
141 | 181 | ||
142 | /* called from the vfs helpers */ | 182 | /* called from the vfs helpers */ |
143 | 183 | ||
144 | /* main fsnotify call to send events */ | 184 | /* main fsnotify call to send events */ |
145 | extern void fsnotify(struct inode *to_tell, __u32 mask, void *data, int data_is); | 185 | extern void fsnotify(struct inode *to_tell, __u32 mask, void *data, int data_is); |
186 | extern void __fsnotify_inode_delete(struct inode *inode); | ||
146 | 187 | ||
147 | 188 | ||
148 | /* called from fsnotify listeners, such as fanotify or dnotify */ | 189 | /* called from fsnotify listeners, such as fanotify or dnotify */ |
@@ -153,6 +194,8 @@ extern void fsnotify_recalc_global_mask(void); | |||
153 | extern struct fsnotify_group *fsnotify_obtain_group(unsigned int group_num, | 194 | extern struct fsnotify_group *fsnotify_obtain_group(unsigned int group_num, |
154 | __u32 mask, | 195 | __u32 mask, |
155 | const struct fsnotify_ops *ops); | 196 | const struct fsnotify_ops *ops); |
197 | /* run all marks associated with this group and update group->mask */ | ||
198 | extern void fsnotify_recalc_group_mask(struct fsnotify_group *group); | ||
156 | /* drop reference on a group from fsnotify_obtain_group */ | 199 | /* drop reference on a group from fsnotify_obtain_group */ |
157 | extern void fsnotify_put_group(struct fsnotify_group *group); | 200 | extern void fsnotify_put_group(struct fsnotify_group *group); |
158 | 201 | ||
@@ -163,6 +206,22 @@ extern void fsnotify_put_event(struct fsnotify_event *event); | |||
163 | extern struct fsnotify_event_private_data *fsnotify_get_priv_from_event(struct fsnotify_group *group, | 206 | extern struct fsnotify_event_private_data *fsnotify_get_priv_from_event(struct fsnotify_group *group, |
164 | struct fsnotify_event *event); | 207 | struct fsnotify_event *event); |
165 | 208 | ||
209 | /* functions used to manipulate the marks attached to inodes */ | ||
210 | |||
211 | /* run all marks associated with an inode and update inode->i_fsnotify_mask */ | ||
212 | extern void fsnotify_recalc_inode_mask(struct inode *inode); | ||
213 | extern void fsnotify_init_mark(struct fsnotify_mark_entry *entry, void (*free_mark)(struct fsnotify_mark_entry *entry)); | ||
214 | /* find (and take a reference) to a mark associated with group and inode */ | ||
215 | extern struct fsnotify_mark_entry *fsnotify_find_mark_entry(struct fsnotify_group *group, struct inode *inode); | ||
216 | /* attach the mark to both the group and the inode */ | ||
217 | extern int fsnotify_add_mark(struct fsnotify_mark_entry *entry, struct fsnotify_group *group, struct inode *inode); | ||
218 | /* given a mark, flag it to be freed when all references are dropped */ | ||
219 | extern void fsnotify_destroy_mark_by_entry(struct fsnotify_mark_entry *entry); | ||
220 | /* run all the marks in a group, and flag them to be freed */ | ||
221 | extern void fsnotify_clear_marks_by_group(struct fsnotify_group *group); | ||
222 | extern void fsnotify_get_mark(struct fsnotify_mark_entry *entry); | ||
223 | extern void fsnotify_put_mark(struct fsnotify_mark_entry *entry); | ||
224 | |||
166 | /* put here because inotify does some weird stuff when destroying watches */ | 225 | /* put here because inotify does some weird stuff when destroying watches */ |
167 | extern struct fsnotify_event *fsnotify_create_event(struct inode *to_tell, __u32 mask, | 226 | extern struct fsnotify_event *fsnotify_create_event(struct inode *to_tell, __u32 mask, |
168 | void *data, int data_is); | 227 | void *data, int data_is); |
@@ -170,6 +229,10 @@ extern struct fsnotify_event *fsnotify_create_event(struct inode *to_tell, __u32 | |||
170 | 229 | ||
171 | static inline void fsnotify(struct inode *to_tell, __u32 mask, void *data, int data_is) | 230 | static inline void fsnotify(struct inode *to_tell, __u32 mask, void *data, int data_is) |
172 | {} | 231 | {} |
232 | |||
233 | static inline void __fsnotify_inode_delete(struct inode *inode) | ||
234 | {} | ||
235 | |||
173 | #endif /* CONFIG_FSNOTIFY */ | 236 | #endif /* CONFIG_FSNOTIFY */ |
174 | 237 | ||
175 | #endif /* __KERNEL __ */ | 238 | #endif /* __KERNEL __ */ |