]> git.proxmox.com Git - mirror_ubuntu-bionic-kernel.git/blame - fs/notify/mark.c
fsnotify: Detach mark from object list when last reference is dropped
[mirror_ubuntu-bionic-kernel.git] / fs / notify / mark.c
CommitLineData
5444e298
EP
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:
9756b918
LS
23 * The group->recnt and mark->refcnt tell how many "things" in the kernel
24 * currently are referencing the objects. Both kind of objects typically will
25 * live inside the kernel with a refcnt of 2, one for its creation and one for
26 * the reference a group and a mark hold to each other.
27 * If you are holding the appropriate locks, you can take a reference and the
28 * object itself is guaranteed to survive until the reference is dropped.
5444e298
EP
29 *
30 * LOCKING:
9756b918
LS
31 * There are 3 locks involved with fsnotify inode marks and they MUST be taken
32 * in order as follows:
5444e298 33 *
9756b918 34 * group->mark_mutex
5444e298 35 * mark->lock
04662cab 36 * mark->connector->lock
5444e298 37 *
9756b918
LS
38 * group->mark_mutex protects the marks_list anchored inside a given group and
39 * each mark is hooked via the g_list. It also protects the groups private
40 * data (i.e group limits).
41
42 * mark->lock protects the marks attributes like its masks and flags.
43 * Furthermore it protects the access to a reference of the group that the mark
44 * is assigned to as well as the access to a reference of the inode/vfsmount
45 * that is being watched by the mark.
5444e298 46 *
04662cab
JK
47 * mark->connector->lock protects the list of marks anchored inside an
48 * inode / vfsmount and each mark is hooked via the i_list.
5444e298 49 *
04662cab
JK
50 * A list of notification marks relating to inode / mnt is contained in
51 * fsnotify_mark_connector. That structure is alive as long as there are any
6b3f05d2
JK
52 * marks in the list and is also protected by fsnotify_mark_srcu. A mark gets
53 * detached from fsnotify_mark_connector when last reference to the mark is
54 * dropped. Thus having mark reference is enough to protect mark->connector
55 * pointer and to make sure fsnotify_mark_connector cannot disappear. Also
56 * because we remove mark from g_list before dropping mark reference associated
57 * with that, any mark found through g_list is guaranteed to have
58 * mark->connector set until we drop group->mark_mutex.
5444e298
EP
59 *
60 * LIFETIME:
61 * Inode marks survive between when they are added to an inode and when their
c1f33073 62 * refcnt==0. Marks are also protected by fsnotify_mark_srcu.
5444e298
EP
63 *
64 * The inode mark can be cleared for a number of different reasons including:
65 * - The inode is unlinked for the last time. (fsnotify_inode_remove)
66 * - The inode is being evicted from cache. (fsnotify_inode_delete)
67 * - The fs the inode is on is unmounted. (fsnotify_inode_delete/fsnotify_unmount_inodes)
68 * - Something explicitly requests that it be removed. (fsnotify_destroy_mark)
69 * - The fsnotify_group associated with the mark is going away and all such marks
70 * need to be cleaned up. (fsnotify_clear_marks_by_group)
71 *
5444e298
EP
72 * This has the very interesting property of being able to run concurrently with
73 * any (or all) other directions.
74 */
75
76#include <linux/fs.h>
77#include <linux/init.h>
78#include <linux/kernel.h>
75c1be48 79#include <linux/kthread.h>
5444e298
EP
80#include <linux/module.h>
81#include <linux/mutex.h>
82#include <linux/slab.h>
83#include <linux/spinlock.h>
75c1be48 84#include <linux/srcu.h>
5444e298 85
60063497 86#include <linux/atomic.h>
5444e298
EP
87
88#include <linux/fsnotify_backend.h>
89#include "fsnotify.h"
90
0918f1c3
JL
91#define FSNOTIFY_REAPER_DELAY (1) /* 1 jiffy */
92
75c1be48 93struct srcu_struct fsnotify_mark_srcu;
9dd813c1
JK
94struct kmem_cache *fsnotify_mark_connector_cachep;
95
13d34ac6
JL
96static DEFINE_SPINLOCK(destroy_lock);
97static LIST_HEAD(destroy_list);
08991e83 98static struct fsnotify_mark_connector *connector_destroy_list;
0918f1c3 99
35e48176
JK
100static void fsnotify_mark_destroy_workfn(struct work_struct *work);
101static DECLARE_DELAYED_WORK(reaper_work, fsnotify_mark_destroy_workfn);
75c1be48 102
08991e83
JK
103static void fsnotify_connector_destroy_workfn(struct work_struct *work);
104static DECLARE_WORK(connector_reaper_work, fsnotify_connector_destroy_workfn);
105
5444e298
EP
106void fsnotify_get_mark(struct fsnotify_mark *mark)
107{
11375145 108 WARN_ON_ONCE(!atomic_read(&mark->refcnt));
5444e298
EP
109 atomic_inc(&mark->refcnt);
110}
111
a242677b 112static void __fsnotify_recalc_mask(struct fsnotify_mark_connector *conn)
0809ab69
JK
113{
114 u32 new_mask = 0;
115 struct fsnotify_mark *mark;
116
04662cab 117 assert_spin_locked(&conn->lock);
6b3f05d2
JK
118 hlist_for_each_entry(mark, &conn->list, obj_list) {
119 if (mark->flags & FSNOTIFY_MARK_FLAG_ATTACHED)
120 new_mask |= mark->mask;
121 }
a242677b
JK
122 if (conn->flags & FSNOTIFY_OBJ_TYPE_INODE)
123 conn->inode->i_fsnotify_mask = new_mask;
124 else if (conn->flags & FSNOTIFY_OBJ_TYPE_VFSMOUNT)
125 real_mount(conn->mnt)->mnt_fsnotify_mask = new_mask;
126}
127
128/*
129 * Calculate mask of events for a list of marks. The caller must make sure
6b3f05d2
JK
130 * connector and connector->inode cannot disappear under us. Callers achieve
131 * this by holding a mark->lock or mark->group->mark_mutex for a mark on this
132 * list.
a242677b
JK
133 */
134void fsnotify_recalc_mask(struct fsnotify_mark_connector *conn)
135{
136 if (!conn)
137 return;
138
04662cab 139 spin_lock(&conn->lock);
a242677b 140 __fsnotify_recalc_mask(conn);
04662cab
JK
141 spin_unlock(&conn->lock);
142 if (conn->flags & FSNOTIFY_OBJ_TYPE_INODE)
a242677b 143 __fsnotify_update_child_dentry_flags(conn->inode);
0809ab69
JK
144}
145
08991e83
JK
146/* Free all connectors queued for freeing once SRCU period ends */
147static void fsnotify_connector_destroy_workfn(struct work_struct *work)
148{
149 struct fsnotify_mark_connector *conn, *free;
150
151 spin_lock(&destroy_lock);
152 conn = connector_destroy_list;
153 connector_destroy_list = NULL;
154 spin_unlock(&destroy_lock);
155
156 synchronize_srcu(&fsnotify_mark_srcu);
157 while (conn) {
158 free = conn;
159 conn = conn->destroy_next;
160 kmem_cache_free(fsnotify_mark_connector_cachep, free);
161 }
162}
163
08991e83
JK
164static struct inode *fsnotify_detach_connector_from_object(
165 struct fsnotify_mark_connector *conn)
166{
167 struct inode *inode = NULL;
168
169 if (conn->flags & FSNOTIFY_OBJ_TYPE_INODE) {
170 inode = conn->inode;
171 rcu_assign_pointer(inode->i_fsnotify_marks, NULL);
172 inode->i_fsnotify_mask = 0;
173 conn->inode = NULL;
174 conn->flags &= ~FSNOTIFY_OBJ_TYPE_INODE;
175 } else if (conn->flags & FSNOTIFY_OBJ_TYPE_VFSMOUNT) {
176 rcu_assign_pointer(real_mount(conn->mnt)->mnt_fsnotify_marks,
177 NULL);
178 real_mount(conn->mnt)->mnt_fsnotify_mask = 0;
179 conn->mnt = NULL;
180 conn->flags &= ~FSNOTIFY_OBJ_TYPE_VFSMOUNT;
181 }
182
183 return inode;
184}
185
6b3f05d2
JK
186static void fsnotify_final_mark_destroy(struct fsnotify_mark *mark)
187{
188 if (mark->group)
189 fsnotify_put_group(mark->group);
190 mark->free_mark(mark);
191}
192
193void fsnotify_put_mark(struct fsnotify_mark *mark)
8212a609
JK
194{
195 struct fsnotify_mark_connector *conn;
196 struct inode *inode = NULL;
08991e83 197 bool free_conn = false;
8212a609 198
6b3f05d2
JK
199 /* Catch marks that were actually never attached to object */
200 if (!mark->connector) {
201 if (atomic_dec_and_test(&mark->refcnt))
202 fsnotify_final_mark_destroy(mark);
203 return;
204 }
205
206 /*
207 * We have to be careful so that traversals of obj_list under lock can
208 * safely grab mark reference.
209 */
210 if (!atomic_dec_and_lock(&mark->refcnt, &mark->connector->lock))
211 return;
212
8212a609 213 conn = mark->connector;
8212a609
JK
214 hlist_del_init_rcu(&mark->obj_list);
215 if (hlist_empty(&conn->list)) {
08991e83
JK
216 inode = fsnotify_detach_connector_from_object(conn);
217 free_conn = true;
218 } else {
219 __fsnotify_recalc_mask(conn);
8212a609
JK
220 }
221 mark->connector = NULL;
04662cab 222 spin_unlock(&conn->lock);
8212a609 223
6b3f05d2
JK
224 iput(inode);
225
08991e83
JK
226 if (free_conn) {
227 spin_lock(&destroy_lock);
228 conn->destroy_next = connector_destroy_list;
229 connector_destroy_list = conn;
230 spin_unlock(&destroy_lock);
231 queue_work(system_unbound_wq, &connector_reaper_work);
232 }
6b3f05d2
JK
233 /*
234 * Note that we didn't update flags telling whether inode cares about
235 * what's happening with children. We update these flags from
236 * __fsnotify_parent() lazily when next event happens on one of our
237 * children.
238 */
239 spin_lock(&destroy_lock);
240 list_add(&mark->g_list, &destroy_list);
241 spin_unlock(&destroy_lock);
242 queue_delayed_work(system_unbound_wq, &reaper_work,
243 FSNOTIFY_REAPER_DELAY);
8212a609
JK
244}
245
5444e298 246/*
6b3f05d2
JK
247 * Mark mark as detached, remove it from group list. Mark still stays in object
248 * list until its last reference is dropped. Note that we rely on mark being
249 * removed from group list before corresponding reference to it is dropped. In
250 * particular we rely on mark->connector being valid while we hold
251 * group->mark_mutex if we found the mark through g_list.
4712e722 252 *
11375145
JK
253 * Must be called with group->mark_mutex held. The caller must either hold
254 * reference to the mark or be protected by fsnotify_mark_srcu.
5444e298 255 */
4712e722 256void fsnotify_detach_mark(struct fsnotify_mark *mark)
5444e298 257{
4712e722 258 struct fsnotify_group *group = mark->group;
5444e298 259
11375145
JK
260 WARN_ON_ONCE(!mutex_is_locked(&group->mark_mutex));
261 WARN_ON_ONCE(!srcu_read_lock_held(&fsnotify_mark_srcu) &&
262 atomic_read(&mark->refcnt) < 1 +
263 !!(mark->flags & FSNOTIFY_MARK_FLAG_ATTACHED));
d5a335b8 264
104d06f0 265 spin_lock(&mark->lock);
700307a2 266 /* something else already called this function on this mark */
4712e722 267 if (!(mark->flags & FSNOTIFY_MARK_FLAG_ATTACHED)) {
5444e298 268 spin_unlock(&mark->lock);
e2a29943 269 return;
5444e298 270 }
4712e722 271 mark->flags &= ~FSNOTIFY_MARK_FLAG_ATTACHED;
5444e298 272 list_del_init(&mark->g_list);
5444e298 273 spin_unlock(&mark->lock);
d5a335b8 274
4712e722 275 atomic_dec(&group->num_marks);
11375145
JK
276
277 /* Drop mark reference acquired in fsnotify_add_mark_locked() */
278 fsnotify_put_mark(mark);
4712e722
JK
279}
280
281/*
11375145
JK
282 * Free fsnotify mark. The mark is actually only marked as being freed. The
283 * freeing is actually happening only once last reference to the mark is
284 * dropped from a workqueue which first waits for srcu period end.
35e48176 285 *
11375145
JK
286 * Caller must have a reference to the mark or be protected by
287 * fsnotify_mark_srcu.
4712e722 288 */
11375145 289void fsnotify_free_mark(struct fsnotify_mark *mark)
4712e722
JK
290{
291 struct fsnotify_group *group = mark->group;
292
293 spin_lock(&mark->lock);
294 /* something else already called this function on this mark */
295 if (!(mark->flags & FSNOTIFY_MARK_FLAG_ALIVE)) {
296 spin_unlock(&mark->lock);
11375145 297 return;
4712e722
JK
298 }
299 mark->flags &= ~FSNOTIFY_MARK_FLAG_ALIVE;
300 spin_unlock(&mark->lock);
5444e298 301
d725e66c
LT
302 /*
303 * Some groups like to know that marks are being freed. This is a
304 * callback to the group function to let it know that this mark
305 * is being freed.
306 */
307 if (group->ops->freeing_mark)
308 group->ops->freeing_mark(mark, group);
d5a335b8
LS
309}
310
311void fsnotify_destroy_mark(struct fsnotify_mark *mark,
312 struct fsnotify_group *group)
313{
6960b0d9 314 mutex_lock_nested(&group->mark_mutex, SINGLE_DEPTH_NESTING);
4712e722 315 fsnotify_detach_mark(mark);
d5a335b8 316 mutex_unlock(&group->mark_mutex);
4712e722 317 fsnotify_free_mark(mark);
5444e298
EP
318}
319
90b1e7a5
EP
320void fsnotify_set_mark_mask_locked(struct fsnotify_mark *mark, __u32 mask)
321{
322 assert_spin_locked(&mark->lock);
323
324 mark->mask = mask;
90b1e7a5
EP
325}
326
33af5e32
EP
327void fsnotify_set_mark_ignored_mask_locked(struct fsnotify_mark *mark, __u32 mask)
328{
329 assert_spin_locked(&mark->lock);
330
331 mark->ignored_mask = mask;
332}
90b1e7a5 333
8edc6e16
JK
334/*
335 * Sorting function for lists of fsnotify marks.
336 *
337 * Fanotify supports different notification classes (reflected as priority of
338 * notification group). Events shall be passed to notification groups in
339 * decreasing priority order. To achieve this marks in notification lists for
340 * inodes and vfsmounts are sorted so that priorities of corresponding groups
341 * are descending.
342 *
343 * Furthermore correct handling of the ignore mask requires processing inode
344 * and vfsmount marks of each group together. Using the group address as
345 * further sort criterion provides a unique sorting order and thus we can
346 * merge inode and vfsmount lists of marks in linear time and find groups
347 * present in both lists.
348 *
349 * A return value of 1 signifies that b has priority over a.
350 * A return value of 0 signifies that the two marks have to be handled together.
351 * A return value of -1 signifies that a has priority over b.
352 */
353int fsnotify_compare_groups(struct fsnotify_group *a, struct fsnotify_group *b)
354{
355 if (a == b)
356 return 0;
357 if (!a)
358 return 1;
359 if (!b)
360 return -1;
361 if (a->priority < b->priority)
362 return 1;
363 if (a->priority > b->priority)
364 return -1;
365 if (a < b)
366 return 1;
367 return -1;
368}
369
9dd813c1 370static int fsnotify_attach_connector_to_object(
08991e83
JK
371 struct fsnotify_mark_connector __rcu **connp,
372 struct inode *inode,
373 struct vfsmount *mnt)
9dd813c1
JK
374{
375 struct fsnotify_mark_connector *conn;
376
755b5bc6 377 conn = kmem_cache_alloc(fsnotify_mark_connector_cachep, GFP_KERNEL);
9dd813c1
JK
378 if (!conn)
379 return -ENOMEM;
04662cab 380 spin_lock_init(&conn->lock);
9dd813c1 381 INIT_HLIST_HEAD(&conn->list);
86ffe245
JK
382 if (inode) {
383 conn->flags = FSNOTIFY_OBJ_TYPE_INODE;
08991e83 384 conn->inode = igrab(inode);
86ffe245
JK
385 } else {
386 conn->flags = FSNOTIFY_OBJ_TYPE_VFSMOUNT;
387 conn->mnt = mnt;
388 }
9dd813c1 389 /*
04662cab
JK
390 * cmpxchg() provides the barrier so that readers of *connp can see
391 * only initialized structure
9dd813c1 392 */
04662cab
JK
393 if (cmpxchg(connp, NULL, conn)) {
394 /* Someone else created list structure for us */
08991e83
JK
395 if (inode)
396 iput(inode);
755b5bc6 397 kmem_cache_free(fsnotify_mark_connector_cachep, conn);
04662cab 398 }
9dd813c1
JK
399
400 return 0;
401}
402
08991e83
JK
403/*
404 * Get mark connector, make sure it is alive and return with its lock held.
405 * This is for users that get connector pointer from inode or mount. Users that
406 * hold reference to a mark on the list may directly lock connector->lock as
407 * they are sure list cannot go away under them.
408 */
409static struct fsnotify_mark_connector *fsnotify_grab_connector(
410 struct fsnotify_mark_connector __rcu **connp)
411{
412 struct fsnotify_mark_connector *conn;
413 int idx;
414
415 idx = srcu_read_lock(&fsnotify_mark_srcu);
416 conn = srcu_dereference(*connp, &fsnotify_mark_srcu);
417 if (!conn)
418 goto out;
419 spin_lock(&conn->lock);
420 if (!(conn->flags & (FSNOTIFY_OBJ_TYPE_INODE |
421 FSNOTIFY_OBJ_TYPE_VFSMOUNT))) {
422 spin_unlock(&conn->lock);
423 srcu_read_unlock(&fsnotify_mark_srcu, idx);
424 return NULL;
425 }
426out:
427 srcu_read_unlock(&fsnotify_mark_srcu, idx);
428 return conn;
429}
430
9dd813c1
JK
431/*
432 * Add mark into proper place in given list of marks. These marks may be used
433 * for the fsnotify backend to determine which event types should be delivered
434 * to which group and for which inodes. These marks are ordered according to
435 * priority, highest number first, and then by the group's location in memory.
436 */
755b5bc6
JK
437static int fsnotify_add_mark_list(struct fsnotify_mark *mark,
438 struct inode *inode, struct vfsmount *mnt,
439 int allow_dups)
0809ab69
JK
440{
441 struct fsnotify_mark *lmark, *last = NULL;
9dd813c1 442 struct fsnotify_mark_connector *conn;
08991e83 443 struct fsnotify_mark_connector __rcu **connp;
0809ab69 444 int cmp;
755b5bc6
JK
445 int err = 0;
446
447 if (WARN_ON(!inode && !mnt))
448 return -EINVAL;
04662cab 449 if (inode)
755b5bc6 450 connp = &inode->i_fsnotify_marks;
04662cab 451 else
755b5bc6 452 connp = &real_mount(mnt)->mnt_fsnotify_marks;
08991e83
JK
453restart:
454 spin_lock(&mark->lock);
455 conn = fsnotify_grab_connector(connp);
456 if (!conn) {
457 spin_unlock(&mark->lock);
04662cab 458 err = fsnotify_attach_connector_to_object(connp, inode, mnt);
9dd813c1
JK
459 if (err)
460 return err;
08991e83 461 goto restart;
9dd813c1 462 }
0809ab69
JK
463
464 /* is mark the first mark? */
9dd813c1
JK
465 if (hlist_empty(&conn->list)) {
466 hlist_add_head_rcu(&mark->obj_list, &conn->list);
86ffe245 467 goto added;
0809ab69
JK
468 }
469
470 /* should mark be in the middle of the current list? */
9dd813c1 471 hlist_for_each_entry(lmark, &conn->list, obj_list) {
0809ab69
JK
472 last = lmark;
473
6b3f05d2
JK
474 if ((lmark->group == mark->group) &&
475 (lmark->flags & FSNOTIFY_MARK_FLAG_ATTACHED) &&
476 !allow_dups) {
755b5bc6
JK
477 err = -EEXIST;
478 goto out_err;
479 }
0809ab69
JK
480
481 cmp = fsnotify_compare_groups(lmark->group, mark->group);
482 if (cmp >= 0) {
483 hlist_add_before_rcu(&mark->obj_list, &lmark->obj_list);
86ffe245 484 goto added;
0809ab69
JK
485 }
486 }
487
488 BUG_ON(last == NULL);
489 /* mark should be the last entry. last is the current last entry */
490 hlist_add_behind_rcu(&mark->obj_list, &last->obj_list);
86ffe245
JK
491added:
492 mark->connector = conn;
755b5bc6 493out_err:
04662cab 494 spin_unlock(&conn->lock);
755b5bc6
JK
495 spin_unlock(&mark->lock);
496 return err;
0809ab69
JK
497}
498
5444e298
EP
499/*
500 * Attach an initialized mark to a given group and fs object.
501 * These marks may be used for the fsnotify backend to determine which
502 * event types should be delivered to which group.
503 */
d5a335b8
LS
504int fsnotify_add_mark_locked(struct fsnotify_mark *mark,
505 struct fsnotify_group *group, struct inode *inode,
506 struct vfsmount *mnt, int allow_dups)
5444e298
EP
507{
508 int ret = 0;
509
5444e298
EP
510 BUG_ON(inode && mnt);
511 BUG_ON(!inode && !mnt);
d5a335b8 512 BUG_ON(!mutex_is_locked(&group->mark_mutex));
5444e298 513
5444e298
EP
514 /*
515 * LOCKING ORDER!!!!
986ab098 516 * group->mark_mutex
104d06f0 517 * mark->lock
04662cab 518 * mark->connector->lock
5444e298 519 */
104d06f0 520 spin_lock(&mark->lock);
4712e722 521 mark->flags |= FSNOTIFY_MARK_FLAG_ALIVE | FSNOTIFY_MARK_FLAG_ATTACHED;
700307a2 522
23e964c2 523 fsnotify_get_group(group);
5444e298
EP
524 mark->group = group;
525 list_add(&mark->g_list, &group->marks_list);
526 atomic_inc(&group->num_marks);
6b3f05d2 527 fsnotify_get_mark(mark); /* for g_list */
5444e298
EP
528 spin_unlock(&mark->lock);
529
755b5bc6
JK
530 ret = fsnotify_add_mark_list(mark, inode, mnt, allow_dups);
531 if (ret)
532 goto err;
533
a242677b
JK
534 if (mark->mask)
535 fsnotify_recalc_mask(mark->connector);
5444e298
EP
536
537 return ret;
538err:
11375145
JK
539 mark->flags &= ~(FSNOTIFY_MARK_FLAG_ALIVE |
540 FSNOTIFY_MARK_FLAG_ATTACHED);
5444e298
EP
541 list_del_init(&mark->g_list);
542 atomic_dec(&group->num_marks);
5444e298
EP
543 spin_unlock(&mark->lock);
544
11375145 545 fsnotify_put_mark(mark);
5444e298
EP
546 return ret;
547}
548
d5a335b8
LS
549int fsnotify_add_mark(struct fsnotify_mark *mark, struct fsnotify_group *group,
550 struct inode *inode, struct vfsmount *mnt, int allow_dups)
551{
552 int ret;
553 mutex_lock(&group->mark_mutex);
554 ret = fsnotify_add_mark_locked(mark, group, inode, mnt, allow_dups);
555 mutex_unlock(&group->mark_mutex);
556 return ret;
557}
558
0809ab69
JK
559/*
560 * Given a list of marks, find the mark associated with given group. If found
561 * take a reference to that mark and return it, else return NULL.
562 */
08991e83
JK
563struct fsnotify_mark *fsnotify_find_mark(
564 struct fsnotify_mark_connector __rcu **connp,
565 struct fsnotify_group *group)
0809ab69 566{
08991e83 567 struct fsnotify_mark_connector *conn;
0809ab69
JK
568 struct fsnotify_mark *mark;
569
08991e83 570 conn = fsnotify_grab_connector(connp);
9dd813c1
JK
571 if (!conn)
572 return NULL;
573
574 hlist_for_each_entry(mark, &conn->list, obj_list) {
6b3f05d2
JK
575 if (mark->group == group &&
576 (mark->flags & FSNOTIFY_MARK_FLAG_ATTACHED)) {
0809ab69 577 fsnotify_get_mark(mark);
04662cab 578 spin_unlock(&conn->lock);
0809ab69
JK
579 return mark;
580 }
581 }
04662cab 582 spin_unlock(&conn->lock);
0809ab69
JK
583 return NULL;
584}
585
5444e298 586/*
d725e66c 587 * clear any marks in a group in which mark->flags & flags is true
5444e298 588 */
4d92604c
EP
589void fsnotify_clear_marks_by_group_flags(struct fsnotify_group *group,
590 unsigned int flags)
5444e298
EP
591{
592 struct fsnotify_mark *lmark, *mark;
8f2f3eb5 593 LIST_HEAD(to_free);
5444e298 594
8f2f3eb5
JK
595 /*
596 * We have to be really careful here. Anytime we drop mark_mutex, e.g.
597 * fsnotify_clear_marks_by_inode() can come and free marks. Even in our
598 * to_free list so we have to use mark_mutex even when accessing that
599 * list. And freeing mark requires us to drop mark_mutex. So we can
600 * reliably free only the first mark in the list. That's why we first
601 * move marks to free to to_free list in one go and then free marks in
602 * to_free list one by one.
603 */
6960b0d9 604 mutex_lock_nested(&group->mark_mutex, SINGLE_DEPTH_NESTING);
5444e298 605 list_for_each_entry_safe(mark, lmark, &group->marks_list, g_list) {
86ffe245 606 if (mark->connector->flags & flags)
8f2f3eb5 607 list_move(&mark->g_list, &to_free);
5444e298 608 }
986ab098 609 mutex_unlock(&group->mark_mutex);
8f2f3eb5
JK
610
611 while (1) {
612 mutex_lock_nested(&group->mark_mutex, SINGLE_DEPTH_NESTING);
613 if (list_empty(&to_free)) {
614 mutex_unlock(&group->mark_mutex);
615 break;
616 }
617 mark = list_first_entry(&to_free, struct fsnotify_mark, g_list);
618 fsnotify_get_mark(mark);
4712e722 619 fsnotify_detach_mark(mark);
8f2f3eb5 620 mutex_unlock(&group->mark_mutex);
4712e722 621 fsnotify_free_mark(mark);
8f2f3eb5
JK
622 fsnotify_put_mark(mark);
623 }
5444e298
EP
624}
625
4d92604c 626/*
35e48176
JK
627 * Given a group, prepare for freeing all the marks associated with that group.
628 * The marks are attached to the list of marks prepared for destruction, the
629 * caller is responsible for freeing marks in that list after SRCU period has
630 * ended.
4d92604c 631 */
35e48176 632void fsnotify_detach_group_marks(struct fsnotify_group *group)
4d92604c 633{
35e48176
JK
634 struct fsnotify_mark *mark;
635
636 while (1) {
637 mutex_lock_nested(&group->mark_mutex, SINGLE_DEPTH_NESTING);
638 if (list_empty(&group->marks_list)) {
639 mutex_unlock(&group->mark_mutex);
640 break;
641 }
642 mark = list_first_entry(&group->marks_list,
643 struct fsnotify_mark, g_list);
644 fsnotify_get_mark(mark);
645 fsnotify_detach_mark(mark);
646 mutex_unlock(&group->mark_mutex);
11375145 647 fsnotify_free_mark(mark);
35e48176
JK
648 fsnotify_put_mark(mark);
649 }
4d92604c
EP
650}
651
08991e83
JK
652/* Destroy all marks attached to inode / vfsmount */
653void fsnotify_destroy_marks(struct fsnotify_mark_connector __rcu **connp)
0810b4f9 654{
08991e83 655 struct fsnotify_mark_connector *conn;
6b3f05d2
JK
656 struct fsnotify_mark *mark, *old_mark = NULL;
657 struct inode *inode;
0810b4f9 658
6b3f05d2
JK
659 conn = fsnotify_grab_connector(connp);
660 if (!conn)
661 return;
662 /*
663 * We have to be careful since we can race with e.g.
664 * fsnotify_clear_marks_by_group() and once we drop the conn->lock, the
665 * list can get modified. However we are holding mark reference and
666 * thus our mark cannot be removed from obj_list so we can continue
667 * iteration after regaining conn->lock.
668 */
669 hlist_for_each_entry(mark, &conn->list, obj_list) {
0810b4f9 670 fsnotify_get_mark(mark);
04662cab 671 spin_unlock(&conn->lock);
6b3f05d2
JK
672 if (old_mark)
673 fsnotify_put_mark(old_mark);
674 old_mark = mark;
0810b4f9 675 fsnotify_destroy_mark(mark, mark->group);
6b3f05d2 676 spin_lock(&conn->lock);
0810b4f9 677 }
6b3f05d2
JK
678 /*
679 * Detach list from object now so that we don't pin inode until all
680 * mark references get dropped. It would lead to strange results such
681 * as delaying inode deletion or blocking unmount.
682 */
683 inode = fsnotify_detach_connector_from_object(conn);
684 spin_unlock(&conn->lock);
685 if (old_mark)
686 fsnotify_put_mark(old_mark);
687 iput(inode);
0810b4f9
JK
688}
689
5444e298
EP
690/*
691 * Nothing fancy, just initialize lists and locks and counters.
692 */
693void fsnotify_init_mark(struct fsnotify_mark *mark,
694 void (*free_mark)(struct fsnotify_mark *mark))
695{
ba643f04 696 memset(mark, 0, sizeof(*mark));
5444e298
EP
697 spin_lock_init(&mark->lock);
698 atomic_set(&mark->refcnt, 1);
5444e298
EP
699 mark->free_mark = free_mark;
700}
13d34ac6 701
35e48176
JK
702/*
703 * Destroy all marks in destroy_list, waits for SRCU period to finish before
704 * actually freeing marks.
705 */
706void fsnotify_mark_destroy_list(void)
13d34ac6
JL
707{
708 struct fsnotify_mark *mark, *next;
709 struct list_head private_destroy_list;
710
0918f1c3
JL
711 spin_lock(&destroy_lock);
712 /* exchange the list head */
713 list_replace_init(&destroy_list, &private_destroy_list);
714 spin_unlock(&destroy_lock);
13d34ac6 715
0918f1c3 716 synchronize_srcu(&fsnotify_mark_srcu);
13d34ac6 717
0918f1c3
JL
718 list_for_each_entry_safe(mark, next, &private_destroy_list, g_list) {
719 list_del_init(&mark->g_list);
6b3f05d2 720 fsnotify_final_mark_destroy(mark);
13d34ac6 721 }
13d34ac6 722}
35e48176
JK
723
724static void fsnotify_mark_destroy_workfn(struct work_struct *work)
725{
726 fsnotify_mark_destroy_list();
727}