diff options
Diffstat (limited to 'libcaja-private/caja-monitor.c')
| -rw-r--r-- | libcaja-private/caja-monitor.c | 157 |
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); +} |