/usr/sbin/lavapdu-runner is in lavapdu-daemon 0.0.5-1.
This file is owned by root:root, with mode 0o755.
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 | #!/usr/bin/python
# Copyright 2013 Linaro Limited
# Author Matt Hart <matthew.hart@linaro.org>
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.
#
# This program 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 General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
# MA 02110-1301, USA.
import logging
import json
import os
import sys
import optparse
from logging.handlers import WatchedFileHandler
import daemon
try:
import daemon.pidlockfile as pidlockfile
except ImportError:
from lockfile import pidlockfile
from lavapdu.pdurunner import PDURunner
def getDaemonLogger(filePath, log_format=None, loglevel=logging.INFO):
logger = logging.getLogger()
logger.setLevel(loglevel)
try:
watchedHandler = WatchedFileHandler(filePath)
except Exception as e:
return e
watchedHandler.setFormatter(logging.Formatter(log_format or '%(asctime)s %(msg)s'))
logger.addHandler(watchedHandler)
return logger, watchedHandler
def readSettings(filename):
"""
Read settings from config file, to listen to all hosts, hostname should be 0.0.0.0
"""
pdus = {}
settings = {}
print("Reading settings from %s" % conffile)
with open(filename) as stream:
jobdata = stream.read()
json_data = json.loads(jobdata)
return json_data
if __name__ == '__main__':
# instance settings come from django - the coordinator doesn't use django and is
# not necessarily per-instance, so use the command line and a default conf file.
pidfile = "/var/run/lavapdu-runner.pid"
logfile = "/var/log/lavapdu-runner.log"
conffile = "/etc/lavapdu/lavapdu.conf"
settings = readSettings(conffile)
usage = "Usage: %prog [--logfile] --[loglevel]"
description = "LAVA PDU request listener server, host and port are handled in %s" % conffile
parser = optparse.OptionParser(usage=usage, description=description)
parser.add_option("--logfile", dest="logfile", action="store",
type="string", help="log file [%s]" % logfile)
parser.add_option("--loglevel", dest="loglevel", action="store",
type="string", help="logging level [INFO]")
(options, args) = parser.parse_args()
if options.logfile:
if os.path.exists(os.path.dirname(options.logfile)):
logfile = options.logfile
else:
print "No such directory for specified logfile '%s'" % logfile
open(logfile, 'w').close()
level = logging.DEBUG
daemon_settings = settings["daemon"]
if daemon_settings["logging_level"] == "DEBUG":
level = logging.DEBUG
if daemon_settings["logging_level"] == "WARNING":
level = logging.WARNING
if daemon_settings["logging_level"] == "ERROR":
level = logging.ERROR
if daemon_settings["logging_level"] == "INFO":
level = logging.INFO
client_logger, watched_file_handler = getDaemonLogger(logfile, loglevel=level,
log_format='%(asctime)s:%(levelname)s:%(name)s:%(message)s')
if isinstance(client_logger, Exception):
print("Fatal error creating client_logger: " + str(client_logger))
sys.exit(os.EX_OSERR)
# noinspection PyArgumentList
lockfile = pidlockfile.PIDLockFile(pidfile)
if lockfile.is_locked():
logging.error("PIDFile %s already locked" % pidfile)
sys.exit(os.EX_OSERR)
context = daemon.DaemonContext(
detach_process=True,
working_directory=os.getcwd(),
pidfile=lockfile,
files_preserve=[watched_file_handler.stream],
stderr=watched_file_handler.stream,
stdout=watched_file_handler.stream)
with context:
logging.info("Running LAVA PDU Runner %s dbhost: %s"
% (logfile, settings["daemon"]["dbhost"]))
p = PDURunner(settings)
p.run_me()
|