164 lines
6.7 KiB
Python
164 lines
6.7 KiB
Python
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
import fixtures
|
|
import mock
|
|
|
|
from lxml import etree
|
|
import six.moves.urllib.parse as urlparse
|
|
|
|
from nova import context
|
|
from nova.network.neutronv2 import api as neutron
|
|
from nova.network.neutronv2 import constants as neutron_constants
|
|
from nova.tests.functional import integrated_helpers
|
|
from nova.tests.functional.libvirt import base as libvirt_base
|
|
from nova.tests.unit.virt.libvirt import fake_os_brick_connector
|
|
from nova.tests.unit.virt.libvirt import fakelibvirt
|
|
from nova.virt.libvirt import guest as libvirt_guest
|
|
|
|
|
|
class TestLiveMigrationWithoutMultiplePortBindings(
|
|
integrated_helpers.InstanceHelperMixin,
|
|
libvirt_base.ServersTestBase):
|
|
"""Regression test for bug 1888395.
|
|
|
|
This regression test asserts that Live migration works when
|
|
neutron does not support the binding-extended api extension
|
|
and the legacy single port binding workflow is used.
|
|
"""
|
|
|
|
ADMIN_API = True
|
|
api_major_version = 'v2.1'
|
|
microversion = 'latest'
|
|
|
|
def list_extensions(self, *args, **kwargs):
|
|
return {
|
|
'extensions': [
|
|
{
|
|
# Copied from neutron-lib portbindings.py
|
|
"updated": "2014-02-03T10:00:00-00:00",
|
|
"name": neutron_constants.PORT_BINDING,
|
|
"links": [],
|
|
"alias": "binding",
|
|
"description": "Expose port bindings of a virtual port to "
|
|
"external application"
|
|
}
|
|
]
|
|
}
|
|
|
|
def setUp(self):
|
|
self.flags(instances_path=self.useFixture(fixtures.TempDir()).path)
|
|
super(TestLiveMigrationWithoutMultiplePortBindings, self).setUp()
|
|
self.neutron.list_extensions = self.list_extensions
|
|
self.neutron_api = neutron.API()
|
|
# TODO(sean-k-mooney): remove after
|
|
# I275509eb0e0eb9eaf26fe607b7d9a67e1edc71f8
|
|
# has merged.
|
|
self.useFixture(fixtures.MonkeyPatch(
|
|
'nova.virt.libvirt.driver.connector',
|
|
fake_os_brick_connector))
|
|
|
|
self.computes = {}
|
|
for host in ['start_host', 'end_host']:
|
|
host_info = fakelibvirt.HostInfo(
|
|
cpu_nodes=1, cpu_sockets=1, cpu_cores=4, cpu_threads=2,
|
|
kB_mem=10740000)
|
|
fake_connection = self._get_connection(
|
|
host_info=host_info, hostname=host)
|
|
|
|
# This is fun. Firstly we need to do a global'ish mock so we can
|
|
# actually start the service.
|
|
with mock.patch('nova.virt.libvirt.host.Host.get_connection',
|
|
return_value=fake_connection):
|
|
compute = self.start_service('compute', host=host)
|
|
|
|
# Once that's done, we need to do some tweaks to each individual
|
|
# compute "service" to make sure they return unique objects
|
|
compute.driver._host.get_connection = lambda: fake_connection
|
|
self.computes[host] = compute
|
|
|
|
self.ctxt = context.get_admin_context()
|
|
# TODO(sean-k-mooney): remove this when it is part of ServersTestBase
|
|
self.useFixture(fixtures.MonkeyPatch(
|
|
'nova.tests.unit.virt.libvirt.fakelibvirt.Domain.migrateToURI3',
|
|
self._migrate_stub))
|
|
self.useFixture(fixtures.MonkeyPatch(
|
|
'nova.virt.libvirt.migration._update_serial_xml',
|
|
self._update_serial_xml_stub))
|
|
|
|
def _update_serial_xml_stub(self, xml_doc, migrate_data):
|
|
return xml_doc
|
|
|
|
def _migrate_stub(self, domain, destination, params, flags):
|
|
"""Stub out migrateToURI3."""
|
|
|
|
src_hostname = domain._connection.hostname
|
|
dst_hostname = urlparse.urlparse(destination).netloc
|
|
|
|
# In a real live migration, libvirt and QEMU on the source and
|
|
# destination talk it out, resulting in the instance starting to exist
|
|
# on the destination. Fakelibvirt cannot do that, so we have to
|
|
# manually create the "incoming" instance on the destination
|
|
# fakelibvirt.
|
|
dst = self.computes[dst_hostname]
|
|
dst.driver._host.get_connection().createXML(
|
|
params['destination_xml'],
|
|
'fake-createXML-doesnt-care-about-flags')
|
|
|
|
src = self.computes[src_hostname]
|
|
conn = src.driver._host.get_connection()
|
|
|
|
# because migrateToURI3 is spawned in a background thread, this method
|
|
# does not block the upper nova layers. Because we don't want nova to
|
|
# think the live migration has finished until this method is done, the
|
|
# last thing we do is make fakelibvirt's Domain.jobStats() return
|
|
# VIR_DOMAIN_JOB_COMPLETED.
|
|
server = etree.fromstring(
|
|
params['destination_xml']
|
|
).find('./uuid').text
|
|
dom = conn.lookupByUUIDString(server)
|
|
dom.complete_job()
|
|
|
|
@mock.patch('nova.virt.libvirt.guest.Guest.get_job_info')
|
|
def test_live_migrate(self, mock_get_job_info):
|
|
mock_get_job_info.return_value = libvirt_guest.JobInfo(
|
|
type=fakelibvirt.VIR_DOMAIN_JOB_COMPLETED)
|
|
flavors = self.api.get_flavors()
|
|
flavor = flavors[0]
|
|
server_req = self._build_minimal_create_server_request(
|
|
self.api, 'some-server', flavor_id=flavor['id'],
|
|
image_uuid='155d900f-4e14-4e4c-a73d-069cbf4541e6',
|
|
networks=[{'port': self.neutron.port_1['id']}])
|
|
server_req['availability_zone'] = 'nova:%s' % "start_host"
|
|
created_server = self.api.post_server({'server': server_req})
|
|
server = self._wait_for_state_change(
|
|
self.api, created_server, 'ACTIVE')
|
|
self.assertFalse(
|
|
self.neutron_api.supports_port_binding_extension(self.ctxt))
|
|
# TODO(sean-k-mooney): extend _live_migrate to support passing a host
|
|
self.api.post_server_action(
|
|
server['id'],
|
|
{
|
|
'os-migrateLive': {
|
|
'host': 'end_host',
|
|
'block_migration': 'auto'
|
|
}
|
|
}
|
|
)
|
|
|
|
self._wait_for_server_parameter(
|
|
self.api, server,
|
|
{'OS-EXT-SRV-ATTR:host': 'end_host', 'status': 'ACTIVE'})
|
|
|
|
msg = "NotImplementedError: Cannot load 'vif_type' in the base class"
|
|
self.assertNotIn(msg, self.stdlog.logger.output)
|