[rygel-gst-0-10-plugins] Cleanup RygelMediaExportHarvestingTask.
- From: Krzesimir Nowak <krnowak src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [rygel-gst-0-10-plugins] Cleanup RygelMediaExportHarvestingTask.
- Date: Wed, 30 Jan 2013 10:50:01 +0000 (UTC)
commit c3f2a42f184477b1fa07725d3a0a5dfdd9a1a03b
Author: Krzesimir Nowak <krnowak openismus com>
Date: Wed Jan 30 11:49:39 2013 +0100
Cleanup RygelMediaExportHarvestingTask.
src/media-export/rygel-media-export-harvester.c | 15 +-
src/media-export/rygel-media-export-harvester.h | 3 +
.../rygel-media-export-harvesting-task.c | 2216 ++++++++------------
.../rygel-media-export-harvesting-task.h | 4 +-
4 files changed, 874 insertions(+), 1364 deletions(-)
---
diff --git a/src/media-export/rygel-media-export-harvester.c b/src/media-export/rygel-media-export-harvester.c
index 273d377..5713ede 100644
--- a/src/media-export/rygel-media-export-harvester.c
+++ b/src/media-export/rygel-media-export-harvester.c
@@ -77,6 +77,14 @@ static guint signals [RYGEL_MEDIA_EXPORT_HARVESTER_SIGNALS_COUNT];
#define RYGEL_MEDIA_EXPORT_HARVESTER_FILE_CHANGE_DEFAULT_GRACE_PERIOD ((guint) 5)
+gboolean
+rygel_media_export_harvester_is_eligible (GFileInfo *info) {
+ return (g_str_has_prefix (g_file_info_get_content_type (info), "image/") ||
+ g_str_has_prefix (g_file_info_get_content_type (info), "video/") ||
+ g_str_has_prefix (g_file_info_get_content_type (info), "audio/") ||
+ g_strcmp0 (g_file_info_get_content_type (info), "application/ogg"));
+}
+
static void
rygel_media_export_harvester_on_file_added (RygelMediaExportHarvester *self,
GFile *file) {
@@ -115,10 +123,7 @@ rygel_media_export_harvester_on_file_added (RygelMediaExportHarvester *self,
goto out;
}
if (g_file_info_get_file_type (info) == G_FILE_TYPE_DIRECTORY ||
- g_str_has_prefix (g_file_info_get_content_type (info), "image/") ||
- g_str_has_prefix (g_file_info_get_content_type (info), "video/") ||
- g_str_has_prefix (g_file_info_get_content_type (info), "audio/") ||
- g_strcmp0 (g_file_info_get_content_type (info), "application/ogg")) {
+ rygel_media_export_harvester_is_eligible (info)) {
RygelMediaContainer *parent_container = NULL;
GFile *current = g_object_ref (file);
GeeAbstractCollection *abstract_locations = GEE_ABSTRACT_COLLECTION (priv->locations);
@@ -437,7 +442,7 @@ rygel_media_export_harvester_on_file_harvested (RygelMediaExportHarvester *self,
g_return_if_fail (RYGEL_MEDIA_EXPORT_IS_HARVESTING_TASK (state_machine));
task = RYGEL_MEDIA_EXPORT_HARVESTING_TASK (state_machine);
- file = task->origin;
+ file = rygel_media_export_harvesting_task_get_origin (task);
uri = g_file_get_uri (file);
g_message (_("'%s' harvested"), uri);
g_free (uri);
diff --git a/src/media-export/rygel-media-export-harvester.h b/src/media-export/rygel-media-export-harvester.h
index 1224dcc..e4a31ba 100644
--- a/src/media-export/rygel-media-export-harvester.h
+++ b/src/media-export/rygel-media-export-harvester.h
@@ -70,6 +70,9 @@ void
rygel_media_export_harvester_cancel (RygelMediaExportHarvester *self,
GFile *file);
+gboolean
+rygel_media_export_harvester_is_eligible (GFileInfo *info);
+
G_END_DECLS
#endif /* __RYGEL_0_10_PLUGINS_MEDIA_EXPORT_HARVESTER_H__ */
diff --git a/src/media-export/rygel-media-export-harvesting-task.c b/src/media-export/rygel-media-export-harvesting-task.c
index 8e13d10..78448bd 100644
--- a/src/media-export/rygel-media-export-harvesting-task.c
+++ b/src/media-export/rygel-media-export-harvesting-task.c
@@ -27,6 +27,7 @@
#include "rygel-media-export-dummy-container.h"
#include "rygel-media-export-errors.h"
+#include "rygel-media-export-harvester.h"
#include "rygel-media-export-harvesting-task.h"
#include "rygel-media-export-item-factory.h"
#include "rygel-media-export-media-cache.h"
@@ -40,1456 +41,955 @@ G_DEFINE_TYPE_WITH_CODE (RygelMediaExportHarvestingTask,
G_IMPLEMENT_INTERFACE (RYGEL_TYPE_STATE_MACHINE,
rygel_media_export_harvesting_task_rygel_state_machine_interface_init))
-#define __g_queue_free_g_object_unref_0(var) ((var == NULL) ? NULL : (var = (_g_queue_free_g_object_unref_ (var), NULL)))
typedef struct _RygelMediaExportHarvestingTaskRunData RygelMediaExportHarvestingTaskRunData;
-
-#define __g_list_free_g_object_unref_0(var) ((var == NULL) ? NULL : (var = (_g_list_free_g_object_unref_ (var), NULL)))
typedef struct _RygelMediaExportHarvestingTaskEnumerateDirectoryData RygelMediaExportHarvestingTaskEnumerateDirectoryData;
struct _RygelMediaExportHarvestingTaskPrivate {
- RygelMediaExportMetadataExtractor* extractor;
- RygelMediaExportMediaCache* cache;
- GQueue* containers;
- GeeQueue* files;
- RygelMediaExportRecursiveFileMonitor* monitor;
- gchar* flag;
- RygelMediaContainer* parent;
- GCancellable* _cancellable;
+ RygelMediaExportMetadataExtractor *extractor;
+ RygelMediaExportMediaCache *cache;
+ GQueue *containers;
+ GeeQueue *files;
+ RygelMediaExportRecursiveFileMonitor *monitor;
+ gchar *flag;
+ RygelMediaContainer *parent;
+ GCancellable *cancellable;
+ GFile *origin;
};
struct _RygelMediaExportHarvestingTaskRunData {
- int _state_;
- GObject* _source_object_;
- GAsyncResult* _res_;
- GSimpleAsyncResult* _async_result;
- RygelMediaExportHarvestingTask* self;
- GFile* _tmp0_;
- GCancellable* _tmp1_;
- GCancellable* _tmp2_;
- GFileInfo* _tmp3_;
- GFileInfo* info;
- GFile* _tmp4_;
- RygelMediaContainer* _tmp5_;
- gboolean _tmp6_;
- GFileType _tmp7_;
- GQueue* _tmp8_;
- RygelMediaContainer* _tmp9_;
- RygelMediaContainer* _tmp10_;
- GError* _error_;
- GError* _tmp11_;
- const gchar* _tmp12_;
- GFile* _tmp13_;
- gchar* _tmp14_;
- gchar* _tmp15_;
- GError* _tmp16_;
- const gchar* _tmp17_;
- GFile* _tmp18_;
- gchar* _tmp19_;
- gchar* _tmp20_;
- GError * _inner_error_;
+ GSimpleAsyncResult *simple;
+ RygelMediaExportHarvestingTask *self;
};
-
struct _RygelMediaExportHarvestingTaskEnumerateDirectoryData {
- int _state_;
- GObject* _source_object_;
- GAsyncResult* _res_;
- GSimpleAsyncResult* _async_result;
- RygelMediaExportHarvestingTask* self;
- GQueue* _tmp0_;
- gconstpointer _tmp1_;
- GFile* _tmp2_;
- GFile* _tmp3_;
- GFile* directory;
- GFile* _tmp4_;
- GCancellable* _tmp5_;
- GCancellable* _tmp6_;
- GFileEnumerator* _tmp7_;
- GFileEnumerator* enumerator;
- GList* list;
- gboolean _tmp8_;
- gboolean _tmp9_;
- GList* _tmp10_;
- gboolean _tmp11_;
- GFileEnumerator* _tmp12_;
- GCancellable* _tmp13_;
- GCancellable* _tmp14_;
- GList* _tmp15_;
- GList* _tmp16_;
- GFileEnumerator* _tmp17_;
- GCancellable* _tmp18_;
- GCancellable* _tmp19_;
- GError* err;
- const gchar* _tmp20_;
- GError* _tmp21_;
- const gchar* _tmp22_;
- GError * _inner_error_;
+ GSimpleAsyncResult *simple;
+ RygelMediaExportHarvestingTask *self;
+ GFile *directory;
+ GFileEnumerator *enumerator;
+ RygelMediaExportDummyContainer *container;
};
#define RYGEL_MEDIA_EXPORT_HARVESTING_TASK_GET_PRIVATE(o) (G_TYPE_INSTANCE_GET_PRIVATE ((o), RYGEL_MEDIA_EXPORT_TYPE_HARVESTING_TASK, RygelMediaExportHarvestingTaskPrivate))
enum {
- RYGEL_MEDIA_EXPORT_HARVESTING_TASK_DUMMY_PROPERTY,
- RYGEL_MEDIA_EXPORT_HARVESTING_TASK_CANCELLABLE
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_DUMMY_PROPERTY,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_CANCELLABLE,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_EXTRACTOR,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_MONITOR,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_ORIGIN,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_PARENT,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_FLAG
};
-static void g_object_unref_ (gpointer var);
-static void _g_queue_free_g_object_unref_ (GQueue* self);
+
#define RYGEL_MEDIA_EXPORT_HARVESTING_TASK_BATCH_SIZE 256
#define RYGEL_MEDIA_EXPORT_HARVESTING_TASK_HARVESTER_ATTRIBUTES G_FILE_ATTRIBUTE_STANDARD_NAME "," G_FILE_ATTRIBUTE_STANDARD_TYPE "," G_FILE_ATTRIBUTE_TIME_MODIFIED "," G_FILE_ATTRIBUTE_STANDARD_CONTENT_TYPE "," G_FILE_ATTRIBUTE_STANDARD_SIZE
-static void rygel_media_export_harvesting_task_on_extracted_cb (RygelMediaExportHarvestingTask* self, GFile* file, GUPnPDLNAInformation* dlna, GFileInfo* file_info);
-static void _rygel_media_export_harvesting_task_on_extracted_cb_rygel_media_export_metadata_extractor_extraction_done (RygelMediaExportMetadataExtractor* _sender, GFile* file, GUPnPDLNAInformation* dlna, GFileInfo* file_info, gpointer self);
-static void rygel_media_export_harvesting_task_on_extractor_error_cb (RygelMediaExportHarvestingTask* self, GFile* file, GError* _error_);
-static void _rygel_media_export_harvesting_task_on_extractor_error_cb_rygel_media_export_metadata_extractor_error (RygelMediaExportMetadataExtractor* _sender, GFile* file, GError* err, gpointer self);
-static void rygel_media_export_harvesting_task_real_run_data_free (gpointer _data);
-static void rygel_media_export_harvesting_task_real_run (RygelStateMachine* base, GAsyncReadyCallback _callback_, gpointer _user_data_);
-static gboolean rygel_media_export_harvesting_task_real_run_co (RygelMediaExportHarvestingTaskRunData* _data_);
-static void rygel_media_export_harvesting_task_run_ready (GObject* source_object, GAsyncResult* _res_, gpointer _user_data_);
-static gboolean rygel_media_export_harvesting_task_process_file (RygelMediaExportHarvestingTask* self, GFile* file, GFileInfo* info, RygelMediaContainer* parent);
-static gboolean rygel_media_export_harvesting_task_on_idle (RygelMediaExportHarvestingTask* self);
-static gboolean rygel_media_export_harvesting_task_push_if_changed_or_unknown (RygelMediaExportHarvestingTask* self, GFile* file, GFileInfo* info);
-static gboolean rygel_media_export_harvesting_task_process_children (RygelMediaExportHarvestingTask* self, GList* list);
-static void rygel_media_export_harvesting_task_enumerate_directory_data_free (gpointer _data);
-static void rygel_media_export_harvesting_task_enumerate_directory (RygelMediaExportHarvestingTask* self, GAsyncReadyCallback _callback_, gpointer _user_data_);
-static gboolean rygel_media_export_harvesting_task_enumerate_directory_co (RygelMediaExportHarvestingTaskEnumerateDirectoryData* _data_);
-static void rygel_media_export_harvesting_task_enumerate_directory_ready (GObject* source_object, GAsyncResult* _res_, gpointer _user_data_);
-static void _g_list_free_g_object_unref_ (GList* self);
-static void rygel_media_export_harvesting_task_cleanup_database (RygelMediaExportHarvestingTask* self);
-static void rygel_media_export_harvesting_task_do_update (RygelMediaExportHarvestingTask* self);
-static void rygel_media_export_harvesting_task_finalize (GObject* obj);
-static void _vala_rygel_media_export_harvesting_task_get_property (GObject * object, guint property_id, GValue * value, GParamSpec * pspec);
-static void _vala_rygel_media_export_harvesting_task_set_property (GObject * object, guint property_id, const GValue * value, GParamSpec * pspec);
-
-
-static void g_object_unref_ (gpointer var) {
- (var == NULL) ? NULL : (var = (g_object_unref (var), NULL));
-}
-
-static void _g_queue_free_g_object_unref_ (GQueue* self) {
- g_queue_foreach (self, (GFunc) g_object_unref_, NULL);
- g_queue_free (self);
+static void
+rygel_media_export_harvesting_task_enumerate_directory_data_free (RygelMediaExportHarvestingTaskEnumerateDirectoryData *data) {
+ if (data->self) {
+ g_object_unref (data->self);
+ }
+ if (data->container) {
+ g_object_unref (data->container);
+ }
+ if (data->directory) {
+ g_object_unref (data->directory);
+ }
+ if (data->enumerator) {
+ g_object_unref (data->enumerator);
+ }
+ g_slice_free (RygelMediaExportHarvestingTaskEnumerateDirectoryData, data);
}
+static void
+rygel_media_export_harvesting_task_cleanup_database (RygelMediaExportHarvestingTask *self) {
+ RygelMediaExportDummyContainer *container;
+ GError *error;
+ RygelMediaExportHarvestingTaskPrivate *priv;
+ GeeList *children_list;
+ gint iter;
+ gint size;
+
+ g_return_if_fail (RYGEL_MEDIA_EXPORT_IS_HARVESTING_TASK (self));
+
+ priv = self->priv;
+ container = RYGEL_MEDIA_EXPORT_DUMMY_CONTAINER (g_queue_peek_head (priv->containers));
+ children_list = rygel_media_export_dummy_container_get_children_list (container);
+ size = gee_abstract_collection_get_size (GEE_ABSTRACT_COLLECTION (children_list));
+ error = NULL;
+
+ for (iter = 0; iter < size; ++iter) {
+ gchar *child = gee_list_get (children_list, iter);
+
+ rygel_media_export_media_cache_remove_by_id (priv->cache, child, &error);
+ g_free (child);
+ if (error) {
+ g_warning (_("Failed to get children of container %s: %s"),
+ rygel_media_object_get_id (RYGEL_MEDIA_OBJECT (container)),
+ error->message);
+ g_error_free (error);
+ }
+ }
+}
+
+/* Needed because of the cycle: do_update calls on_idle, which calls
+ * enumerate_directory, which calls enumerate_children_ready, which
+ * calls failed_to_enumerate_folder, which calls do_update. */
+static void
+rygel_media_export_harvesting_task_do_update (RygelMediaExportHarvestingTask *self);
-static void _rygel_media_export_harvesting_task_on_extracted_cb_rygel_media_export_metadata_extractor_extraction_done (RygelMediaExportMetadataExtractor* _sender G_GNUC_UNUSED, GFile* file, GUPnPDLNAInformation* dlna, GFileInfo* file_info, gpointer self) {
- rygel_media_export_harvesting_task_on_extracted_cb (self, file, dlna, file_info);
+static void
+cleanup_database_and_do_update (RygelMediaExportHarvestingTaskEnumerateDirectoryData *data)
+{
+ rygel_media_export_harvesting_task_cleanup_database (data->self);
+ rygel_media_export_harvesting_task_do_update (data->self);
+ g_simple_async_result_complete (data->simple);
+ g_object_unref (data->simple);
+ rygel_media_export_harvesting_task_enumerate_directory_data_free (data);
}
-
-static void _rygel_media_export_harvesting_task_on_extractor_error_cb_rygel_media_export_metadata_extractor_error (RygelMediaExportMetadataExtractor* _sender G_GNUC_UNUSED, GFile* file, GError* err, gpointer self) {
- rygel_media_export_harvesting_task_on_extractor_error_cb (self, file, err);
+static void
+failed_to_enumerate_folder (RygelMediaExportHarvestingTaskEnumerateDirectoryData *data,
+ GError *error)
+{
+ g_warning (_("Failed to enumerate folder: %s"),
+ error->message);
+ g_error_free (error);
+ cleanup_database_and_do_update (data);
}
+/**
+ * Add a file to the meta-data extraction queue.
+ *
+ * The file will only be added to the queue if one of the following
+ * conditions is met:
+ * - The file is not in the cache
+ * - The current mtime of the file is larger than the cached
+ * - The size has changed
+ * @param file to check
+ * @param info FileInfo of the file to check
+ * @return true, if the file has been queued, false otherwise.
+ */
+static gboolean
+rygel_media_export_harvesting_task_push_if_changed_or_unknown (RygelMediaExportHarvestingTask *self,
+ GFile *file,
+ GFileInfo *info) {
+ GError *inner_error;
+ RygelMediaExportHarvestingTaskPrivate *priv;
+ gboolean exists;
+ gint64 timestamp;
+ gint64 size;
+
+ g_return_val_if_fail (RYGEL_MEDIA_EXPORT_IS_HARVESTING_TASK (self), FALSE);
+ g_return_val_if_fail (G_IS_FILE (file), FALSE);
+ g_return_val_if_fail (G_IS_FILE_INFO (info), FALSE);
+
+ priv = self->priv;
+ inner_error = NULL;
+ timestamp = 0;
+ size = 0;
+ exists = rygel_media_export_media_cache_exists (priv->cache, file, ×tamp, &size, &inner_error);
+ if (inner_error) {
+ g_warning (_("Failed to query database: %s"), inner_error->message);
+ return FALSE;
+ }
+ if (exists) {
+ gint64 mtime = (gint64) g_file_info_get_attribute_uint64 (info, G_FILE_ATTRIBUTE_TIME_MODIFIED);
+
+ if (mtime > timestamp ||
+ g_file_info_get_size (info) != size) {
+ gee_queue_offer (priv->files, file);
+ return TRUE;
+ }
+ } else {
+ gee_queue_offer (priv->files, file);
+ return TRUE;
+ }
+
+ return FALSE;
+}
+
+static gboolean
+rygel_media_export_harvesting_task_process_file (RygelMediaExportHarvestingTask *self,
+ GFile *file,
+ GFileInfo *info,
+ RygelMediaContainer *parent) {
+ GError *inner_error;
+ RygelMediaExportHarvestingTaskPrivate *priv;
+
+ g_return_val_if_fail (RYGEL_MEDIA_EXPORT_IS_HARVESTING_TASK (self), FALSE);
+ g_return_val_if_fail (G_IS_FILE (file), FALSE);
+ g_return_val_if_fail (G_IS_FILE_INFO (info), FALSE);
+ g_return_val_if_fail (RYGEL_IS_MEDIA_CONTAINER (parent), FALSE);
+
+ if (g_file_info_get_name (info)[0] == '.') {
+ return FALSE;
+ }
+
+ priv = self->priv;
+ inner_error = NULL;
+ if (g_file_info_get_file_type (info) == G_FILE_TYPE_DIRECTORY) {
+ RygelMediaExportDummyContainer* container;
+
+ rygel_media_export_recursive_file_monitor_add (priv->monitor, file, NULL, NULL);
+ container = rygel_media_export_dummy_container_new (file, parent);
+ g_queue_push_tail (priv->containers, container); /* takes ownership */
+ rygel_media_export_media_cache_save_container (priv->cache,
+ RYGEL_MEDIA_CONTAINER (container),
+ &inner_error);
+ if (inner_error) {
+ g_warning (_("Failed to update database: %s"),
+ inner_error->message);
+ g_error_free (inner_error);
+ return FALSE;
+ }
+
+ return TRUE;
+ } else {
+ if (rygel_media_export_harvester_is_eligible (info)) {
+ return rygel_media_export_harvesting_task_push_if_changed_or_unknown (self,
+ file,
+ info);
+ }
+ }
+
+ return FALSE;
+}
+
+static gboolean
+rygel_media_export_harvesting_task_process_children (RygelMediaExportHarvestingTask *self,
+ GList *list) {
+ RygelMediaExportDummyContainer* container;
+ GList* iter;
+ GFile *file;
+
+ g_return_val_if_fail (RYGEL_MEDIA_EXPORT_IS_HARVESTING_TASK (self), FALSE);
+
+ if (!list || g_cancellable_is_cancelled (self->priv->cancellable)) {
+ return FALSE;
+ }
+ container = RYGEL_MEDIA_EXPORT_DUMMY_CONTAINER (g_queue_peek_head (self->priv->containers));
+ file = rygel_media_export_dummy_container_get_g_file (container);
+
+ for (iter = list; iter; iter = iter->next) {
+ GFileInfo *info = G_FILE_INFO (iter->data);
+ GFile *child = g_file_get_child (file, g_file_info_get_name (info));
+
+ rygel_media_export_dummy_container_seen (container, child);
+ rygel_media_export_harvesting_task_process_file (self, child, info, RYGEL_MEDIA_CONTAINER (container));
+ g_object_unref (child);
+ }
+
+ return TRUE;
+}
+
+/* Needed because of cycle: get_next_files calls next_files_ready,
+ * which calls get_next_files */
+static void
+get_next_files (RygelMediaExportHarvestingTaskEnumerateDirectoryData *data);
-RygelMediaExportHarvestingTask* rygel_media_export_harvesting_task_construct (GType object_type, RygelMediaExportMetadataExtractor* extractor, RygelMediaExportRecursiveFileMonitor* monitor, GFile* file, RygelMediaContainer* parent, const gchar* flag) {
- RygelMediaExportHarvestingTask * self = NULL;
- RygelMediaExportMetadataExtractor* _tmp0_;
- RygelMediaExportMetadataExtractor* _tmp1_;
- GFile* _tmp2_;
- GFile* _tmp3_;
- RygelMediaContainer* _tmp4_;
- RygelMediaContainer* _tmp5_;
- RygelMediaExportMetadataExtractor* _tmp8_;
- RygelMediaExportMetadataExtractor* _tmp9_;
- GeeLinkedList* _tmp10_;
- GQueue* _tmp11_;
- RygelMediaExportRecursiveFileMonitor* _tmp12_;
- RygelMediaExportRecursiveFileMonitor* _tmp13_;
- const gchar* _tmp14_;
- gchar* _tmp15_;
- GError * _inner_error_ = NULL;
- g_return_val_if_fail (extractor != NULL, NULL);
- g_return_val_if_fail (monitor != NULL, NULL);
- g_return_val_if_fail (file != NULL, NULL);
- g_return_val_if_fail (parent != NULL, NULL);
- self = (RygelMediaExportHarvestingTask*) g_object_new (object_type, NULL);
- _tmp0_ = extractor;
- _tmp1_ = g_object_ref (_tmp0_);
- g_object_unref (self->priv->extractor);
- self->priv->extractor = _tmp1_;
- _tmp2_ = file;
- _tmp3_ = g_object_ref (_tmp2_);
- g_object_unref (self->origin);
- self->origin = _tmp3_;
- _tmp4_ = parent;
- _tmp5_ = g_object_ref (_tmp4_);
- g_object_unref (self->priv->parent);
- self->priv->parent = _tmp5_;
- {
- RygelMediaExportMediaCache* _tmp6_ = NULL;
- RygelMediaExportMediaCache* _tmp7_;
- _tmp6_ = rygel_media_export_media_cache_get_default (&_inner_error_);
- _tmp7_ = _tmp6_;
- if (_inner_error_ != NULL) {
- goto __catch50_g_error;
- }
- g_object_unref (self->priv->cache);
- self->priv->cache = _tmp7_;
- }
- goto __finally50;
- __catch50_g_error:
- {
- GError* _error_ = NULL;
- _error_ = _inner_error_;
- _inner_error_ = NULL;
- g_assert_not_reached ();
- g_error_free (_error_);
- }
- __finally50:
- if (_inner_error_ != NULL) {
- g_critical ("file %s: line %d: uncaught error: %s (%s, %d)", __FILE__, __LINE__, _inner_error_->message, g_quark_to_string (_inner_error_->domain), _inner_error_->code);
- g_clear_error (&_inner_error_);
- return NULL;
- }
- _tmp8_ = self->priv->extractor;
- g_signal_connect_object (_tmp8_, "extraction-done", (GCallback) _rygel_media_export_harvesting_task_on_extracted_cb_rygel_media_export_metadata_extractor_extraction_done, self, 0);
- _tmp9_ = self->priv->extractor;
- g_signal_connect_object (_tmp9_, "error", (GCallback) _rygel_media_export_harvesting_task_on_extractor_error_cb_rygel_media_export_metadata_extractor_error, self, 0);
- _tmp10_ = gee_linked_list_new (G_TYPE_FILE, (GBoxedCopyFunc) g_object_ref, g_object_unref, NULL, NULL, NULL);
- g_object_unref (self->priv->files);
- self->priv->files = (GeeQueue*) _tmp10_;
- _tmp11_ = g_queue_new ();
- __g_queue_free_g_object_unref_0 (self->priv->containers);
- self->priv->containers = _tmp11_;
- _tmp12_ = monitor;
- _tmp13_ = g_object_ref (_tmp12_);
- g_object_unref (self->priv->monitor);
- self->priv->monitor = _tmp13_;
- _tmp14_ = flag;
- _tmp15_ = g_strdup (_tmp14_);
- g_free (self->priv->flag);
- self->priv->flag = _tmp15_;
- return self;
-}
-
+static void
+rygel_media_export_harvesting_task_enumerator_close_ready (GObject *source_object G_GNUC_UNUSED,
+ GAsyncResult *res,
+ gpointer user_data)
+{
+ GError *error = NULL;
+ RygelMediaExportHarvestingTaskEnumerateDirectoryData *data = (RygelMediaExportHarvestingTaskEnumerateDirectoryData *) user_data;
-RygelMediaExportHarvestingTask* rygel_media_export_harvesting_task_new (RygelMediaExportMetadataExtractor* extractor, RygelMediaExportRecursiveFileMonitor* monitor, GFile* file, RygelMediaContainer* parent, const gchar* flag) {
- return rygel_media_export_harvesting_task_construct (RYGEL_MEDIA_EXPORT_TYPE_HARVESTING_TASK, extractor, monitor, file, parent, flag);
+ g_file_enumerator_close_finish (data->enumerator, res, &error);
+ if (error) {
+ failed_to_enumerate_folder (data, error);
+ } else {
+ cleanup_database_and_do_update (data);
+ }
}
-
-void rygel_media_export_harvesting_task_cancel (RygelMediaExportHarvestingTask* self) {
- GCancellable* _tmp0_;
- GCancellable* _tmp1_;
- GCancellable* _tmp2_;
- GCancellable* _tmp3_;
- g_return_if_fail (self != NULL);
- _tmp0_ = g_cancellable_new ();
- _tmp1_ = _tmp0_;
- rygel_state_machine_set_cancellable ((RygelStateMachine*) self, _tmp1_);
- g_object_unref (_tmp1_);
- _tmp2_ = rygel_state_machine_get_cancellable ((RygelStateMachine*) self);
- _tmp3_ = _tmp2_;
- g_cancellable_cancel (_tmp3_);
+static void
+rygel_media_export_harvesting_task_next_files_ready (GObject *source_object G_GNUC_UNUSED,
+ GAsyncResult *res,
+ gpointer user_data)
+{
+ RygelMediaExportHarvestingTaskEnumerateDirectoryData *data = (RygelMediaExportHarvestingTaskEnumerateDirectoryData *) user_data;
+ GError *error = NULL;
+ GList *list = g_file_enumerator_next_files_finish (data->enumerator,
+ res,
+ &error);
+
+ if (error) {
+ failed_to_enumerate_folder (data, error);
+ } else {
+ gboolean make_another_round = rygel_media_export_harvesting_task_process_children (data->self, list);
+
+ if (list) {
+ g_list_free_full (list, g_object_unref);
+ }
+ if (make_another_round) {
+ get_next_files (data);
+ } else {
+ g_file_enumerator_close_async (data->enumerator,
+ G_PRIORITY_DEFAULT,
+ data->self->priv->cancellable,
+ rygel_media_export_harvesting_task_enumerator_close_ready,
+ data);
+ }
+ }
}
-
-static void rygel_media_export_harvesting_task_real_run_data_free (gpointer _data) {
- RygelMediaExportHarvestingTaskRunData* _data_;
- _data_ = _data;
- g_object_unref (_data_->self);
- g_slice_free (RygelMediaExportHarvestingTaskRunData, _data_);
+static void
+get_next_files (RygelMediaExportHarvestingTaskEnumerateDirectoryData *data)
+{
+ g_file_enumerator_next_files_async (data->enumerator,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_BATCH_SIZE,
+ G_PRIORITY_DEFAULT,
+ data->self->priv->cancellable,
+ rygel_media_export_harvesting_task_next_files_ready,
+ data);
}
+static void
+rygel_media_export_harvesting_task_enumerate_children_ready (GObject *source_object,
+ GAsyncResult *res,
+ gpointer user_data) {
+ RygelMediaExportHarvestingTaskEnumerateDirectoryData *data = (RygelMediaExportHarvestingTaskEnumerateDirectoryData *) user_data;
+ GError *error = NULL;
-static void rygel_media_export_harvesting_task_real_run (RygelStateMachine* base, GAsyncReadyCallback _callback_, gpointer _user_data_) {
- RygelMediaExportHarvestingTask * self;
- RygelMediaExportHarvestingTaskRunData* _data_;
- RygelMediaExportHarvestingTask* _tmp0_;
- self = (RygelMediaExportHarvestingTask*) base;
- _data_ = g_slice_new0 (RygelMediaExportHarvestingTaskRunData);
- _data_->_async_result = g_simple_async_result_new (G_OBJECT (self), _callback_, _user_data_, rygel_media_export_harvesting_task_real_run);
- g_simple_async_result_set_op_res_gpointer (_data_->_async_result, _data_, rygel_media_export_harvesting_task_real_run_data_free);
- _tmp0_ = g_object_ref (self);
- _data_->self = _tmp0_;
- rygel_media_export_harvesting_task_real_run_co (_data_);
-}
-
+ data->enumerator = g_file_enumerate_children_finish (G_FILE (source_object), res, &error);
-static void rygel_media_export_harvesting_task_real_run_finish (RygelStateMachine* base G_GNUC_UNUSED, GAsyncResult* _res_ G_GNUC_UNUSED) {
+ if (error) {
+ failed_to_enumerate_folder (data, error);
+ } else {
+ get_next_files (data);
+ }
}
+static void
+rygel_media_export_harvesting_task_enumerate_directory (RygelMediaExportHarvestingTask *self,
+ GAsyncReadyCallback callback,
+ gpointer user_data) {
+ RygelMediaExportHarvestingTaskPrivate *priv;
+ RygelMediaExportHarvestingTaskEnumerateDirectoryData *data;
+
+ g_return_if_fail (RYGEL_MEDIA_EXPORT_HARVESTING_TASK (self));
+
+ priv = self->priv;
+ data = g_slice_new0 (RygelMediaExportHarvestingTaskEnumerateDirectoryData);
+ data->container = RYGEL_MEDIA_EXPORT_DUMMY_CONTAINER (g_object_ref (g_queue_peek_head (priv->containers)));
+ data->directory = g_object_ref (rygel_media_export_dummy_container_get_g_file (data->container));
+ data->self = g_object_ref (self);
+ data->simple = g_simple_async_result_new (G_OBJECT (self),
+ callback,
+ user_data,
+ rygel_media_export_harvesting_task_enumerate_directory);
+
+ g_file_enumerate_children_async (data->directory,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_HARVESTER_ATTRIBUTES,
+ G_FILE_QUERY_INFO_NONE,
+ G_PRIORITY_DEFAULT,
+ priv->cancellable,
+ rygel_media_export_harvesting_task_enumerate_children_ready,
+ data);
+}
+
+static gboolean
+rygel_media_export_harvesting_task_on_idle (RygelMediaExportHarvestingTask *self) {
+ RygelMediaExportHarvestingTaskPrivate *priv;
+
+ g_return_val_if_fail (RYGEL_MEDIA_EXPORT_IS_HARVESTING_TASK (self), FALSE);
+
+ priv = self->priv;
+ if (g_cancellable_is_cancelled (priv->cancellable)) {
+ g_signal_emit_by_name (RYGEL_STATE_MACHINE (self), "completed");
+
+ return FALSE;
+ }
+
+ if (!gee_collection_get_is_empty (GEE_COLLECTION (priv->files))) {
+ GFile *file;
+ gchar *uri;
+
+ file = G_FILE (gee_queue_peek (self->priv->files));
+ uri = g_file_get_uri (file);
+ g_debug ("Scheduling file %s for meta-data extractionâ", uri);
+ g_free (uri);
+ rygel_media_export_metadata_extractor_extract (priv->extractor, file);
+ g_object_unref (file);
+ } else if (!g_queue_is_empty (priv->containers)) {
+ rygel_media_export_harvesting_task_enumerate_directory (self, NULL, NULL);
+ } else {
+ if (priv->flag) {
+ rygel_media_export_media_cache_flag_object (priv->cache, priv->origin, priv->flag, NULL);
+ }
+ rygel_media_container_updated (priv->parent, RYGEL_MEDIA_OBJECT (priv->parent), RYGEL_OBJECT_EVENT_TYPE_MODIFIED, FALSE);
+ g_signal_emit_by_name (RYGEL_STATE_MACHINE (self), "completed");
+ }
+ return FALSE;
+}
/**
- * Extract all metainformation from a given file.
- *
- * What action will be taken depends on the arguments
- * * file is a simple file. Then only information of this
- * file will be extracted
- * * file is a directory and recursive is false. The children
- * of the directory (if not directories themselves) will be
- * enqueued for extraction
- * * file is a directory and recursive is true. ++ All ++ children
- * of the directory will be enqueued for extraction, even directories
- *
- * No matter how many children are contained within file's hierarchy,
- * only one event is sent when all the children are done.
- */
-static void rygel_media_export_harvesting_task_run_ready (GObject* source_object, GAsyncResult* _res_, gpointer _user_data_) {
- RygelMediaExportHarvestingTaskRunData* _data_;
- _data_ = _user_data_;
- _data_->_source_object_ = source_object;
- _data_->_res_ = _res_;
- rygel_media_export_harvesting_task_real_run_co (_data_);
+ * If all files of a container were processed, notify the container
+ * about this and set the updating signal.
+ * Reschedule the iteration and extraction
+ */
+static void
+rygel_media_export_harvesting_task_do_update (RygelMediaExportHarvestingTask *self) {
+ RygelMediaExportHarvestingTaskPrivate *priv;
+
+ g_return_if_fail (RYGEL_MEDIA_EXPORT_IS_HARVESTING_TASK (self));
+
+ priv = self->priv;
+ if (gee_collection_get_is_empty (GEE_COLLECTION (priv->files)) &&
+ !g_queue_is_empty (priv->containers)) {
+ RygelMediaContainer* container = RYGEL_MEDIA_CONTAINER (g_queue_peek_head (priv->containers));
+ GError *error = NULL;
+ gint size = rygel_media_export_media_cache_get_child_count (priv->cache,
+ rygel_media_object_get_id (RYGEL_MEDIA_OBJECT (container)),
+ &error);
+
+ if (error) {
+ goto out;
+ }
+ if (size > 0) {
+ rygel_media_container_updated (container, RYGEL_MEDIA_OBJECT (container), RYGEL_OBJECT_EVENT_TYPE_MODIFIED, FALSE);
+ } else {
+ rygel_media_export_media_cache_remove_by_id (priv->cache, rygel_media_object_get_id (RYGEL_MEDIA_OBJECT (container)), &error);
+ if (error) {
+ goto out;
+ }
+ }
+ out:
+ if (error) {
+ g_error_free (error);
+ }
+
+ g_queue_pop_head (priv->containers);
+ g_object_unref (container);
+ }
+ rygel_media_export_harvesting_task_on_idle (self);
}
-
-static gboolean rygel_media_export_harvesting_task_real_run_co (RygelMediaExportHarvestingTaskRunData* _data_) {
- switch (_data_->_state_) {
- case 0:
- goto _state_0;
- case 1:
- goto _state_1;
- default:
- g_assert_not_reached ();
- }
- _state_0:
- {
- _data_->_tmp0_ = _data_->self->origin;
- _data_->_tmp1_ = rygel_state_machine_get_cancellable ((RygelStateMachine*) _data_->self);
- _data_->_tmp2_ = _data_->_tmp1_;
- _data_->_state_ = 1;
- g_file_query_info_async (_data_->_tmp0_, RYGEL_MEDIA_EXPORT_HARVESTING_TASK_HARVESTER_ATTRIBUTES, G_FILE_QUERY_INFO_NONE, G_PRIORITY_DEFAULT, _data_->_tmp2_, rygel_media_export_harvesting_task_run_ready, _data_);
- return FALSE;
- _state_1:
- _data_->_tmp3_ = NULL;
- _data_->_tmp3_ = g_file_query_info_finish (_data_->_tmp0_, _data_->_res_, &_data_->_inner_error_);
- _data_->info = _data_->_tmp3_;
- if (_data_->_inner_error_ != NULL) {
- goto __catch51_g_error;
- }
- _data_->_tmp4_ = _data_->self->origin;
- _data_->_tmp5_ = _data_->self->priv->parent;
- _data_->_tmp6_ = FALSE;
- _data_->_tmp6_ = rygel_media_export_harvesting_task_process_file (_data_->self, _data_->_tmp4_, _data_->info, _data_->_tmp5_);
- if (_data_->_tmp6_) {
- _data_->_tmp7_ = 0;
- _data_->_tmp7_ = g_file_info_get_file_type (_data_->info);
- if (_data_->_tmp7_ != G_FILE_TYPE_DIRECTORY) {
- _data_->_tmp8_ = _data_->self->priv->containers;
- _data_->_tmp9_ = _data_->self->priv->parent;
- _data_->_tmp10_ = g_object_ref (_data_->_tmp9_);
- g_queue_push_tail (_data_->_tmp8_, _data_->_tmp10_);
- }
- rygel_media_export_harvesting_task_on_idle (_data_->self);
- } else {
- g_signal_emit_by_name ((RygelStateMachine*) _data_->self, "completed");
- }
- g_object_unref (_data_->info);
- }
- goto __finally51;
- __catch51_g_error:
- {
- _data_->_error_ = _data_->_inner_error_;
- _data_->_inner_error_ = NULL;
- _data_->_tmp11_ = _data_->_error_;
- if (!g_error_matches (_data_->_tmp11_, G_IO_ERROR, G_IO_ERROR_CANCELLED)) {
- _data_->_tmp12_ = NULL;
- _data_->_tmp12_ = _ ("Failed to harvest file %s: %s");
- _data_->_tmp13_ = _data_->self->origin;
- _data_->_tmp14_ = NULL;
- _data_->_tmp14_ = g_file_get_uri (_data_->_tmp13_);
- _data_->_tmp15_ = _data_->_tmp14_;
- _data_->_tmp16_ = _data_->_error_;
- _data_->_tmp17_ = _data_->_tmp16_->message;
- g_warning (_data_->_tmp12_, _data_->_tmp15_, _data_->_tmp17_);
- g_free (_data_->_tmp15_);
- } else {
- _data_->_tmp18_ = _data_->self->origin;
- _data_->_tmp19_ = NULL;
- _data_->_tmp19_ = g_file_get_uri (_data_->_tmp18_);
- _data_->_tmp20_ = _data_->_tmp19_;
- g_debug ("rygel-media-export-harvesting-task.vala:116: Harvesting of uri %s was " \
-"cancelled", _data_->_tmp20_);
- g_free (_data_->_tmp20_);
- }
- g_signal_emit_by_name ((RygelStateMachine*) _data_->self, "completed");
- g_error_free (_data_->_error_);
- }
- __finally51:
- if (_data_->_inner_error_ != NULL) {
- g_critical ("file %s: line %d: uncaught error: %s (%s, %d)", __FILE__, __LINE__, _data_->_inner_error_->message, g_quark_to_string (_data_->_inner_error_->domain), _data_->_inner_error_->code);
- g_clear_error (&_data_->_inner_error_);
- return FALSE;
- }
- if (_data_->_state_ == 0) {
- g_simple_async_result_complete_in_idle (_data_->_async_result);
- } else {
- g_simple_async_result_complete (_data_->_async_result);
- }
- g_object_unref (_data_->_async_result);
- return FALSE;
+static void
+rygel_media_export_harvesting_task_on_extracted_cb (RygelMediaExportHarvestingTask *self,
+ GFile *file,
+ GUPnPDLNAInformation *dlna,
+ GFileInfo *file_info) {
+ RygelMediaExportHarvestingTaskPrivate *priv;
+ gboolean ignore;
+ GFile *top_file;
+ RygelMediaItem *item;
+ RygelMediaContainer *container;
+
+ g_return_if_fail (RYGEL_MEDIA_EXPORT_IS_HARVESTING_TASK (self));
+ g_return_if_fail (G_IS_FILE (file));
+ g_return_if_fail (dlna == NULL || GUPNP_IS_DLNA_INFORMATION (dlna));
+ g_return_if_fail (G_IS_FILE_INFO (file_info));
+
+ priv = self->priv;
+
+ if (g_cancellable_is_cancelled (priv->cancellable)) {
+ g_signal_emit_by_name (RYGEL_STATE_MACHINE (self), "completed");
+ }
+
+ top_file = gee_queue_peek (priv->files);
+ ignore = (!top_file || !g_file_equal (file, top_file));
+ if (top_file) {
+ g_object_unref (top_file);
+ }
+ if (!ignore) {
+ return;
+ }
+ container = RYGEL_MEDIA_CONTAINER (g_queue_peek_head (priv->containers));
+
+ if (!dlna) {
+ item = rygel_media_export_item_factory_create_simple (container, file, file_info);
+ } else {
+ item = rygel_media_export_item_factory_create_from_info (container, file, dlna, file_info);
+ }
+ if (item) {
+ rygel_media_object_set_parent_ref (RYGEL_MEDIA_OBJECT (item), container);
+ rygel_media_export_media_cache_save_item (priv->cache, item, NULL);
+ g_object_unref (item);
+ }
+ top_file = G_FILE (gee_queue_poll (priv->files));
+ if (top_file) {
+ g_object_unref (top_file);
+ }
+ rygel_media_export_harvesting_task_do_update (self);
}
-
-/**
- * Add a file to the meta-data extraction queue.
- *
- * The file will only be added to the queue if one of the following
- * conditions is met:
- * - The file is not in the cache
- * - The current mtime of the file is larger than the cached
- * - The size has changed
- * @param file to check
- * @param info FileInfo of the file to check
- * @return true, if the file has been queued, false otherwise.
- */
-static gboolean rygel_media_export_harvesting_task_push_if_changed_or_unknown (RygelMediaExportHarvestingTask* self, GFile* file, GFileInfo* info) {
- gboolean result = FALSE;
- gint64 timestamp = 0LL;
- gint64 size = 0LL;
- GError * _inner_error_ = NULL;
- g_return_val_if_fail (self != NULL, FALSE);
- g_return_val_if_fail (file != NULL, FALSE);
- g_return_val_if_fail (info != NULL, FALSE);
- {
- RygelMediaExportMediaCache* _tmp0_;
- GFile* _tmp1_;
- gint64 _tmp2_ = 0LL;
- gint64 _tmp3_ = 0LL;
- gboolean _tmp4_ = FALSE;
- gboolean _tmp5_;
- _tmp0_ = self->priv->cache;
- _tmp1_ = file;
- _tmp4_ = rygel_media_export_media_cache_exists (_tmp0_, _tmp1_, &_tmp2_, &_tmp3_, &_inner_error_);
- timestamp = _tmp2_;
- size = _tmp3_;
- _tmp5_ = _tmp4_;
- if (_inner_error_ != NULL) {
- goto __catch52_g_error;
- }
- if (_tmp5_) {
- GFileInfo* _tmp6_;
- guint64 _tmp7_ = 0ULL;
- gint64 mtime;
- gboolean _tmp8_ = FALSE;
- gint64 _tmp9_;
- gint64 _tmp10_;
- gboolean _tmp14_;
- _tmp6_ = info;
- _tmp7_ = g_file_info_get_attribute_uint64 (_tmp6_, G_FILE_ATTRIBUTE_TIME_MODIFIED);
- mtime = (gint64) _tmp7_;
- _tmp9_ = mtime;
- _tmp10_ = timestamp;
- if (_tmp9_ > _tmp10_) {
- _tmp8_ = TRUE;
- } else {
- GFileInfo* _tmp11_;
- gint64 _tmp12_ = 0LL;
- gint64 _tmp13_;
- _tmp11_ = info;
- _tmp12_ = g_file_info_get_size (_tmp11_);
- _tmp13_ = size;
- _tmp8_ = _tmp12_ != _tmp13_;
- }
- _tmp14_ = _tmp8_;
- if (_tmp14_) {
- GeeQueue* _tmp15_;
- GFile* _tmp16_;
- _tmp15_ = self->priv->files;
- _tmp16_ = file;
- gee_queue_offer (_tmp15_, _tmp16_);
- result = TRUE;
- return result;
- }
- } else {
- GeeQueue* _tmp17_;
- GFile* _tmp18_;
- _tmp17_ = self->priv->files;
- _tmp18_ = file;
- gee_queue_offer (_tmp17_, _tmp18_);
- result = TRUE;
- return result;
- }
- }
- goto __finally52;
- __catch52_g_error:
- {
- GError* _error_ = NULL;
- const gchar* _tmp19_ = NULL;
- GError* _tmp20_;
- const gchar* _tmp21_;
- _error_ = _inner_error_;
- _inner_error_ = NULL;
- _tmp19_ = _ ("Failed to query database: %s");
- _tmp20_ = _error_;
- _tmp21_ = _tmp20_->message;
- g_warning (_tmp19_, _tmp21_);
- g_error_free (_error_);
- }
- __finally52:
- if (_inner_error_ != NULL) {
- g_critical ("file %s: line %d: uncaught error: %s (%s, %d)", __FILE__, __LINE__, _inner_error_->message, g_quark_to_string (_inner_error_->domain), _inner_error_->code);
- g_clear_error (&_inner_error_);
- return FALSE;
- }
- result = FALSE;
- return result;
+static void
+rygel_media_export_harvesting_task_on_extracted_cb_rygel_media_export_metadata_extractor_extraction_done (RygelMediaExportMetadataExtractor *sender G_GNUC_UNUSED,
+ GFile *file,
+ GUPnPDLNAInformation *dlna,
+ GFileInfo *file_info,
+ gpointer self) {
+ rygel_media_export_harvesting_task_on_extracted_cb (self, file, dlna, file_info);
}
-
-static gchar string_get (const gchar* self, glong index) {
- gchar result = '\0';
- glong _tmp0_;
- gchar _tmp1_;
- g_return_val_if_fail (self != NULL, '\0');
- _tmp0_ = index;
- _tmp1_ = ((gchar*) self)[_tmp0_];
- result = _tmp1_;
- return result;
+static void
+rygel_media_export_harvesting_task_on_extractor_error_cb (RygelMediaExportHarvestingTask *self,
+ GFile *file,
+ GError *error) {
+ RygelMediaExportHarvestingTaskPrivate *priv;
+ gboolean ignore;
+ gchar *uri;
+ GFile *entry;
+
+ g_return_if_fail (RYGEL_MEDIA_EXPORT_IS_HARVESTING_TASK (self));
+ g_return_if_fail (G_IS_FILE (file));
+ g_return_if_fail (error != NULL);
+
+ priv = self->priv;
+ entry = G_FILE (gee_queue_peek (priv->files));
+ ignore = (!entry || g_file_equal (file, entry));
+ g_object_unref (entry);
+
+ if (ignore) {
+ return;
+ }
+
+ uri = g_file_get_uri (file);
+ g_debug ("Skipping %s; extraction completely failed: %s", uri, error->message);
+ g_free (uri);
+ g_object_unref (gee_queue_poll (priv->files));
+ rygel_media_export_harvesting_task_do_update (self);
}
-
-static gboolean rygel_media_export_harvesting_task_process_file (RygelMediaExportHarvestingTask* self, GFile* file, GFileInfo* info, RygelMediaContainer* parent) {
- gboolean result = FALSE;
- GFileInfo* _tmp0_;
- const gchar* _tmp1_ = NULL;
- gchar _tmp2_ = '\0';
- GFileInfo* _tmp3_;
- GFileType _tmp4_ = 0;
- GError * _inner_error_ = NULL;
- g_return_val_if_fail (self != NULL, FALSE);
- g_return_val_if_fail (file != NULL, FALSE);
- g_return_val_if_fail (info != NULL, FALSE);
- g_return_val_if_fail (parent != NULL, FALSE);
- _tmp0_ = info;
- _tmp1_ = g_file_info_get_name (_tmp0_);
- _tmp2_ = string_get (_tmp1_, (glong) 0);
- if (_tmp2_ == '.') {
- result = FALSE;
- return result;
- }
- _tmp3_ = info;
- _tmp4_ = g_file_info_get_file_type (_tmp3_);
- if (_tmp4_ == G_FILE_TYPE_DIRECTORY) {
- RygelMediaExportRecursiveFileMonitor* _tmp5_;
- GFile* _tmp6_;
- GFile* _tmp7_;
- RygelMediaContainer* _tmp8_;
- RygelMediaExportDummyContainer* _tmp9_;
- RygelMediaExportDummyContainer* container;
- GQueue* _tmp10_;
- RygelMediaExportDummyContainer* _tmp11_;
- RygelMediaContainer* _tmp12_;
- _tmp5_ = self->priv->monitor;
- _tmp6_ = file;
- rygel_media_export_recursive_file_monitor_add (_tmp5_, _tmp6_, NULL, NULL);
- _tmp7_ = file;
- _tmp8_ = parent;
- _tmp9_ = rygel_media_export_dummy_container_new (_tmp7_, _tmp8_);
- container = _tmp9_;
- _tmp10_ = self->priv->containers;
- _tmp11_ = container;
- _tmp12_ = g_object_ref ((RygelMediaContainer*) _tmp11_);
- g_queue_push_tail (_tmp10_, _tmp12_);
- {
- RygelMediaExportMediaCache* _tmp13_;
- RygelMediaExportDummyContainer* _tmp14_;
- _tmp13_ = self->priv->cache;
- _tmp14_ = container;
- rygel_media_export_media_cache_save_container (_tmp13_, (RygelMediaContainer*) _tmp14_, &_inner_error_);
- if (_inner_error_ != NULL) {
- goto __catch53_g_error;
- }
- }
- goto __finally53;
- __catch53_g_error:
- {
- GError* err = NULL;
- const gchar* _tmp15_ = NULL;
- GError* _tmp16_;
- const gchar* _tmp17_;
- err = _inner_error_;
- _inner_error_ = NULL;
- _tmp15_ = _ ("Failed to update database: %s");
- _tmp16_ = err;
- _tmp17_ = _tmp16_->message;
- g_warning (_tmp15_, _tmp17_);
- result = FALSE;
- g_error_free (err);
- g_object_unref (container);
- return result;
- }
- __finally53:
- if (_inner_error_ != NULL) {
- g_object_unref (container);
- g_critical ("file %s: line %d: uncaught error: %s (%s, %d)", __FILE__, __LINE__, _inner_error_->message, g_quark_to_string (_inner_error_->domain), _inner_error_->code);
- g_clear_error (&_inner_error_);
- return FALSE;
- }
- result = TRUE;
- g_object_unref (container);
- return result;
- } else {
- gboolean _tmp18_ = FALSE;
- gboolean _tmp19_ = FALSE;
- gboolean _tmp20_ = FALSE;
- GFileInfo* _tmp21_;
- const gchar* _tmp22_ = NULL;
- gboolean _tmp23_ = FALSE;
- gboolean _tmp27_;
- gboolean _tmp31_;
- gboolean _tmp34_;
- _tmp21_ = info;
- _tmp22_ = g_file_info_get_content_type (_tmp21_);
- _tmp23_ = g_str_has_prefix (_tmp22_, "image/");
- if (_tmp23_) {
- _tmp20_ = TRUE;
- } else {
- GFileInfo* _tmp24_;
- const gchar* _tmp25_ = NULL;
- gboolean _tmp26_ = FALSE;
- _tmp24_ = info;
- _tmp25_ = g_file_info_get_content_type (_tmp24_);
- _tmp26_ = g_str_has_prefix (_tmp25_, "video/");
- _tmp20_ = _tmp26_;
- }
- _tmp27_ = _tmp20_;
- if (_tmp27_) {
- _tmp19_ = TRUE;
- } else {
- GFileInfo* _tmp28_;
- const gchar* _tmp29_ = NULL;
- gboolean _tmp30_ = FALSE;
- _tmp28_ = info;
- _tmp29_ = g_file_info_get_content_type (_tmp28_);
- _tmp30_ = g_str_has_prefix (_tmp29_, "audio/");
- _tmp19_ = _tmp30_;
- }
- _tmp31_ = _tmp19_;
- if (_tmp31_) {
- _tmp18_ = TRUE;
- } else {
- GFileInfo* _tmp32_;
- const gchar* _tmp33_ = NULL;
- _tmp32_ = info;
- _tmp33_ = g_file_info_get_content_type (_tmp32_);
- _tmp18_ = g_strcmp0 (_tmp33_, "application/ogg") == 0;
- }
- _tmp34_ = _tmp18_;
- if (_tmp34_) {
- GFile* _tmp35_;
- GFileInfo* _tmp36_;
- gboolean _tmp37_ = FALSE;
- _tmp35_ = file;
- _tmp36_ = info;
- _tmp37_ = rygel_media_export_harvesting_task_push_if_changed_or_unknown (self, _tmp35_, _tmp36_);
- result = _tmp37_;
- return result;
- }
- result = FALSE;
- return result;
- }
+static void
+rygel_media_export_harvesting_task_on_extractor_error_cb_rygel_media_export_metadata_extractor_error (RygelMediaExportMetadataExtractor *sender G_GNUC_UNUSED,
+ GFile *file,
+ GError *err,
+ gpointer self) {
+ rygel_media_export_harvesting_task_on_extractor_error_cb (self, file, err);
}
+RygelMediaExportHarvestingTask *
+rygel_media_export_harvesting_task_new (RygelMediaExportMetadataExtractor *extractor,
+ RygelMediaExportRecursiveFileMonitor *monitor,
+ GFile *file,
+ RygelMediaContainer *parent,
+ const gchar *flag) {
+ g_return_val_if_fail (RYGEL_MEDIA_EXPORT_IS_METADATA_EXTRACTOR (extractor), NULL);
+ g_return_val_if_fail (RYGEL_MEDIA_EXPORT_IS_RECURSIVE_FILE_MONITOR (monitor), NULL);
+ g_return_val_if_fail (G_IS_FILE (file), NULL);
+ g_return_val_if_fail (RYGEL_IS_MEDIA_CONTAINER (parent), NULL);
+ /* flag can be NULL */
-static gboolean rygel_media_export_harvesting_task_process_children (RygelMediaExportHarvestingTask* self, GList* list) {
- gboolean result = FALSE;
- gboolean _tmp0_ = FALSE;
- GList* _tmp1_;
- gboolean _tmp5_;
- GQueue* _tmp6_;
- gconstpointer _tmp7_ = NULL;
- RygelMediaExportDummyContainer* _tmp8_;
- RygelMediaExportDummyContainer* container;
- GList* _tmp9_;
- g_return_val_if_fail (self != NULL, FALSE);
- _tmp1_ = list;
- if (_tmp1_ == NULL) {
- _tmp0_ = TRUE;
- } else {
- GCancellable* _tmp2_;
- GCancellable* _tmp3_;
- gboolean _tmp4_ = FALSE;
- _tmp2_ = rygel_state_machine_get_cancellable ((RygelStateMachine*) self);
- _tmp3_ = _tmp2_;
- _tmp4_ = g_cancellable_is_cancelled (_tmp3_);
- _tmp0_ = _tmp4_;
- }
- _tmp5_ = _tmp0_;
- if (_tmp5_) {
- result = FALSE;
- return result;
- }
- _tmp6_ = self->priv->containers;
- _tmp7_ = g_queue_peek_head (_tmp6_);
- _tmp8_ = g_object_ref (G_TYPE_CHECK_INSTANCE_TYPE ((RygelMediaContainer*) _tmp7_, RYGEL_MEDIA_EXPORT_TYPE_DUMMY_CONTAINER) ? ((RygelMediaExportDummyContainer*) ((RygelMediaContainer*) _tmp7_)) : NULL);
- container = _tmp8_;
- _tmp9_ = list;
- {
- GList* info_collection = NULL;
- GList* info_it = NULL;
- info_collection = _tmp9_;
- for (info_it = info_collection; info_it != NULL; info_it = info_it->next) {
- GFileInfo* _tmp10_;
- GFileInfo* info = NULL;
- _tmp10_ = g_object_ref ((GFileInfo*) info_it->data);
- info = _tmp10_;
- {
- RygelMediaExportDummyContainer* _tmp11_;
- GFile* _tmp12_;
- GFileInfo* _tmp13_;
- const gchar* _tmp14_ = NULL;
- GFile* _tmp15_ = NULL;
- GFile* file;
- RygelMediaExportDummyContainer* _tmp16_;
- GFile* _tmp17_;
- GFile* _tmp18_;
- GFileInfo* _tmp19_;
- RygelMediaExportDummyContainer* _tmp20_;
- _tmp11_ = container;
- _tmp12_ = rygel_media_export_dummy_container_get_g_file (_tmp11_);
- _tmp13_ = info;
- _tmp14_ = g_file_info_get_name (_tmp13_);
- _tmp15_ = g_file_get_child (_tmp12_, _tmp14_);
- file = _tmp15_;
- _tmp16_ = container;
- _tmp17_ = file;
- rygel_media_export_dummy_container_seen (_tmp16_, _tmp17_);
- _tmp18_ = file;
- _tmp19_ = info;
- _tmp20_ = container;
- rygel_media_export_harvesting_task_process_file (self, _tmp18_, _tmp19_, (RygelMediaContainer*) _tmp20_);
- g_object_unref (file);
- g_object_unref (info);
- }
- }
- }
- result = TRUE;
- g_object_unref (container);
- return result;
+ return RYGEL_MEDIA_EXPORT_HARVESTING_TASK (g_object_new (RYGEL_MEDIA_EXPORT_TYPE_HARVESTING_TASK,
+ "extractor", extractor,
+ "monitor", monitor,
+ "origin", file,
+ "parent", parent,
+ "flag", flag,
+ NULL));
}
+void
+rygel_media_export_harvesting_task_cancel (RygelMediaExportHarvestingTask *self) {
+ GCancellable *cancellable;
-static void rygel_media_export_harvesting_task_enumerate_directory_data_free (gpointer _data) {
- RygelMediaExportHarvestingTaskEnumerateDirectoryData* _data_;
- _data_ = _data;
- g_object_unref (_data_->self);
- g_slice_free (RygelMediaExportHarvestingTaskEnumerateDirectoryData, _data_);
-}
-
+ g_return_if_fail (RYGEL_MEDIA_EXPORT_IS_HARVESTING_TASK (self));
-static void rygel_media_export_harvesting_task_enumerate_directory (RygelMediaExportHarvestingTask* self, GAsyncReadyCallback _callback_, gpointer _user_data_) {
- RygelMediaExportHarvestingTaskEnumerateDirectoryData* _data_;
- RygelMediaExportHarvestingTask* _tmp0_;
- _data_ = g_slice_new0 (RygelMediaExportHarvestingTaskEnumerateDirectoryData);
- _data_->_async_result = g_simple_async_result_new (G_OBJECT (self), _callback_, _user_data_, rygel_media_export_harvesting_task_enumerate_directory);
- g_simple_async_result_set_op_res_gpointer (_data_->_async_result, _data_, rygel_media_export_harvesting_task_enumerate_directory_data_free);
- _tmp0_ = g_object_ref (self);
- _data_->self = _tmp0_;
- rygel_media_export_harvesting_task_enumerate_directory_co (_data_);
+ cancellable = g_cancellable_new ();
+ rygel_state_machine_set_cancellable (RYGEL_STATE_MACHINE (self), cancellable);
+ g_cancellable_cancel (cancellable);
}
-
-static void rygel_media_export_harvesting_task_enumerate_directory_ready (GObject* source_object, GAsyncResult* _res_, gpointer _user_data_) {
- RygelMediaExportHarvestingTaskEnumerateDirectoryData* _data_;
- _data_ = _user_data_;
- _data_->_source_object_ = source_object;
- _data_->_res_ = _res_;
- rygel_media_export_harvesting_task_enumerate_directory_co (_data_);
+static void
+rygel_media_export_harvesting_task_real_run_data_free (RygelMediaExportHarvestingTaskRunData *data) {
+ g_object_unref (data->self);
+ g_slice_free (RygelMediaExportHarvestingTaskRunData, data);
}
-
-static void _g_list_free_g_object_unref_ (GList* self) {
- g_list_foreach (self, (GFunc) g_object_unref_, NULL);
- g_list_free (self);
+static void
+rygel_media_export_harvesting_task_run_ready (GObject *source_object,
+ GAsyncResult *res,
+ gpointer user_data) {
+ RygelMediaExportHarvestingTaskRunData *data = (RygelMediaExportHarvestingTaskRunData *) user_data;
+ RygelMediaExportHarvestingTask *self = data->self;
+ RygelMediaExportHarvestingTaskPrivate *priv = self->priv;
+ GFile *origin = G_FILE (source_object);
+ GError *inner_error = NULL;
+ GFileInfo *info = g_file_query_info_finish (origin, res, &inner_error);
+
+ if (!inner_error) {
+ if (rygel_media_export_harvesting_task_process_file (self,
+ origin,
+ info,
+ priv->parent)) {
+ if (g_file_info_get_file_type (info) != G_FILE_TYPE_DIRECTORY) {
+ g_queue_push_tail (priv->containers,
+ g_object_ref (priv->parent));
+ }
+ rygel_media_export_harvesting_task_on_idle (self);
+ } else {
+ g_signal_emit_by_name (RYGEL_STATE_MACHINE (self), "completed");
+ }
+ g_object_unref (info);
+ } else {
+ gchar *uri = g_file_get_uri (origin);
+
+ if (g_error_matches (inner_error, G_IO_ERROR, G_IO_ERROR_CANCELLED)) {
+ g_debug ("Harvesting of uri %s was cancelled", uri);
+ } else {
+ g_warning (_("Failed to harvest file %s: %s"),
+ uri,
+ inner_error->message);
+ }
+
+ g_free (uri);
+ g_signal_emit_by_name (RYGEL_STATE_MACHINE (self), "completed");
+ g_error_free (inner_error);
+ }
+ g_simple_async_result_complete (data->simple);
+ g_object_unref (data->simple);
+ rygel_media_export_harvesting_task_real_run_data_free (data);
}
-
-static gboolean rygel_media_export_harvesting_task_enumerate_directory_co (RygelMediaExportHarvestingTaskEnumerateDirectoryData* _data_) {
- switch (_data_->_state_) {
- case 0:
- goto _state_0;
- case 1:
- goto _state_1;
- case 2:
- goto _state_2;
- case 3:
- goto _state_3;
- default:
- g_assert_not_reached ();
- }
- _state_0:
- _data_->_tmp0_ = _data_->self->priv->containers;
- _data_->_tmp1_ = NULL;
- _data_->_tmp1_ = g_queue_peek_head (_data_->_tmp0_);
- _data_->_tmp2_ = rygel_media_export_dummy_container_get_g_file (G_TYPE_CHECK_INSTANCE_TYPE ((RygelMediaContainer*) _data_->_tmp1_, RYGEL_MEDIA_EXPORT_TYPE_DUMMY_CONTAINER) ? ((RygelMediaExportDummyContainer*) ((RygelMediaContainer*) _data_->_tmp1_)) : NULL);
- _data_->_tmp3_ = g_object_ref (_data_->_tmp2_);
- _data_->directory = _data_->_tmp3_;
- {
- _data_->_tmp4_ = _data_->directory;
- _data_->_tmp5_ = rygel_state_machine_get_cancellable ((RygelStateMachine*) _data_->self);
- _data_->_tmp6_ = _data_->_tmp5_;
- _data_->_state_ = 1;
- g_file_enumerate_children_async (_data_->_tmp4_, RYGEL_MEDIA_EXPORT_HARVESTING_TASK_HARVESTER_ATTRIBUTES, G_FILE_QUERY_INFO_NONE, G_PRIORITY_DEFAULT, _data_->_tmp6_, rygel_media_export_harvesting_task_enumerate_directory_ready, _data_);
- return FALSE;
- _state_1:
- _data_->_tmp7_ = NULL;
- _data_->_tmp7_ = g_file_enumerate_children_finish (_data_->_tmp4_, _data_->_res_, &_data_->_inner_error_);
- _data_->enumerator = _data_->_tmp7_;
- if (_data_->_inner_error_ != NULL) {
- goto __catch54_g_error;
- }
- _data_->list = NULL;
- {
- _data_->_tmp8_ = TRUE;
- while (TRUE) {
- _data_->_tmp9_ = _data_->_tmp8_;
- if (!_data_->_tmp9_) {
- _data_->_tmp10_ = _data_->list;
- _data_->_tmp11_ = FALSE;
- _data_->_tmp11_ = rygel_media_export_harvesting_task_process_children (_data_->self, _data_->_tmp10_);
- if (!_data_->_tmp11_) {
- break;
- }
- }
- _data_->_tmp8_ = FALSE;
- _data_->_tmp12_ = _data_->enumerator;
- _data_->_tmp13_ = rygel_state_machine_get_cancellable ((RygelStateMachine*) _data_->self);
- _data_->_tmp14_ = _data_->_tmp13_;
- _data_->_state_ = 2;
- g_file_enumerator_next_files_async (_data_->_tmp12_, RYGEL_MEDIA_EXPORT_HARVESTING_TASK_BATCH_SIZE, G_PRIORITY_DEFAULT, _data_->_tmp14_, rygel_media_export_harvesting_task_enumerate_directory_ready, _data_);
- return FALSE;
- _state_2:
- _data_->_tmp15_ = NULL;
- _data_->_tmp15_ = g_file_enumerator_next_files_finish (_data_->_tmp12_, _data_->_res_, &_data_->_inner_error_);
- _data_->_tmp16_ = _data_->_tmp15_;
- if (_data_->_inner_error_ != NULL) {
- __g_list_free_g_object_unref_0 (_data_->list);
- g_object_unref (_data_->enumerator);
- goto __catch54_g_error;
- }
- __g_list_free_g_object_unref_0 (_data_->list);
- _data_->list = _data_->_tmp16_;
- }
- }
- _data_->_tmp17_ = _data_->enumerator;
- _data_->_tmp18_ = rygel_state_machine_get_cancellable ((RygelStateMachine*) _data_->self);
- _data_->_tmp19_ = _data_->_tmp18_;
- _data_->_state_ = 3;
- g_file_enumerator_close_async (_data_->_tmp17_, G_PRIORITY_DEFAULT, _data_->_tmp19_, rygel_media_export_harvesting_task_enumerate_directory_ready, _data_);
- return FALSE;
- _state_3:
- g_file_enumerator_close_finish (_data_->_tmp17_, _data_->_res_, &_data_->_inner_error_);
- if (_data_->_inner_error_ != NULL) {
- __g_list_free_g_object_unref_0 (_data_->list);
- g_object_unref (_data_->enumerator);
- goto __catch54_g_error;
- }
- __g_list_free_g_object_unref_0 (_data_->list);
- g_object_unref (_data_->enumerator);
- }
- goto __finally54;
- __catch54_g_error:
- {
- _data_->err = _data_->_inner_error_;
- _data_->_inner_error_ = NULL;
- _data_->_tmp20_ = NULL;
- _data_->_tmp20_ = _ ("failed to enumerate folder: %s");
- _data_->_tmp21_ = _data_->err;
- _data_->_tmp22_ = _data_->_tmp21_->message;
- g_warning (_data_->_tmp20_, _data_->_tmp22_);
- g_error_free (_data_->err);
- }
- __finally54:
- if (_data_->_inner_error_ != NULL) {
- g_object_unref (_data_->directory);
- g_critical ("file %s: line %d: uncaught error: %s (%s, %d)", __FILE__, __LINE__, _data_->_inner_error_->message, g_quark_to_string (_data_->_inner_error_->domain), _data_->_inner_error_->code);
- g_clear_error (&_data_->_inner_error_);
- return FALSE;
- }
- rygel_media_export_harvesting_task_cleanup_database (_data_->self);
- rygel_media_export_harvesting_task_do_update (_data_->self);
- g_object_unref (_data_->directory);
- if (_data_->_state_ == 0) {
- g_simple_async_result_complete_in_idle (_data_->_async_result);
- } else {
- g_simple_async_result_complete (_data_->_async_result);
- }
- g_object_unref (_data_->_async_result);
- return FALSE;
+/**
+ * Extract all metainformation from a given file.
+ *
+ * What action will be taken depends on the arguments
+ * * file is a simple file. Then only information of this
+ * file will be extracted
+ * * file is a directory and recursive is false. The children
+ * of the directory (if not directories themselves) will be
+ * enqueued for extraction
+ * * file is a directory and recursive is true. ++ All ++ children
+ * of the directory will be enqueued for extraction, even directories
+ *
+ * No matter how many children are contained within file's hierarchy,
+ * only one event is sent when all the children are done.
+ */
+static void
+rygel_media_export_harvesting_task_real_run (RygelStateMachine *base,
+ GAsyncReadyCallback callback,
+ gpointer user_data) {
+ RygelMediaExportHarvestingTask *self = RYGEL_MEDIA_EXPORT_HARVESTING_TASK (base);
+ RygelMediaExportHarvestingTaskPrivate *priv = self->priv;
+ RygelMediaExportHarvestingTaskRunData *data = g_slice_new0 (RygelMediaExportHarvestingTaskRunData);
+
+ data->simple = g_simple_async_result_new (G_OBJECT (self),
+ callback,
+ user_data,
+ rygel_media_export_harvesting_task_real_run);
+ data->self = g_object_ref (self);
+
+ g_file_query_info_async (priv->origin,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_HARVESTER_ATTRIBUTES,
+ G_FILE_QUERY_INFO_NONE,
+ G_PRIORITY_DEFAULT,
+ priv->cancellable,
+ rygel_media_export_harvesting_task_run_ready,
+ data);
}
-
-static void rygel_media_export_harvesting_task_cleanup_database (RygelMediaExportHarvestingTask* self) {
- GQueue* _tmp0_;
- gconstpointer _tmp1_ = NULL;
- RygelMediaExportDummyContainer* _tmp2_;
- RygelMediaExportDummyContainer* container;
- GError * _inner_error_ = NULL;
- g_return_if_fail (self != NULL);
- _tmp0_ = self->priv->containers;
- _tmp1_ = g_queue_peek_head (_tmp0_);
- _tmp2_ = g_object_ref (G_TYPE_CHECK_INSTANCE_TYPE ((RygelMediaContainer*) _tmp1_, RYGEL_MEDIA_EXPORT_TYPE_DUMMY_CONTAINER) ? ((RygelMediaExportDummyContainer*) ((RygelMediaContainer*) _tmp1_)) : NULL);
- container = _tmp2_;
- {
- {
- RygelMediaExportDummyContainer* _tmp3_;
- GeeList* _tmp4_;
- GeeList* _tmp5_;
- GeeList* _child_list;
- GeeList* _tmp6_;
- gint _tmp7_;
- gint _tmp8_;
- gint _child_size;
- gint _child_index;
- _tmp3_ = container;
- _tmp4_ = rygel_media_export_dummy_container_get_children_list (_tmp3_);
- _tmp5_ = g_object_ref (_tmp4_);
- _child_list = _tmp5_;
- _tmp6_ = _child_list;
- _tmp7_ = gee_collection_get_size ((GeeCollection*) _tmp6_);
- _tmp8_ = _tmp7_;
- _child_size = _tmp8_;
- _child_index = -1;
- while (TRUE) {
- gint _tmp9_;
- gint _tmp10_;
- gint _tmp11_;
- GeeList* _tmp12_;
- gint _tmp13_;
- gpointer _tmp14_ = NULL;
- gchar* child;
- RygelMediaExportMediaCache* _tmp15_;
- const gchar* _tmp16_;
- _tmp9_ = _child_index;
- _child_index = _tmp9_ + 1;
- _tmp10_ = _child_index;
- _tmp11_ = _child_size;
- if (!(_tmp10_ < _tmp11_)) {
- break;
- }
- _tmp12_ = _child_list;
- _tmp13_ = _child_index;
- _tmp14_ = gee_list_get (_tmp12_, _tmp13_);
- child = (gchar*) _tmp14_;
- _tmp15_ = self->priv->cache;
- _tmp16_ = child;
- rygel_media_export_media_cache_remove_by_id (_tmp15_, _tmp16_, &_inner_error_);
- if (_inner_error_ != NULL) {
- g_free (child);
- g_object_unref (_child_list);
- if (_inner_error_->domain == RYGEL_MEDIA_EXPORT_DATABASE_ERROR) {
- goto __catch55_rygel_media_export_database_error;
- }
- g_free (child);
- g_object_unref (_child_list);
- g_object_unref (container);
- g_critical ("file %s: line %d: unexpected error: %s (%s, %d)", __FILE__, __LINE__, _inner_error_->message, g_quark_to_string (_inner_error_->domain), _inner_error_->code);
- g_clear_error (&_inner_error_);
- return;
- }
- g_free (child);
- }
- g_object_unref (_child_list);
- }
- }
- goto __finally55;
- __catch55_rygel_media_export_database_error:
- {
- GError* _error_ = NULL;
- const gchar* _tmp17_ = NULL;
- RygelMediaExportDummyContainer* _tmp18_;
- const gchar* _tmp19_;
- const gchar* _tmp20_;
- GError* _tmp21_;
- const gchar* _tmp22_;
- _error_ = _inner_error_;
- _inner_error_ = NULL;
- _tmp17_ = _ ("Failed to get children of container %s: %s");
- _tmp18_ = container;
- _tmp19_ = rygel_media_object_get_id ((RygelMediaObject*) _tmp18_);
- _tmp20_ = _tmp19_;
- _tmp21_ = _error_;
- _tmp22_ = _tmp21_->message;
- g_warning (_tmp17_, _tmp20_, _tmp22_);
- g_error_free (_error_);
- }
- __finally55:
- if (_inner_error_ != NULL) {
- g_object_unref (container);
- g_critical ("file %s: line %d: uncaught error: %s (%s, %d)", __FILE__, __LINE__, _inner_error_->message, g_quark_to_string (_inner_error_->domain), _inner_error_->code);
- g_clear_error (&_inner_error_);
- return;
- }
- g_object_unref (container);
+static void
+rygel_media_export_harvesting_task_real_run_finish (RygelStateMachine *base G_GNUC_UNUSED,
+ GAsyncResult *res G_GNUC_UNUSED) {
}
+static GCancellable *
+rygel_media_export_harvesting_task_real_get_cancellable (RygelStateMachine *base) {
+ RygelMediaExportHarvestingTask *self = RYGEL_MEDIA_EXPORT_HARVESTING_TASK (base);
-static gboolean rygel_media_export_harvesting_task_on_idle (RygelMediaExportHarvestingTask* self) {
- gboolean result = FALSE;
- GCancellable* _tmp0_;
- GCancellable* _tmp1_;
- gboolean _tmp2_ = FALSE;
- GeeQueue* _tmp3_;
- gint _tmp4_;
- gint _tmp5_;
- GError * _inner_error_ = NULL;
- g_return_val_if_fail (self != NULL, FALSE);
- _tmp0_ = rygel_state_machine_get_cancellable ((RygelStateMachine*) self);
- _tmp1_ = _tmp0_;
- _tmp2_ = g_cancellable_is_cancelled (_tmp1_);
- if (_tmp2_) {
- g_signal_emit_by_name ((RygelStateMachine*) self, "completed");
- result = FALSE;
- return result;
- }
- _tmp3_ = self->priv->files;
- _tmp4_ = gee_collection_get_size ((GeeCollection*) _tmp3_);
- _tmp5_ = _tmp4_;
- if (_tmp5_ > 0) {
- GeeQueue* _tmp6_;
- gpointer _tmp7_ = NULL;
- GFile* _tmp8_;
- gchar* _tmp9_ = NULL;
- gchar* _tmp10_;
- RygelMediaExportMetadataExtractor* _tmp11_;
- GeeQueue* _tmp12_;
- gpointer _tmp13_ = NULL;
- GFile* _tmp14_;
- _tmp6_ = self->priv->files;
- _tmp7_ = gee_queue_peek (_tmp6_);
- _tmp8_ = (GFile*) _tmp7_;
- _tmp9_ = g_file_get_uri (_tmp8_);
- _tmp10_ = _tmp9_;
- g_debug ("rygel-media-export-harvesting-task.vala:263: Scheduling file %s for me" \
-"ta-data extractionâ", _tmp10_);
- g_free (_tmp10_);
- g_object_unref (_tmp8_);
- _tmp11_ = self->priv->extractor;
- _tmp12_ = self->priv->files;
- _tmp13_ = gee_queue_peek (_tmp12_);
- _tmp14_ = (GFile*) _tmp13_;
- rygel_media_export_metadata_extractor_extract (_tmp11_, _tmp14_);
- g_object_unref (_tmp14_);
- } else {
- GQueue* _tmp15_;
- guint _tmp16_ = 0U;
- _tmp15_ = self->priv->containers;
- _tmp16_ = g_queue_get_length (_tmp15_);
- if (_tmp16_ > ((guint) 0)) {
- rygel_media_export_harvesting_task_enumerate_directory (self, NULL, NULL);
- } else {
- const gchar* _tmp17_;
- RygelMediaContainer* _tmp21_;
- RygelMediaContainer* _tmp22_;
- _tmp17_ = self->priv->flag;
- if (_tmp17_ != NULL) {
- {
- RygelMediaExportMediaCache* _tmp18_;
- GFile* _tmp19_;
- const gchar* _tmp20_;
- _tmp18_ = self->priv->cache;
- _tmp19_ = self->origin;
- _tmp20_ = self->priv->flag;
- rygel_media_export_media_cache_flag_object (_tmp18_, _tmp19_, _tmp20_, &_inner_error_);
- if (_inner_error_ != NULL) {
- goto __catch56_g_error;
- }
- }
- goto __finally56;
- __catch56_g_error:
- {
- GError* _error_ = NULL;
- _error_ = _inner_error_;
- _inner_error_ = NULL;
- g_error_free (_error_);
- }
- __finally56:
- if (_inner_error_ != NULL) {
- g_critical ("file %s: line %d: uncaught error: %s (%s, %d)", __FILE__, __LINE__, _inner_error_->message, g_quark_to_string (_inner_error_->domain), _inner_error_->code);
- g_clear_error (&_inner_error_);
- return FALSE;
- }
- }
- _tmp21_ = self->priv->parent;
- _tmp22_ = self->priv->parent;
- rygel_media_container_updated (_tmp21_, (RygelMediaObject*) _tmp22_, RYGEL_OBJECT_EVENT_TYPE_MODIFIED, FALSE);
- g_signal_emit_by_name ((RygelStateMachine*) self, "completed");
- }
- }
- result = FALSE;
- return result;
+ return self->priv->cancellable;
}
+static void
+rygel_media_export_harvesting_task_real_set_cancellable (RygelStateMachine *base,
+ GCancellable *value) {
+ RygelMediaExportHarvestingTask *self = RYGEL_MEDIA_EXPORT_HARVESTING_TASK (base);
+ RygelMediaExportHarvestingTaskPrivate *priv = self->priv;
-static void rygel_media_export_harvesting_task_on_extracted_cb (RygelMediaExportHarvestingTask* self, GFile* file, GUPnPDLNAInformation* dlna, GFileInfo* file_info) {
- GCancellable* _tmp0_;
- GCancellable* _tmp1_;
- gboolean _tmp2_ = FALSE;
- GeeQueue* _tmp3_;
- gpointer _tmp4_ = NULL;
- GFile* entry;
- gboolean _tmp5_ = FALSE;
- GFile* _tmp6_;
- gboolean _tmp9_;
- RygelMediaItem* item = NULL;
- GUPnPDLNAInformation* _tmp10_;
- RygelMediaItem* _tmp22_;
- GeeQueue* _tmp28_;
- gpointer _tmp29_ = NULL;
- GFile* _tmp30_;
- GError * _inner_error_ = NULL;
- g_return_if_fail (self != NULL);
- g_return_if_fail (file != NULL);
- g_return_if_fail (file_info != NULL);
- _tmp0_ = rygel_state_machine_get_cancellable ((RygelStateMachine*) self);
- _tmp1_ = _tmp0_;
- _tmp2_ = g_cancellable_is_cancelled (_tmp1_);
- if (_tmp2_) {
- g_signal_emit_by_name ((RygelStateMachine*) self, "completed");
- }
- _tmp3_ = self->priv->files;
- _tmp4_ = gee_queue_peek (_tmp3_);
- entry = (GFile*) _tmp4_;
- _tmp6_ = entry;
- if (_tmp6_ == NULL) {
- _tmp5_ = TRUE;
- } else {
- GFile* _tmp7_;
- GFile* _tmp8_;
- _tmp7_ = file;
- _tmp8_ = entry;
- _tmp5_ = _tmp7_ != _tmp8_;
- }
- _tmp9_ = _tmp5_;
- if (_tmp9_) {
- g_object_unref (entry);
- return;
- }
- _tmp10_ = dlna;
- if (_tmp10_ == NULL) {
- GQueue* _tmp11_;
- gconstpointer _tmp12_ = NULL;
- GFile* _tmp13_;
- GFileInfo* _tmp14_;
- RygelMediaItem* _tmp15_ = NULL;
- _tmp11_ = self->priv->containers;
- _tmp12_ = g_queue_peek_head (_tmp11_);
- _tmp13_ = file;
- _tmp14_ = file_info;
- _tmp15_ = rygel_media_export_item_factory_create_simple ((RygelMediaContainer*) _tmp12_, _tmp13_, _tmp14_);
- g_object_unref (item);
- item = _tmp15_;
- } else {
- GQueue* _tmp16_;
- gconstpointer _tmp17_ = NULL;
- GFile* _tmp18_;
- GUPnPDLNAInformation* _tmp19_;
- GFileInfo* _tmp20_;
- RygelMediaItem* _tmp21_ = NULL;
- _tmp16_ = self->priv->containers;
- _tmp17_ = g_queue_peek_head (_tmp16_);
- _tmp18_ = file;
- _tmp19_ = dlna;
- _tmp20_ = file_info;
- _tmp21_ = rygel_media_export_item_factory_create_from_info ((RygelMediaContainer*) _tmp17_, _tmp18_, _tmp19_, _tmp20_);
- g_object_unref (item);
- item = _tmp21_;
- }
- _tmp22_ = item;
- if (_tmp22_ != NULL) {
- RygelMediaItem* _tmp23_;
- GQueue* _tmp24_;
- gconstpointer _tmp25_ = NULL;
- _tmp23_ = item;
- _tmp24_ = self->priv->containers;
- _tmp25_ = g_queue_peek_head (_tmp24_);
- rygel_media_object_set_parent_ref ((RygelMediaObject*) _tmp23_, (RygelMediaContainer*) _tmp25_);
- {
- RygelMediaExportMediaCache* _tmp26_;
- RygelMediaItem* _tmp27_;
- _tmp26_ = self->priv->cache;
- _tmp27_ = item;
- rygel_media_export_media_cache_save_item (_tmp26_, _tmp27_, &_inner_error_);
- if (_inner_error_ != NULL) {
- goto __catch57_g_error;
- }
- }
- goto __finally57;
- __catch57_g_error:
- {
- GError* _error_ = NULL;
- _error_ = _inner_error_;
- _inner_error_ = NULL;
- g_error_free (_error_);
- }
- __finally57:
- if (_inner_error_ != NULL) {
- g_object_unref (item);
- g_object_unref (entry);
- g_critical ("file %s: line %d: uncaught error: %s (%s, %d)", __FILE__, __LINE__, _inner_error_->message, g_quark_to_string (_inner_error_->domain), _inner_error_->code);
- g_clear_error (&_inner_error_);
- return;
- }
- }
- _tmp28_ = self->priv->files;
- _tmp29_ = gee_queue_poll (_tmp28_);
- _tmp30_ = (GFile*) _tmp29_;
- g_object_unref (_tmp30_);
- rygel_media_export_harvesting_task_do_update (self);
- g_object_unref (item);
- g_object_unref (entry);
-}
-
+ if (value) {
+ g_object_ref (value);
+ }
+ if (priv->cancellable) {
+ g_object_unref (priv->cancellable);
+ }
+ priv->cancellable = value;
-static void rygel_media_export_harvesting_task_on_extractor_error_cb (RygelMediaExportHarvestingTask* self, GFile* file, GError* _error_) {
- GeeQueue* _tmp0_;
- gpointer _tmp1_ = NULL;
- GFile* entry;
- gboolean _tmp2_ = FALSE;
- GFile* _tmp3_;
- gboolean _tmp6_;
- GFile* _tmp7_;
- gchar* _tmp8_ = NULL;
- gchar* _tmp9_;
- GError* _tmp10_;
- const gchar* _tmp11_;
- GeeQueue* _tmp12_;
- gpointer _tmp13_ = NULL;
- GFile* _tmp14_;
- g_return_if_fail (self != NULL);
- g_return_if_fail (file != NULL);
- _tmp0_ = self->priv->files;
- _tmp1_ = gee_queue_peek (_tmp0_);
- entry = (GFile*) _tmp1_;
- _tmp3_ = entry;
- if (_tmp3_ == NULL) {
- _tmp2_ = TRUE;
- } else {
- GFile* _tmp4_;
- GFile* _tmp5_;
- _tmp4_ = file;
- _tmp5_ = entry;
- _tmp2_ = _tmp4_ != _tmp5_;
- }
- _tmp6_ = _tmp2_;
- if (_tmp6_) {
- g_object_unref (entry);
- return;
- }
- _tmp7_ = file;
- _tmp8_ = g_file_get_uri (_tmp7_);
- _tmp9_ = _tmp8_;
- _tmp10_ = _error_;
- _tmp11_ = _tmp10_->message;
- g_debug ("rygel-media-export-harvesting-task.vala:335: Skipping %s; extraction c" \
-"ompletely failed: %s", _tmp9_, _tmp11_);
- g_free (_tmp9_);
- _tmp12_ = self->priv->files;
- _tmp13_ = gee_queue_poll (_tmp12_);
- _tmp14_ = (GFile*) _tmp13_;
- g_object_unref (_tmp14_);
- rygel_media_export_harvesting_task_do_update (self);
- g_object_unref (entry);
+ g_object_notify (G_OBJECT (self), "cancellable");
}
+static void
+rygel_media_export_harvesting_task_get_property (GObject *object,
+ guint property_id,
+ GValue *value,
+ GParamSpec *pspec) {
+ RygelMediaExportHarvestingTask *self = RYGEL_MEDIA_EXPORT_HARVESTING_TASK (object);
+ RygelMediaExportHarvestingTaskPrivate *priv = self->priv;
-/**
- * If all files of a container were processed, notify the container
- * about this and set the updating signal.
- * Reschedule the iteration and extraction
- */
-static void rygel_media_export_harvesting_task_do_update (RygelMediaExportHarvestingTask* self) {
- gboolean _tmp0_ = FALSE;
- GeeQueue* _tmp1_;
- gint _tmp2_;
- gint _tmp3_;
- gboolean _tmp6_;
- GError * _inner_error_ = NULL;
- g_return_if_fail (self != NULL);
- _tmp1_ = self->priv->files;
- _tmp2_ = gee_collection_get_size ((GeeCollection*) _tmp1_);
- _tmp3_ = _tmp2_;
- if (_tmp3_ == 0) {
- GQueue* _tmp4_;
- guint _tmp5_ = 0U;
- _tmp4_ = self->priv->containers;
- _tmp5_ = g_queue_get_length (_tmp4_);
- _tmp0_ = _tmp5_ != ((guint) 0);
- } else {
- _tmp0_ = FALSE;
- }
- _tmp6_ = _tmp0_;
- if (_tmp6_) {
- GQueue* _tmp7_;
- gconstpointer _tmp8_ = NULL;
- RygelMediaContainer* _tmp9_;
- RygelMediaContainer* container;
- GQueue* _tmp26_;
- gpointer _tmp27_ = NULL;
- RygelMediaContainer* _tmp28_;
- _tmp7_ = self->priv->containers;
- _tmp8_ = g_queue_peek_head (_tmp7_);
- _tmp9_ = g_object_ref ((RygelMediaContainer*) _tmp8_);
- container = _tmp9_;
- {
- RygelMediaExportMediaCache* _tmp10_ = NULL;
- RygelMediaExportMediaCache* cache;
- RygelMediaExportMediaCache* _tmp11_;
- RygelMediaContainer* _tmp12_;
- const gchar* _tmp13_;
- const gchar* _tmp14_;
- gint _tmp15_ = 0;
- gint _tmp16_;
- _tmp10_ = rygel_media_export_media_cache_get_default (&_inner_error_);
- cache = _tmp10_;
- if (_inner_error_ != NULL) {
- goto __catch58_g_error;
- }
- _tmp11_ = cache;
- _tmp12_ = container;
- _tmp13_ = rygel_media_object_get_id ((RygelMediaObject*) _tmp12_);
- _tmp14_ = _tmp13_;
- _tmp15_ = rygel_media_export_media_cache_get_child_count (_tmp11_, _tmp14_, &_inner_error_);
- _tmp16_ = _tmp15_;
- if (_inner_error_ != NULL) {
- g_object_unref (cache);
- goto __catch58_g_error;
- }
- if (_tmp16_ > 0) {
- GQueue* _tmp17_;
- gconstpointer _tmp18_ = NULL;
- RygelMediaContainer* _tmp19_;
- RygelMediaContainer* head;
- RygelMediaContainer* _tmp20_;
- RygelMediaContainer* _tmp21_;
- _tmp17_ = self->priv->containers;
- _tmp18_ = g_queue_peek_head (_tmp17_);
- _tmp19_ = g_object_ref ((RygelMediaContainer*) _tmp18_);
- head = _tmp19_;
- _tmp20_ = head;
- _tmp21_ = head;
- rygel_media_container_updated (_tmp20_, (RygelMediaObject*) _tmp21_, RYGEL_OBJECT_EVENT_TYPE_MODIFIED, FALSE);
- g_object_unref (head);
- } else {
- RygelMediaExportMediaCache* _tmp22_;
- RygelMediaContainer* _tmp23_;
- const gchar* _tmp24_;
- const gchar* _tmp25_;
- _tmp22_ = cache;
- _tmp23_ = container;
- _tmp24_ = rygel_media_object_get_id ((RygelMediaObject*) _tmp23_);
- _tmp25_ = _tmp24_;
- rygel_media_export_media_cache_remove_by_id (_tmp22_, _tmp25_, &_inner_error_);
- if (_inner_error_ != NULL) {
- g_object_unref (cache);
- goto __catch58_g_error;
- }
- }
- g_object_unref (cache);
- }
- goto __finally58;
- __catch58_g_error:
- {
- GError* _error_ = NULL;
- _error_ = _inner_error_;
- _inner_error_ = NULL;
- g_error_free (_error_);
- }
- __finally58:
- if (_inner_error_ != NULL) {
- g_object_unref (container);
- g_critical ("file %s: line %d: uncaught error: %s (%s, %d)", __FILE__, __LINE__, _inner_error_->message, g_quark_to_string (_inner_error_->domain), _inner_error_->code);
- g_clear_error (&_inner_error_);
- return;
- }
- _tmp26_ = self->priv->containers;
- _tmp27_ = g_queue_pop_head (_tmp26_);
- _tmp28_ = (RygelMediaContainer*) _tmp27_;
- g_object_unref (_tmp28_);
- g_object_unref (container);
- }
- rygel_media_export_harvesting_task_on_idle (self);
-}
+ switch (property_id) {
+ case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_CANCELLABLE:
+ g_value_set_object (value, rygel_state_machine_get_cancellable (RYGEL_STATE_MACHINE (self)));
+ break;
+ case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_EXTRACTOR:
+ g_value_set_object (value, priv->extractor);
+ break;
-static GCancellable* rygel_media_export_harvesting_task_real_get_cancellable (RygelStateMachine* base) {
- GCancellable* result;
- RygelMediaExportHarvestingTask* self;
- GCancellable* _tmp0_;
- self = (RygelMediaExportHarvestingTask*) base;
- _tmp0_ = self->priv->_cancellable;
- result = _tmp0_;
- return result;
-}
+ case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_MONITOR:
+ g_value_set_object (value, priv->monitor);
+ break;
+ case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_ORIGIN:
+ g_value_set_object (value, priv->origin);
+ break;
-static void rygel_media_export_harvesting_task_real_set_cancellable (RygelStateMachine* base, GCancellable* value) {
- RygelMediaExportHarvestingTask* self;
- GCancellable* _tmp0_;
- GCancellable* _tmp1_;
- self = (RygelMediaExportHarvestingTask*) base;
- _tmp0_ = value;
- _tmp1_ = g_object_ref (_tmp0_);
- g_object_unref (self->priv->_cancellable);
- self->priv->_cancellable = _tmp1_;
- g_object_notify ((GObject *) self, "cancellable");
-}
+ case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_PARENT:
+ g_value_set_object (value, priv->parent);
+ break;
+ case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_FLAG:
+ g_value_set_string (value, priv->flag);
+ break;
-static void rygel_media_export_harvesting_task_class_init (RygelMediaExportHarvestingTaskClass * klass) {
- rygel_media_export_harvesting_task_parent_class = g_type_class_peek_parent (klass);
- g_type_class_add_private (klass, sizeof (RygelMediaExportHarvestingTaskPrivate));
- G_OBJECT_CLASS (klass)->get_property = _vala_rygel_media_export_harvesting_task_get_property;
- G_OBJECT_CLASS (klass)->set_property = _vala_rygel_media_export_harvesting_task_set_property;
- G_OBJECT_CLASS (klass)->finalize = rygel_media_export_harvesting_task_finalize;
- g_object_class_install_property (G_OBJECT_CLASS (klass), RYGEL_MEDIA_EXPORT_HARVESTING_TASK_CANCELLABLE, g_param_spec_object ("cancellable", "cancellable", "cancellable", g_cancellable_get_type (), G_PARAM_STATIC_NAME | G_PARAM_STATIC_NICK | G_PARAM_STATIC_BLURB | G_PARAM_READABLE | G_PARAM_WRITABLE));
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
+ break;
+ }
}
+static void
+rygel_media_export_harvesting_task_set_property (GObject *object,
+ guint property_id,
+ const GValue *value,
+ GParamSpec *pspec) {
+ RygelMediaExportHarvestingTask *self = RYGEL_MEDIA_EXPORT_HARVESTING_TASK (object);
+ RygelMediaExportHarvestingTaskPrivate *priv = self->priv;
+
+ switch (property_id) {
+ case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_CANCELLABLE:
+ rygel_state_machine_set_cancellable (RYGEL_STATE_MACHINE (self), g_value_get_object (value));
+ break;
+
+ case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_EXTRACTOR:
+ /* construct only property */
+ priv->extractor = g_value_dup_object (value);
+ break;
+
+ case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_MONITOR:
+ /* construct only property */
+ priv->monitor = g_value_dup_object (value);
+ break;
+
+ case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_ORIGIN:
+ /* construct only property */
+ priv->origin = g_value_dup_object (value);
+ break;
+
+ case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_PARENT:
+ /* construct only property */
+ priv->parent = g_value_dup_object (value);
+ break;
+
+ case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_FLAG:
+ /* construct only property */
+ priv->flag = g_value_dup_string (value);
+ break;
+
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
+ break;
+ }
+}
-static void rygel_media_export_harvesting_task_rygel_state_machine_interface_init (RygelStateMachineIface * iface) {
- iface->run = rygel_media_export_harvesting_task_real_run;
- iface->run_finish = rygel_media_export_harvesting_task_real_run_finish;
- iface->get_cancellable = rygel_media_export_harvesting_task_real_get_cancellable;
- iface->set_cancellable = rygel_media_export_harvesting_task_real_set_cancellable;
+static void
+rygel_media_export_harvesting_task_dispose (GObject *object) {
+ RygelMediaExportHarvestingTask *self = RYGEL_MEDIA_EXPORT_HARVESTING_TASK (object);
+ RygelMediaExportHarvestingTaskPrivate *priv = self->priv;
+
+ if (priv->origin) {
+ GFile *file = priv->origin;
+
+ priv->origin = NULL;
+ g_object_unref (file);
+ }
+ if (priv->extractor) {
+ RygelMediaExportMetadataExtractor *extractor = priv->extractor;
+
+ priv->extractor = NULL;
+ g_object_unref (extractor);
+ }
+ if (priv->cache) {
+ RygelMediaExportMediaCache *cache = priv->cache;
+
+ priv->cache = NULL;
+ g_object_unref (cache);
+ }
+ if (priv->containers) {
+ GQueue *containers = priv->containers;
+
+ priv->containers = NULL;
+ g_queue_free_full (containers, g_object_unref);
+ }
+ if (priv->files) {
+ GeeQueue *files = priv->files;
+
+ priv->files = NULL;
+ g_object_unref (files);
+ }
+ if (priv->monitor) {
+ RygelMediaExportRecursiveFileMonitor *monitor = priv->monitor;
+
+ priv->monitor = NULL;
+ g_object_unref (monitor);
+ }
+ if (priv->parent) {
+ RygelMediaContainer *parent = priv->parent;
+
+ priv->parent = NULL;
+ g_object_unref (parent);
+ }
+ if (priv->cancellable) {
+ GCancellable *cancellable = priv->cancellable;
+
+ priv->cancellable = NULL;
+ g_object_unref (cancellable);
+ }
+ G_OBJECT_CLASS (rygel_media_export_harvesting_task_parent_class)->dispose (object);
}
+static void
+rygel_media_export_harvesting_task_finalize (GObject *object) {
+ RygelMediaExportHarvestingTask *self = RYGEL_MEDIA_EXPORT_HARVESTING_TASK (object);
+ RygelMediaExportHarvestingTaskPrivate *priv = self->priv;
-static void rygel_media_export_harvesting_task_init (RygelMediaExportHarvestingTask * self) {
- self->priv = RYGEL_MEDIA_EXPORT_HARVESTING_TASK_GET_PRIVATE (self);
+ g_free (priv->flag);
+ G_OBJECT_CLASS (rygel_media_export_harvesting_task_parent_class)->finalize (object);
}
+static void
+rygel_media_export_harvesting_task_constructed (GObject *object) {
+ RygelMediaExportHarvestingTask *self = RYGEL_MEDIA_EXPORT_HARVESTING_TASK (object);
+ RygelMediaExportHarvestingTaskPrivate *priv = self->priv;
+ GError *inner_error = NULL;
+
+ G_OBJECT_CLASS (rygel_media_export_harvesting_task_parent_class)->constructed (object);
+
+ priv->cache = rygel_media_export_media_cache_get_default (&inner_error);
+ /* No error should happen now, because harvesting task is created
+ * long after media cache is gotten for the first time. If it erred,
+ * then no tasks would be created. */
+ g_assert_no_error (inner_error);
+
+ g_signal_connect_object (priv->extractor,
+ "extraction-done",
+ G_CALLBACK (rygel_media_export_harvesting_task_on_extracted_cb_rygel_media_export_metadata_extractor_extraction_done),
+ self,
+ 0);
+ g_signal_connect_object (priv->extractor,
+ "error",
+ G_CALLBACK (rygel_media_export_harvesting_task_on_extractor_error_cb_rygel_media_export_metadata_extractor_error),
+ self,
+ 0);
+ priv->files = GEE_QUEUE (gee_linked_list_new (G_TYPE_FILE, (GBoxedCopyFunc) g_object_ref, g_object_unref, NULL, NULL, NULL));
+ priv->containers = g_queue_new ();
+}
-static void rygel_media_export_harvesting_task_finalize (GObject* obj) {
- RygelMediaExportHarvestingTask * self;
- self = G_TYPE_CHECK_INSTANCE_CAST (obj, RYGEL_MEDIA_EXPORT_TYPE_HARVESTING_TASK, RygelMediaExportHarvestingTask);
- g_object_unref (self->origin);
- g_object_unref (self->priv->extractor);
- g_object_unref (self->priv->cache);
- __g_queue_free_g_object_unref_0 (self->priv->containers);
- g_object_unref (self->priv->files);
- g_object_unref (self->priv->monitor);
- g_free (self->priv->flag);
- g_object_unref (self->priv->parent);
- g_object_unref (self->priv->_cancellable);
- G_OBJECT_CLASS (rygel_media_export_harvesting_task_parent_class)->finalize (obj);
+static void
+rygel_media_export_harvesting_task_class_init (RygelMediaExportHarvestingTaskClass *task_class) {
+ GObjectClass *object_class = G_OBJECT_CLASS (task_class);
+
+ object_class->get_property = rygel_media_export_harvesting_task_get_property;
+ object_class->set_property = rygel_media_export_harvesting_task_set_property;
+ object_class->dispose = rygel_media_export_harvesting_task_dispose;
+ object_class->finalize = rygel_media_export_harvesting_task_finalize;
+ object_class->constructed = rygel_media_export_harvesting_task_constructed;
+
+ g_object_class_install_property (object_class,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_CANCELLABLE,
+ g_param_spec_object ("cancellable",
+ "cancellable",
+ "cancellable",
+ G_TYPE_CANCELLABLE,
+ G_PARAM_STATIC_NAME |
+ G_PARAM_STATIC_NICK |
+ G_PARAM_STATIC_BLURB |
+ G_PARAM_READABLE |
+ G_PARAM_WRITABLE |
+ G_PARAM_CONSTRUCT));
+ g_object_class_install_property (object_class,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_EXTRACTOR,
+ g_param_spec_object ("extractor",
+ "extractor",
+ "extractor",
+ RYGEL_MEDIA_EXPORT_TYPE_METADATA_EXTRACTOR,
+ G_PARAM_STATIC_NAME |
+ G_PARAM_STATIC_NICK |
+ G_PARAM_STATIC_BLURB |
+ G_PARAM_READABLE |
+ G_PARAM_WRITABLE |
+ G_PARAM_CONSTRUCT_ONLY));
+ g_object_class_install_property (object_class,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_MONITOR,
+ g_param_spec_object ("monitor",
+ "monitor",
+ "monitor",
+ RYGEL_MEDIA_EXPORT_TYPE_RECURSIVE_FILE_MONITOR,
+ G_PARAM_STATIC_NAME |
+ G_PARAM_STATIC_NICK |
+ G_PARAM_STATIC_BLURB |
+ G_PARAM_READABLE |
+ G_PARAM_WRITABLE |
+ G_PARAM_CONSTRUCT_ONLY));
+ g_object_class_install_property (object_class,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_ORIGIN,
+ g_param_spec_object ("origin",
+ "origin",
+ "origin",
+ G_TYPE_FILE,
+ G_PARAM_STATIC_NAME |
+ G_PARAM_STATIC_NICK |
+ G_PARAM_STATIC_BLURB |
+ G_PARAM_READABLE |
+ G_PARAM_WRITABLE |
+ G_PARAM_CONSTRUCT_ONLY));
+ g_object_class_install_property (object_class,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_PARENT,
+ g_param_spec_object ("parent",
+ "parent",
+ "parent",
+ RYGEL_TYPE_MEDIA_CONTAINER,
+ G_PARAM_STATIC_NAME |
+ G_PARAM_STATIC_NICK |
+ G_PARAM_STATIC_BLURB |
+ G_PARAM_READABLE |
+ G_PARAM_WRITABLE |
+ G_PARAM_CONSTRUCT_ONLY));
+ g_object_class_install_property (object_class,
+ RYGEL_MEDIA_EXPORT_HARVESTING_TASK_FLAG,
+ g_param_spec_string ("flag",
+ "flag",
+ "flag",
+ NULL,
+ G_PARAM_STATIC_NAME |
+ G_PARAM_STATIC_NICK |
+ G_PARAM_STATIC_BLURB |
+ G_PARAM_READABLE |
+ G_PARAM_WRITABLE |
+ G_PARAM_CONSTRUCT_ONLY));
+
+ g_type_class_add_private (task_class, sizeof (RygelMediaExportHarvestingTaskPrivate));
}
+static void
+rygel_media_export_harvesting_task_rygel_state_machine_interface_init (RygelStateMachineIface *iface) {
+ iface->run = rygel_media_export_harvesting_task_real_run;
+ iface->run_finish = rygel_media_export_harvesting_task_real_run_finish;
+ iface->get_cancellable = rygel_media_export_harvesting_task_real_get_cancellable;
+ iface->set_cancellable = rygel_media_export_harvesting_task_real_set_cancellable;
+}
-static void _vala_rygel_media_export_harvesting_task_get_property (GObject * object, guint property_id, GValue * value, GParamSpec * pspec) {
- RygelMediaExportHarvestingTask * self;
- self = G_TYPE_CHECK_INSTANCE_CAST (object, RYGEL_MEDIA_EXPORT_TYPE_HARVESTING_TASK, RygelMediaExportHarvestingTask);
- switch (property_id) {
- case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_CANCELLABLE:
- g_value_set_object (value, rygel_state_machine_get_cancellable ((RygelStateMachine*) self));
- break;
- default:
- G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
- break;
- }
+static void
+rygel_media_export_harvesting_task_init (RygelMediaExportHarvestingTask * self) {
+ self->priv = RYGEL_MEDIA_EXPORT_HARVESTING_TASK_GET_PRIVATE (self);
}
+GFile *
+rygel_media_export_harvesting_task_get_origin (RygelMediaExportHarvestingTask *self) {
+ g_return_val_if_fail (RYGEL_MEDIA_EXPORT_IS_HARVESTING_TASK (self), NULL);
-static void _vala_rygel_media_export_harvesting_task_set_property (GObject * object, guint property_id, const GValue * value, GParamSpec * pspec) {
- RygelMediaExportHarvestingTask * self;
- self = G_TYPE_CHECK_INSTANCE_CAST (object, RYGEL_MEDIA_EXPORT_TYPE_HARVESTING_TASK, RygelMediaExportHarvestingTask);
- switch (property_id) {
- case RYGEL_MEDIA_EXPORT_HARVESTING_TASK_CANCELLABLE:
- rygel_state_machine_set_cancellable ((RygelStateMachine*) self, g_value_get_object (value));
- break;
- default:
- G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec);
- break;
- }
+ return self->priv->origin;
}
diff --git a/src/media-export/rygel-media-export-harvesting-task.h b/src/media-export/rygel-media-export-harvesting-task.h
index eda3292..7e38edc 100644
--- a/src/media-export/rygel-media-export-harvesting-task.h
+++ b/src/media-export/rygel-media-export-harvesting-task.h
@@ -46,7 +46,6 @@ typedef struct _RygelMediaExportHarvestingTaskPrivate RygelMediaExportHarvesting
struct _RygelMediaExportHarvestingTask {
GObject parent_instance;
RygelMediaExportHarvestingTaskPrivate *priv;
- GFile* origin; /* TODO: Move to priv. */
};
struct _RygelMediaExportHarvestingTaskClass {
@@ -66,6 +65,9 @@ rygel_media_export_harvesting_task_new (RygelMediaExportMetadataExtractor *ex
void
rygel_media_export_harvesting_task_cancel (RygelMediaExportHarvestingTask *self);
+GFile *
+rygel_media_export_harvesting_task_get_origin (RygelMediaExportHarvestingTask *self);
+
G_END_DECLS
#endif /* __RYGEL_0_10_PLUGINS_MEDIA_EXPORT_HARVESTING_TASK_H__ */
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]
