938 lines
32 KiB
Python
938 lines
32 KiB
Python
# Copyright 2013 Mirantis, Inc.
|
|
#
|
|
# 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.
|
|
|
|
from __future__ import division
|
|
from __future__ import unicode_literals
|
|
|
|
import re
|
|
from warnings import warn
|
|
|
|
from proboscis.asserts import assert_equal
|
|
from proboscis.asserts import assert_true
|
|
from proboscis import test
|
|
from proboscis import SkipTest
|
|
|
|
from fuelweb_test.helpers.decorators import log_snapshot_after_test
|
|
from fuelweb_test.helpers.eb_tables import Ebtables
|
|
from fuelweb_test.helpers import os_actions
|
|
from fuelweb_test.settings import DEPLOYMENT_MODE
|
|
from fuelweb_test.settings import MIRROR_UBUNTU
|
|
from fuelweb_test.settings import NODE_VOLUME_SIZE
|
|
from fuelweb_test.settings import NEUTRON_SEGMENT
|
|
from fuelweb_test.settings import NEUTRON_SEGMENT_TYPE
|
|
from fuelweb_test.settings import iface_alias
|
|
from fuelweb_test.tests.base_test_case import SetupEnvironment
|
|
from fuelweb_test.tests.base_test_case import TestBasic
|
|
from fuelweb_test import logger
|
|
from fuelweb_test.tests.test_ha_one_controller_base\
|
|
import HAOneControllerNeutronBase
|
|
|
|
|
|
@test()
|
|
class OneNodeDeploy(TestBasic):
|
|
"""OneNodeDeploy. DEPRECATED!""" # TODO documentation
|
|
|
|
@test(depends_on=[SetupEnvironment.prepare_release],
|
|
groups=["deploy_one_node", 'master'])
|
|
@log_snapshot_after_test
|
|
def deploy_one_node(self):
|
|
"""Deploy cluster with controller node only
|
|
|
|
Scenario:
|
|
1. Create cluster
|
|
2. Add 1 node with controller role
|
|
3. Deploy the cluster
|
|
4. Validate cluster was set up correctly, there are no dead
|
|
services, there are no errors in logs
|
|
|
|
Duration 20m
|
|
|
|
"""
|
|
self.env.revert_snapshot("ready")
|
|
self.fuel_web.client.list_nodes()
|
|
self.env.bootstrap_nodes(
|
|
self.env.d_env.nodes().slaves[:1])
|
|
|
|
cluster_id = self.fuel_web.create_cluster(
|
|
name=self.__class__.__name__,
|
|
mode=DEPLOYMENT_MODE,
|
|
)
|
|
logger.info('Cluster is {!s}'.format(cluster_id))
|
|
self.fuel_web.update_nodes(
|
|
cluster_id,
|
|
{'slave-01': ['controller']}
|
|
)
|
|
self.fuel_web.deploy_cluster_wait(cluster_id)
|
|
os_conn = os_actions.OpenStackActions(
|
|
self.fuel_web.get_public_vip(cluster_id))
|
|
self.fuel_web.assert_cluster_ready(os_conn, smiles_count=4)
|
|
self.fuel_web.run_single_ostf_test(
|
|
cluster_id=cluster_id, test_sets=['sanity'],
|
|
test_name=('fuel_health.tests.sanity.test_sanity_identity'
|
|
'.SanityIdentityTest.test_list_users'))
|
|
|
|
|
|
@test(groups=["one_controller_actions"])
|
|
class HAOneControllerNeutron(HAOneControllerNeutronBase):
|
|
"""HAOneControllerNeutron.""" # TODO documentation
|
|
|
|
@test(depends_on=[SetupEnvironment.prepare_slaves_3],
|
|
groups=["smoke", "deploy_ha_one_controller_neutron"])
|
|
@log_snapshot_after_test
|
|
def deploy_ha_one_controller_neutron(self):
|
|
"""Deploy cluster in HA mode (one controller) with neutron
|
|
|
|
Scenario:
|
|
1. Create cluster in HA mode
|
|
2. Add 1 node with controller role
|
|
3. Add 1 node with compute role
|
|
4. Deploy the cluster
|
|
5. Validate cluster was set up correctly, there are no dead
|
|
services, there are no errors in logs
|
|
6. Verify networks
|
|
7. Verify network configuration on controller
|
|
8. Run OSTF
|
|
|
|
Duration 30m
|
|
Snapshot: deploy_ha_one_controller_neutron
|
|
"""
|
|
super(self.__class__, self).deploy_ha_one_controller_neutron_base(
|
|
snapshot_name="deploy_ha_one_controller_neutron")
|
|
|
|
@test(depends_on=[deploy_ha_one_controller_neutron],
|
|
groups=["ha_one_controller_neutron_node_deletion"])
|
|
@log_snapshot_after_test
|
|
def ha_one_controller_neutron_node_deletion(self):
|
|
"""Remove compute from cluster in ha mode with neutron
|
|
|
|
Scenario:
|
|
1. Revert "deploy_ha_one_controller_neutron" environment
|
|
2. Remove compute node
|
|
3. Deploy changes
|
|
4. Verify node returns to unallocated pull
|
|
|
|
Duration 8m
|
|
|
|
"""
|
|
self.env.revert_snapshot("deploy_ha_one_controller_neutron")
|
|
|
|
cluster_id = self.fuel_web.get_last_created_cluster()
|
|
nailgun_nodes = self.fuel_web.update_nodes(
|
|
cluster_id, {'slave-02': ['compute']}, False, True)
|
|
task = self.fuel_web.deploy_cluster(cluster_id)
|
|
self.fuel_web.assert_task_success(task)
|
|
nodes = [
|
|
node for node in nailgun_nodes if node["pending_deletion"] is True]
|
|
assert_true(
|
|
len(nodes) == 1, "Verify 1 node has pending deletion status"
|
|
)
|
|
self.fuel_web.wait_node_is_discovered(nodes[0])
|
|
|
|
@test(depends_on=[SetupEnvironment.prepare_slaves_3],
|
|
groups=["ha_one_controller_neutron_blocked_vlan"])
|
|
@log_snapshot_after_test
|
|
def ha_one_controller_neutron_blocked_vlan(self):
|
|
"""Verify network verification with blocked VLANs
|
|
|
|
Scenario:
|
|
1. Create cluster in Ha mode
|
|
2. Add 1 node with controller role
|
|
3. Add 1 node with compute role
|
|
4. Deploy the cluster
|
|
5. Validate cluster was set up correctly, there are no dead
|
|
services, there are no errors in logs
|
|
6. Block first VLAN
|
|
7. Run Verify network and assert it fails
|
|
8. Restore first VLAN
|
|
|
|
Duration 20m
|
|
|
|
"""
|
|
self.env.revert_snapshot("ready_with_3_slaves")
|
|
|
|
cluster_id = self.fuel_web.create_cluster(
|
|
name=self.__class__.__name__,
|
|
mode=DEPLOYMENT_MODE,
|
|
settings={
|
|
"net_provider": 'neutron',
|
|
"net_segment_type": NEUTRON_SEGMENT['vlan']
|
|
}
|
|
)
|
|
self.fuel_web.update_nodes(
|
|
cluster_id,
|
|
{
|
|
'slave-01': ['controller'],
|
|
'slave-02': ['compute']
|
|
}
|
|
)
|
|
self.fuel_web.deploy_cluster_wait(cluster_id)
|
|
|
|
os_conn = os_actions.OpenStackActions(
|
|
self.fuel_web.get_public_vip(cluster_id))
|
|
self.fuel_web.assert_cluster_ready(os_conn, smiles_count=5)
|
|
ebtables = self.env.get_ebtables(
|
|
cluster_id, self.env.d_env.nodes().slaves[:2])
|
|
ebtables.restore_vlans()
|
|
try:
|
|
ebtables.block_first_vlan()
|
|
self.fuel_web.verify_network(cluster_id, success=False)
|
|
finally:
|
|
ebtables.restore_first_vlan()
|
|
|
|
@test(depends_on=[SetupEnvironment.prepare_slaves_3],
|
|
groups=["ha_one_controller_neutron_add_compute"])
|
|
@log_snapshot_after_test
|
|
def ha_one_controller_neutron_add_compute(self):
|
|
"""Add compute node to cluster in ha mode
|
|
|
|
Scenario:
|
|
1. Create cluster in HA mode
|
|
2. Add 1 node with controller role
|
|
3. Add 1 node with compute role
|
|
4. Deploy the cluster
|
|
5. Validate cluster was set up correctly, there are no dead
|
|
services, there are no errors in logs
|
|
6. Add 1 node with role compute
|
|
7. Deploy changes
|
|
8. Validate cluster was set up correctly, there are no dead
|
|
services, there are no errors in logs
|
|
9. Verify services list on compute nodes
|
|
10. Run OSTF
|
|
|
|
Duration 40m
|
|
Snapshot: ha_one_controller_neutron_add_compute
|
|
"""
|
|
self.env.revert_snapshot("ready_with_3_slaves")
|
|
|
|
data = {
|
|
'tenant': 'neutronAddCompute',
|
|
'user': 'neutronAddCompute',
|
|
'password': 'neutronAddCompute',
|
|
}
|
|
|
|
cluster_id = self.fuel_web.create_cluster(
|
|
name=self.__class__.__name__,
|
|
mode=DEPLOYMENT_MODE,
|
|
settings=data
|
|
)
|
|
self.fuel_web.update_nodes(
|
|
cluster_id,
|
|
{
|
|
'slave-01': ['controller'],
|
|
'slave-02': ['compute']
|
|
}
|
|
)
|
|
self.fuel_web.deploy_cluster_wait(cluster_id)
|
|
|
|
os_conn = os_actions.OpenStackActions(
|
|
self.fuel_web.get_public_vip(cluster_id),
|
|
data['user'], data['password'], data['tenant'])
|
|
self.fuel_web.assert_cluster_ready(os_conn, smiles_count=5)
|
|
|
|
self.fuel_web.update_nodes(
|
|
cluster_id, {'slave-03': ['compute']}, True, False)
|
|
self.fuel_web.deploy_cluster_wait(cluster_id)
|
|
|
|
self.fuel_web.assert_cluster_ready(os_conn, smiles_count=6)
|
|
|
|
assert_equal(
|
|
3, len(self.fuel_web.client.list_cluster_nodes(cluster_id)))
|
|
|
|
self.fuel_web.run_ostf(
|
|
cluster_id=cluster_id)
|
|
|
|
self.env.make_snapshot("ha_one_controller_neutron_add_compute")
|
|
|
|
@test(depends_on=[deploy_ha_one_controller_neutron],
|
|
groups=["deploy_base_os_node"])
|
|
@log_snapshot_after_test
|
|
def deploy_base_os_node(self):
|
|
"""Add base-os node to cluster in HA mode with one controller
|
|
|
|
Scenario:
|
|
1. Revert snapshot "deploy_ha_one_controller_neutron"
|
|
2. Add 1 node with base-os role
|
|
3. Deploy the cluster
|
|
4. Run network verification
|
|
5. Run OSTF
|
|
6. Ssh to the base-os node and check /etc/astute.yaml link source.
|
|
7. Make snapshot.
|
|
|
|
Snapshot: deploy_base_os_node
|
|
|
|
"""
|
|
self.env.revert_snapshot("deploy_ha_one_controller_neutron")
|
|
|
|
cluster_id = self.fuel_web.get_last_created_cluster()
|
|
|
|
self.fuel_web.update_nodes(
|
|
cluster_id, {'slave-03': ['base-os']}, True, False)
|
|
self.fuel_web.deploy_cluster_wait(cluster_id)
|
|
|
|
assert_equal(
|
|
3, len(self.fuel_web.client.list_cluster_nodes(cluster_id)))
|
|
|
|
self.fuel_web.verify_network(cluster_id)
|
|
|
|
self.fuel_web.run_ostf(cluster_id=cluster_id)
|
|
|
|
_ip = self.fuel_web.get_nailgun_node_by_name("slave-03")['ip']
|
|
result = self.ssh_manager.check_call(
|
|
command='hiera roles', ip=_ip).stdout_str
|
|
assert_equal(
|
|
'["base-os"]',
|
|
result,
|
|
message="Role mismatch. Node slave-03 is not base-os")
|
|
|
|
self.env.make_snapshot("deploy_base_os_node")
|
|
|
|
@test(depends_on=[deploy_ha_one_controller_neutron],
|
|
groups=["delete_environment"])
|
|
@log_snapshot_after_test
|
|
def delete_environment(self):
|
|
"""Delete existing environment
|
|
and verify nodes returns to unallocated state
|
|
|
|
Scenario:
|
|
1. Revert "deploy_ha_one_controller" environment
|
|
2. Delete environment
|
|
3. Verify node returns to unallocated pull
|
|
|
|
Duration 15m
|
|
"""
|
|
self.env.revert_snapshot("deploy_ha_one_controller_neutron")
|
|
|
|
cluster_id = self.fuel_web.get_last_created_cluster()
|
|
self.fuel_web.client.delete_cluster(cluster_id)
|
|
nailgun_nodes = self.fuel_web.client.list_nodes()
|
|
nodes = [
|
|
node for node in nailgun_nodes if node["pending_deletion"] is True]
|
|
assert_true(
|
|
len(nodes) == 2, "Verify 2 node has pending deletion status"
|
|
)
|
|
self.fuel_web.wait_node_is_discovered(nodes[0])
|
|
self.fuel_web.wait_node_is_discovered(nodes[1])
|
|
|
|
|
|
@test(groups=["multirole"])
|
|
class MultiroleControllerCinder(TestBasic):
|
|
"""MultiroleControllerCinder.""" # TODO documentation
|
|
|
|
@test(depends_on=[SetupEnvironment.prepare_slaves_3],
|
|
groups=["deploy_multirole_controller_cinder"])
|
|
@log_snapshot_after_test
|
|
def deploy_multirole_controller_cinder(self):
|
|
"""Deploy cluster in HA mode with multi-role controller and cinder
|
|
|
|
Scenario:
|
|
1. Create cluster in HA mode
|
|
2. Add 1 node with controller and cinder roles
|
|
3. Add 1 node with compute role
|
|
4. Deploy the cluster
|
|
5. Run network verification
|
|
6. Run OSTF
|
|
|
|
Duration 30m
|
|
Snapshot: deploy_multirole_controller_cinder
|
|
|
|
"""
|
|
self.env.revert_snapshot("ready_with_3_slaves")
|
|
|
|
data = {
|
|
'tenant': 'multirolecinder',
|
|
'user': 'multirolecinder',
|
|
'password': 'multirolecinder',
|
|
}
|
|
|
|
cluster_id = self.fuel_web.create_cluster(
|
|
name=self.__class__.__name__,
|
|
mode=DEPLOYMENT_MODE,
|
|
settings=data
|
|
)
|
|
self.fuel_web.update_nodes(
|
|
cluster_id,
|
|
{
|
|
'slave-01': ['controller', 'cinder'],
|
|
'slave-02': ['compute']
|
|
}
|
|
)
|
|
self.fuel_web.deploy_cluster_wait(cluster_id)
|
|
|
|
self.fuel_web.verify_network(cluster_id)
|
|
|
|
self.fuel_web.run_ostf(cluster_id=cluster_id)
|
|
|
|
self.env.make_snapshot("deploy_multirole_controller_cinder")
|
|
|
|
|
|
@test(groups=["multirole"])
|
|
class MultiroleComputeCinder(TestBasic):
|
|
"""MultiroleComputeCinder.""" # TODO documentation
|
|
|
|
@test(depends_on=[SetupEnvironment.prepare_slaves_3],
|
|
groups=["deploy_multirole_compute_cinder", "bvt_3"])
|
|
@log_snapshot_after_test
|
|
def deploy_multirole_compute_cinder(self):
|
|
"""Deploy cluster in HA mode with multi-role compute and cinder
|
|
|
|
Scenario:
|
|
1. Create cluster in Ha mode
|
|
2. Add 1 node with controller role
|
|
3. Add 2 node with compute and cinder roles
|
|
4. Deploy the cluster
|
|
5. Run network verification
|
|
6. Run OSTF
|
|
|
|
Duration 30m
|
|
Snapshot: deploy_multirole_compute_cinder
|
|
|
|
"""
|
|
self.env.revert_snapshot("ready_with_3_slaves")
|
|
|
|
cluster_id = self.fuel_web.create_cluster(
|
|
name=self.__class__.__name__,
|
|
mode=DEPLOYMENT_MODE,
|
|
)
|
|
self.fuel_web.update_nodes(
|
|
cluster_id,
|
|
{
|
|
'slave-01': ['controller'],
|
|
'slave-02': ['compute', 'cinder'],
|
|
'slave-03': ['compute', 'cinder']
|
|
}
|
|
)
|
|
self.fuel_web.deploy_cluster_wait(cluster_id)
|
|
|
|
self.fuel_web.verify_network(cluster_id)
|
|
|
|
self.fuel_web.run_ostf(cluster_id=cluster_id)
|
|
|
|
self.env.make_snapshot("deploy_multirole_compute_cinder")
|
|
|
|
|
|
@test(groups=["multirole"])
|
|
class MultiroleMultipleServices(TestBasic):
|
|
"""MultiroleMultipleServices.""" # TODO documentation
|
|
|
|
@test(depends_on=[SetupEnvironment.prepare_slaves_3],
|
|
groups=["deploy_multiple_services_local_mirror"])
|
|
@log_snapshot_after_test
|
|
def deploy_multiple_services_local_mirror(self):
|
|
"""Deploy cluster with multiple services using local mirror
|
|
|
|
Scenario:
|
|
1. Revert snapshot 'prepare_slaves_3' with default set of mirrors
|
|
2. Run 'fuel-mirror' to create mirror repositories
|
|
3. Create cluster with many components to check as many
|
|
packages in local mirrors have correct dependencies
|
|
4. Run 'fuel-mirror' to replace cluster repositories
|
|
with local mirrors
|
|
5. Check that repositories are changed
|
|
6. Deploy cluster
|
|
7. Check running services with OSTF
|
|
|
|
Duration 140m
|
|
"""
|
|
self.show_step(1)
|
|
self.env.revert_snapshot('ready_with_3_slaves')
|
|
|
|
self.show_step(2)
|
|
admin_ip = self.ssh_manager.admin_ip
|
|
if MIRROR_UBUNTU != '':
|
|
ubuntu_url = MIRROR_UBUNTU.split()[1]
|
|
replace_cmd = \
|
|
"sed -i 's,http://archive.ubuntu.com/ubuntu,{0},g'" \
|
|
" /usr/share/fuel-mirror/ubuntu.yaml".format(
|
|
ubuntu_url)
|
|
self.ssh_manager.check_call(ip=admin_ip, command=replace_cmd)
|
|
|
|
create_mirror_cmd = 'fuel-mirror create -P ubuntu -G mos ubuntu'
|
|
self.env.admin_actions.ensure_cmd(create_mirror_cmd)
|
|
|
|
self.show_step(3)
|
|
cluster_id = self.fuel_web.create_cluster(
|
|
name=self.__class__.__name__,
|
|
mode=DEPLOYMENT_MODE,
|
|
settings={
|
|
'net_provider': 'neutron',
|
|
'net_segment_type': NEUTRON_SEGMENT['tun'],
|
|
'sahara': True,
|
|
'volumes_lvm': True,
|
|
'volumes_ceph': False,
|
|
'images_ceph': True
|
|
}
|
|
)
|
|
|
|
self.show_step(4)
|
|
apply_mirror_cmd = 'fuel-mirror apply -P ubuntu -G mos ubuntu ' \
|
|
'--env {0} --replace'.format(cluster_id)
|
|
self.ssh_manager.check_call(ip=admin_ip, command=apply_mirror_cmd)
|
|
|
|
self.fuel_web.update_nodes(
|
|
cluster_id,
|
|
{
|
|
'slave-01': ['controller', 'ceph-osd'],
|
|
'slave-02': ['compute', 'ceph-osd'],
|
|
'slave-03': ['cinder', 'ceph-osd']
|
|
}
|
|
)
|
|
|
|
self.show_step(5)
|
|
repos_ubuntu = self.fuel_web.get_cluster_repos(cluster_id)
|
|
remote_repos = []
|
|
for repo_value in repos_ubuntu['value']:
|
|
if (self.fuel_web.admin_node_ip not in repo_value['uri'] and
|
|
'{settings.MASTER_IP}' not in repo_value['uri']):
|
|
remote_repos.append({repo_value['name']: repo_value['uri']})
|
|
assert_true(not remote_repos,
|
|
"Some repositories weren't replaced with local mirrors: "
|
|
"{0}".format(remote_repos))
|
|
|
|
self.fuel_web.verify_network(cluster_id)
|
|
self.show_step(6)
|
|
self.fuel_web.deploy_cluster_wait(cluster_id)
|
|
|
|
self.show_step(7)
|
|
self.fuel_web.run_ostf(
|
|
cluster_id=cluster_id,
|
|
test_sets=['smoke'])
|
|
|
|
|
|
@test
|
|
class FloatingIPs(TestBasic):
|
|
"""FloatingIPs.""" # TODO documentation
|
|
|
|
@test(depends_on=[SetupEnvironment.prepare_slaves_3],
|
|
groups=["deploy_floating_ips"])
|
|
@log_snapshot_after_test
|
|
def deploy_floating_ips(self):
|
|
"""Deploy cluster with non-default 1 floating IPs ranges
|
|
|
|
Scenario:
|
|
1. Create cluster in HA mode
|
|
2. Add 1 node with controller role
|
|
3. Add 1 node with compute and cinder roles
|
|
4. Update floating IP ranges. Use 1 range
|
|
5. Deploy the cluster
|
|
6. Verify available floating IP list
|
|
7. Run OSTF
|
|
|
|
Duration 30m
|
|
Snapshot: deploy_floating_ips
|
|
|
|
"""
|
|
# Test should be re-worked for neutron according to LP#1481322
|
|
self.env.revert_snapshot("ready_with_3_slaves")
|
|
|
|
csettings = {
|
|
'tenant': 'floatingip',
|
|
'user': 'floatingip',
|
|
'password': 'floatingip',
|
|
'net_provider': 'neutron',
|
|
'net_segment_type': NEUTRON_SEGMENT_TYPE,
|
|
}
|
|
|
|
cluster_id = self.fuel_web.create_cluster(
|
|
name=self.__class__.__name__,
|
|
mode=DEPLOYMENT_MODE,
|
|
settings=csettings,
|
|
)
|
|
self.fuel_web.update_nodes(
|
|
cluster_id,
|
|
{
|
|
'slave-01': ['controller'],
|
|
'slave-02': ['compute']
|
|
}
|
|
)
|
|
|
|
floating_list = [self.fuel_web.get_floating_ranges()[0][0]]
|
|
networking_parameters = {
|
|
"floating_ranges": floating_list}
|
|
|
|
self.fuel_web.client.update_network(
|
|
cluster_id,
|
|
networking_parameters=networking_parameters
|
|
)
|
|
|
|
self.fuel_web.deploy_cluster_wait(cluster_id)
|
|
|
|
os_conn = os_actions.OpenStackActions(
|
|
self.fuel_web.get_public_vip(cluster_id),
|
|
user=csettings['user'],
|
|
passwd=csettings['password'],
|
|
tenant=csettings['tenant'])
|
|
|
|
# assert ips
|
|
expected_ips = self.fuel_web.get_floating_ranges()[1][0]
|
|
self.fuel_web.assert_cluster_floating_list(
|
|
os_conn, cluster_id, expected_ips)
|
|
|
|
self.fuel_web.run_ostf(cluster_id=cluster_id)
|
|
|
|
self.env.make_snapshot("deploy_floating_ips")
|
|
|
|
|
|
@test(enabled=False, groups=["thread_1"])
|
|
class NodeMultipleInterfaces(TestBasic):
|
|
"""NodeMultipleInterfaces.
|
|
|
|
Test disabled and move to fuel_tests suite:
|
|
fuel_tests.test.test_l2_network_config
|
|
""" # TODO documentation
|
|
|
|
@test(depends_on=[SetupEnvironment.prepare_slaves_3],
|
|
groups=["deploy_node_multiple_interfaces"])
|
|
@log_snapshot_after_test
|
|
def deploy_node_multiple_interfaces(self):
|
|
"""Deploy cluster with networks allocated on different interfaces
|
|
|
|
Test disabled and move to fuel_tests suite:
|
|
fuel_tests.test.test_l2_network_config.TestL2NetworkConfig
|
|
|
|
Scenario:
|
|
1. Create cluster in Ha mode
|
|
2. Add 1 node with controller role
|
|
3. Add 1 node with compute role
|
|
4. Add 1 node with cinder role
|
|
5. Split networks on existing physical interfaces
|
|
6. Deploy the cluster
|
|
7. Verify network configuration on each deployed node
|
|
8. Run network verification
|
|
|
|
Duration 25m
|
|
Snapshot: deploy_node_multiple_interfaces
|
|
|
|
"""
|
|
# pylint: disable=W0101
|
|
warn("Test disabled and move to fuel_tests suite", DeprecationWarning)
|
|
raise SkipTest("Test disabled and move to fuel_tests suite")
|
|
|
|
self.env.revert_snapshot("ready_with_3_slaves")
|
|
|
|
interfaces_dict = {
|
|
iface_alias('eth0'): ['fuelweb_admin'],
|
|
iface_alias('eth1'): ['public'],
|
|
iface_alias('eth2'): ['storage'],
|
|
iface_alias('eth3'): ['private'],
|
|
iface_alias('eth4'): ['management'],
|
|
}
|
|
|
|
cluster_id = self.fuel_web.create_cluster(
|
|
name=self.__class__.__name__,
|
|
mode=DEPLOYMENT_MODE,
|
|
)
|
|
self.fuel_web.update_nodes(
|
|
cluster_id,
|
|
{
|
|
'slave-01': ['controller'],
|
|
'slave-02': ['compute'],
|
|
'slave-03': ['cinder']
|
|
}
|
|
)
|
|
nailgun_nodes = self.fuel_web.client.list_cluster_nodes(cluster_id)
|
|
for node in nailgun_nodes:
|
|
self.fuel_web.update_node_networks(node['id'], interfaces_dict)
|
|
|
|
self.fuel_web.deploy_cluster_wait(cluster_id)
|
|
|
|
self.fuel_web.verify_network(cluster_id)
|
|
|
|
self.env.make_snapshot("deploy_node_multiple_interfaces", is_make=True)
|
|
|
|
|
|
@test(enabled=False, groups=["thread_1"])
|
|
class NodeDiskSizes(TestBasic):
|
|
"""NodeDiskSizes.
|
|
|
|
Test disabled and move to fuel_tests suite:
|
|
fuel_tests.test.test_discovery_slave
|
|
|
|
""" # TODO documentation
|
|
|
|
@test(enabled=False, depends_on=[SetupEnvironment.prepare_slaves_3],
|
|
groups=["check_nodes_notifications"])
|
|
@log_snapshot_after_test
|
|
def check_nodes_notifications(self):
|
|
"""Verify nailgun notifications for discovered nodes
|
|
|
|
Test disabled and move to fuel_tests suite:
|
|
fuel_tests.test.test_discovery_slave.TestNodeDiskSizes
|
|
|
|
Scenario:
|
|
1. Revert snapshot "ready_with_3_slaves"
|
|
2. Verify hard drive sizes for discovered nodes in /api/nodes
|
|
3. Verify hard drive sizes for discovered nodes in notifications
|
|
|
|
Duration 5m
|
|
|
|
"""
|
|
# pylint: disable=W0101
|
|
warn("Test disabled and move to fuel_tests suite", DeprecationWarning)
|
|
raise SkipTest("Test disabled and move to fuel_tests suite")
|
|
|
|
self.env.revert_snapshot("ready_with_3_slaves")
|
|
|
|
# assert /api/nodes
|
|
disk_size = NODE_VOLUME_SIZE * 1024 ** 3
|
|
nailgun_nodes = self.fuel_web.client.list_nodes()
|
|
for node in nailgun_nodes:
|
|
for disk in node['meta']['disks']:
|
|
assert_equal(disk['size'], disk_size, 'Disk size')
|
|
|
|
hdd_size = "{0:.3} TB HDD".format((disk_size * 3 / (10 ** 9)) / 1000)
|
|
notifications = self.fuel_web.client.get_notifications()
|
|
|
|
for node in nailgun_nodes:
|
|
# assert /api/notifications
|
|
for notification in notifications:
|
|
discover = notification['topic'] == 'discover'
|
|
current_node = notification['node_id'] == node['id']
|
|
if current_node and discover and \
|
|
"discovered" in notification['message']:
|
|
assert_true(hdd_size in notification['message'],
|
|
'"{size} not found in notification message '
|
|
'"{note}" for node {node} '
|
|
'(hostname {host})!'.format(
|
|
size=hdd_size,
|
|
note=notification['message'],
|
|
node=node['name'],
|
|
host=node['hostname'])
|
|
)
|
|
|
|
# assert disks
|
|
disks = self.fuel_web.client.get_node_disks(node['id'])
|
|
for disk in disks:
|
|
assert_equal(
|
|
disk['size'], NODE_VOLUME_SIZE * 1024 - 500,
|
|
'Disk size {0} is not equals expected {1}'.format(
|
|
disk['size'], NODE_VOLUME_SIZE * 1024 - 500
|
|
))
|
|
|
|
@test(enabled=False,
|
|
depends_on=[NodeMultipleInterfaces.deploy_node_multiple_interfaces],
|
|
groups=["check_nodes_disks"])
|
|
@log_snapshot_after_test
|
|
def check_nodes_disks(self):
|
|
"""Verify hard drive sizes for deployed nodes
|
|
|
|
Test disabled and move to fuel_tests suite:
|
|
fuel_tests.test.test_discovery_slave.TestNodeDiskSizes
|
|
|
|
Scenario:
|
|
1. Revert snapshot "deploy_node_multiple_interfaces"
|
|
2. Verify hard drive sizes for deployed nodes
|
|
|
|
Duration 15m
|
|
"""
|
|
# pylint: disable=W0101
|
|
warn("Test disabled and move to fuel_tests suite", DeprecationWarning)
|
|
raise SkipTest("Test disabled and move to fuel_tests suite")
|
|
|
|
self.env.revert_snapshot("deploy_node_multiple_interfaces")
|
|
|
|
nodes_dict = {
|
|
'slave-01': ['controller'],
|
|
'slave-02': ['compute'],
|
|
'slave-03': ['cinder']
|
|
}
|
|
|
|
# assert node disks after deployment
|
|
for node_name in nodes_dict:
|
|
str_block_devices = self.fuel_web.get_cluster_block_devices(
|
|
node_name)
|
|
|
|
logger.debug("Block device:\n{}".format(str_block_devices))
|
|
|
|
expected_regexp = re.compile(
|
|
"vda\s+\d+:\d+\s+0\s+{}G\s+0\s+disk".format(NODE_VOLUME_SIZE))
|
|
assert_true(
|
|
expected_regexp.search(str_block_devices),
|
|
"Unable to find vda block device for {}G in: {}".format(
|
|
NODE_VOLUME_SIZE, str_block_devices
|
|
))
|
|
|
|
expected_regexp = re.compile(
|
|
"vdb\s+\d+:\d+\s+0\s+{}G\s+0\s+disk".format(NODE_VOLUME_SIZE))
|
|
assert_true(
|
|
expected_regexp.search(str_block_devices),
|
|
"Unable to find vdb block device for {}G in: {}".format(
|
|
NODE_VOLUME_SIZE, str_block_devices
|
|
))
|
|
|
|
expected_regexp = re.compile(
|
|
"vdc\s+\d+:\d+\s+0\s+{}G\s+0\s+disk".format(NODE_VOLUME_SIZE))
|
|
assert_true(
|
|
expected_regexp.search(str_block_devices),
|
|
"Unable to find vdc block device for {}G in: {}".format(
|
|
NODE_VOLUME_SIZE, str_block_devices
|
|
))
|
|
|
|
|
|
@test(enabled=False, groups=["thread_1"])
|
|
class MultinicBootstrap(TestBasic):
|
|
"""MultinicBootstrap.
|
|
|
|
Test disabled and move to fuel_tests suite:
|
|
fuel_tests.test.test_discovery_slave
|
|
|
|
""" # TODO documentation
|
|
|
|
@test(enabled=False,
|
|
depends_on=[SetupEnvironment.prepare_release],
|
|
groups=["multinic_bootstrap_booting"])
|
|
@log_snapshot_after_test
|
|
def multinic_bootstrap_booting(self):
|
|
"""Verify slaves booting with blocked mac address
|
|
|
|
Test disabled and move to fuel_tests suite:
|
|
fuel_tests.test.test_discovery_slave.TestMultinicBootstrap
|
|
|
|
Scenario:
|
|
1. Revert snapshot "ready"
|
|
2. Block traffic for first slave node (by mac)
|
|
3. Restore mac addresses and boot first slave
|
|
4. Verify slave mac addresses is equal to unblocked
|
|
|
|
Duration 2m
|
|
|
|
"""
|
|
# pylint: disable=W0101
|
|
warn("Test disabled and move to fuel_tests suite", DeprecationWarning)
|
|
raise SkipTest("Test disabled and move to fuel_tests suite")
|
|
|
|
self.env.revert_snapshot("ready")
|
|
|
|
slave = self.env.d_env.nodes().slaves[0]
|
|
mac_addresses = [interface.mac_address for interface in
|
|
slave.interfaces.filter(network__name='internal')]
|
|
try:
|
|
for mac in mac_addresses:
|
|
Ebtables.block_mac(mac)
|
|
for mac in mac_addresses:
|
|
Ebtables.restore_mac(mac)
|
|
slave.destroy()
|
|
self.env.d_env.nodes().admins[0].revert("ready")
|
|
nailgun_slave = self.env.bootstrap_nodes([slave])[0]
|
|
assert_equal(mac.upper(), nailgun_slave['mac'].upper())
|
|
Ebtables.block_mac(mac)
|
|
finally:
|
|
for mac in mac_addresses:
|
|
Ebtables.restore_mac(mac)
|
|
|
|
|
|
@test(enabled=False, groups=["thread_1"])
|
|
class UntaggedNetworksNegative(TestBasic):
|
|
"""UntaggedNetworksNegative.
|
|
|
|
Test disabled and move to fuel_tests suite:
|
|
fuel_tests.test.test_l2_network_config.TestL2NetworkConfig
|
|
|
|
""" # TODO documentation
|
|
|
|
@test(
|
|
depends_on=[SetupEnvironment.prepare_slaves_3],
|
|
groups=["untagged_networks_negative"],
|
|
enabled=False)
|
|
@log_snapshot_after_test
|
|
def untagged_networks_negative(self):
|
|
"""Verify network verification fails with untagged network on eth0
|
|
|
|
Test disabled and move to fuel_tests suite:
|
|
fuel_tests.test.test_l2_network_config.TestL2NetworkConfig
|
|
|
|
Scenario:
|
|
1. Create cluster in ha mode
|
|
2. Add 1 node with controller role
|
|
3. Add 1 node with compute role
|
|
4. Split networks on existing physical interfaces
|
|
5. Remove VLAN tagging from networks which are on eth0
|
|
6. Run network verification (assert it fails)
|
|
7. Start cluster deployment (assert it fails)
|
|
|
|
Duration 30m
|
|
|
|
"""
|
|
# pylint: disable=W0101
|
|
warn("Test disabled and move to fuel_tests suite", DeprecationWarning)
|
|
raise SkipTest("Test disabled and move to fuel_tests suite")
|
|
|
|
self.env.revert_snapshot("ready_with_3_slaves")
|
|
|
|
vlan_turn_off = {'vlan_start': None}
|
|
interfaces = {
|
|
iface_alias('eth0'): ["fixed"],
|
|
iface_alias('eth1'): ["public"],
|
|
iface_alias('eth2'): ["management", "storage"],
|
|
iface_alias('eth3'): []
|
|
}
|
|
|
|
cluster_id = self.fuel_web.create_cluster(
|
|
name=self.__class__.__name__,
|
|
mode=DEPLOYMENT_MODE
|
|
)
|
|
self.fuel_web.update_nodes(
|
|
cluster_id,
|
|
{
|
|
'slave-01': ['controller'],
|
|
'slave-02': ['compute']
|
|
}
|
|
)
|
|
|
|
nets = self.fuel_web.client.get_networks(cluster_id)['networks']
|
|
nailgun_nodes = self.fuel_web.client.list_cluster_nodes(cluster_id)
|
|
for node in nailgun_nodes:
|
|
self.fuel_web.update_node_networks(node['id'], interfaces)
|
|
|
|
# select networks that will be untagged:
|
|
for net in nets:
|
|
net.update(vlan_turn_off)
|
|
|
|
# stop using VLANs:
|
|
self.fuel_web.client.update_network(cluster_id, networks=nets)
|
|
|
|
# run network check:
|
|
self.fuel_web.verify_network(cluster_id, success=False)
|
|
|
|
# deploy cluster:
|
|
task = self.fuel_web.deploy_cluster(cluster_id)
|
|
self.fuel_web.assert_task_failed(task)
|
|
|
|
|
|
@test(groups=["thread_usb"])
|
|
class HAOneControllerNeutronUSB(HAOneControllerNeutronBase):
|
|
"""HAOneControllerNeutronUSB.""" # TODO documentation
|
|
|
|
@test(depends_on=[SetupEnvironment.prepare_slaves_3])
|
|
@log_snapshot_after_test
|
|
def deploy_ha_one_controller_neutron_usb(self):
|
|
"""Deploy cluster in HA mode (1 controller) with neutron USB
|
|
|
|
Scenario:
|
|
1. Create cluster in HA mode
|
|
2. Add 1 node with controller role
|
|
3. Add 1 node with compute role
|
|
4. Deploy the cluster
|
|
5. Validate cluster was set up correctly, there are no dead
|
|
services, there are no errors in logs
|
|
6. Verify networks
|
|
7. Verify network configuration on controller
|
|
8. Run OSTF
|
|
|
|
Duration 30m
|
|
Snapshot: deploy_ha_one_controller_neutron
|
|
"""
|
|
|
|
super(self.__class__, self).deploy_ha_one_controller_neutron_base(
|
|
snapshot_name="deploy_ha_one_controller_neutron_usb")
|