|
|
@@ -520,14 +520,14 @@ class BotAgent:
|
|
|
self.cache = Cache(app)
|
|
|
self.dataHandleServer = DataHandleServer(app)
|
|
|
self.pjsua_thread = None
|
|
|
- self.start()
|
|
|
+ self._start()
|
|
|
# threading.Thread(target=self.main_thread_daemon).start()
|
|
|
|
|
|
self.daemon_job_scheduler = BackgroundScheduler()
|
|
|
- self.daemon_job_scheduler.add_job(self.main_thread_daemon, 'interval', seconds=1, max_instances=1, name='bot_agent_daemon')
|
|
|
+ self.daemon_job_scheduler.add_job(self._main_thread_daemon, 'interval', seconds=1, max_instances=1, name='bot_agent_daemon')
|
|
|
self.daemon_job_scheduler.start()
|
|
|
|
|
|
- def create_pjsua2(self, timeout_sec=86400):
|
|
|
+ def _create_pjsua2(self, timeout_sec=86400):
|
|
|
start_time = time.time()
|
|
|
try:
|
|
|
self.cache.set_register_per_hours(expire=timeout_sec - (60*3))
|
|
|
@@ -605,7 +605,7 @@ class BotAgent:
|
|
|
self.logger.info("create pjsua already shutdown")
|
|
|
|
|
|
|
|
|
- def main_thread_daemon(self):
|
|
|
+ def _main_thread_daemon(self):
|
|
|
# while not self.daemon_stopping:
|
|
|
_lock = self._play_complete_degree_check()
|
|
|
if _lock:
|
|
|
@@ -719,17 +719,17 @@ class BotAgent:
|
|
|
self.user_part_pool.put(user_part)
|
|
|
self.logger.info("release, user_part :%d, pool.size :%d", user_part, self.user_part_pool.qsize())
|
|
|
|
|
|
- def start(self):
|
|
|
+ def _start(self):
|
|
|
self.is_stopping = False
|
|
|
self.counter += 1
|
|
|
- self.pjsua_thread = threading.Thread(name=f"PJSUA-THREAD-{self.counter}", target=self.create_pjsua2, daemon=True)
|
|
|
+ self.pjsua_thread = threading.Thread(name=f"PJSUA-THREAD-{self.counter}", target=self._create_pjsua2, daemon=True)
|
|
|
self.pjsua_thread.start()
|
|
|
self.logger.info("bot agent starting ...")
|
|
|
|
|
|
def restart(self):
|
|
|
self.destroy()
|
|
|
self.logger.info('restart, 22222')
|
|
|
- self.start()
|
|
|
+ self._start()
|
|
|
# threading.Thread(target=self.create_pjsua2, daemon=True).start()
|
|
|
|
|
|
def destroy(self):
|
Davidliu