# # 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. """ DRAC inspection interface """ from ironic_lib import metrics_utils from oslo_log import log as logging from oslo_utils import importutils from oslo_utils import units from ironic.common import exception from ironic.common.i18n import _ from ironic.common import states from ironic.common import utils from ironic.drivers import base from ironic.drivers.modules.drac import common as drac_common from ironic import objects drac_exceptions = importutils.try_import('dracclient.exceptions') LOG = logging.getLogger(__name__) METRICS = metrics_utils.get_metrics_logger(__name__) class DracInspect(base.InspectInterface): def get_properties(self): """Return the properties of the interface. :returns: dictionary of : entries. """ return drac_common.COMMON_PROPERTIES @METRICS.timer('DracInspect.validate') def validate(self, task): """Validate the driver-specific info supplied. This method validates whether the 'driver_info' property of the supplied node contains the required information for this driver to manage the node. :param task: a TaskManager instance containing the node to act on. :raises: InvalidParameterValue if required driver_info attribute is missing or invalid on the node. """ return drac_common.parse_driver_info(task.node) @METRICS.timer('DracInspect.inspect_hardware') def inspect_hardware(self, task): """Inspect hardware. Inspect hardware to obtain the essential & additional hardware properties. :param task: a TaskManager instance containing the node to act on. :raises: HardwareInspectionFailure, if unable to get essential hardware properties. :returns: states.MANAGEABLE """ node = task.node client = drac_common.get_drac_client(node) properties = {} try: properties['memory_mb'] = sum( [memory.size_mb for memory in client.list_memory()]) cpus = client.list_cpus() if cpus: properties['cpus'] = sum( [self._calculate_cpus(cpu) for cpu in cpus]) properties['cpu_arch'] = 'x86_64' if cpus[0].arch64 else 'x86' bios_settings = client.list_bios_settings() current_capabilities = node.properties.get('capabilities', '') new_capabilities = { 'boot_mode': bios_settings["BootMode"].current_value.lower()} capabilties = utils.get_updated_capabilities(current_capabilities, new_capabilities) properties['capabilities'] = capabilties virtual_disks = client.list_virtual_disks() root_disk = self._guess_root_disk(virtual_disks) if root_disk: properties['local_gb'] = int(root_disk.size_mb / units.Ki) else: physical_disks = client.list_physical_disks() root_disk = self._guess_root_disk(physical_disks) if root_disk: properties['local_gb'] = int( root_disk.size_mb / units.Ki) except drac_exceptions.BaseClientException as exc: LOG.error('DRAC driver failed to introspect node ' '%(node_uuid)s. Reason: %(error)s.', {'node_uuid': node.uuid, 'error': exc}) raise exception.HardwareInspectionFailure(error=exc) valid_keys = self.ESSENTIAL_PROPERTIES missing_keys = valid_keys - set(properties) if missing_keys: error = (_('Failed to discover the following properties: ' '%(missing_keys)s') % {'missing_keys': ', '.join(missing_keys)}) raise exception.HardwareInspectionFailure(error=error) node.properties = dict(node.properties, **properties) node.save() try: nics = client.list_nics() except drac_exceptions.BaseClientException as exc: LOG.error('DRAC driver failed to introspect node ' '%(node_uuid)s. Reason: %(error)s.', {'node_uuid': node.uuid, 'error': exc}) raise exception.HardwareInspectionFailure(error=exc) pxe_dev_nics = self._get_pxe_dev_nics(client, nics, node) if pxe_dev_nics is None: LOG.warning('No PXE enabled NIC was found for node ' '%(node_uuid)s.', {'node_uuid': node.uuid}) for nic in nics: try: port = objects.Port(task.context, address=nic.mac, node_id=node.id, pxe_enabled=(nic.id in pxe_dev_nics)) port.create() LOG.info('Port created with MAC address %(mac)s ' 'for node %(node_uuid)s during inspection', {'mac': nic.mac, 'node_uuid': node.uuid}) except exception.MACAlreadyExists: LOG.warning('Failed to create a port with MAC address ' '%(mac)s when inspecting the node ' '%(node_uuid)s because the address is already ' 'registered', {'mac': nic.mac, 'node_uuid': node.uuid}) LOG.info('Node %s successfully inspected.', node.uuid) return states.MANAGEABLE def _guess_root_disk(self, disks, min_size_required_mb=4 * units.Ki): """Find a root disk. :param disks: list of disks. :param min_size_required_mb: minimum required size of the root disk in megabytes. :returns: root disk. """ disks.sort(key=lambda disk: disk.size_mb) for disk in disks: if disk.size_mb >= min_size_required_mb: return disk def _calculate_cpus(self, cpu): """Find actual CPU count. :param cpu: Pass cpu. :returns: returns total cpu count. """ if cpu.ht_enabled: return cpu.cores * 2 else: return cpu.cores def _get_pxe_dev_nics(self, client, nics, node): """Get a list of pxe device interfaces. :param client: Dracclient to list the bios settings and nics :param nics: list of nics :returns: Returns list of pxe device interfaces. """ pxe_dev_nics = [] pxe_params = ["PxeDev1EnDis", "PxeDev2EnDis", "PxeDev3EnDis", "PxeDev4EnDis"] pxe_nics = ["PxeDev1Interface", "PxeDev2Interface", "PxeDev3Interface", "PxeDev4Interface"] try: bios_settings = client.list_bios_settings() except drac_exceptions.BaseClientException as exc: LOG.error('DRAC driver failed to list bios settings ' 'for %(node_uuid)s. Reason: %(error)s.', {'node_uuid': node.uuid, 'error': exc}) raise exception.HardwareInspectionFailure(error=exc) if bios_settings["BootMode"].current_value == "Uefi": for param, nic in zip(pxe_params, pxe_nics): if param in bios_settings and bios_settings[ param].current_value == "Enabled": pxe_dev_nics.append( bios_settings[nic].current_value) elif bios_settings["BootMode"].current_value == "Bios": for nic in nics: try: nic_cap = client.list_nic_settings(nic_id=nic.id) except drac_exceptions.BaseClientException as exc: LOG.error('DRAC driver failed to list nic settings ' 'for %(node_uuid)s. Reason: %(error)s.', {'node_uuid': node.uuid, 'error': exc}) raise exception.HardwareInspectionFailure(error=exc) if ("LegacyBootProto" in nic_cap and nic_cap[ 'LegacyBootProto'].current_value == "PXE"): pxe_dev_nics.append(nic.id) return pxe_dev_nics