git.samba.org / ira / wip.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
Removed version number from file header.
[ira/wip.git] / source3 / smbd / notify_kernel.c
diff --git a/source3/smbd/notify_kernel.c b/source3/smbd/notify_kernel.c
index f78198f207905250e68b5df0841e7ba9459b4969..19ea41e19568b750c321bf91716cf9ed5cdbc02c 100644 (file)
--- a/source3/smbd/notify_kernel.c
+++ b/source3/smbd/notify_kernel.c
@@ -1,7 +1,5 @@
-#define OLD_NTDOMAIN 1
 /*
-   Unix SMB/Netbios implementation.
-   Version 3.0
+   Unix SMB/CIFS implementation.
    change notify handling - linux kernel based implementation
    Copyright (C) Andrew Tridgell 2000
 
@@ -24,10 +22,9 @@
 
 #if HAVE_KERNEL_CHANGE_NOTIFY
 
-extern int DEBUGLEVEL;
-static int fd_pending;
-static unsigned signals_received;
-static unsigned signals_processed;
+static VOLATILE sig_atomic_t fd_pending;
+static VOLATILE sig_atomic_t signals_received;
+static VOLATILE sig_atomic_t signals_processed;
 
 #ifndef DN_ACCESS
 #define DN_ACCESS       0x00000001      /* File accessed in directory */
@@ -35,6 +32,7 @@ static unsigned signals_processed;
 #define DN_CREATE       0x00000004      /* File created in directory */
 #define DN_DELETE       0x00000008      /* File removed from directory */
 #define DN_RENAME       0x00000010      /* File renamed in directory */
+#define DN_ATTRIB       0x00000020      /* File changed attribute */
 #define DN_MULTISHOT    0x80000000      /* Don't remove notifier */
 #endif
 
@@ -62,10 +60,10 @@ struct change_data {
 /****************************************************************************
 the signal handler for change notify
 *****************************************************************************/
-static void signal_handler(int signal, siginfo_t *info, void *unused)
+static void signal_handler(int sig, siginfo_t *info, void *unused)
 {
-       BlockSignals(True, signal);
-       fd_pending = info->si_fd;
+       BlockSignals(True, sig);
+       fd_pending = (sig_atomic_t)info->si_fd;
        signals_received++;
        sys_select_signal();
 }
@@ -73,18 +71,24 @@ static void signal_handler(int signal, siginfo_t *info, void *unused)
 
 
 /****************************************************************************
-check if a change notify should be issued 
+ Check if a change notify should be issued.
+ time non-zero means timeout check (used for hash). Ignore this (async method
+ where time is zero will be used instead).
 *****************************************************************************/
 static BOOL kernel_check_notify(connection_struct *conn, uint16 vuid, char *path, uint32 flags, void *datap, time_t t)
 {
        struct change_data *data = (struct change_data *)datap;
 
-       if (data->directory_handle != fd_pending) return False;
+       if (t)
+               return False;
 
-       DEBUG(3,("kernel change notify on %s fd=%d\n", path, fd_pending));
+       if (data->directory_handle != (int)fd_pending) return False;
 
-       close(fd_pending);
-       data->directory_handle = fd_pending = -1;
+       DEBUG(3,("kernel change notify on %s fd=%d\n", path, (int)fd_pending));
+
+       close((int)fd_pending);
+       fd_pending = (sig_atomic_t)-1;
+       data->directory_handle = -1;
        signals_processed++;
        BlockSignals(False, RT_SIGNAL_NOTIFY);
        return True;
@@ -98,14 +102,14 @@ static void kernel_remove_notify(void *datap)
        struct change_data *data = (struct change_data *)datap;
        int fd = data->directory_handle;
        if (fd != -1) {
-               if (fd == fd_pending) {
-                       fd_pending = -1;
+               if (fd == (int)fd_pending) {
+                       fd_pending = (sig_atomic_t)-1;
                        signals_processed++;
                        BlockSignals(False, RT_SIGNAL_NOTIFY);
                }
                close(fd);
        }
-       free(data);
+       SAFE_FREE(data);
        DEBUG(3,("removed kernel change notify fd=%d\n", fd));
 }
 
@@ -119,7 +123,7 @@ static void *kernel_register_notify(connection_struct *conn, char *path, uint32
        int fd;
        unsigned long kernel_flags;
        
-       fd = dos_open(path, O_RDONLY, 0);
+       fd = conn->vfs_ops.open(conn, path, O_RDONLY, 0);
 
        if (fd == -1) {
                DEBUG(3,("Failed to open directory %s for change notify\n", path));
@@ -131,29 +135,27 @@ static void *kernel_register_notify(connection_struct *conn, char *path, uint32
                return NULL;
        }
 
-       kernel_flags = 0;
-       if (flags & FILE_NOTIFY_CHANGE_FILE_NAME)   kernel_flags |= DN_RENAME|DN_DELETE;
+       kernel_flags = DN_CREATE|DN_DELETE|DN_RENAME; /* creation/deletion changes everything! */
+       if (flags & FILE_NOTIFY_CHANGE_FILE)        kernel_flags |= DN_MODIFY;
        if (flags & FILE_NOTIFY_CHANGE_DIR_NAME)    kernel_flags |= DN_RENAME|DN_DELETE;
-       if (flags & FILE_NOTIFY_CHANGE_ATTRIBUTES)  kernel_flags |= DN_MODIFY;
+       if (flags & FILE_NOTIFY_CHANGE_ATTRIBUTES)  kernel_flags |= DN_ATTRIB;
        if (flags & FILE_NOTIFY_CHANGE_SIZE)        kernel_flags |= DN_MODIFY;
        if (flags & FILE_NOTIFY_CHANGE_LAST_WRITE)  kernel_flags |= DN_MODIFY;
        if (flags & FILE_NOTIFY_CHANGE_LAST_ACCESS) kernel_flags |= DN_ACCESS;
        if (flags & FILE_NOTIFY_CHANGE_CREATION)    kernel_flags |= DN_CREATE;
+       if (flags & FILE_NOTIFY_CHANGE_SECURITY)    kernel_flags |= DN_ATTRIB;
+       if (flags & FILE_NOTIFY_CHANGE_EA)          kernel_flags |= DN_ATTRIB;
+       if (flags & FILE_NOTIFY_CHANGE_FILE_NAME)   kernel_flags |= DN_RENAME|DN_DELETE;
 
        if (fcntl(fd, F_NOTIFY, kernel_flags) == -1) {
                DEBUG(3,("Failed to set async flag for change notify\n"));
                return NULL;
        }
 
-       if (fcntl(fd, F_SETOWN, sys_getpid()) == -1) {
-               DEBUG(3,("Failed to set owner for change notify\n"));
-               return NULL;
-       }
-
        data.directory_handle = fd;
 
-       DEBUG(3,("kernel change notify on %s (flags=0x%x) fd=%d\n", 
-                path, (int)kernel_flags, fd));
+       DEBUG(3,("kernel change notify on %s (ntflags=0x%x flags=0x%x) fd=%d\n", 
+                path, (int)flags, (int)kernel_flags, fd));
 
        return (void *)memdup(&data, sizeof(data));
 }
@@ -168,7 +170,7 @@ static BOOL kernel_notify_available(void)
        if (fd == -1) return False; /* uggh! */
        ret = fcntl(fd, F_NOTIFY, 0);
        close(fd);
-       return ret == 0 || errno != EINVAL;
+       return ret == 0;
 }
 
 
@@ -180,8 +182,6 @@ struct cnotify_fns *kernel_notify_init(void)
        static struct cnotify_fns cnotify;
         struct sigaction act;
 
-       if (!kernel_notify_available()) return NULL;
-
         act.sa_handler = NULL;
         act.sa_sigaction = signal_handler;
         act.sa_flags = SA_SIGINFO;
@@ -190,9 +190,12 @@ struct cnotify_fns *kernel_notify_init(void)
                return NULL;
         }
 
+       if (!kernel_notify_available()) return NULL;
+
        cnotify.register_notify = kernel_register_notify;
        cnotify.check_notify = kernel_check_notify;
        cnotify.remove_notify = kernel_remove_notify;
+       cnotify.select_time = -1;
 
        return &cnotify;
 }
@@ -201,5 +204,3 @@ struct cnotify_fns *kernel_notify_init(void)
 #else
  void notify_kernel_dummy(void) {}
 #endif /* HAVE_KERNEL_CHANGE_NOTIFY */
-
-#undef OLD_NTDOMAIN
Unnamed repository; edit this file 'description' to name the repository.