1
0
mirror of https://gitlab.com/libvirt/libvirt.git synced 2025-03-20 06:50:22 +03:00

libxl: Introduce libxlDriverConfig object

The libxlDriverPrivate struct contains an variety of data with
varying access needs. Similar to the QEMU and LXC drivers,
move all the static config data into a dedicated libxlDriverConfig
object. The only locking requirement is to hold the driver lock
while obtaining an instance of libxlDriverConfig. Once a reference
is held on the config object, it can be used completely lockless
since it is immutable.
This commit is contained in:
Jim Fehlig 2013-08-30 14:52:14 -06:00
parent 4147587669
commit d9f19c30d0
3 changed files with 304 additions and 183 deletions

View File

@ -64,6 +64,41 @@ static const char *xen_cap_re = "(xen|hvm)-[[:digit:]]+\\.[[:digit:]]+-(x86_32|x
static regex_t xen_cap_rec; static regex_t xen_cap_rec;
static virClassPtr libxlDriverConfigClass;
static void libxlDriverConfigDispose(void *obj);
static int libxlConfigOnceInit(void)
{
if (!(libxlDriverConfigClass = virClassNew(virClassForObject(),
"libxlDriverConfig",
sizeof(libxlDriverConfig),
libxlDriverConfigDispose)))
return -1;
return 0;
}
VIR_ONCE_GLOBAL_INIT(libxlConfig)
static void
libxlDriverConfigDispose(void *obj)
{
libxlDriverConfigPtr cfg = obj;
virObjectUnref(cfg->caps);
libxl_ctx_free(cfg->ctx);
xtl_logger_destroy(cfg->logger);
if (cfg->logger_file)
VIR_FORCE_FCLOSE(cfg->logger_file);
VIR_FREE(cfg->configDir);
VIR_FREE(cfg->autostartDir);
VIR_FREE(cfg->logDir);
VIR_FREE(cfg->stateDir);
VIR_FREE(cfg->libDir);
VIR_FREE(cfg->saveDir);
}
static int static int
libxlCapsInitHost(libxl_ctx *ctx, virCapsPtr caps) libxlCapsInitHost(libxl_ctx *ctx, virCapsPtr caps)
{ {
@ -978,8 +1013,8 @@ error:
return -1; return -1;
} }
bool static bool
libxlGetAutoballoonConf(libxlDriverPrivatePtr driver) libxlGetAutoballoonConf(libxlDriverConfigPtr cfg)
{ {
regex_t regex; regex_t regex;
int ret; int ret;
@ -990,11 +1025,94 @@ libxlGetAutoballoonConf(libxlDriverPrivatePtr driver)
if (ret) if (ret)
return true; return true;
ret = regexec(&regex, driver->verInfo->commandline, 0, NULL, 0); ret = regexec(&regex, cfg->verInfo->commandline, 0, NULL, 0);
regfree(&regex); regfree(&regex);
return ret == REG_NOMATCH; return ret == REG_NOMATCH;
} }
libxlDriverConfigPtr
libxlDriverConfigNew(void)
{
libxlDriverConfigPtr cfg;
char *log_file = NULL;
char ebuf[1024];
unsigned int free_mem;
if (libxlConfigInitialize() < 0)
return NULL;
if (!(cfg = virObjectNew(libxlDriverConfigClass)))
return NULL;
if (VIR_STRDUP(cfg->configDir, LIBXL_CONFIG_DIR) < 0)
goto error;
if (VIR_STRDUP(cfg->autostartDir, LIBXL_AUTOSTART_DIR) < 0)
goto error;
if (VIR_STRDUP(cfg->logDir, LIBXL_LOG_DIR) < 0)
goto error;
if (VIR_STRDUP(cfg->stateDir, LIBXL_STATE_DIR) < 0)
goto error;
if (VIR_STRDUP(cfg->libDir, LIBXL_LIB_DIR) < 0)
goto error;
if (VIR_STRDUP(cfg->saveDir, LIBXL_SAVE_DIR) < 0)
goto error;
if (virAsprintf(&log_file, "%s/libxl-driver.log", cfg->logDir) < 0)
goto error;
if ((cfg->logger_file = fopen(log_file, "a")) == NULL) {
VIR_ERROR(_("Failed to create log file '%s': %s"),
log_file, virStrerror(errno, ebuf, sizeof(ebuf)));
goto error;
}
VIR_FREE(log_file);
cfg->logger =
(xentoollog_logger *)xtl_createlogger_stdiostream(cfg->logger_file,
XTL_DEBUG, 0);
if (!cfg->logger) {
VIR_ERROR(_("cannot create logger for libxenlight, disabling driver"));
goto error;
}
if (libxl_ctx_alloc(&cfg->ctx, LIBXL_VERSION, 0, cfg->logger)) {
VIR_ERROR(_("cannot initialize libxenlight context, probably not "
"running in a Xen Dom0, disabling driver"));
goto error;
}
if ((cfg->verInfo = libxl_get_version_info(cfg->ctx)) == NULL) {
VIR_ERROR(_("cannot version information from libxenlight, "
"disabling driver"));
goto error;
}
cfg->version = (cfg->verInfo->xen_version_major * 1000000) +
(cfg->verInfo->xen_version_minor * 1000);
/* This will fill xenstore info about free and dom0 memory if missing,
* should be called before starting first domain */
if (libxl_get_free_memory(cfg->ctx, &free_mem)) {
VIR_ERROR(_("Unable to configure libxl's memory management parameters"));
goto error;
}
/* setup autoballoon */
cfg->autoballoon = libxlGetAutoballoonConf(cfg);
return cfg;
error:
VIR_FREE(log_file);
virObjectUnref(cfg);
return NULL;
}
libxlDriverConfigPtr
libxlDriverConfigGet(libxlDriverPrivatePtr driver)
{
return virObjectRef(driver->config);
}
virCapsPtr virCapsPtr
libxlMakeCapabilities(libxl_ctx *ctx) libxlMakeCapabilities(libxl_ctx *ctx)
{ {

View File

@ -51,10 +51,13 @@
typedef struct _libxlDriverPrivate libxlDriverPrivate; typedef struct _libxlDriverPrivate libxlDriverPrivate;
typedef libxlDriverPrivate *libxlDriverPrivatePtr; typedef libxlDriverPrivate *libxlDriverPrivatePtr;
struct _libxlDriverPrivate {
virMutex lock; typedef struct _libxlDriverConfig libxlDriverConfig;
virCapsPtr caps; typedef libxlDriverConfig *libxlDriverConfigPtr;
virDomainXMLOptionPtr xmlopt;
struct _libxlDriverConfig {
virObject parent;
const libxl_version_info *verInfo; const libxl_version_info *verInfo;
unsigned int version; unsigned int version;
@ -64,20 +67,12 @@ struct _libxlDriverPrivate {
/* libxl ctx for driver wide ops; getVersion, getNodeInfo, ... */ /* libxl ctx for driver wide ops; getVersion, getNodeInfo, ... */
libxl_ctx *ctx; libxl_ctx *ctx;
virPortAllocatorPtr reservedVNCPorts;
/* Controls automatic ballooning of domain0. If true, attempt to get /* Controls automatic ballooning of domain0. If true, attempt to get
* memory for new domains from domain0. */ * memory for new domains from domain0. */
bool autoballoon; bool autoballoon;
size_t nactive; /* Once created, caps are immutable */
virStateInhibitCallback inhibitCallback; virCapsPtr caps;
void *inhibitOpaque;
virDomainObjListPtr domains;
virDomainEventStatePtr domainEventState;
virSysinfoDefPtr hostsysinfo;
char *configDir; char *configDir;
char *autostartDir; char *autostartDir;
@ -87,6 +82,30 @@ struct _libxlDriverPrivate {
char *saveDir; char *saveDir;
}; };
struct _libxlDriverPrivate {
virMutex lock;
/* Require lock to get reference on 'config',
* then lockless thereafter */
libxlDriverConfigPtr config;
size_t nactive;
virStateInhibitCallback inhibitCallback;
void *inhibitOpaque;
virDomainObjListPtr domains;
virDomainXMLOptionPtr xmlopt;
virDomainEventStatePtr domainEventState;
virPortAllocatorPtr reservedVNCPorts;
virSysinfoDefPtr hostsysinfo;
};
typedef struct _libxlEventHookInfo libxlEventHookInfo; typedef struct _libxlEventHookInfo libxlEventHookInfo;
typedef libxlEventHookInfo *libxlEventHookInfoPtr; typedef libxlEventHookInfo *libxlEventHookInfoPtr;
@ -103,8 +122,11 @@ struct _libxlSavefileHeader {
uint32_t unused[10]; uint32_t unused[10];
}; };
bool libxlDriverConfigPtr
libxlGetAutoballoonConf(libxlDriverPrivatePtr driver); libxlDriverConfigNew(void);
libxlDriverConfigPtr
libxlDriverConfigGet(libxlDriverPrivatePtr driver);
virCapsPtr virCapsPtr
libxlMakeCapabilities(libxl_ctx *ctx); libxlMakeCapabilities(libxl_ctx *ctx);

View File

@ -126,35 +126,44 @@ libxlDoNodeGetInfo(libxlDriverPrivatePtr driver, virNodeInfoPtr info)
{ {
libxl_physinfo phy_info; libxl_physinfo phy_info;
virArch hostarch = virArchFromHost(); virArch hostarch = virArchFromHost();
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
int ret = -1;
if (libxl_get_physinfo(driver->ctx, &phy_info)) { if (libxl_get_physinfo(cfg->ctx, &phy_info)) {
virReportError(VIR_ERR_INTERNAL_ERROR, "%s", virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
_("libxl_get_physinfo_info failed")); _("libxl_get_physinfo_info failed"));
return -1; goto cleanup;
} }
if (virStrcpyStatic(info->model, virArchToString(hostarch)) == NULL) { if (virStrcpyStatic(info->model, virArchToString(hostarch)) == NULL) {
virReportError(VIR_ERR_INTERNAL_ERROR, virReportError(VIR_ERR_INTERNAL_ERROR,
_("machine type %s too big for destination"), _("machine type %s too big for destination"),
virArchToString(hostarch)); virArchToString(hostarch));
return -1; goto cleanup;
} }
info->memory = phy_info.total_pages * (driver->verInfo->pagesize / 1024); info->memory = phy_info.total_pages * (cfg->verInfo->pagesize / 1024);
info->cpus = phy_info.nr_cpus; info->cpus = phy_info.nr_cpus;
info->nodes = phy_info.nr_nodes; info->nodes = phy_info.nr_nodes;
info->cores = phy_info.cores_per_socket; info->cores = phy_info.cores_per_socket;
info->threads = phy_info.threads_per_core; info->threads = phy_info.threads_per_core;
info->sockets = 1; info->sockets = 1;
info->mhz = phy_info.cpu_khz / 1000; info->mhz = phy_info.cpu_khz / 1000;
return 0;
ret = 0;
cleanup:
virObjectUnref(cfg);
return ret;
} }
static char * static char *
libxlDomainManagedSavePath(libxlDriverPrivatePtr driver, virDomainObjPtr vm) { libxlDomainManagedSavePath(libxlDriverPrivatePtr driver, virDomainObjPtr vm) {
char *ret; char *ret;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
ignore_value(virAsprintf(&ret, "%s/%s.save", driver->saveDir, vm->def->name)); ignore_value(virAsprintf(&ret, "%s/%s.save", cfg->saveDir, vm->def->name));
virObjectUnref(cfg);
return ret; return ret;
} }
@ -168,6 +177,7 @@ libxlSaveImageOpen(libxlDriverPrivatePtr driver, const char *from,
virDomainDefPtr def = NULL; virDomainDefPtr def = NULL;
libxlSavefileHeader hdr; libxlSavefileHeader hdr;
char *xml = NULL; char *xml = NULL;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
if ((fd = virFileOpenAs(from, O_RDONLY, 0, -1, -1, 0)) < 0) { if ((fd = virFileOpenAs(from, O_RDONLY, 0, -1, -1, 0)) < 0) {
virReportSystemError(-fd, virReportSystemError(-fd,
@ -207,12 +217,13 @@ libxlSaveImageOpen(libxlDriverPrivatePtr driver, const char *from,
goto error; goto error;
} }
if (!(def = virDomainDefParseString(xml, driver->caps, driver->xmlopt, if (!(def = virDomainDefParseString(xml, cfg->caps, driver->xmlopt,
1 << VIR_DOMAIN_VIRT_XEN, 1 << VIR_DOMAIN_VIRT_XEN,
VIR_DOMAIN_XML_INACTIVE))) VIR_DOMAIN_XML_INACTIVE)))
goto error; goto error;
VIR_FREE(xml); VIR_FREE(xml);
virObjectUnref(cfg);
*ret_def = def; *ret_def = def;
*ret_hdr = hdr; *ret_hdr = hdr;
@ -221,6 +232,7 @@ libxlSaveImageOpen(libxlDriverPrivatePtr driver, const char *from,
error: error:
VIR_FREE(xml); VIR_FREE(xml);
virObjectUnref(cfg);
virDomainDefFree(def); virDomainDefFree(def);
VIR_FORCE_CLOSE(fd); VIR_FORCE_CLOSE(fd);
return -1; return -1;
@ -237,6 +249,7 @@ libxlVmCleanup(libxlDriverPrivatePtr driver,
virDomainShutoffReason reason) virDomainShutoffReason reason)
{ {
libxlDomainObjPrivatePtr priv = vm->privateData; libxlDomainObjPrivatePtr priv = vm->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
int vnc_port; int vnc_port;
char *file; char *file;
size_t i; size_t i;
@ -276,7 +289,7 @@ libxlVmCleanup(libxlDriverPrivatePtr driver,
vm->def->cputune.nvcpupin = 0; vm->def->cputune.nvcpupin = 0;
} }
if (virAsprintf(&file, "%s/%s.xml", driver->stateDir, vm->def->name) > 0) { if (virAsprintf(&file, "%s/%s.xml", cfg->stateDir, vm->def->name) > 0) {
if (unlink(file) < 0 && errno != ENOENT && errno != ENOTDIR) if (unlink(file) < 0 && errno != ENOENT && errno != ENOTDIR)
VIR_DEBUG("Failed to remove domain XML for %s", vm->def->name); VIR_DEBUG("Failed to remove domain XML for %s", vm->def->name);
VIR_FREE(file); VIR_FREE(file);
@ -290,6 +303,7 @@ libxlVmCleanup(libxlDriverPrivatePtr driver,
} }
libxlDomainObjRegisteredTimeoutsCleanup(priv); libxlDomainObjRegisteredTimeoutsCleanup(priv);
virObjectUnref(cfg);
} }
/* /*
@ -533,6 +547,7 @@ libxlVmStart(libxlDriverPrivatePtr driver, virDomainObjPtr vm,
char *managed_save_path = NULL; char *managed_save_path = NULL;
int managed_save_fd = -1; int managed_save_fd = -1;
libxlDomainObjPrivatePtr priv = vm->privateData; libxlDomainObjPrivatePtr priv = vm->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
if (libxlDomainObjPrivateInitCtx(vm) < 0) if (libxlDomainObjPrivateInitCtx(vm) < 0)
goto error; goto error;
@ -583,7 +598,7 @@ libxlVmStart(libxlDriverPrivatePtr driver, virDomainObjPtr vm,
if (libxlBuildDomainConfig(driver, vm, &d_config) < 0) if (libxlBuildDomainConfig(driver, vm, &d_config) < 0)
goto error; goto error;
if (driver->autoballoon && libxlFreeMem(priv, &d_config) < 0) { if (cfg->autoballoon && libxlFreeMem(priv, &d_config) < 0) {
virReportError(VIR_ERR_INTERNAL_ERROR, virReportError(VIR_ERR_INTERNAL_ERROR,
_("libxenlight failed to get free memory for domain '%s'"), _("libxenlight failed to get free memory for domain '%s'"),
d_config.c_info.name); d_config.c_info.name);
@ -636,7 +651,7 @@ libxlVmStart(libxlDriverPrivatePtr driver, virDomainObjPtr vm,
} }
if (virDomainSaveStatus(driver->xmlopt, driver->stateDir, vm) < 0) if (virDomainSaveStatus(driver->xmlopt, cfg->stateDir, vm) < 0)
goto error; goto error;
if (!driver->nactive && driver->inhibitCallback) if (!driver->nactive && driver->inhibitCallback)
@ -653,6 +668,7 @@ libxlVmStart(libxlDriverPrivatePtr driver, virDomainObjPtr vm,
libxl_domain_config_dispose(&d_config); libxl_domain_config_dispose(&d_config);
VIR_FREE(dom_xml); VIR_FREE(dom_xml);
VIR_FORCE_CLOSE(managed_save_fd); VIR_FORCE_CLOSE(managed_save_fd);
virObjectUnref(cfg);
return 0; return 0;
error: error:
@ -666,6 +682,7 @@ error:
VIR_FREE(managed_save_path); VIR_FREE(managed_save_path);
virDomainDefFree(def); virDomainDefFree(def);
VIR_FORCE_CLOSE(managed_save_fd); VIR_FORCE_CLOSE(managed_save_fd);
virObjectUnref(cfg);
return -1; return -1;
} }
@ -740,28 +757,14 @@ libxlStateCleanup(void)
if (!libxl_driver) if (!libxl_driver)
return -1; return -1;
libxlDriverLock(libxl_driver); virObjectUnref(libxl_driver->config);
virObjectUnref(libxl_driver->caps);
virObjectUnref(libxl_driver->xmlopt); virObjectUnref(libxl_driver->xmlopt);
virObjectUnref(libxl_driver->domains); virObjectUnref(libxl_driver->domains);
libxl_ctx_free(libxl_driver->ctx);
xtl_logger_destroy(libxl_driver->logger);
if (libxl_driver->logger_file)
VIR_FORCE_FCLOSE(libxl_driver->logger_file);
virObjectUnref(libxl_driver->reservedVNCPorts); virObjectUnref(libxl_driver->reservedVNCPorts);
VIR_FREE(libxl_driver->configDir);
VIR_FREE(libxl_driver->autostartDir);
VIR_FREE(libxl_driver->logDir);
VIR_FREE(libxl_driver->stateDir);
VIR_FREE(libxl_driver->libDir);
VIR_FREE(libxl_driver->saveDir);
virDomainEventStateFree(libxl_driver->domainEventState); virDomainEventStateFree(libxl_driver->domainEventState);
virSysinfoDefFree(libxl_driver->hostsysinfo); virSysinfoDefFree(libxl_driver->hostsysinfo);
libxlDriverUnlock(libxl_driver);
virMutexDestroy(&libxl_driver->lock); virMutexDestroy(&libxl_driver->lock);
VIR_FREE(libxl_driver); VIR_FREE(libxl_driver);
@ -807,10 +810,7 @@ libxlStateInitialize(bool privileged,
virStateInhibitCallback callback ATTRIBUTE_UNUSED, virStateInhibitCallback callback ATTRIBUTE_UNUSED,
void *opaque ATTRIBUTE_UNUSED) void *opaque ATTRIBUTE_UNUSED)
{ {
const libxl_version_info *ver_info; libxlDriverConfigPtr cfg;
char *log_file = NULL;
int ret = 0;
unsigned int free_mem;
char ebuf[1024]; char ebuf[1024];
if (!libxlDriverShouldLoad(privileged)) if (!libxlDriverShouldLoad(privileged))
@ -836,64 +836,39 @@ libxlStateInitialize(bool privileged,
if (!(libxl_driver->domains = virDomainObjListNew())) if (!(libxl_driver->domains = virDomainObjListNew()))
goto error; goto error;
if (VIR_STRDUP(libxl_driver->configDir, LIBXL_CONFIG_DIR) < 0) if (!(cfg = libxlDriverConfigNew()))
goto error; goto error;
if (VIR_STRDUP(libxl_driver->autostartDir, LIBXL_AUTOSTART_DIR) < 0) libxl_driver->config = cfg;
goto error; if (virFileMakePath(cfg->logDir) < 0) {
if (VIR_STRDUP(libxl_driver->logDir, LIBXL_LOG_DIR) < 0)
goto error;
if (VIR_STRDUP(libxl_driver->stateDir, LIBXL_STATE_DIR) < 0)
goto error;
if (VIR_STRDUP(libxl_driver->libDir, LIBXL_LIB_DIR) < 0)
goto error;
if (VIR_STRDUP(libxl_driver->saveDir, LIBXL_SAVE_DIR) < 0)
goto error;
if (virFileMakePath(libxl_driver->logDir) < 0) {
virReportError(VIR_ERR_INTERNAL_ERROR, virReportError(VIR_ERR_INTERNAL_ERROR,
_("failed to create log dir '%s': %s"), _("failed to create log dir '%s': %s"),
libxl_driver->logDir, cfg->logDir,
virStrerror(errno, ebuf, sizeof(ebuf))); virStrerror(errno, ebuf, sizeof(ebuf)));
goto error; goto error;
} }
if (virFileMakePath(libxl_driver->stateDir) < 0) { if (virFileMakePath(cfg->stateDir) < 0) {
virReportError(VIR_ERR_INTERNAL_ERROR, virReportError(VIR_ERR_INTERNAL_ERROR,
_("failed to create state dir '%s': %s"), _("failed to create state dir '%s': %s"),
libxl_driver->stateDir, cfg->stateDir,
virStrerror(errno, ebuf, sizeof(ebuf))); virStrerror(errno, ebuf, sizeof(ebuf)));
goto error; goto error;
} }
if (virFileMakePath(libxl_driver->libDir) < 0) { if (virFileMakePath(cfg->libDir) < 0) {
virReportError(VIR_ERR_INTERNAL_ERROR, virReportError(VIR_ERR_INTERNAL_ERROR,
_("failed to create lib dir '%s': %s"), _("failed to create lib dir '%s': %s"),
libxl_driver->libDir, cfg->libDir,
virStrerror(errno, ebuf, sizeof(ebuf))); virStrerror(errno, ebuf, sizeof(ebuf)));
goto error; goto error;
} }
if (virFileMakePath(libxl_driver->saveDir) < 0) { if (virFileMakePath(cfg->saveDir) < 0) {
virReportError(VIR_ERR_INTERNAL_ERROR, virReportError(VIR_ERR_INTERNAL_ERROR,
_("failed to create save dir '%s': %s"), _("failed to create save dir '%s': %s"),
libxl_driver->saveDir, cfg->saveDir,
virStrerror(errno, ebuf, sizeof(ebuf))); virStrerror(errno, ebuf, sizeof(ebuf)));
goto error; goto error;
} }
if (virAsprintf(&log_file, "%s/libxl-driver.log", libxl_driver->logDir) < 0)
goto error;
if ((libxl_driver->logger_file = fopen(log_file, "a")) == NULL) {
virReportSystemError(errno,
_("failed to create logfile %s"),
log_file);
goto error;
}
VIR_FREE(log_file);
/* read the host sysinfo */ /* read the host sysinfo */
if (privileged) if (privileged)
libxl_driver->hostsysinfo = virSysinfoRead(); libxl_driver->hostsysinfo = virSysinfoRead();
@ -902,34 +877,7 @@ libxlStateInitialize(bool privileged,
if (!libxl_driver->domainEventState) if (!libxl_driver->domainEventState)
goto error; goto error;
libxl_driver->logger = if ((cfg->caps = libxlMakeCapabilities(cfg->ctx)) == NULL) {
(xentoollog_logger *)xtl_createlogger_stdiostream(libxl_driver->logger_file, XTL_DEBUG, 0);
if (!libxl_driver->logger) {
virReportError(VIR_ERR_INTERNAL_ERROR,
"%s", _("failed to create logger for libxenlight"));
goto error;
}
if (libxl_ctx_alloc(&libxl_driver->ctx,
LIBXL_VERSION, 0,
libxl_driver->logger)) {
virReportError(VIR_ERR_INTERNAL_ERROR,
"%s", _("failed to initialize libxenlight context"));
goto error;
}
if ((ver_info = libxl_get_version_info(libxl_driver->ctx)) == NULL) {
virReportError(VIR_ERR_INTERNAL_ERROR,
"%s",
_("failed to get version information from libxenlight"));
goto error;
}
libxl_driver->verInfo = ver_info;
libxl_driver->version = (ver_info->xen_version_major * 1000000) +
(ver_info->xen_version_minor * 1000);
if ((libxl_driver->caps =
libxlMakeCapabilities(libxl_driver->ctx)) == NULL) {
virReportError(VIR_ERR_INTERNAL_ERROR, virReportError(VIR_ERR_INTERNAL_ERROR,
"%s", _("cannot create capabilities for libxenlight")); "%s", _("cannot create capabilities for libxenlight"));
goto error; goto error;
@ -940,25 +888,12 @@ libxlStateInitialize(bool privileged,
NULL))) NULL)))
goto error; goto error;
/* This will fill xenstore info about free and dom0 memory if missing,
* should be called before starting first domain */
if (libxl_get_free_memory(libxl_driver->ctx, &free_mem)) {
virReportError(VIR_ERR_INTERNAL_ERROR,
"%s",
_("Unable to configure libxl's memory management "
"parameters"));
goto error;
}
/* setup autoballoon */
libxl_driver->autoballoon = libxlGetAutoballoonConf(libxl_driver);
/* Load running domains first. */ /* Load running domains first. */
if (virDomainObjListLoadAllConfigs(libxl_driver->domains, if (virDomainObjListLoadAllConfigs(libxl_driver->domains,
libxl_driver->stateDir, cfg->stateDir,
libxl_driver->autostartDir, cfg->autostartDir,
1, 1,
libxl_driver->caps, cfg->caps,
libxl_driver->xmlopt, libxl_driver->xmlopt,
1 << VIR_DOMAIN_VIRT_XEN, 1 << VIR_DOMAIN_VIRT_XEN,
NULL, NULL) < 0) NULL, NULL) < 0)
@ -968,10 +903,10 @@ libxlStateInitialize(bool privileged,
/* Then inactive persistent configs */ /* Then inactive persistent configs */
if (virDomainObjListLoadAllConfigs(libxl_driver->domains, if (virDomainObjListLoadAllConfigs(libxl_driver->domains,
libxl_driver->configDir, cfg->configDir,
libxl_driver->autostartDir, cfg->autostartDir,
0, 0,
libxl_driver->caps, cfg->caps,
libxl_driver->xmlopt, libxl_driver->xmlopt,
1 << VIR_DOMAIN_VIRT_XEN, 1 << VIR_DOMAIN_VIRT_XEN,
NULL, NULL) < 0) NULL, NULL) < 0)
@ -985,12 +920,10 @@ libxlStateInitialize(bool privileged,
return 0; return 0;
error: error:
ret = -1;
VIR_FREE(log_file);
if (libxl_driver) if (libxl_driver)
libxlDriverUnlock(libxl_driver); libxlDriverUnlock(libxl_driver);
libxlStateCleanup(); libxlStateCleanup();
return ret; return -1;
} }
static void static void
@ -1008,15 +941,19 @@ libxlStateAutoStart(void)
static int static int
libxlStateReload(void) libxlStateReload(void)
{ {
libxlDriverConfigPtr cfg;
if (!libxl_driver) if (!libxl_driver)
return 0; return 0;
libxlDriverLock(libxl_driver); libxlDriverLock(libxl_driver);
cfg = libxlDriverConfigGet(libxl_driver);
virDomainObjListLoadAllConfigs(libxl_driver->domains, virDomainObjListLoadAllConfigs(libxl_driver->domains,
libxl_driver->configDir, cfg->configDir,
libxl_driver->autostartDir, cfg->autostartDir,
1, 1,
libxl_driver->caps, cfg->caps,
libxl_driver->xmlopt, libxl_driver->xmlopt,
1 << VIR_DOMAIN_VIRT_XEN, 1 << VIR_DOMAIN_VIRT_XEN,
NULL, libxl_driver); NULL, libxl_driver);
@ -1024,6 +961,7 @@ libxlStateReload(void)
virDomainObjListForEach(libxl_driver->domains, libxlAutostartDomain, virDomainObjListForEach(libxl_driver->domains, libxlAutostartDomain,
libxl_driver); libxl_driver);
virObjectUnref(cfg);
libxlDriverUnlock(libxl_driver); libxlDriverUnlock(libxl_driver);
return 0; return 0;
@ -1099,12 +1037,15 @@ static int
libxlConnectGetVersion(virConnectPtr conn, unsigned long *version) libxlConnectGetVersion(virConnectPtr conn, unsigned long *version)
{ {
libxlDriverPrivatePtr driver = conn->privateData; libxlDriverPrivatePtr driver = conn->privateData;
libxlDriverConfigPtr cfg;
if (virConnectGetVersionEnsureACL(conn) < 0) if (virConnectGetVersionEnsureACL(conn) < 0)
return 0; return 0;
libxlDriverLock(driver); libxlDriverLock(driver);
*version = driver->version; cfg = libxlDriverConfigGet(driver);
*version = cfg->version;
virObjectUnref(cfg);
libxlDriverUnlock(driver); libxlDriverUnlock(driver);
return 0; return 0;
} }
@ -1149,16 +1090,19 @@ libxlConnectGetMaxVcpus(virConnectPtr conn, const char *type ATTRIBUTE_UNUSED)
{ {
int ret; int ret;
libxlDriverPrivatePtr driver = conn->privateData; libxlDriverPrivatePtr driver = conn->privateData;
libxlDriverConfigPtr cfg;
if (virConnectGetMaxVcpusEnsureACL(conn) < 0) if (virConnectGetMaxVcpusEnsureACL(conn) < 0)
return -1; return -1;
ret = libxl_get_max_cpus(driver->ctx); cfg = libxlDriverConfigGet(driver);
ret = libxl_get_max_cpus(cfg->ctx);
/* libxl_get_max_cpus() will return 0 if there were any failures, /* libxl_get_max_cpus() will return 0 if there were any failures,
e.g. xc_physinfo() failing */ e.g. xc_physinfo() failing */
if (ret == 0) if (ret == 0)
return -1; ret = -1;
virObjectUnref(cfg);
return ret; return ret;
} }
@ -1176,15 +1120,18 @@ libxlConnectGetCapabilities(virConnectPtr conn)
{ {
libxlDriverPrivatePtr driver = conn->privateData; libxlDriverPrivatePtr driver = conn->privateData;
char *xml; char *xml;
libxlDriverConfigPtr cfg;
if (virConnectGetCapabilitiesEnsureACL(conn) < 0) if (virConnectGetCapabilitiesEnsureACL(conn) < 0)
return NULL; return NULL;
libxlDriverLock(driver); libxlDriverLock(driver);
if ((xml = virCapabilitiesFormatXML(driver->caps)) == NULL) cfg = libxlDriverConfigGet(driver);
if ((xml = virCapabilitiesFormatXML(cfg->caps)) == NULL)
virReportOOMError(); virReportOOMError();
libxlDriverUnlock(driver); libxlDriverUnlock(driver);
virObjectUnref(cfg);
return xml; return xml;
} }
@ -1230,11 +1177,12 @@ libxlDomainCreateXML(virConnectPtr conn, const char *xml,
virDomainDefPtr def; virDomainDefPtr def;
virDomainObjPtr vm = NULL; virDomainObjPtr vm = NULL;
virDomainPtr dom = NULL; virDomainPtr dom = NULL;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
virCheckFlags(VIR_DOMAIN_START_PAUSED, NULL); virCheckFlags(VIR_DOMAIN_START_PAUSED, NULL);
libxlDriverLock(driver); libxlDriverLock(driver);
if (!(def = virDomainDefParseString(xml, driver->caps, driver->xmlopt, if (!(def = virDomainDefParseString(xml, cfg->caps, driver->xmlopt,
1 << VIR_DOMAIN_VIRT_XEN, 1 << VIR_DOMAIN_VIRT_XEN,
VIR_DOMAIN_XML_INACTIVE))) VIR_DOMAIN_XML_INACTIVE)))
goto cleanup; goto cleanup;
@ -1265,6 +1213,7 @@ cleanup:
if (vm) if (vm)
virObjectUnlock(vm); virObjectUnlock(vm);
libxlDriverUnlock(driver); libxlDriverUnlock(driver);
virObjectUnref(cfg);
return dom; return dom;
} }
@ -1359,6 +1308,7 @@ static int
libxlDomainSuspend(virDomainPtr dom) libxlDomainSuspend(virDomainPtr dom)
{ {
libxlDriverPrivatePtr driver = dom->conn->privateData; libxlDriverPrivatePtr driver = dom->conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
virDomainObjPtr vm; virDomainObjPtr vm;
libxlDomainObjPrivatePtr priv; libxlDomainObjPrivatePtr priv;
virDomainEventPtr event = NULL; virDomainEventPtr event = NULL;
@ -1400,7 +1350,7 @@ libxlDomainSuspend(virDomainPtr dom)
VIR_DOMAIN_EVENT_SUSPENDED_PAUSED); VIR_DOMAIN_EVENT_SUSPENDED_PAUSED);
} }
if (virDomainSaveStatus(driver->xmlopt, driver->stateDir, vm) < 0) if (virDomainSaveStatus(driver->xmlopt, cfg->stateDir, vm) < 0)
goto cleanup; goto cleanup;
ret = 0; ret = 0;
@ -1413,6 +1363,7 @@ cleanup:
libxlDomainEventQueue(driver, event); libxlDomainEventQueue(driver, event);
libxlDriverUnlock(driver); libxlDriverUnlock(driver);
} }
virObjectUnref(cfg);
return ret; return ret;
} }
@ -1421,6 +1372,7 @@ static int
libxlDomainResume(virDomainPtr dom) libxlDomainResume(virDomainPtr dom)
{ {
libxlDriverPrivatePtr driver = dom->conn->privateData; libxlDriverPrivatePtr driver = dom->conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
virDomainObjPtr vm; virDomainObjPtr vm;
libxlDomainObjPrivatePtr priv; libxlDomainObjPrivatePtr priv;
virDomainEventPtr event = NULL; virDomainEventPtr event = NULL;
@ -1463,7 +1415,7 @@ libxlDomainResume(virDomainPtr dom)
VIR_DOMAIN_EVENT_RESUMED_UNPAUSED); VIR_DOMAIN_EVENT_RESUMED_UNPAUSED);
} }
if (virDomainSaveStatus(driver->xmlopt, driver->stateDir, vm) < 0) if (virDomainSaveStatus(driver->xmlopt, cfg->stateDir, vm) < 0)
goto cleanup; goto cleanup;
ret = 0; ret = 0;
@ -1476,6 +1428,7 @@ cleanup:
libxlDomainEventQueue(driver, event); libxlDomainEventQueue(driver, event);
libxlDriverUnlock(driver); libxlDriverUnlock(driver);
} }
virObjectUnref(cfg);
return ret; return ret;
} }
@ -1703,6 +1656,7 @@ libxlDomainSetMemoryFlags(virDomainPtr dom, unsigned long newmem,
unsigned int flags) unsigned int flags)
{ {
libxlDriverPrivatePtr driver = dom->conn->privateData; libxlDriverPrivatePtr driver = dom->conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
libxlDomainObjPrivatePtr priv; libxlDomainObjPrivatePtr priv;
virDomainObjPtr vm; virDomainObjPtr vm;
virDomainDefPtr persistentDef = NULL; virDomainDefPtr persistentDef = NULL;
@ -1752,7 +1706,7 @@ libxlDomainSetMemoryFlags(virDomainPtr dom, unsigned long newmem,
_("cannot change persistent config of a transient domain")); _("cannot change persistent config of a transient domain"));
goto cleanup; goto cleanup;
} }
if (!(persistentDef = virDomainObjGetPersistentDef(driver->caps, if (!(persistentDef = virDomainObjGetPersistentDef(cfg->caps,
driver->xmlopt, driver->xmlopt,
vm))) vm)))
goto cleanup; goto cleanup;
@ -1777,7 +1731,7 @@ libxlDomainSetMemoryFlags(virDomainPtr dom, unsigned long newmem,
persistentDef->mem.max_balloon = newmem; persistentDef->mem.max_balloon = newmem;
if (persistentDef->mem.cur_balloon > newmem) if (persistentDef->mem.cur_balloon > newmem)
persistentDef->mem.cur_balloon = newmem; persistentDef->mem.cur_balloon = newmem;
ret = virDomainSaveConfig(driver->configDir, persistentDef); ret = virDomainSaveConfig(cfg->configDir, persistentDef);
goto cleanup; goto cleanup;
} }
@ -1804,7 +1758,7 @@ libxlDomainSetMemoryFlags(virDomainPtr dom, unsigned long newmem,
if (flags & VIR_DOMAIN_MEM_CONFIG) { if (flags & VIR_DOMAIN_MEM_CONFIG) {
sa_assert(persistentDef); sa_assert(persistentDef);
persistentDef->mem.cur_balloon = newmem; persistentDef->mem.cur_balloon = newmem;
ret = virDomainSaveConfig(driver->configDir, persistentDef); ret = virDomainSaveConfig(cfg->configDir, persistentDef);
goto cleanup; goto cleanup;
} }
} }
@ -1814,6 +1768,7 @@ libxlDomainSetMemoryFlags(virDomainPtr dom, unsigned long newmem,
cleanup: cleanup:
if (vm) if (vm)
virObjectUnlock(vm); virObjectUnlock(vm);
virObjectUnref(cfg);
return ret; return ret;
} }
@ -2353,6 +2308,7 @@ libxlDomainSetVcpusFlags(virDomainPtr dom, unsigned int nvcpus,
unsigned int flags) unsigned int flags)
{ {
libxlDriverPrivatePtr driver = dom->conn->privateData; libxlDriverPrivatePtr driver = dom->conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
libxlDomainObjPrivatePtr priv; libxlDomainObjPrivatePtr priv;
virDomainDefPtr def; virDomainDefPtr def;
virDomainObjPtr vm; virDomainObjPtr vm;
@ -2426,7 +2382,7 @@ libxlDomainSetVcpusFlags(virDomainPtr dom, unsigned int nvcpus,
priv = vm->privateData; priv = vm->privateData;
if (!(def = virDomainObjGetPersistentDef(driver->caps, driver->xmlopt, vm))) if (!(def = virDomainObjGetPersistentDef(cfg->caps, driver->xmlopt, vm)))
goto cleanup; goto cleanup;
maplen = VIR_CPU_MAPLEN(nvcpus); maplen = VIR_CPU_MAPLEN(nvcpus);
@ -2475,12 +2431,13 @@ libxlDomainSetVcpusFlags(virDomainPtr dom, unsigned int nvcpus,
ret = 0; ret = 0;
if (flags & VIR_DOMAIN_VCPU_CONFIG) if (flags & VIR_DOMAIN_VCPU_CONFIG)
ret = virDomainSaveConfig(driver->configDir, def); ret = virDomainSaveConfig(cfg->configDir, def);
cleanup: cleanup:
VIR_FREE(bitmask); VIR_FREE(bitmask);
if (vm) if (vm)
virObjectUnlock(vm); virObjectUnlock(vm);
virObjectUnref(cfg);
return ret; return ret;
} }
@ -2558,6 +2515,7 @@ libxlDomainPinVcpu(virDomainPtr dom, unsigned int vcpu, unsigned char *cpumap,
int maplen) int maplen)
{ {
libxlDriverPrivatePtr driver = dom->conn->privateData; libxlDriverPrivatePtr driver = dom->conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
libxlDomainObjPrivatePtr priv; libxlDomainObjPrivatePtr priv;
virDomainObjPtr vm; virDomainObjPtr vm;
int ret = -1; int ret = -1;
@ -2606,7 +2564,7 @@ libxlDomainPinVcpu(virDomainPtr dom, unsigned int vcpu, unsigned char *cpumap,
goto cleanup; goto cleanup;
} }
if (virDomainSaveStatus(driver->xmlopt, driver->stateDir, vm) < 0) if (virDomainSaveStatus(driver->xmlopt, cfg->stateDir, vm) < 0)
goto cleanup; goto cleanup;
ret = 0; ret = 0;
@ -2614,6 +2572,7 @@ libxlDomainPinVcpu(virDomainPtr dom, unsigned int vcpu, unsigned char *cpumap,
cleanup: cleanup:
if (vm) if (vm)
virObjectUnlock(vm); virObjectUnlock(vm);
virObjectUnref(cfg);
return ret; return ret;
} }
@ -2724,6 +2683,7 @@ libxlConnectDomainXMLFromNative(virConnectPtr conn, const char * nativeFormat,
unsigned int flags) unsigned int flags)
{ {
libxlDriverPrivatePtr driver = conn->privateData; libxlDriverPrivatePtr driver = conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
virDomainDefPtr def = NULL; virDomainDefPtr def = NULL;
virConfPtr conf = NULL; virConfPtr conf = NULL;
char *xml = NULL; char *xml = NULL;
@ -2743,8 +2703,8 @@ libxlConnectDomainXMLFromNative(virConnectPtr conn, const char * nativeFormat,
goto cleanup; goto cleanup;
if (!(def = xenParseXM(conf, if (!(def = xenParseXM(conf,
driver->verInfo->xen_version_major, cfg->verInfo->xen_version_major,
driver->caps))) { cfg->caps))) {
virReportError(VIR_ERR_INTERNAL_ERROR, "%s", _("parsing xm config failed")); virReportError(VIR_ERR_INTERNAL_ERROR, "%s", _("parsing xm config failed"));
goto cleanup; goto cleanup;
} }
@ -2755,6 +2715,7 @@ cleanup:
virDomainDefFree(def); virDomainDefFree(def);
if (conf) if (conf)
virConfFree(conf); virConfFree(conf);
virObjectUnref(cfg);
return xml; return xml;
} }
@ -2765,6 +2726,7 @@ libxlConnectDomainXMLToNative(virConnectPtr conn, const char * nativeFormat,
unsigned int flags) unsigned int flags)
{ {
libxlDriverPrivatePtr driver = conn->privateData; libxlDriverPrivatePtr driver = conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
virDomainDefPtr def = NULL; virDomainDefPtr def = NULL;
virConfPtr conf = NULL; virConfPtr conf = NULL;
int len = MAX_CONFIG_SIZE; int len = MAX_CONFIG_SIZE;
@ -2782,11 +2744,11 @@ libxlConnectDomainXMLToNative(virConnectPtr conn, const char * nativeFormat,
} }
if (!(def = virDomainDefParseString(domainXml, if (!(def = virDomainDefParseString(domainXml,
driver->caps, driver->xmlopt, cfg->caps, driver->xmlopt,
1 << VIR_DOMAIN_VIRT_XEN, 0))) 1 << VIR_DOMAIN_VIRT_XEN, 0)))
goto cleanup; goto cleanup;
if (!(conf = xenFormatXM(conn, def, driver->verInfo->xen_version_major))) if (!(conf = xenFormatXM(conn, def, cfg->verInfo->xen_version_major)))
goto cleanup; goto cleanup;
if (VIR_ALLOC_N(ret, len) < 0) if (VIR_ALLOC_N(ret, len) < 0)
@ -2801,6 +2763,7 @@ cleanup:
virDomainDefFree(def); virDomainDefFree(def);
if (conf) if (conf)
virConfFree(conf); virConfFree(conf);
virObjectUnref(cfg);
return ret; return ret;
} }
@ -2887,6 +2850,7 @@ static virDomainPtr
libxlDomainDefineXML(virConnectPtr conn, const char *xml) libxlDomainDefineXML(virConnectPtr conn, const char *xml)
{ {
libxlDriverPrivatePtr driver = conn->privateData; libxlDriverPrivatePtr driver = conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
virDomainDefPtr def = NULL; virDomainDefPtr def = NULL;
virDomainObjPtr vm = NULL; virDomainObjPtr vm = NULL;
virDomainPtr dom = NULL; virDomainPtr dom = NULL;
@ -2894,7 +2858,7 @@ libxlDomainDefineXML(virConnectPtr conn, const char *xml)
virDomainDefPtr oldDef = NULL; virDomainDefPtr oldDef = NULL;
libxlDriverLock(driver); libxlDriverLock(driver);
if (!(def = virDomainDefParseString(xml, driver->caps, driver->xmlopt, if (!(def = virDomainDefParseString(xml, cfg->caps, driver->xmlopt,
1 << VIR_DOMAIN_VIRT_XEN, 1 << VIR_DOMAIN_VIRT_XEN,
VIR_DOMAIN_XML_INACTIVE))) VIR_DOMAIN_XML_INACTIVE)))
goto cleanup; goto cleanup;
@ -2910,7 +2874,7 @@ libxlDomainDefineXML(virConnectPtr conn, const char *xml)
def = NULL; def = NULL;
vm->persistent = 1; vm->persistent = 1;
if (virDomainSaveConfig(driver->configDir, if (virDomainSaveConfig(cfg->configDir,
vm->newDef ? vm->newDef : vm->def) < 0) { vm->newDef ? vm->newDef : vm->def) < 0) {
virDomainObjListRemove(driver->domains, vm); virDomainObjListRemove(driver->domains, vm);
vm = NULL; vm = NULL;
@ -2934,6 +2898,7 @@ cleanup:
if (event) if (event)
libxlDomainEventQueue(driver, event); libxlDomainEventQueue(driver, event);
libxlDriverUnlock(driver); libxlDriverUnlock(driver);
virObjectUnref(cfg);
return dom; return dom;
} }
@ -2942,6 +2907,7 @@ libxlDomainUndefineFlags(virDomainPtr dom,
unsigned int flags) unsigned int flags)
{ {
libxlDriverPrivatePtr driver = dom->conn->privateData; libxlDriverPrivatePtr driver = dom->conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
virDomainObjPtr vm; virDomainObjPtr vm;
virDomainEventPtr event = NULL; virDomainEventPtr event = NULL;
char *name = NULL; char *name = NULL;
@ -2989,9 +2955,7 @@ libxlDomainUndefineFlags(virDomainPtr dom,
} }
} }
if (virDomainDeleteConfig(driver->configDir, if (virDomainDeleteConfig(cfg->configDir, cfg->autostartDir, vm) < 0)
driver->autostartDir,
vm) < 0)
goto cleanup; goto cleanup;
event = virDomainEventNewFromObj(vm, VIR_DOMAIN_EVENT_UNDEFINED, event = virDomainEventNewFromObj(vm, VIR_DOMAIN_EVENT_UNDEFINED,
@ -3013,6 +2977,7 @@ libxlDomainUndefineFlags(virDomainPtr dom,
if (event) if (event)
libxlDomainEventQueue(driver, event); libxlDomainEventQueue(driver, event);
libxlDriverUnlock(driver); libxlDriverUnlock(driver);
virObjectUnref(cfg);
return ret; return ret;
} }
@ -3372,6 +3337,7 @@ libxlDomainAttachDeviceFlags(virDomainPtr dom, const char *xml,
unsigned int flags) unsigned int flags)
{ {
libxlDriverPrivatePtr driver = dom->conn->privateData; libxlDriverPrivatePtr driver = dom->conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
virDomainObjPtr vm = NULL; virDomainObjPtr vm = NULL;
virDomainDefPtr vmdef = NULL; virDomainDefPtr vmdef = NULL;
virDomainDeviceDefPtr dev = NULL; virDomainDeviceDefPtr dev = NULL;
@ -3416,12 +3382,12 @@ libxlDomainAttachDeviceFlags(virDomainPtr dom, const char *xml,
if (flags & VIR_DOMAIN_DEVICE_MODIFY_CONFIG) { if (flags & VIR_DOMAIN_DEVICE_MODIFY_CONFIG) {
if (!(dev = virDomainDeviceDefParse(xml, vm->def, if (!(dev = virDomainDeviceDefParse(xml, vm->def,
driver->caps, driver->xmlopt, cfg->caps, driver->xmlopt,
VIR_DOMAIN_XML_INACTIVE))) VIR_DOMAIN_XML_INACTIVE)))
goto cleanup; goto cleanup;
/* Make a copy for updated domain. */ /* Make a copy for updated domain. */
if (!(vmdef = virDomainObjCopyPersistentDef(vm, driver->caps, if (!(vmdef = virDomainObjCopyPersistentDef(vm, cfg->caps,
driver->xmlopt))) driver->xmlopt)))
goto cleanup; goto cleanup;
@ -3435,7 +3401,7 @@ libxlDomainAttachDeviceFlags(virDomainPtr dom, const char *xml,
/* If dev exists it was created to modify the domain config. Free it. */ /* If dev exists it was created to modify the domain config. Free it. */
virDomainDeviceDefFree(dev); virDomainDeviceDefFree(dev);
if (!(dev = virDomainDeviceDefParse(xml, vm->def, if (!(dev = virDomainDeviceDefParse(xml, vm->def,
driver->caps, driver->xmlopt, cfg->caps, driver->xmlopt,
VIR_DOMAIN_XML_INACTIVE))) VIR_DOMAIN_XML_INACTIVE)))
goto cleanup; goto cleanup;
@ -3446,13 +3412,13 @@ libxlDomainAttachDeviceFlags(virDomainPtr dom, const char *xml,
* update domain status forcibly because the domain status may be * update domain status forcibly because the domain status may be
* changed even if we attach the device failed. * changed even if we attach the device failed.
*/ */
if (virDomainSaveStatus(driver->xmlopt, driver->stateDir, vm) < 0) if (virDomainSaveStatus(driver->xmlopt, cfg->stateDir, vm) < 0)
ret = -1; ret = -1;
} }
/* Finally, if no error until here, we can save config. */ /* Finally, if no error until here, we can save config. */
if (!ret && (flags & VIR_DOMAIN_DEVICE_MODIFY_CONFIG)) { if (!ret && (flags & VIR_DOMAIN_DEVICE_MODIFY_CONFIG)) {
ret = virDomainSaveConfig(driver->configDir, vmdef); ret = virDomainSaveConfig(cfg->configDir, vmdef);
if (!ret) { if (!ret) {
virDomainObjAssignDef(vm, vmdef, false, NULL); virDomainObjAssignDef(vm, vmdef, false, NULL);
vmdef = NULL; vmdef = NULL;
@ -3465,6 +3431,7 @@ cleanup:
if (vm) if (vm)
virObjectUnlock(vm); virObjectUnlock(vm);
libxlDriverUnlock(driver); libxlDriverUnlock(driver);
virObjectUnref(cfg);
return ret; return ret;
} }
@ -3480,6 +3447,7 @@ libxlDomainDetachDeviceFlags(virDomainPtr dom, const char *xml,
unsigned int flags) unsigned int flags)
{ {
libxlDriverPrivatePtr driver = dom->conn->privateData; libxlDriverPrivatePtr driver = dom->conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
virDomainObjPtr vm = NULL; virDomainObjPtr vm = NULL;
virDomainDefPtr vmdef = NULL; virDomainDefPtr vmdef = NULL;
virDomainDeviceDefPtr dev = NULL; virDomainDeviceDefPtr dev = NULL;
@ -3524,12 +3492,12 @@ libxlDomainDetachDeviceFlags(virDomainPtr dom, const char *xml,
if (flags & VIR_DOMAIN_DEVICE_MODIFY_CONFIG) { if (flags & VIR_DOMAIN_DEVICE_MODIFY_CONFIG) {
if (!(dev = virDomainDeviceDefParse(xml, vm->def, if (!(dev = virDomainDeviceDefParse(xml, vm->def,
driver->caps, driver->xmlopt, cfg->caps, driver->xmlopt,
VIR_DOMAIN_XML_INACTIVE))) VIR_DOMAIN_XML_INACTIVE)))
goto cleanup; goto cleanup;
/* Make a copy for updated domain. */ /* Make a copy for updated domain. */
if (!(vmdef = virDomainObjCopyPersistentDef(vm, driver->caps, if (!(vmdef = virDomainObjCopyPersistentDef(vm, cfg->caps,
driver->xmlopt))) driver->xmlopt)))
goto cleanup; goto cleanup;
@ -3543,7 +3511,7 @@ libxlDomainDetachDeviceFlags(virDomainPtr dom, const char *xml,
/* If dev exists it was created to modify the domain config. Free it. */ /* If dev exists it was created to modify the domain config. Free it. */
virDomainDeviceDefFree(dev); virDomainDeviceDefFree(dev);
if (!(dev = virDomainDeviceDefParse(xml, vm->def, if (!(dev = virDomainDeviceDefParse(xml, vm->def,
driver->caps, driver->xmlopt, cfg->caps, driver->xmlopt,
VIR_DOMAIN_XML_INACTIVE))) VIR_DOMAIN_XML_INACTIVE)))
goto cleanup; goto cleanup;
@ -3554,13 +3522,13 @@ libxlDomainDetachDeviceFlags(virDomainPtr dom, const char *xml,
* update domain status forcibly because the domain status may be * update domain status forcibly because the domain status may be
* changed even if we attach the device failed. * changed even if we attach the device failed.
*/ */
if (virDomainSaveStatus(driver->xmlopt, driver->stateDir, vm) < 0) if (virDomainSaveStatus(driver->xmlopt, cfg->stateDir, vm) < 0)
ret = -1; ret = -1;
} }
/* Finally, if no error until here, we can save config. */ /* Finally, if no error until here, we can save config. */
if (!ret && (flags & VIR_DOMAIN_DEVICE_MODIFY_CONFIG)) { if (!ret && (flags & VIR_DOMAIN_DEVICE_MODIFY_CONFIG)) {
ret = virDomainSaveConfig(driver->configDir, vmdef); ret = virDomainSaveConfig(cfg->configDir, vmdef);
if (!ret) { if (!ret) {
virDomainObjAssignDef(vm, vmdef, false, NULL); virDomainObjAssignDef(vm, vmdef, false, NULL);
vmdef = NULL; vmdef = NULL;
@ -3573,6 +3541,7 @@ cleanup:
if (vm) if (vm)
virObjectUnlock(vm); virObjectUnlock(vm);
libxlDriverUnlock(driver); libxlDriverUnlock(driver);
virObjectUnref(cfg);
return ret; return ret;
} }
@ -3588,6 +3557,7 @@ libxlDomainUpdateDeviceFlags(virDomainPtr dom, const char *xml,
unsigned int flags) unsigned int flags)
{ {
libxlDriverPrivatePtr driver = dom->conn->privateData; libxlDriverPrivatePtr driver = dom->conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
virDomainObjPtr vm = NULL; virDomainObjPtr vm = NULL;
virDomainDefPtr vmdef = NULL; virDomainDefPtr vmdef = NULL;
virDomainDeviceDefPtr dev = NULL; virDomainDeviceDefPtr dev = NULL;
@ -3632,12 +3602,12 @@ libxlDomainUpdateDeviceFlags(virDomainPtr dom, const char *xml,
if (flags & VIR_DOMAIN_DEVICE_MODIFY_CONFIG) { if (flags & VIR_DOMAIN_DEVICE_MODIFY_CONFIG) {
if (!(dev = virDomainDeviceDefParse(xml, vm->def, if (!(dev = virDomainDeviceDefParse(xml, vm->def,
driver->caps, driver->xmlopt, cfg->caps, driver->xmlopt,
VIR_DOMAIN_XML_INACTIVE))) VIR_DOMAIN_XML_INACTIVE)))
goto cleanup; goto cleanup;
/* Make a copy for updated domain. */ /* Make a copy for updated domain. */
if (!(vmdef = virDomainObjCopyPersistentDef(vm, driver->caps, if (!(vmdef = virDomainObjCopyPersistentDef(vm, cfg->caps,
driver->xmlopt))) driver->xmlopt)))
goto cleanup; goto cleanup;
@ -3651,7 +3621,7 @@ libxlDomainUpdateDeviceFlags(virDomainPtr dom, const char *xml,
/* If dev exists it was created to modify the domain config. Free it. */ /* If dev exists it was created to modify the domain config. Free it. */
virDomainDeviceDefFree(dev); virDomainDeviceDefFree(dev);
if (!(dev = virDomainDeviceDefParse(xml, vm->def, if (!(dev = virDomainDeviceDefParse(xml, vm->def,
driver->caps, driver->xmlopt, cfg->caps, driver->xmlopt,
VIR_DOMAIN_XML_INACTIVE))) VIR_DOMAIN_XML_INACTIVE)))
goto cleanup; goto cleanup;
@ -3662,13 +3632,13 @@ libxlDomainUpdateDeviceFlags(virDomainPtr dom, const char *xml,
* update domain status forcibly because the domain status may be * update domain status forcibly because the domain status may be
* changed even if we attach the device failed. * changed even if we attach the device failed.
*/ */
if (virDomainSaveStatus(driver->xmlopt, driver->stateDir, vm) < 0) if (virDomainSaveStatus(driver->xmlopt, cfg->stateDir, vm) < 0)
ret = -1; ret = -1;
} }
/* Finally, if no error until here, we can save config. */ /* Finally, if no error until here, we can save config. */
if (!ret && (flags & VIR_DOMAIN_DEVICE_MODIFY_CONFIG)) { if (!ret && (flags & VIR_DOMAIN_DEVICE_MODIFY_CONFIG)) {
ret = virDomainSaveConfig(driver->configDir, vmdef); ret = virDomainSaveConfig(cfg->configDir, vmdef);
if (!ret) { if (!ret) {
virDomainObjAssignDef(vm, vmdef, false, NULL); virDomainObjAssignDef(vm, vmdef, false, NULL);
vmdef = NULL; vmdef = NULL;
@ -3681,6 +3651,7 @@ cleanup:
if (vm) if (vm)
virObjectUnlock(vm); virObjectUnlock(vm);
libxlDriverUnlock(driver); libxlDriverUnlock(driver);
virObjectUnref(cfg);
return ret; return ret;
} }
@ -3689,17 +3660,23 @@ libxlNodeGetFreeMemory(virConnectPtr conn)
{ {
libxl_physinfo phy_info; libxl_physinfo phy_info;
libxlDriverPrivatePtr driver = conn->privateData; libxlDriverPrivatePtr driver = conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
unsigned long long ret = 0;
if (virNodeGetFreeMemoryEnsureACL(conn) < 0) if (virNodeGetFreeMemoryEnsureACL(conn) < 0)
return 0; goto cleanup;
if (libxl_get_physinfo(driver->ctx, &phy_info)) { if (libxl_get_physinfo(cfg->ctx, &phy_info)) {
virReportError(VIR_ERR_INTERNAL_ERROR, "%s", virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
_("libxl_get_physinfo_info failed")); _("libxl_get_physinfo_info failed"));
return 0; goto cleanup;
} }
return phy_info.free_pages * driver->verInfo->pagesize; ret = phy_info.free_pages * cfg->verInfo->pagesize;
cleanup:
virObjectUnref(cfg);
return ret;
} }
static int static int
@ -3712,11 +3689,12 @@ libxlNodeGetCellsFreeMemory(virConnectPtr conn,
int ret = -1, nr_nodes = 0; int ret = -1, nr_nodes = 0;
libxl_numainfo *numa_info = NULL; libxl_numainfo *numa_info = NULL;
libxlDriverPrivatePtr driver = conn->privateData; libxlDriverPrivatePtr driver = conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
if (virNodeGetCellsFreeMemoryEnsureACL(conn) < 0) if (virNodeGetCellsFreeMemoryEnsureACL(conn) < 0)
return -1; goto cleanup;
numa_info = libxl_get_numainfo(driver->ctx, &nr_nodes); numa_info = libxl_get_numainfo(cfg->ctx, &nr_nodes);
if (numa_info == NULL || nr_nodes == 0) { if (numa_info == NULL || nr_nodes == 0) {
virReportError(VIR_ERR_INTERNAL_ERROR, "%s", virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
_("libxl_get_numainfo failed")); _("libxl_get_numainfo failed"));
@ -3745,6 +3723,7 @@ libxlNodeGetCellsFreeMemory(virConnectPtr conn,
cleanup: cleanup:
libxl_numainfo_list_free(numa_info, nr_nodes); libxl_numainfo_list_free(numa_info, nr_nodes);
virObjectUnref(cfg);
return ret; return ret;
} }
@ -3823,6 +3802,7 @@ static int
libxlDomainSetAutostart(virDomainPtr dom, int autostart) libxlDomainSetAutostart(virDomainPtr dom, int autostart)
{ {
libxlDriverPrivatePtr driver = dom->conn->privateData; libxlDriverPrivatePtr driver = dom->conn->privateData;
libxlDriverConfigPtr cfg = libxlDriverConfigGet(driver);
virDomainObjPtr vm; virDomainObjPtr vm;
char *configFile = NULL, *autostartLink = NULL; char *configFile = NULL, *autostartLink = NULL;
int ret = -1; int ret = -1;
@ -3850,16 +3830,16 @@ libxlDomainSetAutostart(virDomainPtr dom, int autostart)
autostart = (autostart != 0); autostart = (autostart != 0);
if (vm->autostart != autostart) { if (vm->autostart != autostart) {
if (!(configFile = virDomainConfigFile(driver->configDir, vm->def->name))) if (!(configFile = virDomainConfigFile(cfg->configDir, vm->def->name)))
goto cleanup; goto cleanup;
if (!(autostartLink = virDomainConfigFile(driver->autostartDir, vm->def->name))) if (!(autostartLink = virDomainConfigFile(cfg->autostartDir, vm->def->name)))
goto cleanup; goto cleanup;
if (autostart) { if (autostart) {
if (virFileMakePath(driver->autostartDir) < 0) { if (virFileMakePath(cfg->autostartDir) < 0) {
virReportSystemError(errno, virReportSystemError(errno,
_("cannot create autostart directory %s"), _("cannot create autostart directory %s"),
driver->autostartDir); cfg->autostartDir);
goto cleanup; goto cleanup;
} }
@ -3888,6 +3868,7 @@ cleanup:
if (vm) if (vm)
virObjectUnlock(vm); virObjectUnlock(vm);
libxlDriverUnlock(driver); libxlDriverUnlock(driver);
virObjectUnref(cfg);
return ret; return ret;
} }