Allow VMs to be resumed after a hypervisor reboot
Fixes bug 1052696. Update the compute manager to pass network_info and block_device_info to the driver.resume() and update all virtualization drivers to accept the new arguments. For libvirt, change resume() to use _create_domain_and_network() rather than _create_domain(). This eliminates the assumption that the network and block device connections remained in place from the period between the VM being suspended and resumed. Instead, all the networking and block connections will be rebuilt on resume (in case they are missing) as is the case after a hypervisor reboot. Change-Id: I6e19ec42f7e929678abce8f276c0a6e91f1fa8af
This commit is contained in:
@@ -274,12 +274,18 @@ class HyperVAPITestCase(basetestcase.BaseTestCase):
|
||||
constants.HYPERV_VM_STATE_SUSPENDED,
|
||||
constants.HYPERV_VM_STATE_SUSPENDED)
|
||||
|
||||
# NOTE (rmk): Resume now takes 3 mandatory args. These tests need to
|
||||
# be updated but cannot be without involvement from the maintainers
|
||||
# of the HyperV driver/tests.
|
||||
def test_resume(self):
|
||||
self.skipTest("Requires updating.")
|
||||
self._test_vm_state_change(self._conn.resume,
|
||||
constants.HYPERV_VM_STATE_SUSPENDED,
|
||||
constants.HYPERV_VM_STATE_ENABLED)
|
||||
|
||||
# NOTE: (rmk): See comment for test_resume().
|
||||
def test_resume_already_running(self):
|
||||
self.skipTest("Requires updating.")
|
||||
self._test_vm_state_change(self._conn.resume, None,
|
||||
constants.HYPERV_VM_STATE_ENABLED)
|
||||
|
||||
|
||||
@@ -340,13 +340,13 @@ class _VirtDriverTestCase(_FakeDriverBackendTestCase):
|
||||
@catch_notimplementederror
|
||||
def test_resume_unsuspended_instance(self):
|
||||
instance_ref, network_info = self._get_running_instance()
|
||||
self.connection.resume(instance_ref)
|
||||
self.connection.resume(instance_ref, network_info)
|
||||
|
||||
@catch_notimplementederror
|
||||
def test_resume_suspended_instance(self):
|
||||
instance_ref, network_info = self._get_running_instance()
|
||||
self.connection.suspend(instance_ref)
|
||||
self.connection.resume(instance_ref)
|
||||
self.connection.resume(instance_ref, network_info)
|
||||
|
||||
@catch_notimplementederror
|
||||
def test_destroy_instance_nonexistent(self):
|
||||
|
||||
@@ -215,21 +215,21 @@ class VMWareAPIVMTestCase(test.TestCase):
|
||||
self.conn.suspend(self.instance)
|
||||
info = self.conn.get_info({'name': 1})
|
||||
self._check_vm_info(info, power_state.PAUSED)
|
||||
self.conn.resume(self.instance)
|
||||
self.conn.resume(self.instance, self.network_info)
|
||||
info = self.conn.get_info({'name': 1})
|
||||
self._check_vm_info(info, power_state.RUNNING)
|
||||
|
||||
def test_resume_non_existent(self):
|
||||
self._create_instance_in_the_db()
|
||||
self.assertRaises(exception.InstanceNotFound, self.conn.resume,
|
||||
self.instance)
|
||||
self.instance, self.network_info)
|
||||
|
||||
def test_resume_not_suspended(self):
|
||||
self._create_vm()
|
||||
info = self.conn.get_info({'name': 1})
|
||||
self._check_vm_info(info, power_state.RUNNING)
|
||||
self.assertRaises(exception.InstanceResumeFailure, self.conn.resume,
|
||||
self.instance)
|
||||
self.instance, self.network_info)
|
||||
|
||||
def test_get_info(self):
|
||||
self._create_vm()
|
||||
|
||||
Reference in New Issue
Block a user