[virt-tools-list] [virt-viewer 13/20] Implement ovirt_proxy_vm_action_async

[Christophe Fergeau]

---
 src/ovirt-proxy.c |  110 +++++++++++++++++++++++++++++++++++++++++++++++++++++
 src/ovirt-proxy.h |   11 ++++++
 2 files changed, 121 insertions(+)

diff --git a/src/ovirt-proxy.c b/src/ovirt-proxy.c
index 948da10..16e1eaa 100644
--- a/src/ovirt-proxy.c
+++ b/src/ovirt-proxy.c
@@ -676,6 +676,116 @@ gboolean ovirt_proxy_vm_stop(OvirtProxy *proxy, OvirtVm *vm, GError **error)
     return ovirt_proxy_vm_action(proxy, vm, "stop", NULL, error);
 }
 
+typedef struct {
+    OvirtProxyActionAsyncCallback async_cb;
+    gpointer user_data;
+    OvirtVm *vm;
+    char *action;
+    ActionResponseParser response_parser;
+} OvirtProxyActionData;
+
+static void action_async_cb(RestProxyCall *call, const GError *librest_error,
+                            GObject *weak_object, gpointer user_data)
+{
+    OvirtProxyActionData *data = (OvirtProxyActionData *)user_data;
+    OvirtProxy *proxy = OVIRT_PROXY(weak_object);
+    const GError *error;
+    GError *action_error = NULL;
+
+    g_return_if_fail(data != NULL);
+
+    if (librest_error == NULL) {
+        parse_action_response(call, data->vm, data->response_parser, &action_error);
+        error = action_error;
+    } else {
+        error = librest_error;
+    }
+
+    if (data->async_cb != NULL) {
+        data->async_cb(proxy, data->vm, error, data->user_data);
+    }
+
+    if (action_error != NULL) {
+        g_error_free(action_error);
+    }
+    g_free(data->action);
+    g_object_unref(G_OBJECT(data->vm));
+    g_slice_free(OvirtProxyActionData, data);
+    g_object_unref(G_OBJECT(call));
+}
+
+static gboolean
+ovirt_proxy_vm_action_async(OvirtProxy *proxy, OvirtVm *vm,
+                            const char *action,
+                            ActionResponseParser response_parser,
+                            OvirtProxyActionAsyncCallback async_cb,
+                            gpointer user_data, GError **error)
+{
+    RestProxyCall *call;
+    OvirtProxyActionData *data;
+    const char *function;
+
+    g_return_val_if_fail(OVIRT_IS_VM(vm), FALSE);
+    g_return_val_if_fail(action != NULL, FALSE);
+    g_return_val_if_fail(OVIRT_IS_PROXY(proxy), FALSE);
+    g_return_val_if_fail(REST_IS_PROXY(proxy->priv->rest_proxy), FALSE);
+    g_return_val_if_fail((error == NULL) || (*error == NULL), FALSE);
+
+    function = ovirt_vm_get_action(vm, action);
+    g_return_val_if_fail(function != NULL, FALSE);
+
+    call = REST_PROXY_CALL(ovirt_rest_call_new(proxy->priv->rest_proxy));
+    rest_proxy_call_set_method(call, "POST");
+    rest_proxy_call_set_function(call, function);
+    rest_proxy_call_add_param(call, "async", "false");
+    data = g_slice_new(OvirtProxyActionData);
+    data->async_cb = async_cb;
+    data->user_data = user_data;
+    data->action = g_strdup(action);
+    data->vm = g_object_ref(G_OBJECT(vm));
+    data->response_parser = response_parser;
+
+    if (!rest_proxy_call_async(call, action_async_cb, G_OBJECT(proxy),
+                               data, error)) {
+        g_warning("Error while running %s on %p", action, vm);
+        g_free(data->action);
+        g_object_unref(G_OBJECT(data->vm));
+        g_slice_free(OvirtProxyActionData, data);
+        g_object_unref(G_OBJECT(call));
+        return FALSE;
+    }
+    return TRUE;
+}
+
+gboolean
+ovirt_proxy_vm_get_ticket_async(OvirtProxy *proxy, OvirtVm *vm,
+                                OvirtProxyActionAsyncCallback async_cb,
+                                gpointer user_data, GError **error)
+{
+    return ovirt_proxy_vm_action_async(proxy, vm, "ticket",
+                                       parse_ticket_status,
+                                       async_cb, user_data,
+                                       error);
+}
+
+gboolean
+ovirt_proxy_vm_start_async(OvirtProxy *proxy, OvirtVm *vm,
+                           OvirtProxyActionAsyncCallback async_cb,
+                           gpointer user_data, GError **error)
+{
+    return ovirt_proxy_vm_action_async(proxy, vm, "start", NULL,
+                                       async_cb, user_data, error);
+}
+
+gboolean
+ovirt_proxy_vm_stop_async(OvirtProxy *proxy, OvirtVm *vm,
+                          OvirtProxyActionAsyncCallback async_cb,
+                          gpointer user_data, GError **error)
+{
+    return ovirt_proxy_vm_action_async(proxy, vm, "stop", NULL,
+                                       async_cb, user_data, error);
+}
+
 static void
 ovirt_get_property(GObject *object, guint property_id,
                    GValue *value, GParamSpec *pspec)
diff --git a/src/ovirt-proxy.h b/src/ovirt-proxy.h
index a562677..1272b9d 100644
--- a/src/ovirt-proxy.h
+++ b/src/ovirt-proxy.h
@@ -80,4 +80,15 @@ typedef void (*OvirtProxyLookupVmAsyncCallback)(OvirtProxy *proxy, OvirtVm *vm,
 gboolean ovirt_proxy_lookup_vm_async(OvirtProxy *proxy, const char *vm_name,
                                      OvirtProxyLookupVmAsyncCallback async_cb,
                                      gpointer user_data, GError **error);
+
+typedef void (*OvirtProxyActionAsyncCallback)(OvirtProxy *proxy, OvirtVm *vm, const GError *error, gpointer user_data);
+gboolean ovirt_proxy_vm_get_ticket_async(OvirtProxy *proxy, OvirtVm *vm,
+                                         OvirtProxyActionAsyncCallback async_cb,
+                                         gpointer user_data, GError **error);
+gboolean ovirt_proxy_vm_start_async(OvirtProxy *proxy, OvirtVm *vm,
+                                    OvirtProxyActionAsyncCallback async_cb,
+                                    gpointer user_data, GError **error);
+gboolean ovirt_proxy_vm_stop_async(OvirtProxy *proxy, OvirtVm *vm,
+                                   OvirtProxyActionAsyncCallback async_cb,
+                                   gpointer user_data, GError **error);
 #endif
-- 
1.7.10.2