debug

src/core/voip/bot.py

@@ -1,5 +1,6 @@
 #!/usr/bin/env python3
 # encoding:utf-8
+import ctypes
 import os
 import time
 import json
@@ -532,7 +533,7 @@ class BotAgent:
         self.acd_service = None
         self.cache = Cache(app)
         self.dataHandleServer = DataHandleServer(app)
-        self.process = None
+        self.pjsua_thread = None
         self.start()
         # threading.Thread(name="PJSUA-THREAD", target=self.create_pjsua2, daemon=True).start()
 
@@ -695,16 +696,13 @@ class BotAgent:
         self.logger.info("release, user_part :%d, pool.size :%d", user_part, self.user_part_pool.qsize())
 
     def start(self):
-        self.process = Process(name="PJSUA-THREAD", target=self.create_pjsua2, daemon=True)
-        self.process.start()
+        self.is_stopping = False
+        self.pjsua_thread = threading.Thread(name="PJSUA-THREAD", target=self.create_pjsua2, daemon=True)
+        self.pjsua_thread.start()
         self.logger.info("bot agent starting ...")
 
     def restart(self):
         self.destroy()
-        self.is_stopping = False
-        self.process.kill()
-        self.logger.info('restart, 11111')
-        self.process.join()
         self.logger.info('restart, 22222')
         self.start()
         # threading.Thread(target=self.create_pjsua2, daemon=True).start()
@@ -721,6 +719,22 @@ class BotAgent:
         # Destroy the library
         self.ep.libDestroy()
 
+        if not self.pjsua_thread.is_alive():
+            return
+        ident = self.pjsua_thread.ident
+        thread_id = ctypes.pythonapi.PyThreadState_SetAsyncExc
+        res = ctypes.pythonapi.PyThreadState_SetAsyncExc(
+            ctypes.c_long(ident), ctypes.py_object(SystemExit)
+        )
+        self.logger.info("destroy, ident=%s, thread_id=%s, res=%s", ident, thread_id, res)
+        # if res == 0:
+        #     raise ValueError("Invalid thread ID")
+        # elif res > 1:
+        #     # 如果多次调用，需要复位
+        #     ctypes.pythonapi.PyThreadState_SetAsyncExc(ident, 0)
+        #     raise SystemError("PyThreadState_SetAsyncExc failed")
+
+
     def __del__(self):
         self.destroy()