[libvirt] [libvirt-glib] [PATCH 3/4] GVirDomain: Add async version of _create_snapshot

[Timm Bäder]

---
 libvirt-gobject/libvirt-gobject-domain.c | 67 ++++++++++++++++++++++++++++++++
 libvirt-gobject/libvirt-gobject-domain.h | 11 ++++++
 libvirt-gobject/libvirt-gobject.sym      |  2 +
 3 files changed, 80 insertions(+)

diff --git a/libvirt-gobject/libvirt-gobject-domain.c b/libvirt-gobject/libvirt-gobject-domain.c
index aa2a170..29b82d0 100644
--- a/libvirt-gobject/libvirt-gobject-domain.c
+++ b/libvirt-gobject/libvirt-gobject-domain.c
@@ -61,6 +61,11 @@ enum {
     LAST_SIGNAL
 };
 
+typedef struct {
+    guint create_flags;
+    GVirConfigDomainSnapshot *snapshot_config;
+} SnapshotCreateData;
+
 static gint signals[LAST_SIGNAL];
 
 #define GVIR_DOMAIN_ERROR gvir_domain_error_quark()
@@ -1524,6 +1529,68 @@ gvir_domain_create_snapshot(GVirDomain *dom,
 }
 
 
+static void _create_snapshot_async_thread(GTask *task,
+                                          gpointer source_object,
+                                          gpointer task_data,
+                                          GCancellable *cancellable) {
+    GError *error = NULL;
+    GVirDomainSnapshot *snapshot;
+    SnapshotCreateData *create_data = task_data;
+
+    snapshot = gvir_domain_create_snapshot(source_object,
+                                           create_data->snapshot_config,
+                                           create_data->create_flags,
+                                           &error);
+    if (snapshot)
+      g_task_return_pointer(task, snapshot, g_object_unref);
+    else
+      g_task_return_error(task, error);
+}
+
+/**
+ * gvir_domain_create_snapshot_async:
+ * @dom: The #GVirDomain
+ * @custom_conf: (allow-none): Configuration of snapshot or %NULL
+ * @flags: Bitwise-OR of #GVirDomainSnapshotCreateFlags
+ * @callback: (scope async): Complection callback
+ * @user_data: (closure): Opaque data for callback
+ */
+void gvir_domain_create_snapshot_async(GVirDomain *dom,
+                                       GVirConfigDomainSnapshot *custom_conf,
+                                       guint flags,
+                                       GAsyncReadyCallback callback,
+                                       gpointer user_data) {
+    SnapshotCreateData *create_data;
+    GTask *task;
+
+    g_return_if_fail(GVIR_IS_DOMAIN(dom));
+    g_return_if_fail(GVIR_CONFIG_IS_DOMAIN_SNAPSHOT(custom_conf));
+
+    create_data = g_slice_new(SnapshotCreateData);
+    create_data->create_flags = flags;
+    create_data->snapshot_config = custom_conf;
+
+    task = g_task_new(dom, NULL, callback, user_data);
+    g_task_set_task_data(task, create_data, NULL);
+    g_task_run_in_thread(task, _create_snapshot_async_thread);
+    g_object_unref(task);
+}
+
+/**
+ * gvir_domain_create_snapshot_finish:
+ * @domain: A #GVirDomain
+ * @result: (transfer none): Async method result
+ * @error: (allow-none): Error placeholder
+ *
+ * Returns: (transfer full): The created snapshot
+ */
+GVirDomainSnapshot * gvir_domain_create_snapshot_finish(GVirDomain  *domain,
+                                                        GAsyncResult *result,
+                                                        GError **error) {
+    g_return_val_if_fail(g_task_is_valid(result, domain), NULL);
+
+    return g_task_propagate_pointer(G_TASK(result), error);
+}
 
 /**
  * gvir_domain_fetch_snapshots:
diff --git a/libvirt-gobject/libvirt-gobject-domain.h b/libvirt-gobject/libvirt-gobject-domain.h
index 56c80b8..b5a0bd9 100644
--- a/libvirt-gobject/libvirt-gobject-domain.h
+++ b/libvirt-gobject/libvirt-gobject-domain.h
@@ -363,6 +363,17 @@ gvir_domain_create_snapshot(GVirDomain *dom,
                             guint flags,
                             GError **err);
 
+void gvir_domain_create_snapshot_async(GVirDomain *dom,
+                                       GVirConfigDomainSnapshot *custom_conf,
+                                       guint flags,
+                                       GAsyncReadyCallback callback,
+                                       gpointer user_data);
+
+GVirDomainSnapshot * gvir_domain_create_snapshot_finish(GVirDomain  *domain,
+                                                        GAsyncResult *result,
+                                                        GError **error);
+
+
 gboolean gvir_domain_fetch_snapshots(GVirDomain *dom,
                                      guint list_flags,
                                      GCancellable *cancellable,
diff --git a/libvirt-gobject/libvirt-gobject.sym b/libvirt-gobject/libvirt-gobject.sym
index ebb9418..a610121 100644
--- a/libvirt-gobject/libvirt-gobject.sym
+++ b/libvirt-gobject/libvirt-gobject.sym
@@ -236,6 +236,8 @@ LIBVIRT_GOBJECT_0.1.5 {
 
 LIBVIRT_GOBJECT_0.1.9 {
   global:
+	gvir_domain_create_snapshot_async;
+	gvir_domain_create_snapshot_finish;
 	gvir_domain_fetch_snapshots;
 	gvir_domain_fetch_snapshots_async;
 	gvir_domain_fetch_snapshots_finish;
-- 
2.0.4