mi

Author: e1732a364fed

crates/ruci-cmd/src/lib.rs

@@ -694,6 +694,9 @@ fn log_setup(args: Args) -> Option<tracing_appender::non_blocking::WorkerGuard>
 
     debug!("possible out maps: {}", all_possible_out_maps.join(", "));
 
+    info!("Running With Mode: {:?}", args.mode);
+    info!("Engine Config file is: {}", args.config);
+
     guard
 }
 

crates/ruci-cmd/src/mode/chain/mod.rs

@@ -19,12 +19,9 @@ pub async fn get_config_file(
     let get_file_f = || -> anyhow::Result<_> {
         let r = data_source.get_file_content(Path::new(&file_name));
 
-        // if r.is_err() {
-        //     debug!("get file err, will use default file name, err: {r:?}");
-        //     r = data_source.get_file_content(Path::new(DEFAULT_LUA_CONFIG_FILE_NAME));
-        // }
-
-        r.context("get_config_file data_source.get_file_content failed")
+        r.context(format!(
+            "get_config_file data_source.get_file_content failed, file_name: {file_name}"
+        ))
     };
 
     //获取到文件的 bytes, 或通过下载 或读取文件. 若 in_memory 给出则下载的文件不持久化

rucimp/src/modes/chain/engine.rs

@@ -257,6 +257,7 @@ impl Engine {
         Ok(hv)
     }
 
+    /// the real function to run the proxy progress.
     pub async fn start_with_tasks(
         &self,
     ) -> anyhow::Result<
@@ -303,7 +304,7 @@ impl Engine {
             );
             index += 1;
 
-            let t2 = Engine::loop_in_to_out(
+            let t2 = Engine::loop_relay(
                 self.global_data.clone(),
                 out_rx,
                 out_selector.clone(),
@@ -322,7 +323,7 @@ impl Engine {
         Ok(tasks)
     }
 
-    async fn loop_in_to_out(
+    async fn loop_relay(
         global_data: GlobalData,
 
         mut rx: Receiver<fold::FoldResult>,