watchdog Namespace Reference

Classes
class	Timeout

Functions
def	alarm_handler (signum, frame)
def	launch (args)
def	log (s)
def	main (args)

Function Documentation

def watchdog.alarm_handler	(		signum,
			frame
	)

Definition at line 15 of file watchdog.py.

def alarm_handler(signum, frame):
    if signum != 14: return
    raise Timeout("Timeout reached.")

signal.signal(signal.SIGALRM, alarm_handler)

def watchdog.launch

(

args

)

Definition at line 25 of file watchdog.py.

References log(), and str.

Referenced by main().

def launch(args):
    fd, wd = os.pipe()

    def preexec():
        os.close(fd)

        env = os.environ
        env["WATCHDOG_FD"] = str(wd)

    p = subprocess.Popen(args.pargs, preexec_fn=preexec, stdin=stdin_, stdout=stdout_)
    os.close(wd)

    while True:
        try:
            signal.alarm(args.t)
            ch = os.read(fd, 1024)
            signal.alarm(0)
            
            if not ch:
                os.close(fd)
                return False, p.wait() # normal exit
            
            log("Received: %s, timer reset." % repr(ch))

        except Timeout as t:
            signal.alarm(0)

            log("Timeout reached, taking action.")

            if p.poll() is None:
                p.send_signal(args.action)

            os.close(fd)
            return True, p.wait()

    for p in open_procs_:
        if p.poll() is None:
            p.send_signal(sig)

def watchdog.log

(

s

)

Definition at line 21 of file watchdog.py.

Referenced by launch(), and main().

def log(s):
    sys.stderr.write("watchdog: " + s + "\n");
    sys.stderr.flush()

def watchdog.main

(

args

)

Definition at line 64 of file watchdog.py.

References launch(), and log().

def main(args):
    while True:
        killed, ret = launch(args)
        log("Program exitted, killed: %s, code: %d." % (killed, ret, ))

        if killed and args.restart:
            log("Restarting.")
            continue
    
        break