From e0f08163852832cba9fc42348dc152f1821224f6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Martin=20Ne=C4=8Das?= <necas.marty@gmail.com>
Date: Fri, 29 Mar 2019 13:10:17 +0100
Subject: [PATCH] ovirt auto migrate vm (#54542)

* ovirt auto migrate vm

* ovirt vm auto migrage only without host

* repair ovirt auto migrate vm
---
 lib/ansible/modules/cloud/ovirt/ovirt_vm.py | 24 +++++++++++++++++----
 1 file changed, 20 insertions(+), 4 deletions(-)

diff --git a/lib/ansible/modules/cloud/ovirt/ovirt_vm.py b/lib/ansible/modules/cloud/ovirt/ovirt_vm.py
index 4ebd057b29b..04f030d9982 100644
--- a/lib/ansible/modules/cloud/ovirt/ovirt_vm.py
+++ b/lib/ansible/modules/cloud/ovirt/ovirt_vm.py
@@ -740,6 +740,11 @@ options:
             - "If I(true), the VM will migrate even if it is defined as non-migratable."
         version_added: "2.8"
         type: bool
+    migrate:
+        description:
+            - "If I(true), the VM will migrate to any available host."
+        version_added: "2.8"
+        type: bool
     next_run:
         description:
             - "If I(true), the update will not be applied to the VM immediately and will be only applied when virtual machine is restarted."
@@ -940,6 +945,12 @@ EXAMPLES = '''
     name: myvm
     host: host1
 
+- name: Migrate VM to any available host
+  ovirt_vm:
+    state: running
+    name: myvm
+    migrate: true
+
 - name: Change VMs CD
   ovirt_vm:
     name: myvm
@@ -1537,9 +1548,9 @@ class VmsModule(BaseModule):
     def _migrate_vm(self, entity):
         vm_host = self.param('host')
         vm_service = self._service.vm_service(entity.id)
-        if vm_host is not None:
-            # In case VM is preparing to be UP, wait to be up, to migrate it:
-            if entity.status == otypes.VmStatus.UP:
+        # In case VM is preparing to be UP, wait to be up, to migrate it:
+        if entity.status == otypes.VmStatus.UP:
+            if vm_host is not None:
                 hosts_service = self._connection.system_service().hosts_service()
                 current_vm_host = hosts_service.host_service(entity.host.id).get().name
                 if vm_host != current_vm_host:
@@ -1547,7 +1558,11 @@ class VmsModule(BaseModule):
                         vm_service.migrate(host=otypes.Host(name=vm_host), force=self.param('force_migrate'))
                         self._wait_for_UP(vm_service)
                     self.changed = True
-
+            elif self.param('migrate'):
+                if not self._module.check_mode:
+                    vm_service.migrate(force=self.param('force_migrate'))
+                    self._wait_for_UP(vm_service)
+                self.changed = True
         return entity
 
     def _wait_for_UP(self, vm_service):
@@ -2214,6 +2229,7 @@ def main():
         export_domain=dict(default=None),
         export_ova=dict(type='dict'),
         force_migrate=dict(type='bool'),
+        migrate=dict(type='bool', default=None),
         next_run=dict(type='bool'),
     )
     module = AnsibleModule(