Blame libvirt-gobject/libvirt-gobject-storage-pool.c

Packit a07778
/*
Packit a07778
 * libvirt-gobject-storage_pool.c: libvirt glib integration
Packit a07778
 *
Packit a07778
 * Copyright (C) 2008 Daniel P. Berrange
Packit a07778
 * Copyright (C) 2010-2011 Red Hat, Inc.
Packit a07778
 *
Packit a07778
 * This library is free software; you can redistribute it and/or
Packit a07778
 * modify it under the terms of the GNU Lesser General Public
Packit a07778
 * License as published by the Free Software Foundation; either
Packit a07778
 * version 2.1 of the License, or (at your option) any later version.
Packit a07778
 *
Packit a07778
 * This library is distributed in the hope that it will be useful,
Packit a07778
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
Packit a07778
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
Packit a07778
 * Lesser General Public License for more details.
Packit a07778
 *
Packit a07778
 * You should have received a copy of the GNU Lesser General Public
Packit a07778
 * License along with this library. If not, see
Packit a07778
 * <http://www.gnu.org/licenses/>.
Packit a07778
 *
Packit a07778
 * Author: Daniel P. Berrange <berrange@redhat.com>
Packit a07778
 */
Packit a07778
Packit a07778
#include <config.h>
Packit a07778
Packit a07778
#include <libvirt/virterror.h>
Packit a07778
#include <string.h>
Packit a07778
Packit a07778
#include "libvirt-glib/libvirt-glib.h"
Packit a07778
#include "libvirt-gobject/libvirt-gobject.h"
Packit a07778
#include "libvirt-gobject-compat.h"
Packit a07778
#include "libvirt-gobject-storage-pool-private.h"
Packit a07778
Packit a07778
#define GVIR_STORAGE_POOL_GET_PRIVATE(obj)                         \
Packit a07778
        (G_TYPE_INSTANCE_GET_PRIVATE((obj), GVIR_TYPE_STORAGE_POOL, GVirStoragePoolPrivate))
Packit a07778
Packit a07778
struct _GVirStoragePoolPrivate
Packit a07778
{
Packit a07778
    GMutex *lock;
Packit a07778
    virStoragePoolPtr handle;
Packit a07778
Packit a07778
    GHashTable *volumes;
Packit a07778
    gchar uuid[VIR_UUID_STRING_BUFLEN];
Packit a07778
};
Packit a07778
Packit a07778
G_DEFINE_TYPE_WITH_PRIVATE(GVirStoragePool, gvir_storage_pool, G_TYPE_OBJECT);
Packit a07778
Packit a07778
Packit a07778
enum {
Packit a07778
    PROP_0,
Packit a07778
    PROP_HANDLE,
Packit a07778
};
Packit a07778
Packit a07778
Packit a07778
#define GVIR_STORAGE_POOL_ERROR gvir_storage_pool_error_quark()
Packit a07778
Packit a07778
Packit a07778
static GQuark
Packit a07778
gvir_storage_pool_error_quark(void)
Packit a07778
{
Packit a07778
    return g_quark_from_static_string("gvir-storage-pool");
Packit a07778
}
Packit a07778
Packit a07778
static void gvir_storage_pool_get_property(GObject *object,
Packit a07778
                                           guint prop_id,
Packit a07778
                                           GValue *value,
Packit a07778
                                           GParamSpec *pspec)
Packit a07778
{
Packit a07778
    GVirStoragePool *pool = GVIR_STORAGE_POOL(object);
Packit a07778
    GVirStoragePoolPrivate *priv = pool->priv;
Packit a07778
Packit a07778
    switch (prop_id) {
Packit a07778
    case PROP_HANDLE:
Packit a07778
        g_value_set_boxed(value, priv->handle);
Packit a07778
        break;
Packit a07778
Packit a07778
    default:
Packit a07778
        G_OBJECT_WARN_INVALID_PROPERTY_ID(object, prop_id, pspec);
Packit a07778
    }
Packit a07778
}
Packit a07778
Packit a07778
Packit a07778
static void gvir_storage_pool_set_property(GObject *object,
Packit a07778
                                           guint prop_id,
Packit a07778
                                           const GValue *value,
Packit a07778
                                           GParamSpec *pspec)
Packit a07778
{
Packit a07778
    GVirStoragePool *pool = GVIR_STORAGE_POOL(object);
Packit a07778
    GVirStoragePoolPrivate *priv = pool->priv;
Packit a07778
Packit a07778
    switch (prop_id) {
Packit a07778
    case PROP_HANDLE:
Packit a07778
        if (priv->handle)
Packit a07778
            virStoragePoolFree(priv->handle);
Packit a07778
        priv->handle = g_value_dup_boxed(value);
Packit a07778
        break;
Packit a07778
Packit a07778
    default:
Packit a07778
        G_OBJECT_WARN_INVALID_PROPERTY_ID(object, prop_id, pspec);
Packit a07778
    }
Packit a07778
}
Packit a07778
Packit a07778
Packit a07778
static void gvir_storage_pool_finalize(GObject *object)
Packit a07778
{
Packit a07778
    GVirStoragePool *pool = GVIR_STORAGE_POOL(object);
Packit a07778
    GVirStoragePoolPrivate *priv = pool->priv;
Packit a07778
Packit a07778
    if (priv->volumes) {
Packit a07778
        g_hash_table_unref(priv->volumes);
Packit a07778
        priv->volumes = NULL;
Packit a07778
    }
Packit a07778
Packit a07778
    virStoragePoolFree(priv->handle);
Packit a07778
Packit a07778
    g_mutex_free(priv->lock);
Packit a07778
Packit a07778
    G_OBJECT_CLASS(gvir_storage_pool_parent_class)->finalize(object);
Packit a07778
}
Packit a07778
Packit a07778
Packit a07778
static void gvir_storage_pool_constructed(GObject *object)
Packit a07778
{
Packit a07778
    GVirStoragePool *pool = GVIR_STORAGE_POOL(object);
Packit a07778
    GVirStoragePoolPrivate *priv = pool->priv;
Packit a07778
Packit a07778
    G_OBJECT_CLASS(gvir_storage_pool_parent_class)->constructed(object);
Packit a07778
Packit a07778
    /* xxx we may want to turn this into an initable */
Packit a07778
    if (virStoragePoolGetUUIDString(priv->handle, priv->uuid) < 0)
Packit a07778
        gvir_warning("Failed to get storage pool UUID on %p", priv->handle);
Packit a07778
}
Packit a07778
Packit a07778
Packit a07778
static void gvir_storage_pool_class_init(GVirStoragePoolClass *klass)
Packit a07778
{
Packit a07778
    GObjectClass *object_class = G_OBJECT_CLASS (klass);
Packit a07778
Packit a07778
    object_class->finalize = gvir_storage_pool_finalize;
Packit a07778
    object_class->get_property = gvir_storage_pool_get_property;
Packit a07778
    object_class->set_property = gvir_storage_pool_set_property;
Packit a07778
    object_class->constructed = gvir_storage_pool_constructed;
Packit a07778
Packit a07778
    g_object_class_install_property(object_class,
Packit a07778
                                    PROP_HANDLE,
Packit a07778
                                    g_param_spec_boxed("handle",
Packit a07778
                                                       "Handle",
Packit a07778
                                                       "The storage_pool handle",
Packit a07778
                                                       GVIR_TYPE_STORAGE_POOL_HANDLE,
Packit a07778
                                                       G_PARAM_READABLE |
Packit a07778
                                                       G_PARAM_WRITABLE |
Packit a07778
                                                       G_PARAM_CONSTRUCT_ONLY |
Packit a07778
                                                       G_PARAM_STATIC_STRINGS));
Packit a07778
}
Packit a07778
Packit a07778
Packit a07778
static void gvir_storage_pool_init(GVirStoragePool *pool)
Packit a07778
{
Packit a07778
    GVirStoragePoolPrivate *priv;
Packit a07778
Packit a07778
    priv = pool->priv = GVIR_STORAGE_POOL_GET_PRIVATE(pool);
Packit a07778
Packit a07778
    priv->lock = g_mutex_new();
Packit a07778
}
Packit a07778
Packit a07778
typedef struct virStoragePool GVirStoragePoolHandle;
Packit a07778
Packit a07778
static GVirStoragePoolHandle*
Packit a07778
gvir_storage_pool_handle_copy(GVirStoragePoolHandle *src)
Packit a07778
{
Packit a07778
    virStoragePoolRef((virStoragePoolPtr)src);
Packit a07778
    return src;
Packit a07778
}
Packit a07778
Packit a07778
static void
Packit a07778
gvir_storage_pool_handle_free(GVirStoragePoolHandle *src)
Packit a07778
{
Packit a07778
    virStoragePoolFree((virStoragePoolPtr)src);
Packit a07778
}
Packit a07778
Packit a07778
G_DEFINE_BOXED_TYPE(GVirStoragePoolHandle, gvir_storage_pool_handle,
Packit a07778
                    gvir_storage_pool_handle_copy, gvir_storage_pool_handle_free)
Packit a07778
Packit a07778
static GVirStoragePoolInfo *
Packit a07778
gvir_storage_pool_info_copy(GVirStoragePoolInfo *info)
Packit a07778
{
Packit a07778
    return g_slice_dup(GVirStoragePoolInfo, info);
Packit a07778
}
Packit a07778
Packit a07778
static void
Packit a07778
gvir_storage_pool_info_free(GVirStoragePoolInfo *info)
Packit a07778
{
Packit a07778
    g_slice_free(GVirStoragePoolInfo, info);
Packit a07778
}
Packit a07778
Packit a07778
G_DEFINE_BOXED_TYPE(GVirStoragePoolInfo, gvir_storage_pool_info,
Packit a07778
                    gvir_storage_pool_info_copy, gvir_storage_pool_info_free)
Packit a07778
Packit a07778
const gchar *gvir_storage_pool_get_name(GVirStoragePool *pool)
Packit a07778
{
Packit a07778
    const char *name;
Packit a07778
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), NULL);
Packit a07778
Packit a07778
    if (!(name = virStoragePoolGetName(pool->priv->handle)))
Packit a07778
        gvir_warning("Failed to get storage_pool name on %p", pool->priv->handle);
Packit a07778
Packit a07778
    return name;
Packit a07778
}
Packit a07778
Packit a07778
Packit a07778
const gchar *gvir_storage_pool_get_uuid(GVirStoragePool *pool)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), NULL);
Packit a07778
Packit a07778
    return pool->priv->uuid;
Packit a07778
}
Packit a07778
Packit a07778
Packit a07778
gboolean gvir_storage_pool_get_active(GVirStoragePool *pool)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
Packit a07778
    return virStoragePoolIsActive(pool->priv->handle);
Packit a07778
}
Packit a07778
Packit a07778
Packit a07778
gboolean gvir_storage_pool_get_persistent(GVirStoragePool *pool)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
Packit a07778
    return virStoragePoolIsPersistent(pool->priv->handle);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_get_config:
Packit a07778
 * @pool: the storage_pool
Packit a07778
 * @flags: the flags
Packit a07778
 * @err: Place-holder for possible errors
Packit a07778
 *
Packit a07778
 * Returns: (transfer full): the config. The returned object should be
Packit a07778
 * unreffed with g_object_unref() when no longer needed.
Packit a07778
 */
Packit a07778
GVirConfigStoragePool *gvir_storage_pool_get_config(GVirStoragePool *pool,
Packit a07778
                                                    guint flags,
Packit a07778
                                                    GError **err)
Packit a07778
{
Packit a07778
    GVirStoragePoolPrivate *priv;
Packit a07778
    gchar *xml;
Packit a07778
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), NULL);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, NULL);
Packit a07778
Packit a07778
    priv = pool->priv;
Packit a07778
    if (!(xml = virStoragePoolGetXMLDesc(priv->handle, flags))) {
Packit a07778
        gvir_set_error_literal(err, GVIR_STORAGE_POOL_ERROR,
Packit a07778
                               0,
Packit a07778
                               "Unable to get storage_pool XML config");
Packit a07778
        return NULL;
Packit a07778
    }
Packit a07778
Packit a07778
    GVirConfigStoragePool *conf = gvir_config_storage_pool_new_from_xml(xml, err);
Packit a07778
Packit a07778
    free(xml);
Packit a07778
    return conf;
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_get_info:
Packit a07778
 * @pool: the storage_pool
Packit a07778
 * @err: Place-holder for possible errors
Packit a07778
 *
Packit a07778
 * Returns: (transfer full): the info. The returned pointer should be
Packit a07778
 * freed using #g_boxed_free() when no longer needed.
Packit a07778
 */
Packit a07778
GVirStoragePoolInfo *gvir_storage_pool_get_info(GVirStoragePool *pool,
Packit a07778
                                                GError **err)
Packit a07778
{
Packit a07778
    GVirStoragePoolPrivate *priv;
Packit a07778
    virStoragePoolInfo info;
Packit a07778
    GVirStoragePoolInfo *ret;
Packit a07778
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), NULL);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, NULL);
Packit a07778
Packit a07778
    priv = pool->priv;
Packit a07778
    if (virStoragePoolGetInfo(priv->handle, &info) < 0) {
Packit a07778
        if (err)
Packit a07778
            *err = gvir_error_new_literal(GVIR_STORAGE_POOL_ERROR,
Packit a07778
                                          0,
Packit a07778
                                          "Unable to get storage pool info");
Packit a07778
        return NULL;
Packit a07778
    }
Packit a07778
Packit a07778
    ret = g_slice_new(GVirStoragePoolInfo);
Packit a07778
    ret->state = info.state;
Packit a07778
    ret->capacity = info.capacity;
Packit a07778
    ret->allocation = info.allocation;
Packit a07778
    ret->available = info.available;
Packit a07778
Packit a07778
    return ret;
Packit a07778
}
Packit a07778
Packit a07778
typedef gint (* CountFunction) (virStoragePoolPtr vpool);
Packit a07778
typedef gint (* ListFunction) (virStoragePoolPtr vpool, gchar **lst, gint max);
Packit a07778
Packit a07778
static gchar ** fetch_list(virStoragePoolPtr vpool,
Packit a07778
                           const char *name,
Packit a07778
                           CountFunction count_func,
Packit a07778
                           ListFunction list_func,
Packit a07778
                           GCancellable *cancellable,
Packit a07778
                           gint *length,
Packit a07778
                           GError **err)
Packit a07778
{
Packit a07778
    gchar **lst = NULL;
Packit a07778
    gint n = 0;
Packit a07778
Packit a07778
    if ((n = count_func(vpool)) < 0) {
Packit a07778
        gvir_set_error(err, GVIR_STORAGE_POOL_ERROR,
Packit a07778
                       0,
Packit a07778
                       "Unable to count %s", name);
Packit a07778
        goto error;
Packit a07778
    }
Packit a07778
Packit a07778
    if (n) {
Packit a07778
        if (g_cancellable_set_error_if_cancelled(cancellable, err))
Packit a07778
            goto error;
Packit a07778
Packit a07778
        lst = g_new0(gchar *, n);
Packit a07778
        if ((n = list_func(vpool, lst, n)) < 0) {
Packit a07778
            gvir_set_error(err, GVIR_STORAGE_POOL_ERROR,
Packit a07778
                           0,
Packit a07778
                           "Unable to list %s %d", name, n);
Packit a07778
            goto error;
Packit a07778
        }
Packit a07778
    }
Packit a07778
Packit a07778
    *length = n;
Packit a07778
    return lst;
Packit a07778
Packit a07778
error:
Packit a07778
    g_free(lst);
Packit a07778
    return NULL;
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_refresh:
Packit a07778
 * @pool: the storage pool
Packit a07778
 * @cancellable: (allow-none)(transfer none): cancellation object
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_refresh(GVirStoragePool *pool,
Packit a07778
                                   GCancellable *cancellable,
Packit a07778
                                   GError **err)
Packit a07778
{
Packit a07778
    GVirStoragePoolPrivate *priv;
Packit a07778
    GHashTable *vol_hash;
Packit a07778
    gchar **volumes = NULL;
Packit a07778
    gint nvolumes = 0;
Packit a07778
    gboolean ret = FALSE;
Packit a07778
    gint i;
Packit a07778
    virStoragePoolPtr vpool = NULL;
Packit a07778
    GError *lerr = NULL;
Packit a07778
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail((cancellable == NULL) || G_IS_CANCELLABLE(cancellable),
Packit a07778
                         FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    priv = pool->priv;
Packit a07778
    vpool = priv->handle;
Packit a07778
Packit a07778
    if (virStoragePoolRefresh(vpool, 0) < 0) {
Packit a07778
        gvir_set_error_literal(err, GVIR_STORAGE_POOL_ERROR,
Packit a07778
                               0,
Packit a07778
                               "Unable to refresh storage pool");
Packit a07778
        goto cleanup;
Packit a07778
    }
Packit a07778
Packit a07778
    volumes = fetch_list(vpool,
Packit a07778
                         "Storage Volumes",
Packit a07778
                         virStoragePoolNumOfVolumes,
Packit a07778
                         virStoragePoolListVolumes,
Packit a07778
                         cancellable,
Packit a07778
                         &nvolumes,
Packit a07778
                         &lerr);
Packit a07778
    if (lerr) {
Packit a07778
        g_propagate_error(err, lerr);
Packit a07778
        lerr = NULL;
Packit a07778
        goto cleanup;
Packit a07778
    }
Packit a07778
Packit a07778
    if (g_cancellable_set_error_if_cancelled(cancellable, err))
Packit a07778
        goto cleanup;
Packit a07778
Packit a07778
    vol_hash = g_hash_table_new_full(g_str_hash,
Packit a07778
                                     g_str_equal,
Packit a07778
                                     g_free,
Packit a07778
                                     g_object_unref);
Packit a07778
Packit a07778
    for (i = 0 ; i < nvolumes ; i++) {
Packit a07778
        if (g_cancellable_set_error_if_cancelled(cancellable, err))
Packit a07778
            goto cleanup;
Packit a07778
Packit a07778
        virStorageVolPtr vvolume;
Packit a07778
        GVirStorageVol *volume;
Packit a07778
Packit a07778
        vvolume = virStorageVolLookupByName(vpool, volumes[i]);
Packit a07778
        if (!vvolume)
Packit a07778
            continue;
Packit a07778
Packit a07778
        volume = GVIR_STORAGE_VOL(g_object_new(GVIR_TYPE_STORAGE_VOL,
Packit a07778
                                               "handle", vvolume,
Packit a07778
                                               "pool", pool,
Packit a07778
                                               NULL));
Packit a07778
        virStorageVolFree(vvolume);
Packit a07778
        g_hash_table_insert(vol_hash, g_strdup(volumes[i]), volume);
Packit a07778
    }
Packit a07778
Packit a07778
    g_mutex_lock(priv->lock);
Packit a07778
    if (priv->volumes)
Packit a07778
        g_hash_table_unref(priv->volumes);
Packit a07778
    priv->volumes = vol_hash;
Packit a07778
    g_mutex_unlock(priv->lock);
Packit a07778
Packit a07778
    ret = TRUE;
Packit a07778
Packit a07778
cleanup:
Packit a07778
    for (i = 0 ; i < nvolumes ; i++)
Packit a07778
        g_free(volumes[i]);
Packit a07778
    g_free(volumes);
Packit a07778
    return ret;
Packit a07778
}
Packit a07778
Packit a07778
static void
Packit a07778
gvir_storage_pool_refresh_helper(GTask *task,
Packit a07778
                                 gpointer source_object,
Packit a07778
                                 gpointer task_data G_GNUC_UNUSED,
Packit a07778
                                 GCancellable *cancellable)
Packit a07778
{
Packit a07778
    GVirStoragePool *pool = GVIR_STORAGE_POOL(source_object);
Packit a07778
    GError *err = NULL;
Packit a07778
Packit a07778
    if (!gvir_storage_pool_refresh(pool, cancellable, &err))
Packit a07778
        g_task_return_error(task, err);
Packit a07778
    else
Packit a07778
        g_task_return_boolean(task, TRUE);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_refresh_async:
Packit a07778
 * @pool: the storage pool
Packit a07778
 * @cancellable: (allow-none)(transfer none): cancellation object
Packit a07778
 * @callback: (scope async): completion callback
Packit a07778
 * @user_data: (closure): opaque data for callback
Packit a07778
 */
Packit a07778
void gvir_storage_pool_refresh_async(GVirStoragePool *pool,
Packit a07778
                                     GCancellable *cancellable,
Packit a07778
                                     GAsyncReadyCallback callback,
Packit a07778
                                     gpointer user_data)
Packit a07778
{
Packit a07778
    GTask *task;
Packit a07778
Packit a07778
    g_return_if_fail(GVIR_IS_STORAGE_POOL(pool));
Packit a07778
    g_return_if_fail((cancellable == NULL) || G_IS_CANCELLABLE(cancellable));
Packit a07778
Packit a07778
    task = g_task_new(G_OBJECT(pool),
Packit a07778
                      cancellable,
Packit a07778
                      callback,
Packit a07778
                      user_data);
Packit a07778
    g_task_run_in_thread(task, gvir_storage_pool_refresh_helper);
Packit a07778
    g_object_unref(task);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_refresh_finish:
Packit a07778
 * @pool: the storage pool
Packit a07778
 * @result: (transfer none): async method result
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_refresh_finish(GVirStoragePool *pool,
Packit a07778
                                          GAsyncResult *result,
Packit a07778
                                          GError **err)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(g_task_is_valid(result, pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    return g_task_propagate_boolean(G_TASK(result), err);
Packit a07778
}
Packit a07778
Packit a07778
static void gvir_storage_vol_ref(gpointer obj, gpointer ignore G_GNUC_UNUSED)
Packit a07778
{
Packit a07778
    g_object_ref(obj);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_get_volumes:
Packit a07778
 * @pool: the storage pool
Packit a07778
 *
Packit a07778
 * Return value: (element-type LibvirtGObject.StorageVol) (transfer full):
Packit a07778
 * List of #GVirStorageVol.  The returned list should be freed with
Packit a07778
 * g_list_free(), after its elements have been unreffed with
Packit a07778
 * g_object_unref().
Packit a07778
 */
Packit a07778
GList *gvir_storage_pool_get_volumes(GVirStoragePool *pool)
Packit a07778
{
Packit a07778
    GVirStoragePoolPrivate *priv;
Packit a07778
    GList *volumes = NULL;
Packit a07778
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), NULL);
Packit a07778
Packit a07778
    priv = pool->priv;
Packit a07778
    g_mutex_lock(priv->lock);
Packit a07778
    if (priv->volumes != NULL) {
Packit a07778
        volumes = g_hash_table_get_values(priv->volumes);
Packit a07778
        g_list_foreach(volumes, gvir_storage_vol_ref, NULL);
Packit a07778
    } else {
Packit a07778
        g_warn_if_reached();
Packit a07778
    }
Packit a07778
    g_mutex_unlock(priv->lock);
Packit a07778
Packit a07778
    return volumes;
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_get_volume:
Packit a07778
 * @pool: the storage pool
Packit a07778
 * @name: Name of the requested storage volume
Packit a07778
 *
Packit a07778
 * Return value: (transfer full): the #GVirStorageVol, or NULL. The
Packit a07778
 * returned object should be unreffed with g_object_unref() when no longer
Packit a07778
 * needed.
Packit a07778
 */
Packit a07778
GVirStorageVol *gvir_storage_pool_get_volume(GVirStoragePool *pool,
Packit a07778
                                             const gchar *name)
Packit a07778
{
Packit a07778
    GVirStoragePoolPrivate *priv;
Packit a07778
    GVirStorageVol *volume;
Packit a07778
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), NULL);
Packit a07778
    g_return_val_if_fail(name != NULL, NULL);
Packit a07778
Packit a07778
    priv = pool->priv;
Packit a07778
    g_mutex_lock(priv->lock);
Packit a07778
    if (priv->volumes != NULL) {
Packit a07778
        volume = g_hash_table_lookup(priv->volumes, name);
Packit a07778
        if (volume)
Packit a07778
            g_object_ref(volume);
Packit a07778
    } else {
Packit a07778
        g_warn_if_reached();
Packit a07778
        volume = NULL;
Packit a07778
    }
Packit a07778
    g_mutex_unlock(priv->lock);
Packit a07778
Packit a07778
    return volume;
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_create_volume:
Packit a07778
 * @pool: the storage pool in which to create the volume
Packit a07778
 * @conf: the configuration for the new volume
Packit a07778
 * @err: Place-holder for possible errors
Packit a07778
 *
Packit a07778
 * Returns: (transfer full): the newly created volume. The returned object
Packit a07778
 * should be unreffed with g_object_unref() when no longer needed.
Packit a07778
 */
Packit a07778
GVirStorageVol *gvir_storage_pool_create_volume
Packit a07778
                                (GVirStoragePool *pool,
Packit a07778
                                 GVirConfigStorageVol *conf,
Packit a07778
                                 GError **err)
Packit a07778
{
Packit a07778
    const gchar *xml;
Packit a07778
    virStorageVolPtr handle;
Packit a07778
    GVirStoragePoolPrivate *priv;
Packit a07778
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), NULL);
Packit a07778
    g_return_val_if_fail(GVIR_CONFIG_IS_STORAGE_VOL(conf), NULL);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, NULL);
Packit a07778
Packit a07778
    xml = gvir_config_object_to_xml(GVIR_CONFIG_OBJECT(conf));
Packit a07778
Packit a07778
    g_return_val_if_fail(xml != NULL, NULL);
Packit a07778
Packit a07778
    priv = pool->priv;
Packit a07778
    if (!(handle = virStorageVolCreateXML(priv->handle, xml, 0))) {
Packit a07778
        gvir_set_error_literal(err, GVIR_STORAGE_POOL_ERROR,
Packit a07778
                               0,
Packit a07778
                               "Failed to create volume");
Packit a07778
        return NULL;
Packit a07778
    }
Packit a07778
Packit a07778
    GVirStorageVol *volume;
Packit a07778
    const char *name;
Packit a07778
Packit a07778
    volume = GVIR_STORAGE_VOL(g_object_new(GVIR_TYPE_STORAGE_VOL,
Packit a07778
                                           "handle", handle,
Packit a07778
                                           "pool", pool,
Packit a07778
                                           NULL));
Packit a07778
    name = gvir_storage_vol_get_name(volume);
Packit a07778
    if (name == NULL) {
Packit a07778
        g_object_unref(G_OBJECT(volume));
Packit a07778
        return NULL;
Packit a07778
    }
Packit a07778
Packit a07778
    g_mutex_lock(priv->lock);
Packit a07778
    if (priv->volumes != NULL) {
Packit a07778
        g_hash_table_insert(priv->volumes, g_strdup(name), volume);
Packit a07778
    } else {
Packit a07778
        g_warn_if_reached();
Packit a07778
        g_object_unref(G_OBJECT(volume));
Packit a07778
        g_mutex_unlock(priv->lock);
Packit a07778
        return NULL;
Packit a07778
    }
Packit a07778
    g_mutex_unlock(priv->lock);
Packit a07778
Packit a07778
    return g_object_ref(volume);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_build:
Packit a07778
 * @pool: the storage pool to build
Packit a07778
 * @flags:  the flags
Packit a07778
 * @err: return location for any #GError
Packit a07778
 *
Packit a07778
 * Return value: #True on success, #False otherwise.
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_build (GVirStoragePool *pool,
Packit a07778
                                  guint flags,
Packit a07778
                                  GError **err)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    if (virStoragePoolBuild(pool->priv->handle, flags)) {
Packit a07778
        gvir_set_error_literal(err, GVIR_STORAGE_POOL_ERROR,
Packit a07778
                               0,
Packit a07778
                               "Failed to build storage pool");
Packit a07778
        return FALSE;
Packit a07778
    }
Packit a07778
Packit a07778
    return TRUE;
Packit a07778
}
Packit a07778
Packit a07778
static void
Packit a07778
gvir_storage_pool_build_helper(GTask *task,
Packit a07778
                               gpointer source_object,
Packit a07778
                               gpointer task_data,
Packit a07778
                               GCancellable *cancellable G_GNUC_UNUSED)
Packit a07778
{
Packit a07778
    GVirStoragePool *pool = GVIR_STORAGE_POOL(source_object);
Packit a07778
    guint flags = GPOINTER_TO_UINT(task_data);
Packit a07778
    GError *err = NULL;
Packit a07778
Packit a07778
    if (!gvir_storage_pool_build(pool, flags, &err))
Packit a07778
        g_task_return_error(task, err);
Packit a07778
    else
Packit a07778
        g_task_return_boolean(task, TRUE);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_build_async:
Packit a07778
 * @pool: the storage pool to build
Packit a07778
 * @flags:  the flags
Packit a07778
 * @cancellable: (allow-none)(transfer none): cancellation object
Packit a07778
 * @callback: (scope async): completion callback
Packit a07778
 * @user_data: (closure): opaque data for callback
Packit a07778
 */
Packit a07778
void gvir_storage_pool_build_async (GVirStoragePool *pool,
Packit a07778
                                    guint flags,
Packit a07778
                                    GCancellable *cancellable,
Packit a07778
                                    GAsyncReadyCallback callback,
Packit a07778
                                    gpointer user_data)
Packit a07778
{
Packit a07778
    GTask *task;
Packit a07778
Packit a07778
    g_return_if_fail(GVIR_IS_STORAGE_POOL(pool));
Packit a07778
    g_return_if_fail((cancellable == NULL) || G_IS_CANCELLABLE(cancellable));
Packit a07778
Packit a07778
    task = g_task_new(G_OBJECT(pool),
Packit a07778
                      cancellable,
Packit a07778
                      callback,
Packit a07778
                      user_data);
Packit a07778
    g_task_set_task_data(task, GUINT_TO_POINTER(flags), NULL);
Packit a07778
    g_task_run_in_thread(task, gvir_storage_pool_build_helper);
Packit a07778
    g_object_unref(task);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_build_finish:
Packit a07778
 * @pool: the storage pool to build
Packit a07778
 * @result: (transfer none): async method result
Packit a07778
 * @err: return location for any #GError
Packit a07778
 *
Packit a07778
 * Return value: #True on success, #False otherwise.
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_build_finish(GVirStoragePool *pool,
Packit a07778
                                        GAsyncResult *result,
Packit a07778
                                        GError **err)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(g_task_is_valid(result, pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    return g_task_propagate_boolean(G_TASK(result), err);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_undefine:
Packit a07778
 * @pool: the storage pool to undefine
Packit a07778
 * @err: return location for any #GError
Packit a07778
 *
Packit a07778
 * Return value: #True on success, #False otherwise.
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_undefine (GVirStoragePool *pool,
Packit a07778
                                     GError **err)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    if (virStoragePoolUndefine(pool->priv->handle)) {
Packit a07778
        gvir_set_error_literal(err, GVIR_STORAGE_POOL_ERROR,
Packit a07778
                               0,
Packit a07778
                               "Failed to undefine storage pool");
Packit a07778
        return FALSE;
Packit a07778
    }
Packit a07778
Packit a07778
    return TRUE;
Packit a07778
}
Packit a07778
Packit a07778
static void
Packit a07778
gvir_storage_pool_undefine_helper(GTask *task,
Packit a07778
                                  gpointer source_object,
Packit a07778
                                  gpointer task_data G_GNUC_UNUSED,
Packit a07778
                                  GCancellable *cancellable G_GNUC_UNUSED)
Packit a07778
{
Packit a07778
    GVirStoragePool *pool = GVIR_STORAGE_POOL(source_object);
Packit a07778
    GError *err = NULL;
Packit a07778
Packit a07778
    if (!gvir_storage_pool_undefine(pool, &err))
Packit a07778
        g_task_return_error(task, err);
Packit a07778
    else
Packit a07778
        g_task_return_boolean(task, TRUE);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_undefine_async:
Packit a07778
 * @pool: the storage pool to undefine
Packit a07778
 * @cancellable: (allow-none)(transfer none): cancellation object
Packit a07778
 * @callback: (scope async): completion callback
Packit a07778
 * @user_data: (closure): opaque data for callback
Packit a07778
 */
Packit a07778
void gvir_storage_pool_undefine_async (GVirStoragePool *pool,
Packit a07778
                                       GCancellable *cancellable,
Packit a07778
                                       GAsyncReadyCallback callback,
Packit a07778
                                       gpointer user_data)
Packit a07778
{
Packit a07778
    GTask *task;
Packit a07778
Packit a07778
    g_return_if_fail(GVIR_IS_STORAGE_POOL(pool));
Packit a07778
    g_return_if_fail((cancellable == NULL) || G_IS_CANCELLABLE(cancellable));
Packit a07778
Packit a07778
    task = g_task_new(G_OBJECT(pool),
Packit a07778
                      cancellable,
Packit a07778
                      callback,
Packit a07778
                      user_data);
Packit a07778
    g_task_run_in_thread(task, gvir_storage_pool_undefine_helper);
Packit a07778
    g_object_unref(task);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_undefine_finish:
Packit a07778
 * @pool: the storage pool to undefine
Packit a07778
 * @result: (transfer none): async method result
Packit a07778
 * @err: return location for any #GError
Packit a07778
 *
Packit a07778
 * Return value: #True on success, #False otherwise.
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_undefine_finish(GVirStoragePool *pool,
Packit a07778
                                           GAsyncResult *result,
Packit a07778
                                           GError **err)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(g_task_is_valid(result, pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    return g_task_propagate_boolean(G_TASK(result), err);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_start:
Packit a07778
 * @pool: the storage pool to start
Packit a07778
 * @flags:  the flags
Packit a07778
 * @err: return location for any #GError
Packit a07778
 *
Packit a07778
 * Return value: #True on success, #False otherwise.
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_start (GVirStoragePool *pool,
Packit a07778
                                  guint flags,
Packit a07778
                                  GError **err)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    if (virStoragePoolCreate(pool->priv->handle, flags)) {
Packit a07778
        gvir_set_error_literal(err, GVIR_STORAGE_POOL_ERROR,
Packit a07778
                               0,
Packit a07778
                               "Failed to start storage pool");
Packit a07778
        return FALSE;
Packit a07778
    }
Packit a07778
Packit a07778
    return TRUE;
Packit a07778
}
Packit a07778
Packit a07778
static void
Packit a07778
gvir_storage_pool_start_helper(GTask *task,
Packit a07778
                               gpointer source_object,
Packit a07778
                               gpointer task_data,
Packit a07778
                               GCancellable *cancellable G_GNUC_UNUSED)
Packit a07778
{
Packit a07778
    GVirStoragePool *pool = GVIR_STORAGE_POOL(source_object);
Packit a07778
    guint flags = GPOINTER_TO_UINT(task_data);
Packit a07778
    GError *err = NULL;
Packit a07778
Packit a07778
    if (!gvir_storage_pool_start(pool, flags, &err))
Packit a07778
        g_task_return_error(task, err);
Packit a07778
    else
Packit a07778
        g_task_return_boolean(task, TRUE);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_start_async:
Packit a07778
 * @pool: the storage pool to start
Packit a07778
 * @flags:  the flags
Packit a07778
 * @cancellable: (allow-none)(transfer none): cancellation object
Packit a07778
 * @callback: (scope async): completion callback
Packit a07778
 * @user_data: (closure): opaque data for callback
Packit a07778
 */
Packit a07778
void gvir_storage_pool_start_async (GVirStoragePool *pool,
Packit a07778
                                    guint flags,
Packit a07778
                                    GCancellable *cancellable,
Packit a07778
                                    GAsyncReadyCallback callback,
Packit a07778
                                    gpointer user_data)
Packit a07778
{
Packit a07778
    GTask *task;
Packit a07778
Packit a07778
    g_return_if_fail(GVIR_IS_STORAGE_POOL(pool));
Packit a07778
    g_return_if_fail((cancellable == NULL) || G_IS_CANCELLABLE(cancellable));
Packit a07778
Packit a07778
    task = g_task_new(G_OBJECT(pool),
Packit a07778
                      cancellable,
Packit a07778
                      callback,
Packit a07778
                      user_data);
Packit a07778
    g_task_set_task_data(task, GUINT_TO_POINTER(flags), NULL);
Packit a07778
    g_task_run_in_thread(task, gvir_storage_pool_start_helper);
Packit a07778
    g_object_unref(task);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_start_finish:
Packit a07778
 * @pool: the storage pool to start
Packit a07778
 * @result: (transfer none): async method result
Packit a07778
 * @err: return location for any #GError
Packit a07778
 *
Packit a07778
 * Return value: #True on success, #False otherwise.
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_start_finish(GVirStoragePool *pool,
Packit a07778
                                        GAsyncResult *result,
Packit a07778
                                        GError **err)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(g_task_is_valid(result, pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    return g_task_propagate_boolean(G_TASK(result), err);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_stop:
Packit a07778
 * @pool: the storage pool to stop
Packit a07778
 * @err: return location for any #GError
Packit a07778
 *
Packit a07778
 * Return value: #True on success, #False otherwise.
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_stop (GVirStoragePool *pool,
Packit a07778
                                 GError **err)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    if (virStoragePoolDestroy(pool->priv->handle)) {
Packit a07778
        gvir_set_error_literal(err, GVIR_STORAGE_POOL_ERROR,
Packit a07778
                               0,
Packit a07778
                               "Failed to stop storage pool");
Packit a07778
        return FALSE;
Packit a07778
    }
Packit a07778
Packit a07778
    return TRUE;
Packit a07778
}
Packit a07778
Packit a07778
static void
Packit a07778
gvir_storage_pool_stop_helper(GTask *task,
Packit a07778
                              gpointer source_object,
Packit a07778
                              gpointer task_data G_GNUC_UNUSED,
Packit a07778
                              GCancellable *cancellable G_GNUC_UNUSED)
Packit a07778
{
Packit a07778
    GVirStoragePool *pool = GVIR_STORAGE_POOL(source_object);
Packit a07778
    GError *err = NULL;
Packit a07778
Packit a07778
    if (!gvir_storage_pool_stop(pool, &err))
Packit a07778
        g_task_return_error(task, err);
Packit a07778
    else
Packit a07778
        g_task_return_boolean(task, TRUE);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_stop_async:
Packit a07778
 * @pool: the storage pool to stop
Packit a07778
 * @cancellable: (allow-none)(transfer none): cancellation object
Packit a07778
 * @callback: (scope async): completion callback
Packit a07778
 * @user_data: (closure): opaque data for callback
Packit a07778
 */
Packit a07778
void gvir_storage_pool_stop_async (GVirStoragePool *pool,
Packit a07778
                                   GCancellable *cancellable,
Packit a07778
                                   GAsyncReadyCallback callback,
Packit a07778
                                   gpointer user_data)
Packit a07778
{
Packit a07778
    GTask *task;
Packit a07778
Packit a07778
    g_return_if_fail(GVIR_IS_STORAGE_POOL(pool));
Packit a07778
    g_return_if_fail((cancellable == NULL) || G_IS_CANCELLABLE(cancellable));
Packit a07778
Packit a07778
    task = g_task_new(G_OBJECT(pool),
Packit a07778
                      cancellable,
Packit a07778
                      callback,
Packit a07778
                      user_data);
Packit a07778
    g_task_run_in_thread(task, gvir_storage_pool_stop_helper);
Packit a07778
    g_object_unref(task);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_stop_finish:
Packit a07778
 * @pool: the storage pool to stop
Packit a07778
 * @result: (transfer none): async method result
Packit a07778
 * @err: return location for any #GError
Packit a07778
 *
Packit a07778
 * Return value: #True on success, #False otherwise.
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_stop_finish(GVirStoragePool *pool,
Packit a07778
                                       GAsyncResult *result,
Packit a07778
                                       GError **err)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(g_task_is_valid(result, pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    return g_task_propagate_boolean(G_TASK(result), err);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_delete:
Packit a07778
 * @pool: the storage pool to delete
Packit a07778
 * @flags:  the flags
Packit a07778
 * @err: return location for any #GError
Packit a07778
 *
Packit a07778
 * Return value: #True on success, #False otherwise.
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_delete (GVirStoragePool *pool,
Packit a07778
                                   guint flags,
Packit a07778
                                   GError **err)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    if (virStoragePoolDelete(pool->priv->handle, flags)) {
Packit a07778
        gvir_set_error_literal(err, GVIR_STORAGE_POOL_ERROR,
Packit a07778
                               0,
Packit a07778
                               "Failed to delete storage pool");
Packit a07778
        return FALSE;
Packit a07778
    }
Packit a07778
Packit a07778
    return TRUE;
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_get_autostart:
Packit a07778
 * @pool: the storage pool
Packit a07778
 * @err: return location for any #GError
Packit a07778
 *
Packit a07778
 * Return value: #True if autostart is enabled, #False otherwise.
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_get_autostart(GVirStoragePool *pool,
Packit a07778
                                         GError **err)
Packit a07778
{
Packit a07778
    int ret;
Packit a07778
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    if (virStoragePoolGetAutostart(pool->priv->handle, &ret)) {
Packit a07778
        gvir_set_error_literal(err, GVIR_STORAGE_POOL_ERROR,
Packit a07778
                               0,
Packit a07778
                               "Failed to get autostart flag from storage pool");
Packit a07778
    }
Packit a07778
Packit a07778
    return !!ret;
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_set_autostart:
Packit a07778
 * @pool: the storage pool
Packit a07778
 * @autostart: Whether or not to autostart
Packit a07778
 * @err: return location for any #GError
Packit a07778
 *
Packit a07778
 * Sets whether or not storage pool @pool is started automatically on boot.
Packit a07778
 *
Packit a07778
 * Return value: #TRUE on success, #FALSE otherwise.
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_set_autostart(GVirStoragePool *pool,
Packit a07778
                                         gboolean autostart,
Packit a07778
                                         GError **err)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    if (virStoragePoolSetAutostart(pool->priv->handle, autostart)) {
Packit a07778
        gvir_set_error_literal(err, GVIR_STORAGE_POOL_ERROR,
Packit a07778
                               0,
Packit a07778
                               "Failed to set autostart flag on storage pool");
Packit a07778
        return FALSE;
Packit a07778
    }
Packit a07778
Packit a07778
    return TRUE;
Packit a07778
}
Packit a07778
Packit a07778
static void
Packit a07778
gvir_storage_pool_delete_helper(GTask *task,
Packit a07778
                                gpointer source_object,
Packit a07778
                                gpointer task_data,
Packit a07778
                                GCancellable *cancellable G_GNUC_UNUSED)
Packit a07778
{
Packit a07778
    GVirStoragePool *pool = GVIR_STORAGE_POOL(source_object);
Packit a07778
    guint flags = GPOINTER_TO_UINT(task_data);
Packit a07778
    GError *err = NULL;
Packit a07778
Packit a07778
    if (!gvir_storage_pool_delete(pool, flags, &err))
Packit a07778
        g_task_return_error(task, err);
Packit a07778
    else
Packit a07778
        g_task_return_boolean(task, TRUE);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_delete_async:
Packit a07778
 * @pool: the storage pool to delete
Packit a07778
 * @flags:  the flags
Packit a07778
 * @cancellable: (allow-none)(transfer none): cancellation object
Packit a07778
 * @callback: (scope async): completion callback
Packit a07778
 * @user_data: (closure): opaque data for callback
Packit a07778
 */
Packit a07778
void gvir_storage_pool_delete_async (GVirStoragePool *pool,
Packit a07778
                                     guint flags,
Packit a07778
                                     GCancellable *cancellable,
Packit a07778
                                     GAsyncReadyCallback callback,
Packit a07778
                                     gpointer user_data)
Packit a07778
{
Packit a07778
    GTask *task;
Packit a07778
Packit a07778
    g_return_if_fail(GVIR_IS_STORAGE_POOL(pool));
Packit a07778
    g_return_if_fail((cancellable == NULL) || G_IS_CANCELLABLE(cancellable));
Packit a07778
Packit a07778
    task = g_task_new(G_OBJECT(pool),
Packit a07778
                      cancellable,
Packit a07778
                      callback,
Packit a07778
                      user_data);
Packit a07778
    g_task_set_task_data(task, GUINT_TO_POINTER(flags), NULL);
Packit a07778
    g_task_run_in_thread(task, gvir_storage_pool_delete_helper);
Packit a07778
    g_object_unref(task);
Packit a07778
}
Packit a07778
Packit a07778
/**
Packit a07778
 * gvir_storage_pool_delete_finish:
Packit a07778
 * @pool: the storage pool to delete
Packit a07778
 * @result: (transfer none): async method result
Packit a07778
 * @err: return location for any #GError
Packit a07778
 *
Packit a07778
 * Return value: #True on success, #False otherwise.
Packit a07778
 */
Packit a07778
gboolean gvir_storage_pool_delete_finish(GVirStoragePool *pool,
Packit a07778
                                         GAsyncResult *result,
Packit a07778
                                         GError **err)
Packit a07778
{
Packit a07778
    g_return_val_if_fail(GVIR_IS_STORAGE_POOL(pool), FALSE);
Packit a07778
    g_return_val_if_fail(g_task_is_valid(result, pool), FALSE);
Packit a07778
    g_return_val_if_fail(err == NULL || *err == NULL, FALSE);
Packit a07778
Packit a07778
    return g_task_propagate_boolean(G_TASK(result), err);
Packit a07778
}
Packit a07778
Packit a07778
G_GNUC_INTERNAL void gvir_storage_pool_delete_vol(GVirStoragePool *pool,
Packit a07778
                                                  GVirStorageVol *volume)
Packit a07778
{
Packit a07778
    GVirStoragePoolPrivate *priv;
Packit a07778
Packit a07778
    g_return_if_fail(GVIR_IS_STORAGE_POOL(pool));
Packit a07778
    g_return_if_fail(GVIR_IS_STORAGE_VOL(volume));
Packit a07778
Packit a07778
    priv = pool->priv;
Packit a07778
    g_mutex_lock(priv->lock);
Packit a07778
    if (priv->volumes != NULL) {
Packit a07778
        const gchar *name = gvir_storage_vol_get_name(volume);
Packit a07778
        g_hash_table_remove(priv->volumes, name);
Packit a07778
    } else {
Packit a07778
        g_warn_if_reached();
Packit a07778
    }
Packit a07778
    g_mutex_unlock(priv->lock);
Packit a07778
}