<html xmlns:v="urn:schemas-microsoft-com:vml" xmlns:o="urn:schemas-microsoft-com:office:office" xmlns:w="urn:schemas-microsoft-com:office:word" xmlns:m="http://schemas.microsoft.com/office/2004/12/omml" xmlns="http://www.w3.org/TR/REC-html40"> <head> <meta http-equiv="Content-Type" content="text/html; charset=us-ascii"> <meta name="Generator" content="Microsoft Word 15 (filtered medium)"> <style></style> </head> <body lang="ZH-CN" link="#0563C1" vlink="#954F72" style="text-justify-trim:punctuation"> <div class="WordSection1"> Introduce a new virDomainReloadTLSCertificates API for notify domain<o:p></o:p> reload its certificates without restart, and avoid service interruption.<o:p></o:p> <o:p> </o:p> Take reload QEMU VNC TLS certificates as an example, we can call:<o:p></o:p> <o:p> </o:p> virDomainReloadTLSCertificates(dom, VIR_DOMAIN_TLS_CERT_GRAPHICS_VNC)<o:p></o:p> <o:p> </o:p> Then the specified QMP message would be send to QEMU:<o:p></o:p> {"execute": "display-reload", "arguments":{"type": "vnc", "tls-certs": true}}<o:p></o:p> <o:p> </o:p> Refers:<o:p></o:p> https://gitlab.com/qemu-project/qemu/-/commit/9cc07651655ee86eca41059f5ead8c4e5607c734<o:p></o:p> ---<o:p></o:p> include/libvirt/libvirt-domain.h | 17 ++++++++++++++++<o:p></o:p> src/driver-hypervisor.h | 5 +++++<o:p></o:p> src/libvirt-domain.c | 33 ++++++++++++++++++++++++++++++++<o:p></o:p> src/qemu/qemu_driver.c | 11 +++++++++++<o:p></o:p> src/qemu/qemu_hotplug.c | 21 ++++++++++++++++++++<o:p></o:p> src/qemu/qemu_hotplug.h | 4 ++++<o:p></o:p> src/qemu/qemu_monitor.c | 10 ++++++++++<o:p></o:p> src/qemu/qemu_monitor.h | 3 +++<o:p></o:p> src/qemu/qemu_monitor_json.c | 22 +++++++++++++++++++++<o:p></o:p> src/qemu/qemu_monitor_json.h | 3 +++<o:p></o:p> 10 files changed, 129 insertions(+)<o:p></o:p> <o:p> </o:p> diff --git a/include/libvirt/libvirt-domain.h b/include/libvirt/libvirt-domain.h<o:p></o:p> index e99bfb7654..aeb33d69d9 100644<o:p></o:p> --- a/include/libvirt/libvirt-domain.h<o:p></o:p> +++ b/include/libvirt/libvirt-domain.h<o:p></o:p> @@ -5152,4 +5152,21 @@ int virDomainStartDirtyRateCalc(virDomainPtr domain,<o:p></o:p> int seconds,<o:p></o:p> unsigned int flags);<o:p></o:p> <o:p></o:p> +/**<o:p></o:p> + * virDomainTLSCertificaType:<o:p></o:p> + *<o:p></o:p> + * the used scene of TLS certificates for doamin.<o:p></o:p> + */<o:p></o:p> +typedef enum {<o:p></o:p> + VIR_DOMAIN_TLS_CERT_GRAPHICS_VNC = 0,<o:p></o:p> + VIR_DOMAIN_TLS_CERT_GRAPHICS_SPICE = 1,<o:p></o:p> +<o:p></o:p> + VIR_DOMAIN_TLS_CERT_LAST<o:p></o:p> +} virDomainTLSCertificaType;<o:p></o:p> +<o:p></o:p> +int<o:p></o:p> +virDomainReloadTLSCertificates(virDomainPtr domain,<o:p></o:p> + unsigned int type);<o:p></o:p> +<o:p></o:p> +<o:p></o:p> #endif /* LIBVIRT_DOMAIN_H */<o:p></o:p> diff --git a/src/driver-hypervisor.h b/src/driver-hypervisor.h<o:p></o:p> index d642af8a37..8de2bc4137 100644<o:p></o:p> --- a/src/driver-hypervisor.h<o:p></o:p> +++ b/src/driver-hypervisor.h<o:p></o:p> @@ -1410,6 +1410,10 @@ typedef int<o:p></o:p> int seconds,<o:p></o:p> unsigned int flags);<o:p></o:p> <o:p></o:p> +typedef int<o:p></o:p> +(*virDrvDomainReloadTLSCertificates)(virDomainPtr domain,<o:p></o:p> + unsigned int type);<o:p></o:p> +<o:p></o:p> typedef struct _virHypervisorDriver virHypervisorDriver;<o:p></o:p> <o:p></o:p> /**<o:p></o:p> @@ -1676,4 +1680,5 @@ struct _virHypervisorDriver {<o:p></o:p> virDrvDomainAuthorizedSSHKeysSet domainAuthorizedSSHKeysSet;<o:p></o:p> virDrvDomainGetMessages domainGetMessages;<o:p></o:p> virDrvDomainStartDirtyRateCalc domainStartDirtyRateCalc;<o:p></o:p> + virDrvDomainReloadTLSCertificates domainiReloadTLSCertificates;<o:p></o:p> };<o:p></o:p> diff --git a/src/libvirt-domain.c b/src/libvirt-domain.c<o:p></o:p> index 42c75f6cc5..fb9e5ec2d1 100644<o:p></o:p> --- a/src/libvirt-domain.c<o:p></o:p> +++ b/src/libvirt-domain.c<o:p></o:p> @@ -13218,3 +13218,36 @@ virDomainStartDirtyRateCalc(virDomainPtr domain,<o:p></o:p> virDispatchError(conn);<o:p></o:p> return -1;<o:p></o:p> }<o:p></o:p> +<o:p></o:p> +/**<o:p></o:p> + * virDomainReloadTLSCertificates:<o:p></o:p> + * @domain: a domain object.<o:p></o:p> + * @type: a value of virDomainTLSCertificaType<o:p></o:p> + *<o:p></o:p> + * Notify domain reload its certificates with specified 'type'.<o:p></o:p> + *<o:p></o:p> + * Returns 0 in case of success, -1 otherwise .<o:p></o:p> + */<o:p></o:p> +int<o:p></o:p> +virDomainReloadTLSCertificates(virDomainPtr domain,<o:p></o:p> + unsigned int type)<o:p></o:p> +{<o:p></o:p> + virConnectPtr conn;<o:p></o:p> + VIR_DOMAIN_DEBUG(domain, "certificate type=%d", type);<o:p></o:p> + virResetLastError();<o:p></o:p> + virCheckDomainReturn(domain, -1);<o:p></o:p> + conn = domain->conn;<o:p></o:p> + if (type >= VIR_DOMAIN_TLS_CERT_LAST)<o:p></o:p> + goto error;<o:p></o:p> + if (conn->driver->domainiReloadTLSCertificates) {<o:p></o:p> + int ret;<o:p></o:p> + ret = conn->driver->domainiReloadTLSCertificates(domain, type);<o:p></o:p> + if (ret < 0)<o:p></o:p> + goto error;<o:p></o:p> + return ret;<o:p></o:p> + }<o:p></o:p> + virReportUnsupportedError();<o:p></o:p> + error:<o:p></o:p> + virDispatchError(domain->conn);<o:p></o:p> + return -1;<o:p></o:p> +}<o:p></o:p> diff --git a/src/qemu/qemu_driver.c b/src/qemu/qemu_driver.c<o:p></o:p> index c90d52edc0..61cd8cfa24 100644<o:p></o:p> --- a/src/qemu/qemu_driver.c<o:p></o:p> +++ b/src/qemu/qemu_driver.c<o:p></o:p> @@ -20449,6 +20449,16 @@ qemuDomainStartDirtyRateCalc(virDomainPtr dom,<o:p></o:p> return ret;<o:p></o:p> }<o:p></o:p> <o:p></o:p> +static int<o:p></o:p> +qemuDomainReloadTLSCertificates(virDomainPtr domain,<o:p></o:p> + unsigned int type)<o:p></o:p> +{<o:p></o:p> + virQEMUDriver *driver = domain->conn->privateData;<o:p></o:p> + virDomainObj *vm = qemuDomainObjFromDomain(domain);<o:p></o:p> + if (!driver || !vm)<o:p></o:p> + return -1;<o:p></o:p> + return qemuDomainReloadTLSCerts(driver, vm, type);<o:p></o:p> +}<o:p></o:p> <o:p></o:p> static virHypervisorDriver qemuHypervisorDriver = {<o:p></o:p> .name = QEMU_DRIVER_NAME,<o:p></o:p> @@ -20693,6 +20703,7 @@ static virHypervisorDriver qemuHypervisorDriver = {<o:p></o:p> .domainAuthorizedSSHKeysSet = qemuDomainAuthorizedSSHKeysSet, /* 6.10.0 */<o:p></o:p> .domainGetMessages = qemuDomainGetMessages, /* 7.1.0 */<o:p></o:p> .domainStartDirtyRateCalc = qemuDomainStartDirtyRateCalc, /* 7.2.0 */<o:p></o:p> + .domainiReloadTLSCertificates = qemuDomainReloadTLSCertificates, /* 7.2.0 */<o:p></o:p> };<o:p></o:p> <o:p></o:p> <o:p></o:p> diff --git a/src/qemu/qemu_hotplug.c b/src/qemu/qemu_hotplug.c<o:p></o:p> index 444d89d64a..013d8728a0 100644<o:p></o:p> --- a/src/qemu/qemu_hotplug.c<o:p></o:p> +++ b/src/qemu/qemu_hotplug.c<o:p></o:p> @@ -6704,3 +6704,24 @@ qemuDomainSetVcpuInternal(virQEMUDriver *driver,<o:p></o:p> virBitmapFree(livevcpus);<o:p></o:p> return ret;<o:p></o:p> }<o:p></o:p> +<o:p></o:p> +int qemuDomainReloadTLSCerts(virQEMUDriverPtr driver,<o:p></o:p> + virDomainObjPtr vm,<o:p></o:p> + int type)<o:p></o:p> +{<o:p></o:p> + int ret = -1;<o:p></o:p> + qemuDomainObjPrivate *priv = vm->privateData;<o:p></o:p> + /* for now, only VNC is supported */<o:p></o:p> + if (type != VIR_DOMAIN_TLS_CERT_GRAPHICS_VNC)<o:p></o:p> + virReportError(VIR_ERR_INVALID_ARG,<o:p></o:p> + _("invalid certificate type=%d, only support VNC"),<o:p></o:p> + type);<o:p></o:p> + return ret;<o:p></o:p> + }<o:p></o:p> + if (qemuDomainObjEnterMonitorAsync(driver, vm, QEMU_ASYNC_JOB_NONE) < 0)<o:p></o:p> + return ret;<o:p></o:p> + ret = qemuMonitorReloadTLSCerts(priv->mon, type);<o:p></o:p> + if (qemuDomainObjExitMonitor(driver, vm) < 0)<o:p></o:p> + ret = -1;<o:p></o:p> + return ret;<o:p></o:p> +}<o:p></o:p> diff --git a/src/qemu/qemu_hotplug.h b/src/qemu/qemu_hotplug.h<o:p></o:p> index df8f76f8d6..44afe23f0a 100644<o:p></o:p> --- a/src/qemu/qemu_hotplug.h<o:p></o:p> +++ b/src/qemu/qemu_hotplug.h<o:p></o:p> @@ -160,3 +160,7 @@ int qemuHotplugAttachDBusVMState(virQEMUDriver *driver,<o:p></o:p> int qemuHotplugRemoveDBusVMState(virQEMUDriver *driver,<o:p></o:p> virDomainObj *vm,<o:p></o:p> qemuDomainAsyncJob asyncJob);<o:p></o:p> +<o:p></o:p> +int qemuDomainReloadTLSCerts(virQEMUDriverPtr driver,<o:p></o:p> + virDomainObjPtr vm,<o:p></o:p> + int type);<o:p></o:p> diff --git a/src/qemu/qemu_monitor.c b/src/qemu/qemu_monitor.c<o:p></o:p> index 3a7f231ce0..952ef87a6b 100644<o:p></o:p> --- a/src/qemu/qemu_monitor.c<o:p></o:p> +++ b/src/qemu/qemu_monitor.c<o:p></o:p> @@ -4746,3 +4746,13 @@ qemuMonitorQueryDirtyRate(qemuMonitor *mon,<o:p></o:p> <o:p></o:p> return qemuMonitorJSONQueryDirtyRate(mon, info);<o:p></o:p> }<o:p></o:p> +<o:p></o:p> +int<o:p></o:p> +qemuMonitorReloadTLSCerts(qemuMonitorPtr mon, int type)<o:p></o:p> +{<o:p></o:p> + const char *protocol = qemuMonitorTypeToProtocol(type);<o:p></o:p> + if (!protocol)<o:p></o:p> + return -1;<o:p></o:p> + VIR_DEBUG("protocol=%s", protocol);<o:p></o:p> + return qemuMonitorJSONReloadTLSCerts(mon, protocol);<o:p></o:p> +}<o:p></o:p> diff --git a/src/qemu/qemu_monitor.h b/src/qemu/qemu_monitor.h<o:p></o:p> index 6a25def78b..a5b702b023 100644<o:p></o:p> --- a/src/qemu/qemu_monitor.h<o:p></o:p> +++ b/src/qemu/qemu_monitor.h<o:p></o:p> @@ -1496,3 +1496,6 @@ struct _qemuMonitorDirtyRateInfo {<o:p></o:p> int<o:p></o:p> qemuMonitorQueryDirtyRate(qemuMonitor *mon,<o:p></o:p> qemuMonitorDirtyRateInfo *info);<o:p></o:p> +<o:p></o:p> +int qemuMonitorReloadTLSCerts(qemuMonitorPtr mon,<o:p></o:p> + int type);<o:p></o:p> diff --git a/src/qemu/qemu_monitor_json.c b/src/qemu/qemu_monitor_json.c<o:p></o:p> index 46aa3330a8..d2b06c4703 100644<o:p></o:p> --- a/src/qemu/qemu_monitor_json.c<o:p></o:p> +++ b/src/qemu/qemu_monitor_json.c<o:p></o:p> @@ -9446,3 +9446,25 @@ qemuMonitorJSONQueryDirtyRate(qemuMonitor *mon,<o:p></o:p> <o:p></o:p> return qemuMonitorJSONExtractDirtyRateInfo(data, info);<o:p></o:p> }<o:p></o:p> +<o:p></o:p> +int qemuMonitorJSONReloadTLSCerts(qemuMonitorPtr mon,<o:p></o:p> + const char *protocol)<o:p></o:p> +{<o:p></o:p> + int ret = -1;<o:p></o:p> + virJSONValuePtr reply = NULL;<o:p></o:p> + virJSONValuePtr cmd = qemuMonitorJSONMakeCommand("display-reload",<o:p></o:p> + "s:type", protocol,<o:p></o:p> + "b:tls-certs", 1,<o:p></o:p> + NULL);<o:p></o:p> + if (!cmd)<o:p></o:p> + return -1;<o:p></o:p> + if (qemuMonitorJSONCommand(mon, cmd, &reply) < 0)<o:p></o:p> + goto cleanup;<o:p></o:p> + if (qemuMonitorJSONCheckError(cmd, reply) < 0)<o:p></o:p> + goto cleanup;<o:p></o:p> + ret = 0;<o:p></o:p> + cleanup:<o:p></o:p> + virJSONValueFree(cmd);<o:p></o:p> + virJSONValueFree(reply);<o:p></o:p> + return ret;<o:p></o:p> +}<o:p></o:p> diff --git a/src/qemu/qemu_monitor_json.h b/src/qemu/qemu_monitor_json.h<o:p></o:p> index 01a3ba25f1..d9ad77e873 100644<o:p></o:p> --- a/src/qemu/qemu_monitor_json.h<o:p></o:p> +++ b/src/qemu/qemu_monitor_json.h<o:p></o:p> @@ -706,3 +706,6 @@ qemuMonitorJSONStartDirtyRateCalc(qemuMonitor *mon,<o:p></o:p> int<o:p></o:p> qemuMonitorJSONQueryDirtyRate(qemuMonitor *mon,<o:p></o:p> qemuMonitorDirtyRateInfo *info);<o:p></o:p> +<o:p></o:p> +int qemuMonitorJSONReloadTLSCerts(qemuMonitorPtr mon,<o:p></o:p> + const char *protocol);<o:p></o:p> -- <o:p></o:p> 2.25.1<o:p></o:p> <o:p> </o:p> </div> </body> </html>