if (priv->cgroup) {
int rv = -1;
/* Create cgroup for the onlined vcpu */
- rv = virCgroupNewVcpu(priv->cgroup, i, true, &cgroup_vcpu);
- if (rv < 0) {
- virReportSystemError(-rv,
- _("Unable to create vcpu cgroup for %s(vcpu:"
- " %zu)"),
- vm->def->name, i);
+ if (virCgroupNewVcpu(priv->cgroup, i, true, &cgroup_vcpu) < 0)
goto cleanup;
- }
/* Add vcpu thread to the cgroup */
rv = virCgroupAddTask(cgroup_vcpu, cpupids[i]);
virDomainVcpuPinDefPtr vcpupin = NULL;
if (priv->cgroup) {
- int rv = -1;
-
- rv = virCgroupNewVcpu(priv->cgroup, i, false, &cgroup_vcpu);
- if (rv < 0) {
- virReportSystemError(-rv,
- _("Unable to access vcpu cgroup for %s(vcpu:"
- " %zu)"),
- vm->def->name, i);
+ if (virCgroupNewVcpu(priv->cgroup, i, false, &cgroup_vcpu) < 0)
goto cleanup;
- }
/* Remove cgroup for the offlined vcpu */
virCgroupRemove(cgroup_vcpu);
/* Configure the corresponding cpuset cgroup before set affinity. */
if (virCgroupHasController(priv->cgroup, VIR_CGROUP_CONTROLLER_CPUSET)) {
- if (virCgroupNewVcpu(priv->cgroup, vcpu, false, &cgroup_vcpu) == 0 &&
- qemuSetupCgroupVcpuPin(cgroup_vcpu, newVcpuPin, newVcpuPinNum, vcpu) < 0) {
+ if (virCgroupNewVcpu(priv->cgroup, vcpu, false, &cgroup_vcpu) < 0)
+ goto cleanup;
+ if (qemuSetupCgroupVcpuPin(cgroup_vcpu, newVcpuPin, newVcpuPinNum, vcpu) < 0) {
virReportError(VIR_ERR_OPERATION_INVALID,
_("failed to set cpuset.cpus in cgroup"
" for vcpu %d"), vcpu);
VIR_CGROUP_CONTROLLER_CPUSET)) {
/*
* Configure the corresponding cpuset cgroup.
- * If no cgroup for domain or hypervisor exists, do nothing.
*/
- if (virCgroupNewEmulator(priv->cgroup, false, &cgroup_emulator) == 0) {
- if (qemuSetupCgroupEmulatorPin(cgroup_emulator,
- newVcpuPin[0]->cpumask) < 0) {
- virReportError(VIR_ERR_OPERATION_INVALID, "%s",
- _("failed to set cpuset.cpus in cgroup"
- " for emulator threads"));
- goto cleanup;
- }
+ if (virCgroupNewEmulator(priv->cgroup, false, &cgroup_emulator) < 0)
+ goto cleanup;
+ if (qemuSetupCgroupEmulatorPin(cgroup_emulator,
+ newVcpuPin[0]->cpumask) < 0) {
+ virReportError(VIR_ERR_OPERATION_INVALID, "%s",
+ _("failed to set cpuset.cpus in cgroup"
+ " for emulator threads"));
+ goto cleanup;
}
} else {
if (virProcessSetAffinity(pid, pcpumap) < 0) {
size_t i;
qemuDomainObjPrivatePtr priv = vm->privateData;
virCgroupPtr cgroup_vcpu = NULL;
- int rc;
if (period == 0 && quota == 0)
return 0;
*/
if (priv->nvcpupids != 0 && priv->vcpupids[0] != vm->pid) {
for (i = 0; i < priv->nvcpupids; i++) {
- rc = virCgroupNewVcpu(cgroup, i, false, &cgroup_vcpu);
- if (rc < 0) {
- virReportSystemError(-rc,
- _("Unable to find vcpu cgroup for %s(vcpu:"
- " %zu)"),
- vm->def->name, i);
+ if (virCgroupNewVcpu(cgroup, i, false, &cgroup_vcpu) < 0)
goto cleanup;
- }
if (qemuSetupCgroupVcpuBW(cgroup_vcpu, period, quota) < 0)
goto cleanup;
{
qemuDomainObjPrivatePtr priv = vm->privateData;
virCgroupPtr cgroup_emulator = NULL;
- int rc;
if (period == 0 && quota == 0)
return 0;
return 0;
}
- rc = virCgroupNewEmulator(cgroup, false, &cgroup_emulator);
- if (rc < 0) {
- virReportSystemError(-rc,
- _("Unable to find emulator cgroup for %s"),
- vm->def->name);
+ if (virCgroupNewEmulator(cgroup, false, &cgroup_emulator) < 0)
goto cleanup;
- }
if (qemuSetupCgroupVcpuBW(cgroup_emulator, period, quota) < 0)
goto cleanup;
}
/* get period and quota for vcpu0 */
- rc = virCgroupNewVcpu(priv->cgroup, 0, false, &cgroup_vcpu);
- if (!cgroup_vcpu) {
- virReportSystemError(-rc,
- _("Unable to find vcpu cgroup for %s(vcpu: 0)"),
- vm->def->name);
+ if (virCgroupNewVcpu(priv->cgroup, 0, false, &cgroup_vcpu) < 0)
goto cleanup;
- }
rc = qemuGetVcpuBWLive(cgroup_vcpu, period, quota);
if (rc < 0)
}
/* get period and quota for emulator */
- rc = virCgroupNewEmulator(cgroup, false, &cgroup_emulator);
- if (!cgroup_emulator) {
- virReportSystemError(-rc,
- _("Unable to find emulator cgroup for %s"),
- vm->def->name);
+ if (virCgroupNewEmulator(cgroup, false, &cgroup_emulator) < 0)
goto cleanup;
- }
rc = qemuGetVcpuBWLive(cgroup_emulator, period, quota);
if (rc < 0)
unsigned long long tmp;
size_t j;
- if (virCgroupNewVcpu(priv->cgroup, i, false, &group_vcpu) < 0) {
- virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
- _("error accessing cgroup cpuacct for vcpu"));
+ if (virCgroupNewVcpu(priv->cgroup, i, false, &group_vcpu) < 0)
goto cleanup;
- }
if (virCgroupGetCpuacctPercpuUsage(group_vcpu, &buf) < 0)
goto cleanup;
*/
} virCgroupFlags;
+bool virCgroupAvailable(void)
+{
+ FILE *mounts = NULL;
+ struct mntent entry;
+ bool ret = false;
+ char buf[CGROUP_MAX_VAL];
+
+ if (!virFileExists("/proc/cgroups"))
+ return false;
+
+ if (!(mounts = fopen("/proc/mounts", "r")))
+ return false;
+
+ while (getmntent_r(mounts, &entry, buf, sizeof(buf)) != NULL) {
+ if (STREQ(entry.mnt_type, "cgroup")) {
+ ret = true;
+ break;
+ }
+ }
+
+ VIR_FORCE_FCLOSE(mounts);
+ return ret;
+}
+
/**
* virCgroupFree:
*
if (!parent->controllers[i].mountPoint)
continue;
- if (VIR_STRDUP_QUIET(group->controllers[i].mountPoint,
- parent->controllers[i].mountPoint) < 0)
- return -ENOMEM;
+ if (VIR_STRDUP(group->controllers[i].mountPoint,
+ parent->controllers[i].mountPoint) < 0)
+ return -1;
- if (VIR_STRDUP_QUIET(group->controllers[i].linkPoint,
- parent->controllers[i].linkPoint) < 0)
- return -ENOMEM;
+ if (VIR_STRDUP(group->controllers[i].linkPoint,
+ parent->controllers[i].linkPoint) < 0)
+ return -1;
}
return 0;
}
mounts = fopen("/proc/mounts", "r");
if (mounts == NULL) {
- VIR_ERROR(_("Unable to open /proc/mounts"));
- return -ENOENT;
+ virReportSystemError(errno, "%s",
+ _("Unable to open /proc/mounts"));
+ return -1;
}
while (getmntent_r(mounts, &entry, buf, sizeof(buf)) != NULL) {
struct stat sb;
char *tmp2;
- if (VIR_STRDUP_QUIET(group->controllers[i].mountPoint,
- entry.mnt_dir) < 0)
+ if (VIR_STRDUP(group->controllers[i].mountPoint,
+ entry.mnt_dir) < 0)
goto error;
tmp2 = strrchr(entry.mnt_dir, '/');
if (!tmp2) {
- errno = EINVAL;
+ virReportError(VIR_ERR_INTERNAL_ERROR,
+ _("Missing '/' separator in cgroup mount '%s'"),
+ entry.mnt_dir);
goto error;
}
*tmp2 = '\0';
typestr, entry.mnt_dir, linksrc);
VIR_FREE(linksrc);
} else {
+ virReportSystemError(errno,
+ _("Cannot stat %s"), linksrc);
goto error;
}
} else {
error:
VIR_FORCE_FCLOSE(mounts);
- return -errno;
+ return -1;
}
continue;
if (path[0] == '/') {
- if (VIR_STRDUP_QUIET(group->controllers[i].placement, path) < 0)
- return -ENOMEM;
+ if (VIR_STRDUP(group->controllers[i].placement, path) < 0)
+ return -1;
} else {
/*
* parent=="/" + path="" => "/"
(STREQ(parent->controllers[i].placement, "/") ||
STREQ(path, "") ? "" : "/"),
path) < 0)
- return -ENOMEM;
+ return -1;
}
}
size_t i;
FILE *mapping = NULL;
char line[1024];
+ int ret = -1;
mapping = fopen("/proc/self/cgroup", "r");
if (mapping == NULL) {
- VIR_ERROR(_("Unable to open /proc/self/cgroup"));
- return -ENOENT;
+ virReportSystemError(errno, "%s",
+ _("Unable to open /proc/self/cgroup"));
+ return -1;
}
while (fgets(line, sizeof(line), mapping) != NULL) {
(STREQ(selfpath, "/") ||
STREQ(path, "") ? "" : "/"),
path) < 0)
- goto no_memory;
+ goto cleanup;
}
tmp = next;
}
}
- VIR_FORCE_FCLOSE(mapping);
-
- return 0;
+ ret = 0;
-no_memory:
+cleanup:
VIR_FORCE_FCLOSE(mapping);
- return -ENOMEM;
+ return ret;
}
static int virCgroupDetect(virCgroupPtr group,
const char *path,
virCgroupPtr parent)
{
- int rc;
size_t i;
size_t j;
VIR_DEBUG("group=%p controllers=%d path=%s parent=%p",
group, controllers, path, parent);
- if (parent)
- rc = virCgroupCopyMounts(group, parent);
- else
- rc = virCgroupDetectMounts(group);
- if (rc < 0) {
- VIR_ERROR(_("Failed to detect mounts for %s"), group->path);
- return rc;
+ if (parent) {
+ if (virCgroupCopyMounts(group, parent) < 0)
+ return -1;
+ } else {
+ if (virCgroupDetectMounts(group) < 0)
+ return -1;
}
if (controllers >= 0) {
if (STREQ_NULLABLE(group->controllers[i].mountPoint,
group->controllers[j].mountPoint)) {
- VIR_DEBUG("Controller '%s' is not wanted, but '%s' is co-mounted",
- virCgroupControllerTypeToString(i),
- virCgroupControllerTypeToString(j));
- return -EINVAL;
+ virReportSystemError(EINVAL,
+ _("Controller '%s' is not wanted, but '%s' is co-mounted"),
+ virCgroupControllerTypeToString(i),
+ virCgroupControllerTypeToString(j));
+ return -1;
}
}
VIR_FREE(group->controllers[i].mountPoint);
/* Check that at least 1 controller is available */
if (!controllers) {
- VIR_DEBUG("No controllers set");
- return -ENXIO;
+ virReportSystemError(ENXIO, "%s",
+ _("At least one cgroup controller is required"));
+ return -1;
}
- if (parent || path[0] == '/')
- rc = virCgroupCopyPlacement(group, path, parent);
- else
- rc = virCgroupDetectPlacement(group, path);
-
- if (rc == 0) {
- /* Check that for every mounted controller, we found our placement */
- for (i = 0; i < VIR_CGROUP_CONTROLLER_LAST; i++) {
- if (!group->controllers[i].mountPoint)
- continue;
+ if (parent || path[0] == '/') {
+ if (virCgroupCopyPlacement(group, path, parent) < 0)
+ return -1;
+ } else {
+ if (virCgroupDetectPlacement(group, path) < 0)
+ return -1;
+ }
- if (!group->controllers[i].placement) {
- VIR_ERROR(_("Could not find placement for controller %s at %s"),
- virCgroupControllerTypeToString(i),
- group->controllers[i].placement);
- rc = -ENOENT;
- break;
- }
+ /* Check that for every mounted controller, we found our placement */
+ for (i = 0; i < VIR_CGROUP_CONTROLLER_LAST; i++) {
+ if (!group->controllers[i].mountPoint)
+ continue;
- VIR_DEBUG("Detected mount/mapping %zu:%s at %s in %s", i,
- virCgroupControllerTypeToString(i),
- group->controllers[i].mountPoint,
- group->controllers[i].placement);
+ if (!group->controllers[i].placement) {
+ virReportError(VIR_ERR_INTERNAL_ERROR,
+ _("Could not find placement for controller %s at %s"),
+ virCgroupControllerTypeToString(i),
+ group->controllers[i].placement);
+ return -1;
}
- } else {
- VIR_ERROR(_("Failed to detect mapping for %s"), group->path);
+
+ VIR_DEBUG("Detected mount/mapping %zu:%s at %s in %s", i,
+ virCgroupControllerTypeToString(i),
+ group->controllers[i].mountPoint,
+ group->controllers[i].placement);
}
- return rc;
+ return 0;
}
#endif
inherit_values[i],
&value);
if (rc != 0) {
- VIR_ERROR(_("Failed to get %s %d"), inherit_values[i], rc);
- break;
+ virReportSystemError(-rc,
+ _("Failed to get '%s'"), inherit_values[i]);
+ return -1;
}
VIR_DEBUG("Inherit %s = %s", inherit_values[i], value);
VIR_FREE(value);
if (rc != 0) {
- VIR_ERROR(_("Failed to set %s %d"), inherit_values[i], rc);
- break;
+ virReportSystemError(-rc,
+ _("Failed to set '%s'"), inherit_values[i]);
+ return -1;
}
}
- return rc;
+ return 0;
}
static int virCgroupSetMemoryUseHierarchy(virCgroupPtr group)
VIR_CGROUP_CONTROLLER_MEMORY,
filename, &value);
if (rc != 0) {
- VIR_ERROR(_("Failed to read %s/%s (%d)"), group->path, filename, rc);
- return rc;
+ virReportSystemError(-rc,
+ _("Failed to get '%s'"), filename);
+ return -1;
}
/* Setting twice causes error, so if already enabled, skip setting */
filename, 1);
if (rc != 0) {
- VIR_ERROR(_("Failed to set %s/%s (%d)"), group->path, filename, rc);
+ virReportSystemError(-rc,
+ _("Failed to set '%s'"), filename);
+ return -1;
}
- return rc;
+ return 0;
}
static int virCgroupMakeGroup(virCgroupPtr parent,
unsigned int flags)
{
size_t i;
- int rc = 0;
+ int ret = -1;
VIR_DEBUG("Make group %s", group->path);
for (i = 0; i < VIR_CGROUP_CONTROLLER_LAST; i++) {
continue;
}
- rc = virCgroupPathOfController(group, i, "", &path);
- if (rc < 0) {
- VIR_DEBUG("Failed to find path of controller %s",
- virCgroupControllerTypeToString(i));
- return rc;
+ if (virCgroupPathOfController(group, i, "", &path) < 0) {
+ virReportError(VIR_ERR_INTERNAL_ERROR,
+ _("Failed to find path of controller %s"),
+ virCgroupControllerTypeToString(i));
+ return -1;
}
/* As of Feb 2011, clang can't see that the above function
* call did not modify group. */
* treat blkio as unmounted if mkdir fails. */
if (i == VIR_CGROUP_CONTROLLER_BLKIO) {
VIR_DEBUG("Ignoring mkdir failure with blkio controller. Kernel probably too old");
- rc = 0;
VIR_FREE(group->controllers[i].mountPoint);
VIR_FREE(path);
continue;
} else {
- VIR_DEBUG("Failed to create controller %s for group",
- virCgroupControllerTypeToString(i));
- rc = -errno;
+ virReportSystemError(errno,
+ _("Failed to create controller %s for group"),
+ virCgroupControllerTypeToString(i));
VIR_FREE(path);
- break;
+ goto cleanup;
}
}
if (group->controllers[VIR_CGROUP_CONTROLLER_CPUSET].mountPoint != NULL &&
(i == VIR_CGROUP_CONTROLLER_CPUSET ||
STREQ(group->controllers[i].mountPoint, group->controllers[VIR_CGROUP_CONTROLLER_CPUSET].mountPoint))) {
- rc = virCgroupCpuSetInherit(parent, group);
- if (rc != 0) {
+ if (virCgroupCpuSetInherit(parent, group) < 0) {
VIR_FREE(path);
- break;
+ goto cleanup;
}
}
/*
(group->controllers[VIR_CGROUP_CONTROLLER_MEMORY].mountPoint != NULL) &&
(i == VIR_CGROUP_CONTROLLER_MEMORY ||
STREQ(group->controllers[i].mountPoint, group->controllers[VIR_CGROUP_CONTROLLER_MEMORY].mountPoint))) {
- rc = virCgroupSetMemoryUseHierarchy(group);
- if (rc != 0) {
+ if (virCgroupSetMemoryUseHierarchy(group) < 0) {
VIR_FREE(path);
- break;
+ goto cleanup;
}
}
}
}
VIR_DEBUG("Done making controllers for group");
- return rc;
+ ret = 0;
+
+cleanup:
+ return ret;
}
* @parent is NULL, then the placement of the current
* process is used.
*
+ * Returns 0 on success, -1 on error
*/
static int virCgroupNew(const char *path,
virCgroupPtr parent,
int controllers,
virCgroupPtr *group)
{
- int rc = 0;
- char *typpath = NULL;
-
VIR_DEBUG("parent=%p path=%s controllers=%d",
parent, path, controllers);
*group = NULL;
- if (VIR_ALLOC((*group)) != 0) {
- rc = -ENOMEM;
- goto err;
- }
+ if (VIR_ALLOC((*group)) < 0)
+ goto error;
if (path[0] == '/' || !parent) {
- if (VIR_STRDUP_QUIET((*group)->path, path) < 0) {
- rc = -ENOMEM;
- goto err;
- }
+ if (VIR_STRDUP((*group)->path, path) < 0)
+ goto error;
} else {
if (virAsprintf(&(*group)->path, "%s%s%s",
parent->path,
STREQ(parent->path, "") ? "" : "/",
- path) < 0) {
- rc = -ENOMEM;
- goto err;
- }
+ path) < 0)
+ goto error;
}
- rc = virCgroupDetect(*group, controllers, path, parent);
- if (rc < 0)
- goto err;
+ if (virCgroupDetect(*group, controllers, path, parent) < 0)
+ goto error;
- return rc;
-err:
+ return 0;
+
+error:
virCgroupFree(group);
*group = NULL;
- VIR_FREE(typpath);
-
- return rc;
+ return -1;
}
static int virCgroupAppRoot(virCgroupPtr *group,
int controllers)
{
virCgroupPtr selfgrp = NULL;
- int rc;
-
- rc = virCgroupNewSelf(&selfgrp);
+ int ret = -1;
- if (rc != 0)
- return rc;
+ if (virCgroupNewSelf(&selfgrp) < 0)
+ return -1;
- rc = virCgroupNew("libvirt", selfgrp, controllers, group);
- if (rc != 0)
+ if (virCgroupNew("libvirt", selfgrp, controllers, group) < 0)
goto cleanup;
- rc = virCgroupMakeGroup(selfgrp, *group, create, VIR_CGROUP_NONE);
+ if (virCgroupMakeGroup(selfgrp, *group, create, VIR_CGROUP_NONE) < 0)
+ goto cleanup;
+ ret = 0;
cleanup:
virCgroupFree(&selfgrp);
- return rc;
+ return ret;
}
#endif
#else
int virCgroupRemoveRecursively(char *grppath ATTRIBUTE_UNUSED)
{
- /* Claim no support */
- return -ENXIO;
+ virReportSystemError(ENXIO, "%s",
+ _("Control groups not supported on this platform"));
+ return -1;
}
#endif
* if cgroups are not available on a host */
if (errno == ENOENT)
errno = ENXIO;
- return -errno;
+ virReportSystemError(errno, "%s",
+ _("Cannot open /proc/cgroups"));
+ return -1;
}
/*
}
if (ferror(fp)) {
- ret = -EIO;
+ virReportSystemError(errno, "%s",
+ _("Error while reading /proc/cgroups"));
goto cleanup;
}
return rc;
if (VIR_INSERT_ELEMENT(*path, 0, len, escape) < 0)
- return -ENOMEM;
+ return -1;
return 0;
}
static int virCgroupSetPartitionSuffix(const char *path, char **res)
{
- char **tokens = virStringSplit(path, "/", 0);
+ char **tokens;
size_t i;
int ret = -1;
- if (!tokens)
+ if (!(tokens = virStringSplit(path, "/", 0)))
return ret;
for (i = 0; tokens[i] != NULL; i++) {
if (STRNEQ(tokens[i], "") &&
!strchr(tokens[i], '.')) {
if (VIR_REALLOC_N(tokens[i],
- strlen(tokens[i]) + strlen(".partition") + 1) < 0) {
- ret = -ENOMEM;
+ strlen(tokens[i]) + strlen(".partition") + 1) < 0)
goto cleanup;
- }
strcat(tokens[i], ".partition");
}
- ret = virCgroupPartitionEscape(&(tokens[i]));
- if (ret < 0) {
+ if (virCgroupPartitionEscape(&(tokens[i])) < 0)
goto cleanup;
- }
}
- if (!(*res = virStringJoin((const char **)tokens, "/"))) {
- ret = -ENOMEM;
+ if (!(*res = virStringJoin((const char **)tokens, "/")))
goto cleanup;
- }
ret = 0;
* Creates a new cgroup to represent the resource
* partition path identified by @name.
*
- * Returns 0 on success, -errno on failure
+ * Returns 0 on success, -1 on failure
*/
int virCgroupNewPartition(const char *path,
bool create,
int controllers,
virCgroupPtr *group)
{
- int rc;
+ int ret = -1;
char *parentPath = NULL;
virCgroupPtr parent = NULL;
char *newpath = NULL;
VIR_DEBUG("path=%s create=%d controllers=%x",
path, create, controllers);
- if (path[0] != '/')
- return -EINVAL;
+ if (path[0] != '/') {
+ virReportError(VIR_ERR_INTERNAL_ERROR,
+ _("Partition path '%s' must start with '/'"),
+ path);
+ return -1;
+ }
- /* XXX convert all cgroups APIs to use error report
- * APIs instead of returning errno */
- rc = virCgroupSetPartitionSuffix(path, &newpath);
- if (rc < 0) {
- virResetLastError();
+ if (virCgroupSetPartitionSuffix(path, &newpath) < 0)
goto cleanup;
- }
- rc = virCgroupNew(newpath, NULL, controllers, group);
- if (rc != 0)
+ if (virCgroupNew(newpath, NULL, controllers, group) < 0)
goto cleanup;
if (STRNEQ(newpath, "/")) {
char *tmp;
- if (VIR_STRDUP_QUIET(parentPath, newpath) < 0) {
- rc = -ENOMEM;
+ if (VIR_STRDUP(parentPath, newpath) < 0)
goto cleanup;
- }
tmp = strrchr(parentPath, '/');
tmp++;
*tmp = '\0';
- rc = virCgroupNew(parentPath, NULL, controllers, &parent);
- if (rc != 0)
+ if (virCgroupNew(parentPath, NULL, controllers, &parent) < 0)
goto cleanup;
- rc = virCgroupMakeGroup(parent, *group, create, VIR_CGROUP_NONE);
- if (rc != 0) {
+ if (virCgroupMakeGroup(parent, *group, create, VIR_CGROUP_NONE) < 0) {
virCgroupRemove(*group);
goto cleanup;
}
}
+ ret = 0;
cleanup:
- if (rc != 0)
+ if (ret != 0)
virCgroupFree(group);
virCgroupFree(&parent);
VIR_FREE(parentPath);
VIR_FREE(newpath);
- return rc;
+ return ret;
}
#else
int virCgroupNewPartition(const char *path ATTRIBUTE_UNUSED,
int controllers ATTRIBUTE_UNUSED,
virCgroupPtr *group ATTRIBUTE_UNUSED)
{
- /* Claim no support */
- return -ENXIO;
+ virReportSystemError(ENXIO, "%s",
+ _("Control groups not supported on this platform"));
+ return -1;
}
#endif
* @name: name of this driver (e.g., xen, qemu, lxc)
* @group: Pointer to returned virCgroupPtr
*
- * Returns 0 on success
+ * Returns 0 on success, or -1 on error
*/
#if defined HAVE_MNTENT_H && defined HAVE_GETMNTENT_R
int virCgroupNewDriver(const char *name,
int controllers,
virCgroupPtr *group)
{
- int rc;
+ int ret = -1;
virCgroupPtr rootgrp = NULL;
- rc = virCgroupAppRoot(&rootgrp,
- create, controllers);
- if (rc != 0)
- goto out;
+ if (virCgroupAppRoot(&rootgrp,
+ create, controllers) < 0)
+ goto cleanup;
- rc = virCgroupNew(name, rootgrp, -1, group);
- if (rc == 0) {
- rc = virCgroupMakeGroup(rootgrp, *group, create, VIR_CGROUP_NONE);
- if (rc != 0) {
- virCgroupRemove(*group);
- virCgroupFree(group);
- }
+ if (virCgroupNew(name, rootgrp, -1, group) < 0)
+ goto cleanup;
+
+ if (virCgroupMakeGroup(rootgrp, *group, create, VIR_CGROUP_NONE) < 0) {
+ virCgroupRemove(*group);
+ virCgroupFree(group);
+ goto cleanup;
}
-out:
- virCgroupFree(&rootgrp);
- return rc;
+ ret = 0;
+
+cleanup:
+ virCgroupFree(&rootgrp);
+ return ret;
}
#else
int virCgroupNewDriver(const char *name ATTRIBUTE_UNUSED,
int controllers ATTRIBUTE_UNUSED,
virCgroupPtr *group ATTRIBUTE_UNUSED)
{
- /* Claim no support */
- return -ENXIO;
+ virReportSystemError(ENXIO, "%s",
+ _("Control groups not supported on this platform"));
+ return -1;
}
#endif
* Obtain a cgroup representing the config of the
* current process
*
-* Returns 0 on success
+* Returns 0 on success, or -1 on error
*/
#if defined HAVE_MNTENT_H && defined HAVE_GETMNTENT_R
int virCgroupNewSelf(virCgroupPtr *group)
#else
int virCgroupNewSelf(virCgroupPtr *group ATTRIBUTE_UNUSED)
{
- return -ENXIO;
+ virReportSystemError(ENXIO, "%s",
+ _("Control groups not supported on this platform"));
+ return -1;
}
#endif
* @name: name of the domain
* @group: Pointer to returned virCgroupPtr
*
- * Returns 0 on success
+ * Returns 0 on success, or -1 on error
*/
#if defined HAVE_MNTENT_H && defined HAVE_GETMNTENT_R
int virCgroupNewDomainDriver(virCgroupPtr driver,
bool create,
virCgroupPtr *group)
{
- int rc;
+ int ret = -1;
- rc = virCgroupNew(name, driver, -1, group);
-
- if (rc == 0) {
- /*
- * Create a cgroup with memory.use_hierarchy enabled to
- * surely account memory usage of lxc with ns subsystem
- * enabled. (To be exact, memory and ns subsystems are
- * enabled at the same time.)
- *
- * The reason why doing it here, not a upper group, say
- * a group for driver, is to avoid overhead to track
- * cumulative usage that we don't need.
- */
- rc = virCgroupMakeGroup(driver, *group, create, VIR_CGROUP_MEM_HIERACHY);
- if (rc != 0) {
- virCgroupRemove(*group);
- virCgroupFree(group);
- }
+ if (virCgroupNew(name, driver, -1, group) < 0)
+ goto cleanup;
+
+ /*
+ * Create a cgroup with memory.use_hierarchy enabled to
+ * surely account memory usage of lxc with ns subsystem
+ * enabled. (To be exact, memory and ns subsystems are
+ * enabled at the same time.)
+ *
+ * The reason why doing it here, not a upper group, say
+ * a group for driver, is to avoid overhead to track
+ * cumulative usage that we don't need.
+ */
+ if (virCgroupMakeGroup(driver, *group, create, VIR_CGROUP_MEM_HIERACHY) < 0) {
+ virCgroupRemove(*group);
+ virCgroupFree(group);
+ goto cleanup;
}
- return rc;
+ ret = 0;
+cleanup:
+ return ret;
}
#else
int virCgroupNewDomainDriver(virCgroupPtr driver ATTRIBUTE_UNUSED,
bool create ATTRIBUTE_UNUSED,
virCgroupPtr *group ATTRIBUTE_UNUSED)
{
- return -ENXIO;
+ virReportSystemError(ENXIO, "%s",
+ _("Control groups not supported on this platform"));
+ return -1;
}
#endif
* @name: name of the domain
* @group: Pointer to returned virCgroupPtr
*
- * Returns 0 on success
+ * Returns 0 on success, or -1 on error
*/
#if defined HAVE_MNTENT_H && defined HAVE_GETMNTENT_R
int virCgroupNewDomainPartition(virCgroupPtr partition,
bool create,
virCgroupPtr *group)
{
- int rc;
+ int ret = -1;
char *grpname = NULL;
if (virAsprintf(&grpname, "%s.libvirt-%s",
name, driver) < 0)
- return -ENOMEM;
+ goto cleanup;
- if ((rc = virCgroupPartitionEscape(&grpname)) < 0)
- return rc;
+ if (virCgroupPartitionEscape(&grpname) < 0)
+ goto cleanup;
- rc = virCgroupNew(grpname, partition, -1, group);
-
- if (rc == 0) {
- /*
- * Create a cgroup with memory.use_hierarchy enabled to
- * surely account memory usage of lxc with ns subsystem
- * enabled. (To be exact, memory and ns subsystems are
- * enabled at the same time.)
- *
- * The reason why doing it here, not a upper group, say
- * a group for driver, is to avoid overhead to track
- * cumulative usage that we don't need.
- */
- rc = virCgroupMakeGroup(partition, *group, create, VIR_CGROUP_MEM_HIERACHY);
- if (rc != 0) {
- virCgroupRemove(*group);
- virCgroupFree(group);
- }
+ if (virCgroupNew(grpname, partition, -1, group) < 0)
+ goto cleanup;
+
+ /*
+ * Create a cgroup with memory.use_hierarchy enabled to
+ * surely account memory usage of lxc with ns subsystem
+ * enabled. (To be exact, memory and ns subsystems are
+ * enabled at the same time.)
+ *
+ * The reason why doing it here, not a upper group, say
+ * a group for driver, is to avoid overhead to track
+ * cumulative usage that we don't need.
+ */
+ if (virCgroupMakeGroup(partition, *group, create, VIR_CGROUP_MEM_HIERACHY) < 0) {
+ virCgroupRemove(*group);
+ virCgroupFree(group);
+ goto cleanup;
}
+ ret = 0;
+
+cleanup:
VIR_FREE(grpname);
- return rc;
+ return ret;
}
#else
int virCgroupNewDomainPartition(virCgroupPtr partition ATTRIBUTE_UNUSED,
bool create ATTRIBUTE_UNUSED,
virCgroupPtr *group ATTRIBUTE_UNUSED)
{
- return -ENXIO;
+ virReportSystemError(ENXIO, "%s",
+ _("Control groups not supported on this platform"));
+ return -1;
}
#endif
* @create: true to create if not already existing
* @group: Pointer to returned virCgroupPtr
*
- * Returns 0 on success
+ * Returns 0 on success, or -1 on error
*/
#if defined HAVE_MNTENT_H && defined HAVE_GETMNTENT_R
int virCgroupNewVcpu(virCgroupPtr domain,
bool create,
virCgroupPtr *group)
{
- int rc;
- char *name;
+ int ret = -1;
+ char *name = NULL;
int controllers;
if (virAsprintf(&name, "vcpu%d", vcpuid) < 0)
- return -ENOMEM;
+ goto cleanup;
controllers = ((1 << VIR_CGROUP_CONTROLLER_CPU) |
(1 << VIR_CGROUP_CONTROLLER_CPUACCT) |
(1 << VIR_CGROUP_CONTROLLER_CPUSET));
- rc = virCgroupNew(name, domain, controllers, group);
- VIR_FREE(name);
+ if (virCgroupNew(name, domain, controllers, group) < 0)
+ goto cleanup;
- if (rc == 0) {
- rc = virCgroupMakeGroup(domain, *group, create, VIR_CGROUP_NONE);
- if (rc != 0) {
- virCgroupRemove(*group);
- virCgroupFree(group);
- }
+ if (virCgroupMakeGroup(domain, *group, create, VIR_CGROUP_NONE) < 0) {
+ virCgroupRemove(*group);
+ virCgroupFree(group);
+ goto cleanup;
}
- return rc;
+ ret = 0;
+cleanup:
+ VIR_FREE(name);
+ return ret;
}
#else
int virCgroupNewVcpu(virCgroupPtr domain ATTRIBUTE_UNUSED,
bool create ATTRIBUTE_UNUSED,
virCgroupPtr *group ATTRIBUTE_UNUSED)
{
- return -ENXIO;
+ virReportSystemError(ENXIO, "%s",
+ _("Control groups not supported on this platform"));
+ return -1;
}
#endif
* @create: true to create if not already existing
* @group: Pointer to returned virCgroupPtr
*
- * Returns: 0 on success or -errno on failure
+ * Returns: 0 on success or -1 on error
*/
#if defined HAVE_MNTENT_H && defined HAVE_GETMNTENT_R
int virCgroupNewEmulator(virCgroupPtr domain,
bool create,
virCgroupPtr *group)
{
- int rc;
+ int ret = -1;
int controllers;
controllers = ((1 << VIR_CGROUP_CONTROLLER_CPU) |
(1 << VIR_CGROUP_CONTROLLER_CPUACCT) |
(1 << VIR_CGROUP_CONTROLLER_CPUSET));
- rc = virCgroupNew("emulator", domain, controllers, group);
+ if (virCgroupNew("emulator", domain, controllers, group) < 0)
+ goto cleanup;
- if (rc == 0) {
- rc = virCgroupMakeGroup(domain, *group, create, VIR_CGROUP_NONE);
- if (rc != 0) {
- virCgroupRemove(*group);
- virCgroupFree(group);
- }
+ if (virCgroupMakeGroup(domain, *group, create, VIR_CGROUP_NONE) < 0) {
+ virCgroupRemove(*group);
+ virCgroupFree(group);
+ goto cleanup;
}
- return rc;
+ ret = 0;
+cleanup:
+ return ret;
}
#else
int virCgroupNewEmulator(virCgroupPtr domain ATTRIBUTE_UNUSED,
bool create ATTRIBUTE_UNUSED,
virCgroupPtr *group ATTRIBUTE_UNUSED)
{
- return -ENXIO;
+ virReportSystemError(ENXIO, "%s",
+ _("Control groups not supported on this platform"));
+ return -1;
}
#endif
+
+bool virCgroupNewIgnoreError(void)
+{
+ if (virLastErrorIsSystemErrno(ENXIO) ||
+ virLastErrorIsSystemErrno(EPERM) ||
+ virLastErrorIsSystemErrno(EACCES)) {
+ virResetLastError();
+ VIR_DEBUG("No cgroups present/configured/accessible, ignoring error");
+ return true;
+ }
+ return false;
+}
+
/**
* virCgroupSetBlkioWeight:
*
VIR_DEBUG("Process subdir %s", ent->d_name);
- if ((rc = virCgroupNew(ent->d_name, group, -1, &subgroup)) != 0)
+ if (virCgroupNew(ent->d_name, group, -1, &subgroup) < 0) {
+ virErrorSetErrnoFromLastError();
+ rc = -errno;
goto cleanup;
+ }
if ((rc = virCgroupKillRecursiveInternal(subgroup, signum, pids, true)) < 0)
goto cleanup;
}
+# define ENSURE_ERRNO(en) \
+ do { \
+ if (!virLastErrorIsSystemErrno(en)) { \
+ virErrorPtr err = virGetLastError(); \
+ fprintf(stderr, "Did not get " #en " error code: %d:%d\n", \
+ err ? err->code : 0, err ? err->int1 : 0); \
+ goto cleanup; \
+ } } while (0)
+
+ /* Asking for impossible combination since CPU is co-mounted */
+
+
static int testCgroupNewForDriver(const void *args ATTRIBUTE_UNUSED)
{
virCgroupPtr cgroup = NULL;
[VIR_CGROUP_CONTROLLER_BLKIO] = "/libvirt/lxc",
};
- if ((rv = virCgroupNewDriver("lxc", false, -1, &cgroup)) != -ENOENT) {
+ if ((rv = virCgroupNewDriver("lxc", false, -1, &cgroup)) != -1) {
fprintf(stderr, "Unexpected found LXC cgroup: %d\n", -rv);
goto cleanup;
}
+ ENSURE_ERRNO(ENOENT);
- /* Asking for impossible combination since CPU is co-mounted */
if ((rv = virCgroupNewDriver("lxc", true,
(1 << VIR_CGROUP_CONTROLLER_CPU),
- &cgroup)) != -EINVAL) {
+ &cgroup)) != -1) {
fprintf(stderr, "Should not have created LXC cgroup: %d\n", -rv);
goto cleanup;
}
+ ENSURE_ERRNO(EINVAL);
/* Asking for impossible combination since devices is not mounted */
if ((rv = virCgroupNewDriver("lxc", true,
(1 << VIR_CGROUP_CONTROLLER_DEVICES),
- &cgroup)) != -ENXIO) {
+ &cgroup)) != -1) {
fprintf(stderr, "Should not have created LXC cgroup: %d\n", -rv);
goto cleanup;
}
+ ENSURE_ERRNO(ENXIO);
/* Asking for small combination since devices is not mounted */
if ((rv = virCgroupNewDriver("lxc", true,
[VIR_CGROUP_CONTROLLER_BLKIO] = "/virtualmachines.partition",
};
- if ((rv = virCgroupNewPartition("/virtualmachines", false, -1, &cgroup)) != -ENOENT) {
+ if ((rv = virCgroupNewPartition("/virtualmachines", false, -1, &cgroup)) != -1) {
fprintf(stderr, "Unexpected found /virtualmachines cgroup: %d\n", -rv);
goto cleanup;
}
+ ENSURE_ERRNO(ENOENT);
/* Asking for impossible combination since CPU is co-mounted */
if ((rv = virCgroupNewPartition("/virtualmachines", true,
(1 << VIR_CGROUP_CONTROLLER_CPU),
- &cgroup)) != -EINVAL) {
+ &cgroup)) != -1) {
fprintf(stderr, "Should not have created /virtualmachines cgroup: %d\n", -rv);
goto cleanup;
}
+ ENSURE_ERRNO(EINVAL);
/* Asking for impossible combination since devices is not mounted */
if ((rv = virCgroupNewPartition("/virtualmachines", true,
(1 << VIR_CGROUP_CONTROLLER_DEVICES),
- &cgroup)) != -ENXIO) {
+ &cgroup)) != -1) {
fprintf(stderr, "Should not have created /virtualmachines cgroup: %d\n", -rv);
goto cleanup;
}
+ ENSURE_ERRNO(ENXIO);
/* Asking for small combination since devices is not mounted */
if ((rv = virCgroupNewPartition("/virtualmachines", true,
[VIR_CGROUP_CONTROLLER_BLKIO] = "/deployment.partition/production.partition",
};
- if ((rv = virCgroupNewPartition("/deployment/production", false, -1, &cgroup)) != -ENOENT) {
+ if ((rv = virCgroupNewPartition("/deployment/production", false, -1, &cgroup)) != -1) {
fprintf(stderr, "Unexpected found /deployment/production cgroup: %d\n", -rv);
goto cleanup;
}
+ ENSURE_ERRNO(ENOENT);
/* Should not work, since we require /deployment to be pre-created */
- if ((rv = virCgroupNewPartition("/deployment/production", true, -1, &cgroup)) != -ENOENT) {
+ if ((rv = virCgroupNewPartition("/deployment/production", true, -1, &cgroup)) != -1) {
fprintf(stderr, "Unexpected created /deployment/production cgroup: %d\n", -rv);
goto cleanup;
}
+ ENSURE_ERRNO(ENOENT);
if ((rv = virCgroupNewPartition("/deployment", true, -1, &cgroup)) != 0) {
fprintf(stderr, "Failed to create /deployment cgroup: %d\n", -rv);
[VIR_CGROUP_CONTROLLER_BLKIO] = "/user/berrange.user/production.partition",
};
- if ((rv = virCgroupNewPartition("/user/berrange.user/production", false, -1, &cgroup)) != -ENOENT) {
+ if ((rv = virCgroupNewPartition("/user/berrange.user/production", false, -1, &cgroup)) != -1) {
fprintf(stderr, "Unexpected found /user/berrange.user/production cgroup: %d\n", -rv);
goto cleanup;
}
+ ENSURE_ERRNO(ENOENT);
/* Should not work, since we require /user/berrange.user to be pre-created */
- if ((rv = virCgroupNewPartition("/user/berrange.user/production", true, -1, &cgroup)) != -ENOENT) {
+ if ((rv = virCgroupNewPartition("/user/berrange.user/production", true, -1, &cgroup)) != -1) {
fprintf(stderr, "Unexpected created /user/berrange.user/production cgroup: %d\n", -rv);
goto cleanup;
}
+ ENSURE_ERRNO(ENOENT);
if ((rv = virCgroupNewPartition("/user", true, -1, &cgroup)) != 0) {
fprintf(stderr, "Failed to create /user/berrange.user cgroup: %d\n", -rv);
projects / libvirt.git / commitdiff