Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 207691
b: refs/heads/master
c: 43ed7e1
h: refs/heads/master
i:
  207689: 8e73dcb
  207687: bf927a5
v: v3
  • Loading branch information
Eric Paris committed Jul 28, 2010
1 parent 8076647 commit 3b2c3d8
Show file tree
Hide file tree
Showing 2 changed files with 17 additions and 6 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: 6e5f77b32e9097a8a68a8d453799676cacf70cad
refs/heads/master: 43ed7e16a8b47059d7f6ff67ba76f383a2421de3
21 changes: 16 additions & 5 deletions trunk/fs/notify/fanotify/fanotify.c
Original file line number Diff line number Diff line change
Expand Up @@ -27,24 +27,30 @@ static bool should_merge(struct fsnotify_event *old, struct fsnotify_event *new)
return false;
}

/* Note, if we return an event in *arg that a reference is being held... */
static int fanotify_merge(struct list_head *list,
struct fsnotify_event *event,
void **arg)
{
struct fsnotify_event_holder *test_holder;
struct fsnotify_event *test_event;
struct fsnotify_event *new_event;
struct fsnotify_event **return_event = (struct fsnotify_event **)arg;
int ret = 0;

pr_debug("%s: list=%p event=%p\n", __func__, list, event);

*return_event = NULL;

/* and the list better be locked by something too! */

list_for_each_entry_reverse(test_holder, list, event_list) {
test_event = test_holder->event;
if (should_merge(test_event, event)) {
ret = -EEXIST;
fsnotify_get_event(test_event);
*return_event = test_event;

ret = -EEXIST;
/* if they are exactly the same we are done */
if (test_event->mask == event->mask)
goto out;
Expand All @@ -66,11 +72,14 @@ static int fanotify_merge(struct list_head *list,
goto out;
}

/* we didn't return the test_event, so drop that ref */
fsnotify_put_event(test_event);
/* the reference we return on new_event is from clone */
*return_event = new_event;

/* build new event and replace it on the list */
new_event->mask = (test_event->mask | event->mask);
fsnotify_replace_event(test_holder, new_event);
/* match ref from fsnotify_clone_event() */
fsnotify_put_event(new_event);

break;
}
Expand All @@ -82,7 +91,7 @@ static int fanotify_merge(struct list_head *list,
static int fanotify_handle_event(struct fsnotify_group *group, struct fsnotify_event *event)
{
int ret;

struct fsnotify_event *used_event;

BUILD_BUG_ON(FAN_ACCESS != FS_ACCESS);
BUILD_BUG_ON(FAN_MODIFY != FS_MODIFY);
Expand All @@ -94,10 +103,12 @@ static int fanotify_handle_event(struct fsnotify_group *group, struct fsnotify_e

pr_debug("%s: group=%p event=%p\n", __func__, group, event);

ret = fsnotify_add_notify_event(group, event, NULL, fanotify_merge, NULL);
ret = fsnotify_add_notify_event(group, event, NULL, fanotify_merge, (void **)&used_event);
/* -EEXIST means this event was merged with another, not that it was an error */
if (ret == -EEXIST)
ret = 0;
if (used_event)
fsnotify_put_event(used_event);
return ret;
}

Expand Down

0 comments on commit 3b2c3d8

Please sign in to comment.