#!/bin/env python
# coding:utf-8
from multiprocessing import Process
import include.functions as func
import os
import sys
import string
import time
import datetime
import logging
import logging.config

log_file_path = os.path.join(os.path.dirname(os.path.abspath(__file__)), 'etc/logger.ini')
logging.config.fileConfig(log_file_path)
logger = logging.getLogger("lepus")
path = './include'
sys.path.insert(0, path)


def job_run(script_name, times):
    while True:
        os.system("python "+script_name+".py")
        time.sleep(int(times))


def main():
    logger.info("lepus controller start.")
    monitor = str(func.get_option('monitor'))
    monitor_mysql = str(func.get_option('monitor_mysql'))
    monitor_oracle = str(func.get_option('monitor_oracle'))
    monitor_os = str(func.get_option('monitor_os'))
    alarm = str(func.get_option('alarm'))
    frequency_monitor = func.get_option('frequency_monitor')
    frequency_monitor_alarm = int(frequency_monitor)+10

    joblist = []
    if monitor == "1":
        if monitor_mysql == "1":
            job = Process(target=job_run, args=(
                'check_mysql', frequency_monitor))
            joblist.append(job)
            job.start()
        time.sleep(3)
        if monitor_oracle == "1":
            job = Process(target=job_run, args=(
                'check_oracle', frequency_monitor))
            joblist.append(job)
            job.start()
        time.sleep(3)
        if monitor_os == "1":
            job = Process(target=job_run, args=('check_os', frequency_monitor))
            joblist.append(job)
            job.start()
        time.sleep(3)
        if alarm == "1":
            job = Process(target=job_run, args=(
                'alarm', frequency_monitor_alarm))
            joblist.append(job)
            job.start()
        for job in joblist:
            job.join()

    logger.info("lepus controller finished.")


if __name__ == '__main__':
    main()