|
|
@ -69,7 +69,7 @@ class ICollector(Thread) :
|
|
|
|
def run(self):
|
|
|
|
def run(self):
|
|
|
|
write_class = self.config['store']['class']['write']
|
|
|
|
write_class = self.config['store']['class']['write']
|
|
|
|
read_args = self.config['store']['args']
|
|
|
|
read_args = self.config['store']['args']
|
|
|
|
|
|
|
|
DELAY = self.config['delay'] * 60
|
|
|
|
while self.quit == False:
|
|
|
|
while self.quit == False:
|
|
|
|
|
|
|
|
|
|
|
|
for thread in self.pool :
|
|
|
|
for thread in self.pool :
|
|
|
@ -92,7 +92,7 @@ class ICollector(Thread) :
|
|
|
|
if 'MONITOR_CONFIG_PATH' in os.environ :
|
|
|
|
if 'MONITOR_CONFIG_PATH' in os.environ :
|
|
|
|
break
|
|
|
|
break
|
|
|
|
print '\t *** ',str(datetime.today()),' ** '
|
|
|
|
print '\t *** ',str(datetime.today()),' ** '
|
|
|
|
time.sleep(self.DELAY)
|
|
|
|
time.sleep(DELAY)
|
|
|
|
|
|
|
|
|
|
|
|
print ' *** Exiting ',self.name
|
|
|
|
print ' *** Exiting ',self.name
|
|
|
|
# read_class=self.config['class']['read']
|
|
|
|
# read_class=self.config['class']['read']
|
|
|
|