gio/kqueue/kqueue-helper.c

   1 /*******************************************************************************
   2   Copyright (c) 2011, 2012 Dmitry Matveev <me@dmitrymatveev.co.uk>
   3
   4   Permission is hereby granted, free of charge, to any person obtaining a copy
   5   of this software and associated documentation files (the "Software"), to deal
   6   in the Software without restriction, including without limitation the rights
   7   to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
   8   copies of the Software, and to permit persons to whom the Software is
   9   furnished to do so, subject to the following conditions:
  10
  11   The above copyright notice and this permission notice shall be included in
  12   all copies or substantial portions of the Software.
  13
  14   THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  15   IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  16   FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  17   AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  18   LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  19   OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
  20   THE SOFTWARE.
  21 *******************************************************************************/
  22
  23 #include "config.h"
  24 #include <sys/types.h>
  25 #include <sys/event.h>
  26 #include <sys/time.h>
  27 #include <sys/socket.h>
  28 #include <sys/stat.h>
  29 #include <gio/glocalfile.h>
  30 #include <gio/glocalfilemonitor.h>
  31 #include <gio/gfile.h>
  32 #include <fcntl.h>
  33 #include <unistd.h>
  34 #include <string.h>
  35 #include <errno.h>
  36 #include <pthread.h>
  37 #include "kqueue-helper.h"
  38
  39 typedef struct {
  40   kqueue_sub *sub;
  41   GFileMonitorSource *source;
  42   gboolean handle_deleted;
  43 } handle_ctx;
  44
  45 /**
  46  * handle_created:
  47  * @udata: a pointer to user data (#handle_context).
  48  * @path: file name of a new file.
  49  * @inode: inode number of a new file.
  50  *
  51  * A callback function for the directory diff calculation routine,
  52  * produces G_FILE_MONITOR_EVENT_CREATED event for a created file.
  53  **/
  54 static void
  55 handle_created (void *udata, const char *path, ino_t inode)
  56 {
  57   handle_ctx *ctx = NULL;
  58   gint64 now;
  59   gchar *fullname;
  60   struct stat st;
  61
  62   (void) inode;
  63   ctx = (handle_ctx *) udata;
  64   g_assert (udata != NULL);
  65   g_assert (ctx->sub != NULL);
  66   g_assert (ctx->source != NULL);
  67
  68   now = g_get_monotonic_time ();
  69   g_file_monitor_source_handle_event (ctx->source, G_FILE_MONITOR_EVENT_CREATED, path,
  70                                       NULL, NULL, now);
  71
  72   /* Copied from ih_event_callback to report 'CHANGES_DONE_HINT' earlier. */
  73   fullname = g_build_filename (ctx->sub->filename, path, NULL);
  74   if (stat (fullname, &st) != 0 || !S_ISREG (st.st_mode) || st.st_nlink != 1)
  75     g_file_monitor_source_handle_event (ctx->source, G_FILE_MONITOR_EVENT_CHANGES_DONE_HINT, path,
  76                                         NULL, NULL, now);
  77   g_free (fullname);
  78 }
  79
  80 /**
  81  * handle_deleted:
  82  * @udata: a pointer to user data (#handle_context).
  83  * @path: file name of the removed file.
  84  * @inode: inode number of the removed file.
  85  *
  86  * A callback function for the directory diff calculation routine,
  87  * produces G_FILE_MONITOR_EVENT_DELETED event for a deleted file.
  88  **/
  89 static void
  90 handle_deleted (void *udata, const char *path, ino_t inode)
  91 {
  92   handle_ctx *ctx = NULL;
  93
  94   (void) inode;
  95   ctx = (handle_ctx *) udata;
  96   g_assert (udata != NULL);
  97   g_assert (ctx->sub != NULL);
  98   g_assert (ctx->source != NULL);
  99
 100   if (!ctx->handle_deleted)
 101     return;
 102
 103   g_file_monitor_source_handle_event (ctx->source, G_FILE_MONITOR_EVENT_DELETED, path,
 104                                       NULL, NULL, g_get_monotonic_time ());
 105 }
 106
 107 /**
 108  * handle_moved:
 109  * @udata: a pointer to user data (#handle_context).
 110  * @from_path: file name of the source file.
 111  * @from_inode: inode number of the source file.
 112  * @to_path: file name of the replaced file.
 113  * @to_inode: inode number of the replaced file.
 114  *
 115  * A callback function for the directory diff calculation routine,
 116  * produces G_FILE_MONITOR_EVENT_RENAMED event on a move.
 117  **/
 118 static void
 119 handle_moved (void       *udata,
 120               const char *from_path,
 121               ino_t       from_inode,
 122               const char *to_path,
 123               ino_t       to_inode)
 124 {
 125   handle_ctx *ctx = NULL;
 126
 127   (void) from_inode;
 128   (void) to_inode;
 129
 130   ctx = (handle_ctx *) udata;
 131   g_assert (udata != NULL);
 132   g_assert (ctx->sub != NULL);
 133   g_assert (ctx->source != NULL);
 134
 135   g_file_monitor_source_handle_event (ctx->source, G_FILE_MONITOR_EVENT_RENAMED,
 136                                       from_path, to_path, NULL, g_get_monotonic_time ());
 137 }
 138
 139 /**
 140  * handle_overwritten:
 141  * @data: a pointer to user data (#handle_context).
 142  * @path: file name of the overwritten file.
 143  * @node: inode number of the overwritten file.
 144  *
 145  * A callback function for the directory diff calculation routine,
 146  * produces G_FILE_MONITOR_EVENT_DELETED/CREATED event pair when
 147  * an overwrite occurs in the directory (see dep-list for details).
 148  **/
 149 static void
 150 handle_overwritten (void *udata, const char *path, ino_t inode)
 151 {
 152   handle_ctx *ctx = NULL;
 153
 154   (void) inode;
 155   ctx = (handle_ctx *) udata;
 156   g_assert (udata != NULL);
 157   g_assert (ctx->sub != NULL);
 158   g_assert (ctx->source != NULL);
 159
 160   g_file_monitor_source_handle_event (ctx->source, G_FILE_MONITOR_EVENT_DELETED,
 161                                       path, NULL, NULL, g_get_monotonic_time ());
 162
 163   g_file_monitor_source_handle_event (ctx->source, G_FILE_MONITOR_EVENT_CREATED,
 164                                       path, NULL, NULL, g_get_monotonic_time ());
 165 }
 166
 167 static const traverse_cbs cbs = {
 168   handle_created,
 169   handle_deleted,
 170   handle_moved,
 171   handle_overwritten,
 172   handle_moved,
 173   NULL, /* many added */
 174   NULL, /* many removed */
 175   NULL, /* names updated */
 176 };
 177
 178
 179 void
 180 _kh_dir_diff (kqueue_sub *sub, gboolean handle_deleted)
 181 {
 182   dep_list *was;
 183   handle_ctx ctx;
 184
 185   memset (&ctx, 0, sizeof (handle_ctx));
 186   ctx.sub = sub;
 187   ctx.source = sub->source;
 188   ctx.handle_deleted = handle_deleted;
 189
 190   was = sub->deps;
 191   sub->deps = dl_listing (sub->filename);
 192
 193   dl_calculate (was, sub->deps, &cbs, &ctx);
 194
 195   dl_free (was);
 196 }
 197
 198