Merge "Virtual power driver is superceded by ssh driver"
This commit is contained in:
Jenkins
Gerrit Code Review
commit
58b9e2f34e
|
|
@ -1,235 +0,0 @@
|
|||
# vim: tabstop=4 shiftwidth=4 softtabstop=4
|
||||
|
||||
# Copyright 2012 Hewlett-Packard Development Company, L.P.
|
||||
# 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.
|
||||
#
|
||||
# Virtual power driver
|
||||
|
||||
from oslo.config import cfg
|
||||
|
||||
from ironic.common import context as nova_context
|
||||
from ironic.common import exception
|
||||
from ironic.common import utils
|
||||
from ironic.common import states
|
||||
from ironic.manager import base
|
||||
from ironic.openstack.common import importutils
|
||||
from ironic.openstack.common import log as logging
|
||||
from ironic import db
|
||||
import nova.virt.powervm.common as connection
|
||||
|
||||
opts = [
|
||||
cfg.StrOpt('virtual_power_ssh_host',
|
||||
default='',
|
||||
help='ip or name to virtual power host'),
|
||||
cfg.IntOpt('virtual_power_ssh_port',
|
||||
default=22,
|
||||
help='Port to use for ssh to virtual power host'),
|
||||
cfg.StrOpt('virtual_power_type',
|
||||
default='virsh',
|
||||
help='base command to use for virtual power(vbox,virsh)'),
|
||||
cfg.StrOpt('virtual_power_host_user',
|
||||
default='',
|
||||
help='user to execute virtual power commands as'),
|
||||
cfg.StrOpt('virtual_power_host_pass',
|
||||
default='',
|
||||
help='password for virtual power host_user'),
|
||||
cfg.StrOpt('virtual_power_host_key',
|
||||
default=None,
|
||||
help='ssh key for virtual power host_user'),
|
||||
|
||||
]
|
||||
|
||||
CONF = cfg.CONF
|
||||
CONF.register_opts(opts)
|
||||
|
||||
_conn = None
|
||||
_virtual_power_settings = None
|
||||
_vp_cmd = None
|
||||
_cmds = None
|
||||
|
||||
LOG = logging.getLogger(__name__)
|
||||
|
||||
|
||||
def _normalize_mac(mac):
|
||||
return mac.replace(':', '').lower()
|
||||
|
||||
|
||||
class VirtualPowerManager(base.PowerManager):
|
||||
"""Virtual Power Driver for Baremetal Nova Compute
|
||||
|
||||
This PowerManager class provides mechanism for controlling the power state
|
||||
of VMs based on their name and MAC address. It uses ssh to connect to the
|
||||
VM's host and issue commands.
|
||||
|
||||
Node will be matched based on mac address
|
||||
|
||||
NOTE: for use in dev/test environments only!
|
||||
|
||||
"""
|
||||
def __init__(self, **kwargs):
|
||||
global _conn
|
||||
global _virtual_power_settings
|
||||
global _cmds
|
||||
|
||||
if _cmds is None:
|
||||
LOG.debug("Setting up %s commands." %
|
||||
CONF.virtual_power_type)
|
||||
_vpc = 'ironic.virtual_power_driver_settings.%s' % \
|
||||
CONF.virtual_power_type
|
||||
_cmds = importutils.import_class(_vpc)
|
||||
self._vp_cmd = _cmds()
|
||||
self.connection_data = _conn
|
||||
node = kwargs.pop('node', {})
|
||||
instance = kwargs.pop('instance', {})
|
||||
self._node_name = instance.get('hostname', "")
|
||||
context = nova_context.get_admin_context()
|
||||
ifs = db.bm_interface_get_all_by_bm_node_id(context, node['id'])
|
||||
self._mac_addresses = [_normalize_mac(i['address']) for i in ifs]
|
||||
self._connection = None
|
||||
self._matched_name = ''
|
||||
self.state = None
|
||||
|
||||
def _get_conn(self):
|
||||
if not CONF.virtual_power_ssh_host:
|
||||
raise exception.NovaException(
|
||||
_('virtual_power_ssh_host not defined. Can not Start'))
|
||||
|
||||
if not CONF.virtual_power_host_user:
|
||||
raise exception.NovaException(
|
||||
_('virtual_power_host_user not defined. Can not Start'))
|
||||
|
||||
if not CONF.virtual_power_host_pass:
|
||||
# it is ok to not have a password if you have a keyfile
|
||||
if CONF.virtual_power_host_key is None:
|
||||
raise exception.NovaException(
|
||||
_('virtual_power_host_pass/key not set. Can not Start'))
|
||||
|
||||
_conn = connection.Connection(
|
||||
CONF.virtual_power_ssh_host,
|
||||
CONF.virtual_power_host_user,
|
||||
CONF.virtual_power_host_pass,
|
||||
CONF.virtual_power_ssh_port,
|
||||
CONF.virtual_power_host_key)
|
||||
return _conn
|
||||
|
||||
def _set_connection(self):
|
||||
if self._connection is None:
|
||||
if self.connection_data is None:
|
||||
self.connection_data = self._get_conn()
|
||||
|
||||
self._connection = connection.ssh_connect(self.connection_data)
|
||||
|
||||
def _get_full_node_list(self):
|
||||
LOG.debug("Getting full node list.")
|
||||
cmd = self._vp_cmd.list_cmd
|
||||
full_list = self._run_command(cmd)
|
||||
return full_list
|
||||
|
||||
def _check_for_node(self):
|
||||
LOG.debug("Looking up Name for Mac address %s." % self._mac_addresses)
|
||||
self._matched_name = ''
|
||||
full_node_list = self._get_full_node_list()
|
||||
|
||||
for node in full_node_list:
|
||||
cmd = self._vp_cmd.get_node_macs.replace('{_NodeName_}', node)
|
||||
mac_address_list = self._run_command(cmd)
|
||||
|
||||
for mac in mac_address_list:
|
||||
if _normalize_mac(mac) in self._mac_addresses:
|
||||
self._matched_name = ('"%s"' % node)
|
||||
break
|
||||
return self._matched_name
|
||||
|
||||
def activate_node(self):
|
||||
LOG.info("activate_node name %s" % self._node_name)
|
||||
if self._check_for_node():
|
||||
cmd = self._vp_cmd.start_cmd
|
||||
self._run_command(cmd)
|
||||
|
||||
if self.is_power_on():
|
||||
self.state = states.ACTIVE
|
||||
else:
|
||||
self.state = states.ERROR
|
||||
return self.state
|
||||
|
||||
def reboot_node(self):
|
||||
LOG.info("reset node: %s" % self._node_name)
|
||||
if self._check_for_node():
|
||||
cmd = self._vp_cmd.reboot_cmd
|
||||
self._run_command(cmd)
|
||||
if self.is_power_on():
|
||||
self.state = states.ACTIVE
|
||||
else:
|
||||
self.state = states.ERROR
|
||||
return self.state
|
||||
|
||||
def deactivate_node(self):
|
||||
LOG.info("deactivate_node name %s" % self._node_name)
|
||||
if self._check_for_node():
|
||||
if self.is_power_on():
|
||||
cmd = self._vp_cmd.stop_cmd
|
||||
self._run_command(cmd)
|
||||
|
||||
if self.is_power_on():
|
||||
self.state = states.ERROR
|
||||
else:
|
||||
self.state = states.DELETED
|
||||
return self.state
|
||||
|
||||
def is_power_on(self):
|
||||
LOG.debug("Checking if %s is running" % self._node_name)
|
||||
|
||||
if not self._check_for_node():
|
||||
return False
|
||||
|
||||
cmd = self._vp_cmd.list_running_cmd
|
||||
running_node_list = self._run_command(cmd)
|
||||
|
||||
for node in running_node_list:
|
||||
if self._matched_name in node:
|
||||
return True
|
||||
return False
|
||||
|
||||
def start_console(self):
|
||||
pass
|
||||
|
||||
def stop_console(self):
|
||||
pass
|
||||
|
||||
def _run_command(self, cmd, check_exit_code=True):
|
||||
"""Run a remote command using an active ssh connection.
|
||||
|
||||
:param command: String with the command to run.
|
||||
|
||||
If {_NodeName_} is in the command it will get replaced by
|
||||
the _matched_name value.
|
||||
|
||||
base_cmd will also get prepended to the command.
|
||||
"""
|
||||
self._set_connection()
|
||||
|
||||
cmd = cmd.replace('{_NodeName_}', self._matched_name)
|
||||
|
||||
cmd = '%s %s' % (self._vp_cmd.base_cmd, cmd)
|
||||
|
||||
try:
|
||||
stdout, stderr = utils.ssh_execute(self._connection, cmd,
|
||||
check_exit_code=check_exit_code)
|
||||
result = stdout.strip().splitlines()
|
||||
LOG.debug('Result for run_command: %s' % result)
|
||||
except exception.ProcessExecutionError:
|
||||
result = []
|
||||
LOG.exception("Error running command: %s" % cmd)
|
||||
return result
|
||||
|
|
@ -1,56 +0,0 @@
|
|||
# vim: tabstop=4 shiftwidth=4 softtabstop=4
|
||||
|
||||
# Copyright 2012 Hewlett-Packard Development Company, L.P.
|
||||
|
||||
# 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.
|
||||
#
|
||||
# Virtual power driver commands
|
||||
|
||||
|
||||
class vbox(object):
|
||||
"""set commands for basic Virtual Box control."""
|
||||
|
||||
def __init__(self):
|
||||
self.base_cmd = '/usr/bin/VBoxManage'
|
||||
self.start_cmd = 'startvm {_NodeName_}'
|
||||
self.stop_cmd = 'controlvm {_NodeName_} poweroff'
|
||||
self.reboot_cmd = 'controlvm {_NodeName_} reset'
|
||||
self.list_cmd = "list vms|awk -F'\"' '{print $2}'"
|
||||
self.list_running_cmd = 'list runningvms'
|
||||
self.get_node_macs = ("showvminfo --machinereadable {_NodeName_} | "
|
||||
"grep "
|
||||
'"macaddress" | awk -F '
|
||||
"'"
|
||||
'"'
|
||||
"' '{print $2}'")
|
||||
|
||||
|
||||
class virsh(object):
|
||||
"""set commands for basic Virsh control."""
|
||||
|
||||
def __init__(self):
|
||||
self.base_cmd = '/usr/bin/virsh'
|
||||
self.start_cmd = 'start {_NodeName_}'
|
||||
self.stop_cmd = 'destroy {_NodeName_}'
|
||||
self.reboot_cmd = 'reset {_NodeName_}'
|
||||
self.list_cmd = "list --all | tail -n +2 | awk -F\" \" '{print $2}'"
|
||||
self.list_running_cmd = \
|
||||
"list --all|grep running|awk -v qc='\"' -F\" \" '{print qc$2qc}'"
|
||||
self.get_node_macs = ("dumpxml {_NodeName_} | grep "
|
||||
'"mac address" | awk -F'
|
||||
'"'
|
||||
"'"
|
||||
'" '
|
||||
"'{print $2}' | tr -d ':'")
|
||||
Loading…
Reference in New Issue