summaryrefslogtreecommitdiff
path: root/crates/vcs_actions/src/connection
diff options
context:
space:
mode:
author魏曹先生 <1992414357@qq.com>2025-12-24 16:12:46 +0800
committer魏曹先生 <1992414357@qq.com>2025-12-24 16:12:46 +0800
commitca29e7b2152260059417c142641cd19ddbb512c4 (patch)
tree8927915b3cc5229e6cd503e886de33e596d5814c /crates/vcs_actions/src/connection
parent4cccc5d093bed8abbe35689c061486b79c44c558 (diff)
Add local output channel for CLI feedback in track actions
Add `try_get_local_output` helper to retrieve output channel from context and `local_println!` macro for sending formatted strings. Use these in track actions to send progress messages to CLI instead of stdout. Also reduce log level for connection events from info to debug.
Diffstat (limited to 'crates/vcs_actions/src/connection')
-rw-r--r--crates/vcs_actions/src/connection/action_service.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/crates/vcs_actions/src/connection/action_service.rs b/crates/vcs_actions/src/connection/action_service.rs
index a736ed8..f137126 100644
--- a/crates/vcs_actions/src/connection/action_service.rs
+++ b/crates/vcs_actions/src/connection/action_service.rs
@@ -8,7 +8,7 @@ use std::{
use action_system::{action::ActionContext, action_pool::ActionPool};
use cfg_file::config::ConfigFile;
-use log::{error, info, warn};
+use log::{debug, error, info, warn};
use tcp_connection::{error::TcpTargetError, instance::ConnectionInstance};
use tokio::{
net::{TcpListener, TcpStream},
@@ -134,7 +134,7 @@ fn build_server_future(
accept_result = listener.accept(), if !shutdown_requested => {
match accept_result {
Ok((stream, _addr)) => {
- info!("New connection. (now {})", active_connections);
+ debug!("New connection. (now {})", active_connections);
let _ = tx.send(1).await;
let vault_clone = vault.clone();
@@ -143,7 +143,7 @@ fn build_server_future(
spawn(async move {
process_connection(stream, vault_clone, action_pool_clone).await;
- info!("A connection closed. (now {})", active_connections);
+ debug!("A connection closed. (now {})", active_connections);
let _ = tx_clone.send(-1).await;
});
}