Reference Manual

All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages

Classes
class	Timeout

Functions
def	alarm_handler

def	launch

def	log

def	main

Variables
tuple	args = parser.parse_args()

tuple	group = parser.add_mutually_exclusive_group()

tuple	parser = argparse.ArgumentParser(description="Kill/restart the child process if it doesn't out the required string.")

tuple	stdin_ = os.dup(sys.stdin.fileno())

tuple	stdout_ = os.dup(sys.stdout.fileno())

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)

watchdog.Timeout

Definition: watchdog.py:12

watchdog.alarm_handler

def alarm_handler

Definition: watchdog.py:15

def watchdog.launch ( args )

Definition at line 25 of file watchdog.py.

References log().

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)

watchdog.launch

def launch

Definition: watchdog.py:25

watchdog.log

def log

Definition: watchdog.py:21

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()

watchdog.log

def log

Definition: watchdog.py:21

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
 