fix: abort output listener task during VM cleanup to prevent hangs

src/commands/common.rs

@@ -290,6 +290,7 @@ pub async fn cleanup_vm(
     data_dir: &Path,
     health_cancel_token: Option<tokio_util::sync::CancellationToken>,
     health_monitor_handle: Option<JoinHandle<()>>,
+    output_listener_handle: Option<JoinHandle<Vec<(String, String)>>>,
 ) {
     info!("cleaning up resources");
 
@@ -306,6 +307,11 @@ pub async fn cleanup_vm(
         }
     }
 
+    // Abort output listener task if still running
+    if let Some(handle) = output_listener_handle {
+        handle.abort();
+    }
+
     // Cancel VolumeServer tasks
     for handle in volume_server_handles {
         handle.abort();

src/commands/podman.rs

@@ -1430,7 +1430,7 @@ async fn cmd_podman_run(args: RunArgs) -> Result<()> {
     };
 
     // For non-TTY mode, use async output listener
-    let _output_handle = if !tty_mode {
+    let output_handle = if !tty_mode {
         let socket_path = output_socket_path.clone();
         let vm_id_clone = vm_id.clone();
         Some(tokio::spawn(async move {
@@ -1642,6 +1642,7 @@ async fn cmd_podman_run(args: RunArgs) -> Result<()> {
         &data_dir,
         Some(health_cancel_token),
         Some(health_monitor_handle),
+        output_handle, // abort output listener task
     )
     .await;
 

src/commands/snapshot.rs

@@ -598,7 +598,7 @@ pub async fn cmd_snapshot_run(args: SnapshotRunArgs) -> Result<()> {
     };
 
     // For non-TTY mode, use async output listener
-    let _output_handle = if !tty_mode {
+    let output_handle = if !tty_mode {
         let socket_path = output_socket_path.clone();
         let vm_id_clone = vm_id.clone();
         Some(tokio::spawn(async move {
@@ -839,6 +839,7 @@ pub async fn cmd_snapshot_run(args: SnapshotRunArgs) -> Result<()> {
             &data_dir,
             None, // no health monitor in exec path
             None,
+            output_handle, // abort output listener task
         )
         .await;
 
@@ -964,6 +965,7 @@ pub async fn cmd_snapshot_run(args: SnapshotRunArgs) -> Result<()> {
         &data_dir,
         Some(health_cancel_token),
         Some(health_monitor_handle),
+        output_handle, // abort output listener task
     )
     .await;