From af093c8f39497e6974264889a3ad22da1539b30c Mon Sep 17 00:00:00 2001 From: "Rafael.Timmerberg" Date: Thu, 20 Jun 2013 00:26:07 +0200 Subject: [PATCH] added pointer for hostgroup in service --- lib/config/parser.py | 5 ++++- linspector | 20 +++++++++++++++----- 2 files changed, 19 insertions(+), 6 deletions(-) diff --git a/lib/config/parser.py b/lib/config/parser.py index d2b9da7..7af45b1 100644 --- a/lib/config/parser.py +++ b/lib/config/parser.py @@ -254,5 +254,8 @@ class FullConfigParser(ConfigParser): for hg in hostgroups: for service in hg.get_services(): service.set_hostgroup(hg) + core = None + if "core" in self.jsonDict: + core = self.jsonDict["core"] - return layouts \ No newline at end of file + return (layouts, core) \ No newline at end of file diff --git a/linspector b/linspector index c1f7f50..4aea47f 100755 --- a/linspector +++ b/linspector @@ -12,6 +12,7 @@ from lib.core.logger import Logger from lib.config.parser import FullConfigParser from apscheduler.scheduler import Scheduler +log = None def parseArgs(): parser = argparse.ArgumentParser( @@ -43,7 +44,7 @@ def parseArgs(): def handleJob(jobInfo): - jobInfo.handleCall() + log.w(jobInfo) def main(): @@ -54,11 +55,20 @@ def main(): if args.action == "start": configParser = FullConfigParser(log) - config = configParser.parse_config(args.config) + layouts, core = configParser.parse_config(args.config) - #jobs = [] - #scheduler = Scheduler() - #scheduler.start() + scheduler = Scheduler() + + + jobs = [] + for layout in layouts: + if layout.is_enabled(): + for hg in layout.get_hostgroups(): + for services in hg.get_services(): + for service in services: + for period in service.get_periods(): + jobs.append(period.createJob(scheduler, service, handleJob)) + scheduler.start() #log.i("starting linspector: reading config... (" + args.config + ")") #config_parser = ConfigParser(log)