File 0001-Port-scripts-to-Python-3.patch of Package cluster-glue
diff --git a/configure.ac b/configure.ac
index e1462834..b5ac133c 100644
--- a/configure.ac
+++ b/configure.ac
@@ -499,7 +499,6 @@ dnl Replacing AC_PROG_LIBTOOL with AC_CHECK_PROG because LIBTOOL
dnl was NOT being expanded all the time thus causing things to fail.
AC_CHECK_PROGS(LIBTOOL, glibtool libtool libtool15 libtool13)
-AM_PATH_PYTHON
AC_CHECK_PROGS(MAKE, gmake make)
AC_PATH_PROGS(HTML2TXT, lynx w3m)
AC_PATH_PROGS(HELP2MAN, help2man)
@@ -1375,7 +1374,6 @@ lib/Makefile \
lib/plugins/lrm/Makefile \
lib/plugins/lrm/dbus/Makefile \
lib/plugins/stonith/Makefile \
- lib/plugins/stonith/ribcl.py \
lib/plugins/stonith/external/Makefile \
lib/plugins/stonith/external/drac5 \
lib/plugins/stonith/external/kdumpcheck \
diff --git a/lib/plugins/stonith/Makefile.am b/lib/plugins/stonith/Makefile.am
index fc007f21..d57f0c19 100644
--- a/lib/plugins/stonith/Makefile.am
+++ b/lib/plugins/stonith/Makefile.am
@@ -211,5 +211,3 @@ suicide_la_LDFLAGS = -export-dynamic -module -avoid-version
suicide_la_LIBADD = $(top_builddir)/lib/stonith/libstonith.la
stonithscriptdir = $(stonith_plugindir)/stonith2
-
-stonithscript_SCRIPTS = ribcl.py
diff --git a/lib/plugins/stonith/external/dracmc-telnet b/lib/plugins/stonith/external/dracmc-telnet
index 78c01453..b78b2e25 100644
--- a/lib/plugins/stonith/external/dracmc-telnet
+++ b/lib/plugins/stonith/external/dracmc-telnet
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/python3
# vim: set filetype=python
#######################################################################
#
@@ -23,6 +23,7 @@
#
# History:
# 2009-10-12 First release.
+# 2017-12-14 Port to Python 3 (Kristoffer Gronlund <kgronlund@suse.com>)
#
# Copyright (c) 2009 Novell, Inc.
# All Rights Reserved.
@@ -55,6 +56,18 @@ import subprocess
LOGINRETRIES = 10
+
+def is_program(prog):
+ """Is this program available?"""
+ def isexec(filename):
+ return os.path.isfile(filename) and os.access(filename, os.X_OK)
+ for p in os.getenv("PATH").split(os.pathsep):
+ f = os.path.join(p, prog)
+ if isexec(f):
+ return f
+ return None
+
+
class TimeoutException(Exception):
def __init__(self, value=None):
Exception.__init__(self)
@@ -69,71 +82,73 @@ class DracMC(telnetlib.Telnet):
self._timeout = 4
self._loggedin = 0
self._history = []
- self._appl = os.path.basename(sys.argv[0])
self._server = args[0]
- def _get_timestamp(self):
+ def _get_timestamp(self) -> str:
ct = time.time()
- msecs = (ct - long(ct)) * 1000
+ msecs = (ct - int(ct)) * 1000
return "%s,%03d" % (time.strftime("%Y-%m-%d %H:%M:%S",
time.localtime(ct)), msecs)
- def write(self, buffer):
- self._history.append(self._get_timestamp() + ': WRITE: ' + repr(buffer))
+ def write(self, buffer: bytes) -> None:
+ self._history.append(self._get_timestamp() + ': WRITE: ' + repr(buffer.decode('ascii')))
telnetlib.Telnet.write(self, buffer)
- def read_until(self, what, timeout=2):
+ def read_until(self, what: bytes, timeout:int=2) -> bytes:
line = telnetlib.Telnet.read_until(self, what, timeout)
- self._history.append(self._get_timestamp() + ': READ : ' + repr(line))
- if not line.endswith(what):
- raise TimeoutException("Timeout while waiting for '%s'." % (what, ))
+ line = line
+ linestr = line.decode('ascii')
+ self._history.append(self._get_timestamp() + ': READ : ' + repr(linestr))
+ whatstr = what.decode('ascii')
+ if not linestr.endswith(whatstr):
+ raise TimeoutException("Timeout while waiting for '%s'." % (whatstr, ))
return line
- def login(self, user, passwd):
+ def login(self, user: bytes, passwd: bytes):
time.sleep(0.3)
try:
- line = self.read_until('Login: ', self._timeout)
+ line = self.read_until(b'Login: ', self._timeout)
self.write(user)
- self.write('\r')
- line = self.read_until('Password: ', self._timeout)
+ self.write(b'\r')
+ line = self.read_until(b'Password: ', self._timeout)
self.write(passwd)
- self.write('\r')
- except:
- self.write("\r")
- line = self.read_until('Login: ', self._timeout)
+ self.write(b'\r')
+ except (EOFError, TimeoutException):
+ self.write(b'\r')
+ line = self.read_until(b'Login: ', self._timeout)
self.write(user)
- self.write('\r')
- line = self.read_until('Password: ', self._timeout)
+ self.write(b'\r')
+ line = self.read_until(b'Password: ', self._timeout)
self.write(passwd)
- self.write('\r')
+ self.write(b'\r')
try:
- line = self.read_until('DRAC/MC:', self._timeout)
- except:
- self.write("\r")
- line = self.read_until('DRAC/MC:', self._timeout)
+ line = self.read_until(b'DRAC/MC:', self._timeout)
+ except (EOFError, TimeoutException):
+ self.write(b'\r')
+ line = self.read_until(b'DRAC/MC:', self._timeout)
def hardreset(self):
- self.write('serveraction -s %s hardreset\r' % self._server)
- line = self.read_until('OK', 10)
- line = self.read_until('DRAC/MC:', self._timeout)
-
+ self.write('serveraction -s {} hardreset\r'.format(self._server).encode('ascii'))
+ line = self.read_until(b'OK', 10)
+ line = self.read_until(b'DRAC/MC:', self._timeout)
+
def powercycle(self):
- self.write('serveraction -s %s powercycle\r' % self._server)
- line = self.read_until('OK', 10)
- line = self.read_until('DRAC/MC:', self._timeout)
+ self.write('serveraction -s {} powercycle\r'.format(self._server).encode('ascii'))
+ line = self.read_until(b'OK', 10)
+ line = self.read_until(b'DRAC/MC:', self._timeout)
def on(self):
- self.write('serveraction -s %s powerup\r' % self._server)
- line = self.read_until('OK', 10)
- line = self.read_until('DRAC/MC:', self._timeout)
+ self.write('serveraction -s {} powerup\r'.format(self._server).encode('ascii'))
+ line = self.read_until(b'OK', 10)
+ line = self.read_until(b'DRAC/MC:', self._timeout)
def off(self):
- self.write('serveraction -s %s powerdown\r' % self._server)
- line = self.read_until('OK', 10)
- line = self.read_until('DRAC/MC:', self._timeout)
+ self.write('serveraction -s {} powerdown\r'.format(self._server).encode('ascii'))
+ line = self.read_until(b'OK', 10)
+ line = self.read_until(b'DRAC/MC:', self._timeout)
def exit(self):
- self.write('exit\r')
+ self.write(b'exit\r')
def get_history(self):
return "\n".join(self._history)
@@ -150,9 +165,6 @@ class DracMCStonithPlugin:
self._required_cmds_list = self._required_cmds.split()
self._optional_cmds_list = self._optional_cmds.split()
- # who am i
- self._appl = os.path.basename(sys.argv[0])
-
# telnet connection object
self._connection = None
@@ -168,14 +180,17 @@ class DracMCStonithPlugin:
except IndexError:
self._parameters[name] = ''
- def _get_timestamp(self):
+ def _get_timestamp(self) -> str:
ct = time.time()
- msecs = (ct - long(ct)) * 1000
+ msecs = (ct - int(ct)) * 1000
return "%s,%03d" % (time.strftime("%Y-%m-%d %H:%M:%S",
time.localtime(ct)), msecs)
def _echo_debug(self, *args):
- subprocess.call("ha_log.sh debug '%s'" % ' '.join(args), shell=True)
+ if is_program("ha_log.sh"):
+ subprocess.call("ha_log.sh debug '{}'".format(' '.join(args)), shell=True)
+ elif os.environ.get("DRACMC_DEBUG") == "yes":
+ print('debug :', ' '.join(args))
def echo(self, *args):
what = ''.join([str(x) for x in args])
@@ -185,7 +200,10 @@ class DracMCStonithPlugin:
self._echo_debug("STDOUT:", what)
def echo_log(self, level, *args):
- subprocess.call("ha_log.sh %s '%s'" % (level,' '.join(args)), shell=True)
+ if is_program("ha_log.sh"):
+ subprocess.call("ha_log.sh {} '{}'".format(level, ' '.join(args)), shell=True)
+ elif os.environ.get("DRACMC_DEBUG") == "yes":
+ print(level, ':', ' '.join(args))
def _get_connection(self):
if not self._connection:
@@ -198,9 +216,9 @@ class DracMCStonithPlugin:
try:
c.open(self._parameters['cyclades_ip'],
self._parameters['cyclades_port'])
- c.login(self._parameters['username'],
- self._parameters['password'])
- except Exception, args:
+ c.login(self._parameters['username'].encode('ascii'),
+ self._parameters['password'].encode('ascii'))
+ except Exception as args:
if "Connection reset by peer" in str(args):
self._echo_debug("Someone is already logged in... retry=%s" % tries)
c.close()
@@ -362,7 +380,7 @@ class DracMCStonithPlugin:
func = getattr(self, cmd, self.not_implemented)
rc = func()
return(rc)
- except Exception, args:
+ except Exception as args:
self.echo_log("err", 'Exception raised:', str(args))
if self._connection:
self.echo_log("err", self._connection.get_history())
diff --git a/lib/plugins/stonith/external/ibmrsa-telnet b/lib/plugins/stonith/external/ibmrsa-telnet
index adb2a3eb..ea57c75d 100644
--- a/lib/plugins/stonith/external/ibmrsa-telnet
+++ b/lib/plugins/stonith/external/ibmrsa-telnet
@@ -1,4 +1,4 @@
-#!/usr/bin/python
+#!/usr/bin/python3
# vim: set filetype=python
#######################################################################
#
@@ -53,6 +53,18 @@ import time
import telnetlib
import subprocess
+
+def is_program(prog):
+ """Is this program available?"""
+ def isexec(filename):
+ return os.path.isfile(filename) and os.access(filename, os.X_OK)
+ for p in os.getenv("PATH").split(os.pathsep):
+ f = os.path.join(p, prog)
+ if isexec(f):
+ return f
+ return None
+
+
class TimeoutException(Exception):
def __init__(self, value=None):
Exception.__init__(self)
@@ -61,59 +73,59 @@ class TimeoutException(Exception):
def __str__(self):
return repr(self.value)
+
class RSABoard(telnetlib.Telnet):
def __init__(self, *args, **kwargs):
telnetlib.Telnet.__init__(self, *args, **kwargs)
self._timeout = 10
self._loggedin = 0
self._history = []
- self._appl = os.path.basename(sys.argv[0])
- def _get_timestamp(self):
+ def _get_timestamp(self) -> str:
ct = time.time()
- msecs = (ct - long(ct)) * 1000
+ msecs = (ct - int(ct)) * 1000
return "%s,%03d" % (time.strftime("%Y-%m-%d %H:%M:%S",
time.localtime(ct)), msecs)
- def write(self, buffer, nolog = False):
+ def write(self, buffer: bytes, nolog = False) -> None:
self._history.append(self._get_timestamp() + ': WRITE: ' +
- (nolog and '******' or repr(buffer)))
+ (nolog and '******' or repr(buffer.decode('ascii'))))
telnetlib.Telnet.write(self, buffer)
- def expect(self, what, timeout=20):
+ def expect(self, what: bytes, timeout=20):
line = telnetlib.Telnet.expect(self, what, timeout)
- self._history.append(self._get_timestamp() + ': READ : ' + repr(line))
+ self._history.append(self._get_timestamp() + ': READ : ' + repr(line.decode('ascii')))
if not line:
- raise TimeoutException("Timeout while waiting for '%s'." % (what, ))
+ raise TimeoutException("Timeout while waiting for '%s'." % (what.decode('ascii'), ))
return line
- def login(self, user, passwd):
+ def login(self, user: bytes, passwd: bytes):
time.sleep(1)
- line = self.expect(['\nlogin : ', '\nusername: '], self._timeout)
+ line = self.expect([b'\nlogin : ', b'\nusername: '], self._timeout)
self.write(user)
- self.write('\r')
- line = self.expect(['\nPassword: ', '\npassword: '], self._timeout)
+ self.write(b'\r')
+ line = self.expect([b'\nPassword: ', b'\npassword: '], self._timeout)
self.write(passwd, nolog = True)
- self.write('\r')
- line = self.expect(['\nsystem>', '> '], self._timeout)
+ self.write(b'\r')
+ line = self.expect([b'\nsystem>', b'> '], self._timeout)
def reset(self):
- self.write('power cycle\r')
- line = self.expect(['\nok'], self._timeout)
- line = self.expect(['\nsystem>', '> '], self._timeout)
+ self.write(b'power cycle\r')
+ line = self.expect([b'\nok'], self._timeout)
+ line = self.expect([b'\nsystem>', b'> '], self._timeout)
def on(self):
- self.write('power on\r')
- line = self.expect(['\nok'], self._timeout)
- line = self.expect(['\nsystem>', '> '], self._timeout)
+ self.write(b'power on\r')
+ line = self.expect([b'\nok'], self._timeout)
+ line = self.expect([b'\nsystem>', b'> '], self._timeout)
def off(self):
- self.write('power off\r')
- line = self.expect(['\nok'], self._timeout)
- line = self.expect(['\nsystem>', '> '], self._timeout)
+ self.write(b'power off\r')
+ line = self.expect([b'\nok'], self._timeout)
+ line = self.expect([b'\nsystem>', b'> '], self._timeout)
def exit(self):
- self.write('exit\r')
+ self.write(b'exit\r')
def get_history(self):
return "\n".join(self._history)
@@ -130,9 +142,6 @@ class RSAStonithPlugin:
self._required_cmds_list = self._required_cmds.split()
self._optional_cmds_list = self._optional_cmds.split()
- # who am i
- self._appl = os.path.basename(sys.argv[0])
-
# telnet connection object
self._connection = None
@@ -149,7 +158,7 @@ class RSAStonithPlugin:
def _get_timestamp(self):
ct = time.time()
- msecs = (ct - long(ct)) * 1000
+ msecs = (ct - int(ct)) * 1000
return "%s,%03d" % (time.strftime("%Y-%m-%d %H:%M:%S",
time.localtime(ct)), msecs)
@@ -164,7 +173,10 @@ class RSAStonithPlugin:
self._echo_debug("STDOUT:", what)
def echo_log(self, level, *args):
- subprocess.call(('ha_log.sh', level) + args)
+ if is_program("ha_log.sh"):
+ subprocess.call("ha_log.sh {} '{}'".format(level, ' '.join(args)), shell=True)
+ elif os.environ.get("IBMRSA_DEBUG") == "yes":
+ print(level, ':', ' '.join(args))
def _get_connection(self):
if not self._connection:
@@ -173,8 +185,8 @@ class RSAStonithPlugin:
(self._parameters['ip_address'],))
c.open(self._parameters['ip_address'])
self._echo_debug("Connection established")
- c.login(self._parameters['username'],
- self._parameters['password'])
+ c.login(self._parameters['username'].encode('ascii'),
+ self._parameters['password'].encode('ascii'))
self._connection = c
def _end_connection(self):
@@ -305,7 +317,7 @@ class RSAStonithPlugin:
func = getattr(self, cmd, self.not_implemented)
rc = func()
return(rc)
- except Exception, args:
+ except Exception as args:
self.echo_log("err", 'Exception raised:', str(args))
if self._connection:
self.echo_log("err", self._connection.get_history())
diff --git a/lib/plugins/stonith/external/riloe b/lib/plugins/stonith/external/riloe
index 412873f5..9610162b 100644
--- a/lib/plugins/stonith/external/riloe
+++ b/lib/plugins/stonith/external/riloe
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/python3
#
# Stonith module for RILOE Stonith device
#
@@ -17,6 +17,8 @@
# Extended by Jochen Roeder <jochen.roeder@novell.com>
# to enable access via proxies
#
+# Ported to Python 3 by Kristoffer Gronlund <kgronlund@suse.com>
+#
# This library is free software; you can redistribute it and/or
# modify it under the terms of the GNU Lesser General Public
# License as published by the Free Software Foundation; either
@@ -35,12 +37,27 @@ import os
import socket
import subprocess
import xml.dom.minidom
-import httplib
+import http.client as httplib
import time
import re
+
+def is_program(prog):
+ """Is this program available?"""
+ def isexec(filename):
+ return os.path.isfile(filename) and os.access(filename, os.X_OK)
+ for p in os.getenv("PATH").split(os.pathsep):
+ f = os.path.join(p, prog)
+ if isexec(f):
+ return f
+ return None
+
+
def log_msg(level,msg):
- subprocess.call("ha_log.sh %s '%s'" % (level,msg), shell=True)
+ if is_program("ha_log.sh"):
+ subprocess.call("ha_log.sh %s '%s'" % (level,msg), shell=True)
+ elif os.environ.get("RILOE_DEBUG") == "yes":
+ print("{} {}".format(level, msg))
def my_err(msg):
log_msg("err", msg)
def my_warn(msg):
@@ -163,12 +180,12 @@ info = {
}
if cmd in info:
- print info[cmd]
+ print(info[cmd])
sys.exit(0)
if cmd == 'getconfignames':
for arg in [ "hostlist", "ilo_hostname", "ilo_user", "ilo_password", "ilo_can_reset", "ilo_protocol", "ilo_powerdown_method", "ilo_proxyhost", "ilo_proxyport"]:
- print arg
+ print(arg)
sys.exit(0)
if not rihost:
@@ -332,11 +349,11 @@ def open_ilo(host):
proxy_connect='CONNECT %s:%s HTTP/1.1\r\n'%(host,443)
user_agent='User-Agent: python\r\n'
proxy_pieces=proxy_connect+user_agent+'\r\n'
- proxy.sendall(proxy_pieces)
+ proxy.sendall(proxy_pieces.encode('ascii'))
response=proxy.recv(8192)
status=response.split()[1]
if status!=str(200):
- fatal("Error status=: %s" %(response))
+ fatal("Error status=: %s" %(response.decode('ascii')))
import ssl
sock = ssl.wrap_socket(proxy)
h=httplib.HTTPConnection('localhost')
@@ -344,13 +361,13 @@ def open_ilo(host):
return h
else:
return httplib.HTTPSConnection(host)
- except socket.gaierror, msg:
+ except socket.gaierror as msg:
fatal("%s: %s" %(msg,host))
- except socket.sslerror, msg:
+ except socket.sslerror as msg:
fatal("%s for %s" %(msg,host))
- except socket.error, msg:
+ except socket.error as msg:
fatal("%s while talking to %s" %(msg,host))
- except ImportError, msg:
+ except ImportError as msg:
fatal("ssl support missing (%s)" %msg)
def send_request(req,proc_f):
@@ -363,8 +380,8 @@ def send_request(req,proc_f):
t_begin = time.time()
c = open_ilo(rihost)
try:
- c.send(req+'\r\n')
- except socket.error, msg:
+ c.send((req+'\r\n').encode('ascii'))
+ except socket.error as msg:
fatal("%s, while talking to %s" %(msg,rihost))
t_end = time.time()
my_debug("request sent in %0.2f s" % ((t_end-t_begin)))
@@ -376,8 +393,8 @@ def send_request(req,proc_f):
reply = c.sock.recv(1024)
if not reply:
break
- result.append(reply)
- except socket.error, msg:
+ result.append(reply.decode('ascii'))
+ except socket.error as msg:
if msg[0] == 6: # connection closed
break
my_err("%s, while talking to %s" %(msg,rihost))
@@ -393,7 +410,7 @@ def send_request(req,proc_f):
reply = re.sub("<(RIBCL.*)/>", r"<\1>", reply)
try:
doc = xml.dom.minidom.parseString(reply)
- except xml.parsers.expat.ExpatError,msg:
+ except xml.parsers.expat.ExpatError as msg:
fatal("malformed response: %s\n%s"%(msg,reply))
rc = proc_f(doc)
doc.unlink()
diff --git a/lib/plugins/stonith/external/vcenter b/lib/plugins/stonith/external/vcenter
index 38ba36e3..0a26fdd4 100755
--- a/lib/plugins/stonith/external/vcenter
+++ b/lib/plugins/stonith/external/vcenter
@@ -1,4 +1,4 @@
-#!/usr/bin/env perl
+#!/usr/bin/perl
#
# External STONITH module for VMWare vCenter/ESX
#
diff --git a/lib/plugins/stonith/ribcl.py.in b/lib/plugins/stonith/ribcl.py.in
deleted file mode 100644
index 0733bb24..00000000
--- a/lib/plugins/stonith/ribcl.py.in
+++ /dev/null
@@ -1,100 +0,0 @@
-#!@PYTHON@
-
-
-#
-# This library is free software; you can redistribute it and/or
-# modify it under the terms of the GNU Lesser General Public
-# License as published by the Free Software Foundation; either
-# version 2.1 of the License, or (at your option) any later version.
-#
-# This library is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-# Lesser General Public License for more details.
-#
-# You should have received a copy of the GNU Lesser General Public
-# License along with this library; if not, see <http://www.gnu.org/licenses/>
-#
-
-import sys
-import socket
-from httplib import *
-from time import sleep
-
-
-argv = sys.argv
-
-
-try:
- host = argv[1].split('.')[0]+'-rm'
- cmd = argv[2]
-except IndexError:
- print "Not enough arguments"
- sys.exit(1)
-
-
-login = [ '<RIBCL VERSION="1.2">',
- '<LOGIN USER_LOGIN="Administrator" PASSWORD="********">' ]
-
-
-logout = [ '</LOGIN>', '</RIBCL>' ]
-
-
-status = [ '<SERVER_INFO MODE="read">', '<GET_HOST_POWER_STATUS/>',
- '</SERVER_INFO>' ]
-
-
-reset = [ '<SERVER_INFO MODE="write">', '<RESET_SERVER/>', '</SERVER_INFO>' ]
-
-
-off = [ '<SERVER_INFO MODE = "write">', '<SET_HOST_POWER HOST_POWER = "N"/>',
- '</SERVER_INFO>' ]
-
-
-on = [ '<SERVER_INFO MODE = "write">', '<SET_HOST_POWER HOST_POWER = "Y"/>',
- '</SERVER_INFO>' ]
-
-
-todo = { 'reset':reset, 'on':on, 'off':off, 'status':status }
-
-
-acmds=[]
-try:
- if cmd == 'reset' and host.startswith('gfxcl'):
- acmds.append(login + todo['off'] + logout)
- acmds.append(login + todo['on'] + logout)
- else:
- acmds.append(login + todo[cmd] + logout)
-except KeyError:
- print "Invalid command: "+ cmd
- sys.exit(1)
-
-
-try:
- for cmds in acmds:
-
-
- c=HTTPSConnection(host)
- c.send('<?xml version="1.0"?>\r\n')
- c.sock.recv(1024)
-
-
- for line in cmds:
- c.send(line+'\r\n')
- c.sock.recv(1024)
-
-
- c.close()
- sleep(1)
-
-
-except socket.gaierror, msg:
- print msg
- sys.exit(1)
-except socket.sslerror, msg:
- print msg
- sys.exit(1)
-except socket.error, msg:
- print msg
- sys.exit(1)
-
diff --git a/lib/plugins/stonith/riloe.c b/lib/plugins/stonith/riloe.c
deleted file mode 100644
index 50583428..00000000
--- a/lib/plugins/stonith/riloe.c
+++ /dev/null
@@ -1,337 +0,0 @@
-/*
- * Stonith module for RILOE Stonith device
- *
- * Copyright (c) 2004 Alain St-Denis <alain.st-denis@ec.gc.ca>
- *
- * Mangled by Zhaokai <zhaokai@cn.ibm.com>, IBM, 2005
- *
- * This library is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License as published by the Free Software Foundation; either
- * version 2.1 of the License, or (at your option) any later version.
- *
- * This library is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this library; if not, see <http://www.gnu.org/licenses/>
- *
- */
-
-#define DEVICE "Compaq RILOE"
-#include "stonith_plugin_common.h"
-
-#define PIL_PLUGIN riloe
-#define PIL_PLUGIN_S "riloe"
-#define PIL_PLUGINLICENSE LICENSE_LGPL
-#define PIL_PLUGINLICENSEURL URL_LGPL
-#include <pils/plugin.h>
-
-static StonithPlugin * riloe_new(const char *);
-static void riloe_destroy(StonithPlugin *);
-static int riloe_set_config(StonithPlugin *, StonithNVpair *);
-static const char * const * riloe_get_confignames(StonithPlugin * );
-static const char * riloe_getinfo(StonithPlugin * s, int InfoType);
-static int riloe_status(StonithPlugin * );
-static int riloe_reset_req(StonithPlugin * s, int request, const char * host);
-static char ** riloe_hostlist(StonithPlugin *);
-
-static struct stonith_ops riloeOps ={
- riloe_new, /* Create new STONITH object */
- riloe_destroy, /* Destroy STONITH object */
- riloe_getinfo, /* Return STONITH info string */
- riloe_get_confignames, /* Return STONITH info string */
- riloe_set_config, /* Get configuration from NVpairs */
- riloe_status, /* Return STONITH device status */
- riloe_reset_req, /* Request a reset */
- riloe_hostlist, /* Return list of supported hosts */
-};
-
-PIL_PLUGIN_BOILERPLATE2("1.0", Debug)
-static const PILPluginImports* PluginImports;
-static PILPlugin* OurPlugin;
-static PILInterface* OurInterface;
-static StonithImports* OurImports;
-static void* interfprivate;
-
-PIL_rc
-PIL_PLUGIN_INIT(PILPlugin*us, const PILPluginImports* imports);
-
-PIL_rc
-PIL_PLUGIN_INIT(PILPlugin*us, const PILPluginImports* imports)
-{
- /* Force the compiler to do a little type checking */
- (void)(PILPluginInitFun)PIL_PLUGIN_INIT;
-
- PluginImports = imports;
- OurPlugin = us;
-
- /* Register ourself as a plugin */
- imports->register_plugin(us, &OurPIExports);
-
- /* Register our interface implementation */
- return imports->register_interface(us, PIL_PLUGINTYPE_S
- , PIL_PLUGIN_S
- , &riloeOps
- , NULL /*close */
- , &OurInterface
- , (void*)&OurImports
- , &interfprivate);
-}
-
-#define RILOE_COMMAND STONITH_MODULES "/ribcl.py"
-
-/*
- * Riloe STONITH device. We are very agreeable, but don't do much :-)
- */
-
-struct pluginDevice {
- StonithPlugin sp;
- const char * pluginid;
- const char * idinfo;
- char ** hostlist;
- int hostcount;
-};
-
-static const char * pluginid = "RiloeDevice-Stonith";
-static const char * NOTriloeID = "Riloe device has been destroyed";
-
-#include "stonith_config_xml.h"
-
-static const char *riloeXML =
- XML_PARAMETERS_BEGIN
- XML_HOSTLIST_PARM
- XML_PARAMETERS_END;
-
-static int
-riloe_status(StonithPlugin *s)
-{
-
- if (Debug) {
- LOG(PIL_DEBUG, "%s:called.", __FUNCTION__);
- }
-
- ERRIFWRONGDEV(s,S_OOPS);
- return S_OK;
-}
-
-
-/*
- * Return the list of hosts configured for this RILOE device
- */
-
-static char **
-riloe_hostlist(StonithPlugin *s)
-{
- struct pluginDevice* nd;
-
- if (Debug) {
- LOG(PIL_DEBUG, "%s:called.", __FUNCTION__);
- }
-
- ERRIFWRONGDEV(s,NULL);
- nd = (struct pluginDevice*) s;
- if (nd->hostcount < 0) {
- LOG(PIL_CRIT
- , "unconfigured stonith object in %s", __FUNCTION__);
- return(NULL);
- }
-
- return OurImports->CopyHostList((const char * const*)nd->hostlist);
-}
-
-/*
- * Parse the config information, and stash it away...
- */
-
-static int
-RILOE_parse_config_info(struct pluginDevice* nd, const char * info)
-{
- if (Debug) {
- LOG(PIL_DEBUG, "%s:called.", __FUNCTION__);
- }
-
- if (nd->hostcount >= 0) {
- return(S_OOPS);
- }
-
- nd->hostlist = OurImports->StringToHostList(info);
- if (nd->hostlist == NULL) {
- LOG(PIL_CRIT,"StringToHostList() failed");
- return S_OOPS;
- }
- for (nd->hostcount = 0; nd->hostlist[nd->hostcount]; nd->hostcount++) {
- strdown(nd->hostlist[nd->hostcount]);
- }
- return(S_OK);
-}
-
-
-/*
- * Pretend to reset the given host on this Stonith device.
- * (we don't even error check the "request" type)
- */
-static int
-riloe_reset_req(StonithPlugin * s, int request, const char * host)
-{
- char cmd[4096];
-
- if (Debug) {
- LOG(PIL_DEBUG, "%s:called.", __FUNCTION__);
- }
-
- ERRIFWRONGDEV(s,S_OOPS);
-
- if (Debug) {
- LOG(PIL_DEBUG, "%s:called.", __FUNCTION__);
- }
-
- snprintf(cmd, sizeof(cmd), "%s %s reset", RILOE_COMMAND, host);
-
- if (Debug) {
- LOG(PIL_DEBUG, "command %s will be executed", cmd);
- }
-
- if (system(cmd) == 0) {
- return S_OK;
- } else {
- LOG(PIL_CRIT, "command %s failed", cmd);
- return(S_RESETFAIL);
- }
-}
-
-/*
- * Parse the information in the given string,
- * and stash it away...
- */
-static int
-riloe_set_config(StonithPlugin* s, StonithNVpair *list)
-{
- StonithNamesToGet namestocopy [] =
- { {ST_HOSTLIST, NULL}
- , {NULL, NULL}
- };
- struct pluginDevice* nd;
- int rc;
-
- if (Debug) {
- LOG(PIL_DEBUG, "%s:called.", __FUNCTION__);
- }
-
- ERRIFWRONGDEV(s,S_OOPS);
- nd = (struct pluginDevice*) s;
-
- if ((rc = OurImports->CopyAllValues(namestocopy, list)) != S_OK) {
- return rc;
- }
-
- rc = RILOE_parse_config_info(nd , namestocopy[0].s_value);
- FREE(namestocopy[0].s_value);
- return rc;
-}
-
-/*
- * Return the Stonith plugin configuration parameter
- */
-static const char* const *
-riloe_get_confignames(StonithPlugin* p)
-{
- static const char * RiloeParams[] = {ST_HOSTLIST, NULL };
-
- if (Debug) {
- LOG(PIL_DEBUG, "%s:called.", __FUNCTION__);
- }
-
- return RiloeParams;
-}
-
-/*
- * Return STONITH info string
- */
-
-static const char *
-riloe_getinfo(StonithPlugin * s, int reqtype)
-{
- struct pluginDevice* nd;
- const char * ret;
-
- if (Debug) {
- LOG(PIL_DEBUG, "%s:called.", __FUNCTION__);
- }
-
- ERRIFWRONGDEV(s,NULL);
- /*
- * We look in the ST_TEXTDOMAIN catalog for our messages
- */
- nd = (struct pluginDevice *)s;
-
- switch (reqtype) {
- case ST_DEVICEID:
- ret = nd->idinfo;
- break;
- case ST_DEVICEDESCR:
- ret = "Compaq RILOE STONITH device\n"
- "Very early version!";
- break;
- case ST_DEVICEURL:
- ret = "http://www.hp.com/";
- break;
- case ST_CONF_XML: /* XML metadata */
- ret = riloeXML;
- break;
- default:
- ret = NULL;
- break;
- }
- return ret;
-}
-
-/*
- * RILOE Stonith destructor...
- */
-static void
-riloe_destroy(StonithPlugin *s)
-{
- struct pluginDevice* nd;
-
- if (Debug) {
- LOG(PIL_DEBUG, "%s:called.", __FUNCTION__);
- }
-
- VOIDERRIFWRONGDEV(s);
- nd = (struct pluginDevice *)s;
-
- nd->pluginid = NOTriloeID;
- if (nd->hostlist) {
- stonith_free_hostlist(nd->hostlist);
- nd->hostlist = NULL;
- }
- nd->hostcount = -1;
- FREE(nd);
-}
-
-/* Create a new Riloe Stonith device. Too bad this function can't be static */
-static StonithPlugin *
-riloe_new(const char *subplugin)
-{
- struct pluginDevice* nd = ST_MALLOCT(struct pluginDevice);
-
- if (Debug) {
- LOG(PIL_DEBUG, "%s:called.", __FUNCTION__);
- }
-
- if (nd == NULL) {
- LOG(PIL_CRIT, "out of memory");
- return(NULL);
- }
- memset(nd, 0, sizeof(*nd));
- nd->pluginid = pluginid;
- nd->hostlist = NULL;
- nd->hostcount = -1;
- nd->idinfo = DEVICE;
- nd->sp.s_ops = &riloeOps;
-
- return &(nd->sp);
-}
