fix: refine codes

Author: halajohn

core/src/ten_manager/src/fs/file_watcher.rs

@@ -184,7 +184,10 @@ async fn watch_file_task(
     loop {
         // Wait for stop or the next check interval.
         tokio::select! {
-            _ = &mut stop_rx => break,
+            _ = &mut stop_rx => {
+                eprintln!("Stopping file watcher");
+                break;
+            },
             _ = tokio::time::sleep(options.check_interval) => {
                 // Check if the file has been rotated or truncated.
                 match std::fs::metadata(&path) {
@@ -217,6 +220,7 @@ async fn watch_file_task(
                 if curr_len > last_pos {
                     // Read the new part.
                     if let Err(e) = file.seek(SeekFrom::Start(last_pos)) {
+                        eprintln!("Error seeking to position: {}", e);
                         let _ = content_tx.send(Err(anyhow::anyhow!(e))).await;
                         break;
                     }
@@ -231,13 +235,15 @@ async fn watch_file_task(
                         }
                         Ok(_) => {}
                         Err(e) => {
+                            eprintln!("Error reading from file: {}", e);
                             let _ = content_tx.send(Err(anyhow::anyhow!(e))).await;
                             break;
                         }
                     }
                 } else {
                     // Reached EOF, check if the timeout has been reached.
                     if Instant::now().duration_since(last_activity) > options.timeout {
+                        eprintln!("Timeout reached, breaking");
                         break;
                     }
                 }

core/src/ten_manager/tests/test_case/fs/mod.rs

@@ -60,6 +60,7 @@ mod tests {
             }
 
             // Stop watching.
+            println!("Stopping stream");
             stream.stop();
 
             Ok(())