提交 333fd2bd 编写于 作者: S Seeteena Thoufeek 提交者: Michal Privoznik

qemu_cgroup.c: use VIR_AUTOSTRINGLIST, g_autofree and g_autoptr

Signed-off-by: NSeeteena Thoufeek <s1seetee@linux.vnet.ibm.com>
Signed-off-by: NMichal Privoznik <mprivozn@redhat.com>
Reviewed-by: NMichal Privoznik <mprivozn@redhat.com>
Reviewed-by: NDaniel Henrique Barboza <danielhb413@gmail.com>
上级 89bbe9bb
...@@ -62,10 +62,9 @@ qemuSetupImagePathCgroup(virDomainObjPtr vm, ...@@ -62,10 +62,9 @@ qemuSetupImagePathCgroup(virDomainObjPtr vm,
{ {
qemuDomainObjPrivatePtr priv = vm->privateData; qemuDomainObjPrivatePtr priv = vm->privateData;
int perms = VIR_CGROUP_DEVICE_READ; int perms = VIR_CGROUP_DEVICE_READ;
char **targetPaths = NULL; VIR_AUTOSTRINGLIST targetPaths = NULL;
size_t i; size_t i;
int rv; int rv;
int ret = -1;
if (!virCgroupHasController(priv->cgroup, VIR_CGROUP_CONTROLLER_DEVICES)) if (!virCgroupHasController(priv->cgroup, VIR_CGROUP_CONTROLLER_DEVICES))
return 0; return 0;
...@@ -82,12 +81,11 @@ qemuSetupImagePathCgroup(virDomainObjPtr vm, ...@@ -82,12 +81,11 @@ qemuSetupImagePathCgroup(virDomainObjPtr vm,
virCgroupGetDevicePermsString(perms), virCgroupGetDevicePermsString(perms),
rv); rv);
if (rv < 0) if (rv < 0)
goto cleanup; return -1;
if (rv > 0) { if (rv > 0) {
/* @path is neither character device nor block device. */ /* @path is neither character device nor block device. */
ret = 0; return 0;
goto cleanup;
} }
if (virDevMapperGetTargets(path, &targetPaths) < 0 && if (virDevMapperGetTargets(path, &targetPaths) < 0 &&
...@@ -95,7 +93,7 @@ qemuSetupImagePathCgroup(virDomainObjPtr vm, ...@@ -95,7 +93,7 @@ qemuSetupImagePathCgroup(virDomainObjPtr vm,
virReportSystemError(errno, virReportSystemError(errno,
_("Unable to get devmapper targets for %s"), _("Unable to get devmapper targets for %s"),
path); path);
goto cleanup; return -1;
} }
for (i = 0; targetPaths && targetPaths[i]; i++) { for (i = 0; targetPaths && targetPaths[i]; i++) {
...@@ -105,13 +103,10 @@ qemuSetupImagePathCgroup(virDomainObjPtr vm, ...@@ -105,13 +103,10 @@ qemuSetupImagePathCgroup(virDomainObjPtr vm,
virCgroupGetDevicePermsString(perms), virCgroupGetDevicePermsString(perms),
rv); rv);
if (rv < 0) if (rv < 0)
goto cleanup; return -1;
} }
ret = 0; return 0;
cleanup:
virStringListFree(targetPaths);
return ret;
} }
...@@ -739,10 +734,9 @@ static int ...@@ -739,10 +734,9 @@ static int
qemuSetupDevicesCgroup(virDomainObjPtr vm) qemuSetupDevicesCgroup(virDomainObjPtr vm)
{ {
qemuDomainObjPrivatePtr priv = vm->privateData; qemuDomainObjPrivatePtr priv = vm->privateData;
virQEMUDriverConfigPtr cfg = NULL; g_autoptr(virQEMUDriverConfig) cfg = virQEMUDriverGetConfig(priv->driver);
const char *const *deviceACL = NULL; const char *const *deviceACL = NULL;
int rv = -1; int rv = -1;
int ret = -1;
size_t i; size_t i;
if (!virCgroupHasController(priv->cgroup, VIR_CGROUP_CONTROLLER_DEVICES)) if (!virCgroupHasController(priv->cgroup, VIR_CGROUP_CONTROLLER_DEVICES))
...@@ -757,15 +751,15 @@ qemuSetupDevicesCgroup(virDomainObjPtr vm) ...@@ -757,15 +751,15 @@ qemuSetupDevicesCgroup(virDomainObjPtr vm)
return 0; return 0;
} }
goto cleanup; return -1;
} }
if (qemuSetupFirmwareCgroup(vm) < 0) if (qemuSetupFirmwareCgroup(vm) < 0)
goto cleanup; return -1;
for (i = 0; i < vm->def->ndisks; i++) { for (i = 0; i < vm->def->ndisks; i++) {
if (qemuSetupImageChainCgroup(vm, vm->def->disks[i]->src) < 0) if (qemuSetupImageChainCgroup(vm, vm->def->disks[i]->src) < 0)
goto cleanup; return -1;
} }
rv = virCgroupAllowDevice(priv->cgroup, 'c', DEVICE_PTY_MAJOR, -1, rv = virCgroupAllowDevice(priv->cgroup, 'c', DEVICE_PTY_MAJOR, -1,
...@@ -773,9 +767,8 @@ qemuSetupDevicesCgroup(virDomainObjPtr vm) ...@@ -773,9 +767,8 @@ qemuSetupDevicesCgroup(virDomainObjPtr vm)
virDomainAuditCgroupMajor(vm, priv->cgroup, "allow", DEVICE_PTY_MAJOR, virDomainAuditCgroupMajor(vm, priv->cgroup, "allow", DEVICE_PTY_MAJOR,
"pty", "rw", rv == 0); "pty", "rw", rv == 0);
if (rv < 0) if (rv < 0)
goto cleanup; return -1;
cfg = virQEMUDriverGetConfig(priv->driver);
deviceACL = cfg->cgroupDeviceACL ? deviceACL = cfg->cgroupDeviceACL ?
(const char *const *)cfg->cgroupDeviceACL : (const char *const *)cfg->cgroupDeviceACL :
defaultDeviceACL; defaultDeviceACL;
...@@ -791,7 +784,7 @@ qemuSetupDevicesCgroup(virDomainObjPtr vm) ...@@ -791,7 +784,7 @@ qemuSetupDevicesCgroup(virDomainObjPtr vm)
virDomainAuditCgroupMajor(vm, priv->cgroup, "allow", DEVICE_SND_MAJOR, virDomainAuditCgroupMajor(vm, priv->cgroup, "allow", DEVICE_SND_MAJOR,
"sound", "rw", rv == 0); "sound", "rw", rv == 0);
if (rv < 0) if (rv < 0)
goto cleanup; return -1;
} }
for (i = 0; deviceACL[i] != NULL; i++) { for (i = 0; deviceACL[i] != NULL; i++) {
...@@ -805,57 +798,54 @@ qemuSetupDevicesCgroup(virDomainObjPtr vm) ...@@ -805,57 +798,54 @@ qemuSetupDevicesCgroup(virDomainObjPtr vm)
virDomainAuditCgroupPath(vm, priv->cgroup, "allow", deviceACL[i], "rw", rv); virDomainAuditCgroupPath(vm, priv->cgroup, "allow", deviceACL[i], "rw", rv);
if (rv < 0 && if (rv < 0 &&
!virLastErrorIsSystemErrno(ENOENT)) !virLastErrorIsSystemErrno(ENOENT))
goto cleanup; return -1;
} }
if (virDomainChrDefForeach(vm->def, if (virDomainChrDefForeach(vm->def,
true, true,
qemuSetupChardevCgroupCB, qemuSetupChardevCgroupCB,
vm) < 0) vm) < 0)
goto cleanup; return -1;
if (vm->def->tpm && qemuSetupTPMCgroup(vm) < 0) if (vm->def->tpm && qemuSetupTPMCgroup(vm) < 0)
goto cleanup; return -1;
for (i = 0; i < vm->def->nhostdevs; i++) { for (i = 0; i < vm->def->nhostdevs; i++) {
/* This may allow /dev/vfio/vfio multiple times, but that /* This may allow /dev/vfio/vfio multiple times, but that
* is not a problem. Kernel will have only one record. */ * is not a problem. Kernel will have only one record. */
if (qemuSetupHostdevCgroup(vm, vm->def->hostdevs[i]) < 0) if (qemuSetupHostdevCgroup(vm, vm->def->hostdevs[i]) < 0)
goto cleanup; return -1;
} }
for (i = 0; i < vm->def->nmems; i++) { for (i = 0; i < vm->def->nmems; i++) {
if (qemuSetupMemoryDevicesCgroup(vm, vm->def->mems[i]) < 0) if (qemuSetupMemoryDevicesCgroup(vm, vm->def->mems[i]) < 0)
goto cleanup; return -1;
} }
for (i = 0; i < vm->def->ngraphics; i++) { for (i = 0; i < vm->def->ngraphics; i++) {
if (qemuSetupGraphicsCgroup(vm, vm->def->graphics[i]) < 0) if (qemuSetupGraphicsCgroup(vm, vm->def->graphics[i]) < 0)
goto cleanup; return -1;
} }
for (i = 0; i < vm->def->nvideos; i++) { for (i = 0; i < vm->def->nvideos; i++) {
if (qemuSetupVideoCgroup(vm, vm->def->videos[i]) < 0) if (qemuSetupVideoCgroup(vm, vm->def->videos[i]) < 0)
goto cleanup; return -1;
} }
for (i = 0; i < vm->def->ninputs; i++) { for (i = 0; i < vm->def->ninputs; i++) {
if (qemuSetupInputCgroup(vm, vm->def->inputs[i]) < 0) if (qemuSetupInputCgroup(vm, vm->def->inputs[i]) < 0)
goto cleanup; return -1;
} }
for (i = 0; i < vm->def->nrngs; i++) { for (i = 0; i < vm->def->nrngs; i++) {
if (qemuSetupRNGCgroup(vm, vm->def->rngs[i]) < 0) if (qemuSetupRNGCgroup(vm, vm->def->rngs[i]) < 0)
goto cleanup; return -1;
} }
if (vm->def->sev && qemuSetupSEVCgroup(vm) < 0) if (vm->def->sev && qemuSetupSEVCgroup(vm) < 0)
goto cleanup; return -1;
ret = 0; return 0;
cleanup:
virObjectUnref(cfg);
return ret;
} }
...@@ -922,15 +912,14 @@ qemuInitCgroup(virDomainObjPtr vm, ...@@ -922,15 +912,14 @@ qemuInitCgroup(virDomainObjPtr vm,
size_t nnicindexes, size_t nnicindexes,
int *nicindexes) int *nicindexes)
{ {
int ret = -1;
qemuDomainObjPrivatePtr priv = vm->privateData; qemuDomainObjPrivatePtr priv = vm->privateData;
virQEMUDriverConfigPtr cfg = virQEMUDriverGetConfig(priv->driver); g_autoptr(virQEMUDriverConfig) cfg = virQEMUDriverGetConfig(priv->driver);
if (!virQEMUDriverIsPrivileged(priv->driver)) if (!virQEMUDriverIsPrivileged(priv->driver))
goto done; return 0;
if (!virCgroupAvailable()) if (!virCgroupAvailable())
goto done; return 0;
virCgroupFree(&priv->cgroup); virCgroupFree(&priv->cgroup);
...@@ -938,7 +927,7 @@ qemuInitCgroup(virDomainObjPtr vm, ...@@ -938,7 +927,7 @@ qemuInitCgroup(virDomainObjPtr vm,
virDomainResourceDefPtr res; virDomainResourceDefPtr res;
if (VIR_ALLOC(res) < 0) if (VIR_ALLOC(res) < 0)
goto cleanup; return -1;
res->partition = g_strdup("/machine"); res->partition = g_strdup("/machine");
...@@ -949,7 +938,7 @@ qemuInitCgroup(virDomainObjPtr vm, ...@@ -949,7 +938,7 @@ qemuInitCgroup(virDomainObjPtr vm,
virReportError(VIR_ERR_CONFIG_UNSUPPORTED, virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
_("Resource partition '%s' must start with '/'"), _("Resource partition '%s' must start with '/'"),
vm->def->resource->partition); vm->def->resource->partition);
goto cleanup; return -1;
} }
if (virCgroupNewMachine(priv->machineName, if (virCgroupNewMachine(priv->machineName,
...@@ -964,27 +953,23 @@ qemuInitCgroup(virDomainObjPtr vm, ...@@ -964,27 +953,23 @@ qemuInitCgroup(virDomainObjPtr vm,
cfg->maxThreadsPerProc, cfg->maxThreadsPerProc,
&priv->cgroup) < 0) { &priv->cgroup) < 0) {
if (virCgroupNewIgnoreError()) if (virCgroupNewIgnoreError())
goto done; return 0;
goto cleanup; return -1;
} }
done: return 0;
ret = 0;
cleanup:
virObjectUnref(cfg);
return ret;
} }
static void static void
qemuRestoreCgroupState(virDomainObjPtr vm) qemuRestoreCgroupState(virDomainObjPtr vm)
{ {
char *mem_mask = NULL; g_autofree char *mem_mask = NULL;
char *nodeset = NULL; g_autofree char *nodeset = NULL;
int empty = -1; int empty = -1;
qemuDomainObjPrivatePtr priv = vm->privateData; qemuDomainObjPrivatePtr priv = vm->privateData;
size_t i = 0; size_t i = 0;
virBitmapPtr all_nodes; g_autoptr(virBitmap) all_nodes = NULL;
virCgroupPtr cgroup_temp = NULL; virCgroupPtr cgroup_temp = NULL;
if (!virNumaIsAvailable() || if (!virNumaIsAvailable() ||
...@@ -1042,9 +1027,6 @@ qemuRestoreCgroupState(virDomainObjPtr vm) ...@@ -1042,9 +1027,6 @@ qemuRestoreCgroupState(virDomainObjPtr vm)
goto cleanup; goto cleanup;
cleanup: cleanup:
VIR_FREE(mem_mask);
VIR_FREE(nodeset);
virBitmapFree(all_nodes);
virCgroupFree(&cgroup_temp); virCgroupFree(&cgroup_temp);
return; return;
...@@ -1058,14 +1040,13 @@ int ...@@ -1058,14 +1040,13 @@ int
qemuConnectCgroup(virDomainObjPtr vm) qemuConnectCgroup(virDomainObjPtr vm)
{ {
qemuDomainObjPrivatePtr priv = vm->privateData; qemuDomainObjPrivatePtr priv = vm->privateData;
virQEMUDriverConfigPtr cfg = virQEMUDriverGetConfig(priv->driver); g_autoptr(virQEMUDriverConfig) cfg = virQEMUDriverGetConfig(priv->driver);
int ret = -1;
if (!virQEMUDriverIsPrivileged(priv->driver)) if (!virQEMUDriverIsPrivileged(priv->driver))
goto done; return 0;
if (!virCgroupAvailable()) if (!virCgroupAvailable())
goto done; return 0;
virCgroupFree(&priv->cgroup); virCgroupFree(&priv->cgroup);
...@@ -1075,15 +1056,10 @@ qemuConnectCgroup(virDomainObjPtr vm) ...@@ -1075,15 +1056,10 @@ qemuConnectCgroup(virDomainObjPtr vm)
cfg->cgroupControllers, cfg->cgroupControllers,
priv->machineName, priv->machineName,
&priv->cgroup) < 0) &priv->cgroup) < 0)
goto cleanup; return -1;
qemuRestoreCgroupState(vm); qemuRestoreCgroupState(vm);
return 0;
done:
ret = 0;
cleanup:
virObjectUnref(cfg);
return ret;
} }
int int
...@@ -1180,7 +1156,7 @@ qemuSetupGlobalCpuCgroup(virDomainObjPtr vm) ...@@ -1180,7 +1156,7 @@ qemuSetupGlobalCpuCgroup(virDomainObjPtr vm)
qemuDomainObjPrivatePtr priv = vm->privateData; qemuDomainObjPrivatePtr priv = vm->privateData;
unsigned long long period = vm->def->cputune.global_period; unsigned long long period = vm->def->cputune.global_period;
long long quota = vm->def->cputune.global_quota; long long quota = vm->def->cputune.global_quota;
char *mem_mask = NULL; g_autofree char *mem_mask = NULL;
virDomainNumatuneMemMode mem_mode; virDomainNumatuneMemMode mem_mode;
if ((period || quota) && if ((period || quota) &&
...@@ -1205,21 +1181,14 @@ qemuSetupGlobalCpuCgroup(virDomainObjPtr vm) ...@@ -1205,21 +1181,14 @@ qemuSetupGlobalCpuCgroup(virDomainObjPtr vm)
virDomainNumatuneMaybeFormatNodeset(vm->def->numa, virDomainNumatuneMaybeFormatNodeset(vm->def->numa,
priv->autoNodeset, priv->autoNodeset,
&mem_mask, -1) < 0) &mem_mask, -1) < 0)
goto cleanup; return -1;
if (period || quota) { if (period || quota) {
if (qemuSetupCgroupVcpuBW(priv->cgroup, period, quota) < 0) if (qemuSetupCgroupVcpuBW(priv->cgroup, period, quota) < 0)
goto cleanup; return -1;
} }
VIR_FREE(mem_mask);
return 0; return 0;
cleanup:
VIR_FREE(mem_mask);
return -1;
} }
...@@ -1269,8 +1238,8 @@ qemuCgroupEmulatorAllNodesAllow(virCgroupPtr cgroup, ...@@ -1269,8 +1238,8 @@ qemuCgroupEmulatorAllNodesAllow(virCgroupPtr cgroup,
qemuCgroupEmulatorAllNodesDataPtr *retData) qemuCgroupEmulatorAllNodesDataPtr *retData)
{ {
qemuCgroupEmulatorAllNodesDataPtr data = NULL; qemuCgroupEmulatorAllNodesDataPtr data = NULL;
char *all_nodes_str = NULL; g_autofree char *all_nodes_str = NULL;
virBitmapPtr all_nodes = NULL; g_autoptr(virBitmap) all_nodes = NULL;
int ret = -1; int ret = -1;
if (!virNumaIsAvailable() || if (!virNumaIsAvailable() ||
...@@ -1298,8 +1267,6 @@ qemuCgroupEmulatorAllNodesAllow(virCgroupPtr cgroup, ...@@ -1298,8 +1267,6 @@ qemuCgroupEmulatorAllNodesAllow(virCgroupPtr cgroup,
ret = 0; ret = 0;
cleanup: cleanup:
VIR_FREE(all_nodes_str);
virBitmapFree(all_nodes);
qemuCgroupEmulatorAllNodesDataFree(data); qemuCgroupEmulatorAllNodesDataFree(data);
return ret; return ret;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册