[PATCH 1/3] qemuDomainAttachDeviceLive: Rework event emitting

Michal Privoznik mprivozn at redhat.com
Wed May 20 08:01:38 UTC 2020


Some devices that we want to emit event for do not have an alias.
Rework event emitting to make code more generic.

Signed-off-by: Michal Privoznik <mprivozn at redhat.com>
---
 src/qemu/qemu_driver.c | 36 ++++++++++++++++--------------------
 1 file changed, 16 insertions(+), 20 deletions(-)

diff --git a/src/qemu/qemu_driver.c b/src/qemu/qemu_driver.c
index db65862163..83674169c2 100644
--- a/src/qemu/qemu_driver.c
+++ b/src/qemu/qemu_driver.c
@@ -7828,15 +7828,15 @@ qemuDomainAttachDeviceLive(virDomainObjPtr vm,
                            virDomainDeviceDefPtr dev,
                            virQEMUDriverPtr driver)
 {
+    virObjectEventPtr event = NULL;
     int ret = -1;
-    const char *alias = NULL;
 
     switch ((virDomainDeviceType)dev->type) {
     case VIR_DOMAIN_DEVICE_DISK:
         qemuDomainObjCheckDiskTaint(driver, vm, dev->data.disk, NULL);
         ret = qemuDomainAttachDeviceDiskLive(driver, vm, dev);
         if (!ret) {
-            alias = dev->data.disk->info.alias;
+            event = virDomainEventDeviceAddedNewFromObj(vm, dev->data.disk->info.alias);
             dev->data.disk = NULL;
         }
         break;
@@ -7844,7 +7844,7 @@ qemuDomainAttachDeviceLive(virDomainObjPtr vm,
     case VIR_DOMAIN_DEVICE_CONTROLLER:
         ret = qemuDomainAttachControllerDevice(driver, vm, dev->data.controller);
         if (!ret) {
-            alias = dev->data.controller->info.alias;
+            event = virDomainEventDeviceAddedNewFromObj(vm, dev->data.controller->info.alias);
             dev->data.controller = NULL;
         }
         break;
@@ -7860,7 +7860,7 @@ qemuDomainAttachDeviceLive(virDomainObjPtr vm,
         qemuDomainObjCheckNetTaint(driver, vm, dev->data.net, NULL);
         ret = qemuDomainAttachNetDevice(driver, vm, dev->data.net);
         if (!ret) {
-            alias = dev->data.net->info.alias;
+            event = virDomainEventDeviceAddedNewFromObj(vm, dev->data.net->info.alias);
             dev->data.net = NULL;
         }
         break;
@@ -7870,7 +7870,7 @@ qemuDomainAttachDeviceLive(virDomainObjPtr vm,
         ret = qemuDomainAttachHostDevice(driver, vm,
                                          dev->data.hostdev);
         if (!ret) {
-            alias = dev->data.hostdev->info->alias;
+            event = virDomainEventDeviceAddedNewFromObj(vm, dev->data.hostdev->info->alias);
             dev->data.hostdev = NULL;
         }
         break;
@@ -7879,7 +7879,7 @@ qemuDomainAttachDeviceLive(virDomainObjPtr vm,
         ret = qemuDomainAttachRedirdevDevice(driver, vm,
                                              dev->data.redirdev);
         if (!ret) {
-            alias = dev->data.redirdev->info.alias;
+            event = virDomainEventDeviceAddedNewFromObj(vm, dev->data.redirdev->info.alias);
             dev->data.redirdev = NULL;
         }
         break;
@@ -7888,7 +7888,7 @@ qemuDomainAttachDeviceLive(virDomainObjPtr vm,
         ret = qemuDomainAttachChrDevice(driver, vm,
                                         dev->data.chr);
         if (!ret) {
-            alias = dev->data.chr->info.alias;
+            event = virDomainEventDeviceAddedNewFromObj(vm, dev->data.chr->info.alias);
             dev->data.chr = NULL;
         }
         break;
@@ -7897,7 +7897,7 @@ qemuDomainAttachDeviceLive(virDomainObjPtr vm,
         ret = qemuDomainAttachRNGDevice(driver, vm,
                                         dev->data.rng);
         if (!ret) {
-            alias = dev->data.rng->info.alias;
+            event = virDomainEventDeviceAddedNewFromObj(vm, dev->data.rng->info.alias);
             dev->data.rng = NULL;
         }
         break;
@@ -7914,7 +7914,7 @@ qemuDomainAttachDeviceLive(virDomainObjPtr vm,
         ret = qemuDomainAttachShmemDevice(driver, vm,
                                           dev->data.shmem);
         if (!ret) {
-            alias = dev->data.shmem->info.alias;
+            event = virDomainEventDeviceAddedNewFromObj(vm, dev->data.shmem->info.alias);
             dev->data.shmem = NULL;
         }
         break;
@@ -7923,7 +7923,7 @@ qemuDomainAttachDeviceLive(virDomainObjPtr vm,
         ret = qemuDomainAttachWatchdog(driver, vm,
                                        dev->data.watchdog);
         if (!ret) {
-            alias = dev->data.watchdog->info.alias;
+            event = virDomainEventDeviceAddedNewFromObj(vm, dev->data.watchdog->info.alias);
             dev->data.watchdog = NULL;
         }
         break;
@@ -7931,7 +7931,7 @@ qemuDomainAttachDeviceLive(virDomainObjPtr vm,
     case VIR_DOMAIN_DEVICE_INPUT:
         ret = qemuDomainAttachInputDevice(driver, vm, dev->data.input);
         if (ret == 0) {
-            alias = dev->data.input->info.alias;
+            event = virDomainEventDeviceAddedNewFromObj(vm, dev->data.input->info.alias);
             dev->data.input = NULL;
         }
         break;
@@ -7939,7 +7939,7 @@ qemuDomainAttachDeviceLive(virDomainObjPtr vm,
     case VIR_DOMAIN_DEVICE_VSOCK:
         ret = qemuDomainAttachVsockDevice(driver, vm, dev->data.vsock);
         if (ret == 0) {
-            alias = dev->data.vsock->info.alias;
+            event = virDomainEventDeviceAddedNewFromObj(vm, dev->data.vsock->info.alias);
             dev->data.vsock = NULL;
         }
         break;
@@ -7963,14 +7963,10 @@ qemuDomainAttachDeviceLive(virDomainObjPtr vm,
         break;
     }
 
-    if (alias) {
-        /* queue the event before the alias has a chance to get freed
-         * if the domain disappears while qemuDomainUpdateDeviceList
-         * is in monitor */
-        virObjectEventPtr event;
-        event = virDomainEventDeviceAddedNewFromObj(vm, alias);
-        virObjectEventStateQueue(driver->domainEventState, event);
-    }
+    /* queue the event before the alias has a chance to get freed
+     * if the domain disappears while qemuDomainUpdateDeviceList
+     * is in monitor */
+    virObjectEventStateQueue(driver->domainEventState, event);
 
     if (ret == 0)
         ret = qemuDomainUpdateDeviceList(driver, vm, QEMU_ASYNC_JOB_NONE);
-- 
2.26.2




More information about the libvir-list mailing list