|
@@ -289,13 +289,13 @@ class AgentOperService:
|
|
|
def check_agent_live_daemon(_members):
|
|
|
key = CENTER_AGENT_LIVE_CNT % SAAS_ID
|
|
|
pre_val = self.redis_handler.redis.get(key)
|
|
|
- self.logger.info('check_agent_live_daemon, members=%s, pre_val=%s', (len(_members) if _members else 0), pre_val)
|
|
|
if not pre_val:
|
|
|
if not _members or len(_members) == 0:
|
|
|
value = datetime.now().timestamp()
|
|
|
self.redis_handler.redis.set(key, value, ex=60*60, nx=True)
|
|
|
else:
|
|
|
diff = datetime.now().timestamp() - float(pre_val)
|
|
|
+ self.logger.info('check_agent_live_daemon, members=%s, diff=%s, pre_val=%s', (len(_members) if _members else 0), diff, pre_val)
|
|
|
if diff > self.agent_serial_live_expire:
|
|
|
self.logger.warn('WARING::live agent count less than 1 serial ten minutes')
|
|
|
self.redis_handler.redis.delete(key)
|