Fixing a race condition in synchronising the worker and main
Created by pmeunier yesterday at 01:03
ML5Y2THVDX7Z43RVTEI6KCTF2DHFJP5XKNYHVFJPJHDIBADBV5XQC Dependencies
In channels
main
Change contents
Replacement in api/src/replication.rs at line 438 [6.431834]
Replacement in api/src/replication.rs at line 449 [6.431834]
Replacement in api/src/replication.rs at line 477 [6.431834]
let (mut status_tx, _status_rx) = tokio::sync::watch::channel(None::<i32>);let (_kill_tx, mut kill_rx) = tokio::sync::oneshot::channel();for (script, s) in status.results.iter() {let mut cmd = tokio::process::Command::new("nix-store");cmd.arg("-r").arg(&s);let cmd = cmd.stderr(Stdio::piped()).stdout(Stdio::piped()).stdin(Stdio::null()).spawn().unwrap();ci::dump_cmd(cmd, &mut files, &mut kill_rx).await.unwrap();}for (script, s) in status.results.iter() {debug!("launching {:?} {:?}", s, script);let cmd = tokio::process::Command::new(format!("{}/bin/{script}", s.display())).stderr(Stdio::piped()).stdout(Stdio::piped()).stdin(Stdio::null()).spawn().unwrap();ci::dump_cmd(cmd, &mut files, &mut kill_rx).await.unwrap();if let Some(status) = status {let (mut status_tx, _status_rx) = tokio::sync::watch::channel(None::<i32>);let (_kill_tx, mut kill_rx) = tokio::sync::oneshot::channel();for (script, s) in status.results.iter() {let mut cmd = tokio::process::Command::new("nix-store");cmd.arg("-r").arg(&s);let cmd = cmd.stderr(Stdio::piped()).stdout(Stdio::piped()).stdin(Stdio::null()).spawn().unwrap();ci::dump_cmd(cmd, &mut files, &mut kill_rx).await.unwrap();}for (script, s) in status.results.iter() {debug!("launching {:?} {:?}", s, script);let cmd = tokio::process::Command::new(format!("{}/bin/{script}", s.display())).stderr(Stdio::piped()).stdout(Stdio::piped()).stdin(Stdio::null()).spawn().unwrap();ci::dump_cmd(cmd, &mut files, &mut kill_rx).await.unwrap();}