render / rpms / libvirt

Forked from rpms/libvirt 7 months ago
Clone
735c6b
From 0fe11b92a8278ffab202033a61340649b0296368 Mon Sep 17 00:00:00 2001
735c6b
Message-Id: <0fe11b92a8278ffab202033a61340649b0296368@dist-git>
735c6b
From: Peter Krempa <pkrempa@redhat.com>
735c6b
Date: Tue, 31 Jan 2023 15:30:51 +0100
735c6b
Subject: [PATCH] qemu: domain: Store fdset ID for disks passed to qemu via FD
735c6b
735c6b
To ensure that we can hot-unplug the disk including the associated fdset
735c6b
we need to store the fdset ID in the status XML.
735c6b
735c6b
Signed-off-by: Peter Krempa <pkrempa@redhat.com>
735c6b
Reviewed-by: Martin Kletzander <mkletzan@redhat.com>
735c6b
(cherry picked from commit f730b1e4f203cbabe363aab246d8a1679063f756)
735c6b
735c6b
https://bugzilla.redhat.com/show_bug.cgi?id=2040272
735c6b
---
735c6b
 src/qemu/qemu_domain.c                    | 17 ++++++++++++++++-
735c6b
 tests/qemustatusxml2xmldata/modern-in.xml |  3 +++
735c6b
 2 files changed, 19 insertions(+), 1 deletion(-)
735c6b
735c6b
diff --git a/src/qemu/qemu_domain.c b/src/qemu/qemu_domain.c
735c6b
index 226d4d6dc1..247134672b 100644
735c6b
--- a/src/qemu/qemu_domain.c
735c6b
+++ b/src/qemu/qemu_domain.c
735c6b
@@ -1941,6 +1941,8 @@ qemuStorageSourcePrivateDataParse(xmlXPathContextPtr ctxt,
735c6b
     g_autofree char *httpcookiealias = NULL;
735c6b
     g_autofree char *tlskeyalias = NULL;
735c6b
     g_autofree char *thresholdEventWithIndex = NULL;
735c6b
+    bool fdsetPresent = false;
735c6b
+    unsigned int fdSetID;
735c6b
 
735c6b
     src->nodestorage = virXPathString("string(./nodenames/nodename[@type='storage']/@name)", ctxt);
735c6b
     src->nodeformat = virXPathString("string(./nodenames/nodename[@type='format']/@name)", ctxt);
735c6b
@@ -1957,7 +1959,9 @@ qemuStorageSourcePrivateDataParse(xmlXPathContextPtr ctxt,
735c6b
     httpcookiealias = virXPathString("string(./objects/secret[@type='httpcookie']/@alias)", ctxt);
735c6b
     tlskeyalias = virXPathString("string(./objects/secret[@type='tlskey']/@alias)", ctxt);
735c6b
 
735c6b
-    if (authalias || encalias || httpcookiealias || tlskeyalias) {
735c6b
+    fdsetPresent = virXPathUInt("string(./fdsets/fdset[@type='storage']/@id)", ctxt, &fdSetID) == 0;
735c6b
+
735c6b
+    if (authalias || encalias || httpcookiealias || tlskeyalias || fdsetPresent) {
735c6b
         if (!src->privateData &&
735c6b
             !(src->privateData = qemuDomainStorageSourcePrivateNew()))
735c6b
             return -1;
735c6b
@@ -1975,6 +1979,9 @@ qemuStorageSourcePrivateDataParse(xmlXPathContextPtr ctxt,
735c6b
 
735c6b
         if (qemuStorageSourcePrivateDataAssignSecinfo(&priv->tlsKeySecret, &tlskeyalias) < 0)
735c6b
             return -1;
735c6b
+
735c6b
+        if (fdsetPresent)
735c6b
+            priv->fdpass = qemuFDPassNewPassed(fdSetID);
735c6b
     }
735c6b
 
735c6b
     if (virStorageSourcePrivateDataParseRelPath(ctxt, src) < 0)
735c6b
@@ -2008,6 +2015,7 @@ qemuStorageSourcePrivateDataFormat(virStorageSource *src,
735c6b
     qemuDomainStorageSourcePrivate *srcPriv = QEMU_DOMAIN_STORAGE_SOURCE_PRIVATE(src);
735c6b
     g_auto(virBuffer) nodenamesChildBuf = VIR_BUFFER_INIT_CHILD(buf);
735c6b
     g_auto(virBuffer) objectsChildBuf = VIR_BUFFER_INIT_CHILD(buf);
735c6b
+    g_auto(virBuffer) fdsetsChildBuf = VIR_BUFFER_INIT_CHILD(buf);
735c6b
 
735c6b
     virBufferEscapeString(&nodenamesChildBuf, "<nodename type='storage' name='%s'/>\n", src->nodestorage);
735c6b
     virBufferEscapeString(&nodenamesChildBuf, "<nodename type='format' name='%s'/>\n", src->nodeformat);
735c6b
@@ -2025,10 +2033,15 @@ qemuStorageSourcePrivateDataFormat(virStorageSource *src,
735c6b
         return -1;
735c6b
 
735c6b
     if (srcPriv) {
735c6b
+        unsigned int fdSetID;
735c6b
+
735c6b
         qemuStorageSourcePrivateDataFormatSecinfo(&objectsChildBuf, srcPriv->secinfo, "auth");
735c6b
         qemuStorageSourcePrivateDataFormatSecinfo(&objectsChildBuf, srcPriv->encinfo, "encryption");
735c6b
         qemuStorageSourcePrivateDataFormatSecinfo(&objectsChildBuf, srcPriv->httpcookie, "httpcookie");
735c6b
         qemuStorageSourcePrivateDataFormatSecinfo(&objectsChildBuf, srcPriv->tlsKeySecret, "tlskey");
735c6b
+
735c6b
+        if (qemuFDPassIsPassed(srcPriv->fdpass, &fdSetID))
735c6b
+            virBufferAsprintf(&fdsetsChildBuf, "<fdset type='storage' id='%u'/>\n", fdSetID);
735c6b
     }
735c6b
 
735c6b
     if (src->tlsAlias)
735c6b
@@ -2036,6 +2049,8 @@ qemuStorageSourcePrivateDataFormat(virStorageSource *src,
735c6b
 
735c6b
     virXMLFormatElement(buf, "objects", NULL, &objectsChildBuf);
735c6b
 
735c6b
+    virXMLFormatElement(buf, "fdsets", NULL, &fdsetsChildBuf);
735c6b
+
735c6b
     if (src->thresholdEventWithIndex)
735c6b
         virBufferAddLit(buf, "<thresholdEvent indexUsed='yes'/>\n");
735c6b
 
735c6b
diff --git a/tests/qemustatusxml2xmldata/modern-in.xml b/tests/qemustatusxml2xmldata/modern-in.xml
735c6b
index 7759034f7a..f5beab722b 100644
735c6b
--- a/tests/qemustatusxml2xmldata/modern-in.xml
735c6b
+++ b/tests/qemustatusxml2xmldata/modern-in.xml
735c6b
@@ -341,6 +341,9 @@
735c6b
                 <secret type='tlskey' alias='tls-certificate-key-alias'/>
735c6b
                 <TLSx509 alias='transport-alias'/>
735c6b
               </objects>
735c6b
+              <fdsets>
735c6b
+                <fdset type='storage' id='1337'/>
735c6b
+              </fdsets>
735c6b
               <thresholdEvent indexUsed='yes'/>
735c6b
             </privateData>
735c6b
           </source>
735c6b
-- 
735c6b
2.39.1
735c6b