gfilemonitor.c 9.43 KB
Newer Older
1 2 3 4 5 6 7
/* GIO - GLib Input, Output and Streaming Library
 * 
 * Copyright (C) 2006-2007 Red Hat, Inc.
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
8
 * version 2.1 of the License, or (at your option) any later version.
9 10 11 12 13 14 15
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General
16
 * Public License along with this library; if not, see <http://www.gnu.org/licenses/>.
17 18 19 20
 *
 * Author: Alexander Larsson <alexl@redhat.com>
 */

21
#include "config.h"
22 23 24
#include <string.h>

#include "gfilemonitor.h"
25
#include "gioenumtypes.h"
26
#include "gmarshal-internal.h"
27
#include "gfile.h"
28 29 30
#include "gvfs.h"
#include "glibintl.h"

31 32 33
/**
 * SECTION:gfilemonitor
 * @short_description: File Monitor
Matthias Clasen's avatar
Matthias Clasen committed
34
 * @include: gio/gio.h
35
 *
36
 * Monitors a file or directory for changes.
Matthias Clasen's avatar
Matthias Clasen committed
37 38
 *
 * To obtain a #GFileMonitor for a file or directory, use
39 40
 * g_file_monitor(), g_file_monitor_file(), or
 * g_file_monitor_directory().
Matthias Clasen's avatar
Matthias Clasen committed
41
 *
42 43
 * To get informed about changes to the file or directory you are
 * monitoring, connect to the #GFileMonitor::changed signal. The
44 45 46
 * signal will be emitted in the
 * [thread-default main context][g-main-context-push-thread-default]
 * of the thread that the monitor was created in
47 48 49
 * (though if the global default main context is blocked, this may
 * cause notifications to be blocked even if the thread-default
 * context is still running).
50 51
 **/

52
#define DEFAULT_RATE_LIMIT_MSECS 800
53

54 55
struct _GFileMonitorPrivate
{
56 57 58
  gboolean cancelled;
};

59 60 61 62
G_DEFINE_ABSTRACT_TYPE_WITH_PRIVATE (GFileMonitor, g_file_monitor, G_TYPE_OBJECT)

enum
{
63 64
  PROP_0,
  PROP_RATE_LIMIT,
65
  PROP_CANCELLED
66 67
};

68
static guint g_file_monitor_changed_signal;
69

70 71 72 73 74 75
static void
g_file_monitor_set_property (GObject      *object,
                             guint         prop_id,
                             const GValue *value,
                             GParamSpec   *pspec)
{
76
  //GFileMonitor *monitor;
77

78
  //monitor = G_FILE_MONITOR (object);
79 80 81 82

  switch (prop_id)
    {
    case PROP_RATE_LIMIT:
83
      /* not supported by default */
84 85
      break;

86 87 88 89 90 91 92 93 94 95 96 97 98 99 100
    default:
      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
      break;
    }
}

static void
g_file_monitor_get_property (GObject    *object,
                             guint       prop_id,
                             GValue     *value,
                             GParamSpec *pspec)
{
  switch (prop_id)
    {
    case PROP_RATE_LIMIT:
101 102
      /* we expect this to be overridden... */
      g_value_set_int (value, DEFAULT_RATE_LIMIT_MSECS);
103 104 105
      break;

    case PROP_CANCELLED:
106 107 108
      //g_mutex_lock (&fms->lock);
      g_value_set_boolean (value, FALSE);//fms->cancelled);
      //g_mutex_unlock (&fms->lock);
109 110 111 112 113 114 115 116
      break;

    default:
      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
      break;
    }
}

117 118 119
static void
g_file_monitor_dispose (GObject *object)
{
120
  GFileMonitor *monitor = G_FILE_MONITOR (object);
121 122

  /* Make sure we cancel on last unref */
123
  g_file_monitor_cancel (monitor);
124 125

  G_OBJECT_CLASS (g_file_monitor_parent_class)->dispose (object);
126 127
}

128 129 130 131 132 133
static void
g_file_monitor_init (GFileMonitor *monitor)
{
  monitor->priv = g_file_monitor_get_instance_private (monitor);
}

134 135 136
static void
g_file_monitor_class_init (GFileMonitorClass *klass)
{
137
  GObjectClass *object_class;
138

139 140 141 142
  object_class = G_OBJECT_CLASS (klass);
  object_class->dispose = g_file_monitor_dispose;
  object_class->get_property = g_file_monitor_get_property;
  object_class->set_property = g_file_monitor_set_property;
143

144 145 146 147
  /**
   * GFileMonitor::changed:
   * @monitor: a #GFileMonitor.
   * @file: a #GFile.
148
   * @other_file: (nullable): a #GFile or #NULL.
149
   * @event_type: a #GFileMonitorEvent.
150 151 152
   *
   * Emitted when @file has been changed.
   *
153
   * If using %G_FILE_MONITOR_WATCH_MOVES on a directory monitor, and
154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171
   * the information is available (and if supported by the backend),
   * @event_type may be %G_FILE_MONITOR_EVENT_RENAMED,
   * %G_FILE_MONITOR_EVENT_MOVED_IN or %G_FILE_MONITOR_EVENT_MOVED_OUT.
   *
   * In all cases @file will be a child of the monitored directory.  For
   * renames, @file will be the old name and @other_file is the new
   * name.  For "moved in" events, @file is the name of the file that
   * appeared and @other_file is the old name that it was moved from (in
   * another directory).  For "moved out" events, @file is the name of
   * the file that used to be in this directory and @other_file is the
   * name of the file at its new location.
   *
   * It makes sense to treat %G_FILE_MONITOR_EVENT_MOVED_IN as
   * equivalent to %G_FILE_MONITOR_EVENT_CREATED and
   * %G_FILE_MONITOR_EVENT_MOVED_OUT as equivalent to
   * %G_FILE_MONITOR_EVENT_DELETED, with extra information.
   * %G_FILE_MONITOR_EVENT_RENAMED is equivalent to a delete/create
   * pair.  This is exactly how the events will be reported in the case
172
   * that the %G_FILE_MONITOR_WATCH_MOVES flag is not in use.
173 174
   *
   * If using the deprecated flag %G_FILE_MONITOR_SEND_MOVED flag and @event_type is
Dan Winship's avatar
Dan Winship committed
175
   * #G_FILE_MONITOR_EVENT_MOVED, @file will be set to a #GFile containing the
176 177 178
   * old path, and @other_file will be set to a #GFile containing the new path.
   *
   * In all the other cases, @other_file will be set to #NULL.
179
   **/
180 181 182 183 184
  g_file_monitor_changed_signal = g_signal_new (I_("changed"),
                                                G_TYPE_FILE_MONITOR,
                                                G_SIGNAL_RUN_LAST,
                                                G_STRUCT_OFFSET (GFileMonitorClass, changed),
                                                NULL, NULL,
185
                                                _g_cclosure_marshal_VOID__OBJECT_OBJECT_ENUM,
186 187
                                                G_TYPE_NONE, 3,
                                                G_TYPE_FILE, G_TYPE_FILE, G_TYPE_FILE_MONITOR_EVENT);
188 189 190
  g_signal_set_va_marshaller (g_file_monitor_changed_signal,
                              G_TYPE_FROM_CLASS (klass),
                              _g_cclosure_marshal_VOID__OBJECT_OBJECT_ENUMv);
191 192

  g_object_class_install_property (object_class, PROP_RATE_LIMIT,
193 194 195
                                   g_param_spec_int ("rate-limit",
                                                     P_("Rate limit"),
                                                     P_("The limit of the monitor to watch for changes, in milliseconds"),
196 197
                                                     0, G_MAXINT, DEFAULT_RATE_LIMIT_MSECS, G_PARAM_READWRITE |
                                                     G_PARAM_EXPLICIT_NOTIFY | G_PARAM_STATIC_STRINGS));
198

199
  g_object_class_install_property (object_class, PROP_CANCELLED,
200 201 202
                                   g_param_spec_boolean ("cancelled",
                                                         P_("Cancelled"),
                                                         P_("Whether the monitor has been cancelled"),
203
                                                         FALSE, G_PARAM_READABLE | G_PARAM_STATIC_STRINGS));
204 205 206 207
}

/**
 * g_file_monitor_is_cancelled:
Matthias Clasen's avatar
Matthias Clasen committed
208
 * @monitor: a #GFileMonitor
209
 * 
Matthias Clasen's avatar
Matthias Clasen committed
210 211
 * Returns whether the monitor is canceled.
 *
212 213 214 215 216
 * Returns: %TRUE if monitor is canceled. %FALSE otherwise.
 **/
gboolean
g_file_monitor_is_cancelled (GFileMonitor *monitor)
{
217
  gboolean res;
218

219 220
  g_return_val_if_fail (G_IS_FILE_MONITOR (monitor), FALSE);

221
  res = monitor->priv->cancelled;
222

223
  return res;
224 225 226 227
}

/**
 * g_file_monitor_cancel:
228
 * @monitor: a #GFileMonitor.
229
 *
230
 * Cancels a file monitor.
231 232
 *
 * Returns: always %TRUE
233 234
 **/
gboolean
235
g_file_monitor_cancel (GFileMonitor *monitor)
236 237
{
  g_return_val_if_fail (G_IS_FILE_MONITOR (monitor), FALSE);
238 239

  if (!monitor->priv->cancelled)
240
    {
241 242 243 244
      G_FILE_MONITOR_GET_CLASS (monitor)->cancel (monitor);

      monitor->priv->cancelled = TRUE;
      g_object_notify (G_OBJECT (monitor), "cancelled");
245
    }
246 247

  return TRUE;
248 249 250 251 252
}

/**
 * g_file_monitor_set_rate_limit:
 * @monitor: a #GFileMonitor.
253 254
 * @limit_msecs: a non-negative integer with the limit in milliseconds
 *     to poll for changes
255
 *
256
 * Sets the rate limit to which the @monitor will report
257 258
 * consecutive change events to the same file.
 */
259 260
void
g_file_monitor_set_rate_limit (GFileMonitor *monitor,
261
                               gint          limit_msecs)
262
{
263
  g_object_set (monitor, "rate-limit", limit_msecs, NULL);
264 265
}

266 267 268 269 270 271 272 273 274 275 276 277 278 279 280
/**
 * g_file_monitor_emit_event:
 * @monitor: a #GFileMonitor.
 * @child: a #GFile.
 * @other_file: a #GFile.
 * @event_type: a set of #GFileMonitorEvent flags.
 *
 * Emits the #GFileMonitor::changed signal if a change
 * has taken place. Should be called from file monitor
 * implementations only.
 *
 * Implementations are responsible to call this method from the
 * [thread-default main context][g-main-context-push-thread-default] of the
 * thread that the monitor was created in.
 **/
281
void
Matthias Clasen's avatar
Matthias Clasen committed
282
g_file_monitor_emit_event (GFileMonitor      *monitor,
283 284 285
                           GFile             *child,
                           GFile             *other_file,
                           GFileMonitorEvent  event_type)
286 287
{
  g_return_if_fail (G_IS_FILE_MONITOR (monitor));
288
  g_return_if_fail (G_IS_FILE (child));
289
  g_return_if_fail (!other_file || G_IS_FILE (other_file));
290

291 292
  if (monitor->priv->cancelled)
    return;
293

294
  g_signal_emit (monitor, g_file_monitor_changed_signal, 0, child, other_file, event_type);
295
}