just added some sleep stuff but commented it out... testing only
This commit is contained in:
parent
74fff9ce35
commit
9824afb8a5
1 changed files with 6 additions and 2 deletions
|
|
@ -28,6 +28,7 @@ import logging
|
||||||
import logging.handlers
|
import logging.handlers
|
||||||
import os
|
import os
|
||||||
import os.path as path
|
import os.path as path
|
||||||
|
import time
|
||||||
|
|
||||||
from linspector.core.interface import LinspectorInterface
|
from linspector.core.interface import LinspectorInterface
|
||||||
from linspector.config.parser import FullConfigParser
|
from linspector.config.parser import FullConfigParser
|
||||||
|
|
@ -70,9 +71,9 @@ def setup_logging(logfile="./log/linspector.log", logLevel=logging.ERROR, logfil
|
||||||
if not path.exists(path.dirname(logfile)):
|
if not path.exists(path.dirname(logfile)):
|
||||||
os.makedirs(path.dirname(logfile))
|
os.makedirs(path.dirname(logfile))
|
||||||
|
|
||||||
#logging.basicConfig(level=logging.WARNING)
|
logging.basicConfig(level=logging.WARNING)
|
||||||
log = logging.getLogger(__name__)
|
log = logging.getLogger(__name__)
|
||||||
log.setLevel(logging.DEBUG)
|
#log.setLevel(logging.DEBUG)
|
||||||
|
|
||||||
consoleHandler = logging.StreamHandler()
|
consoleHandler = logging.StreamHandler()
|
||||||
consoleHandler.setLevel(logLevel)
|
consoleHandler.setLevel(logLevel)
|
||||||
|
|
@ -113,9 +114,12 @@ def main():
|
||||||
|
|
||||||
for layout in linConf.get_enabled_layouts():
|
for layout in linConf.get_enabled_layouts():
|
||||||
for hostgroup in layout.get_hostgroups():
|
for hostgroup in layout.get_hostgroups():
|
||||||
|
#time.sleep(1)
|
||||||
for service in hostgroup.get_services():
|
for service in hostgroup.get_services():
|
||||||
for host in hostgroup.get_hosts():
|
for host in hostgroup.get_hosts():
|
||||||
|
#time.sleep(0.5)
|
||||||
for period in service.get_periods():
|
for period in service.get_periods():
|
||||||
|
#time.sleep(0.1)
|
||||||
job = Job(service, host, hostgroup.get_members(), hostgroup.get_processors(), core, hostgroup)
|
job = Job(service, host, hostgroup.get_members(), hostgroup.get_processors(), core, hostgroup)
|
||||||
schedulerJob = period.createJob(scheduler, job, handle_job)
|
schedulerJob = period.createJob(scheduler, job, handle_job)
|
||||||
if schedulerJob is not None:
|
if schedulerJob is not None:
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue