Add support for Ampere Falcon server

[ta/ironic-virtmedia-driver.git] / src / ironic_virtmedia_driver / vendors / nokia / nokia_hw.py

diff --git a/src/ironic_virtmedia_driver/vendors/nokia/nokia_hw.py b/src/ironic_virtmedia_driver/vendors/nokia/nokia_hw.py
index 9596804..3805cd7 100644 (file)
--- a/src/ironic_virtmedia_driver/vendors/nokia/nokia_hw.py
+++ b/src/ironic_virtmedia_driver/vendors/nokia/nokia_hw.py
@@ -13,114 +13,8 @@
 # limitations under the License.
 #
 
-import time
+from ..openbmc_hw import OpenBMCIronicVirtMediaHW
 
-from ironic.drivers.modules import ipmitool
-from ironic.common.i18n import  _translators
-from oslo_concurrency import processutils
-from ironic.common import exception
-
-from ..ironic_virtmedia_hw import IronicVirtMediaHW
-
-class NokiaIronicVirtMediaHW(IronicVirtMediaHW):
+class NokiaIronicVirtMediaHW(OpenBMCIronicVirtMediaHW):
     def __init__(self, log):
         super(NokiaIronicVirtMediaHW, self).__init__(log)
-        self.remote_share = '/remote_image_share_root/'
-
-    def attach_virtual_cd(self, image_filename, driver_info, task):
-        """ see ironic_virtmedia_hw.py"""
-        raise NotImplementedError
-
-    def detach_virtual_cd(self, driver_info, task):
-        """ see ironic_virtmedia_hw.py"""
-        raise NotImplementedError
-
-    def set_boot_device(self, task):
-        """ see ironic_virtmedia_hw.py"""
-        raise NotImplementedError
-
-    def get_disk_attachment_status(self, task):
-        """ Get the disk attachment status.
-        :param task: a TaskManager instance.
-        :returns: <str>: 'mounting' if operation is ongoing
-                         'nfserror' if failed
-                         'mounted' if the disk is successfully mounted
-        """
-        raise NotImplementedError
-
-    @staticmethod
-    def hex_convert(string_value, padding=False, length=0):
-        hex_value = '0x'
-        hex_value += ' 0x'.join(x.encode('hex') for x in string_value)
-        if padding and (len(string_value)<length):
-            hex_value += ' 0x'
-            hex_value += ' 0x'.join('00' for _ in range(len(string_value), length)) 
-        return hex_value
-
-    def _issue_bmc_reset(self, driver_info, task):
-        """ Issues a bmc reset and waits till the bcm is ready for servicing
-        """
-        cmd = 'bmc reset cold'
-        node_uuid = task.node.uuid
-        self.log.debug("Issuing bmc cold reset to node %s" %(task.node.name))
-        try:
-            out, err = ipmitool._exec_ipmitool(driver_info, cmd)
-            self.log.debug('bmc reset returned stdout: %(stdout)s, stderr:'
-                           ' %(stderr)s', {'stdout': out, 'stderr': err})
-        except processutils.ProcessExecutionError as err:
-            self.log.exception(_translators.log_error('IPMI "bmc reset" failed for node %(node_id)s '
-                                                      'with error: %(error)s.'),
-                               {'node_id': node_uuid, 'error': err})
-            raise exception.IPMIFailure(cmd=cmd)
-
-        sleep_count = 10
-        cmd = 'bmc info'
-        while sleep_count:
-            try:
-                out, err = ipmitool._exec_ipmitool(driver_info, cmd)
-                self.log.debug('bmc reset returned stdout: %(stdout)s, stderr:'
-                               ' %(stderr)s', {'stdout': out, 'stderr': err})
-                break
-            except processutils.ProcessExecutionError as err:
-                self.log.debug(_translators.log_error('IPMI "bmc info" failed for node %(node_id)s '
-                                                      'with error: %(error)s. Sleeping and retrying later.'
-                                                      'sleep_count: %(sleep_count)s'),
-                               {'node_id': node_uuid, 'error': err, 'sleep_count': sleep_count})
-                time.sleep(10)
-                sleep_count -= 1
-
-        if not sleep_count:
-            self.log.exception('After bmc reset, connection to bmc is lost!')
-            raise exception.IPMIFailure(cmd='bmc reset')
-
-
-    def _wait_for_cd_mounting(self, driver_info, task):
-        sleep_count = 10
-        while self.get_disk_attachment_status(task) == 'mounting' and sleep_count:
-            self.log.debug("Waiting for the CD to be Mounted")
-            sleep_count -= 1
-            time.sleep(1)
-
-        if sleep_count:
-            return True
-
-        self.log.warning("NFS mount timed out!. Trying BMC reset!")
-        self._issue_bmc_reset(driver_info, task)
-
-    def check_and_wait_for_cd_mounting(self, image_filename, task, driver_info):
-        mount_status = self.get_disk_attachment_status(task)
-        if mount_status == 'mounting':
-            if self._wait_for_cd_mounting(driver_info, task):
-                self.log.debug("Attached CD: %s" %(image_filename))
-                return True
-            else:
-                return False
-        elif mount_status == 'nfserror':
-            self.log.exception("NFS mount failed!. Issue could be with NFS server status or connectivity to target.")
-            raise exception.InstanceDeployFailure(reason='NFS mount failed!')
-        elif mount_status == 'mounted':
-            self.log.debug("Attached CD: %s" %(image_filename))
-            return True
-        else:
-            self.log.exception("NFS mount failed!. Unknown error!")
-            raise exception.InstanceDeployFailure(reason='NFS mount failed!')