<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"> This is an RFC request for supporting virt-admin to update cacrl without restarting libvirtd.<o:p></o:p> <o:p> </o:p> When a client wants to establish a TLS connection with libvirtd, a CRL file is used by libvirtd to verify the client’s certificate. Right now, if the CRL file is changed, you must restart libvirtd to make it take effect. The restart behavior of libvirtd will cause clients connecting with libvirtd to fail.<o:p></o:p> <o:p> </o:p> In a server cluster, the CRL file may be updated quite frequently due to the large amount of certificates. If the new CRL does not take effect in time, there are security risks. So you may need to restart libvirtd frequently to make the CRL take effect in time. However, frequent restarts will affect the reliability of cluster virtual machine management(such as openstack) services.<o:p></o:p> <o:p> </o:p> This RFC patch adds a virt-admin command to update the server's CRL *online*.<o:p></o:p> <o:p> </o:p> This patch is not elegant enough, if this feature makes sense, I’d do more improvements.<o:p></o:p> <o:p> </o:p> ---<o:p></o:p> include/libvirt/libvirt-admin.h | 4 ++<o:p></o:p> src/admin/admin_protocol.x | 13 +++++-<o:p></o:p> src/admin/admin_server.c | 13 ++++++<o:p></o:p> src/admin/admin_server.h | 4 ++<o:p></o:p> src/admin/libvirt-admin.c | 33 ++++++++++++++++<o:p></o:p> src/admin/libvirt_admin_private.syms | 1 +<o:p></o:p> src/admin/libvirt_admin_public.syms | 1 +<o:p></o:p> src/rpc/virnetserver.c | 58 +++++++++++++++++++++++++++<o:p></o:p> src/rpc/virnetserver.h | 3 ++<o:p></o:p> src/rpc/virnettlscontext.c | 33 ++++++++++++++++<o:p></o:p> src/rpc/virnettlscontext.h | 3 ++<o:p></o:p> tools/virt-admin.c | 59 ++++++++++++++++++++++++++++<o:p></o:p> 12 files changed, 224 insertions(+), 1 deletion(-)<o:p></o:p> <o:p> </o:p> diff --git a/include/libvirt/libvirt-admin.h b/include/libvirt/libvirt-admin.h<o:p></o:p> index abf2792926..2df43db567 100644<o:p></o:p> --- a/include/libvirt/libvirt-admin.h<o:p></o:p> +++ b/include/libvirt/libvirt-admin.h<o:p></o:p> @@ -402,6 +402,10 @@ int virAdmServerSetClientLimits(virAdmServerPtr srv,<o:p></o:p> int nparams,<o:p></o:p> unsigned int flags);<o:p></o:p> <o:p> </o:p> +int virAdmServerUpdateTlsFile(virAdmServerPtr srv,<o:p></o:p> + unsigned int filetype,<o:p></o:p> + unsigned int flags);<o:p></o:p> +<o:p></o:p> int virAdmConnectGetLoggingOutputs(virAdmConnectPtr conn,<o:p></o:p> char **outputs,<o:p></o:p> unsigned int flags);<o:p></o:p> diff --git a/src/admin/admin_protocol.x b/src/admin/admin_protocol.x<o:p></o:p> index 42e215d23a..c74c0d777b 100644<o:p></o:p> --- a/src/admin/admin_protocol.x<o:p></o:p> +++ b/src/admin/admin_protocol.x<o:p></o:p> @@ -181,6 +181,12 @@ struct admin_server_set_client_limits_args {<o:p></o:p> unsigned int flags;<o:p></o:p> };<o:p></o:p> <o:p> </o:p> +struct admin_server_update_tls_file_args {<o:p></o:p> + admin_nonnull_server srv;<o:p></o:p> + unsigned int filetype;<o:p></o:p> + unsigned int flags;<o:p></o:p> +};<o:p></o:p> +<o:p></o:p> struct admin_connect_get_logging_outputs_args {<o:p></o:p> unsigned int flags;<o:p></o:p> };<o:p></o:p> @@ -314,5 +320,10 @@ enum admin_procedure {<o:p></o:p> /**<o:p></o:p> * @generate: both<o:p></o:p> */<o:p></o:p> - ADMIN_PROC_CONNECT_SET_LOGGING_FILTERS = 17<o:p></o:p> + ADMIN_PROC_CONNECT_SET_LOGGING_FILTERS = 17,<o:p></o:p> +<o:p></o:p> + /**<o:p></o:p> + * @generate: both<o:p></o:p> + */<o:p></o:p> + ADMIN_PROC_SERVER_UPDATE_TLS_FILE = 18<o:p></o:p> };<o:p></o:p> diff --git a/src/admin/admin_server.c b/src/admin/admin_server.c<o:p></o:p> index ba87f701c3..2f695eea4f 100644<o:p></o:p> --- a/src/admin/admin_server.c<o:p></o:p> +++ b/src/admin/admin_server.c<o:p></o:p> @@ -367,3 +367,16 @@ adminServerSetClientLimits(virNetServerPtr srv,<o:p></o:p> <o:p> </o:p> return 0;<o:p></o:p> }<o:p></o:p> +<o:p></o:p> +int<o:p></o:p> +adminServerUpdateTlsFile(virNetServerPtr srv,<o:p></o:p> + unsigned int filetype,<o:p></o:p> + unsigned int flags)<o:p></o:p> +{<o:p></o:p> + virCheckFlags(0, -1);<o:p></o:p> +<o:p></o:p> + if (virNetServerUpdateTlsFile(srv, filetype) < 0)<o:p></o:p> + return -1;<o:p></o:p> +<o:p></o:p> + return 0;<o:p></o:p> +}<o:p></o:p> diff --git a/src/admin/admin_server.h b/src/admin/admin_server.h<o:p></o:p> index 1d5cbec55f..748235811a 100644<o:p></o:p> --- a/src/admin/admin_server.h<o:p></o:p> +++ b/src/admin/admin_server.h<o:p></o:p> @@ -67,3 +67,7 @@ int adminServerSetClientLimits(virNetServerPtr srv,<o:p></o:p> virTypedParameterPtr params,<o:p></o:p> int nparams,<o:p></o:p> unsigned int flags);<o:p></o:p> +<o:p></o:p> +int adminServerUpdateTlsFile(virNetServerPtr srv,<o:p></o:p> + unsigned int filetype,<o:p></o:p> + unsigned int flags);<o:p></o:p> diff --git a/src/admin/libvirt-admin.c b/src/admin/libvirt-admin.c<o:p></o:p> index 4099a54854..13c8db016d 100644<o:p></o:p> --- a/src/admin/libvirt-admin.c<o:p></o:p> +++ b/src/admin/libvirt-admin.c<o:p></o:p> @@ -1082,6 +1082,39 @@ virAdmServerSetClientLimits(virAdmServerPtr srv,<o:p></o:p> return ret;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> +/**<o:p></o:p> + * virAdmServerUpdateTlsFile:<o:p></o:p> + * @srv: a valid server object reference<o:p></o:p> + * @filetype: TLS file type, such as crl, cert, key<o:p></o:p> + * @flags: extra flags; not used yet, so callers should always pass 0<o:p></o:p> + *<o:p></o:p> + * update TLS Context in TLS service.<o:p></o:p> + *<o:p></o:p> + * Returns 0 if the TLS files have been updated successfully or -1 in case of an<o:p></o:p> + * error.<o:p></o:p> + */<o:p></o:p> +int<o:p></o:p> +virAdmServerUpdateTlsFile(virAdmServerPtr srv,<o:p></o:p> + unsigned int filetype,<o:p></o:p> + unsigned int flags)<o:p></o:p> +{<o:p></o:p> + int ret = -1;<o:p></o:p> +<o:p></o:p> + VIR_DEBUG("srv=%p, filetype=%u flags=%x", srv, filetype, flags);<o:p></o:p> + virResetLastError();<o:p></o:p> +<o:p></o:p> + virCheckAdmServerGoto(srv, error);<o:p></o:p> +<o:p></o:p> + /* rpc call to update tls file */<o:p></o:p> + if ((ret = remoteAdminServerUpdateTlsFile(srv, filetype, flags)) < 0)<o:p></o:p> + goto error;<o:p></o:p> +<o:p></o:p> + return ret;<o:p></o:p> + error:<o:p></o:p> + virDispatchError(NULL);<o:p></o:p> + return ret;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> /**<o:p></o:p> * virAdmConnectGetLoggingOutputs:<o:p></o:p> * @conn: pointer to an active admin connection<o:p></o:p> diff --git a/src/admin/libvirt_admin_private.syms b/src/admin/libvirt_admin_private.syms<o:p></o:p> index 9526412de8..d563757482 100644<o:p></o:p> --- a/src/admin/libvirt_admin_private.syms<o:p></o:p> +++ b/src/admin/libvirt_admin_private.syms<o:p></o:p> @@ -31,6 +31,7 @@ xdr_admin_server_lookup_client_args;<o:p></o:p> xdr_admin_server_lookup_client_ret;<o:p></o:p> xdr_admin_server_set_client_limits_args;<o:p></o:p> xdr_admin_server_set_threadpool_parameters_args;<o:p></o:p> +xdr_admin_server_update_tls_file_args;<o:p></o:p> <o:p> </o:p> # datatypes.h<o:p></o:p> virAdmClientClass;<o:p></o:p> diff --git a/src/admin/libvirt_admin_public.syms b/src/admin/libvirt_admin_public.syms<o:p></o:p> index 9a3f843780..97b223bfba 100644<o:p></o:p> --- a/src/admin/libvirt_admin_public.syms<o:p></o:p> +++ b/src/admin/libvirt_admin_public.syms<o:p></o:p> @@ -38,6 +38,7 @@ LIBVIRT_ADMIN_2.0.0 {<o:p></o:p> virAdmClientClose;<o:p></o:p> virAdmServerGetClientLimits;<o:p></o:p> virAdmServerSetClientLimits;<o:p></o:p> + virAdmServerUpdateTlsFile;<o:p></o:p> };<o:p></o:p> <o:p> </o:p> LIBVIRT_ADMIN_3.0.0 {<o:p></o:p> diff --git a/src/rpc/virnetserver.c b/src/rpc/virnetserver.c<o:p></o:p> index 4122636805..fc18b2a224 100644<o:p></o:p> --- a/src/rpc/virnetserver.c<o:p></o:p> +++ b/src/rpc/virnetserver.c<o:p></o:p> @@ -1209,3 +1209,61 @@ virNetServerSetClientLimits(virNetServerPtr srv,<o:p></o:p> virObjectUnlock(srv);<o:p></o:p> return ret;<o:p></o:p> }<o:p></o:p> +<o:p></o:p> +int<o:p></o:p> +virNetServerUpdateTlsFile(virNetServerPtr srv,<o:p></o:p> + unsigned int filetype)<o:p></o:p> +{<o:p></o:p> + int ret = -1;<o:p></o:p> +#if WITH_GNUTLS<o:p></o:p> + size_t i;<o:p></o:p> + int cnt = 0;<o:p></o:p> + virNetTLSContextPtr ctxt = NULL;<o:p></o:p> + virNetServerServicePtr svc = NULL;<o:p></o:p> +<o:p></o:p> + if (filetype != TYPE_CACRL_LIBVIRT) {<o:p></o:p> + virReportError(VIR_ERR_SYSTEM_ERROR,<o:p></o:p> + _("Don't support CRL filetype: %d"),<o:p></o:p> + filetype);<o:p></o:p> + return ret;<o:p></o:p> + }<o:p></o:p> +<o:p></o:p> + virObjectLock(srv);<o:p></o:p> +<o:p></o:p> + /* find svcTLS from srv */<o:p></o:p> + for (i = 0; i < srv->nservices; i++) {<o:p></o:p> + svc = srv->services[i];<o:p></o:p> + /* find tls from svc */<o:p></o:p> + ctxt = virNetServerServiceGetTLSContext(svc);<o:p></o:p> + if (ctxt == NULL)<o:p></o:p> + continue;<o:p></o:p> +<o:p></o:p> + ret = virNetTLSContextUpdateCRL(ctxt);<o:p></o:p> + if (ret < 0) {<o:p></o:p> + VIR_ERROR(_("update tls file fail, "<o:p></o:p> + "filetype: %d, svcID: %zu"), filetype, i);<o:p></o:p> + ret = -1;<o:p></o:p> + goto cleanup;<o:p></o:p> + }<o:p></o:p> + VIR_INFO("update success, filetype: %d, svcID: %zu", filetype, i);<o:p></o:p> + cnt++;<o:p></o:p> + }<o:p></o:p> +<o:p></o:p> + if (cnt == 0) {<o:p></o:p> + virReportError(VIR_ERR_SYSTEM_ERROR,<o:p></o:p> + _("no tls server found, don't need update %d"),<o:p></o:p> + filetype);<o:p></o:p> + } else {<o:p></o:p> + VIR_INFO("update tls file complete, filetype: %d",<o:p></o:p> + filetype);<o:p></o:p> + }<o:p></o:p> +<o:p></o:p> + cleanup:<o:p></o:p> + virObjectUnlock(srv);<o:p></o:p> +#else<o:p></o:p> + virReportError(VIR_ERR_SYSTEM_ERROR,<o:p></o:p> + _("Don't support GNUTLS: %d"),<o:p></o:p> + filetype);<o:p></o:p> +#endif<o:p></o:p> + return ret;<o:p></o:p> +}<o:p></o:p> diff --git a/src/rpc/virnetserver.h b/src/rpc/virnetserver.h<o:p></o:p> index 260c99b22d..d0138d250f 100644<o:p></o:p> --- a/src/rpc/virnetserver.h<o:p></o:p> +++ b/src/rpc/virnetserver.h<o:p></o:p> @@ -133,3 +133,6 @@ size_t virNetServerGetCurrentUnauthClients(virNetServerPtr srv);<o:p></o:p> int virNetServerSetClientLimits(virNetServerPtr srv,<o:p></o:p> long long int maxClients,<o:p></o:p> long long int maxClientsUnauth);<o:p></o:p> +<o:p></o:p> +int virNetServerUpdateTlsFile(virNetServerPtr srv,<o:p></o:p> + unsigned int filetype);<o:p></o:p> diff --git a/src/rpc/virnettlscontext.c b/src/rpc/virnettlscontext.c<o:p></o:p> index 08944f6771..1cc3cb8620 100644<o:p></o:p> --- a/src/rpc/virnettlscontext.c<o:p></o:p> +++ b/src/rpc/virnettlscontext.c<o:p></o:p> @@ -1106,6 +1106,39 @@ int virNetTLSContextCheckCertificate(virNetTLSContextPtr ctxt,<o:p></o:p> return ret;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> +int virNetTLSContextUpdateCRL(virNetTLSContextPtr ctxt)<o:p></o:p> +{<o:p></o:p> + int ret = -1;<o:p></o:p> + char *cacrl = NULL;<o:p></o:p> +<o:p></o:p> + if (VIR_STRDUP(cacrl, LIBVIRT_CACRL) < 0)<o:p></o:p> + return -1;<o:p></o:p> +<o:p></o:p> + if (!virFileExists(cacrl)) {<o:p></o:p> + virReportSystemError(errno, _("%s not exist"), cacrl);<o:p></o:p> + goto cleanup;<o:p></o:p> + }<o:p></o:p> +<o:p></o:p> + virObjectLock(ctxt);<o:p></o:p> +<o:p></o:p> + ret = gnutls_certificate_set_x509_crl_file(ctxt->x509cred,<o:p></o:p> + cacrl,<o:p></o:p> + GNUTLS_X509_FMT_PEM);<o:p></o:p> + if (ret < 0) {<o:p></o:p> + virReportError(VIR_ERR_SYSTEM_ERROR,<o:p></o:p> + _("Unable to update x509 CRL %s: %s"),<o:p></o:p> + cacrl, gnutls_strerror(ret));<o:p></o:p> + } else {<o:p></o:p> + VIR_INFO("Load %d CRL from %s", ret, cacrl);<o:p></o:p> + ret = 0;<o:p></o:p> + }<o:p></o:p> +<o:p></o:p> + virObjectUnlock(ctxt);<o:p></o:p> + cleanup:<o:p></o:p> + VIR_FREE(cacrl);<o:p></o:p> + return ret;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> void virNetTLSContextDispose(void *obj)<o:p></o:p> {<o:p></o:p> virNetTLSContextPtr ctxt = obj;<o:p></o:p> diff --git a/src/rpc/virnettlscontext.h b/src/rpc/virnettlscontext.h<o:p></o:p> index f3273bc26a..b823ab2c3f 100644<o:p></o:p> --- a/src/rpc/virnettlscontext.h<o:p></o:p> +++ b/src/rpc/virnettlscontext.h<o:p></o:p> @@ -23,6 +23,8 @@<o:p></o:p> #include "internal.h"<o:p></o:p> #include "virobject.h"<o:p></o:p> <o:p> </o:p> +#define TYPE_CACRL_LIBVIRT 13<o:p></o:p> +<o:p></o:p> typedef struct _virNetTLSContext virNetTLSContext;<o:p></o:p> typedef virNetTLSContext *virNetTLSContextPtr;<o:p></o:p> <o:p> </o:p> @@ -65,6 +67,7 @@ virNetTLSContextPtr virNetTLSContextNewClient(const char *cacert,<o:p></o:p> int virNetTLSContextCheckCertificate(virNetTLSContextPtr ctxt,<o:p></o:p> virNetTLSSessionPtr sess);<o:p></o:p> <o:p> </o:p> +int virNetTLSContextUpdateCRL(virNetTLSContextPtr ctxt);<o:p></o:p> <o:p> </o:p> typedef ssize_t (*virNetTLSSessionWriteFunc)(const char *buf, size_t len,<o:p></o:p> void *opaque);<o:p></o:p> diff --git a/tools/virt-admin.c b/tools/virt-admin.c<o:p></o:p> index 30106d1971..25971dbf27 100644<o:p></o:p> --- a/tools/virt-admin.c<o:p></o:p> +++ b/tools/virt-admin.c<o:p></o:p> @@ -50,6 +50,8 @@<o:p></o:p> /* we don't need precision to milliseconds in this module */<o:p></o:p> #define VIRT_ADMIN_TIME_BUFLEN VIR_TIME_STRING_BUFLEN - 3<o:p></o:p> <o:p> </o:p> +#define LIBVIRT_CACRL_TYPE 13<o:p></o:p> +<o:p></o:p> static char *progname;<o:p></o:p> <o:p> </o:p> static const vshCmdGrp cmdGroups[];<o:p></o:p> @@ -1103,6 +1105,57 @@ cmdDaemonLogOutputs(vshControl *ctl, const vshCmd *cmd)<o:p></o:p> return true;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> +/* ------------------------<o:p></o:p> + * Command update-crl-file<o:p></o:p> + * ------------------------<o:p></o:p> + */<o:p></o:p> +static const vshCmdInfo info_srv_update_tls_file[] = {<o:p></o:p> + {.name = "help",<o:p></o:p> + .data = N_("notify tls file type, current only support libvirt cacrl(13)")<o:p></o:p> + },<o:p></o:p> + {.name = "desc",<o:p></o:p> + .data = N_("notify libvirtd TLS server hot update CACRL.")<o:p></o:p> + },<o:p></o:p> + {.name = NULL}<o:p></o:p> +};<o:p></o:p> +<o:p></o:p> +static const vshCmdOptDef opts_srv_update_tls_file[] = {<o:p></o:p> + {.name = "server",<o:p></o:p> + .type = VSH_OT_DATA,<o:p></o:p> + .flags = VSH_OFLAG_REQ,<o:p></o:p> + .help = N_("Server to reload the CRL file."),<o:p></o:p> + },<o:p></o:p> + {.name = NULL}<o:p></o:p> +};<o:p></o:p> +<o:p></o:p> +static bool<o:p></o:p> +cmdSrvUpdateTlsFile(vshControl *ctl, const vshCmd *cmd)<o:p></o:p> +{<o:p></o:p> + bool ret = false;<o:p></o:p> + const char *srvname = NULL;<o:p></o:p> + unsigned int filetype = LIBVIRT_CACRL_TYPE;<o:p></o:p> +<o:p></o:p> + virAdmServerPtr srv = NULL;<o:p></o:p> + vshAdmControlPtr priv = ctl->privData;<o:p></o:p> +<o:p></o:p> + if (vshCommandOptStringReq(ctl, cmd, "server", &srvname) < 0)<o:p></o:p> + return false;<o:p></o:p> +<o:p></o:p> + if (!(srv = virAdmConnectLookupServer(priv->conn, srvname, 0)))<o:p></o:p> + goto cleanup;<o:p></o:p> +<o:p></o:p> + if (virAdmServerUpdateTlsFile(srv, filetype, 0) < 0) {<o:p></o:p> + vshError(ctl, "%s", _("Unable to update server's tls file."));<o:p></o:p> + goto cleanup;<o:p></o:p> + }<o:p></o:p> +<o:p></o:p> + ret = true;<o:p></o:p> +<o:p></o:p> + cleanup:<o:p></o:p> + virAdmServerFree(srv);<o:p></o:p> + return ret;<o:p></o:p> +}<o:p></o:p> +<o:p></o:p> static void *<o:p></o:p> vshAdmConnectionHandler(vshControl *ctl)<o:p></o:p> {<o:p></o:p> @@ -1486,6 +1539,12 @@ static const vshCmdDef managementCmds[] = {<o:p></o:p> .info = info_daemon_log_outputs,<o:p></o:p> .flags = 0<o:p></o:p> },<o:p></o:p> + {.name = "update-crl-file",<o:p></o:p> + .handler = cmdSrvUpdateTlsFile,<o:p></o:p> + .opts = opts_srv_update_tls_file,<o:p></o:p> + .info = info_srv_update_tls_file,<o:p></o:p> + .flags = 0<o:p></o:p> + },<o:p></o:p> {.name = NULL}<o:p></o:p> };<o:p></o:p> <o:p> </o:p> <o:p> </o:p> </div> </body> </html>