From c4b1c51e9e745f32037e04c3ae17fd4a6f0799a5 Mon Sep 17 00:00:00 2001
From: Kingtous <kingtous@qq.com>
Date: Tue, 7 Feb 2023 19:33:58 +0800
Subject: [PATCH] opt: more debug info

---
 flutter/lib/main.dart    | 4 +---
 src/flutter.rs           | 4 +++-
 src/server/connection.rs | 5 +++--
 3 files changed, 7 insertions(+), 6 deletions(-)

diff --git a/flutter/lib/main.dart b/flutter/lib/main.dart
index b923a31e1..c61287d4f 100644
--- a/flutter/lib/main.dart
+++ b/flutter/lib/main.dart
@@ -114,9 +114,6 @@ Future<void> initEnv(String appType) async {
   _registerEventHandler();
   // Update the system theme.
   updateSystemWindowTheme();
-  if (appType == kAppTypeConnectionManager) {
-    await bind.cmStartListenIpcThread();
-  }
 }
 
 void runMainApp(bool startService) async {
@@ -219,6 +216,7 @@ void runMultiWindow(
 
 void runConnectionManagerScreen(bool hide) async {
   await initEnv(kAppTypeConnectionManager);
+  await bind.cmStartListenIpcThread();
   _runApp(
     '',
     const DesktopServerPage(),
diff --git a/src/flutter.rs b/src/flutter.rs
index a27a9d4e1..2d7d3fb86 100644
--- a/src/flutter.rs
+++ b/src/flutter.rs
@@ -549,9 +549,11 @@ pub mod connection_manager {
             let mut h: HashMap<&str, &str> = event.iter().cloned().collect();
             assert!(h.get("name").is_none());
             h.insert("name", name);
-
+        
             if let Some(s) = GLOBAL_EVENT_STREAM.read().unwrap().get(super::APP_TYPE_CM) {
                 s.add(serde_json::ser::to_string(&h).unwrap_or("".to_owned()));
+            } else {
+                println!("Push event {} failed. No {} event stream found.", name, super::APP_TYPE_CM);
             };
         }
     }
diff --git a/src/server/connection.rs b/src/server/connection.rs
index 17417cf61..a8849b4e6 100644
--- a/src/server/connection.rs
+++ b/src/server/connection.rs
@@ -401,10 +401,11 @@ impl Connection {
                             conn.handle_voice_call(accepted).await;
                         }
                         ipc::Data::CloseVoiceCall(_reason) => {
+                            log::debug!("Close the voice call from the ipc.");
                             conn.close_voice_call().await;
                             // Notify the peer that we closed the voice call.
-                            let req = new_voice_call_request(false);
-                            conn.send(req).await;
+                            let msg = new_voice_call_request(false);
+                            conn.send(msg).await;
                         }
                         _ => {}
                     }