1 files changed, 157 insertions, 0 deletions
diff --git a/libcaja-private/caja-monitor.c b/libcaja-private/caja-monitor.c
new file mode 100644
index 00000000..0a8a2e34
--- /dev/null
+++ b/libcaja-private/caja-monitor.c
@@ -0,0 +1,157 @@
+/* -*- Mode: C; indent-tabs-mode: t; c-basic-offset: 8; tab-width: 8 -*-
+
+ caja-monitor.c: file and directory change monitoring for caja
+
+ Copyright (C) 2000, 2001 Eazel, Inc.
+
+ This program is free software; you can redistribute it and/or
+ modify it under the terms of the GNU General Public License as
+ published by the Free Software Foundation; either version 2 of the
+ License, or (at your option) any later version.
+
+ This program 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
+ General Public License for more details.
+
+ You should have received a copy of the GNU General Public
+ License along with this program; if not, write to the
+ Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+ Boston, MA 02111-1307, USA.
+
+ Authors: Seth Nickell <[email protected]>
+ Darin Adler <[email protected]>
+ Alex Graveley <[email protected]>
+*/
+
+#include <config.h>
+#include "caja-monitor.h"
+#include "caja-file-changes-queue.h"
+#include "caja-file-utilities.h"
+
+#include <gio/gio.h>
+
+struct CajaMonitor
+{
+ GFileMonitor *monitor;
+};
+
+gboolean
+caja_monitor_active (void)
+{
+ static gboolean tried_monitor = FALSE;
+ static gboolean monitor_success;
+ GFileMonitor *dir_monitor;
+ GFile *file;
+
+ if (tried_monitor == FALSE)
+ {
+ file = g_file_new_for_path (g_get_home_dir ());
+ dir_monitor = g_file_monitor_directory (file, G_FILE_MONITOR_NONE, NULL, NULL);
+ g_object_unref (file);
+
+ monitor_success = (dir_monitor != NULL);
+ if (dir_monitor)
+ {
+ g_object_unref (dir_monitor);
+ }
+
+ tried_monitor = TRUE;
+ }
+
+ return monitor_success;
+}
+
+static gboolean call_consume_changes_idle_id = 0;
+
+static gboolean
+call_consume_changes_idle_cb (gpointer not_used)
+{
+ caja_file_changes_consume_changes (TRUE);
+ call_consume_changes_idle_id = 0;
+ return FALSE;
+}
+
+static void
+dir_changed (GFileMonitor* monitor,
+ GFile *child,
+ GFile *other_file,
+ GFileMonitorEvent event_type,
+ gpointer user_data)
+{
+ char *uri, *to_uri;
+
+ uri = g_file_get_uri (child);
+ to_uri = NULL;
+ if (other_file)
+ {
+ to_uri = g_file_get_uri (other_file);
+ }
+
+ switch (event_type)
+ {
+ default:
+ case G_FILE_MONITOR_EVENT_CHANGED:
+ /* ignore */
+ break;
+ case G_FILE_MONITOR_EVENT_ATTRIBUTE_CHANGED:
+ case G_FILE_MONITOR_EVENT_CHANGES_DONE_HINT:
+ caja_file_changes_queue_file_changed (child);
+ break;
+ case G_FILE_MONITOR_EVENT_DELETED:
+ caja_file_changes_queue_file_removed (child);
+ break;
+ case G_FILE_MONITOR_EVENT_CREATED:
+ caja_file_changes_queue_file_added (child);
+ break;
+
+ case G_FILE_MONITOR_EVENT_PRE_UNMOUNT:
+ /* TODO: Do something */
+ break;
+ case G_FILE_MONITOR_EVENT_UNMOUNTED:
+ /* TODO: Do something */
+ break;
+ }
+
+ g_free (uri);
+ g_free (to_uri);
+
+ if (call_consume_changes_idle_id == 0)
+ {
+ call_consume_changes_idle_id =
+ g_idle_add (call_consume_changes_idle_cb, NULL);
+ }
+}
+
+CajaMonitor *
+caja_monitor_directory (GFile *location)
+{
+ GFileMonitor *dir_monitor;
+ CajaMonitor *ret;
+
+ dir_monitor = g_file_monitor_directory (location, G_FILE_MONITOR_WATCH_MOUNTS, NULL, NULL);
+
+ ret = g_new0 (CajaMonitor, 1);
+ ret->monitor = dir_monitor;
+
+ if (ret->monitor)
+ {
+ g_signal_connect (ret->monitor, "changed", (GCallback)dir_changed, ret);
+ }
+
+ /* We return a monitor even on failure, so we can avoid later trying again */
+ return ret;
+}
+
+void
+caja_monitor_cancel (CajaMonitor *monitor)
+{
+ if (monitor->monitor != NULL)
+ {
+ g_signal_handlers_disconnect_by_func (monitor->monitor, dir_changed, monitor);
+ g_file_monitor_cancel (monitor->monitor);
+ g_object_unref (monitor->monitor);
+ }
+
+ g_free (monitor);
+}