From 16a37c713a6946d4919e17ef7eadd3650b858bb9 Mon Sep 17 00:00:00 2001 From: lubeilin <1791778603@qq.com> Date: Fri, 22 Sep 2023 18:18:29 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- vnt-cli/src/command/server.rs | 8 ++++++-- vnt-cli/src/main.rs | 1 + 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/vnt-cli/src/command/server.rs b/vnt-cli/src/command/server.rs index 94e6946..2de1089 100644 --- a/vnt-cli/src/command/server.rs +++ b/vnt-cli/src/command/server.rs @@ -17,15 +17,19 @@ impl CommandServer { let udp = UdpSocket::bind("127.0.0.1:0").await?; let path_buf = crate::app_home()?.join("command-port"); let mut file = std::fs::File::create(path_buf)?; - file.write_all(udp.local_addr()?.port().to_string().as_bytes())?; + let addr = udp.local_addr()?; + file.write_all(addr.port().to_string().as_bytes())?; file.sync_all()?; + log::info!("启动后台cmd:{:?}", addr); let mut buf = [0u8; 64]; loop { let (len, addr) = udp.recv_from(&mut buf).await?; match std::str::from_utf8(&buf[..len]) { Ok(cmd) => { if let Ok(out) = command(cmd, &vnt) { - let _ = udp.send_to(out.as_bytes(), addr).await; + if let Err(e) = udp.send_to(out.as_bytes(), addr).await { + log::warn!("cmd={},err={:?}", cmd, e); + } if "stopped" == &out { break; } diff --git a/vnt-cli/src/main.rs b/vnt-cli/src/main.rs index 4049c0d..b875091 100644 --- a/vnt-cli/src/main.rs +++ b/vnt-cli/src/main.rs @@ -362,6 +362,7 @@ async fn main0(config: Config, show_cmd: bool) { let vnt_c = vnt.clone(); tokio::spawn(async { if let Err(e) = command::server::CommandServer::new().start(vnt_c).await { + log::warn!("cmd:{:?}", e); println!("command error :{}", e); } });