FM / supervisor

/usr/lib/python2.6/site-packages/supervisor/

/usr/lib/python2.6/site-packages/supervisor

Name	Size	Mode	Actions
medusa/	-	0755	rm
ui/	-	0755	rm
datatypes.py	6641	0644	edit dl rm
datatypes.pyc	9095	0644	edit dl rm
datatypes.pyo	9047	0644	edit dl rm
http.py	26533	0644	edit dl rm
http.pyc	22766	0644	edit dl rm
http.pyo	22766	0644	edit dl rm
http_client.py	6291	0644	edit dl rm
http_client.pyc	8759	0644	edit dl rm
http_client.pyo	8680	0644	edit dl rm
options.py	55449	0644	edit dl rm
options.pyc	49411	0644	edit dl rm
options.pyo	49411	0644	edit dl rm
pidproxy.py	1797	0644	edit dl rm
pidproxy.pyc	2658	0644	edit dl rm
pidproxy.pyo	2658	0644	edit dl rm
supervisorctl.py	21497	0644	edit dl rm
supervisorctl.pyc	20043	0644	edit dl rm
supervisorctl.pyo	20043	0644	edit dl rm
supervisord.py	27490	0644	edit dl rm
supervisord.pyc	22117	0644	edit dl rm
supervisord.pyo	22004	0644	edit dl rm
test.py	117544	0644	edit dl rm
test.pyc	117216	0644	edit dl rm
test.pyo	117216	0644	edit dl rm
web.py	17563	0644	edit dl rm
web.pyc	15022	0644	edit dl rm
web.pyo	15022	0644	edit dl rm
xmlrpc.py	32658	0644	edit dl rm
xmlrpc.pyc	27660	0644	edit dl rm
xmlrpc.pyo	27542	0644	edit dl rm
__init__.py	8	0644	edit dl rm
__init__.pyc	142	0644	edit dl rm
__init__.pyo	142	0644	edit dl rm

Edit: /usr/lib/python2.6/site-packages/supervisor/pidproxy.py (1797B)

# An executable which proxies for a subprocess; upon a signal, it sends that
# signal to the process identified by a pidfile

import os
import sys
import signal
import time

class PidProxy:
    pid = None
    def __init__(self, args):
        self.setsignals()
        try:
            self.pidfile, cmdargs = args[1], args[2:]
            self.command = os.path.abspath(cmdargs[0])
            self.cmdargs = cmdargs
        except (ValueError, IndexError):
            self.usage()
            sys.exit(1)

def go(self):
        self.pid = os.spawnv(os.P_NOWAIT, self.command, self.cmdargs)
        while 1:
            time.sleep(5)
            try:
                pid, sts = os.waitpid(-1, os.WNOHANG)
            except os.error:
                pid, sts = None, None
            if pid:
                break

def usage(self):
        print "pidproxy.py <pidfile name> <command> [<cmdarg1> ...]"

def setsignals(self):
        signal.signal(signal.SIGTERM, self.passtochild)
        signal.signal(signal.SIGHUP, self.passtochild)
        signal.signal(signal.SIGINT, self.passtochild)
        signal.signal(signal.SIGUSR1, self.passtochild)
        signal.signal(signal.SIGUSR2, self.passtochild)
        signal.signal(signal.SIGCHLD, self.reap)

def reap(self, sig, frame):
        # do nothing, we reap our child synchronously
        pass

def passtochild(self, sig, frame):
        try:
            pid = int(open(self.pidfile, 'r').read().strip())
        except:
            pid = None
            print "Can't read child pidfile %s!" % self.pidfile
            return
        os.kill(pid, sig)
        if sig in [signal.SIGTERM, signal.SIGINT, signal.SIGQUIT]:
            sys.exit(0)

if __name__ == '__main__':
    pp = PidProxy(sys.argv)
    pp.go()

# An executable which proxies for a subprocess; upon a signal, it sends that # signal to the process identified by a pidfile import os import sys import signal import time class PidProxy: pid = None def __init__(self, args): self.setsignals() try: self.pidfile, cmdargs = args[1], args[2:] self.command = os.path.abspath(cmdargs[0]) self.cmdargs = cmdargs except (ValueError, IndexError): self.usage() sys.exit(1) def go(self): self.pid = os.spawnv(os.P_NOWAIT, self.command, self.cmdargs) while 1: time.sleep(5) try: pid, sts = os.waitpid(-1, os.WNOHANG) except os.error: pid, sts = None, None if pid: break def usage(self): print "pidproxy.py [ ...]" def setsignals(self): signal.signal(signal.SIGTERM, self.passtochild) signal.signal(signal.SIGHUP, self.passtochild) signal.signal(signal.SIGINT, self.passtochild) signal.signal(signal.SIGUSR1, self.passtochild) signal.signal(signal.SIGUSR2, self.passtochild) signal.signal(signal.SIGCHLD, self.reap) def reap(self, sig, frame): # do nothing, we reap our child synchronously pass def passtochild(self, sig, frame): try: pid = int(open(self.pidfile, 'r').read().strip()) except: pid = None print "Can't read child pidfile %s!" % self.pidfile return os.kill(pid, sig) if sig in [signal.SIGTERM, signal.SIGINT, signal.SIGQUIT]: sys.exit(0) if __name__ == '__main__': pp = PidProxy(sys.argv) pp.go()