/usr/lib/python3/dist-packages/provisioningserver/drivers/power/seamicro.py is in python3-maas-provisioningserver 2.4.0~beta2-6865-gec43e47e6-0ubuntu1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 | # Copyright 2015-2016 Canonical Ltd. This software is licensed under the
# GNU Affero General Public License version 3 (see the file LICENSE).
"""SeaMicro Power Driver."""
__all__ = []
from provisioningserver.drivers import (
make_ip_extractor,
make_setting_field,
SETTING_SCOPE,
)
from provisioningserver.drivers.hardware.seamicro import (
power_control_seamicro15k_v09,
power_control_seamicro15k_v2,
power_query_seamicro15k_v2,
)
from provisioningserver.drivers.power import (
PowerActionError,
PowerDriver,
)
from provisioningserver.utils import shell
from provisioningserver.utils.shell import (
call_and_check,
ExternalProcessError,
)
# Power control choices for sm15k power type
SM15K_POWER_CONTROL_CHOICES = [
["ipmi", "IPMI"],
["restapi", "REST API v0.9"],
["restapi2", "REST API v2.0"],
]
def extract_seamicro_parameters(context):
ip = context.get('power_address')
username = context.get('power_user')
password = context.get('power_pass')
server_id = context.get('system_id')
power_control = context.get('power_control')
return ip, username, password, server_id, power_control
class SeaMicroPowerDriver(PowerDriver):
name = 'sm15k'
description = "SeaMicro 15000"
settings = [
make_setting_field(
'system_id', "System ID", scope=SETTING_SCOPE.NODE,
required=True),
make_setting_field('power_address', "Power address", required=True),
make_setting_field('power_user', "Power user"),
make_setting_field(
'power_pass', "Power password", field_type='password'),
make_setting_field(
'power_control', "Power control type", field_type='choice',
choices=SM15K_POWER_CONTROL_CHOICES, default='ipmi',
required=True),
]
ip_extractor = make_ip_extractor('power_address')
def detect_missing_packages(self):
if not shell.has_command_available('ipmitool'):
return ['ipmitool']
return []
def _power_control_seamicro15k_ipmi(
self, ip, username, password, server_id, power_change):
"""Power on/off SeaMicro node via ipmitool."""
power_mode = 1 if power_change == 'on' else 6
try:
call_and_check([
'ipmitool', '-I', 'lanplus', '-H', ip, '-U', username,
'-P', password, 'raw', '0x2E', '1', '0x00', '0x7d',
'0xab', power_mode, '0', server_id,
])
except ExternalProcessError as e:
raise PowerActionError(
"Failed to power %s %s at %s: %s" % (
power_change, server_id, ip, e.output_as_unicode))
def _power(self, power_change, context):
"""Power SeaMicro node."""
ip, username, password, server_id, power_control = (
extract_seamicro_parameters(context))
if power_control == 'ipmi':
self._power_control_seamicro15k_ipmi(
ip, username, password, server_id, power_change=power_change)
elif power_control == 'restapi':
power_control_seamicro15k_v09(
ip, username, password, server_id, power_change=power_change)
elif power_control == 'restapi2':
power_control_seamicro15k_v2(
ip, username, password, server_id, power_change=power_change)
def power_on(self, system_id, context):
"""Power on SeaMicro node."""
self._power('on', context)
def power_off(self, system_id, context):
"""Power off SeaMicro node."""
self._power('off', context)
def power_query(self, system_id, context):
"""Power query SeaMicro node."""
# Query the state.
# Only supported by REST v2.
ip, username, password, server_id, power_control = (
extract_seamicro_parameters(context))
if power_control == 'restapi2':
return power_query_seamicro15k_v2(
ip, username, password, server_id)
else:
return 'unknown'
|