chore: null-terminate perf commands

Author: not-matthias

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

@@ -96,28 +96,28 @@ impl PerfFifo {
     }
 
     pub async fn start_events(&mut self) -> anyhow::Result<()> {
-        self.ctl_fifo.write_all(b"enable\n").await?;
+        self.ctl_fifo.write_all(b"enable\n\0").await?;
         self.wait_for_ack().await;
 
         Ok(())
     }
 
     pub async fn stop_events(&mut self) -> anyhow::Result<()> {
-        self.ctl_fifo.write_all(b"disable\n").await?;
+        self.ctl_fifo.write_all(b"disable\n\0").await?;
         self.wait_for_ack().await;
 
         Ok(())
     }
 
     pub async fn ping(&mut self) -> anyhow::Result<()> {
-        self.ctl_fifo.write_all(b"ping\n").await?;
+        self.ctl_fifo.write_all(b"ping\n\0").await?;
         self.wait_for_ack().await;
 
         Ok(())
     }
 
     async fn wait_for_ack(&mut self) {
-        const ACK: &[u8] = b"ack\n\x00";
+        const ACK: &[u8] = b"ack\n\0";
 
         loop {
             let mut buf: [u8; ACK.len()] = [0; ACK.len()];

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

@@ -193,7 +193,7 @@ impl PerfRunner {
         let mut integration = None;
 
         loop {
-            let perf_ping = tokio::time::timeout(Duration::from_secs(1), perf_fifo.ping()).await;
+            let perf_ping = tokio::time::timeout(Duration::from_secs(15), perf_fifo.ping()).await;
             if let Ok(Err(_)) | Err(_) = perf_ping {
                 error!("Perf timeout");
                 break;