]>
Commit | Line | Data |
---|---|---|
90586523 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 | #include <linux/list.h> | |
20 | #include <linux/mutex.h> | |
21 | #include <linux/slab.h> | |
22 | #include <linux/srcu.h> | |
23 | #include <linux/rculist.h> | |
24 | #include <linux/wait.h> | |
5b88fdd9 | 25 | #include <linux/module.h> |
90586523 EP |
26 | |
27 | #include <linux/fsnotify_backend.h> | |
28 | #include "fsnotify.h" | |
29 | ||
60063497 | 30 | #include <linux/atomic.h> |
90586523 | 31 | |
90586523 EP |
32 | /* |
33 | * Final freeing of a group | |
34 | */ | |
cafbaae8 | 35 | static void fsnotify_final_destroy_group(struct fsnotify_group *group) |
90586523 EP |
36 | { |
37 | if (group->ops->free_group_priv) | |
38 | group->ops->free_group_priv(group); | |
39 | ||
40 | kfree(group); | |
41 | } | |
42 | ||
12703dbf JK |
43 | /* |
44 | * Stop queueing new events for this group. Once this function returns | |
45 | * fsnotify_add_event() will not add any new events to the group's queue. | |
46 | */ | |
47 | void fsnotify_group_stop_queueing(struct fsnotify_group *group) | |
48 | { | |
c21dbe20 | 49 | spin_lock(&group->notification_lock); |
12703dbf | 50 | group->shutdown = true; |
c21dbe20 | 51 | spin_unlock(&group->notification_lock); |
12703dbf JK |
52 | } |
53 | ||
3be25f49 | 54 | /* |
23e964c2 LS |
55 | * Trying to get rid of a group. Remove all marks, flush all events and release |
56 | * the group reference. | |
57 | * Note that another thread calling fsnotify_clear_marks_by_group() may still | |
58 | * hold a ref to the group. | |
3be25f49 | 59 | */ |
d8153d4d | 60 | void fsnotify_destroy_group(struct fsnotify_group *group) |
3be25f49 | 61 | { |
12703dbf JK |
62 | /* |
63 | * Stop queueing new events. The code below is careful enough to not | |
64 | * require this but fanotify needs to stop queuing events even before | |
65 | * fsnotify_destroy_group() is called and this makes the other callers | |
66 | * of fsnotify_destroy_group() to see the same behavior. | |
67 | */ | |
68 | fsnotify_group_stop_queueing(group); | |
69 | ||
35e48176 JK |
70 | /* clear all inode marks for this group, attach them to destroy_list */ |
71 | fsnotify_detach_group_marks(group); | |
3be25f49 | 72 | |
35e48176 JK |
73 | /* |
74 | * Wait for fsnotify_mark_srcu period to end and free all marks in | |
75 | * destroy_list | |
76 | */ | |
77 | fsnotify_mark_destroy_list(); | |
75c1be48 | 78 | |
35e48176 JK |
79 | /* |
80 | * Since we have waited for fsnotify_mark_srcu in | |
81 | * fsnotify_mark_destroy_list() there can be no outstanding event | |
82 | * notification against this group. So clearing the notification queue | |
83 | * of all events is reliable now. | |
84 | */ | |
23e964c2 LS |
85 | fsnotify_flush_notify(group); |
86 | ||
ff57cd58 JK |
87 | /* |
88 | * Destroy overflow event (we cannot use fsnotify_destroy_event() as | |
89 | * that deliberately ignores overflow events. | |
90 | */ | |
91 | if (group->overflow_event) | |
92 | group->ops->free_event(group->overflow_event); | |
93 | ||
23e964c2 | 94 | fsnotify_put_group(group); |
3be25f49 EP |
95 | } |
96 | ||
98612952 LS |
97 | /* |
98 | * Get reference to a group. | |
99 | */ | |
100 | void fsnotify_get_group(struct fsnotify_group *group) | |
101 | { | |
102 | atomic_inc(&group->refcnt); | |
103 | } | |
5b88fdd9 | 104 | EXPORT_SYMBOL_GPL(fsnotify_get_group); |
98612952 | 105 | |
90586523 EP |
106 | /* |
107 | * Drop a reference to a group. Free it if it's through. | |
108 | */ | |
109 | void fsnotify_put_group(struct fsnotify_group *group) | |
110 | { | |
02436668 | 111 | if (atomic_dec_and_test(&group->refcnt)) |
23e964c2 | 112 | fsnotify_final_destroy_group(group); |
90586523 | 113 | } |
5b88fdd9 | 114 | EXPORT_SYMBOL_GPL(fsnotify_put_group); |
90586523 | 115 | |
90586523 | 116 | /* |
ffab8340 | 117 | * Create a new fsnotify_group and hold a reference for the group returned. |
90586523 | 118 | */ |
0d2e2a1d | 119 | struct fsnotify_group *fsnotify_alloc_group(const struct fsnotify_ops *ops) |
90586523 | 120 | { |
74be0cc8 | 121 | struct fsnotify_group *group; |
90586523 | 122 | |
f0553af0 | 123 | group = kzalloc(sizeof(struct fsnotify_group), GFP_KERNEL); |
90586523 EP |
124 | if (!group) |
125 | return ERR_PTR(-ENOMEM); | |
126 | ||
36fddeba | 127 | /* set to 0 when there a no external references to this group */ |
90586523 | 128 | atomic_set(&group->refcnt, 1); |
23e964c2 | 129 | atomic_set(&group->num_marks, 0); |
36fddeba | 130 | |
c21dbe20 | 131 | spin_lock_init(&group->notification_lock); |
a2d8bc6c EP |
132 | INIT_LIST_HEAD(&group->notification_list); |
133 | init_waitqueue_head(&group->notification_waitq); | |
a2d8bc6c EP |
134 | group->max_events = UINT_MAX; |
135 | ||
986ab098 | 136 | mutex_init(&group->mark_mutex); |
e61ce867 | 137 | INIT_LIST_HEAD(&group->marks_list); |
3be25f49 | 138 | |
90586523 EP |
139 | group->ops = ops; |
140 | ||
90586523 EP |
141 | return group; |
142 | } | |
5b88fdd9 | 143 | EXPORT_SYMBOL_GPL(fsnotify_alloc_group); |
0a6b6bd5 EP |
144 | |
145 | int fsnotify_fasync(int fd, struct file *file, int on) | |
146 | { | |
147 | struct fsnotify_group *group = file->private_data; | |
148 | ||
149 | return fasync_helper(fd, file, on, &group->fsn_fa) >= 0 ? 0 : -EIO; | |
150 | } |