gid_t group;
};
-static virLockManagerSanlockDriver *driver;
+static virLockManagerSanlockDriverPtr sanlockDriver;
struct _virLockManagerSanlockPrivate {
const char *vm_uri;
/*
* sanlock plugin for the libvirt virLockManager API
*/
-static int virLockManagerSanlockLoadConfig(const char *configFile)
+static int
+virLockManagerSanlockLoadConfig(virLockManagerSanlockDriverPtr driver,
+ const char *configFile)
{
virConfPtr conf;
int ret = -1;
/* How many times try adding a lockspace? */
#define LOCKSPACE_RETRIES 10
-static int virLockManagerSanlockSetupLockspace(void)
+static int
+virLockManagerSanlockSetupLockspace(virLockManagerSanlockDriverPtr driver)
{
int fd = -1;
struct stat st;
const char *configFile,
unsigned int flags)
{
+ virLockManagerSanlockDriverPtr driver;
+
VIR_DEBUG("version=%u configFile=%s flags=%x",
version, NULLSTR(configFile), flags);
virCheckFlags(0, -1);
- if (driver)
+ if (sanlockDriver)
return 0;
- if (VIR_ALLOC(driver) < 0)
+ if (VIR_ALLOC(sanlockDriver) < 0)
return -1;
+ driver = sanlockDriver;
+
driver->requireLeaseForDisks = true;
driver->hostID = 0;
driver->autoDiskLease = false;
goto error;
}
- if (virLockManagerSanlockLoadConfig(configFile) < 0)
+ if (virLockManagerSanlockLoadConfig(driver, configFile) < 0)
goto error;
if (driver->autoDiskLease && !driver->hostID) {
}
if (driver->autoDiskLease) {
- if (virLockManagerSanlockSetupLockspace() < 0)
+ if (virLockManagerSanlockSetupLockspace(driver) < -1)
goto error;
}
static int virLockManagerSanlockDeinit(void)
{
- if (!driver)
+ if (!sanlockDriver)
return 0;
- VIR_FREE(driver->autoDiskLeasePath);
- VIR_FREE(driver);
+ VIR_FREE(sanlockDriver->autoDiskLeasePath);
+ VIR_FREE(sanlockDriver);
return 0;
}
virCheckFlags(VIR_LOCK_MANAGER_NEW_STARTED, -1);
- if (!driver) {
+ if (!sanlockDriver) {
virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
_("Sanlock plugin is not initialized"));
return -1;
-static int virLockManagerSanlockAddDisk(virLockManagerPtr lock,
- const char *name,
- size_t nparams,
- virLockManagerParamPtr params ATTRIBUTE_UNUSED,
- bool shared)
+static int
+virLockManagerSanlockAddDisk(virLockManagerSanlockDriverPtr driver,
+ virLockManagerPtr lock,
+ const char *name,
+ size_t nparams,
+ virLockManagerParamPtr params ATTRIBUTE_UNUSED,
+ bool shared)
{
virLockManagerSanlockPrivatePtr priv = lock->privateData;
int ret = -1;
}
-static int virLockManagerSanlockCreateLease(struct sanlk_resource *res)
+static int
+virLockManagerSanlockCreateLease(virLockManagerSanlockDriverPtr driver,
+ struct sanlk_resource *res)
{
int fd = -1;
struct stat st;
virLockManagerParamPtr params,
unsigned int flags)
{
+ virLockManagerSanlockDriverPtr driver = sanlockDriver;
virLockManagerSanlockPrivatePtr priv = lock->privateData;
virCheckFlags(VIR_LOCK_MANAGER_RESOURCE_READONLY |
switch (type) {
case VIR_LOCK_MANAGER_RESOURCE_TYPE_DISK:
if (driver->autoDiskLease) {
- if (virLockManagerSanlockAddDisk(lock, name, nparams, params,
+ if (virLockManagerSanlockAddDisk(driver, lock, name, nparams, params,
!!(flags & VIR_LOCK_MANAGER_RESOURCE_SHARED)) < 0)
return -1;
- if (virLockManagerSanlockCreateLease(priv->res_args[priv->res_count-1]) < 0)
+ if (virLockManagerSanlockCreateLease(driver,
+ priv->res_args[priv->res_count-1]) < 0)
return -1;
} else {
if (!(flags & (VIR_LOCK_MANAGER_RESOURCE_SHARED |
virDomainLockFailureAction action,
int *fd)
{
+ virLockManagerSanlockDriverPtr driver = sanlockDriver;
virLockManagerSanlockPrivatePtr priv = lock->privateData;
struct sanlk_options *opt = NULL;
struct sanlk_resource **res_args;