added members and processor info to job

This commit is contained in:
Rafael.Timmerberg 2013-08-15 01:26:28 +02:00
commit 8cd39860ae
3 changed files with 4 additions and 3 deletions

View file

@ -14,9 +14,11 @@ def generateId():
class Job: class Job:
def __init__(self, service, host): def __init__(self, service, host, members, processors):
self.service = service self.service = service
self.host = host self.host = host
self.members = members
self.processors = processors
self.jobInfos = [] self.jobInfos = []
self.jobThreshold = 0 self.jobThreshold = 0

View file

@ -42,6 +42,5 @@ class TcpconnectService(Service):
jobInfo.set_message("Connection successful established to host: " + jobInfo.get_host() + " to port: " + str(self.port)) jobInfo.set_message("Connection successful established to host: " + jobInfo.get_host() + " to port: " + str(self.port))
sock.close() sock.close()
def create(kwargs): def create(kwargs):
return TcpconnectService(**kwargs) return TcpconnectService(**kwargs)

View file

@ -66,7 +66,7 @@ def main():
for service in hostgroup.get_services(): for service in hostgroup.get_services():
for host in hostgroup.get_hosts(): for host in hostgroup.get_hosts():
for period in service.get_periods(): for period in service.get_periods():
job = Job(service, host) job = Job(service, host, hostgroup.get_members(), hostgroup.get_processors())
schedulerJob = period.createJob(scheduler, job, handleJob) schedulerJob = period.createJob(scheduler, job, handleJob)
if schedulerJob is not None: if schedulerJob is not None:
job.set_job(schedulerJob) job.set_job(schedulerJob)