aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorEric Paris <eparis@redhat.com>2009-05-21 17:01:26 -0400
committerEric Paris <eparis@redhat.com>2009-06-11 14:57:53 -0400
commit3be25f49b9d6a97eae9bcb96d3292072b7658bd8 (patch)
tree36f7d96481a47a6bde3c2f961346e940698111e0
parent90586523eb4b349806887c62ee70685a49415124 (diff)
fsnotify: add marks to inodes so groups can interpret how to handle those inodes
This patch creates a way for fsnotify groups to attach marks to inodes. These marks have little meaning to the generic fsnotify infrastructure and thus their meaning should be interpreted by the group that attached them to the inode's list. dnotify and inotify will make use of these markings to indicate which inodes are of interest to their respective groups. But this implementation has the useful property that in the future other listeners could actually use the marks for the exact opposite reason, aka to indicate which inodes it had NO interest in. Signed-off-by: Eric Paris <eparis@redhat.com> Acked-by: Al Viro <viro@zeniv.linux.org.uk> Cc: Christoph Hellwig <hch@lst.de>
-rw-r--r--fs/inode.c9
-rw-r--r--fs/notify/Makefile2
-rw-r--r--fs/notify/fsnotify.c13
-rw-r--r--fs/notify/fsnotify.h5
-rw-r--r--fs/notify/group.c49
-rw-r--r--fs/notify/inode_mark.c329
-rw-r--r--include/linux/fs.h5
-rw-r--r--include/linux/fsnotify.h9
-rw-r--r--include/linux/fsnotify_backend.h65
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
194out_free_security: 199out_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}
256EXPORT_SYMBOL(inode_init_once); 265EXPORT_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 @@
1obj-$(CONFIG_FSNOTIFY) += fsnotify.o notification.o group.o 1obj-$(CONFIG_FSNOTIFY) += fsnotify.o notification.o group.o inode_mark.o
2 2
3obj-y += dnotify/ 3obj-y += dnotify/
4obj-y += inotify/ 4obj-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 */
31void __fsnotify_inode_delete(struct inode *inode)
32{
33 fsnotify_clear_marks_by_inode(inode);
34}
35EXPORT_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;
12extern struct list_head fsnotify_groups; 12extern 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 */
14extern __u32 fsnotify_mask; 14extern __u32 fsnotify_mask;
15
16/* final kfree of a group */
17extern 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 */
19extern 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 */
63void 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 */
69static void fsnotify_destroy_group(struct fsnotify_group *group) 92void 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 */
108static 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
98void fsnotify_get_mark(struct fsnotify_mark_entry *entry)
99{
100 atomic_inc(&entry->refcnt);
101}
102
103void 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 */
112static 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 */
129void 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 */
141void 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 */
204void 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 */
226void 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 */
250struct 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 */
270void 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 */
288int 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 */
105static 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 */
105static inline void fsnotify_nameremove(struct dentry *dentry, int isdir) 113static 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
49struct fsnotify_group; 49struct fsnotify_group;
50struct fsnotify_event; 50struct fsnotify_event;
51struct 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 */
59struct fsnotify_ops { 65struct 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 */
165struct 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 */
145extern void fsnotify(struct inode *to_tell, __u32 mask, void *data, int data_is); 185extern void fsnotify(struct inode *to_tell, __u32 mask, void *data, int data_is);
186extern 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);
153extern struct fsnotify_group *fsnotify_obtain_group(unsigned int group_num, 194extern 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 */
198extern 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 */
157extern void fsnotify_put_group(struct fsnotify_group *group); 200extern void fsnotify_put_group(struct fsnotify_group *group);
158 201
@@ -163,6 +206,22 @@ extern void fsnotify_put_event(struct fsnotify_event *event);
163extern struct fsnotify_event_private_data *fsnotify_get_priv_from_event(struct fsnotify_group *group, 206extern 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 */
212extern void fsnotify_recalc_inode_mask(struct inode *inode);
213extern 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 */
215extern 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 */
217extern 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 */
219extern 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 */
221extern void fsnotify_clear_marks_by_group(struct fsnotify_group *group);
222extern void fsnotify_get_mark(struct fsnotify_mark_entry *entry);
223extern 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 */
167extern struct fsnotify_event *fsnotify_create_event(struct inode *to_tell, __u32 mask, 226extern 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
171static inline void fsnotify(struct inode *to_tell, __u32 mask, void *data, int data_is) 230static inline void fsnotify(struct inode *to_tell, __u32 mask, void *data, int data_is)
172{} 231{}
232
233static 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 __ */