fence-agents: master - Add iPDU fencing agent for model 46M4002

Gitweb: http://git.fedorahosted.org/git/?p=fence-agents.git;a=commitdiff;h=74d124... Commit: 74d1242d8b968d5886be4394c8792d8c8d93f321 Parent: efcf34f5156385c397509f9fe40ae08ca74a96a0 Author: Lon Hohberger <lhh(a)redhat.com&gt; AuthorDate: Fri Jul 20 15:43:14 2012 -0400 Committer: Marek 'marx' Grac <mgrac(a)redhat.com&gt; CommitterDate: Mon Jul 23 11:10:19 2012 +0200 Add iPDU fencing agent for model 46M4002 Resolves: rhbz#741985 Signed-off-by: Lon Hohberger <lhh(a)redhat.com&gt; Signed-off-by: Marek 'marx' Grac <mgrac(a)redhat.com&gt; --- .gitignore | 1 + configure.ac | 1 + fence/agents/ipdu/Makefile.am | 17 ++++ fence/agents/ipdu/fence_ipdu.py | 179 +++++++++++++++++++++++++++++++++++++++ 4 files changed, 198 insertions(+), 0 deletions(-) diff --git a/.gitignore b/.gitignore index 3a182d8..c1b028c 100644 --- a/.gitignore +++ b/.gitignore @@ -49,6 +49,7 @@ fence/agents/ifmib/fence_ifmib fence/agents/ilo/fence_ilo fence/agents/ilo_mp/fence_ilo_mp fence/agents/intelmodular/fence_intelmodular +fence/agents/ipdu/fence_ipdu fence/agents/ipmilan/fence_ipmilan fence/agents/ldom/fence_ldom fence/agents/lib/fencing.py diff --git a/configure.ac b/configure.ac index 4797740..1b0ee22 100644 --- a/configure.ac +++ b/configure.ac @@ -263,6 +263,7 @@ AC_CONFIG_FILES([Makefile fence/agents/eps/Makefile fence/agents/hpblade/Makefile fence/agents/ibmblade/Makefile + fence/agents/ipdu/Makefile fence/agents/ifmib/Makefile fence/agents/ilo/Makefile fence/agents/ilo_mp/Makefile diff --git a/fence/agents/ipdu/Makefile.am b/fence/agents/ipdu/Makefile.am new file mode 100644 index 0000000..fb02cc8 --- /dev/null +++ b/fence/agents/ipdu/Makefile.am @@ -0,0 +1,17 @@ +MAINTAINERCLEANFILES = Makefile.in + +TARGET = fence_ipdu + +SRC = $(TARGET).py + +EXTRA_DIST = $(SRC) + +sbin_SCRIPTS = $(TARGET) + +man_MANS = $(TARGET).8 + +include $(top_srcdir)/make/fencebuild.mk +include $(top_srcdir)/make/fenceman.mk + +clean-local: clean-man + rm -f $(TARGET) diff --git a/fence/agents/ipdu/fence_ipdu.py b/fence/agents/ipdu/fence_ipdu.py new file mode 100644 index 0000000..9c135e6 --- /dev/null +++ b/fence/agents/ipdu/fence_ipdu.py @@ -0,0 +1,179 @@ +#!/usr/bin/python + +# The Following agent has been tested on: +# IBM iPDU model 46M4002 +# Firmware release OPDP_sIBM_v01.2_1 +# + +import sys, re, pexpect +sys.path.append("/usr/share/fence") +from fencing import * +from fencing_snmp import * + +#BEGIN_VERSION_GENERATION +RELEASE_VERSION="IBM iPDU SNMP fence agent" +REDHAT_COPYRIGHT="" +BUILD_DATE="" +#END_VERSION_GENERATION + +### CONSTANTS ### +# oid defining fence device +OID_SYS_OBJECT_ID='.1.3.6.1.2.1.1.2.0' + +### GLOBAL VARIABLES ### +# Device - see IBM iPDU +device=None + +# Port ID +port_id=None +# Switch ID +switch_id=None + +# Classes describing Device params +class IBMiPDU: + # iPDU + status_oid= '.1.3.6.1.4.1.2.6.223.8.2.2.1.11.%d' + control_oid= '.1.3.6.1.4.1.2.6.223.8.2.2.1.11.%d' + outlet_table_oid='.1.3.6.1.4.1.2.6.223.8.2.2.1.2' + ident_str="IBM iPDU" + state_on=1 + state_off=0 + turn_on=1 + turn_off=0 + has_switches=False + +### FUNCTIONS ### +def ipdu_set_device(conn,options): + global device + + agents_dir={'.1.3.6.1.4.1.2.6.223':IBMiPDU, + None:IBMiPDU} + + # First resolve type of APC + pdu_type=conn.walk(OID_SYS_OBJECT_ID) + + if (not ((len(pdu_type)==1) and (agents_dir.has_key(pdu_type[0][1])))): + pdu_type=[[None,None]] + + device=agents_dir[pdu_type[0][1]] + + conn.log_command("Trying %s"%(device.ident_str)) + +def ipdu_resolv_port_id(conn,options): + global port_id,switch_id,device + + if (device==None): + ipdu_set_device(conn,options) + + # Now we resolv port_id/switch_id + if ((options["-n"].isdigit()) and ((not device.has_switches) or (options["-s"].isdigit()))): + port_id=int(options["-n"]) + + if (device.has_switches): + switch_id=int(options["-s"]) + else: + table=conn.walk(device.outlet_table_oid,30) + + for x in table: + if (x[1].strip('"')==options["-n"]): + t=x[0].split('.') + if (device.has_switches): + port_id=int(t[len(t)-1]) + switch_id=int(t[len(t)-3]) + else: + port_id=int(t[len(t)-1]) + + if (port_id==None): + fail_usage("Can't find port with name %s!"%(options["-n"])) + +def get_power_status(conn,options): + global port_id,switch_id,device + + if (port_id==None): + ipdu_resolv_port_id(conn,options) + + oid=((device.has_switches) and device.status_oid%(switch_id,port_id) or device.status_oid%(port_id)) + + (oid,status)=conn.get(oid) + return (status==str(device.state_on) and "on" or "off") + +def set_power_status(conn, options): + global port_id,switch_id,device + + if (port_id==None): + ipdu_resolv_port_id(conn,options) + + oid=((device.has_switches) and device.control_oid%(switch_id,port_id) or device.control_oid%(port_id)) + + conn.set(oid,(options["-o"]=="on" and device.turn_on or device.turn_off)) + + +def get_outlets_status(conn, options): + global device + + result={} + + if (device==None): + ipdu_set_device(conn,options) + + res_ports=conn.walk(device.outlet_table_oid,30) + + for x in res_ports: + t=x[0].split('.') + + port_num=((device.has_switches) and "%s:%s"%(t[len(t)-3],t[len(t)-1]) or "%s"%(t[len(t)-1])) + + port_name=x[1].strip('"') + port_status="" + result[port_num]=(port_name,port_status) + + return result + +# Define new options +def ipdu_snmp_define_defaults(): + all_opt["snmp_version"]["default"]="3" + all_opt["community"]["default"]="private" + device=IBMiPDU + +# Main agent method +def main(): + device_opt = [ "help", "version", "agent", "quiet", "verbose", "debug", + "action", "ipaddr", "login", "passwd", "passwd_script", + "test", "port", "separator", "no_login", "no_password", + "snmp_version", "community", "snmp_auth_prot", "snmp_sec_level", + "snmp_priv_prot", "snmp_priv_passwd", "snmp_priv_passwd_script", + "udpport","inet4_only","inet6_only", + "power_timeout", "shell_timeout", "login_timeout", "power_wait" ] + + atexit.register(atexit_handler) + + snmp_define_defaults () + ipdu_snmp_define_defaults() + + options=check_input(device_opt,process_input(device_opt)) + + ## Support for -n [switch]:[plug] notation that was used before + if ((options.has_key("-n")) and (-1 != options["-n"].find(":"))): + (switch, plug) = options["-n"].split(":", 1) + if ((switch.isdigit()) and (plug.isdigit())): + options["-s"] = switch + options["-n"] = plug + + if (not (options.has_key("-s"))): + options["-s"]="1" + + docs = { } + docs["shortdesc"] = "Fence agent for iPDU over SNMP" + docs["longdesc"] = "fence_ipdu is an I/O Fencing agent \ +which can be used with the IBM iPDU network power switch. It logs \ +into a device via SNMP and reboots a specified outlet. It supports \ +SNMP v3 with all combinations of authenticity/privacy settings." + docs["vendorurl"] = "http://www.ibm.com" + show_docs(options, docs) + + # Operate the fencing device + result = fence_action(FencingSnmp(options), options, set_power_status, get_power_status, get_outlets_status) + + sys.exit(result) +if __name__ == "__main__": + main()