¡@
OpenStack Study: tilera_pdu.py**** CubicPower OpenStack Study ****
# Copyright (c) 2011-2013 University of Southern California / ISI # All Rights Reserved. # # 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. """ Baremetal PDU power manager. """ import time from oslo.config import cfg from nova import exception from nova.openstack.common.gettextutils import _ from nova.openstack.common import log as logging from nova.openstack.common import processutils from nova import utils from nova.virt.baremetal import baremetal_states from nova.virt.baremetal import base opts = [ cfg.StrOpt('tile_pdu_ip', default='10.0.100.1', help='IP address of tilera pdu'), cfg.StrOpt('tile_pdu_mgr', default='/tftpboot/pdu_mgr', help='Management script for tilera pdu'), cfg.IntOpt('tile_pdu_off', default=2, help='Power status of tilera PDU is OFF'), cfg.IntOpt('tile_pdu_on', default=1, help='Power status of tilera PDU is ON'), cfg.IntOpt('tile_pdu_status', default=9, help='Power status of tilera PDU'), cfg.IntOpt('tile_power_wait', default=9, help='Wait time in seconds until check the result ' 'after tilera power operations'), ] baremetal_group = cfg.OptGroup(name='baremetal', title='Baremetal Options') CONF = cfg.CONF CONF.register_group(baremetal_group) CONF.register_opts(opts, baremetal_group) LOG = logging.getLogger(__name__)
**** CubicPower OpenStack Study **** class Pdu(base.PowerManager): """PDU Power Driver for Baremetal Nova Compute This PowerManager class provides mechanism for controlling the power state of physical hardware via PDU calls. """
**** CubicPower OpenStack Study **** def __init__(self, node, **kwargs): self.state = None self.retries = None self.node_id = node['id'] self.address = node['pm_address'] self.user = node['pm_user'] self.password = node['pm_password'] self.port = node['terminal_port'] if self.node_id == None: raise exception.InvalidParameterValue(_("Node id not supplied " "to PDU")) if self.address == None: raise exception.InvalidParameterValue(_("Address not supplied " "to PDU")) if self.user == None: raise exception.InvalidParameterValue(_("User not supplied " "to PDU")) if self.password == None: raise exception.InvalidParameterValue(_("Password not supplied " "to PDU"))
**** CubicPower OpenStack Study **** def _exec_pdutool(self, mode): """Changes power state of the given node. According to the mode (1-ON, 2-OFF, 3-REBOOT), power state can be changed. /tftpboot/pdu_mgr script handles power management of PDU (Power Distribution Unit). """ if mode == CONF.baremetal.tile_pdu_status: try: utils.execute('ping', '-c1', self.address, check_exit_code=True) return CONF.baremetal.tile_pdu_on except processutils.ProcessExecutionError: return CONF.baremetal.tile_pdu_off else: try: utils.execute(CONF.baremetal.tile_pdu_mgr, CONF.baremetal.tile_pdu_ip, mode) time.sleep(CONF.baremetal.tile_power_wait) return mode except processutils.ProcessExecutionError: LOG.exception(_("PDU failed"))
**** CubicPower OpenStack Study **** def _is_power(self, state): out_err = self._exec_pdutool(CONF.baremetal.tile_pdu_status) return out_err == state
**** CubicPower OpenStack Study **** def _power_on(self): """Turn the power to this node ON.""" try: self._exec_pdutool(CONF.baremetal.tile_pdu_on) if self._is_power(CONF.baremetal.tile_pdu_on): self.state = baremetal_states.ACTIVE else: self.state = baremetal_states.ERROR except Exception: self.state = baremetal_states.ERROR LOG.exception(_("PDU power on failed"))
**** CubicPower OpenStack Study **** def _power_off(self): """Turn the power to this node OFF.""" try: self._exec_pdutool(CONF.baremetal.tile_pdu_off) if self._is_power(CONF.baremetal.tile_pdu_off): self.state = baremetal_states.DELETED else: self.state = baremetal_states.ERROR except Exception: self.state = baremetal_states.ERROR LOG.exception(_("PDU power off failed"))
**** CubicPower OpenStack Study **** def activate_node(self): """Turns the power to node ON.""" if (self._is_power(CONF.baremetal.tile_pdu_on) and self.state == baremetal_states.ACTIVE): LOG.warning(_("Activate node called, but node %s " "is already active") % self.address) self._power_on() return self.state
**** CubicPower OpenStack Study **** def reboot_node(self): """Cycles the power to a node.""" self._power_off() self._power_on() return self.state
**** CubicPower OpenStack Study **** def deactivate_node(self): """Turns the power to node OFF, regardless of current state.""" self._power_off() return self.state
**** CubicPower OpenStack Study **** def is_power_on(self): return self._is_power(CONF.baremetal.tile_pdu_on)
|