844 lines
40 KiB
Python
844 lines
40 KiB
Python
# coding=utf-8
|
|
|
|
# Copyright 2013 Hewlett-Packard Development Company, L.P.
|
|
# All Rights Reserved.
|
|
#
|
|
# 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.
|
|
|
|
"""Test class for PXE driver."""
|
|
|
|
import os
|
|
import tempfile
|
|
|
|
import fixtures
|
|
import mock
|
|
from oslo.config import cfg
|
|
from oslo.serialization import jsonutils as json
|
|
|
|
from ironic.common import dhcp_factory
|
|
from ironic.common import exception
|
|
from ironic.common.glance_service import base_image_service
|
|
from ironic.common import keystone
|
|
from ironic.common import pxe_utils
|
|
from ironic.common import states
|
|
from ironic.common import utils
|
|
from ironic.conductor import task_manager
|
|
from ironic.conductor import utils as manager_utils
|
|
from ironic.drivers.modules import deploy_utils
|
|
from ironic.drivers.modules import iscsi_deploy
|
|
from ironic.drivers.modules import pxe
|
|
from ironic.openstack.common import fileutils
|
|
from ironic.tests.conductor import utils as mgr_utils
|
|
from ironic.tests.db import base as db_base
|
|
from ironic.tests.db import utils as db_utils
|
|
from ironic.tests.objects import utils as obj_utils
|
|
|
|
CONF = cfg.CONF
|
|
|
|
INST_INFO_DICT = db_utils.get_test_pxe_instance_info()
|
|
DRV_INFO_DICT = db_utils.get_test_pxe_driver_info()
|
|
|
|
|
|
class PXEValidateParametersTestCase(db_base.DbTestCase):
|
|
|
|
def test__parse_deploy_info(self):
|
|
# make sure we get back the expected things
|
|
node = obj_utils.create_test_node(self.context,
|
|
driver='fake_pxe',
|
|
instance_info=INST_INFO_DICT,
|
|
driver_info=DRV_INFO_DICT)
|
|
info = pxe._parse_deploy_info(node)
|
|
self.assertIsNotNone(info.get('deploy_ramdisk'))
|
|
self.assertIsNotNone(info.get('deploy_kernel'))
|
|
self.assertIsNotNone(info.get('image_source'))
|
|
self.assertIsNotNone(info.get('root_gb'))
|
|
self.assertEqual(0, info.get('ephemeral_gb'))
|
|
|
|
def test__parse_driver_info_missing_deploy_kernel(self):
|
|
# make sure error is raised when info is missing
|
|
info = dict(DRV_INFO_DICT)
|
|
del info['pxe_deploy_kernel']
|
|
node = obj_utils.create_test_node(self.context, driver_info=info)
|
|
self.assertRaises(exception.MissingParameterValue,
|
|
pxe._parse_driver_info,
|
|
node)
|
|
|
|
def test__parse_driver_info_missing_deploy_ramdisk(self):
|
|
# make sure error is raised when info is missing
|
|
info = dict(DRV_INFO_DICT)
|
|
del info['pxe_deploy_ramdisk']
|
|
node = obj_utils.create_test_node(self.context, driver_info=info)
|
|
self.assertRaises(exception.MissingParameterValue,
|
|
pxe._parse_driver_info,
|
|
node)
|
|
|
|
def test__parse_driver_info_good(self):
|
|
# make sure we get back the expected things
|
|
node = obj_utils.create_test_node(self.context,
|
|
driver='fake_pxe',
|
|
driver_info=DRV_INFO_DICT)
|
|
info = pxe._parse_driver_info(node)
|
|
self.assertIsNotNone(info.get('deploy_ramdisk'))
|
|
self.assertIsNotNone(info.get('deploy_kernel'))
|
|
|
|
|
|
class PXEPrivateMethodsTestCase(db_base.DbTestCase):
|
|
|
|
def setUp(self):
|
|
super(PXEPrivateMethodsTestCase, self).setUp()
|
|
n = {
|
|
'driver': 'fake_pxe',
|
|
'instance_info': INST_INFO_DICT,
|
|
'driver_info': DRV_INFO_DICT,
|
|
}
|
|
mgr_utils.mock_the_extension_manager(driver="fake_pxe")
|
|
self.node = obj_utils.create_test_node(self.context, **n)
|
|
|
|
@mock.patch.object(base_image_service.BaseImageService, '_show')
|
|
def test__get_image_info(self, show_mock):
|
|
properties = {'properties': {u'kernel_id': u'instance_kernel_uuid',
|
|
u'ramdisk_id': u'instance_ramdisk_uuid'}}
|
|
|
|
expected_info = {'ramdisk':
|
|
('instance_ramdisk_uuid',
|
|
os.path.join(CONF.pxe.tftp_root,
|
|
self.node.uuid,
|
|
'ramdisk')),
|
|
'kernel':
|
|
('instance_kernel_uuid',
|
|
os.path.join(CONF.pxe.tftp_root,
|
|
self.node.uuid,
|
|
'kernel')),
|
|
'deploy_ramdisk':
|
|
('deploy_ramdisk_uuid',
|
|
os.path.join(CONF.pxe.tftp_root,
|
|
self.node.uuid,
|
|
'deploy_ramdisk')),
|
|
'deploy_kernel':
|
|
('deploy_kernel_uuid',
|
|
os.path.join(CONF.pxe.tftp_root,
|
|
self.node.uuid,
|
|
'deploy_kernel'))}
|
|
show_mock.return_value = properties
|
|
image_info = pxe._get_image_info(self.node, self.context)
|
|
show_mock.assert_called_once_with('glance://image_uuid',
|
|
method='get')
|
|
self.assertEqual(expected_info, image_info)
|
|
|
|
# test with saved info
|
|
show_mock.reset_mock()
|
|
image_info = pxe._get_image_info(self.node, self.context)
|
|
self.assertEqual(expected_info, image_info)
|
|
self.assertFalse(show_mock.called)
|
|
self.assertEqual('instance_kernel_uuid',
|
|
self.node.instance_info.get('kernel'))
|
|
self.assertEqual('instance_ramdisk_uuid',
|
|
self.node.instance_info.get('ramdisk'))
|
|
|
|
@mock.patch.object(utils, 'random_alnum')
|
|
@mock.patch.object(pxe_utils, '_build_pxe_config')
|
|
def _test_build_pxe_config_options(self, build_pxe_mock, random_alnum_mock,
|
|
ipxe_enabled=False):
|
|
self.config(pxe_append_params='test_param', group='pxe')
|
|
# NOTE: right '/' should be removed from url string
|
|
self.config(api_url='http://192.168.122.184:6385/', group='conductor')
|
|
self.config(disk_devices='sda', group='pxe')
|
|
|
|
fake_key = '0123456789ABCDEFGHIJKLMNOPQRSTUV'
|
|
random_alnum_mock.return_value = fake_key
|
|
tftp_server = CONF.pxe.tftp_server
|
|
|
|
if ipxe_enabled:
|
|
http_url = 'http://192.1.2.3:1234'
|
|
self.config(ipxe_enabled=True, group='pxe')
|
|
self.config(http_url=http_url, group='pxe')
|
|
|
|
deploy_kernel = os.path.join(http_url, self.node.uuid,
|
|
'deploy_kernel')
|
|
deploy_ramdisk = os.path.join(http_url, self.node.uuid,
|
|
'deploy_ramdisk')
|
|
kernel = os.path.join(http_url, self.node.uuid, 'kernel')
|
|
ramdisk = os.path.join(http_url, self.node.uuid, 'ramdisk')
|
|
root_dir = CONF.pxe.http_root
|
|
else:
|
|
deploy_kernel = os.path.join(CONF.pxe.tftp_root, self.node.uuid,
|
|
'deploy_kernel')
|
|
deploy_ramdisk = os.path.join(CONF.pxe.tftp_root, self.node.uuid,
|
|
'deploy_ramdisk')
|
|
kernel = os.path.join(CONF.pxe.tftp_root, self.node.uuid,
|
|
'kernel')
|
|
ramdisk = os.path.join(CONF.pxe.tftp_root, self.node.uuid,
|
|
'ramdisk')
|
|
root_dir = CONF.pxe.tftp_root
|
|
|
|
expected_options = {
|
|
'deployment_key': '0123456789ABCDEFGHIJKLMNOPQRSTUV',
|
|
'ari_path': ramdisk,
|
|
'iscsi_target_iqn': u'iqn-1be26c0b-03f2-4d2e-ae87-c02d7f33'
|
|
u'c123',
|
|
'deployment_ari_path': deploy_ramdisk,
|
|
'pxe_append_params': 'test_param',
|
|
'aki_path': kernel,
|
|
'deployment_id': u'1be26c0b-03f2-4d2e-ae87-c02d7f33c123',
|
|
'ironic_api_url': 'http://192.168.122.184:6385',
|
|
'deployment_aki_path': deploy_kernel,
|
|
'disk': 'sda',
|
|
'tftp_server': tftp_server
|
|
}
|
|
|
|
image_info = {'deploy_kernel': ('deploy_kernel',
|
|
os.path.join(root_dir,
|
|
self.node.uuid,
|
|
'deploy_kernel')),
|
|
'deploy_ramdisk': ('deploy_ramdisk',
|
|
os.path.join(root_dir,
|
|
self.node.uuid,
|
|
'deploy_ramdisk')),
|
|
'kernel': ('kernel_id',
|
|
os.path.join(root_dir,
|
|
self.node.uuid,
|
|
'kernel')),
|
|
'ramdisk': ('ramdisk_id',
|
|
os.path.join(root_dir,
|
|
self.node.uuid,
|
|
'ramdisk'))
|
|
}
|
|
options = pxe._build_pxe_config_options(self.node,
|
|
image_info,
|
|
self.context)
|
|
self.assertEqual(expected_options, options)
|
|
|
|
random_alnum_mock.assert_called_once_with(32)
|
|
|
|
# test that deploy_key saved
|
|
db_node = self.dbapi.get_node_by_uuid(self.node.uuid)
|
|
db_key = db_node.instance_info.get('deploy_key')
|
|
self.assertEqual(fake_key, db_key)
|
|
|
|
def test__build_pxe_config_options(self):
|
|
self._test_build_pxe_config_options(ipxe_enabled=False)
|
|
|
|
def test__build_pxe_config_options_ipxe(self):
|
|
self._test_build_pxe_config_options(ipxe_enabled=True)
|
|
|
|
def test_get_token_file_path(self):
|
|
node_uuid = self.node.uuid
|
|
self.assertEqual('/tftpboot/token-' + node_uuid,
|
|
pxe._get_token_file_path(node_uuid))
|
|
|
|
@mock.patch.object(deploy_utils, 'fetch_images')
|
|
def test__cache_tftp_images_master_path(self, mock_fetch_image):
|
|
temp_dir = tempfile.mkdtemp()
|
|
self.config(tftp_root=temp_dir, group='pxe')
|
|
self.config(tftp_master_path=os.path.join(temp_dir,
|
|
'tftp_master_path'),
|
|
group='pxe')
|
|
image_path = os.path.join(temp_dir, self.node.uuid,
|
|
'deploy_kernel')
|
|
image_info = {'deploy_kernel': ('deploy_kernel', image_path)}
|
|
fileutils.ensure_tree(CONF.pxe.tftp_master_path)
|
|
|
|
pxe._cache_ramdisk_kernel(None, self.node, image_info)
|
|
|
|
mock_fetch_image.assert_called_once_with(None,
|
|
mock.ANY,
|
|
[('deploy_kernel',
|
|
image_path)],
|
|
True)
|
|
|
|
@mock.patch.object(pxe, 'TFTPImageCache', lambda: None)
|
|
@mock.patch.object(fileutils, 'ensure_tree')
|
|
@mock.patch.object(deploy_utils, 'fetch_images')
|
|
def test__cache_ramdisk_kernel(self, mock_fetch_image, mock_ensure_tree):
|
|
self.config(ipxe_enabled=False, group='pxe')
|
|
fake_pxe_info = {'foo': 'bar'}
|
|
expected_path = os.path.join(CONF.pxe.tftp_root, self.node.uuid)
|
|
|
|
pxe._cache_ramdisk_kernel(self.context, self.node, fake_pxe_info)
|
|
mock_ensure_tree.assert_called_with(expected_path)
|
|
mock_fetch_image.assert_called_once_with(self.context, mock.ANY,
|
|
fake_pxe_info.values(), True)
|
|
|
|
@mock.patch.object(pxe, 'TFTPImageCache', lambda: None)
|
|
@mock.patch.object(fileutils, 'ensure_tree')
|
|
@mock.patch.object(deploy_utils, 'fetch_images')
|
|
def test__cache_ramdisk_kernel_ipxe(self, mock_fetch_image,
|
|
mock_ensure_tree):
|
|
self.config(ipxe_enabled=True, group='pxe')
|
|
fake_pxe_info = {'foo': 'bar'}
|
|
expected_path = os.path.join(CONF.pxe.http_root, self.node.uuid)
|
|
|
|
pxe._cache_ramdisk_kernel(self.context, self.node, fake_pxe_info)
|
|
mock_ensure_tree.assert_called_with(expected_path)
|
|
mock_fetch_image.assert_called_once_with(self.context, mock.ANY,
|
|
fake_pxe_info.values(),
|
|
True)
|
|
|
|
|
|
class PXEDriverTestCase(db_base.DbTestCase):
|
|
|
|
def setUp(self):
|
|
super(PXEDriverTestCase, self).setUp()
|
|
self.context.auth_token = '4562138218392831'
|
|
self.temp_dir = tempfile.mkdtemp()
|
|
self.config(tftp_root=self.temp_dir, group='pxe')
|
|
self.temp_dir = tempfile.mkdtemp()
|
|
self.config(images_path=self.temp_dir, group='pxe')
|
|
mgr_utils.mock_the_extension_manager(driver="fake_pxe")
|
|
instance_info = INST_INFO_DICT
|
|
instance_info['deploy_key'] = 'fake-56789'
|
|
self.node = obj_utils.create_test_node(self.context,
|
|
driver='fake_pxe',
|
|
instance_info=instance_info,
|
|
driver_info=DRV_INFO_DICT)
|
|
self.port = obj_utils.create_test_port(self.context,
|
|
node_id=self.node.id)
|
|
self.config(group='conductor', api_url='http://127.0.0.1:1234/')
|
|
|
|
def _create_token_file(self):
|
|
token_path = pxe._get_token_file_path(self.node.uuid)
|
|
open(token_path, 'w').close()
|
|
return token_path
|
|
|
|
def test_get_properties(self):
|
|
expected = pxe.COMMON_PROPERTIES
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
self.assertEqual(expected, task.driver.get_properties())
|
|
|
|
@mock.patch.object(base_image_service.BaseImageService, '_show')
|
|
def test_validate_good(self, mock_glance):
|
|
mock_glance.return_value = {'properties': {'kernel_id': 'fake-kernel',
|
|
'ramdisk_id': 'fake-initr'}}
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
task.driver.deploy.validate(task)
|
|
|
|
def test_validate_fail(self):
|
|
info = dict(INST_INFO_DICT)
|
|
del info['image_source']
|
|
self.node.instance_info = json.dumps(info)
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
task.node['instance_info'] = json.dumps(info)
|
|
self.assertRaises(exception.MissingParameterValue,
|
|
task.driver.deploy.validate, task)
|
|
|
|
@mock.patch.object(base_image_service.BaseImageService, '_show')
|
|
def test_validate_fail_invalid_boot_mode(self, mock_glance):
|
|
properties = {'capabilities': 'boot_mode:foo,cap2:value2'}
|
|
mock_glance.return_value = {'properties': {'kernel_id': 'fake-kernel',
|
|
'ramdisk_id': 'fake-initr'}}
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
task.node.properties = properties
|
|
self.assertRaises(exception.InvalidParameterValue,
|
|
task.driver.deploy.validate, task)
|
|
|
|
@mock.patch.object(base_image_service.BaseImageService, '_show')
|
|
def test_validate_fail_invalid_config_uefi_ipxe(self, mock_glance):
|
|
properties = {'capabilities': 'boot_mode:uefi,cap2:value2'}
|
|
mock_glance.return_value = {'properties': {'kernel_id': 'fake-kernel',
|
|
'ramdisk_id': 'fake-initr'}}
|
|
self.config(ipxe_enabled=True, group='pxe')
|
|
self.config(http_url='dummy_url', group='pxe')
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
task.node.properties = properties
|
|
self.assertRaises(exception.InvalidParameterValue,
|
|
task.driver.deploy.validate, task)
|
|
|
|
def test_validate_fail_no_port(self):
|
|
new_node = obj_utils.create_test_node(
|
|
self.context,
|
|
uuid='aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee',
|
|
driver='fake_pxe', instance_info=INST_INFO_DICT,
|
|
driver_info=DRV_INFO_DICT)
|
|
with task_manager.acquire(self.context, new_node.uuid,
|
|
shared=True) as task:
|
|
self.assertRaises(exception.InvalidParameterValue,
|
|
task.driver.deploy.validate, task)
|
|
|
|
@mock.patch.object(base_image_service.BaseImageService, '_show')
|
|
@mock.patch.object(keystone, 'get_service_url')
|
|
def test_validate_good_api_url_from_config_file(self, mock_ks,
|
|
mock_glance):
|
|
mock_glance.return_value = {'properties': {'kernel_id': 'fake-kernel',
|
|
'ramdisk_id': 'fake-initr'}}
|
|
# not present in the keystone catalog
|
|
mock_ks.side_effect = exception.KeystoneFailure
|
|
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
task.driver.deploy.validate(task)
|
|
self.assertFalse(mock_ks.called)
|
|
|
|
@mock.patch.object(base_image_service.BaseImageService, '_show')
|
|
@mock.patch.object(keystone, 'get_service_url')
|
|
def test_validate_good_api_url_from_keystone(self, mock_ks, mock_glance):
|
|
mock_glance.return_value = {'properties': {'kernel_id': 'fake-kernel',
|
|
'ramdisk_id': 'fake-initr'}}
|
|
# present in the keystone catalog
|
|
mock_ks.return_value = 'http://127.0.0.1:1234'
|
|
# not present in the config file
|
|
self.config(group='conductor', api_url=None)
|
|
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
task.driver.deploy.validate(task)
|
|
mock_ks.assert_called_once_with()
|
|
|
|
@mock.patch.object(keystone, 'get_service_url')
|
|
def test_validate_fail_no_api_url(self, mock_ks):
|
|
# not present in the keystone catalog
|
|
mock_ks.side_effect = exception.KeystoneFailure
|
|
# not present in the config file
|
|
self.config(group='conductor', api_url=None)
|
|
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
self.assertRaises(exception.InvalidParameterValue,
|
|
task.driver.deploy.validate, task)
|
|
mock_ks.assert_called_once_with()
|
|
|
|
@mock.patch.object(base_image_service.BaseImageService, '_show')
|
|
def test_validate_fail_no_image_kernel_ramdisk_props(self, mock_glance):
|
|
mock_glance.return_value = {'properties': {}}
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
self.assertRaises(exception.MissingParameterValue,
|
|
task.driver.deploy.validate,
|
|
task)
|
|
|
|
@mock.patch.object(base_image_service.BaseImageService, '_show')
|
|
def test_validate_fail_glance_image_doesnt_exists(self, mock_glance):
|
|
mock_glance.side_effect = exception.ImageNotFound('not found')
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
self.assertRaises(exception.InvalidParameterValue,
|
|
task.driver.deploy.validate, task)
|
|
|
|
@mock.patch.object(base_image_service.BaseImageService, '_show')
|
|
def test_validate_fail_glance_conn_problem(self, mock_glance):
|
|
exceptions = (exception.GlanceConnectionFailed('connection fail'),
|
|
exception.ImageNotAuthorized('not authorized'),
|
|
exception.Invalid('invalid'))
|
|
mock_glance.side_effect = exceptions
|
|
for exc in exceptions:
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
self.assertRaises(exception.InvalidParameterValue,
|
|
task.driver.deploy.validate, task)
|
|
|
|
def test_vendor_passthru_validate_good(self):
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
task.driver.vendor.validate(task, method='pass_deploy_info',
|
|
address='123456', iqn='aaa-bbb',
|
|
key='fake-56789')
|
|
|
|
def test_vendor_passthru_validate_fail(self):
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
self.assertRaises(exception.InvalidParameterValue,
|
|
task.driver.vendor.validate,
|
|
task, method='pass_deploy_info',
|
|
key='fake-56789')
|
|
|
|
def test_vendor_passthru_validate_key_notmatch(self):
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
self.assertRaises(exception.InvalidParameterValue,
|
|
task.driver.vendor.validate,
|
|
task, method='pass_deploy_info',
|
|
address='123456', iqn='aaa-bbb',
|
|
key='fake-12345')
|
|
|
|
@mock.patch.object(pxe, '_get_image_info')
|
|
@mock.patch.object(pxe, '_cache_ramdisk_kernel')
|
|
@mock.patch.object(pxe, '_build_pxe_config_options')
|
|
@mock.patch.object(pxe_utils, 'create_pxe_config')
|
|
def test_prepare(self, mock_pxe_config,
|
|
mock_build_pxe, mock_cache_r_k,
|
|
mock_img_info):
|
|
mock_build_pxe.return_value = None
|
|
mock_img_info.return_value = None
|
|
mock_pxe_config.return_value = None
|
|
mock_cache_r_k.return_value = None
|
|
with task_manager.acquire(self.context, self.node.uuid) as task:
|
|
task.driver.deploy.prepare(task)
|
|
mock_img_info.assert_called_once_with(task.node,
|
|
self.context)
|
|
mock_pxe_config.assert_called_once_with(
|
|
task, None, CONF.pxe.pxe_config_template)
|
|
mock_cache_r_k.assert_called_once_with(self.context,
|
|
task.node, None)
|
|
|
|
@mock.patch.object(keystone, 'token_expires_soon')
|
|
@mock.patch.object(deploy_utils, 'get_image_mb')
|
|
@mock.patch.object(iscsi_deploy, '_get_image_file_path')
|
|
@mock.patch.object(iscsi_deploy, 'cache_instance_image')
|
|
@mock.patch.object(dhcp_factory.DHCPFactory, 'update_dhcp')
|
|
@mock.patch.object(manager_utils, 'node_power_action')
|
|
@mock.patch.object(manager_utils, 'node_set_boot_device')
|
|
def test_deploy(self, mock_node_set_boot, mock_node_power_action,
|
|
mock_update_dhcp, mock_cache_instance_image,
|
|
mock_get_image_file_path, mock_get_image_mb, mock_expire):
|
|
fake_img_path = '/test/path/test.img'
|
|
mock_get_image_file_path.return_value = fake_img_path
|
|
mock_get_image_mb.return_value = 1
|
|
mock_expire.return_value = False
|
|
self.config(deploy_callback_timeout=600, group='conductor')
|
|
|
|
with task_manager.acquire(self.context,
|
|
self.node.uuid, shared=False) as task:
|
|
dhcp_opts = pxe_utils.dhcp_options_for_instance(task)
|
|
state = task.driver.deploy.deploy(task)
|
|
self.assertEqual(state, states.DEPLOYWAIT)
|
|
mock_cache_instance_image.assert_called_once_with(
|
|
self.context, task.node)
|
|
mock_get_image_file_path.assert_called_once_with(task.node.uuid)
|
|
mock_get_image_mb.assert_called_once_with(fake_img_path)
|
|
mock_update_dhcp.assert_called_once_with(task, dhcp_opts)
|
|
mock_expire.assert_called_once_with(self.context.auth_token, 600)
|
|
mock_node_set_boot.assert_called_once_with(task, 'pxe',
|
|
persistent=True)
|
|
mock_node_power_action.assert_called_once_with(task, states.REBOOT)
|
|
|
|
# ensure token file created
|
|
t_path = pxe._get_token_file_path(self.node.uuid)
|
|
token = open(t_path, 'r').read()
|
|
self.assertEqual(self.context.auth_token, token)
|
|
|
|
@mock.patch.object(keystone, 'get_admin_auth_token')
|
|
@mock.patch.object(keystone, 'token_expires_soon')
|
|
@mock.patch.object(deploy_utils, 'get_image_mb')
|
|
@mock.patch.object(iscsi_deploy, '_get_image_file_path')
|
|
@mock.patch.object(iscsi_deploy, 'cache_instance_image')
|
|
@mock.patch.object(dhcp_factory.DHCPFactory, 'update_dhcp')
|
|
@mock.patch.object(manager_utils, 'node_power_action')
|
|
@mock.patch.object(manager_utils, 'node_set_boot_device')
|
|
def test_deploy_token_near_expiration(self, mock_node_set_boot,
|
|
mock_node_power_action, mock_update_dhcp,
|
|
mock_cache_instance_image, mock_get_image_file_path,
|
|
mock_get_image_mb, mock_expire, mock_admin_token):
|
|
mock_get_image_mb.return_value = 1
|
|
mock_expire.return_value = True
|
|
new_token = 'new_admin_token'
|
|
mock_admin_token.return_value = new_token
|
|
self.config(deploy_callback_timeout=600, group='conductor')
|
|
|
|
with task_manager.acquire(self.context,
|
|
self.node.uuid, shared=False) as task:
|
|
task.driver.deploy.deploy(task)
|
|
|
|
mock_expire.assert_called_once_with(self.context.auth_token, 600)
|
|
mock_admin_token.assert_called_once_with()
|
|
# ensure token file created with new token
|
|
t_path = pxe._get_token_file_path(self.node.uuid)
|
|
token = open(t_path, 'r').read()
|
|
self.assertEqual(new_token, token)
|
|
|
|
@mock.patch.object(deploy_utils, 'get_image_mb')
|
|
@mock.patch.object(iscsi_deploy, '_get_image_file_path')
|
|
@mock.patch.object(iscsi_deploy, 'cache_instance_image')
|
|
def test_deploy_image_too_large(self, mock_cache_instance_image,
|
|
mock_get_image_file_path,
|
|
mock_get_image_mb):
|
|
fake_img_path = '/test/path/test.img'
|
|
mock_get_image_file_path.return_value = fake_img_path
|
|
mock_get_image_mb.return_value = 999999
|
|
|
|
with task_manager.acquire(self.context,
|
|
self.node.uuid, shared=False) as task:
|
|
self.assertRaises(exception.InstanceDeployFailure,
|
|
task.driver.deploy.deploy, task)
|
|
mock_cache_instance_image.assert_called_once_with(
|
|
self.context, task.node)
|
|
mock_get_image_file_path.assert_called_once_with(task.node.uuid)
|
|
mock_get_image_mb.assert_called_once_with(fake_img_path)
|
|
|
|
@mock.patch.object(manager_utils, 'node_power_action')
|
|
def test_tear_down(self, node_power_mock):
|
|
with task_manager.acquire(self.context,
|
|
self.node.uuid) as task:
|
|
state = task.driver.deploy.tear_down(task)
|
|
self.assertEqual(states.DELETED, state)
|
|
node_power_mock.assert_called_once_with(task, states.POWER_OFF)
|
|
|
|
@mock.patch.object(dhcp_factory.DHCPFactory, 'update_dhcp')
|
|
def test_take_over(self, update_dhcp_mock):
|
|
with task_manager.acquire(
|
|
self.context, self.node.uuid, shared=True) as task:
|
|
dhcp_opts = pxe_utils.dhcp_options_for_instance(task)
|
|
task.driver.deploy.take_over(task)
|
|
update_dhcp_mock.assert_called_once_with(
|
|
task, dhcp_opts)
|
|
|
|
@mock.patch.object(deploy_utils, 'notify_deploy_complete')
|
|
@mock.patch.object(deploy_utils, 'switch_pxe_config')
|
|
@mock.patch.object(iscsi_deploy, 'InstanceImageCache')
|
|
def test_continue_deploy_good(self, mock_image_cache, mock_switch_config,
|
|
notify_mock):
|
|
token_path = self._create_token_file()
|
|
self.node.power_state = states.POWER_ON
|
|
self.node.provision_state = states.DEPLOYWAIT
|
|
self.node.save()
|
|
|
|
root_uuid = "12345678-1234-1234-1234-1234567890abcxyz"
|
|
boot_mode = None
|
|
|
|
def fake_deploy(**kwargs):
|
|
return root_uuid
|
|
|
|
self.useFixture(fixtures.MonkeyPatch(
|
|
'ironic.drivers.modules.deploy_utils.deploy',
|
|
fake_deploy))
|
|
|
|
with task_manager.acquire(self.context, self.node.uuid) as task:
|
|
task.driver.vendor._continue_deploy(
|
|
task, address='123456', iqn='aaa-bbb', key='fake-56789')
|
|
|
|
self.node.refresh()
|
|
self.assertEqual(states.ACTIVE, self.node.provision_state)
|
|
self.assertEqual(states.POWER_ON, self.node.power_state)
|
|
self.assertIsNone(self.node.last_error)
|
|
self.assertFalse(os.path.exists(token_path))
|
|
mock_image_cache.assert_called_once_with()
|
|
mock_image_cache.return_value.clean_up.assert_called_once_with()
|
|
pxe_config_path = pxe_utils.get_pxe_config_file_path(self.node.uuid)
|
|
mock_switch_config.assert_called_once_with(pxe_config_path, root_uuid,
|
|
boot_mode)
|
|
notify_mock.assert_called_once_with('123456')
|
|
|
|
@mock.patch.object(iscsi_deploy, 'InstanceImageCache')
|
|
def test_continue_deploy_fail(self, mock_image_cache):
|
|
token_path = self._create_token_file()
|
|
self.node.power_state = states.POWER_ON
|
|
self.node.provision_state = states.DEPLOYWAIT
|
|
self.node.save()
|
|
|
|
def fake_deploy(**kwargs):
|
|
raise exception.InstanceDeployFailure("test deploy error")
|
|
|
|
self.useFixture(fixtures.MonkeyPatch(
|
|
'ironic.drivers.modules.deploy_utils.deploy',
|
|
fake_deploy))
|
|
|
|
with task_manager.acquire(self.context, self.node.uuid) as task:
|
|
task.driver.vendor._continue_deploy(
|
|
task, address='123456', iqn='aaa-bbb', key='fake-56789')
|
|
|
|
self.node.refresh()
|
|
self.assertEqual(states.DEPLOYFAIL, self.node.provision_state)
|
|
self.assertEqual(states.POWER_OFF, self.node.power_state)
|
|
self.assertIsNotNone(self.node.last_error)
|
|
self.assertFalse(os.path.exists(token_path))
|
|
mock_image_cache.assert_called_once_with()
|
|
mock_image_cache.return_value.clean_up.assert_called_once_with()
|
|
|
|
@mock.patch.object(iscsi_deploy, 'InstanceImageCache')
|
|
def test_continue_deploy_ramdisk_fails(self, mock_image_cache):
|
|
token_path = self._create_token_file()
|
|
self.node.power_state = states.POWER_ON
|
|
self.node.provision_state = states.DEPLOYWAIT
|
|
self.node.save()
|
|
|
|
def fake_deploy(**kwargs):
|
|
pass
|
|
|
|
self.useFixture(fixtures.MonkeyPatch(
|
|
'ironic.drivers.modules.deploy_utils.deploy',
|
|
fake_deploy))
|
|
|
|
with task_manager.acquire(self.context, self.node.uuid) as task:
|
|
task.driver.vendor._continue_deploy(
|
|
task, address='123456', iqn='aaa-bbb',
|
|
key='fake-56789', error='test ramdisk error')
|
|
|
|
self.node.refresh()
|
|
self.assertEqual(states.DEPLOYFAIL, self.node.provision_state)
|
|
self.assertEqual(states.POWER_OFF, self.node.power_state)
|
|
self.assertIsNotNone(self.node.last_error)
|
|
self.assertFalse(os.path.exists(token_path))
|
|
mock_image_cache.assert_called_once_with()
|
|
mock_image_cache.return_value.clean_up.assert_called_once_with()
|
|
|
|
def test_continue_deploy_invalid(self):
|
|
self.node.power_state = states.POWER_ON
|
|
self.node.provision_state = 'FAKE'
|
|
self.node.save()
|
|
|
|
with task_manager.acquire(self.context, self.node.uuid) as task:
|
|
task.driver.vendor._continue_deploy(
|
|
task, address='123456', iqn='aaa-bbb',
|
|
key='fake-56789', error='test ramdisk error')
|
|
|
|
self.node.refresh()
|
|
self.assertEqual('FAKE', self.node.provision_state)
|
|
self.assertEqual(states.POWER_ON, self.node.power_state)
|
|
|
|
def test_lock_elevated(self):
|
|
with task_manager.acquire(self.context, self.node.uuid) as task:
|
|
with mock.patch.object(task.driver.vendor,
|
|
'_continue_deploy') as _cont_deploy_mock:
|
|
task.driver.vendor._continue_deploy(
|
|
task, address='123456', iqn='aaa-bbb', key='fake-56789')
|
|
|
|
# lock elevated w/o exception
|
|
self.assertEqual(1, _cont_deploy_mock.call_count,
|
|
"_continue_deploy was not called once.")
|
|
|
|
def test_vendor_routes(self):
|
|
expected = ['pass_deploy_info']
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
vendor_routes = task.driver.vendor.vendor_routes
|
|
self.assertIsInstance(vendor_routes, dict)
|
|
self.assertEqual(expected, list(vendor_routes))
|
|
|
|
def test_driver_routes(self):
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
driver_routes = task.driver.vendor.driver_routes
|
|
self.assertIsInstance(driver_routes, dict)
|
|
self.assertEqual({}, driver_routes)
|
|
|
|
|
|
@mock.patch.object(utils, 'unlink_without_raise')
|
|
@mock.patch.object(iscsi_deploy, 'destroy_images')
|
|
@mock.patch.object(pxe_utils, 'clean_up_pxe_config')
|
|
@mock.patch.object(pxe, 'TFTPImageCache')
|
|
@mock.patch.object(pxe, '_get_image_info')
|
|
class CleanUpTestCase(db_base.DbTestCase):
|
|
def setUp(self):
|
|
super(CleanUpTestCase, self).setUp()
|
|
mgr_utils.mock_the_extension_manager(driver="fake_pxe")
|
|
instance_info = INST_INFO_DICT
|
|
instance_info['deploy_key'] = 'fake-56789'
|
|
self.node = obj_utils.create_test_node(self.context,
|
|
driver='fake_pxe',
|
|
instance_info=instance_info,
|
|
driver_info=DRV_INFO_DICT)
|
|
|
|
def test_clean_up(self, mock_image_info, mock_cache, mock_pxe_clean,
|
|
mock_iscsi_clean, mock_unlink):
|
|
mock_image_info.return_value = {'label': ['', 'deploy_kernel']}
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
task.driver.deploy.clean_up(task)
|
|
mock_image_info.assert_called_once_with(task.node,
|
|
task.context)
|
|
mock_pxe_clean.assert_called_once_with(task)
|
|
mock_unlink.assert_any_call('deploy_kernel')
|
|
mock_unlink.assert_any_call(pxe._get_token_file_path(
|
|
task.node.uuid))
|
|
mock_iscsi_clean.assert_called_once_with(task.node.uuid)
|
|
mock_cache.return_value.clean_up.assert_called_once_with()
|
|
|
|
def test_clean_up_fail_get_image_info(self, mock_image_info, mock_cache,
|
|
mock_pxe_clean, mock_iscsi_clean,
|
|
mock_unlink):
|
|
mock_image_info.side_effect = exception.MissingParameterValue('foo')
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
task.driver.deploy.clean_up(task)
|
|
mock_image_info.assert_called_once_with(task.node,
|
|
task.context)
|
|
mock_pxe_clean.assert_called_once_with(task)
|
|
mock_unlink.assert_called_once_with(pxe._get_token_file_path(
|
|
task.node.uuid))
|
|
mock_iscsi_clean.assert_called_once_with(task.node.uuid)
|
|
mock_cache.return_value.clean_up.assert_called_once_with()
|
|
|
|
|
|
class CleanUpFullFlowTestCase(db_base.DbTestCase):
|
|
def setUp(self):
|
|
super(CleanUpFullFlowTestCase, self).setUp()
|
|
self.config(image_cache_size=0, group='pxe')
|
|
|
|
# Configure node
|
|
mgr_utils.mock_the_extension_manager(driver="fake_pxe")
|
|
instance_info = INST_INFO_DICT
|
|
instance_info['deploy_key'] = 'fake-56789'
|
|
self.node = obj_utils.create_test_node(self.context,
|
|
driver='fake_pxe',
|
|
instance_info=instance_info,
|
|
driver_info=DRV_INFO_DICT)
|
|
self.port = obj_utils.create_test_port(self.context,
|
|
node_id=self.node.id)
|
|
|
|
# Configure temporary directories
|
|
pxe_temp_dir = tempfile.mkdtemp()
|
|
self.config(tftp_root=pxe_temp_dir, group='pxe')
|
|
tftp_master_dir = os.path.join(CONF.pxe.tftp_root,
|
|
'tftp_master')
|
|
self.config(tftp_master_path=tftp_master_dir, group='pxe')
|
|
os.makedirs(tftp_master_dir)
|
|
|
|
instance_temp_dir = tempfile.mkdtemp()
|
|
self.config(images_path=instance_temp_dir,
|
|
group='pxe')
|
|
instance_master_dir = os.path.join(CONF.pxe.images_path,
|
|
'instance_master')
|
|
self.config(instance_master_path=instance_master_dir,
|
|
group='pxe')
|
|
os.makedirs(instance_master_dir)
|
|
self.pxe_config_dir = os.path.join(CONF.pxe.tftp_root, 'pxelinux.cfg')
|
|
os.makedirs(self.pxe_config_dir)
|
|
|
|
# Populate some file names
|
|
self.master_kernel_path = os.path.join(CONF.pxe.tftp_master_path,
|
|
'kernel')
|
|
self.master_instance_path = os.path.join(CONF.pxe.instance_master_path,
|
|
'image_uuid')
|
|
self.node_tftp_dir = os.path.join(CONF.pxe.tftp_root,
|
|
self.node.uuid)
|
|
os.makedirs(self.node_tftp_dir)
|
|
self.kernel_path = os.path.join(self.node_tftp_dir,
|
|
'kernel')
|
|
self.node_image_dir = iscsi_deploy._get_image_dir_path(self.node.uuid)
|
|
os.makedirs(self.node_image_dir)
|
|
self.image_path = iscsi_deploy._get_image_file_path(self.node.uuid)
|
|
self.config_path = pxe_utils.get_pxe_config_file_path(self.node.uuid)
|
|
self.mac_path = pxe_utils._get_pxe_mac_path(self.port.address)
|
|
self.token_path = pxe._get_token_file_path(self.node.uuid)
|
|
|
|
# Create files
|
|
self.files = [self.config_path, self.master_kernel_path,
|
|
self.master_instance_path, self.token_path]
|
|
for fname in self.files:
|
|
# NOTE(dtantsur): files with 0 size won't be cleaned up
|
|
with open(fname, 'w') as fp:
|
|
fp.write('test')
|
|
|
|
os.link(self.config_path, self.mac_path)
|
|
os.link(self.master_kernel_path, self.kernel_path)
|
|
os.link(self.master_instance_path, self.image_path)
|
|
|
|
@mock.patch.object(pxe, '_get_image_info')
|
|
def test_clean_up_with_master(self, mock_get_image_info):
|
|
image_info = {'kernel': ('kernel_uuid',
|
|
self.kernel_path)}
|
|
mock_get_image_info.return_value = image_info
|
|
|
|
with task_manager.acquire(self.context, self.node.uuid,
|
|
shared=True) as task:
|
|
task.driver.deploy.clean_up(task)
|
|
mock_get_image_info.assert_called_once_with(task.node,
|
|
task.context)
|
|
for path in ([self.kernel_path, self.image_path, self.config_path]
|
|
+ self.files):
|
|
self.assertFalse(os.path.exists(path),
|
|
'%s is not expected to exist' % path)
|