ironic.drivers.modules.drac.inspect

Source code for ironic.drivers.modules.drac.inspect

#
# 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.drivers import base
from ironic.drivers.modules.drac import common as drac_common
from ironic import objects

drac_exceptions = importutils.try_import('dracclient.exceptions')
drac_utils = importutils.try_import('dracclient.utils')

DCIM_NICEnumeration = ('http://schemas.dell.com/wbem/wscim/1/cim-schema/2/'
                       'DCIM_NICEnumeration')  # noqa
NS_WSMAN = 'http://schemas.dmtf.org/wbem/wsman/1/wsman.xsd'

LOG = logging.getLogger(__name__)

METRICS = metrics_utils.get_metrics_logger(__name__)


[docs]class DracInspect(base.InspectInterface):
[docs] def get_properties(self): """Return the properties of the interface. :returns: dictionary of <property name>:<property description> entries. """ return drac_common.COMMON_PROPERTIES
[docs] @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)
[docs] @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' 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 not pxe_dev_nics: 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 :param node: Baremetal Node object :returns: list of pxe device interfaces. """ pxe_dev_nics = [] nic_cap = {} 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 = self._list_nic_settings(client, 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'] == "PXE"): pxe_dev_nics.append(nic.id) return pxe_dev_nics def _list_nic_settings(self, client, nic_id): """Get nic attributes. :param client: Dracclient instance :param nic_id: an FQDD of NIC :returns: a dict of FQDD, LegacyBootProto. """ result = {} doc = client.client.enumerate(DCIM_NICEnumeration) items = doc.find('.//{%s}Items' % NS_WSMAN) for item in items: if nic_id == drac_utils.get_wsman_resource_attr( item, DCIM_NICEnumeration, 'FQDD'): name = drac_utils.get_wsman_resource_attr(item, DCIM_NICEnumeration, 'AttributeName') current_value = drac_utils.get_wsman_resource_attr( item, DCIM_NICEnumeration, 'CurrentValue', nullable=True) if name == 'LegacyBootProto': result[name] = current_value result['FQDD'] = nic_id return result
Creative Commons Attribution 3.0 License

Except where otherwise noted, this document is licensed under Creative Commons Attribution 3.0 License. See all OpenStack Legal Documents.