Source code for ironic.drivers.modules.pxe

# Copyright 2013 Hewlett-Packard Development Company, L.P.
# 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
# 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.
PXE Boot Interface

from ironic_lib import metrics_utils
from oslo_log import log as logging

from ironic.common import boot_devices
from ironic.common.i18n import _
from ironic.common import pxe_utils
from ironic.common import states
from ironic.conductor import task_manager
from ironic.conductor import utils as manager_utils
from ironic.conf import CONF
from ironic.drivers import base
from ironic.drivers.modules import agent_base
from ironic.drivers.modules import boot_mode_utils
from ironic.drivers.modules import deploy_utils
from ironic.drivers.modules import pxe_base
LOG = logging.getLogger(__name__)

METRICS = metrics_utils.get_metrics_logger(__name__)

[docs] class PXEBoot(pxe_base.PXEBaseMixin, base.BootInterface): capabilities = ['ramdisk_boot', 'pxe_boot'] def __init__(self): pxe_utils.place_common_config() pxe_utils.place_loaders_for_boot(CONF.deploy.http_root) pxe_utils.place_loaders_for_boot(CONF.pxe.tftp_root)
[docs] class HttpBoot(pxe_base.PXEBaseMixin, base.BootInterface): http_boot_enabled = True capabilities = ['ramdisk_boot', 'pxe_boot'] def __init__(self): pxe_utils.place_common_config() pxe_utils.place_loaders_for_boot(CONF.deploy.http_root)
[docs] class PXEAnacondaDeploy(agent_base.AgentBaseMixin, agent_base.HeartbeatMixin, base.DeployInterface):
[docs] def get_properties(self): return {}
[docs] def validate(self, task): task.driver.boot.validate(task)
[docs] @METRICS.timer('AnacondaDeploy.deploy') @base.deploy_step(priority=100) @task_manager.require_exclusive_lock def deploy(self, task): manager_utils.node_power_action(task, states.POWER_OFF) with manager_utils.power_state_for_network_configuration(task): # calling boot.prepare_instance will also set the node # to PXE boot, and update PXE templates accordingly task.driver.boot.prepare_instance(task) # Power-on the instance, with PXE prepared, we're done. manager_utils.node_power_action(task, states.POWER_ON)'Deployment setup for node %s done', task.node.uuid) return states.DEPLOYWAIT
[docs] @METRICS.timer('AnacondaDeploy.prepare') @task_manager.require_exclusive_lock def prepare(self, task): node = task.node deploy_utils.populate_storage_driver_internal_info(task) if node.provision_state == states.DEPLOYING: # Ask the network interface to validate itself so # we can ensure we are able to proceed. manager_utils.node_power_action(task, states.POWER_OFF) # NOTE(TheJulia): If this was any other interface, we would # unconfigure tenant networks, add provisioning networks, etc. node.instance_info = deploy_utils.build_instance_info_for_deploy( task) if node.provision_state in (states.ACTIVE, states.UNRESCUING): # In the event of takeover or unrescue. task.driver.boot.prepare_instance(task)
[docs] def deploy_has_started(self, task): agent_status = task.node.driver_internal_info.get('agent_status') if agent_status == 'start': return True return False
[docs] def deploy_is_done(self, task): agent_status = task.node.driver_internal_info.get('agent_status') if agent_status == 'end': return True return False
[docs] def should_manage_boot(self, task): if task.node.provision_state in ( states.DEPLOYING, states.DEPLOYWAIT, states.DEPLOYFAIL): return False # For cleaning and rescue, we use IPA, not anaconda return agent_base.AgentBaseMixin.should_manage_boot(self, task)
[docs] def reboot_to_instance(self, task): node = task.node try: task.process_event('resume') self.clean_up(task) manager_utils.node_power_action(task, states.POWER_OFF) deploy_utils.try_set_boot_device(task, boot_devices.DISK) boot_mode_utils.configure_secure_boot_if_needed(task) manager_utils.node_power_action(task, states.POWER_ON) task.process_event('done') except Exception as e: msg = (_('An error occurred after deployment, while preparing to ' 'reboot the node %(node)s: %(error)s') % {'node': node.uuid, 'error': e}) agent_base.log_and_raise_deployment_error(task, msg)
def _heartbeat_deploy_wait(self, task): node = task.node agent_status_message = node.driver_internal_info.get( 'agent_status_message' ) msg = {'node_id': node.uuid, 'agent_status_message': agent_status_message} if self.deploy_has_started(task):'The deploy on node %(node_id)s has started. Anaconda ' 'returned following message: ' '%(agent_status_message)s ', msg) node.touch_provisioning() elif self.deploy_is_done(task):'The deploy on node %(node_id)s has ended. Anaconda ' 'agent returned following message: ' '%(agent_status_message)s', msg) self.reboot_to_instance(task) else: LOG.error('The deploy on node %(node_id)s failed. Anaconda ' 'returned following error message: ' '%(agent_status_message)s', msg) deploy_utils.set_failed_state(task, agent_status_message, collect_logs=False)
[docs] @METRICS.timer('AnacondaDeploy.clean_up') @task_manager.require_exclusive_lock def clean_up(self, task): super(PXEAnacondaDeploy, self).clean_up(task) node = task.node # NOTE(rloo): These were added during deployment, as a side-effect of # pxe_utils.get_instance_image_info(). node.del_driver_internal_info('stage2') node.del_driver_internal_info('ks_template')