vfs: do bulk POLL* -> EPOLL* replacement
[linux-2.6-block.git] / fs / notify / inotify / inotify_user.c
CommitLineData
2d9048e2
AG
1/*
2 * fs/inotify_user.c - inotify support for userspace
3 *
4 * Authors:
5 * John McCutchan <ttb@tentacle.dhs.org>
6 * Robert Love <rml@novell.com>
7 *
8 * Copyright (C) 2005 John McCutchan
9 * Copyright 2006 Hewlett-Packard Development Company, L.P.
10 *
63c882a0
EP
11 * Copyright (C) 2009 Eric Paris <Red Hat Inc>
12 * inotify was largely rewriten to make use of the fsnotify infrastructure
13 *
2d9048e2
AG
14 * This program is free software; you can redistribute it and/or modify it
15 * under the terms of the GNU General Public License as published by the
16 * Free Software Foundation; either version 2, or (at your option) any
17 * later version.
18 *
19 * This program is distributed in the hope that it will be useful, but
20 * WITHOUT ANY WARRANTY; without even the implied warranty of
21 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
22 * General Public License for more details.
23 */
24
2d9048e2 25#include <linux/file.h>
63c882a0
EP
26#include <linux/fs.h> /* struct inode */
27#include <linux/fsnotify_backend.h>
28#include <linux/idr.h>
c013d5a4 29#include <linux/init.h> /* fs_initcall */
2d9048e2 30#include <linux/inotify.h>
63c882a0 31#include <linux/kernel.h> /* roundup() */
63c882a0 32#include <linux/namei.h> /* LOOKUP_FOLLOW */
174cd4b1 33#include <linux/sched/signal.h>
63c882a0 34#include <linux/slab.h> /* struct kmem_cache */
2d9048e2 35#include <linux/syscalls.h>
63c882a0 36#include <linux/types.h>
c44dcc56 37#include <linux/anon_inodes.h>
63c882a0
EP
38#include <linux/uaccess.h>
39#include <linux/poll.h>
40#include <linux/wait.h>
2d9048e2 41
63c882a0 42#include "inotify.h"
be77196b 43#include "../fdinfo.h"
2d9048e2 44
63c882a0 45#include <asm/ioctls.h>
2d9048e2 46
1cce1eea 47/* configurable via /proc/sys/fs/inotify/ */
3c828e49 48static int inotify_max_queued_events __read_mostly;
2d9048e2 49
054c636e 50struct kmem_cache *inotify_inode_mark_cachep __read_mostly;
2d9048e2 51
2d9048e2
AG
52#ifdef CONFIG_SYSCTL
53
54#include <linux/sysctl.h>
55
56static int zero;
57
92f778dd 58struct ctl_table inotify_table[] = {
2d9048e2 59 {
2d9048e2 60 .procname = "max_user_instances",
1cce1eea 61 .data = &init_user_ns.ucount_max[UCOUNT_INOTIFY_INSTANCES],
2d9048e2
AG
62 .maxlen = sizeof(int),
63 .mode = 0644,
6d456111 64 .proc_handler = proc_dointvec_minmax,
2d9048e2
AG
65 .extra1 = &zero,
66 },
67 {
2d9048e2 68 .procname = "max_user_watches",
1cce1eea 69 .data = &init_user_ns.ucount_max[UCOUNT_INOTIFY_WATCHES],
2d9048e2
AG
70 .maxlen = sizeof(int),
71 .mode = 0644,
6d456111 72 .proc_handler = proc_dointvec_minmax,
2d9048e2
AG
73 .extra1 = &zero,
74 },
75 {
2d9048e2
AG
76 .procname = "max_queued_events",
77 .data = &inotify_max_queued_events,
78 .maxlen = sizeof(int),
79 .mode = 0644,
6d456111 80 .proc_handler = proc_dointvec_minmax,
2d9048e2
AG
81 .extra1 = &zero
82 },
ab09203e 83 { }
2d9048e2
AG
84};
85#endif /* CONFIG_SYSCTL */
86
63c882a0 87static inline __u32 inotify_arg_to_mask(u32 arg)
1c17d18e 88{
63c882a0 89 __u32 mask;
1c17d18e 90
611da04f
EP
91 /*
92 * everything should accept their own ignored, cares about children,
93 * and should receive events when the inode is unmounted
94 */
95 mask = (FS_IN_IGNORED | FS_EVENT_ON_CHILD | FS_UNMOUNT);
2d9048e2 96
63c882a0 97 /* mask off the flags used to open the fd */
8c1934c8 98 mask |= (arg & (IN_ALL_EVENTS | IN_ONESHOT | IN_EXCL_UNLINK));
2d9048e2 99
63c882a0 100 return mask;
2d9048e2
AG
101}
102
63c882a0 103static inline u32 inotify_mask_to_arg(__u32 mask)
2d9048e2 104{
63c882a0
EP
105 return mask & (IN_ALL_EVENTS | IN_ISDIR | IN_UNMOUNT | IN_IGNORED |
106 IN_Q_OVERFLOW);
2d9048e2
AG
107}
108
63c882a0 109/* intofiy userspace file descriptor functions */
076ccb76 110static __poll_t inotify_poll(struct file *file, poll_table *wait)
2d9048e2 111{
63c882a0 112 struct fsnotify_group *group = file->private_data;
076ccb76 113 __poll_t ret = 0;
2d9048e2 114
63c882a0 115 poll_wait(file, &group->notification_waitq, wait);
c21dbe20 116 spin_lock(&group->notification_lock);
63c882a0 117 if (!fsnotify_notify_queue_is_empty(group))
a9a08845 118 ret = EPOLLIN | EPOLLRDNORM;
c21dbe20 119 spin_unlock(&group->notification_lock);
2d9048e2
AG
120
121 return ret;
122}
123
7053aee2 124static int round_event_name_len(struct fsnotify_event *fsn_event)
e9fe6904 125{
7053aee2
JK
126 struct inotify_event_info *event;
127
128 event = INOTIFY_E(fsn_event);
e9fe6904
JK
129 if (!event->name_len)
130 return 0;
131 return roundup(event->name_len + 1, sizeof(struct inotify_event));
132}
133
3632dee2
VN
134/*
135 * Get an inotify_kernel_event if one exists and is small
136 * enough to fit in "count". Return an error pointer if
137 * not large enough.
138 *
c21dbe20 139 * Called with the group->notification_lock held.
3632dee2 140 */
63c882a0
EP
141static struct fsnotify_event *get_one_event(struct fsnotify_group *group,
142 size_t count)
3632dee2
VN
143{
144 size_t event_size = sizeof(struct inotify_event);
63c882a0 145 struct fsnotify_event *event;
3632dee2 146
63c882a0 147 if (fsnotify_notify_queue_is_empty(group))
3632dee2
VN
148 return NULL;
149
8ba8fa91 150 event = fsnotify_peek_first_event(group);
63c882a0 151
5ba08e2e
EP
152 pr_debug("%s: group=%p event=%p\n", __func__, group, event);
153
e9fe6904 154 event_size += round_event_name_len(event);
3632dee2
VN
155 if (event_size > count)
156 return ERR_PTR(-EINVAL);
157
c21dbe20 158 /* held the notification_lock the whole time, so this is the
63c882a0 159 * same event we peeked above */
8ba8fa91 160 fsnotify_remove_first_event(group);
63c882a0
EP
161
162 return event;
3632dee2
VN
163}
164
165/*
166 * Copy an event to user space, returning how much we copied.
167 *
168 * We already checked that the event size is smaller than the
169 * buffer we had in "get_one_event()" above.
170 */
63c882a0 171static ssize_t copy_event_to_user(struct fsnotify_group *group,
7053aee2 172 struct fsnotify_event *fsn_event,
3632dee2
VN
173 char __user *buf)
174{
63c882a0 175 struct inotify_event inotify_event;
7053aee2 176 struct inotify_event_info *event;
3632dee2 177 size_t event_size = sizeof(struct inotify_event);
e9fe6904
JK
178 size_t name_len;
179 size_t pad_name_len;
63c882a0 180
7053aee2 181 pr_debug("%s: group=%p event=%p\n", __func__, group, fsn_event);
63c882a0 182
7053aee2 183 event = INOTIFY_E(fsn_event);
e9fe6904 184 name_len = event->name_len;
b962e731 185 /*
e9fe6904 186 * round up name length so it is a multiple of event_size
0db501bd
EB
187 * plus an extra byte for the terminating '\0'.
188 */
7053aee2 189 pad_name_len = round_event_name_len(fsn_event);
e9fe6904 190 inotify_event.len = pad_name_len;
7053aee2
JK
191 inotify_event.mask = inotify_mask_to_arg(fsn_event->mask);
192 inotify_event.wd = event->wd;
63c882a0 193 inotify_event.cookie = event->sync_cookie;
3632dee2 194
63c882a0
EP
195 /* send the main event */
196 if (copy_to_user(buf, &inotify_event, event_size))
3632dee2
VN
197 return -EFAULT;
198
63c882a0 199 buf += event_size;
3632dee2 200
63c882a0
EP
201 /*
202 * fsnotify only stores the pathname, so here we have to send the pathname
203 * and then pad that pathname out to a multiple of sizeof(inotify_event)
e9fe6904 204 * with zeros.
63c882a0 205 */
e9fe6904 206 if (pad_name_len) {
63c882a0 207 /* copy the path name */
7053aee2 208 if (copy_to_user(buf, event->name, name_len))
3632dee2 209 return -EFAULT;
e9fe6904 210 buf += name_len;
3632dee2 211
0db501bd 212 /* fill userspace with 0's */
e9fe6904 213 if (clear_user(buf, pad_name_len - name_len))
63c882a0 214 return -EFAULT;
e9fe6904 215 event_size += pad_name_len;
3632dee2 216 }
63c882a0 217
3632dee2
VN
218 return event_size;
219}
220
2d9048e2
AG
221static ssize_t inotify_read(struct file *file, char __user *buf,
222 size_t count, loff_t *pos)
223{
63c882a0
EP
224 struct fsnotify_group *group;
225 struct fsnotify_event *kevent;
2d9048e2
AG
226 char __user *start;
227 int ret;
e23738a7 228 DEFINE_WAIT_FUNC(wait, woken_wake_function);
2d9048e2
AG
229
230 start = buf;
63c882a0 231 group = file->private_data;
2d9048e2 232
e23738a7 233 add_wait_queue(&group->notification_waitq, &wait);
2d9048e2 234 while (1) {
c21dbe20 235 spin_lock(&group->notification_lock);
63c882a0 236 kevent = get_one_event(group, count);
c21dbe20 237 spin_unlock(&group->notification_lock);
2d9048e2 238
5ba08e2e
EP
239 pr_debug("%s: group=%p kevent=%p\n", __func__, group, kevent);
240
3632dee2
VN
241 if (kevent) {
242 ret = PTR_ERR(kevent);
243 if (IS_ERR(kevent))
244 break;
63c882a0 245 ret = copy_event_to_user(group, kevent, buf);
7053aee2 246 fsnotify_destroy_event(group, kevent);
3632dee2
VN
247 if (ret < 0)
248 break;
249 buf += ret;
250 count -= ret;
251 continue;
2d9048e2
AG
252 }
253
3632dee2
VN
254 ret = -EAGAIN;
255 if (file->f_flags & O_NONBLOCK)
2d9048e2 256 break;
1ca39ab9 257 ret = -ERESTARTSYS;
3632dee2 258 if (signal_pending(current))
2d9048e2 259 break;
16dbc6c9 260
3632dee2 261 if (start != buf)
2d9048e2 262 break;
16dbc6c9 263
e23738a7 264 wait_woken(&wait, TASK_INTERRUPTIBLE, MAX_SCHEDULE_TIMEOUT);
2d9048e2 265 }
e23738a7 266 remove_wait_queue(&group->notification_waitq, &wait);
2d9048e2 267
3632dee2
VN
268 if (start != buf && ret != -EFAULT)
269 ret = buf - start;
2d9048e2
AG
270 return ret;
271}
272
273static int inotify_release(struct inode *ignored, struct file *file)
274{
63c882a0 275 struct fsnotify_group *group = file->private_data;
2d9048e2 276
5ba08e2e
EP
277 pr_debug("%s: group=%p\n", __func__, group);
278
63c882a0 279 /* free this group, matching get was inotify_init->fsnotify_obtain_group */
d8153d4d 280 fsnotify_destroy_group(group);
2d9048e2
AG
281
282 return 0;
283}
284
285static long inotify_ioctl(struct file *file, unsigned int cmd,
286 unsigned long arg)
287{
63c882a0 288 struct fsnotify_group *group;
7053aee2 289 struct fsnotify_event *fsn_event;
2d9048e2
AG
290 void __user *p;
291 int ret = -ENOTTY;
63c882a0 292 size_t send_len = 0;
2d9048e2 293
63c882a0 294 group = file->private_data;
2d9048e2
AG
295 p = (void __user *) arg;
296
5ba08e2e
EP
297 pr_debug("%s: group=%p cmd=%u\n", __func__, group, cmd);
298
2d9048e2
AG
299 switch (cmd) {
300 case FIONREAD:
c21dbe20 301 spin_lock(&group->notification_lock);
7053aee2
JK
302 list_for_each_entry(fsn_event, &group->notification_list,
303 list) {
63c882a0 304 send_len += sizeof(struct inotify_event);
7053aee2 305 send_len += round_event_name_len(fsn_event);
63c882a0 306 }
c21dbe20 307 spin_unlock(&group->notification_lock);
63c882a0 308 ret = put_user(send_len, (int __user *) p);
2d9048e2
AG
309 break;
310 }
311
312 return ret;
313}
314
315static const struct file_operations inotify_fops = {
be77196b 316 .show_fdinfo = inotify_show_fdinfo,
63c882a0
EP
317 .poll = inotify_poll,
318 .read = inotify_read,
0a6b6bd5 319 .fasync = fsnotify_fasync,
63c882a0
EP
320 .release = inotify_release,
321 .unlocked_ioctl = inotify_ioctl,
2d9048e2 322 .compat_ioctl = inotify_ioctl,
6038f373 323 .llseek = noop_llseek,
2d9048e2
AG
324};
325
2d9048e2 326
63c882a0
EP
327/*
328 * find_inode - resolve a user-given path to a specific inode
329 */
330static int inotify_find_inode(const char __user *dirname, struct path *path, unsigned flags)
331{
332 int error;
333
334 error = user_path_at(AT_FDCWD, dirname, flags, path);
335 if (error)
336 return error;
337 /* you can only watch an inode if you have read permissions on it */
338 error = inode_permission(path->dentry->d_inode, MAY_READ);
339 if (error)
340 path_put(path);
341 return error;
342}
343
b7ba8371 344static int inotify_add_to_idr(struct idr *idr, spinlock_t *idr_lock,
000285de 345 struct inotify_inode_mark *i_mark)
b7ba8371
EP
346{
347 int ret;
348
4542da63
TH
349 idr_preload(GFP_KERNEL);
350 spin_lock(idr_lock);
b7ba8371 351
a66c04b4 352 ret = idr_alloc_cyclic(idr, i_mark, 1, 0, GFP_NOWAIT);
4542da63 353 if (ret >= 0) {
b7ba8371 354 /* we added the mark to the idr, take a reference */
4542da63 355 i_mark->wd = ret;
4542da63
TH
356 fsnotify_get_mark(&i_mark->fsn_mark);
357 }
b7ba8371 358
4542da63
TH
359 spin_unlock(idr_lock);
360 idr_preload_end();
361 return ret < 0 ? ret : 0;
b7ba8371
EP
362}
363
000285de 364static struct inotify_inode_mark *inotify_idr_find_locked(struct fsnotify_group *group,
b7ba8371
EP
365 int wd)
366{
367 struct idr *idr = &group->inotify_data.idr;
368 spinlock_t *idr_lock = &group->inotify_data.idr_lock;
000285de 369 struct inotify_inode_mark *i_mark;
b7ba8371
EP
370
371 assert_spin_locked(idr_lock);
372
000285de
EP
373 i_mark = idr_find(idr, wd);
374 if (i_mark) {
375 struct fsnotify_mark *fsn_mark = &i_mark->fsn_mark;
b7ba8371 376
000285de 377 fsnotify_get_mark(fsn_mark);
b7ba8371 378 /* One ref for being in the idr, one ref we just took */
ab97f873 379 BUG_ON(refcount_read(&fsn_mark->refcnt) < 2);
b7ba8371
EP
380 }
381
000285de 382 return i_mark;
b7ba8371
EP
383}
384
000285de 385static struct inotify_inode_mark *inotify_idr_find(struct fsnotify_group *group,
b7ba8371
EP
386 int wd)
387{
000285de 388 struct inotify_inode_mark *i_mark;
b7ba8371
EP
389 spinlock_t *idr_lock = &group->inotify_data.idr_lock;
390
391 spin_lock(idr_lock);
000285de 392 i_mark = inotify_idr_find_locked(group, wd);
b7ba8371
EP
393 spin_unlock(idr_lock);
394
000285de 395 return i_mark;
b7ba8371
EP
396}
397
dead537d
EP
398/*
399 * Remove the mark from the idr (if present) and drop the reference
400 * on the mark because it was in the idr.
401 */
7e790dd5 402static void inotify_remove_from_idr(struct fsnotify_group *group,
000285de 403 struct inotify_inode_mark *i_mark)
7e790dd5 404{
e7253760 405 struct idr *idr = &group->inotify_data.idr;
b7ba8371 406 spinlock_t *idr_lock = &group->inotify_data.idr_lock;
000285de 407 struct inotify_inode_mark *found_i_mark = NULL;
dead537d 408 int wd;
7e790dd5 409
b7ba8371 410 spin_lock(idr_lock);
000285de 411 wd = i_mark->wd;
dead537d 412
b7ba8371 413 /*
000285de 414 * does this i_mark think it is in the idr? we shouldn't get called
b7ba8371
EP
415 * if it wasn't....
416 */
417 if (wd == -1) {
25c829af
JK
418 WARN_ONCE(1, "%s: i_mark=%p i_mark->wd=%d i_mark->group=%p\n",
419 __func__, i_mark, i_mark->wd, i_mark->fsn_mark.group);
dead537d 420 goto out;
b7ba8371 421 }
dead537d 422
b7ba8371 423 /* Lets look in the idr to see if we find it */
000285de
EP
424 found_i_mark = inotify_idr_find_locked(group, wd);
425 if (unlikely(!found_i_mark)) {
25c829af
JK
426 WARN_ONCE(1, "%s: i_mark=%p i_mark->wd=%d i_mark->group=%p\n",
427 __func__, i_mark, i_mark->wd, i_mark->fsn_mark.group);
dead537d 428 goto out;
b7ba8371 429 }
dead537d 430
b7ba8371 431 /*
000285de
EP
432 * We found an mark in the idr at the right wd, but it's
433 * not the mark we were told to remove. eparis seriously
b7ba8371
EP
434 * fucked up somewhere.
435 */
000285de
EP
436 if (unlikely(found_i_mark != i_mark)) {
437 WARN_ONCE(1, "%s: i_mark=%p i_mark->wd=%d i_mark->group=%p "
25c829af
JK
438 "found_i_mark=%p found_i_mark->wd=%d "
439 "found_i_mark->group=%p\n", __func__, i_mark,
440 i_mark->wd, i_mark->fsn_mark.group, found_i_mark,
441 found_i_mark->wd, found_i_mark->fsn_mark.group);
dead537d
EP
442 goto out;
443 }
444
b7ba8371
EP
445 /*
446 * One ref for being in the idr
b7ba8371
EP
447 * one ref grabbed by inotify_idr_find
448 */
ab97f873 449 if (unlikely(refcount_read(&i_mark->fsn_mark.refcnt) < 2)) {
25c829af
JK
450 printk(KERN_ERR "%s: i_mark=%p i_mark->wd=%d i_mark->group=%p\n",
451 __func__, i_mark, i_mark->wd, i_mark->fsn_mark.group);
b7ba8371
EP
452 /* we can't really recover with bad ref cnting.. */
453 BUG();
454 }
dead537d 455
e7253760
JK
456 idr_remove(idr, wd);
457 /* Removed from the idr, drop that ref. */
458 fsnotify_put_mark(&i_mark->fsn_mark);
dead537d 459out:
e7253760
JK
460 i_mark->wd = -1;
461 spin_unlock(idr_lock);
b7ba8371 462 /* match the ref taken by inotify_idr_find_locked() */
000285de
EP
463 if (found_i_mark)
464 fsnotify_put_mark(&found_i_mark->fsn_mark);
7e790dd5 465}
dead537d 466
63c882a0 467/*
dead537d 468 * Send IN_IGNORED for this wd, remove this wd from the idr.
63c882a0 469 */
000285de 470void inotify_ignored_and_remove_idr(struct fsnotify_mark *fsn_mark,
528da3e9 471 struct fsnotify_group *group)
63c882a0 472{
000285de 473 struct inotify_inode_mark *i_mark;
63c882a0 474
7053aee2
JK
475 /* Queue ignore event for the watch */
476 inotify_handle_event(group, NULL, fsn_mark, NULL, FS_IN_IGNORED,
9385a84d 477 NULL, FSNOTIFY_EVENT_NONE, NULL, 0, NULL);
f44aebcc 478
7053aee2 479 i_mark = container_of(fsn_mark, struct inotify_inode_mark, fsn_mark);
000285de
EP
480 /* remove this mark from the idr */
481 inotify_remove_from_idr(group, i_mark);
63c882a0 482
1cce1eea 483 dec_inotify_watches(group->inotify_data.ucounts);
63c882a0
EP
484}
485
52cef755
EP
486static int inotify_update_existing_watch(struct fsnotify_group *group,
487 struct inode *inode,
488 u32 arg)
63c882a0 489{
000285de
EP
490 struct fsnotify_mark *fsn_mark;
491 struct inotify_inode_mark *i_mark;
63c882a0 492 __u32 old_mask, new_mask;
52cef755
EP
493 __u32 mask;
494 int add = (arg & IN_MASK_ADD);
495 int ret;
63c882a0 496
63c882a0 497 mask = inotify_arg_to_mask(arg);
63c882a0 498
b1362edf 499 fsn_mark = fsnotify_find_mark(&inode->i_fsnotify_marks, group);
000285de 500 if (!fsn_mark)
52cef755 501 return -ENOENT;
7e790dd5 502
000285de 503 i_mark = container_of(fsn_mark, struct inotify_inode_mark, fsn_mark);
75fe2b26 504
000285de 505 spin_lock(&fsn_mark->lock);
000285de 506 old_mask = fsn_mark->mask;
90b1e7a5 507 if (add)
66d2b81b 508 fsn_mark->mask |= mask;
90b1e7a5 509 else
66d2b81b 510 fsn_mark->mask = mask;
90b1e7a5 511 new_mask = fsn_mark->mask;
000285de 512 spin_unlock(&fsn_mark->lock);
63c882a0
EP
513
514 if (old_mask != new_mask) {
515 /* more bits in old than in new? */
516 int dropped = (old_mask & ~new_mask);
000285de 517 /* more bits in this fsn_mark than the inode's mask? */
63c882a0 518 int do_inode = (new_mask & ~inode->i_fsnotify_mask);
63c882a0 519
000285de 520 /* update the inode with this new fsn_mark */
63c882a0 521 if (dropped || do_inode)
8920d273 522 fsnotify_recalc_mask(inode->i_fsnotify_marks);
63c882a0 523
63c882a0
EP
524 }
525
52cef755 526 /* return the wd */
000285de 527 ret = i_mark->wd;
52cef755 528
d0775441 529 /* match the get from fsnotify_find_mark() */
000285de 530 fsnotify_put_mark(fsn_mark);
75fe2b26 531
52cef755
EP
532 return ret;
533}
534
535static int inotify_new_watch(struct fsnotify_group *group,
536 struct inode *inode,
537 u32 arg)
538{
000285de 539 struct inotify_inode_mark *tmp_i_mark;
52cef755
EP
540 __u32 mask;
541 int ret;
b7ba8371
EP
542 struct idr *idr = &group->inotify_data.idr;
543 spinlock_t *idr_lock = &group->inotify_data.idr_lock;
52cef755 544
52cef755 545 mask = inotify_arg_to_mask(arg);
52cef755 546
000285de
EP
547 tmp_i_mark = kmem_cache_alloc(inotify_inode_mark_cachep, GFP_KERNEL);
548 if (unlikely(!tmp_i_mark))
52cef755
EP
549 return -ENOMEM;
550
054c636e 551 fsnotify_init_mark(&tmp_i_mark->fsn_mark, group);
000285de
EP
552 tmp_i_mark->fsn_mark.mask = mask;
553 tmp_i_mark->wd = -1;
52cef755 554
a66c04b4 555 ret = inotify_add_to_idr(idr, idr_lock, tmp_i_mark);
b7ba8371 556 if (ret)
52cef755 557 goto out_err;
52cef755 558
1cce1eea
NB
559 /* increment the number of watches the user has */
560 if (!inc_inotify_watches(group->inotify_data.ucounts)) {
561 inotify_remove_from_idr(group, tmp_i_mark);
562 ret = -ENOSPC;
563 goto out_err;
564 }
565
52cef755 566 /* we are on the idr, now get on the inode */
7b129323 567 ret = fsnotify_add_mark_locked(&tmp_i_mark->fsn_mark, inode, NULL, 0);
52cef755
EP
568 if (ret) {
569 /* we failed to get on the inode, get off the idr */
000285de 570 inotify_remove_from_idr(group, tmp_i_mark);
52cef755
EP
571 goto out_err;
572 }
573
52cef755 574
000285de
EP
575 /* return the watch descriptor for this new mark */
576 ret = tmp_i_mark->wd;
52cef755 577
63c882a0 578out_err:
000285de
EP
579 /* match the ref from fsnotify_init_mark() */
580 fsnotify_put_mark(&tmp_i_mark->fsn_mark);
52cef755
EP
581
582 return ret;
583}
584
585static int inotify_update_watch(struct fsnotify_group *group, struct inode *inode, u32 arg)
586{
587 int ret = 0;
588
e1e5a9f8 589 mutex_lock(&group->mark_mutex);
52cef755
EP
590 /* try to update and existing watch with the new arg */
591 ret = inotify_update_existing_watch(group, inode, arg);
592 /* no mark present, try to add a new one */
593 if (ret == -ENOENT)
594 ret = inotify_new_watch(group, inode, arg);
e1e5a9f8 595 mutex_unlock(&group->mark_mutex);
7e790dd5 596
63c882a0
EP
597 return ret;
598}
599
d0de4dc5 600static struct fsnotify_group *inotify_new_group(unsigned int max_events)
63c882a0
EP
601{
602 struct fsnotify_group *group;
ff57cd58 603 struct inotify_event_info *oevent;
63c882a0 604
0d2e2a1d 605 group = fsnotify_alloc_group(&inotify_fsnotify_ops);
63c882a0
EP
606 if (IS_ERR(group))
607 return group;
608
ff57cd58
JK
609 oevent = kmalloc(sizeof(struct inotify_event_info), GFP_KERNEL);
610 if (unlikely(!oevent)) {
611 fsnotify_destroy_group(group);
612 return ERR_PTR(-ENOMEM);
613 }
614 group->overflow_event = &oevent->fse;
615 fsnotify_init_event(group->overflow_event, NULL, FS_Q_OVERFLOW);
616 oevent->wd = -1;
617 oevent->sync_cookie = 0;
618 oevent->name_len = 0;
619
63c882a0
EP
620 group->max_events = max_events;
621
622 spin_lock_init(&group->inotify_data.idr_lock);
623 idr_init(&group->inotify_data.idr);
1cce1eea
NB
624 group->inotify_data.ucounts = inc_ucount(current_user_ns(),
625 current_euid(),
626 UCOUNT_INOTIFY_INSTANCES);
d0de4dc5 627
1cce1eea 628 if (!group->inotify_data.ucounts) {
d8153d4d 629 fsnotify_destroy_group(group);
d0de4dc5
EP
630 return ERR_PTR(-EMFILE);
631 }
63c882a0
EP
632
633 return group;
634}
635
636
637/* inotify syscalls */
938bb9f5 638SYSCALL_DEFINE1(inotify_init1, int, flags)
2d9048e2 639{
63c882a0 640 struct fsnotify_group *group;
c44dcc56 641 int ret;
2d9048e2 642
e38b36f3
UD
643 /* Check the IN_* constants for consistency. */
644 BUILD_BUG_ON(IN_CLOEXEC != O_CLOEXEC);
645 BUILD_BUG_ON(IN_NONBLOCK != O_NONBLOCK);
646
510df2dd 647 if (flags & ~(IN_CLOEXEC | IN_NONBLOCK))
4006553b
UD
648 return -EINVAL;
649
63c882a0 650 /* fsnotify_obtain_group took a reference to group, we put this when we kill the file in the end */
d0de4dc5
EP
651 group = inotify_new_group(inotify_max_queued_events);
652 if (IS_ERR(group))
653 return PTR_ERR(group);
825f9692 654
c44dcc56
AV
655 ret = anon_inode_getfd("inotify", &inotify_fops, group,
656 O_RDONLY | flags);
d0de4dc5 657 if (ret < 0)
d8153d4d 658 fsnotify_destroy_group(group);
825f9692 659
2d9048e2
AG
660 return ret;
661}
662
938bb9f5 663SYSCALL_DEFINE0(inotify_init)
4006553b
UD
664{
665 return sys_inotify_init1(0);
666}
667
2e4d0924
HC
668SYSCALL_DEFINE3(inotify_add_watch, int, fd, const char __user *, pathname,
669 u32, mask)
2d9048e2 670{
63c882a0 671 struct fsnotify_group *group;
2d9048e2 672 struct inode *inode;
2d8f3038 673 struct path path;
2903ff01
AV
674 struct fd f;
675 int ret;
2d9048e2
AG
676 unsigned flags = 0;
677
d30e2c05
DH
678 /*
679 * We share a lot of code with fs/dnotify. We also share
680 * the bit layout between inotify's IN_* and the fsnotify
681 * FS_*. This check ensures that only the inotify IN_*
682 * bits get passed in and set in watches/events.
683 */
684 if (unlikely(mask & ~ALL_INOTIFY_BITS))
685 return -EINVAL;
686 /*
687 * Require at least one valid bit set in the mask.
688 * Without _something_ set, we would have no events to
689 * watch for.
690 */
04df32fa
ZH
691 if (unlikely(!(mask & ALL_INOTIFY_BITS)))
692 return -EINVAL;
693
2903ff01
AV
694 f = fdget(fd);
695 if (unlikely(!f.file))
2d9048e2
AG
696 return -EBADF;
697
698 /* verify that this is indeed an inotify instance */
2903ff01 699 if (unlikely(f.file->f_op != &inotify_fops)) {
2d9048e2
AG
700 ret = -EINVAL;
701 goto fput_and_out;
702 }
703
704 if (!(mask & IN_DONT_FOLLOW))
705 flags |= LOOKUP_FOLLOW;
706 if (mask & IN_ONLYDIR)
707 flags |= LOOKUP_DIRECTORY;
708
63c882a0
EP
709 ret = inotify_find_inode(pathname, &path, flags);
710 if (ret)
2d9048e2
AG
711 goto fput_and_out;
712
63c882a0 713 /* inode held in place by reference to path; group by fget on fd */
2d8f3038 714 inode = path.dentry->d_inode;
2903ff01 715 group = f.file->private_data;
2d9048e2 716
63c882a0
EP
717 /* create/update an inode mark */
718 ret = inotify_update_watch(group, inode, mask);
2d8f3038 719 path_put(&path);
2d9048e2 720fput_and_out:
2903ff01 721 fdput(f);
2d9048e2
AG
722 return ret;
723}
724
2e4d0924 725SYSCALL_DEFINE2(inotify_rm_watch, int, fd, __s32, wd)
2d9048e2 726{
63c882a0 727 struct fsnotify_group *group;
000285de 728 struct inotify_inode_mark *i_mark;
2903ff01
AV
729 struct fd f;
730 int ret = 0;
2d9048e2 731
2903ff01
AV
732 f = fdget(fd);
733 if (unlikely(!f.file))
2d9048e2
AG
734 return -EBADF;
735
736 /* verify that this is indeed an inotify instance */
b7ba8371 737 ret = -EINVAL;
2903ff01 738 if (unlikely(f.file->f_op != &inotify_fops))
2d9048e2 739 goto out;
2d9048e2 740
2903ff01 741 group = f.file->private_data;
2d9048e2 742
b7ba8371 743 ret = -EINVAL;
000285de
EP
744 i_mark = inotify_idr_find(group, wd);
745 if (unlikely(!i_mark))
63c882a0 746 goto out;
63c882a0 747
b7ba8371
EP
748 ret = 0;
749
e2a29943 750 fsnotify_destroy_mark(&i_mark->fsn_mark, group);
b7ba8371
EP
751
752 /* match ref taken by inotify_idr_find */
000285de 753 fsnotify_put_mark(&i_mark->fsn_mark);
2d9048e2
AG
754
755out:
2903ff01 756 fdput(f);
2d9048e2
AG
757 return ret;
758}
759
2d9048e2 760/*
ae0e47f0 761 * inotify_user_setup - Our initialization function. Note that we cannot return
2d9048e2
AG
762 * error because we have compiled-in VFS hooks. So an (unlikely) failure here
763 * must result in panic().
764 */
765static int __init inotify_user_setup(void)
766{
f874e1ac
EP
767 BUILD_BUG_ON(IN_ACCESS != FS_ACCESS);
768 BUILD_BUG_ON(IN_MODIFY != FS_MODIFY);
769 BUILD_BUG_ON(IN_ATTRIB != FS_ATTRIB);
770 BUILD_BUG_ON(IN_CLOSE_WRITE != FS_CLOSE_WRITE);
771 BUILD_BUG_ON(IN_CLOSE_NOWRITE != FS_CLOSE_NOWRITE);
772 BUILD_BUG_ON(IN_OPEN != FS_OPEN);
773 BUILD_BUG_ON(IN_MOVED_FROM != FS_MOVED_FROM);
774 BUILD_BUG_ON(IN_MOVED_TO != FS_MOVED_TO);
775 BUILD_BUG_ON(IN_CREATE != FS_CREATE);
776 BUILD_BUG_ON(IN_DELETE != FS_DELETE);
777 BUILD_BUG_ON(IN_DELETE_SELF != FS_DELETE_SELF);
778 BUILD_BUG_ON(IN_MOVE_SELF != FS_MOVE_SELF);
779 BUILD_BUG_ON(IN_UNMOUNT != FS_UNMOUNT);
780 BUILD_BUG_ON(IN_Q_OVERFLOW != FS_Q_OVERFLOW);
781 BUILD_BUG_ON(IN_IGNORED != FS_IN_IGNORED);
782 BUILD_BUG_ON(IN_EXCL_UNLINK != FS_EXCL_UNLINK);
b29866aa 783 BUILD_BUG_ON(IN_ISDIR != FS_ISDIR);
f874e1ac
EP
784 BUILD_BUG_ON(IN_ONESHOT != FS_IN_ONESHOT);
785
786 BUG_ON(hweight32(ALL_INOTIFY_BITS) != 21);
787
000285de 788 inotify_inode_mark_cachep = KMEM_CACHE(inotify_inode_mark, SLAB_PANIC);
63c882a0 789
2d9048e2 790 inotify_max_queued_events = 16384;
1cce1eea
NB
791 init_user_ns.ucount_max[UCOUNT_INOTIFY_INSTANCES] = 128;
792 init_user_ns.ucount_max[UCOUNT_INOTIFY_WATCHES] = 8192;
2d9048e2 793
2d9048e2
AG
794 return 0;
795}
c013d5a4 796fs_initcall(inotify_user_setup);