openstack
/
fuel-qa
Code Issues Proposed changes

Add tests for Virt role nodes and VM spawing 

Add tests for checking VM spawning feature.

Change-Id: I32e7a290411ff8ccd2811f7f053a62fbc408d544
Implements: blueprint reduced-footprint-tests
This commit is contained in:
Dmitry Kalashnik 2015-08-16 20:27:47 +03:00
parent c041bda502
commit beb9d7f60a
6 changed files with 259 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
doc/base_tests.rst
View File

@ -116,6 +116,11 @@ Test Pull Requests
.. automodule:: fuelweb_test.tests.test_pullrequest
:members:
Test Reduced Footprint
----------------------
.. automodule:: fuelweb_test.tests.test_reduced_footprint
:members:
Test Services
-------------
.. automodule:: fuelweb_test.tests.test_services

8
fuelweb_test/helpers/checkers.py
View File

@ -348,6 +348,14 @@ def check_enable_experimental_mode(remote, path):
assert_equal(0, result['exit_code'], result['stderr'])
@logwrap
def enable_advanced_mode(remote, path):
cmd = "sed '/feature_groups:" \
"/a \ \ \ \ - advanced' -i {0}".format(path)
result = remote.execute(cmd)
assert_equal(0, result['exit_code'], result['stderr'])
@logwrap
def restart_nailgun(remote):
cmd = 'dockerctl shell nailgun supervisorctl restart nailgun'

6
fuelweb_test/models/fuel_web_client.py
View File

@ -2332,3 +2332,9 @@ class FuelWebClient(object):
return {'username': username,
'password': password,
'tenant': tenant}
@logwrap
def spawn_vms_wait(self, cluster_id, timeout=60 * 60, interval=30):
logger.info('Spawn VMs of a cluster %s', cluster_id)
task = self.client.spawn_vms(cluster_id)
self.assert_task_success(task, timeout=timeout, interval=interval)

14
fuelweb_test/models/nailgun_client.py
View File

@ -503,3 +503,17 @@ class NailgunClient(object):
@json_parse
def add_network_group(self, network_data):
return self.client.post('/api/networks/', data=network_data)
@logwrap
@json_parse
def create_vm_nodes(self, node_id, data):
logger.info("Uploading VMs configuration to node {0}: {1}".
format(node_id, data))
url = "/api/nodes/{0}/vms_conf/".format(node_id)
return self.client.put(url, {'vms_conf': data})
@logwrap
@json_parse
def spawn_vms(self, cluster_id):
url = '/api/clusters/{0}/spawn_vms/'.format(cluster_id)
return self.client.put(url)

1
fuelweb_test/run_tests.py
View File

@ -52,6 +52,7 @@ def import_tests():
from tests import test_services # noqa
from tests import test_ha_one_controller # noqa
from tests import test_vcenter # noqa
from tests import test_reduced_footprint # noqa
from tests.tests_separate_services import test_separate_db # noqa
from tests.tests_separate_services import test_separate_horizon # noqa
from tests.tests_separate_services import test_separate_keystone # noqa

225
fuelweb_test/tests/test_reduced_footprint.py Normal file
View File

@ -0,0 +1,225 @@
# Copyright 2015 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 devops.helpers.helpers import wait
from proboscis import asserts
from proboscis import test
from fuelweb_test.helpers import checkers
from fuelweb_test.helpers.decorators import log_snapshot_after_test
from fuelweb_test import settings
from fuelweb_test.tests.base_test_case import SetupEnvironment
from fuelweb_test.tests.base_test_case import TestBasic
@test(groups=["virt_role", "reduced_footprint"])
class TestVirtRole(TestBasic):
"""Tests for virt role.
Part of Reduced footprint feature.
Creating reduced footprint environments performed by assigning new role
named "virt" to physical server, after that user should upload VMs
properties as node attributes. Virtual machines will be treated by Fuel
as standard bare metal servers.
"""
@test(depends_on=[SetupEnvironment.prepare_slaves_1],
groups=["spawn_one_vm_on_one_virt_node"])
@log_snapshot_after_test
def spawn_one_vm_on_one_virt_node(self):
"""Spawn one vm node on one slave node
Scenario:
1. Create cluster
2. Assign compute and virt roles to slave node
3. Upload configuration for one VM
4. Spawn VM
5. Wait till VM become available for allocation
Duration: 60m
"""
self.env.revert_snapshot("ready_with_1_slaves")
with self.env.d_env.get_admin_remote() as remote:
checkers.enable_advanced_mode(remote, '/etc/fuel/version.yaml')
checkers.restart_nailgun(remote)
cluster_id = self.fuel_web.create_cluster(
name=self.__class__.__name__,
mode=settings.DEPLOYMENT_MODE_HA,
settings={
'net_provider': 'neutron',
'net_segment_type': settings.NEUTRON_SEGMENT['tun']
})
asserts.assert_true(settings.HARDWARE['slave_node_memory'] >= 1024,
"Wrong SLAVE_NODE_MEMORY value: {0}."
"Please allocate more than 1024Mb.".
format(settings.HARDWARE['slave_node_memory']))
self.fuel_web.update_nodes(
cluster_id,
{
'slave-01': ['compute', 'virt']
})
node_id = self.fuel_web.get_nailgun_node_by_name("slave-01")['id']
self.fuel_web.client.create_vm_nodes(
node_id,
[{
"id": 1,
"mem": 1,
"cpu": 1
}])
self.fuel_web.spawn_vms_wait(cluster_id)
wait(lambda: len(self.fuel_web.client.list_nodes()) == 2,
timeout=60 * 60,
timeout_msg=("Timeout waiting 2 available nodes, "
"current nodes: \n{0}" + '\n'.join(
['Name: {0}, status: {1}, online: {2}'.
format(i['name'], i['status'], i['online'])
for i in self.fuel_web.client.list_nodes()])))
@test(depends_on=[SetupEnvironment.prepare_slaves_1],
groups=["spawn_two_vms_on_one_virt_node"])
@log_snapshot_after_test
def spawn_two_vms_on_one_virt_node(self):
"""Spawn two vm nodes on one slave node
Scenario:
1. Create cluster
2. Assign compute and virt roles to slave node
3. Upload configuration for two VMs
4. Spawn VMs
5. Wait till VMs become available for allocation
Duration: 60m
"""
self.env.revert_snapshot("ready_with_1_slaves")
with self.env.d_env.get_admin_remote() as remote:
checkers.enable_advanced_mode(remote, '/etc/fuel/version.yaml')
checkers.restart_nailgun(remote)
cluster_id = self.fuel_web.create_cluster(
name=self.__class__.__name__,
mode=settings.DEPLOYMENT_MODE_HA,
settings={
'net_provider': 'neutron',
'net_segment_type': settings.NEUTRON_SEGMENT['tun']
})
asserts.assert_true(settings.HARDWARE['slave_node_memory'] >= 2048,
"Wrong SLAVE_NODE_MEMORY value: {0}."
"Please allocate more than 2048Mb.".
format(settings.HARDWARE['slave_node_memory']))
self.fuel_web.update_nodes(
cluster_id,
{
'slave-01': ['compute', 'virt']
})
node_id = self.fuel_web.get_nailgun_node_by_name("slave-01")['id']
self.fuel_web.client.create_vm_nodes(
node_id,
[
{
"id": 1,
"mem": 1,
"cpu": 1
},
{
"id": 2,
"mem": 1,
"cpu": 1
}
])
self.fuel_web.spawn_vms_wait(cluster_id)
wait(lambda: len(self.fuel_web.client.list_nodes()) == 3,
timeout=60 * 60,
timeout_msg=("Timeout waiting 3 available nodes, "
"current nodes: \n{0}" + '\n'.join(
['Name: {0}, status: {1}, online: {2}'.
format(i['name'], i['status'], i['online'])
for i in self.fuel_web.client.list_nodes()])))
@test(depends_on=[SetupEnvironment.prepare_slaves_3],
groups=["spawn_three_vms_across_three_virt_nodes"])
@log_snapshot_after_test
def spawn_three_vms_across_three_virt_nodes(self):
"""Spawn three vm nodes across three slave nodes
Scenario:
1. Create cluster
2. Assign compute and virt roles to three slave nodes
3. Upload VM configuration for one VM to each slave node
4. Spawn VMs
5. Wait till VMs become available for allocation
Duration: 60m
"""
self.env.revert_snapshot("ready_with_3_slaves")
with self.env.d_env.get_admin_remote() as remote:
checkers.enable_advanced_mode(remote, '/etc/fuel/version.yaml')
checkers.restart_nailgun(remote)
cluster_id = self.fuel_web.create_cluster(
name=self.__class__.__name__,
mode=settings.DEPLOYMENT_MODE_HA,
settings={
'net_provider': 'neutron',
'net_segment_type': settings.NEUTRON_SEGMENT['tun']
})
asserts.assert_true(settings.HARDWARE['slave_node_memory'] >= 1024,
"Wrong SLAVE_NODE_MEMORY value: {0}."
"Please allocate more than 1024Mb.".
format(settings.HARDWARE['slave_node_memory']))
self.fuel_web.update_nodes(
cluster_id,
{
'slave-01': ['compute', 'virt'],
'slave-02': ['compute', 'virt'],
'slave-03': ['compute', 'virt']
})
hw_nodes = self.fuel_web.client.list_cluster_nodes(cluster_id)
for node in hw_nodes:
self.fuel_web.client.create_vm_nodes(
node['id'],
[
{
"id": 1,
"mem": 1,
"cpu": 1
}
])
self.fuel_web.spawn_vms_wait(cluster_id)
wait(lambda: len(self.fuel_web.client.list_nodes()) == 6,
timeout=60 * 60,
timeout_msg=("Timeout waiting 6 available nodes, "
"current nodes: \n{0}" + '\n'.join(
['Name: {0}, status: {1}, online: {2}'.
format(i['name'], i['status'], i['online'])
for i in self.fuel_web.client.list_nodes()])))