Source code for ironic.drivers.modules.ramdisk

# 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.

"""
Ramdisk Deploy Interface
"""

from ironic_lib import metrics_utils
from oslo_log import log as logging

from ironic.common import exception
from ironic.common.i18n import _
from ironic.common import states
from ironic.conductor import task_manager
from ironic.conductor import utils as manager_utils
from ironic.drivers import base
from ironic.drivers.modules import agent_base
from ironic.drivers.modules import deploy_utils

LOG = logging.getLogger(__name__)

METRICS = metrics_utils.get_metrics_logger(__name__)


[docs] class RamdiskDeploy(agent_base.AgentBaseMixin, agent_base.HeartbeatMixin, base.DeployInterface):
[docs] def get_properties(self): return {}
[docs] def validate(self, task): if 'ramdisk_boot' not in task.driver.boot.capabilities: raise exception.InvalidParameterValue( message=_('Invalid configuration: The boot interface ' 'must have the `ramdisk_boot` capability. ' 'You are using an incompatible boot interface.')) task.driver.boot.validate(task) # Validate node capabilities deploy_utils.validate_capabilities(task.node)
[docs] @METRICS.timer('RamdiskDeploy.deploy') @base.deploy_step(priority=100) @task_manager.require_exclusive_lock def deploy(self, task): if ('configdrive' in task.node.instance_info and 'ramdisk_boot_configdrive' not in task.driver.boot.capabilities): # TODO(dtantsur): make it an actual error? LOG.warning('A configuration drive is present in the ramdisk ' 'deployment request of node %(node)s with boot ' 'interface %(drv)s. The configuration drive will be ' 'ignored for this deployment.', {'node': task.node, 'drv': task.node.get_interface('boot')}) manager_utils.node_power_action(task, states.POWER_OFF) # Tenant networks must enable connectivity to the boot # location, as reboot() can otherwise be very problematic. # IDEA(TheJulia): Maybe a "trusted environment" mode flag # that we otherwise fail validation on for drivers that # require explicit security postures. with manager_utils.power_state_for_network_configuration(task): task.driver.network.configure_tenant_networks(task) # calling boot.prepare_instance will also set the node # to boot, and update the 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) LOG.info('Deployment setup for node %s done', task.node.uuid) return None
[docs] @METRICS.timer('RamdiskDeploy.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. task.driver.network.validate(task) 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. task.driver.storage.attach_volumes(task) if node.provision_state in (states.ACTIVE, states.UNRESCUING): # In the event of takeover or unrescue. task.driver.boot.prepare_instance(task)