|
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 |
}
|