tempest/test_extension.py

# import testtools
# @test.attr(type='full')
# @test.services('compute', 'network')
# @testtools.skipUnless(CONF.compute_feature_enabled.live_migration,
#                       'Live migration must be enabled in tempest.conf')
#
# def test_live_migrate_to_all_nodes(self):
#     # collect all active hosts in all az
#     if not CONF.compute_feature_enabled.live_migration:
#         raise cls.skipException(
#             "Live migration is disabled")
#     available_zone = \
#         self.os_adm.availability_zone_client.list_availability_zones(
#             detail=True)['availabilityZoneInfo']
#     hosts = []
#     for zone in available_zone:
#         if zone['zoneState']['available']:
#             for host in zone['hosts']:
#                 if 'nova-compute' in zone['hosts'][host] and \
#                     zone['hosts'][host]['nova-compute']['available']:
#                     hosts.append({'zone': zone['zoneName'],
#                                   'host_name': host})
#
#     # ensure we have at least as many compute hosts as we expect
#     if len(hosts) < CONF.compute.min_compute_nodes:
#         raise exceptions.InvalidConfiguration(
#             "Host list %s is shorter than min_compute_nodes. "
#             "Did a compute worker not boot correctly?" % hosts)
#
#     # Create 1 VM
#     servers = []
#     first_last_host = hosts[0]
#     inst = self.create_server(
#         availability_zone='%(zone)s:%(host_name)s' % hosts[0],
#         wait_until='ACTIVE')
#     server = self.servers_client.show_server(inst['id'])['server']
#     # ensure server is located on the requested host
#     self.assertEqual(hosts[0]['host_name'], server['OS-EXT-SRV-ATTR:host'])
#     hosts.remove(first_last_host)
#     hosts.append(first_last_host)
#
#     # Live migrate to every host
#     for host in hosts[:CONF.compute.min_compute_nodes]:
#         self.servers_client.live_migrate_server(server_id=inst["id"],host=host['host_name'],block_migration=CONF.compute_feature_enabled.block_migration_for_live_migration,disk_over_commit=False)
#         waiters.wait_for_server_status(self.servers_client, inst["id"], 'ACTIVE')
#         server = self.servers_client.show_server(inst['id'])['server']
#         # ensure server is located on the requested host
#         self.assertEqual(host['host_name'], server['OS-EXT-SRV-ATTR:host'])
#
#
# from tempest.lib.common.utils import test_utils
# class TestServerSshAllComputes(manager.NetworkScenarioTest):
# credentials = ['primary', 'admin']
#
#
# @classmethod
# def setup_clients(cls):
#     super(TestServerSshAllComputes, cls).setup_clients()
#     # Use admin client by default
#     cls.manager = cls.admin_manager
#     # this is needed so that we can use the availability_zone:host
#     # scheduler hint, which is admin_only by default
#     cls.servers_client = cls.admin_manager.servers_client
#
# @test.attr(type='full')
# @test.services('compute', 'network')
# def test_ssh_to_all_nodes(self):
#     available_zone = \
#         self.os_adm.availability_zone_client.list_availability_zones(
#             detail=True)['availabilityZoneInfo']
#     hosts = []
#     for zone in available_zone:
#         if zone['zoneState']['available']:
#             for host in zone['hosts']:
#                 if 'nova-compute' in zone['hosts'][host] and \
#                     zone['hosts'][host]['nova-compute']['available']:
#                     hosts.append({'zone': zone['zoneName'],
#                                   'host_name': host})
#
#     # ensure we have at least as many compute hosts as we expect
#     if len(hosts) < CONF.compute.min_compute_nodes:
#         raise exceptions.InvalidConfiguration(
#             "Host list %s is shorter than min_compute_nodes. "
#             "Did a compute worker not boot correctly?" % hosts)
#
#     servers = []
#
#     # prepare key pair and sec group
#     keypair = self.os_adm.keypairs_client.create_keypair(name="tempest-live")
#     secgroup = self._create_security_group(security_groups_client=self.os_adm.security_groups_client, security_group_rules_client=self.os_adm.security_group_rules_client, tenant_id=self.os_adm.security_groups_client.tenant_id)
#
#     # create 1 compute for each node, up to the min_compute_nodes
#     # threshold (so that things don't get crazy if you have 1000
#     # compute nodes but set min to 3).
#
#     for host in hosts[:CONF.compute.min_compute_nodes]:
#         inst = self.create_server(
#             availability_zone='%(zone)s:%(host_name)s' % host,
#             key_name=keypair['keypair']['name'])
#         server = self.os_adm.servers_client.show_server(inst['id'])['server']
#         # TODO we may create server with sec group instead of adding it
#         self.os_adm.servers_client.add_security_group(server['id'],
#                                              name=secgroup['name'])
#
#         # ensure server is located on the requested host
#         self.assertEqual(host['host_name'], server['OS-EXT-SRV-ATTR:host'])
#         # TODO maybe check validate = True?
#         if CONF.network.public_network_id:
#             # Check VM via ssh
#             floating_ip = self.os_adm.compute_floating_ips_client.create_floating_ip(pool=CONF.network.floating_network_name)['floating_ip']
#             self.addCleanup(test_utils.call_and_ignore_notfound_exc,
#                     self.os_adm.compute_floating_ips_client.delete_floating_ip,
#                     floating_ip['id'])
#             self.os_adm.compute_floating_ips_client.associate_floating_ip_to_server(floating_ip['ip'], inst['id'])
#
#             #   TODO maybe add this
#             #    "Failed to find floating IP '%s' in server addresses: %s" %
#             #   (floating_ip['ip'], server['addresses']))
#
#             # check that we can SSH to the server
#             self.linux_client = self.get_remote_client(
#                 floating_ip['ip'], private_key=keypair['keypair']['private_key'])
#
#         servers.append(server)
#
#     # make sure we really have the number of servers we think we should
#     self.assertEqual(
#         len(servers), CONF.compute.min_compute_nodes,
#         "Incorrect number of servers built %s" % servers)
#
#     # ensure that every server ended up on a different host
#     host_ids = [x['hostId'] for x in servers]
#     self.assertEqual(
#         len(set(host_ids)), len(servers),
#         "Incorrect number of distinct host_ids scheduled to %s" % servers)
#     self.os_adm.keypairs_client.delete_keypair(keypair['keypair']['name'])
#