esMonitoring Namespace Reference

Classes
class	AsyncLineReaderMixin
class	AsyncLineReaderTimeoutMixin
class	ElasticReport
class	FDJsonHandler
class	FDJsonServer
class	FDOutputListener
class	JsonEncoder
class	LineHistoryEnd
class	LineHistoryStart

Functions
def	dt2time (dt)
def	handle_signal (signum, frame)
def	launch_monitoring (args)
def	log (s)

Variables
	action
	args
	CURRENT_PROC
	default
	description
	help
	nargs
	None
	pargs
	parser
	str
	type

Function Documentation

def esMonitoring.dt2time

(

dt

)

Definition at line 15 of file esMonitoring.py.

def dt2time(dt):
    # convert datetime timstamp to unix
    return time.mktime(dt.timetuple())

def esMonitoring.handle_signal	(		signum,
			frame
	)

Definition at line 452 of file esMonitoring.py.

def handle_signal(signum, frame):
    for proc in CURRENT_PROC:
        proc.send_signal(signum)

def esMonitoring.launch_monitoring

(

args

)

Definition at line 387 of file esMonitoring.py.

References log(), and str.

def launch_monitoring(args):
    es = ElasticReport(args=args)

    json_handler = FDJsonServer(es=es, args=args)
    env = os.environ.copy()
    env["DQM2_SOCKET"] = json_handler.fn 

    def preexec():
        try:
            # ensure the child dies if we are SIGKILLED
            import ctypes
            libc = ctypes.CDLL("libc.so.6")
            PR_SET_PDEATHSIG = 1
            libc.prctl(PR_SET_PDEATHSIG, signal.SIGKILL)
        except:
            log("Failed to setup PR_SET_PDEATHSIG.")
            pass

    p = subprocess.Popen(args.pargs, preexec_fn=preexec, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, close_fds=True, env=env)
    CURRENT_PROC.append(p)

    zlog = None
    if args.zlog:
        try:
            relpath = os.path.dirname(__file__)
            sys.path.append(relpath)
            from ztee import GZipLog
            
            zlog_ = GZipLog(log_file=args.zlog)
            es.update_doc({ "stdlog_gzip": args.zlog })

            log("Open gzip log file: %s" % args.zlog)
            zlog = zlog_
        except Exception as e:
            log("Failed to setup zlog file: " + str(e))

    es.update_doc({ "pid": p.pid })
    es.update_doc({ "monitoring_pid": os.getpid() })
    es.update_doc({ "monitoring_socket": json_handler.fn })
    es.defaults()
    es.make_report()

    log_handler = FDOutputListener(fd=p.stdout.fileno(), es=es, zlog=zlog, close_socket=json_handler)
    log_handler.handle_line("-- starting process: %s --\n" % str(args.pargs))

    try:
        #manager.event_loop(timeout=5, exit_fd=p.stdout.fileno())
        asyncore.loop(timeout=5)
    except select.error as e:
        # we have this on ctrl+c
        # just terminate the child
        log("Select error (we will terminate): " + str(e))
        p.terminate()

    # at this point the program is dead
    r =  p.wait()
    log_handler.handle_line("\n-- process exit: %s --\n" % str(r))
    log_handler.finish()

    es.update_doc({ "exit_code": r })
    es.make_report()

    CURRENT_PROC.remove(p)
    return r

def esMonitoring.log

(

s

)

Definition at line 11 of file esMonitoring.py.

Referenced by esMonitoring.FDJsonHandler.handle_line(), launch_monitoring(), and esMonitoring.ElasticReport.make_report().

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

Variable Documentation

esMonitoring.action

Definition at line 458 of file esMonitoring.py.

esMonitoring.args

Definition at line 462 of file esMonitoring.py.

esMonitoring.CURRENT_PROC

Definition at line 386 of file esMonitoring.py.

esMonitoring.default

Definition at line 459 of file esMonitoring.py.

esMonitoring.description

Definition at line 457 of file esMonitoring.py.

esMonitoring.help

Definition at line 458 of file esMonitoring.py.

esMonitoring.nargs

Definition at line 461 of file esMonitoring.py.

esMonitoring.None

Definition at line 459 of file esMonitoring.py.

esMonitoring.pargs

Definition at line 469 of file esMonitoring.py.

esMonitoring.parser

Definition at line 457 of file esMonitoring.py.

esMonitoring.str

Definition at line 459 of file esMonitoring.py.

Referenced by launch_monitoring(), and esMonitoring.ElasticReport.update_mem_status().

esMonitoring.type

Definition at line 459 of file esMonitoring.py.