/* 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 * version 2 of the License, or (at your option) any later version. * * 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 * Public License along with this library; if not, write to the * Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, * Boston, MA 02110-1301, USA. * * Author: Alexander Larsson */ #include #include #include #include #include #include "gdaemonvfs.h" #include "gvfsuriutils.h" #include "gdaemonfile.h" #include #include #include #include "gmountspec.h" #include "gvfsurimapper.h" #include "gdaemonvolumemonitor.h" #include "gvfsicon.h" #include "gvfsiconloadable.h" #include #include #include typedef struct { char *type; char *scheme; char **scheme_aliases; int default_port; gboolean host_is_inet; } MountableInfo; struct _GDaemonVfs { GVfs parent; GDBusConnection *async_bus; GVfs *wrapped_vfs; GList *mount_cache; GFile *fuse_root; GHashTable *from_uri_hash; GHashTable *to_uri_hash; MountableInfo **mountable_info; char **supported_uri_schemes; }; struct _GDaemonVfsClass { GVfsClass parent_class; }; G_DEFINE_DYNAMIC_TYPE (GDaemonVfs, g_daemon_vfs, G_TYPE_VFS) static GDaemonVfs *the_vfs = NULL; G_LOCK_DEFINE_STATIC (metadata_proxy); static GVfsMetadata *metadata_proxy = NULL; G_LOCK_DEFINE_STATIC(mount_cache); static void fill_mountable_info (GDaemonVfs *vfs); static void g_daemon_vfs_finalize (GObject *object) { GDaemonVfs *vfs; vfs = G_DAEMON_VFS (object); if (vfs->from_uri_hash) g_hash_table_destroy (vfs->from_uri_hash); if (vfs->to_uri_hash) g_hash_table_destroy (vfs->to_uri_hash); g_strfreev (vfs->supported_uri_schemes); g_clear_object (&vfs->async_bus); g_clear_object (&vfs->wrapped_vfs); /* must chain up */ G_OBJECT_CLASS (g_daemon_vfs_parent_class)->finalize (object); } static MountableInfo * get_mountable_info_for_scheme (GDaemonVfs *vfs, const char *scheme) { MountableInfo *info; int i, j; if (vfs->mountable_info == NULL) return NULL; for (i = 0; vfs->mountable_info[i] != NULL; i++) { info = vfs->mountable_info[i]; if (info->scheme != NULL && strcmp (info->scheme, scheme) == 0) return info; if (info->scheme_aliases != NULL) { for (j = 0; info->scheme_aliases[j] != NULL; j++) { if (strcmp (info->scheme_aliases[j], scheme) == 0) return info; } } } return NULL; } static MountableInfo * get_mountable_info_for_type (GDaemonVfs *vfs, const char *type) { MountableInfo *info; int i; if (vfs->mountable_info == NULL) return NULL; for (i = 0; vfs->mountable_info[i] != NULL; i++) { info = vfs->mountable_info[i]; if (strcmp (info->type, type) == 0) return info; } return NULL; } static void str_tolower_inplace (char *str) { char *p = str; while (*p != 0) { *p = g_ascii_tolower (*p); p++; } } static gboolean get_mountspec_from_uri (GDaemonVfs *vfs, const char *uri, GMountSpec **spec_out, char **path_out) { GMountSpec *spec; char *path; GVfsUriMapper *mapper; char *scheme; scheme = g_uri_parse_scheme (uri); if (scheme == NULL) return FALSE; /* convert the scheme to lower case since g_uri_parse_scheme * doesn't do that and we compare with g_str_equal */ str_tolower_inplace (scheme); spec = NULL; path = NULL; mapper = g_hash_table_lookup (vfs->from_uri_hash, scheme); if (mapper) spec = g_vfs_uri_mapper_from_uri (mapper, uri, &path); if (spec == NULL) { GDecodedUri *decoded; MountableInfo *mountable; char *type; int l; decoded = g_vfs_decode_uri (uri); if (decoded) { mountable = get_mountable_info_for_scheme (vfs, decoded->scheme); if (mountable) type = mountable->type; else type = decoded->scheme; spec = g_mount_spec_new (type); if (decoded->host && *decoded->host) { if (mountable && mountable->host_is_inet) { /* Convert hostname to lower case */ str_tolower_inplace (decoded->host); /* Remove brackets aroung ipv6 addresses */ l = strlen (decoded->host); if (decoded->host[0] == '[' && decoded->host[l - 1] == ']') g_mount_spec_set_with_len (spec, "host", decoded->host+1, l - 2); else g_mount_spec_set (spec, "host", decoded->host); } else g_mount_spec_set (spec, "host", decoded->host); } if (decoded->userinfo && *decoded->userinfo) g_mount_spec_set (spec, "user", decoded->userinfo); if (decoded->port != -1 && (mountable == NULL || mountable->default_port == 0 || mountable->default_port != decoded->port)) { char *port = g_strdup_printf ("%d", decoded->port); g_mount_spec_set (spec, "port", port); g_free (port); } if (decoded->query && *decoded->query) g_mount_spec_set (spec, "query", decoded->query); if (decoded->fragment && *decoded->fragment) g_mount_spec_set (spec, "fragment", decoded->fragment); path = g_strdup (decoded->path); g_vfs_decoded_uri_free (decoded); } } g_free (scheme); if (spec == NULL) return FALSE; *spec_out = spec; *path_out = path; return TRUE; } static void g_daemon_vfs_init (GDaemonVfs *vfs) { GType *mappers; guint n_mappers; const char * const *schemes, * const *mount_types; GVfsUriMapper *mapper; GList *modules; char *file; int i; bindtextdomain (GETTEXT_PACKAGE, GVFS_LOCALEDIR); bind_textdomain_codeset (GETTEXT_PACKAGE, "UTF-8"); vfs->async_bus = g_bus_get_sync (G_BUS_TYPE_SESSION, NULL, NULL); if (vfs->async_bus == NULL) return; /* Not supported, return here and return false in vfs_is_active() */ g_assert (the_vfs == NULL); the_vfs = vfs; /* We disable SIGPIPE globally. This is sort of bad for s library to do since its a global resource. However, without this there is no way to be able to handle mount daemons dying without client apps crashing, which is much worse. I blame Unix, there really should be a portable way to do this on all unixes, but there isn't, even for somewhat modern ones like solaris. */ signal (SIGPIPE, SIG_IGN); fill_mountable_info (vfs); vfs->wrapped_vfs = g_vfs_get_local (); /* Use the old .gvfs location as fallback, not .cache/gvfs */ if (g_get_user_runtime_dir() == g_get_user_cache_dir ()) file = g_build_filename (g_get_home_dir(), ".gvfs", NULL); else file = g_build_filename (g_get_user_runtime_dir(), "gvfs", NULL); vfs->fuse_root = g_vfs_get_file_for_path (vfs->wrapped_vfs, file); g_free (file); modules = g_io_modules_load_all_in_directory (GVFS_MODULE_DIR); vfs->from_uri_hash = g_hash_table_new (g_str_hash, g_str_equal); vfs->to_uri_hash = g_hash_table_new (g_str_hash, g_str_equal); mappers = g_type_children (G_VFS_TYPE_URI_MAPPER, &n_mappers); for (i = 0; i < n_mappers; i++) { int j; mapper = g_object_new (mappers[i], NULL); schemes = g_vfs_uri_mapper_get_handled_schemes (mapper); for (j = 0; schemes != NULL && schemes[j] != NULL; j++) g_hash_table_insert (vfs->from_uri_hash, (char *)schemes[j], mapper); mount_types = g_vfs_uri_mapper_get_handled_mount_types (mapper); for (j = 0; mount_types != NULL && mount_types[j] != NULL; j++) g_hash_table_insert (vfs->to_uri_hash, (char *)mount_types[j], mapper); } /* The above should have ref:ed the modules anyway */ g_list_free_full (modules, (GDestroyNotify)g_type_module_unuse); g_free (mappers); } GDaemonVfs * g_daemon_vfs_new (void) { return g_object_new (G_TYPE_DAEMON_VFS, NULL); } /* This unrefs file if its changed */ static GFile * convert_fuse_path (GVfs *vfs, GFile *file) { GFile *fuse_root; char *fuse_path, *mount_path; GMountInfo *mount_info; fuse_root = ((GDaemonVfs *)vfs)->fuse_root; if (g_file_has_prefix (file, fuse_root)) { fuse_path = g_file_get_path (file); mount_info = _g_daemon_vfs_get_mount_info_by_fuse_sync (fuse_path, &mount_path); g_free (fuse_path); if (mount_info) { g_object_unref (file); file = g_daemon_file_new (mount_info->mount_spec, mount_path); g_free (mount_path); g_mount_info_unref (mount_info); } } return file; } static GFile * g_daemon_vfs_get_file_for_path (GVfs *vfs, const char *path) { GFile *file; file = g_vfs_get_file_for_path (G_DAEMON_VFS (vfs)->wrapped_vfs, path); file = convert_fuse_path (vfs, file); return file; } static GFile * g_daemon_vfs_get_file_for_uri (GVfs *vfs, const char *uri) { GDaemonVfs *daemon_vfs; GFile *file; GMountSpec *spec; char *path; daemon_vfs = G_DAEMON_VFS (vfs); if (g_ascii_strncasecmp (uri, "file:", 5) == 0) { path = g_filename_from_uri (uri, NULL, NULL); if (path == NULL) /* Dummy file */ return g_vfs_get_file_for_uri (G_DAEMON_VFS (vfs)->wrapped_vfs, uri); file = g_daemon_vfs_get_file_for_path (vfs, path); g_free (path); return file; } if (get_mountspec_from_uri (daemon_vfs, uri, &spec, &path)) { file = g_daemon_file_new (spec, path); g_mount_spec_unref (spec); g_free (path); return file; } /* Dummy file */ return g_vfs_get_file_for_uri (G_DAEMON_VFS (vfs)->wrapped_vfs, uri); } GMountSpec * _g_daemon_vfs_get_mount_spec_for_path (GMountSpec *spec, const char *path, const char *new_path) { const char *type; GVfsUriMapper *mapper; GMountSpec *new_spec; type = g_mount_spec_get_type (spec); if (type == NULL) return g_mount_spec_ref (spec); new_spec = NULL; mapper = g_hash_table_lookup (the_vfs->to_uri_hash, type); if (mapper) new_spec = g_vfs_uri_mapper_get_mount_spec_for_path (mapper, spec, path, new_path); if (new_spec == NULL) new_spec = g_mount_spec_ref (spec); return new_spec; } char * _g_daemon_vfs_get_uri_for_mountspec (GMountSpec *spec, char *path, gboolean allow_utf8) { char *uri; const char *type; GVfsUriMapper *mapper; type = g_mount_spec_get_type (spec); if (type == NULL) { GString *string = g_string_new ("unknown://"); if (path) g_string_append_uri_escaped (string, path, "!$&'()*+,;=:@/", allow_utf8); return g_string_free (string, FALSE); } uri = NULL; mapper = g_hash_table_lookup (the_vfs->to_uri_hash, type); if (mapper) uri = g_vfs_uri_mapper_to_uri (mapper, spec, path, allow_utf8); if (uri == NULL) { GDecodedUri decoded; MountableInfo *mountable; const char *port; gboolean free_host; memset (&decoded, 0, sizeof (decoded)); decoded.port = -1; mountable = get_mountable_info_for_type (the_vfs, type); if (mountable) decoded.scheme = mountable->scheme; else decoded.scheme = (char *)type; decoded.host = (char *)g_mount_spec_get (spec, "host"); free_host = FALSE; if (mountable && mountable->host_is_inet && decoded.host != NULL && strchr (decoded.host, ':') != NULL) { free_host = TRUE; decoded.host = g_strconcat ("[", decoded.host, "]", NULL); } decoded.userinfo = (char *)g_mount_spec_get (spec, "user"); port = g_mount_spec_get (spec, "port"); if (port != NULL) decoded.port = atoi (port); if (path == NULL) decoded.path = "/"; else decoded.path = path; decoded.query = (char *)g_mount_spec_get (spec, "query"); decoded.fragment = (char *)g_mount_spec_get (spec, "fragment"); uri = g_vfs_encode_uri (&decoded, FALSE); if (free_host) g_free (decoded.host); } return uri; } const char * _g_daemon_vfs_mountspec_get_uri_scheme (GMountSpec *spec) { const char *type, *scheme; GVfsUriMapper *mapper; MountableInfo *mountable; type = g_mount_spec_get_type (spec); mapper = g_hash_table_lookup (the_vfs->to_uri_hash, type); scheme = NULL; if (mapper) scheme = g_vfs_uri_mapper_to_uri_scheme (mapper, spec); if (scheme == NULL) { mountable = get_mountable_info_for_type (the_vfs, type); if (mountable) scheme = mountable->scheme; else scheme = type; } return scheme; } static int find_string (GPtrArray *array, const char *find_me) { int i; g_return_val_if_fail (find_me != NULL, -1); for (i = 0; i < array->len; ++i) { if (strcmp (g_ptr_array_index (array, i), find_me) == 0) return i; } return -1; } static GVfsDBusMountTracker * create_mount_tracker_proxy () { GVfsDBusMountTracker *proxy; GError *error; error = NULL; proxy = gvfs_dbus_mount_tracker_proxy_new_for_bus_sync (G_BUS_TYPE_SESSION, G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS | G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES, G_VFS_DBUS_DAEMON_NAME, G_VFS_DBUS_MOUNTTRACKER_PATH, NULL, &error); if (proxy == NULL) { g_printerr ("Error creating proxy: %s (%s, %d)\n", error->message, g_quark_to_string (error->domain), error->code); g_error_free (error); } return proxy; } static void fill_mountable_info (GDaemonVfs *vfs) { MountableInfo *info; GPtrArray *infos, *uri_schemes; gint i; GVfsDBusMountTracker *proxy; GVariant *iter_mountables; GError *error; GVariantIter iter; const gchar *type, *scheme, **scheme_aliases; guint scheme_aliases_len; gint32 default_port; gboolean host_is_inet; proxy = create_mount_tracker_proxy (); g_return_if_fail (proxy != NULL); error = NULL; if (!gvfs_dbus_mount_tracker_call_list_mountable_info_sync (proxy, &iter_mountables, NULL, &error)) { /* Don't warn if we're running a new gvfs plugin against an old gvfs-daemon, * as happens in jhbuild. */ if (!g_error_matches (error, G_DBUS_ERROR, G_DBUS_ERROR_UNKNOWN_METHOD)) g_printerr ("org.gtk.vfs.MountTracker.listMountableInfo call failed: %s (%s, %d)\n", error->message, g_quark_to_string (error->domain), error->code); g_error_free (error); g_object_unref (proxy); return; } infos = g_ptr_array_new (); uri_schemes = g_ptr_array_new (); g_ptr_array_add (uri_schemes, g_strdup ("file")); g_variant_iter_init (&iter, iter_mountables); while (g_variant_iter_loop (&iter, "(&s&s^a&sib)", &type, &scheme, &scheme_aliases, &default_port, &host_is_inet)) { info = g_new0 (MountableInfo, 1); info->type = g_strdup (type); if (*scheme != 0) { info->scheme = g_strdup (scheme); if (find_string (uri_schemes, scheme) == -1) g_ptr_array_add (uri_schemes, g_strdup (scheme)); } scheme_aliases_len = g_strv_length ((gchar **) scheme_aliases); if (scheme_aliases_len > 0) { info->scheme_aliases = g_new (char *, scheme_aliases_len + 1); for (i = 0; i < scheme_aliases_len; i++) { info->scheme_aliases[i] = g_strdup (scheme_aliases[i]); if (find_string (uri_schemes, scheme_aliases[i]) == -1) g_ptr_array_add (uri_schemes, g_strdup (scheme_aliases[i])); } info->scheme_aliases[scheme_aliases_len] = NULL; } info->default_port = default_port; info->host_is_inet = host_is_inet; g_ptr_array_add (infos, info); } g_ptr_array_add (uri_schemes, NULL); g_ptr_array_add (infos, NULL); vfs->mountable_info = (MountableInfo **)g_ptr_array_free (infos, FALSE); vfs->supported_uri_schemes = (char **)g_ptr_array_free (uri_schemes, FALSE); g_variant_unref (iter_mountables); g_object_unref (proxy); } static const gchar * const * g_daemon_vfs_get_supported_uri_schemes (GVfs *vfs) { return (const gchar * const *) G_DAEMON_VFS (vfs)->supported_uri_schemes; } static GMountInfo * lookup_mount_info_in_cache_locked (GMountSpec *spec, const char *path) { GMountInfo *info; GList *l; info = NULL; for (l = the_vfs->mount_cache; l != NULL; l = l->next) { GMountInfo *mount_info = l->data; if (g_mount_spec_match_with_path (mount_info->mount_spec, spec, path)) { info = g_mount_info_ref (mount_info); break; } } return info; } static GMountInfo * lookup_mount_info_in_cache (GMountSpec *spec, const char *path) { GMountInfo *info; G_LOCK (mount_cache); info = lookup_mount_info_in_cache_locked (spec, path); G_UNLOCK (mount_cache); return info; } static GMountInfo * lookup_mount_info_by_fuse_path_in_cache (const char *fuse_path, char **mount_path) { GMountInfo *info; GList *l; G_LOCK (mount_cache); info = NULL; for (l = the_vfs->mount_cache; l != NULL; l = l->next) { GMountInfo *mount_info = l->data; if (mount_info->fuse_mountpoint != NULL && g_str_has_prefix (fuse_path, mount_info->fuse_mountpoint)) { int len = strlen (mount_info->fuse_mountpoint); if (fuse_path[len] == 0 || fuse_path[len] == '/') { if (fuse_path[len] == 0) *mount_path = g_strdup ("/"); else *mount_path = g_strdup (fuse_path + len); info = g_mount_info_ref (mount_info); break; } } } G_UNLOCK (mount_cache); return info; } /* * _g_daemon_vfs_invalidate: * @dbus_id: the D-Bus unique name of the backend process * @object_path: the object path of the mount, or %NULL to invalidate * all mounts in that process * * Invalidate cache entries because we get out-of-band information that * something has been mounted or unmounted. */ void _g_daemon_vfs_invalidate (const char *dbus_id, const char *object_path) { GList *l, *next; G_LOCK (mount_cache); for (l = the_vfs->mount_cache; l != NULL; l = next) { GMountInfo *mount_info = l->data; next = l->next; if (strcmp (mount_info->dbus_id, dbus_id) == 0 && (object_path == NULL || strcmp (mount_info->object_path, object_path) == 0)) { the_vfs->mount_cache = g_list_delete_link (the_vfs->mount_cache, l); g_mount_info_unref (mount_info); } } G_UNLOCK (mount_cache); } static GMountInfo * handler_lookup_mount_reply (GVariant *iter, GError **error) { GMountInfo *info; GList *l; gboolean in_cache; info = g_mount_info_from_dbus (iter); if (info == NULL) { g_set_error (error, G_IO_ERROR, G_IO_ERROR_FAILED, _("Error while getting mount info: %s"), "Invalid reply"); return NULL; } G_LOCK (mount_cache); in_cache = FALSE; /* Already in cache from other thread? */ for (l = the_vfs->mount_cache; l != NULL; l = l->next) { GMountInfo *cached_info = l->data; if (g_mount_info_equal (info, cached_info)) { in_cache = TRUE; g_mount_info_unref (info); info = g_mount_info_ref (cached_info); break; } } /* No, lets add it to the cache */ if (!in_cache) the_vfs->mount_cache = g_list_prepend (the_vfs->mount_cache, g_mount_info_ref (info)); G_UNLOCK (mount_cache); return info; } typedef struct { GMountInfoLookupCallback callback; gpointer user_data; GMountInfo *info; GMountSpec *spec; char *path; } GetMountInfoData; static void free_get_mount_info_data (GetMountInfoData *data) { if (data->info) g_mount_info_unref (data->info); if (data->spec) g_mount_spec_unref (data->spec); g_free (data->path); g_free (data); } static void async_get_mount_info_response (GVfsDBusMountTracker *proxy, GAsyncResult *res, gpointer user_data) { GetMountInfoData *data = user_data; GMountInfo *info; GError *error; GVariant *iter_mount; error = NULL; if (! gvfs_dbus_mount_tracker_call_lookup_mount_finish (proxy, &iter_mount, res, &error)) { /* g_warning ("Error from org.gtk.vfs.MountTracker.lookupMount(): %s", error->message); */ data->callback (NULL, data->user_data, error); g_error_free (error); } else { info = handler_lookup_mount_reply (iter_mount, &error); data->callback (info, data->user_data, error); if (info) g_mount_info_unref (info); g_variant_unref (iter_mount); g_clear_error (&error); } free_get_mount_info_data (data); } static gboolean async_get_mount_info_cache_hit (gpointer _data) { GetMountInfoData *data = _data; data->callback (data->info, data->user_data, NULL); free_get_mount_info_data (data); return FALSE; } static void get_mount_info_async_got_proxy_cb (GObject *source_object, GAsyncResult *res, gpointer user_data) { GetMountInfoData *data = user_data; GVfsDBusMountTracker *proxy; GError *error = NULL; proxy = gvfs_dbus_mount_tracker_proxy_new_for_bus_finish (res, &error); if (proxy == NULL) { g_warning ("Error creating MountTracker proxy: %s", error->message); data->callback (NULL, data->user_data, error); free_get_mount_info_data (data); g_error_free (error); return; } gvfs_dbus_mount_tracker_call_lookup_mount (proxy, g_mount_spec_to_dbus_with_path (data->spec, data->path), NULL, (GAsyncReadyCallback) async_get_mount_info_response, data); g_object_unref (proxy); } void _g_daemon_vfs_get_mount_info_async (GMountSpec *spec, const char *path, GMountInfoLookupCallback callback, gpointer user_data) { GMountInfo *info; GetMountInfoData *data; data = g_new0 (GetMountInfoData, 1); data->callback = callback; data->user_data = user_data; data->spec = g_mount_spec_ref (spec); data->path = g_strdup (path); info = lookup_mount_info_in_cache (spec, path); if (info != NULL) { data->info = info; g_idle_add (async_get_mount_info_cache_hit, data); return; } gvfs_dbus_mount_tracker_proxy_new_for_bus (G_BUS_TYPE_SESSION, G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS | G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES, G_VFS_DBUS_DAEMON_NAME, G_VFS_DBUS_MOUNTTRACKER_PATH, NULL, get_mount_info_async_got_proxy_cb, data); } GMountInfo * _g_daemon_vfs_get_mount_info_sync (GMountSpec *spec, const char *path, GCancellable *cancellable, GError **error) { GMountInfo *info; GVfsDBusMountTracker *proxy; GVariant *iter_mount; info = lookup_mount_info_in_cache (spec, path); if (info != NULL) return info; proxy = create_mount_tracker_proxy (); g_return_val_if_fail (proxy != NULL, NULL); if (gvfs_dbus_mount_tracker_call_lookup_mount_sync (proxy, g_mount_spec_to_dbus_with_path (spec, path), &iter_mount, cancellable, error)) { info = handler_lookup_mount_reply (iter_mount, error); g_variant_unref (iter_mount); } g_object_unref (proxy); return info; } GMountInfo * _g_daemon_vfs_get_mount_info_by_fuse_sync (const char *fuse_path, char **mount_path) { GMountInfo *info; int len; const char *mount_path_end; GVfsDBusMountTracker *proxy; GVariant *iter_mount; info = lookup_mount_info_by_fuse_path_in_cache (fuse_path, mount_path); if (info != NULL) return info; proxy = create_mount_tracker_proxy (); g_return_val_if_fail (proxy != NULL, NULL); if (gvfs_dbus_mount_tracker_call_lookup_mount_by_fuse_path_sync (proxy, fuse_path, &iter_mount, NULL, NULL)) { info = handler_lookup_mount_reply (iter_mount, NULL); g_variant_unref (iter_mount); } if (info) { if (info->fuse_mountpoint) { len = strlen (info->fuse_mountpoint); if (fuse_path[len] == 0) mount_path_end = "/"; else mount_path_end = fuse_path + len; *mount_path = g_build_filename (info->mount_spec->mount_prefix, mount_path_end, NULL); } else { /* This could happen if we race with the gvfs fuse mount * at startup of gvfsd... */ g_mount_info_unref (info); info = NULL; } } g_object_unref (proxy); return info; } static GFile * g_daemon_vfs_parse_name (GVfs *vfs, const char *parse_name) { GFile *file; if (g_path_is_absolute (parse_name) || *parse_name == '~') { file = g_vfs_parse_name (G_DAEMON_VFS (vfs)->wrapped_vfs, parse_name); file = convert_fuse_path (vfs, file); } else { file = g_daemon_vfs_get_file_for_uri (vfs, parse_name); } return file; } static gboolean enumerate_keys_callback (const char *key, MetaKeyType type, gpointer value, gpointer user_data) { GFileInfo *info = user_data; char *attr; attr = g_strconcat ("metadata::", key, NULL); if (type == META_KEY_TYPE_STRING) g_file_info_set_attribute_string (info, attr, (char *)value); else g_file_info_set_attribute_stringv (info, attr, (char **)value); g_free (attr); return TRUE; } static void g_daemon_vfs_local_file_add_info (GVfs *vfs, const char *filename, guint64 device, GFileAttributeMatcher *matcher, GFileInfo *info, GCancellable *cancellable, gpointer *extra_data, GDestroyNotify *extra_data_free) { MetaLookupCache *cache; const char *first; char *tree_path; gboolean all; MetaTree *tree; /* Filename may or may not be a symlink, but we should not follow it. However, we want to follow symlinks for all parents that have the same device node */ all = g_file_attribute_matcher_enumerate_namespace (matcher, "metadata"); first = NULL; if (!all) { first = g_file_attribute_matcher_enumerate_next (matcher); if (first == NULL) return; /* No match */ } if (*extra_data == NULL) { *extra_data = meta_lookup_cache_new (); *extra_data_free = (GDestroyNotify)meta_lookup_cache_free; } cache = (MetaLookupCache *)*extra_data; tree = meta_lookup_cache_lookup_path (cache, filename, device, FALSE, &tree_path); if (tree) { meta_tree_enumerate_keys (tree, tree_path, enumerate_keys_callback, info); meta_tree_unref (tree); g_free (tree_path); } } static void g_daemon_vfs_add_writable_namespaces (GVfs *vfs, GFileAttributeInfoList *list) { g_file_attribute_info_list_add (list, "metadata", G_FILE_ATTRIBUTE_TYPE_STRING, /* Also STRINGV, but no way express this ... */ G_FILE_ATTRIBUTE_INFO_COPY_WITH_FILE | G_FILE_ATTRIBUTE_INFO_COPY_WHEN_MOVED); } static gboolean strv_equal (char **a, char **b) { int i; if (g_strv_length (a) != g_strv_length (b)) return FALSE; for (i = 0; a[i] != NULL; i++) { if (strcmp (a[i], b[i]) != 0) return FALSE; } return TRUE; } /* -1 => error, otherwise number of added items */ int _g_daemon_vfs_append_metadata_for_set (GVariantBuilder *builder, MetaTree *tree, const char *path, const char *attribute, GFileAttributeType type, gpointer value) { const char *key; int res; key = attribute + strlen ("metadata::"); res = 0; if (type == G_FILE_ATTRIBUTE_TYPE_STRING) { char *current; const char *val = (char *)value; current = meta_tree_lookup_string (tree, path, key); if (current == NULL || strcmp (current, val) != 0) { res = 1; g_variant_builder_add (builder, "{sv}", key, g_variant_new_string (val)); } g_free (current); } else if (type == G_FILE_ATTRIBUTE_TYPE_STRINGV) { char **current; char **val = (char **)value; current = meta_tree_lookup_stringv (tree, path, key); if (current == NULL || !strv_equal (current, val)) { res = 1; g_variant_builder_add (builder, "{sv}", key, g_variant_new_strv ((const gchar * const *) val, -1)); } g_strfreev (current); } else if (type == G_FILE_ATTRIBUTE_TYPE_INVALID) { if (meta_tree_lookup_key_type (tree, path, key) != META_KEY_TYPE_NONE) { char c = 0; res = 1; /* Byte => unset */ g_variant_builder_add (builder, "{sv}", key, g_variant_new_byte (c)); } } else res = -1; return res; } GVfsMetadata * _g_daemon_vfs_get_metadata_proxy (GCancellable *cancellable, GError **error) { GVfsMetadata *proxy; G_LOCK (metadata_proxy); proxy = NULL; if (metadata_proxy == NULL) { metadata_proxy = gvfs_metadata_proxy_new_for_bus_sync (G_BUS_TYPE_SESSION, G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS | G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES, G_VFS_DBUS_METADATA_NAME, G_VFS_DBUS_METADATA_PATH, cancellable, error); } proxy = metadata_proxy; G_UNLOCK (metadata_proxy); return proxy; } static gboolean g_daemon_vfs_local_file_set_attributes (GVfs *vfs, const char *filename, GFileInfo *info, GFileQueryInfoFlags flags, GCancellable *cancellable, GError **error) { GFileAttributeType type; MetaLookupCache *cache; const char *metatreefile; struct stat statbuf; char **attributes; char *tree_path; MetaTree *tree; int errsv; int i, num_set; gboolean res; int appended; gpointer value; GVfsMetadata *proxy; GVariantBuilder *builder; res = TRUE; if (g_file_info_has_namespace (info, "metadata")) { attributes = g_file_info_list_attributes (info, "metadata"); if (g_lstat (filename, &statbuf) != 0) { errsv = errno; g_set_error (error, G_IO_ERROR, g_io_error_from_errno (errsv), _("Error setting file metadata: %s"), g_strerror (errsv)); error = NULL; /* Don't set further errors */ for (i = 0; attributes[i] != NULL; i++) g_file_info_set_attribute_status (info, attributes[i], G_FILE_ATTRIBUTE_STATUS_ERROR_SETTING); res = FALSE; } else { cache = meta_lookup_cache_new (); tree = meta_lookup_cache_lookup_path (cache, filename, statbuf.st_dev, FALSE, &tree_path); proxy = _g_daemon_vfs_get_metadata_proxy (NULL, error); if (proxy == NULL) { res = FALSE; error = NULL; /* Don't set further errors */ } else { builder = g_variant_builder_new (G_VARIANT_TYPE_VARDICT); metatreefile = meta_tree_get_filename (tree); num_set = 0; for (i = 0; attributes[i] != NULL; i++) { if (g_file_info_get_attribute_data (info, attributes[i], &type, &value, NULL)) { appended = _g_daemon_vfs_append_metadata_for_set (builder, tree, tree_path, attributes[i], type, value); if (appended != -1) { num_set += appended; g_file_info_set_attribute_status (info, attributes[i], G_FILE_ATTRIBUTE_STATUS_SET); } else { res = FALSE; g_set_error (error, G_IO_ERROR, G_IO_ERROR_INVALID_ARGUMENT, _("Error setting file metadata: %s"), _("values must be string or list of strings")); error = NULL; /* Don't set further errors */ g_file_info_set_attribute_status (info, attributes[i], G_FILE_ATTRIBUTE_STATUS_ERROR_SETTING); } } } if (num_set > 0 && ! gvfs_metadata_call_set_sync (proxy, metatreefile, tree_path, g_variant_builder_end (builder), NULL, error)) { res = FALSE; error = NULL; /* Don't set further errors */ for (i = 0; attributes[i] != NULL; i++) g_file_info_set_attribute_status (info, attributes[i], G_FILE_ATTRIBUTE_STATUS_ERROR_SETTING); } g_variant_builder_unref (builder); meta_lookup_cache_free (cache); meta_tree_unref (tree); g_free (tree_path); } } g_strfreev (attributes); } return res; } static void g_daemon_vfs_local_file_removed (GVfs *vfs, const char *filename) { MetaLookupCache *cache; const char *metatreefile; MetaTree *tree; char *tree_path; GVfsMetadata *proxy; cache = meta_lookup_cache_new (); tree = meta_lookup_cache_lookup_path (cache, filename, 0, FALSE, &tree_path); if (tree) { proxy = _g_daemon_vfs_get_metadata_proxy (NULL, NULL); if (proxy) { metatreefile = meta_tree_get_filename (tree); /* we don't care about the result, let's queue the call and don't block */ gvfs_metadata_call_remove (proxy, metatreefile, tree_path, NULL, NULL, /* callback */ NULL); /* flush the call with the expense of sending all queued messages on the connection */ g_dbus_connection_flush_sync (g_dbus_proxy_get_connection (G_DBUS_PROXY (proxy)), NULL, NULL); } meta_tree_unref (tree); g_free (tree_path); } meta_lookup_cache_free (cache); } static void g_daemon_vfs_local_file_moved (GVfs *vfs, const char *source, const char *dest) { MetaLookupCache *cache; const char *metatreefile; MetaTree *tree1, *tree2; char *tree_path1, *tree_path2; GVfsMetadata *proxy; cache = meta_lookup_cache_new (); tree1 = meta_lookup_cache_lookup_path (cache, source, 0, FALSE, &tree_path1); tree2 = meta_lookup_cache_lookup_path (cache, dest, 0, FALSE, &tree_path2); if (tree1 && tree2 && tree1 == tree2) { proxy = _g_daemon_vfs_get_metadata_proxy (NULL, NULL); if (proxy) { metatreefile = meta_tree_get_filename (tree1); /* we don't care about the result, let's queue the call and don't block */ gvfs_metadata_call_move (proxy, metatreefile, tree_path1, tree_path2, NULL, NULL, /* callback */ NULL); /* flush the call with the expense of sending all queued messages on the connection */ g_dbus_connection_flush_sync (g_dbus_proxy_get_connection (G_DBUS_PROXY (proxy)), NULL, NULL); } } if (tree1) { meta_tree_unref (tree1); g_free (tree_path1); } if (tree2) { meta_tree_unref (tree2); g_free (tree_path2); } meta_lookup_cache_free (cache); } static GIcon * g_daemon_vfs_deserialize_icon (GVfs *vfs, GVariant *value) { return g_vfs_icon_deserialize (value); } GDBusConnection * _g_daemon_vfs_get_async_bus (void) { return the_vfs->async_bus; } static gboolean g_daemon_vfs_is_active (GVfs *vfs) { GDaemonVfs *daemon_vfs = G_DAEMON_VFS (vfs); return daemon_vfs->async_bus != NULL; } static void g_daemon_vfs_class_finalize (GDaemonVfsClass *klass) { } static void g_daemon_vfs_class_init (GDaemonVfsClass *class) { GObjectClass *object_class; GVfsClass *vfs_class; object_class = (GObjectClass *) class; g_daemon_vfs_parent_class = g_type_class_peek_parent (class); object_class->finalize = g_daemon_vfs_finalize; vfs_class = G_VFS_CLASS (class); vfs_class->is_active = g_daemon_vfs_is_active; vfs_class->get_file_for_path = g_daemon_vfs_get_file_for_path; vfs_class->get_file_for_uri = g_daemon_vfs_get_file_for_uri; vfs_class->get_supported_uri_schemes = g_daemon_vfs_get_supported_uri_schemes; vfs_class->parse_name = g_daemon_vfs_parse_name; vfs_class->local_file_add_info = g_daemon_vfs_local_file_add_info; vfs_class->add_writable_namespaces = g_daemon_vfs_add_writable_namespaces; vfs_class->local_file_set_attributes = g_daemon_vfs_local_file_set_attributes; vfs_class->local_file_removed = g_daemon_vfs_local_file_removed; vfs_class->local_file_moved = g_daemon_vfs_local_file_moved; vfs_class->deserialize_icon = g_daemon_vfs_deserialize_icon; } /* Module API */ void g_vfs_uri_mapper_smb_register (GIOModule *module); void g_vfs_uri_mapper_http_register (GIOModule *module); void g_vfs_uri_mapper_afp_register (GIOModule *module); void g_io_module_load (GIOModule *module) { /* This is so that system daemons can use gio * without spawning private dbus instances. * See bug 526454. */ if (g_getenv ("DBUS_SESSION_BUS_ADDRESS") == NULL) return; /* Make this module resident so that we ground the common * library. If that is unloaded we could get into all kinds * of strange situations. This is safe to do even if we loaded * some other common-using module first as all modules are loaded * before any are freed. */ g_type_module_use (G_TYPE_MODULE (module)); g_daemon_vfs_register_type (G_TYPE_MODULE (module)); g_daemon_volume_monitor_register_types (G_TYPE_MODULE (module)); /* We implement GLoadableIcon only on client side. see comment in common/giconvfs.c */ _g_vfs_icon_add_loadable_interface (); g_io_extension_point_implement (G_VFS_EXTENSION_POINT_NAME, G_TYPE_DAEMON_VFS, "gvfs", 10); g_vfs_uri_mapper_register (module); g_vfs_uri_mapper_smb_register (module); g_vfs_uri_mapper_http_register (module); g_vfs_uri_mapper_afp_register (module); } void g_io_module_unload (GIOModule *module) { } char ** g_io_module_query (void) { char *eps[] = { G_VFS_EXTENSION_POINT_NAME, G_VOLUME_MONITOR_EXTENSION_POINT_NAME, NULL }; return g_strdupv (eps); }