smbd/notify_inotify.c

ソースコードを見る。

データ構造
struct	inotify_private
struct	inotify_watch_context
関数
static int	inotify_init (void)
static int	inotify_add_watch (int fd, const char *path, __u32 mask)
static int	inotify_rm_watch (int fd, int wd)
static int	inotify_destructor (struct inotify_private *in)
static BOOL	filter_match (struct inotify_watch_context *w, struct inotify_event *e)
static void	inotify_dispatch (struct inotify_private *in, struct inotify_event *e, uint32_t prev_cookie, struct inotify_event *e2)
static void	inotify_handler (struct event_context *ev, struct fd_event *fde, uint16_t flags, void *private_data)
static NTSTATUS	inotify_setup (struct sys_notify_context *ctx)
static uint32_t	inotify_map (struct notify_entry *e)
static int	watch_destructor (struct inotify_watch_context *w)
NTSTATUS	inotify_watch (struct sys_notify_context *ctx, struct notify_entry *e, void(*callback)(struct sys_notify_context *ctx, void *private_data, struct notify_event *ev), void *private_data, void *handle_p)
変数
struct {
uint32_t   notify_mask
uint32_t   inotify_mask
}	inotify_mapping []

---

関数

static int inotify_init

(

void

)

[static]

notify_inotify.c の 42 行で定義されています。

参照元 inotify_setup().

{
        return syscall(__NR_inotify_init);
}

static int inotify_add_watch	(	int	fd,
		const char *	path,
		__u32	mask
	)			[static]

notify_inotify.c の 47 行で定義されています。

参照元 inotify_watch().

{
        return syscall(__NR_inotify_add_watch, fd, path, mask);
}

static int inotify_rm_watch	(	int	fd,
		int	wd
	)			[static]

notify_inotify.c の 52 行で定義されています。

参照元 inotify_watch()・watch_destructor().

{
        return syscall(__NR_inotify_rm_watch, fd, wd);
}

static int inotify_destructor

(

struct inotify_private *

in

)

[static]

notify_inotify.c の 95 行で定義されています。

参照先 inotify_private::fd.

参照元 inotify_setup().

{
        close(in->fd);
        return 0;
}

static BOOL filter_match	(	struct inotify_watch_context *	w,
		struct inotify_event *	e
	)			[static]

notify_inotify.c の 106 行で定義されています。

参照先 inotify_watch_context::filter・inotify_watch_context::mask.

参照元 inotify_dispatch().

{
        DEBUG(10, ("filter_match: e->mask=%x, w->mask=%x, w->filter=%x\n",
                   e->mask, w->mask, w->filter));

        if ((e->mask & w->mask) == 0) {
                /* this happens because inotify_add_watch() coalesces watches on the same
                   path, oring their masks together */
                return False;
        }

        /* SMB separates the filters for files and directories */
        if (e->mask & IN_ISDIR) {
                if ((w->filter & FILE_NOTIFY_CHANGE_DIR_NAME) == 0) {
                        return False;
                }
        } else {
                if ((e->mask & IN_ATTRIB) &&
                    (w->filter & (FILE_NOTIFY_CHANGE_ATTRIBUTES|
                                  FILE_NOTIFY_CHANGE_LAST_WRITE|
                                  FILE_NOTIFY_CHANGE_LAST_ACCESS|
                                  FILE_NOTIFY_CHANGE_EA|
                                  FILE_NOTIFY_CHANGE_SECURITY))) {
                        return True;
                }
                if ((e->mask & IN_MODIFY) && 
                    (w->filter & FILE_NOTIFY_CHANGE_ATTRIBUTES)) {
                        return True;
                }
                if ((w->filter & FILE_NOTIFY_CHANGE_FILE_NAME) == 0) {
                        return False;
                }
        }

        return True;
}

static void inotify_dispatch	(	struct inotify_private *	in,
		struct inotify_event *	e,
		uint32_t	prev_cookie,
		struct inotify_event *	e2
	)			[static]

notify_inotify.c の 151 行で定義されています。

参照先 notify_event::action・inotify_watch_context::callback・inotify_private::ctx・inotify_watch_context::filter・filter_match()・inotify_watch_context::next・notify_event::path・inotify_watch_context::private_data・inotify_private::watches・inotify_watch_context::wd.

参照元 inotify_handler().

{
        struct inotify_watch_context *w, *next;
        struct notify_event ne;

        DEBUG(10, ("inotify_dispatch called with mask=%x, name=[%s]\n",
                   e->mask, e->len ? e->name : ""));

        /* ignore extraneous events, such as unmount and IN_IGNORED events */
        if ((e->mask & (IN_ATTRIB|IN_MODIFY|IN_CREATE|IN_DELETE|
                        IN_MOVED_FROM|IN_MOVED_TO)) == 0) {
                return;
        }

        /* map the inotify mask to a action. This gets complicated for
           renames */
        if (e->mask & IN_CREATE) {
                ne.action = NOTIFY_ACTION_ADDED;
        } else if (e->mask & IN_DELETE) {
                ne.action = NOTIFY_ACTION_REMOVED;
        } else if (e->mask & IN_MOVED_FROM) {
                if (e2 != NULL && e2->cookie == e->cookie) {
                        ne.action = NOTIFY_ACTION_OLD_NAME;
                } else {
                        ne.action = NOTIFY_ACTION_REMOVED;
                }
        } else if (e->mask & IN_MOVED_TO) {
                if (e->cookie == prev_cookie) {
                        ne.action = NOTIFY_ACTION_NEW_NAME;
                } else {
                        ne.action = NOTIFY_ACTION_ADDED;
                }
        } else {
                ne.action = NOTIFY_ACTION_MODIFIED;
        }
        ne.path = e->name;

        DEBUG(10, ("inotify_dispatch: ne.action = %d, ne.path = %s\n",
                   ne.action, ne.path));

        /* find any watches that have this watch descriptor */
        for (w=in->watches;w;w=next) {
                next = w->next;
                if (w->wd == e->wd && filter_match(w, e)) {
                        w->callback(in->ctx, w->private_data, &ne);
                }
        }

        /* SMB expects a file rename to generate three events, two for
           the rename and the other for a modify of the
           destination. Strange! */
        if (ne.action != NOTIFY_ACTION_NEW_NAME ||
            (e->mask & IN_ISDIR) != 0) {
                return;
        }

        ne.action = NOTIFY_ACTION_MODIFIED;
        e->mask = IN_ATTRIB;
        
        for (w=in->watches;w;w=next) {
                next = w->next;
                if (w->wd == e->wd && filter_match(w, e) &&
                    !(w->filter & FILE_NOTIFY_CHANGE_CREATION)) {
                        w->callback(in->ctx, w->private_data, &ne);
                }
        }
}

static void inotify_handler	(	struct event_context *	ev,
		struct fd_event *	fde,
		uint16_t	flags,
		void *	private_data
	)			[static]

notify_inotify.c の 225 行で定義されています。

参照先 inotify_private::broken_inotify・errno・inotify_private::fd・inotify_dispatch()・talloc_free().

参照元 inotify_setup().

{
        struct inotify_private *in = talloc_get_type(private_data,
                                                     struct inotify_private);
        int bufsize = 0;
        struct inotify_event *e0, *e;
        uint32_t prev_cookie=0;

        /*
          we must use FIONREAD as we cannot predict the length of the
          filenames, and thus can't know how much to allocate
          otherwise
        */

        if ((ioctl(in->fd, FIONREAD, &bufsize) != 0) && (errno == EACCES)) {
                /*
                 * Workaround for broken SELinux policies on Fedora
                 */
                TALLOC_FREE(fde);
                in->broken_inotify = True;
                return;
        }
        if (bufsize == 0) {
                DEBUG(0,("No data on inotify fd?!\n"));
                return;
        }

        e0 = e = (struct inotify_event *)TALLOC_SIZE(in, bufsize);
        if (e == NULL) return;

        if (read(in->fd, e0, bufsize) != bufsize) {
                DEBUG(0,("Failed to read all inotify data\n"));
                talloc_free(e0);
                return;
        }

        /* we can get more than one event in the buffer */
        while (bufsize >= sizeof(*e)) {
                struct inotify_event *e2 = NULL;
                bufsize -= e->len + sizeof(*e);
                if (bufsize >= sizeof(*e)) {
                        e2 = (struct inotify_event *)(e->len + sizeof(*e) + (char *)e);
                }
                inotify_dispatch(in, e, prev_cookie, e2);
                prev_cookie = e->cookie;
                e = e2;
        }

        talloc_free(e0);
}

static NTSTATUS inotify_setup

(

struct sys_notify_context *

ctx

)

[static]

notify_inotify.c の 281 行で定義されています。

参照先 inotify_private::broken_inotify・inotify_private::ctx・ctx・errno・event_add_fd()・inotify_private::fd・inotify_destructor()・inotify_handler()・inotify_init()・lp_parm_bool()・map_nt_error_from_unix()・strerror()・talloc_free()・inotify_private::watches.

参照元 inotify_watch().

{
        struct inotify_private *in;

        if (!lp_parm_bool(-1, "notify", "inotify", True)) {
                return NT_STATUS_INVALID_SYSTEM_SERVICE;
        }

        in = talloc(ctx, struct inotify_private);
        NT_STATUS_HAVE_NO_MEMORY(in);
        in->fd = inotify_init();
        if (in->fd == -1) {
                DEBUG(0,("Failed to init inotify - %s\n", strerror(errno)));
                talloc_free(in);
                return map_nt_error_from_unix(errno);
        }
        in->ctx = ctx;
        in->watches = NULL;
        in->broken_inotify = False;

        ctx->private_data = in;
        talloc_set_destructor(in, inotify_destructor);

        /* add a event waiting for the inotify fd to be readable */
        event_add_fd(ctx->ev, in, in->fd, EVENT_FD_READ, inotify_handler, in);
        
        return NT_STATUS_OK;
}

static uint32_t inotify_map

(

struct notify_entry *

e

)

[static]

notify_inotify.c の 328 行で定義されています。

参照先 notify_entry::filter・inotify_mapping・notify_mask.

参照元 inotify_watch().

{
        int i;
        uint32_t out=0;
        for (i=0;i<ARRAY_SIZE(inotify_mapping);i++) {
                if (inotify_mapping[i].notify_mask & e->filter) {
                        out |= inotify_mapping[i].inotify_mask;
                        e->filter &= ~inotify_mapping[i].notify_mask;
                }
        }
        return out;
}

static int watch_destructor

(

struct inotify_watch_context *

w

)

[static]

notify_inotify.c の 344 行で定義されています。

参照先 errno・inotify_private::fd・inotify_watch_context::in・inotify_rm_watch()・inotify_watch_context::next・strerror()・inotify_private::watches・inotify_watch_context::wd.

参照元 inotify_watch().

{
        struct inotify_private *in = w->in;
        int wd = w->wd;
        DLIST_REMOVE(w->in->watches, w);

        /* only rm the watch if its the last one with this wd */
        for (w=in->watches;w;w=w->next) {
                if (w->wd == wd) break;
        }
        if (w == NULL) {
                DEBUG(10, ("Deleting inotify watch %d\n", wd));
                if (inotify_rm_watch(in->fd, wd) == -1) {
                        DEBUG(1, ("inotify_rm_watch returned %s\n",
                                  strerror(errno)));
                }
                
        }
        return 0;
}

NTSTATUS inotify_watch	(	struct sys_notify_context *	ctx,
		struct notify_entry *	e,
		void(*)(struct sys_notify_context *ctx, void *private_data, struct notify_event *ev)	callback,
		void *	private_data,
		void *	handle_p
	)

notify_inotify.c の 370 行で定義されています。

参照先 inotify_private::broken_inotify・inotify_watch_context::callback・errno・inotify_private::fd・notify_entry::filter・inotify_watch_context::filter・handle・inotify_watch_context::in・inotify_add_watch()・inotify_map()・inotify_rm_watch()・inotify_setup()・map_nt_error_from_unix()・inotify_watch_context::mask・inotify_watch_context::path・notify_entry::path・inotify_watch_context::private_data・status・strerror()・talloc_strdup()・watch_destructor()・inotify_private::watches・inotify_watch_context::wd.

参照元 vfswrap_notify_watch().

{
        struct inotify_private *in;
        int wd;
        uint32_t mask;
        struct inotify_watch_context *w;
        uint32_t filter = e->filter;
        void **handle = (void **)handle_p;

        /* maybe setup the inotify fd */
        if (ctx->private_data == NULL) {
                NTSTATUS status;
                status = inotify_setup(ctx);
                NT_STATUS_NOT_OK_RETURN(status);
        }

        in = talloc_get_type(ctx->private_data, struct inotify_private);

        if (in->broken_inotify) {
                return NT_STATUS_OK;
        }

        mask = inotify_map(e);
        if (mask == 0) {
                /* this filter can't be handled by inotify */
                return NT_STATUS_INVALID_PARAMETER;
        }

        /* using IN_MASK_ADD allows us to cope with inotify() returning the same
           watch descriptor for muliple watches on the same path */
        mask |= (IN_MASK_ADD | IN_ONLYDIR);

        /* get a new watch descriptor for this path */
        wd = inotify_add_watch(in->fd, e->path, mask);
        if (wd == -1) {
                e->filter = filter;
                DEBUG(1, ("inotify_add_watch returned %s\n", strerror(errno)));
                return map_nt_error_from_unix(errno);
        }

        DEBUG(10, ("inotify_add_watch for %s mask %x returned wd %d\n",
                   e->path, mask, wd));

        w = talloc(in, struct inotify_watch_context);
        if (w == NULL) {
                inotify_rm_watch(in->fd, wd);
                e->filter = filter;
                return NT_STATUS_NO_MEMORY;
        }

        w->in = in;
        w->wd = wd;
        w->callback = callback;
        w->private_data = private_data;
        w->mask = mask;
        w->filter = filter;
        w->path = talloc_strdup(w, e->path);
        if (w->path == NULL) {
                inotify_rm_watch(in->fd, wd);
                e->filter = filter;
                return NT_STATUS_NO_MEMORY;
        }

        (*handle) = w;

        DLIST_ADD(in->watches, w);

        /* the caller frees the handle to stop watching */
        talloc_set_destructor(w, watch_destructor);
        
        return NT_STATUS_OK;
}

---

変数

uint32_t notify_mask

notify_inotify.c の 316 行で定義されています。

参照元 inotify_map().

uint32_t inotify_mask

notify_inotify.c の 317 行で定義されています。

struct { ... } inotify_mapping[] [static]

参照元 inotify_map().

---