BugFix: 连接wwise失败造成卡死

szz1031 · Apr 21, 2023 · 2010a25 · 2010a25
1 parent b210f7c
commit 2010a25
Show file tree

Hide file tree

Showing 2 changed files with 31 additions and 11 deletions.
diff --git a/SourceCode_CN/ReplaceWwiseWavesWithP4.py b/SourceCode_CN/ReplaceWwiseWavesWithP4.py
@@ -98,7 +98,7 @@ class GUI(QMainWindow):
     def __init__(self):
         super(GUI, self).__init__()
         self.p4 = p4Manager()
-        self.setWindowTitle("ReplaceWwiseWavesWithP4 @SZZ    Version: 2.1  2023.04.14")
+        self.setWindowTitle("ReplaceWwiseWavesWithP4 @SZZ    Version: 2.2  2023.04.21")
         self.setGeometry(100, 100, 880, 600)
         self.setStyleSheet("""
         QWidget {
@@ -135,7 +135,7 @@ def __init__(self):
         }
         """)
         self.initUI()
-        self.connectWwise()
+        #self.connectWwise()
         self.load_p4_config()
 
     def load_p4_config(self):
@@ -179,7 +179,7 @@ def initUI(self):
         bold_font.setPointSize(13)
 
         font2 = QFont()
-        font2.setPointSize(10)
+        font2.setPointSize(8)
 
         button0 = QPushButton("连接到 Wwise", self)
         button0.clicked.connect(self.connectWwise)

diff --git a/SourceCode_CN/szz_wwiseManager.py b/SourceCode_CN/szz_wwiseManager.py
@@ -1,6 +1,8 @@
 from waapi import WaapiClient
 import os
 from pprint import pprint
+from concurrent.futures import ThreadPoolExecutor, wait
+import asyncio
 
 class WwiseManager:
 
@@ -25,17 +27,35 @@ class WwiseManager:
 
     myUrl=""
 
+    def try_connect_waapi(self):
+        loop = asyncio.new_event_loop()
+        asyncio.set_event_loop(loop)
+        try:
+            with WaapiClient(url=self.myUrl) as client:
+                client.call("ak.soundengine.postMsgMonitor", self._msgToArgs("Waapi Connect Success"))
+                return True
+        except Exception as e:
+            print(f"Error connecting to Wwise: {e}")
+            return False
+
     def __init__(self,in_portId='8070'):
         self.myUrl= "ws://127.0.0.1:"+in_portId+"/waapi" # WAMP port 
         self._lastSelectedObject=self.defaultSelectedObject
-        try:
-            with WaapiClient(url=self.myUrl) as client:             
-                client.call("ak.soundengine.postMsgMonitor",self._msgToArgs("Waapi Connect Success"))
-        except:
-            return
-        self._getWwiseInfo()
-        self._getWwiseProjectInfo()
-
+        timeout = 5  # 设置超时时间，单位为秒
+
+        with ThreadPoolExecutor(max_workers=1) as executor:
+            future = executor.submit(self.try_connect_waapi)
+            done, not_done = wait([future], timeout=timeout)
+
+            if future in done:
+                if future.result():
+                    self._getWwiseInfo()
+                    self._getWwiseProjectInfo()
+                else:
+                    return
+            else:
+                print("Connection to Wwise timed out.")
+                return
 
 
     def _msgToArgs(self,msg): #在wwise里打log的格式转换