4aiman/thunar-usagebars
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
thunar-usagebars/thunar/thunar-thumbnail-cache.c

797 lines
23 KiB
C
Raw Normal View History

thunar 4.20.2 upstream Tree of tag thunar-4.20.2 (commit 11a519f) from https://gitlab.xfce.org/xfce/thunar. Upstream history is not included here to keep the repository small.
2025-02-10 09:12:59 +01:00
/* vi:set et ai sw=2 sts=2 ts=2: */
/*-
* Copyright (c) 2011 Jannis Pohlmann <jannis@xfce.org>
*
* 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., 51 Franklin Street, Fifth Floor,
* Boston, MA 02110-1301, USA.
*/
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#include "thunar/thunar-file.h"
#include "thunar/thunar-private.h"
#include "thunar/thunar-thumbnail-cache-proxy.h"
#include "thunar/thunar-thumbnail-cache.h"
#include <gio/gio.h>
#include <glib-object.h>
#include <glib.h>
#define _thumbnail_cache_lock(cache) g_mutex_lock (&((cache)->lock))
#define _thumbnail_cache_unlock(cache) g_mutex_unlock (&((cache)->lock))
static void
thunar_thumbnail_cache_finalize (GObject *object);
enum
{
THUNAR_THUMBNAIL_CACHE_PROXY_AVAILABLE,
THUNAR_THUMBNAIL_CACHE_PROXY_WAITING,
THUNAR_THUMBNAIL_CACHE_PROXY_FAILED
};
struct _ThunarThumbnailCacheClass
{
GObjectClass __parent__;
};
struct _ThunarThumbnailCache
{
GObject __parent__;
ThunarThumbnailCacheDBus *cache_proxy;
int proxy_state;
GList *move_source_queue;
GList *move_target_queue;
guint move_queue_idle_id;
GList *copy_source_queue;
GList *copy_target_queue;
guint copy_queue_idle_id;
GList *delete_queue;
guint delete_queue_idle_id;
GList *cleanup_queue;
guint cleanup_queue_idle_id;
GMutex lock;
};
G_DEFINE_TYPE (ThunarThumbnailCache, thunar_thumbnail_cache, G_TYPE_OBJECT)
static void
thunar_thumbnail_cache_class_init (ThunarThumbnailCacheClass *klass)
{
GObjectClass *gobject_class;
/* Determine the parent type class */
thunar_thumbnail_cache_parent_class = g_type_class_peek_parent (klass);
gobject_class = G_OBJECT_CLASS (klass);
gobject_class->finalize = thunar_thumbnail_cache_finalize;
}
static void
thunar_thumbnail_cache_finalize (GObject *object)
{
ThunarThumbnailCache *cache = THUNAR_THUMBNAIL_CACHE (object);
/* acquire a cache lock */
_thumbnail_cache_lock (cache);
/* drop the move queue idle and all queued files */
if (cache->move_queue_idle_id > 0)
g_source_remove (cache->move_queue_idle_id);
g_list_free_full (cache->move_source_queue, g_object_unref);
g_list_free_full (cache->move_target_queue, g_object_unref);
/* drop the copy queue idle and all queued files */
if (cache->copy_queue_idle_id > 0)
g_source_remove (cache->copy_queue_idle_id);
g_list_free_full (cache->copy_source_queue, g_object_unref);
g_list_free_full (cache->copy_target_queue, g_object_unref);
/* drop the delete queue idle and all queued files */
if (cache->delete_queue_idle_id > 0)
g_source_remove (cache->delete_queue_idle_id);
g_list_free_full (cache->delete_queue, g_object_unref);
/* drop the cleanup queue idle and all queued files */
if (cache->cleanup_queue_idle_id > 0)
g_source_remove (cache->cleanup_queue_idle_id);
g_list_free_full (cache->cleanup_queue, g_object_unref);
/* check if we have a valid cache proxy */
if (cache->cache_proxy != NULL)
g_object_unref (cache->cache_proxy);
/* release the cache lock */
_thumbnail_cache_unlock (cache);
/* release the mutex itself */
g_mutex_clear (&cache->lock);
(*G_OBJECT_CLASS (thunar_thumbnail_cache_parent_class)->finalize) (object);
}
static void
thunar_thumbnail_cache_copy_async_reply (ThunarThumbnailCacheDBus *proxy,
GAsyncResult *res,
gpointer user_data)
{
GList *li;
ThunarFile *file;
GError *error = NULL;
_thunar_return_if_fail (THUNAR_IS_THUMBNAIL_CACHE_DBUS (proxy));
if (!thunar_thumbnail_cache_dbus_call_copy_finish (proxy, res, &error))
{
g_warning ("ThunarThumbnailCache: failed to call Copy(): %s", error->message);
}
g_clear_error (&error);
for (li = user_data; li != NULL; li = li->next)
{
file = thunar_file_cache_lookup (G_FILE (li->data));
if (G_LIKELY (file != NULL))
{
/* if visible, let the view know there might be a thumb */
thunar_file_changed (file);
g_object_unref (file);
}
}
g_list_free_full (user_data, g_object_unref);
}
static void
thunar_thumbnail_cache_move_async_reply (ThunarThumbnailCacheDBus *proxy,
GAsyncResult *res,
gpointer user_data)
{
GList *li;
ThunarFile *file;
GError *error = NULL;
_thunar_return_if_fail (THUNAR_IS_THUMBNAIL_CACHE_DBUS (proxy));
if (!thunar_thumbnail_cache_dbus_call_move_finish (proxy, res, &error))
{
g_warning ("ThunarThumbnailCache: failed to call Move(): %s", error->message);
}
g_clear_error (&error);
for (li = user_data; li != NULL; li = li->next)
{
file = thunar_file_cache_lookup (G_FILE (li->data));
if (G_LIKELY (file != NULL))
{
/* if visible, let the view know there might be a thumb */
thunar_file_changed (file);
g_object_unref (file);
}
}
g_list_free_full (user_data, g_object_unref);
}
static void
thunar_thumbnail_cache_move_async (ThunarThumbnailCache *cache,
const gchar **source_uris,
const gchar **target_uris,
gpointer user_data)
{
_thunar_return_if_fail (THUNAR_IS_THUMBNAIL_CACHE (cache));
_thunar_return_if_fail (source_uris != NULL);
_thunar_return_if_fail (target_uris != NULL);
/* request a thumbnail cache update asynchronously */
thunar_thumbnail_cache_dbus_call_move (cache->cache_proxy,
source_uris, target_uris,
NULL,
(GAsyncReadyCallback) thunar_thumbnail_cache_move_async_reply,
user_data);
}
static void
thunar_thumbnail_cache_copy_async (ThunarThumbnailCache *cache,
const gchar **source_uris,
const gchar **target_uris,
gpointer user_data)
{
_thunar_return_if_fail (THUNAR_IS_THUMBNAIL_CACHE (cache));
_thunar_return_if_fail (source_uris != NULL);
_thunar_return_if_fail (target_uris != NULL);
/* request a thumbnail cache update asynchronously */
thunar_thumbnail_cache_dbus_call_copy (cache->cache_proxy,
source_uris, target_uris,
NULL,
(GAsyncReadyCallback) thunar_thumbnail_cache_copy_async_reply,
user_data);
}
static void
thunar_thumbnail_cache_delete_async (ThunarThumbnailCache *cache,
const gchar **uris)
{
_thunar_return_if_fail (THUNAR_IS_THUMBNAIL_CACHE (cache));
_thunar_return_if_fail (uris != NULL);
/* request a thumbnail cache update asynchronously */
thunar_thumbnail_cache_dbus_call_delete (cache->cache_proxy, uris,
NULL, NULL, NULL);
}
static void
thunar_thumbnail_cache_cleanup_async (ThunarThumbnailCache *cache,
const gchar *const *base_uris)
{
_thunar_return_if_fail (THUNAR_IS_THUMBNAIL_CACHE (cache));
_thunar_return_if_fail (base_uris != NULL);
/* request a thumbnail cache update asynchronously */
thunar_thumbnail_cache_dbus_call_cleanup (cache->cache_proxy,
(const gchar **) base_uris, 0,
NULL, NULL, NULL);
}
static gboolean
thunar_thumbnail_cache_process_queue (ThunarThumbnailCache *cache,
gboolean copy_async)
{
GList *sp;
GList *tp;
gchar **source_uris;
gchar **target_uris;
guint n_uris;
guint n;
GList *source_queue;
GList *target_queue;
_thunar_return_val_if_fail (THUNAR_IS_THUMBNAIL_CACHE (cache), FALSE);
/* acquire a cache lock */
_thumbnail_cache_lock (cache);
/* steal the lists */
if (copy_async)
{
source_queue = cache->copy_source_queue;
cache->copy_source_queue = NULL;
target_queue = cache->copy_target_queue;
cache->copy_target_queue = NULL;
}
else
{
source_queue = cache->move_source_queue;
cache->move_source_queue = NULL;
target_queue = cache->move_target_queue;
cache->move_target_queue = NULL;
}
/* compute how many URIs there are */
n_uris = g_list_length (source_queue);
/* allocate a string array for the URIs */
source_uris = g_new0 (gchar *, n_uris + 1);
target_uris = g_new0 (gchar *, n_uris + 1);
/* fill URI array with file URIs from the move queue */
for (n = 0,
sp = g_list_last (source_queue),
tp = g_list_last (target_queue);
sp != NULL && tp != NULL;
sp = sp->prev, tp = tp->prev, ++n)
{
source_uris[n] = g_file_get_uri (sp->data);
target_uris[n] = g_file_get_uri (tp->data);
/* release the source object */
g_object_unref (sp->data);
}
/* NULL-terminate the URI arrays */
source_uris[n] = NULL;
target_uris[n] = NULL;
if (copy_async)
{
/* asynchronously copy the thumbnails */
thunar_thumbnail_cache_copy_async (cache,
(const gchar **) source_uris,
(const gchar **) target_uris,
target_queue);
}
else
{
/* asynchronously move the thumbnails */
thunar_thumbnail_cache_move_async (cache,
(const gchar **) source_uris,
(const gchar **) target_uris,
target_queue);
}
/* free the URI arrays */
g_strfreev (source_uris);
g_strfreev (target_uris);
/* release the move queue lists */
g_list_free (source_queue);
/* release the cache lock */
_thumbnail_cache_unlock (cache);
return FALSE;
}
static gboolean
thunar_thumbnail_cache_process_move_queue (gpointer user_data)
{
return thunar_thumbnail_cache_process_queue (user_data, FALSE);
}
static void
thunar_thumbnail_cache_process_move_queue_destroy (gpointer user_data)
{
THUNAR_THUMBNAIL_CACHE (user_data)->move_queue_idle_id = 0;
}
static gboolean
thunar_thumbnail_cache_process_copy_queue (gpointer user_data)
{
return thunar_thumbnail_cache_process_queue (user_data, TRUE);
}
static void
thunar_thumbnail_cache_process_copy_queue_destroy (gpointer user_data)
{
THUNAR_THUMBNAIL_CACHE (user_data)->copy_queue_idle_id = 0;
}
static gboolean
thunar_thumbnail_cache_process_delete_queue (gpointer user_data)
{
ThunarThumbnailCache *cache = user_data;
GList *lp;
gchar **uris;
guint n_uris;
guint n;
_thunar_return_val_if_fail (THUNAR_IS_THUMBNAIL_CACHE (cache), FALSE);
/* acquire a cache lock */
_thumbnail_cache_lock (cache);
/* compute how many URIs there are */
n_uris = g_list_length (cache->delete_queue);
/* allocate a string array for the URIs */
uris = g_new0 (gchar *, n_uris + 1);
/* fill URI array with file URIs from the delete queue */
for (lp = g_list_last (cache->delete_queue), n = 0; lp != NULL; lp = lp->prev, ++n)
{
uris[n] = g_file_get_uri (lp->data);
/* release the file object */
g_object_unref (lp->data);
}
/* NULL-terminate the URI array */
uris[n] = NULL;
/* asynchronously delete the thumbnails */
thunar_thumbnail_cache_delete_async (cache, (const gchar **) uris);
/* free the URI array */
g_strfreev (uris);
/* release the delete queue list */
g_list_free (cache->delete_queue);
cache->delete_queue = NULL;
/* reset the delete queue idle ID */
cache->delete_queue_idle_id = 0;
/* release the cache lock */
_thumbnail_cache_unlock (cache);
return FALSE;
}
static gboolean
thunar_thumbnail_cache_process_cleanup_queue (gpointer user_data)
{
ThunarThumbnailCache *cache = user_data;
GList *lp;
gchar **uris;
guint n_uris;
guint n;
_thunar_return_val_if_fail (THUNAR_IS_THUMBNAIL_CACHE (cache), FALSE);
/* acquire a cache lock */
_thumbnail_cache_lock (cache);
/* compute how many URIs there are */
n_uris = g_list_length (cache->cleanup_queue);
/* allocate a string array for the URIs */
uris = g_new0 (gchar *, n_uris + 1);
#ifndef NDEBUG
g_debug ("cleanup:");
#endif
/* fill URI array with file URIs from the cleanup queue */
for (lp = g_list_last (cache->cleanup_queue), n = 0; lp != NULL; lp = lp->prev, ++n)
{
uris[n] = g_file_get_uri (lp->data);
#ifndef NDEBUG
g_debug (" %s", uris[n]);
#endif
/* release the file object */
g_object_unref (lp->data);
}
/* NULL-terminate the URI array */
uris[n] = NULL;
/* asynchronously cleanup the thumbnails */
thunar_thumbnail_cache_cleanup_async (cache, (const gchar *const *) uris);
/* free the URI array */
g_strfreev (uris);
/* release the cleanup queue list */
g_list_free (cache->cleanup_queue);
cache->cleanup_queue = NULL;
/* reset the cleanup queue idle ID */
cache->cleanup_queue_idle_id = 0;
/* release the cache lock */
_thumbnail_cache_unlock (cache);
return FALSE;
}
ThunarThumbnailCache *
thunar_thumbnail_cache_new (void)
{
return g_object_new (THUNAR_TYPE_THUMBNAIL_CACHE, NULL);
}
void
thunar_thumbnail_cache_move_file (ThunarThumbnailCache *cache,
GFile *source_file,
GFile *target_file)
{
GFileInfo *file_info;
gboolean is_symlink = TRUE;
_thunar_return_if_fail (THUNAR_IS_THUMBNAIL_CACHE (cache));
_thunar_return_if_fail (G_IS_FILE (source_file));
_thunar_return_if_fail (G_IS_FILE (target_file));
/* For some weird reason, gio will spam criticals, when we dont query is-hidden/is-backup. So lets just querry all standard attributes */
file_info = g_file_query_info (target_file, "standard::*", G_FILE_QUERY_INFO_NONE, NULL, NULL);
if (file_info != NULL)
{
is_symlink = g_file_info_get_attribute_boolean (file_info, G_FILE_ATTRIBUTE_STANDARD_IS_SYMLINK);
g_object_unref (file_info);
}
/* relative symlinks might point to new files */
/* So if the file is a symlink, or we are not sure, only clear the old cache */
if (is_symlink)
{
thunar_thumbnail_cache_delete_file (cache, source_file);
return;
}
/* acquire a cache lock */
_thumbnail_cache_lock (cache);
/* check if we have a valid proxy for the cache service */
if (cache->proxy_state != THUNAR_THUMBNAIL_CACHE_PROXY_FAILED)
{
/* add the files to the move queue */
cache->move_source_queue = g_list_prepend (cache->move_source_queue,
g_object_ref (source_file));
cache->move_target_queue = g_list_prepend (cache->move_target_queue,
g_object_ref (target_file));
}
if (cache->proxy_state == THUNAR_THUMBNAIL_CACHE_PROXY_AVAILABLE)
{
/* cancel any pending timeout to process the move queue */
if (cache->move_queue_idle_id > 0)
{
g_source_remove (cache->move_queue_idle_id);
cache->move_queue_idle_id = 0;
}
/* process the move queue in a 250ms timeout */
cache->move_queue_idle_id =
g_timeout_add_full (G_PRIORITY_DEFAULT_IDLE, 250, thunar_thumbnail_cache_process_move_queue,
cache, thunar_thumbnail_cache_process_move_queue_destroy);
}
/* release the cache lock */
_thumbnail_cache_unlock (cache);
}
void
thunar_thumbnail_cache_copy_file (ThunarThumbnailCache *cache,
GFile *source_file,
GFile *target_file)
{
GFileInfo *file_info;
gboolean is_symlink = TRUE;
_thunar_return_if_fail (THUNAR_IS_THUMBNAIL_CACHE (cache));
_thunar_return_if_fail (G_IS_FILE (source_file));
_thunar_return_if_fail (G_IS_FILE (target_file));
/* For some weird reason, gio will spam criticals, when we dont query is-hidden/is-backup. So lets just querry all standard attributes */
file_info = g_file_query_info (target_file, "standard::*", G_FILE_QUERY_INFO_NONE, NULL, NULL);
if (file_info != NULL)
{
is_symlink = g_file_info_get_attribute_boolean (file_info, G_FILE_ATTRIBUTE_STANDARD_IS_SYMLINK);
g_object_unref (file_info);
}
/* relative symlinks might point to new files */
/* So if the file is a symlink, or we are not sure, rather dont copy the cache */
if (is_symlink)
return;
/* acquire a cache lock */
_thumbnail_cache_lock (cache);
/* check if we have a valid proxy for the cache service */
if (cache->proxy_state != THUNAR_THUMBNAIL_CACHE_PROXY_FAILED)
{
/* add the files to the copy queues */
cache->copy_source_queue = g_list_prepend (cache->copy_source_queue,
g_object_ref (source_file));
cache->copy_target_queue = g_list_prepend (cache->copy_target_queue,
g_object_ref (target_file));
}
if (cache->proxy_state == THUNAR_THUMBNAIL_CACHE_PROXY_AVAILABLE)
{
/* cancel any pending timeout to process the copy queue */
if (cache->copy_queue_idle_id > 0)
{
g_source_remove (cache->copy_queue_idle_id);
cache->copy_queue_idle_id = 0;
}
/* process the copy queue in a 250ms timeout */
cache->copy_queue_idle_id =
g_timeout_add_full (G_PRIORITY_DEFAULT_IDLE, 500, thunar_thumbnail_cache_process_copy_queue,
cache, thunar_thumbnail_cache_process_copy_queue_destroy);
}
/* release the cache lock */
_thumbnail_cache_unlock (cache);
}
void
thunar_thumbnail_cache_delete_file (ThunarThumbnailCache *cache,
GFile *file)
{
_thunar_return_if_fail (THUNAR_IS_THUMBNAIL_CACHE (cache));
_thunar_return_if_fail (G_IS_FILE (file));
/* acquire a cache lock */
_thumbnail_cache_lock (cache);
/* check if we have a valid proxy for the cache service */
if (cache->proxy_state != THUNAR_THUMBNAIL_CACHE_PROXY_FAILED)
{
/* add the file to the delete queue */
cache->delete_queue = g_list_prepend (cache->delete_queue, g_object_ref (file));
}
if (cache->proxy_state == THUNAR_THUMBNAIL_CACHE_PROXY_AVAILABLE)
{
/* cancel any pending timeout to process the delete queue */
if (cache->delete_queue_idle_id > 0)
{
g_source_remove (cache->delete_queue_idle_id);
cache->delete_queue_idle_id = 0;
}
/* process the delete queue in a 250ms timeout */
cache->delete_queue_idle_id =
g_timeout_add (500, thunar_thumbnail_cache_process_delete_queue, cache);
}
/* release the cache lock */
_thumbnail_cache_unlock (cache);
}
void
thunar_thumbnail_cache_cleanup_file (ThunarThumbnailCache *cache,
GFile *file)
{
_thunar_return_if_fail (THUNAR_IS_THUMBNAIL_CACHE (cache));
_thunar_return_if_fail (G_IS_FILE (file));
/* acquire a cache lock */
_thumbnail_cache_lock (cache);
/* check if we have a valid proxy for the cache service */
if (cache->proxy_state != THUNAR_THUMBNAIL_CACHE_PROXY_FAILED)
{
/* add the file to the cleanup queue */
cache->cleanup_queue = g_list_prepend (cache->cleanup_queue, g_object_ref (file));
}
if (cache->proxy_state == THUNAR_THUMBNAIL_CACHE_PROXY_AVAILABLE)
{
/* cancel any pending timeout to process the cleanup queue */
if (cache->cleanup_queue_idle_id > 0)
{
g_source_remove (cache->cleanup_queue_idle_id);
cache->cleanup_queue_idle_id = 0;
}
/* process the cleanup queue in a 250ms timeout */
cache->cleanup_queue_idle_id =
g_timeout_add (1000, thunar_thumbnail_cache_process_cleanup_queue, cache);
}
/* release the cache lock */
_thumbnail_cache_unlock (cache);
}
static void
thunar_thumbnail_cache_proxy_created (GObject *source,
GAsyncResult *res,
gpointer userdata)
{
ThunarThumbnailCache *cache = THUNAR_THUMBNAIL_CACHE (userdata);
ThunarThumbnailCacheDBus *proxy;
GError *error = NULL;
_thumbnail_cache_lock (cache);
if ((proxy = thunar_thumbnail_cache_dbus_proxy_new_for_bus_finish (res, &error)))
{
cache->cache_proxy = proxy;
cache->proxy_state = THUNAR_THUMBNAIL_CACHE_PROXY_AVAILABLE;
}
else
{
cache->proxy_state = THUNAR_THUMBNAIL_CACHE_PROXY_FAILED;
g_warning ("ThunarThumbnailCache: Couldn't connect to bus service: %s", error->message);
}
g_clear_error (&error);
/* process the move queue in a 250ms timeout */
if (cache->move_source_queue)
cache->move_queue_idle_id =
g_timeout_add_full (G_PRIORITY_DEFAULT_IDLE, 250, thunar_thumbnail_cache_process_move_queue,
cache, thunar_thumbnail_cache_process_move_queue_destroy);
/* process the copy queue in a 250ms timeout */
if (cache->copy_source_queue)
cache->copy_queue_idle_id =
g_timeout_add_full (G_PRIORITY_DEFAULT_IDLE, 500, thunar_thumbnail_cache_process_copy_queue,
cache, thunar_thumbnail_cache_process_copy_queue_destroy);
/* process the delete queue in a 250ms timeout */
if (cache->delete_queue)
cache->delete_queue_idle_id =
g_timeout_add (500, thunar_thumbnail_cache_process_delete_queue, cache);
/* process the cleanup queue in a 250ms timeout */
if (cache->cleanup_queue)
cache->cleanup_queue_idle_id =
g_timeout_add (1000, thunar_thumbnail_cache_process_cleanup_queue, cache);
_thumbnail_cache_unlock (cache);
/* drop additional reference */
g_object_unref (cache);
}
static void
thunar_thumbnail_cache_init (ThunarThumbnailCache *cache)
{
/* create a new mutex for accessing the cache from different threads */
g_mutex_init (&cache->lock);
/* add an additional reference to keep us alive while tre proxy initializes */
g_object_ref (cache);
/* try to connect to D-Bus */
cache->proxy_state = THUNAR_THUMBNAIL_CACHE_PROXY_WAITING;
thunar_thumbnail_cache_dbus_proxy_new_for_bus (G_BUS_TYPE_SESSION,
0,
"org.freedesktop.thumbnails.Cache1",
"/org/freedesktop/thumbnails/Cache1",
NULL,
thunar_thumbnail_cache_proxy_created,
cache);
}
Reference in a new issue Copy permalink