lib: read_data->read_data_ntstatus

[obnox/samba/samba-obnox.git] / source3 / smbd / notify_inotify.c

diff --git a/source3/smbd/notify_inotify.c b/source3/smbd/notify_inotify.c
index efb659f7c07addd20dd2762cecb54ba463cafe25..a9b7131ef75607e3acc9916c0d0fe1ca2b84788e 100644 (file)
--- a/source3/smbd/notify_inotify.c
+++ b/source3/smbd/notify_inotify.c
@@ -118,6 +118,7 @@ static bool filter_match(struct inotify_watch_context *w,
 */
 static void inotify_dispatch(struct inotify_private *in, 
                             struct inotify_event *e, 
+                            int prev_wd,
                             uint32_t prev_cookie,
                             struct inotify_event *e2)
 {
@@ -140,13 +141,14 @@ static void inotify_dispatch(struct inotify_private *in,
        } 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) {
+               if (e2 != NULL && e2->cookie == e->cookie &&
+                   e2->wd == e->wd) {
                        ne.action = NOTIFY_ACTION_OLD_NAME;
                } else {
                        ne.action = NOTIFY_ACTION_REMOVED;
                }
        } else if (e->mask & IN_MOVED_TO) {
-               if (e->cookie == prev_cookie) {
+               if ((e->cookie == prev_cookie) && (e->wd == prev_wd)) {
                        ne.action = NOTIFY_ACTION_NEW_NAME;
                } else {
                        ne.action = NOTIFY_ACTION_ADDED;
@@ -198,6 +200,7 @@ static void inotify_handler(struct tevent_context *ev, struct tevent_fd *fde,
        int bufsize = 0;
        struct inotify_event *e0, *e;
        uint32_t prev_cookie=0;
+       int prev_wd = -1;
        NTSTATUS status;
 
        /*
@@ -216,7 +219,7 @@ static void inotify_handler(struct tevent_context *ev, struct tevent_fd *fde,
        if (e == NULL) return;
        ((uint8_t *)e)[bufsize] = '\0';
 
-       status = read_data(in->fd, (char *)e0, bufsize);
+       status = read_data_ntstatus(in->fd, (char *)e0, bufsize);
        if (!NT_STATUS_IS_OK(status)) {
                DEBUG(0,("Failed to read all inotify data - %s\n",
                        nt_errstr(status)));
@@ -234,7 +237,8 @@ static void inotify_handler(struct tevent_context *ev, struct tevent_fd *fde,
                if (bufsize >= sizeof(*e)) {
                        e2 = (struct inotify_event *)(e->len + sizeof(*e) + (char *)e);
                }
-               inotify_dispatch(in, e, prev_cookie, e2);
+               inotify_dispatch(in, e, prev_wd, prev_cookie, e2);
+               prev_wd = e->wd;
                prev_cookie = e->cookie;
                e = e2;
        }