From c8ece4c62b6f8b5165de4d9d38a467bbc1e94a53 Mon Sep 17 00:00:00 2001 From: "1992414357@qq.com" <1992414357@qq.com> Date: Mon, 9 Jun 2025 10:29:05 +0800 Subject: 修改了导出脚本 MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- core/src/service/cli_addition/runtime_consoles.rs | 10 +++++++--- core/src/service/tcp_network/pad_server/implements.rs | 2 +- 2 files changed, 8 insertions(+), 4 deletions(-) (limited to 'core/src/service') diff --git a/core/src/service/cli_addition/runtime_consoles.rs b/core/src/service/cli_addition/runtime_consoles.rs index 76ff20c..38d8404 100644 --- a/core/src/service/cli_addition/runtime_consoles.rs +++ b/core/src/service/cli_addition/runtime_consoles.rs @@ -1,6 +1,7 @@ use crate::service::cli_addition::utils::read_cli; use clap::{Command, FromArgMatches}; use std::sync::{Arc, Mutex}; +use log::info; use tokio::{join, spawn}; use crate::service::service_runner::NoGamepadsService; @@ -9,14 +10,14 @@ where Cmd: FromArgMatches { command: Command, prefix: String, service: Arc>, - process_command: fn(Arc>, Cmd), + process_command: fn(Arc>, Cmd) -> bool, } impl RuntimeConsole { pub fn build(command: Command, prefix: String, service: Arc>, - process_command: fn(Arc>, Cmd), + process_command: fn(Arc>, Cmd) -> bool, ) -> RuntimeConsole { RuntimeConsole { command, prefix, service, process_command } } @@ -52,9 +53,12 @@ impl RuntimeConsole

{} Some(cmd) => { - (self.process_command)(Arc::clone(&self.service), cmd); + if !(self.process_command)(Arc::clone(&self.service), cmd) { + break; + } } } } + info!("[Console] Shutdown.") } } \ No newline at end of file diff --git a/core/src/service/tcp_network/pad_server/implements.rs b/core/src/service/tcp_network/pad_server/implements.rs index c4d8cfc..d4288bf 100644 --- a/core/src/service/tcp_network/pad_server/implements.rs +++ b/core/src/service/tcp_network/pad_server/implements.rs @@ -5,7 +5,7 @@ use std::time::Duration; use log::{error, info, trace, warn}; use tokio::{join, select, spawn}; use tokio::net::{TcpListener, TcpStream}; -use tokio::sync::watch::{channel, Receiver, Sender}; +use tokio::sync::watch::{channel}; use tokio::time::sleep; use nogamepads::entry_mutex; use crate::data::game::runtime::structs::GameRuntime; -- cgit