From ae91b62332b338665e11e3bdf0f8d77fb16c3988 Mon Sep 17 00:00:00 2001 From: CakeCN Date: Thu, 11 Dec 2025 15:02:33 +0800 Subject: [PATCH] logger time --- Html/apps/extension_ase/ase_client/client.py | 16 +++++----------- 1 file changed, 5 insertions(+), 11 deletions(-) diff --git a/Html/apps/extension_ase/ase_client/client.py b/Html/apps/extension_ase/ase_client/client.py index 2cc6f9e..1e23ba7 100644 --- a/Html/apps/extension_ase/ase_client/client.py +++ b/Html/apps/extension_ase/ase_client/client.py @@ -433,17 +433,20 @@ class HSAEngineClient(ASEngineClient): super().__init__(server_url, namespace, id) self.chatmanager = chatmanager def loadmarkdown(self, fmd, fmdp, fsp): + now = time.time() # 并行发送三个消息，获取事件对象和ack_id event1, ack_id1 = self.send_text('markdown-in', fmd, self.id, wait_for_ack=True, return_event=True) event2, ack_id2 = self.send_text('markdown-prompt-in', fmdp, self.id, wait_for_ack=True, return_event=True) event3, ack_id3 = self.send_text('score-prompt-in', fsp, self.id, wait_for_ack=True, return_event=True) - + self.chatmanager.app.logger.info(f"Load markdown time cost: {time.time() - now}") + now = time.time() # 等待所有事件完成 timeout = 5 # 超时时间 success1 = event1.wait(timeout=timeout) success2 = event2.wait(timeout=timeout) success3 = event3.wait(timeout=timeout) - + self.chatmanager.app.logger.info(f"Wait markdown time cost: {time.time() - now}") + now = time.time() # 清理ACK事件 if ack_id1 in self.ack_events: del self.ack_events[ack_id1] @@ -451,13 +454,4 @@ class HSAEngineClient(ASEngineClient): del self.ack_events[ack_id2] if ack_id3 in self.ack_events: del self.ack_events[ack_id3] - - # 检查是否所有ACK都成功收到 - if not success1: - print(f"ACK timeout for message: {ack_id1}") - if not success2: - print(f"ACK timeout for message: {ack_id2}") - if not success3: - print(f"ACK timeout for message: {ack_id3}") - return success1 and success2 and success3