[PATCH 2/2] add default migrate uri in definition file

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

 



Current virsh migrate command require specfying migration URI with
command option.

Here is current step.
1) If user specifies --migrateuri on virsh migrate command, then the command
   transfers the data to specified host.
2) If --migrateuri is not specified, the command transfers the data to host
   whose name is resolved by DNS or /etc/hosts.

   but we are able to use virsh migrate command more usefull.
   User can specify a constant destination by definition file.
   if user want to specify other temporary destination, command option
   is good for it.

Signed-off-by: Chen Fan <chen.fan.fnst@xxxxxxxxxxxxxx>
---
 daemon/remote.c              | 11 ++++++++++-
 src/driver.h                 |  1 +
 src/libvirt.c                | 12 +++++++++++-
 src/libvirt.conf             |  7 +++++++
 src/libvirt_internal.h       |  1 +
 src/qemu/qemu_driver.c       | 37 ++++++++++++++++++++++++++++++++++---
 src/remote/remote_driver.c   | 13 +++++++++++++
 src/remote/remote_protocol.x |  1 +
 8 files changed, 78 insertions(+), 5 deletions(-)

diff --git a/daemon/remote.c b/daemon/remote.c
index 8476961..693f460 100644
--- a/daemon/remote.c
+++ b/daemon/remote.c
@@ -5331,6 +5331,7 @@ remoteDispatchDomainMigrateBegin3Params(virNetServerPtr server ATTRIBUTE_UNUSED,
     int nparams = 0;
     char *cookieout = NULL;
     int cookieoutlen = 0;
+    char **uri_out = NULL;
     int rv = -1;
     struct daemonClientPrivate *priv =
         virNetServerClientGetPrivateData(client);
@@ -5355,21 +5356,29 @@ remoteDispatchDomainMigrateBegin3Params(virNetServerPtr server ATTRIBUTE_UNUSED,
                                                     0, &nparams)))
         goto cleanup;
 
+    /* Wacky world of XDR ... */
+    if (VIR_ALLOC(uri_out) < 0)
+        goto cleanup;
+
     if (!(xml = virDomainMigrateBegin3Params(dom, params, nparams,
                                              &cookieout, &cookieoutlen,
+                                             uri_out,
                                              args->flags)))
         goto cleanup;
 
     ret->cookie_out.cookie_out_len = cookieoutlen;
     ret->cookie_out.cookie_out_val = cookieout;
+    ret->uri_out = !*uri_out ? NULL : uri_out;
     ret->xml = xml;
 
     rv = 0;
 
  cleanup:
     virTypedParamsFree(params, nparams);
-    if (rv < 0)
+    if (rv < 0) {
         virNetMessageSaveError(rerr);
+        VIR_FREE(uri_out);
+     }
     if (dom)
         virDomainFree(dom);
     return rv;
diff --git a/src/driver.h b/src/driver.h
index e66fc7a..738ab3a 100644
--- a/src/driver.h
+++ b/src/driver.h
@@ -1094,6 +1094,7 @@ typedef char *
                                    int nparams,
                                    char **cookieout,
                                    int *cookieoutlen,
+                                   char **uri_out,
                                    unsigned int flags);
 
 typedef int
diff --git a/src/libvirt.c b/src/libvirt.c
index f8d5240..257adbd 100644
--- a/src/libvirt.c
+++ b/src/libvirt.c
@@ -4738,7 +4738,7 @@ virDomainMigrateVersion3Full(virDomainPtr domain,
     VIR_DEBUG("Begin3 %p", domain->conn);
     if (useParams) {
         dom_xml = domain->conn->driver->domainMigrateBegin3Params
-            (domain, params, nparams, &cookieout, &cookieoutlen,
+            (domain, params, nparams, &cookieout, &cookieoutlen, &uri_out,
              flags | protection);
     } else {
         dom_xml = domain->conn->driver->domainMigrateBegin3
@@ -4748,6 +4748,14 @@ virDomainMigrateVersion3Full(virDomainPtr domain,
     if (!dom_xml)
         goto done;
 
+    /* Does domainMigrateBegin3Params() change URI? */
+    if (uri_out) {
+        if (virTypedParamsReplaceString(&params, &nparams,
+                                        VIR_MIGRATE_PARAM_URI,
+                                        uri_out) < 0)
+            goto done;
+    }
+
     if (useParams) {
         /* If source is new enough to support extensible migration parameters,
          * it's certainly new enough to support virDomainGetState. */
@@ -6778,6 +6786,7 @@ virDomainMigrateBegin3Params(virDomainPtr domain,
                              int nparams,
                              char **cookieout,
                              int *cookieoutlen,
+                             char **uri_out,
                              unsigned int flags)
 {
     virConnectPtr conn;
@@ -6798,6 +6807,7 @@ virDomainMigrateBegin3Params(virDomainPtr domain,
         char *xml;
         xml = conn->driver->domainMigrateBegin3Params(domain, params, nparams,
                                                       cookieout, cookieoutlen,
+                                                      uri_out,
                                                       flags);
         VIR_DEBUG("xml %s", NULLSTR(xml));
         if (!xml)
diff --git a/src/libvirt.conf b/src/libvirt.conf
index 016cd24..9cef343 100644
--- a/src/libvirt.conf
+++ b/src/libvirt.conf
@@ -16,3 +16,10 @@
 # driver when no URI is supplied by the application.
 
 #uri_default = "qemu:///system"
+
+#
+# This can be used to provide the default migrate URI when
+# migrate to target host. if migrate URI had been specified
+# in command line, this URI was ignored.
+
+#uri_migrate = "tcp://dest-uri-example"
diff --git a/src/libvirt_internal.h b/src/libvirt_internal.h
index ebf2acf..c4b92b2 100644
--- a/src/libvirt_internal.h
+++ b/src/libvirt_internal.h
@@ -236,6 +236,7 @@ char *virDomainMigrateBegin3Params(virDomainPtr domain,
                                    int nparams,
                                    char **cookieout,
                                    int *cookieoutlen,
+                                   char **uri_out,
                                    unsigned int flags);
 
 int virDomainMigratePrepare3Params(virConnectPtr dconn,
diff --git a/src/qemu/qemu_driver.c b/src/qemu/qemu_driver.c
index 1d08951..c82fbca 100644
--- a/src/qemu/qemu_driver.c
+++ b/src/qemu/qemu_driver.c
@@ -95,6 +95,7 @@
 #include "viraccessapicheckqemu.h"
 #include "storage/storage_driver.h"
 #include "virhostdev.h"
+#include "virconf.h"
 
 #define VIR_FROM_THIS VIR_FROM_QEMU
 
@@ -10801,12 +10802,17 @@ qemuDomainMigrateBegin3Params(virDomainPtr domain,
                               int nparams,
                               char **cookieout,
                               int *cookieoutlen,
+                              char **uri_out,
                               unsigned int flags)
 {
     const char *xmlin = NULL;
     const char *dname = NULL;
     virDomainObjPtr vm;
+    const char *uri_in = NULL;
+    virConfPtr conf = NULL;
+    virConfValuePtr value = NULL;
 
+    *uri_out = NULL;
     virCheckFlags(QEMU_MIGRATION_FLAGS, NULL);
     if (virTypedParamsValidate(params, nparams, QEMU_MIGRATION_PARAMETERS) < 0)
         return NULL;
@@ -10816,19 +10822,44 @@ qemuDomainMigrateBegin3Params(virDomainPtr domain,
                                 &xmlin) < 0 ||
         virTypedParamsGetString(params, nparams,
                                 VIR_MIGRATE_PARAM_DEST_NAME,
-                                &dname) < 0)
+                                &dname) < 0 ||
+        virTypedParamsGetString(params, nparams,
+                                VIR_MIGRATE_PARAM_URI,
+                                &uri_in) < 0)
         return NULL;
 
     if (!(vm = qemuDomObjFromDomain(domain)))
         return NULL;
 
     if (virDomainMigrateBegin3ParamsEnsureACL(domain->conn, vm->def) < 0) {
-        virObjectUnlock(vm);
-        return NULL;
+        goto cleanup;
+    }
+
+    if (!uri_in) {
+        if (virConnectGetConfigFile(&conf) < 0) {
+            goto cleanup;
+        }
+
+        if ((value = virConfGetValue(conf, "uri_migrate"))) {
+            if (value->type != VIR_CONF_STRING) {
+                VIR_WARN("Expected a string for 'uri_migrate' config parameter");
+            } else {
+                if (VIR_STRDUP(*uri_out, value->str) < 0)
+                    goto cleanup;
+            }
+        }
+        virConfFree(conf);
     }
 
     return qemuMigrationBegin(domain->conn, vm, xmlin, dname,
                               cookieout, cookieoutlen, flags);
+
+cleanup:
+    if (vm)
+        virObjectUnlock(vm);
+    virConfFree(conf);
+
+    return NULL;
 }
 
 
diff --git a/src/remote/remote_driver.c b/src/remote/remote_driver.c
index ed7dde6..3df59da 100644
--- a/src/remote/remote_driver.c
+++ b/src/remote/remote_driver.c
@@ -6970,6 +6970,7 @@ remoteDomainMigrateBegin3Params(virDomainPtr domain,
                                 int nparams,
                                 char **cookieout,
                                 int *cookieoutlen,
+                                char **uri_out,
                                 unsigned int flags)
 {
     char *rv = NULL;
@@ -7017,15 +7018,27 @@ remoteDomainMigrateBegin3Params(virDomainPtr domain,
         *cookieoutlen = ret.cookie_out.cookie_out_len;
     }
 
+    if (ret.uri_out) {
+        if (!uri_out) {
+            virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
+                           _("caller ignores uri_out"));
+            goto error;
+        }
+        *uri_out = *ret.uri_out; /* Caller frees. */
+    }
+
     rv = ret.xml; /* caller frees */
 
  cleanup:
     remoteFreeTypedParameters(args.params.params_val, args.params.params_len);
+    VIR_FREE(ret.uri_out);
     remoteDriverUnlock(priv);
     return rv;
 
  error:
     VIR_FREE(ret.cookie_out.cookie_out_val);
+    if (ret.uri_out)
+        VIR_FREE(*ret.uri_out);
     goto cleanup;
 }
 
diff --git a/src/remote/remote_protocol.x b/src/remote/remote_protocol.x
index 6c445cc..202a0eb 100644
--- a/src/remote/remote_protocol.x
+++ b/src/remote/remote_protocol.x
@@ -2860,6 +2860,7 @@ struct remote_domain_migrate_begin3_params_args {
 
 struct remote_domain_migrate_begin3_params_ret {
     opaque cookie_out<REMOTE_MIGRATE_COOKIE_MAX>;
+    remote_string uri_out;
     remote_nonnull_string xml;
 };
 
-- 
1.8.1.4

--
libvir-list mailing list
libvir-list@xxxxxxxxxx
https://www.redhat.com/mailman/listinfo/libvir-list




[Index of Archives]     [Virt Tools]     [Libvirt Users]     [Lib OS Info]     [Fedora Users]     [Fedora Desktop]     [Fedora SELinux]     [Big List of Linux Books]     [Yosemite News]     [KDE Users]     [Fedora Tools]