fix: break when parsing invalid command

Author: not-matthias

src/run/runner/wall_time/perf/fifo.rs

@@ -1,4 +1,5 @@
 use super::FifoCommand;
+use anyhow::Context;
 use runner_shared::fifo::{RUNNER_ACK_FIFO, RUNNER_CTL_FIFO};
 use std::path::PathBuf;
 use tokio::io::{AsyncReadExt, AsyncWriteExt};
@@ -52,7 +53,9 @@ impl RunnerFifo {
             }
         }
 
-        let decoded = bincode::deserialize(&buffer)?;
+        let decoded = bincode::deserialize(&buffer).with_context(|| {
+            format!("Failed to deserialize FIFO command (len: {message_len}, data: {buffer:?})")
+        })?;
         Ok(decoded)
     }
 

src/run/runner/wall_time/perf/mod.rs

@@ -296,8 +296,13 @@ impl PerfRunner {
             perf_ping_timeout = 1;
 
             let result = tokio::time::timeout(Duration::from_secs(5), runner_fifo.recv_cmd()).await;
-            let Ok(Ok(cmd)) = result else {
-                continue;
+            let cmd = match result {
+                Ok(Ok(cmd)) => cmd,
+                Ok(Err(e)) => {
+                    warn!("Failed to parse FIFO command: {e}");
+                    break;
+                }
+                Err(_) => continue,
             };
             debug!("Received command: {cmd:?}");