1 /* -*- mode: C; c-file-style: "gnu"; indent-tabs-mode: nil; -*- */
3 /* GIO - GLib Input, Output and Streaming Library
5 * Copyright (C) 2006-2007 Red Hat, Inc.
7 * This library is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Lesser General Public
9 * License as published by the Free Software Foundation; either
10 * version 2 of the License, or (at your option) any later version.
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Lesser General Public License for more details.
17 * You should have received a copy of the GNU Lesser General
18 * Public License along with this library; if not, write to the
19 * Free Software Foundation, Inc., 59 Temple Place, Suite 330,
20 * Boston, MA 02111-1307, USA.
22 * Author: Alexander Larsson <alexl@redhat.com>
23 * David Zeuthen <davidz@redhat.com>
31 #include "gunixvolumemonitor.h"
32 #include "gunixmounts.h"
33 #include "gunixmount.h"
34 #include "gunixvolume.h"
36 #include "gmountprivate.h"
37 #include "giomodule.h"
42 struct _GUnixVolumeMonitor {
43 GNativeVolumeMonitor parent;
45 GUnixMountMonitor *mount_monitor;
47 GList *last_mountpoints;
54 static void mountpoints_changed (GUnixMountMonitor *mount_monitor,
56 static void mounts_changed (GUnixMountMonitor *mount_monitor,
58 static void update_volumes (GUnixVolumeMonitor *monitor);
59 static void update_mounts (GUnixVolumeMonitor *monitor);
61 #define g_unix_volume_monitor_get_type _g_unix_volume_monitor_get_type
62 G_DEFINE_TYPE_WITH_CODE (GUnixVolumeMonitor, g_unix_volume_monitor, G_TYPE_NATIVE_VOLUME_MONITOR,
63 g_io_extension_point_implement (G_NATIVE_VOLUME_MONITOR_EXTENSION_POINT_NAME,
69 g_unix_volume_monitor_finalize (GObject *object)
71 GUnixVolumeMonitor *monitor;
73 monitor = G_UNIX_VOLUME_MONITOR (object);
75 g_signal_handlers_disconnect_by_func (monitor->mount_monitor, mountpoints_changed, monitor);
76 g_signal_handlers_disconnect_by_func (monitor->mount_monitor, mounts_changed, monitor);
78 g_object_unref (monitor->mount_monitor);
80 g_list_foreach (monitor->last_mountpoints, (GFunc)g_unix_mount_point_free, NULL);
81 g_list_free (monitor->last_mountpoints);
82 g_list_foreach (monitor->last_mounts, (GFunc)g_unix_mount_free, NULL);
83 g_list_free (monitor->last_mounts);
85 g_list_foreach (monitor->volumes, (GFunc)g_object_unref, NULL);
86 g_list_free (monitor->volumes);
87 g_list_foreach (monitor->mounts, (GFunc)g_object_unref, NULL);
88 g_list_free (monitor->mounts);
90 G_OBJECT_CLASS (g_unix_volume_monitor_parent_class)->finalize (object);
94 g_unix_volume_monitor_dispose (GObject *object)
96 GUnixVolumeMonitor *monitor;
98 monitor = G_UNIX_VOLUME_MONITOR (object);
99 g_list_foreach (monitor->volumes, (GFunc)g_object_unref, NULL);
100 g_list_free (monitor->volumes);
101 monitor->volumes = NULL;
103 g_list_foreach (monitor->mounts, (GFunc)g_object_unref, NULL);
104 g_list_free (monitor->mounts);
105 monitor->mounts = NULL;
107 G_OBJECT_CLASS (g_unix_volume_monitor_parent_class)->dispose (object);
111 get_mounts (GVolumeMonitor *volume_monitor)
113 GUnixVolumeMonitor *monitor;
116 monitor = G_UNIX_VOLUME_MONITOR (volume_monitor);
118 l = g_list_copy (monitor->mounts);
119 g_list_foreach (l, (GFunc)g_object_ref, NULL);
125 get_volumes (GVolumeMonitor *volume_monitor)
127 GUnixVolumeMonitor *monitor;
130 monitor = G_UNIX_VOLUME_MONITOR (volume_monitor);
132 l = g_list_copy (monitor->volumes);
133 g_list_foreach (l, (GFunc)g_object_ref, NULL);
139 get_connected_drives (GVolumeMonitor *volume_monitor)
145 get_volume_for_uuid (GVolumeMonitor *volume_monitor, const char *uuid)
151 get_mount_for_uuid (GVolumeMonitor *volume_monitor, const char *uuid)
163 get_mount_for_mount_path (const char *mount_path,
164 GCancellable *cancellable)
166 GUnixMountEntry *mount_entry;
169 mount_entry = g_unix_mount_at (mount_path, NULL);
174 /* TODO: Set mountable volume? */
175 mount = _g_unix_mount_new (NULL, mount_entry, NULL);
177 g_unix_mount_free (mount_entry);
179 return G_MOUNT (mount);
183 g_unix_volume_monitor_class_init (GUnixVolumeMonitorClass *klass)
185 GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
186 GVolumeMonitorClass *monitor_class = G_VOLUME_MONITOR_CLASS (klass);
187 GNativeVolumeMonitorClass *native_class = G_NATIVE_VOLUME_MONITOR_CLASS (klass);
189 gobject_class->finalize = g_unix_volume_monitor_finalize;
190 gobject_class->dispose = g_unix_volume_monitor_dispose;
192 monitor_class->get_mounts = get_mounts;
193 monitor_class->get_volumes = get_volumes;
194 monitor_class->get_connected_drives = get_connected_drives;
195 monitor_class->get_volume_for_uuid = get_volume_for_uuid;
196 monitor_class->get_mount_for_uuid = get_mount_for_uuid;
197 monitor_class->is_supported = is_supported;
199 native_class->get_mount_for_mount_path = get_mount_for_mount_path;
203 mountpoints_changed (GUnixMountMonitor *mount_monitor,
206 GUnixVolumeMonitor *unix_monitor = user_data;
208 /* Update both to make sure volumes are created before mounts */
209 update_volumes (unix_monitor);
210 update_mounts (unix_monitor);
214 mounts_changed (GUnixMountMonitor *mount_monitor,
217 GUnixVolumeMonitor *unix_monitor = user_data;
219 /* Update both to make sure volumes are created before mounts */
220 update_volumes (unix_monitor);
221 update_mounts (unix_monitor);
225 g_unix_volume_monitor_init (GUnixVolumeMonitor *unix_monitor)
228 unix_monitor->mount_monitor = g_unix_mount_monitor_new ();
230 g_signal_connect (unix_monitor->mount_monitor,
231 "mounts-changed", G_CALLBACK (mounts_changed),
234 g_signal_connect (unix_monitor->mount_monitor,
235 "mountpoints-changed", G_CALLBACK (mountpoints_changed),
238 update_volumes (unix_monitor);
239 update_mounts (unix_monitor);
243 * g_unix_volume_monitor_new:
245 * Returns: a new #GVolumeMonitor.
248 _g_unix_volume_monitor_new (void)
250 GUnixVolumeMonitor *monitor;
252 monitor = g_object_new (G_TYPE_UNIX_VOLUME_MONITOR, NULL);
254 return G_VOLUME_MONITOR (monitor);
258 diff_sorted_lists (GList *list1,
260 GCompareFunc compare,
266 *added = *removed = NULL;
268 while (list1 != NULL &&
271 order = (*compare) (list1->data, list2->data);
274 *removed = g_list_prepend (*removed, list1->data);
279 *added = g_list_prepend (*added, list2->data);
289 while (list1 != NULL)
291 *removed = g_list_prepend (*removed, list1->data);
294 while (list2 != NULL)
296 *added = g_list_prepend (*added, list2->data);
302 * _g_unix_volume_monitor_lookup_volume_for_mount_path:
306 * Returns: #GUnixVolume for the given @mount_path.
309 _g_unix_volume_monitor_lookup_volume_for_mount_path (GUnixVolumeMonitor *monitor,
310 const char *mount_path)
314 for (l = monitor->volumes; l != NULL; l = l->next)
316 GUnixVolume *volume = l->data;
318 if (_g_unix_volume_has_mount_path (volume, mount_path))
326 find_mount_by_mountpath (GUnixVolumeMonitor *monitor,
327 const char *mount_path)
331 for (l = monitor->mounts; l != NULL; l = l->next)
333 GUnixMount *mount = l->data;
335 if (_g_unix_mount_has_mount_path (mount, mount_path))
343 update_volumes (GUnixVolumeMonitor *monitor)
345 GList *new_mountpoints;
346 GList *removed, *added;
350 new_mountpoints = g_unix_mount_points_get (NULL);
352 new_mountpoints = g_list_sort (new_mountpoints, (GCompareFunc) g_unix_mount_point_compare);
354 diff_sorted_lists (monitor->last_mountpoints,
355 new_mountpoints, (GCompareFunc) g_unix_mount_point_compare,
358 for (l = removed; l != NULL; l = l->next)
360 GUnixMountPoint *mountpoint = l->data;
362 volume = _g_unix_volume_monitor_lookup_volume_for_mount_path (monitor,
363 g_unix_mount_point_get_mount_path (mountpoint));
366 _g_unix_volume_disconnected (volume);
367 monitor->volumes = g_list_remove (monitor->volumes, volume);
368 g_signal_emit_by_name (monitor, "volume-removed", volume);
369 g_signal_emit_by_name (volume, "removed");
370 g_object_unref (volume);
374 for (l = added; l != NULL; l = l->next)
376 GUnixMountPoint *mountpoint = l->data;
378 volume = _g_unix_volume_new (G_VOLUME_MONITOR (monitor), mountpoint);
381 monitor->volumes = g_list_prepend (monitor->volumes, volume);
382 g_signal_emit_by_name (monitor, "volume-added", volume);
387 g_list_free (removed);
388 g_list_foreach (monitor->last_mountpoints,
389 (GFunc)g_unix_mount_point_free, NULL);
390 g_list_free (monitor->last_mountpoints);
391 monitor->last_mountpoints = new_mountpoints;
395 update_mounts (GUnixVolumeMonitor *monitor)
398 GList *removed, *added;
402 const char *mount_path;
404 new_mounts = g_unix_mounts_get (NULL);
406 new_mounts = g_list_sort (new_mounts, (GCompareFunc) g_unix_mount_compare);
408 diff_sorted_lists (monitor->last_mounts,
409 new_mounts, (GCompareFunc) g_unix_mount_compare,
412 for (l = removed; l != NULL; l = l->next)
414 GUnixMountEntry *mount_entry = l->data;
416 mount = find_mount_by_mountpath (monitor, g_unix_mount_get_mount_path (mount_entry));
419 _g_unix_mount_unmounted (mount);
420 monitor->mounts = g_list_remove (monitor->mounts, mount);
421 g_signal_emit_by_name (monitor, "mount-removed", mount);
422 g_signal_emit_by_name (mount, "unmounted");
423 g_object_unref (mount);
427 for (l = added; l != NULL; l = l->next)
429 GUnixMountEntry *mount_entry = l->data;
431 mount_path = g_unix_mount_get_mount_path (mount_entry);
433 volume = _g_unix_volume_monitor_lookup_volume_for_mount_path (monitor, mount_path);
434 mount = _g_unix_mount_new (G_VOLUME_MONITOR (monitor), mount_entry, volume);
437 monitor->mounts = g_list_prepend (monitor->mounts, mount);
438 g_signal_emit_by_name (monitor, "mount-added", mount);
443 g_list_free (removed);
444 g_list_foreach (monitor->last_mounts,
445 (GFunc)g_unix_mount_free, NULL);
446 g_list_free (monitor->last_mounts);
447 monitor->last_mounts = new_mounts;