]> xenbits.xensource.com Git - libvirt.git/commitdiff
nodedev: Wait for device initialization in all public API callbacks
authorMichal Privoznik <mprivozn@redhat.com>
Tue, 13 Apr 2021 09:18:23 +0000 (11:18 +0200)
committerMichal Privoznik <mprivozn@redhat.com>
Wed, 14 Apr 2021 08:16:48 +0000 (10:16 +0200)
Although I have not experienced this in real life, there is a
possible race condition when creating new device, getting its XML
or parent or listing its capabilities.  If the nodedev driver is
still enumerating devices (in a separate thread) and one of
virNodeDeviceGetXMLDesc(), virNodeDeviceGetParent(),
virNodeDeviceNumOfCaps(), virNodeDeviceListCaps() or
virNodeDeviceCreate() is called then it can lead to spurious
results because the device enumeration thread is removing devices
from or adding them to the internal list of devices (among with
their states).

Therefore, wait for things to settle down before proceeding with
any of the APIs.

Signed-off-by: Michal Privoznik <mprivozn@redhat.com>
Reviewed-by: Erik Skultety <eskultet@redhat.com>
src/node_device/node_device_driver.c

index 5f8995172dc1fdc0d13bd4d5c78a5e0cacf3d93d..7aee8201e81b7305a0420e5abe692a67e3ac689c 100644 (file)
@@ -340,6 +340,9 @@ nodeDeviceGetXMLDesc(virNodeDevicePtr device,
 
     virCheckFlags(0, NULL);
 
+    if (nodeDeviceInitWait() < 0)
+        return NULL;
+
     if (!(obj = nodeDeviceObjFindByName(device->name)))
         return NULL;
     def = virNodeDeviceObjGetDef(obj);
@@ -368,6 +371,9 @@ nodeDeviceGetParent(virNodeDevicePtr device)
     virNodeDeviceDef *def;
     char *ret = NULL;
 
+    if (nodeDeviceInitWait() < 0)
+        return NULL;
+
     if (!(obj = nodeDeviceObjFindByName(device->name)))
         return NULL;
     def = virNodeDeviceObjGetDef(obj);
@@ -395,6 +401,9 @@ nodeDeviceNumOfCaps(virNodeDevicePtr device)
     virNodeDeviceDef *def;
     int ret = -1;
 
+    if (nodeDeviceInitWait() < 0)
+        return -1;
+
     if (!(obj = nodeDeviceObjFindByName(device->name)))
         return -1;
     def = virNodeDeviceObjGetDef(obj);
@@ -423,6 +432,9 @@ nodeDeviceListCaps(virNodeDevicePtr device,
     int ret = -1;
     size_t i = 0;
 
+    if (nodeDeviceInitWait() < 0)
+        return -1;
+
     if (!(obj = nodeDeviceObjFindByName(device->name)))
         return -1;
     def = virNodeDeviceObjGetDef(obj);
@@ -1399,6 +1411,9 @@ nodeDeviceCreate(virNodeDevice *device,
 
     virCheckFlags(0, -1);
 
+    if (nodeDeviceInitWait() < 0)
+        return -1;
+
     if (!(obj = nodeDeviceObjFindByName(device->name)))
         return -1;