[gnome-photos/wip/rishi/share-point: 1/10] base-item: Add photos_base_item_save_to_stream_async
- From: Debarshi Ray <debarshir src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [gnome-photos/wip/rishi/share-point: 1/10] base-item: Add photos_base_item_save_to_stream_async
- Date: Sat, 23 Jul 2016 14:48:43 +0000 (UTC)
commit df7b1c72c6ae531589409b241d3b1d4910dda706
Author: Debarshi Ray <debarshir gnome org>
Date: Fri Jul 22 11:14:15 2016 +0200
base-item: Add photos_base_item_save_to_stream_async
src/photos-base-item.c | 240 ++++++++++++++++++++++++++++++++++++++++++++++++
src/photos-base-item.h | 11 ++
2 files changed, 251 insertions(+), 0 deletions(-)
---
diff --git a/src/photos-base-item.c b/src/photos-base-item.c
index bbed616..3fc7a1d 100644
--- a/src/photos-base-item.c
+++ b/src/photos-base-item.c
@@ -133,6 +133,7 @@ EGG_DEFINE_COUNTER (instances, "PhotosBaseItem", "Instances", "Number of PhotosB
typedef struct _PhotosBaseItemSaveData PhotosBaseItemSaveData;
typedef struct _PhotosBaseItemSaveBufferData PhotosBaseItemSaveBufferData;
+typedef struct _PhotosBaseItemSaveToStreamData PhotosBaseItemSaveToStreamData;
struct _PhotosBaseItemSaveData
{
@@ -148,6 +149,13 @@ struct _PhotosBaseItemSaveBufferData
GFileOutputStream *stream;
};
+struct _PhotosBaseItemSaveToStreamData
+{
+ GFile *file;
+ GFileIOStream *iostream;
+ GOutputStream *ostream;
+};
+
static GdkPixbuf *failed_icon;
static GdkPixbuf *thumbnailing_icon;
static GThreadPool *create_thumbnail_pool;
@@ -209,6 +217,28 @@ photos_base_item_save_buffer_data_free (PhotosBaseItemSaveBufferData *data)
}
+static PhotosBaseItemSaveToStreamData *
+photos_base_item_save_to_stream_data_new (GOutputStream *ostream)
+{
+ PhotosBaseItemSaveToStreamData *data;
+
+ data = g_slice_new0 (PhotosBaseItemSaveToStreamData);
+ data->ostream = g_object_ref (ostream);
+
+ return data;
+}
+
+
+static void
+photos_base_item_save_to_stream_data_free (PhotosBaseItemSaveToStreamData *data)
+{
+ g_clear_object (&data->file);
+ g_clear_object (&data->iostream);
+ g_clear_object (&data->ostream);
+ g_slice_free (PhotosBaseItemSaveToStreamData, data);
+}
+
+
static GdkPixbuf *
photos_base_item_create_placeholder_icon (const gchar *icon_name)
{
@@ -1579,6 +1609,154 @@ photos_base_item_save_buffer_zoom (GObject *source_object, GAsyncResult *res, gp
static void
+photos_base_item_save_to_stream_stream_close (GObject *source_object, GAsyncResult *res, gpointer user_data)
+{
+ GError *error;
+ GIOStream *iostream = G_IO_STREAM (source_object);
+ GTask *task = G_TASK (user_data);
+
+ error = NULL;
+ g_io_stream_close_finish (iostream, res, &error);
+ if (error != NULL)
+ {
+ g_task_return_error (task, error);
+ goto out;
+ }
+
+ g_task_return_boolean (task, TRUE);
+
+ out:
+ g_object_unref (task);
+}
+
+
+static void
+photos_base_item_save_to_stream_stream_splice (GObject *source_object, GAsyncResult *res, gpointer user_data)
+{
+ GCancellable *cancellable;
+ GError *error;
+ GOutputStream *ostream = G_OUTPUT_STREAM (source_object);
+ GTask *task = G_TASK (user_data);
+ PhotosBaseItemSaveToStreamData *data;
+
+ cancellable = g_task_get_cancellable (task);
+ data = (PhotosBaseItemSaveToStreamData *) g_task_get_task_data (task);
+
+ error = NULL;
+ g_output_stream_splice_finish (ostream, res, &error);
+ if (error != NULL)
+ {
+ g_task_return_error (task, error);
+ goto out;
+ }
+
+ g_io_stream_close_async (G_IO_STREAM (data->iostream),
+ G_PRIORITY_DEFAULT,
+ cancellable,
+ photos_base_item_save_to_stream_stream_close,
+ g_object_ref (task));
+
+ out:
+ g_object_unref (task);
+}
+
+
+static void
+photos_base_item_save_to_stream_save_buffer (GObject *source_object, GAsyncResult *res, gpointer user_data)
+{
+ PhotosBaseItem *self = PHOTOS_BASE_ITEM (source_object);
+ GCancellable *cancellable;
+ GError *error;
+ GInputStream *istream;
+ GTask *task = G_TASK (user_data);
+ PhotosBaseItemSaveToStreamData *data;
+
+ cancellable = g_task_get_cancellable (task);
+ data = (PhotosBaseItemSaveToStreamData *) g_task_get_task_data (task);
+
+ error = NULL;
+ if (!photos_base_item_save_buffer_finish (self, res, &error))
+ {
+ g_task_return_error (task, error);
+ goto out;
+ }
+
+ error = NULL;
+ if (!g_seekable_seek (G_SEEKABLE (data->iostream), 0, G_SEEK_SET, cancellable, &error))
+ {
+ g_task_return_error (task, error);
+ goto out;
+ }
+
+ istream = g_io_stream_get_input_stream (G_IO_STREAM (data->iostream));
+ g_output_stream_splice_async (data->ostream,
+ istream,
+ G_OUTPUT_STREAM_SPLICE_CLOSE_SOURCE | G_OUTPUT_STREAM_SPLICE_CLOSE_TARGET,
+ G_PRIORITY_DEFAULT,
+ cancellable,
+ photos_base_item_save_to_stream_stream_splice,
+ g_object_ref (task));
+
+ out:
+ g_object_unref (task);
+}
+
+
+static void
+photos_base_item_save_to_stream_buffer_zoom (GObject *source_object, GAsyncResult *res, gpointer user_data)
+{
+ GTask *task = G_TASK (user_data);
+ PhotosBaseItem *self;
+ GCancellable *cancellable;
+ GError *error;
+ GFile *file = NULL;
+ GFileIOStream *iostream = NULL;
+ GOutputStream *ostream;
+ GeglBuffer *buffer = GEGL_BUFFER (source_object);
+ GeglBuffer *buffer_zoomed = NULL;
+ PhotosBaseItemSaveToStreamData *data;
+
+ self = PHOTOS_BASE_ITEM (g_task_get_source_object (task));
+ cancellable = g_task_get_cancellable (task);
+ data = (PhotosBaseItemSaveToStreamData *) g_task_get_task_data (task);
+
+ error = NULL;
+ buffer_zoomed = photos_utils_buffer_zoom_finish (buffer, res, &error);
+ if (error != NULL)
+ {
+ g_task_return_error (task, error);
+ goto out;
+ }
+
+ error = NULL;
+ file = g_file_new_tmp ("gnome-photos-XXXXXX", &iostream, &error);
+ if (error != NULL)
+ {
+ g_task_return_error (task, error);
+ goto out;
+ }
+
+ g_assert_null (data->iostream);
+ data->iostream = g_object_ref (iostream);
+
+ ostream = g_io_stream_get_output_stream (G_IO_STREAM (iostream));
+ photos_base_item_save_buffer_async (self,
+ buffer_zoomed,
+ file,
+ G_FILE_OUTPUT_STREAM (ostream),
+ cancellable,
+ photos_base_item_save_to_stream_save_buffer,
+ g_object_ref (task));
+
+ out:
+ g_clear_object (&buffer_zoomed);
+ g_clear_object (&file);
+ g_clear_object (&iostream);
+ g_object_unref (task);
+}
+
+
+static void
photos_base_item_set_thumbnailing_icon (PhotosBaseItem *self)
{
if (thumbnailing_icon == NULL)
@@ -2921,6 +3099,68 @@ photos_base_item_save_finish (PhotosBaseItem *self, GAsyncResult *res, GError **
void
+photos_base_item_save_to_stream_async (PhotosBaseItem *self,
+ GOutputStream *stream,
+ gdouble zoom,
+ GCancellable *cancellable,
+ GAsyncReadyCallback callback,
+ gpointer user_data)
+{
+ PhotosBaseItemPrivate *priv;
+ GTask *task;
+ GeglBuffer *buffer;
+ GeglNode *graph;
+ PhotosBaseItemSaveToStreamData *data;
+
+ g_return_if_fail (PHOTOS_IS_BASE_ITEM (self));
+ priv = self->priv;
+
+ g_return_if_fail (!priv->collection);
+ g_return_if_fail (G_IS_OUTPUT_STREAM (stream));
+ g_return_if_fail (priv->edit_graph != NULL);
+ g_return_if_fail (priv->filename != NULL && priv->filename[0] != '\0');
+ g_return_if_fail (priv->load_graph != NULL);
+ g_return_if_fail (priv->pipeline != NULL);
+ g_return_if_fail (priv->processor != NULL);
+ g_return_if_fail (!gegl_processor_work (priv->processor, NULL));
+
+ data = photos_base_item_save_to_stream_data_new (stream);
+
+ task = g_task_new (self, cancellable, callback, user_data);
+ g_task_set_source_tag (task, photos_base_item_save_to_stream_async);
+ g_task_set_task_data (task, data, (GDestroyNotify) photos_base_item_save_to_stream_data_free);
+
+ graph = photos_pipeline_get_graph (priv->pipeline);
+ buffer = photos_utils_create_buffer_from_node (graph);
+ photos_utils_buffer_zoom_async (buffer,
+ zoom,
+ cancellable,
+ photos_base_item_save_to_stream_buffer_zoom,
+ g_object_ref (task));
+
+ g_object_unref (buffer);
+ g_object_unref (task);
+}
+
+
+gboolean
+photos_base_item_save_to_stream_finish (PhotosBaseItem *self, GAsyncResult *res, GError **error)
+{
+ GTask *task;
+
+ g_return_val_if_fail (PHOTOS_IS_BASE_ITEM (self), FALSE);
+
+ g_return_val_if_fail (g_task_is_valid (res, self), FALSE);
+ task = G_TASK (res);
+
+ g_return_val_if_fail (g_task_get_source_tag (task) == photos_base_item_save_to_stream_async, FALSE);
+ g_return_val_if_fail (error == NULL || *error == NULL, FALSE);
+
+ return g_task_propagate_boolean (task, error);
+}
+
+
+void
photos_base_item_set_default_app (PhotosBaseItem *self, GAppInfo *default_app)
{
PhotosBaseItemPrivate *priv;
diff --git a/src/photos-base-item.h b/src/photos-base-item.h
index b2c454f..523903f 100644
--- a/src/photos-base-item.h
+++ b/src/photos-base-item.h
@@ -269,6 +269,17 @@ GFile *photos_base_item_save_finish (PhotosBaseItem *se
GAsyncResult *res,
GError **error) G_GNUC_WARN_UNUSED_RESULT;
+void photos_base_item_save_to_stream_async (PhotosBaseItem *self,
+ GOutputStream *stream,
+ gdouble zoom,
+ GCancellable *cancellable,
+ GAsyncReadyCallback callback,
+ gpointer user_data);
+
+gboolean photos_base_item_save_to_stream_finish (PhotosBaseItem *self,
+ GAsyncResult *res,
+ GError **error);
+
void photos_base_item_set_default_app (PhotosBaseItem *self, GAppInfo *default_app);
void photos_base_item_set_default_app_name (PhotosBaseItem *self, const gchar
*default_app_name);
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]