From 01c8f66275e2125d5b71bb8e5bab49d0551c6d78 Mon Sep 17 00:00:00 2001 From: John Ferlan Date: Wed, 11 Mar 2015 16:22:33 -0400 Subject: [PATCH] Replace virDomainIOThreadsPinAdd with virDomainPinAdd This one is no longer necessary since the Vcpu and IOThreads API's share --- src/conf/domain_conf.c | 45 ---------------------------------------- src/conf/domain_conf.h | 6 ------ src/libvirt_private.syms | 1 - src/qemu/qemu_driver.c | 14 ++++++------- 4 files changed, 7 insertions(+), 59 deletions(-) diff --git a/src/conf/domain_conf.c b/src/conf/domain_conf.c index 097796b84b..a4026ca7bd 100644 --- a/src/conf/domain_conf.c +++ b/src/conf/domain_conf.c @@ -16875,51 +16875,6 @@ virDomainEmulatorPinDel(virDomainDefPtr def) return 0; } -int -virDomainIOThreadsPinAdd(virDomainPinDefPtr **iothreadspin_list, - size_t *niothreadspin, - unsigned char *cpumap, - int maplen, - unsigned int iothread_id) -{ - virDomainPinDefPtr iothreadpin = NULL; - - if (!iothreadspin_list) - return -1; - - iothreadpin = virDomainPinFind(*iothreadspin_list, - *niothreadspin, - iothread_id); - if (iothreadpin) { - iothreadpin->id = iothread_id; - virBitmapFree(iothreadpin->cpumask); - iothreadpin->cpumask = virBitmapNewData(cpumap, maplen); - if (!iothreadpin->cpumask) - return -1; - - return 0; - } - - /* No existing iothreadpin matches iothread_id, adding a new one */ - - if (VIR_ALLOC(iothreadpin) < 0) - goto error; - - iothreadpin->id = iothread_id; - iothreadpin->cpumask = virBitmapNewData(cpumap, maplen); - if (!iothreadpin->cpumask) - goto error; - - if (VIR_APPEND_ELEMENT(*iothreadspin_list, *niothreadspin, iothreadpin) < 0) - goto error; - - return 0; - - error: - virDomainPinDefFree(iothreadpin); - return -1; -} - void virDomainIOThreadsPinDel(virDomainDefPtr def, unsigned int iothread_id) diff --git a/src/conf/domain_conf.h b/src/conf/domain_conf.h index 8f5610a49c..49d83a226f 100644 --- a/src/conf/domain_conf.h +++ b/src/conf/domain_conf.h @@ -2571,12 +2571,6 @@ int virDomainEmulatorPinAdd(virDomainDefPtr def, int virDomainEmulatorPinDel(virDomainDefPtr def); -int virDomainIOThreadsPinAdd(virDomainPinDefPtr **iothreadspin_list, - size_t *niothreads, - unsigned char *cpumap, - int maplen, - unsigned int iothread_id); - void virDomainIOThreadsPinDel(virDomainDefPtr def, unsigned int iothread_id); diff --git a/src/libvirt_private.syms b/src/libvirt_private.syms index 0b50a4e0b3..9fe766ad6b 100644 --- a/src/libvirt_private.syms +++ b/src/libvirt_private.syms @@ -312,7 +312,6 @@ virDomainHubTypeToString; virDomainHypervTypeFromString; virDomainHypervTypeToString; virDomainInputDefFree; -virDomainIOThreadsPinAdd; virDomainIOThreadsPinDel; virDomainLeaseDefFree; virDomainLeaseIndex; diff --git a/src/qemu/qemu_driver.c b/src/qemu/qemu_driver.c index 5ec07f41b7..5c8d75b3d1 100644 --- a/src/qemu/qemu_driver.c +++ b/src/qemu/qemu_driver.c @@ -5997,8 +5997,8 @@ qemuDomainPinIOThread(virDomainPtr dom, newIOThreadsPinNum = 0; } - if (virDomainIOThreadsPinAdd(&newIOThreadsPin, &newIOThreadsPinNum, - cpumap, maplen, iothread_id) < 0) { + if (virDomainPinAdd(&newIOThreadsPin, &newIOThreadsPinNum, + cpumap, maplen, iothread_id) < 0) { virReportError(VIR_ERR_INTERNAL_ERROR, "%s", _("failed to update iothreadspin")); goto endjob; @@ -6069,11 +6069,11 @@ qemuDomainPinIOThread(virDomainPtr dom, goto endjob; persistentDef->cputune.niothreadspin = 0; } - if (virDomainIOThreadsPinAdd(&persistentDef->cputune.iothreadspin, - &persistentDef->cputune.niothreadspin, - cpumap, - maplen, - iothread_id) < 0) { + if (virDomainPinAdd(&persistentDef->cputune.iothreadspin, + &persistentDef->cputune.niothreadspin, + cpumap, + maplen, + iothread_id) < 0) { virReportError(VIR_ERR_INTERNAL_ERROR, "%s", _("failed to update or add iothreadspin xml " "of a persistent domain"));