{"header":{"message":"Removing locks when deploying","description":null,"timestamp":"2026-04-25T17:37:43.96035505Z","authors":[{}]},"hash":"W4LOGDLDBZIUUNACCXWWUZGVEGWAXYAZI3C66HYHURFQ3CWZ7XKAC","authors":[{"login":"pmeunier","key":"8ES6e1QmLjuQn1DzS2DQRKebzCKPHpdf4E9hfwMqQoe7"}],"deps":{"hashes":[["W4LOGDLDBZIUUNACCXWWUZGVEGWAXYAZI3C66HYHURFQ3CWZ7XKAC","Removing locks when deploying"],["AA",null],["YYJ76Q7V6G7FHSNZ25MU3ZZY5KGXIODBHLWOZUGB4FIKL7PUCNAAC","Initial attempt at CI/CD"],["OA6YWBAY6H6JSGD73NMYFREJOJPO42FW74F5BUKQKK6A2H4BXW6AC","create log files"],["NRBML6UEXH5QCDVL7M4DNEU6XZ72SUKYUIPUTYHEFDOLM3Z6MKCAC","Updating ssh + debug"],["D4SBRY6KHEAMGUEVWSUYHNCRYXCOC5JJ3N3DQ47ZXOXQGT73VERAC","Initial patch"]],"deps":["YYJ76Q7V6G7FHSNZ25MU3ZZY5KGXIODBHLWOZUGB4FIKL7PUCNAAC","OA6YWBAY6H6JSGD73NMYFREJOJPO42FW74F5BUKQKK6A2H4BXW6AC","NRBML6UEXH5QCDVL7M4DNEU6XZ72SUKYUIPUTYHEFDOLM3Z6MKCAC"],"known":["D4SBRY6KHEAMGUEVWSUYHNCRYXCOC5JJ3N3DQ47ZXOXQGT73VERAC"]},"hunks":[{"Replacement":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":152,"ins":{"up_context":[{"change":2,"pos":20400}],"down_context":[{"change":2,"pos":20859}],"flag":"BLOCK","start":0,"end":1528,"inode":{"change":5,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":20400},"to":{"change":2,"start":20400,"end":20859},"introduced_by":2}],"inode":{"change":5,"pos":431834}},"ins_contents":[{"Add":" if let Some((temp, depl)) = {"},{"Add":" let pri = repo_.pristine.blocking_write();"},{"Add":" let txn = pri.arc_txn_begin()?;"},{"Add":" let channel = format!(\"{}_{}\", repo, channel);"},{"Add":" let channel_ = {"},{"Add":" let mut txn_ = txn.write();"},{"Add":" txn_.open_or_create_channel(&channel)?"},{"Add":" };"},{"Add":" let changes = repo_.changes.clone();"},{"Add":""},{"Add":" s.output_for_deployment(&txn, &channel_, &changes)?"},{"Add":" } {"},{"Add":" tokio::spawn(async move {"},{"Add":" use crate::db::jobs::dsl as jobs;"},{"Add":" let id = diesel::insert_into(jobs::jobs)"},{"Add":" .values((jobs::repo.eq(repo),))"},{"Add":" .returning(jobs::id)"},{"Add":" .get_result::(&mut s.db.get().await.unwrap())"},{"Add":" .await"},{"Add":" .unwrap();"},{"Add":""},{"Add":" let permit = s.builders.acquire().await.unwrap();"},{"Add":" {"},{"Add":" s.deploy(id, temp, depl).await?;"},{"Add":" }"},{"Add":" std::mem::drop(permit);"},{"Add":" Ok::<_, Error>(())"},{"Add":" });"},{"Add":" }"}],"del_contents":[{"Del":" let pri = repo_.pristine.blocking_write();\n let txn = pri.arc_txn_begin()?;\n let channel = format!(\"{}_{}\", repo, channel);\n let channel_ = {\n let mut txn_ = txn.write();\n txn_.open_or_create_channel(&channel)?\n };\n s.deploy(&txn, &channel_, &repo_.changes, repo)?;\n"}]}},{"Replacement":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":329,"ins":{"up_context":[{"change":2,"pos":22273}],"down_context":[{"change":2,"pos":22288}],"flag":"BLOCK","start":1529,"end":1559,"inode":{"change":5,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":22273},"to":{"change":2,"start":22273,"end":22288},"introduced_by":2}],"inode":{"change":5,"pos":431834}},"ins_contents":[{"Add":" fn output_for_deployment<"}],"del_contents":[{"Del":" fn deploy<\n"}]}},{"Replacement":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":336,"ins":{"up_context":[{"change":2,"pos":22566}],"down_context":[{"change":2,"pos":22621}],"flag":"BLOCK","start":1560,"end":1622,"inode":{"change":5,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":22566},"to":{"change":2,"start":22566,"end":22621},"introduced_by":2}],"inode":{"change":5,"pos":431834}},"ins_contents":[{"Add":" ) -> Result, Error> {"}],"del_contents":[{"Del":" repo: uuid::Uuid,\n ) -> Result<(), Error> {\n"}]}},{"Edit":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":343,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":22870},"to":{"change":2,"start":22870,"end":22916},"introduced_by":2}],"inode":{"change":5,"pos":431834}}},"contents":[{"Del":" let db = self.db.clone();\n"}]}},{"Replacement":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":346,"ins":{"up_context":[{"change":2,"pos":23061}],"down_context":[{"change":2,"pos":23215}],"flag":"BLOCK","start":1623,"end":2095,"inode":{"change":5,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":23061},"to":{"change":2,"start":23061,"end":23215},"introduced_by":2}],"inode":{"change":5,"pos":431834}},"ins_contents":[{"Add":" let tmp_dir = tempfile::tempdir()?;"},{"Add":" let wc ="},{"Add":" libpijul::working_copy::filesystem::FileSystem::from_root(tmp_dir.path());"},{"Add":" libpijul::output::output_repository_no_pending("},{"Add":" &wc, &changes, &txn, &channel, \"\", true, None, 1, 0,"},{"Add":" )?;"},{"Add":" return Ok(Some((tmp_dir, depl)));"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" Ok(None)"},{"Add":" }"}],"del_contents":[{"Del":" let jobs = self.jobs.clone();\n let builders = self.builders.clone();\n let ci = self.ci.clone();\n"}]}},{"Replacement":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":359,"ins":{"up_context":[{"change":2,"pos":23216}],"down_context":[{"change":4,"pos":819}],"flag":"BLOCK","start":2096,"end":2494,"inode":{"change":5,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":23216},"to":{"change":2,"start":23216,"end":23650},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":23650},"to":{"change":4,"start":442,"end":516},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":516},"to":{"change":2,"start":23687,"end":23688},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":23687},"to":{"change":2,"start":23687,"end":23688},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":23688},"to":{"change":4,"start":517,"end":636},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":636},"to":{"change":2,"start":23748,"end":24271},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":23748},"to":{"change":2,"start":23748,"end":24271},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":24271},"to":{"change":4,"start":637,"end":706},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":706},"to":{"change":2,"start":24307,"end":24526},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":24307},"to":{"change":2,"start":24307,"end":24526},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":24526},"to":{"change":4,"start":707,"end":819},"introduced_by":4}],"inode":{"change":5,"pos":431834}},"ins_contents":[{"Add":" async fn deploy("},{"Add":" &self,"},{"Add":" id: uuid::Uuid,"},{"Add":" tmp_dir: tempfile::TempDir,"},{"Add":" depl: String,"},{"Add":" ) -> Result<(), Error> {"},{"Add":" use std::process::Stdio;"},{"Add":" let (status_tx, status_rx) = tokio::sync::watch::channel(None);"},{"Add":" let (kill_tx, kill_rx) = tokio::sync::oneshot::channel();"},{"Add":" let p = tmp_dir.path().join(depl);"},{"Add":" debug!(\"launching {:?}\", p);"}],"del_contents":[{"Del":" tokio::spawn(async move {\n let permit = builders.acquire().await.unwrap();\n use crate::db::jobs::dsl as jobs;\n let id = diesel::insert_into(jobs::jobs)\n .values((jobs::repo.eq(repo),))\n .returning(jobs::id)\n .get_result::(&mut db.get().await.unwrap())\n"},{"Del":" .await\n .unwrap();\n"},{"Del":"\n"},{"Del":" let mut tmp_dir = tempfile::tempdir()?;\n tmp_dir.disable_cleanup(true);\n"},{"Del":" let wc = libpijul::working_copy::filesystem::FileSystem::from_root(\n tmp_dir.path(),\n );\n tokio::task::spawn_blocking(move || {\n libpijul::output::output_repository_no_pending(\n &wc, &changes, &txn, &channel, \"\", true, None, 1, 0,\n )?;\n Ok::<_, Error>(())\n })\n .await\n"},{"Del":" .unwrap()\n .unwrap();\n"},{"Del":" use std::process::Stdio;\n let (status_tx, status_rx) = tokio::sync::watch::channel(None);\n let (kill_tx, kill_rx) = tokio::sync::oneshot::channel();\n"},{"Del":" let p = tmp_dir.path().join(depl);\n debug!(\"launching {:?}\", p);\n"}]}},{"Replacement":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":371,"ins":{"up_context":[{"change":4,"pos":820}],"down_context":[{"change":2,"pos":24870}],"flag":"BLOCK","start":2495,"end":2740,"inode":{"change":5,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":820},"to":{"change":4,"start":820,"end":890},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":890},"to":{"change":2,"start":24620,"end":24831},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":24620},"to":{"change":2,"start":24620,"end":24831},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":24831},"to":{"change":4,"start":891,"end":967},"introduced_by":4}],"inode":{"change":5,"pos":431834}},"ins_contents":[{"Add":" let mut cmd = tokio::process::Command::new(p)"},{"Add":" .current_dir(tmp_dir.path())"},{"Add":" .stderr(Stdio::piped())"},{"Add":" .stdout(Stdio::piped())"},{"Add":" .stdin(Stdio::null())"},{"Add":" .spawn()"},{"Add":" .unwrap();"}],"del_contents":[{"Del":" let mut cmd = tokio::process::Command::new(p)\n"},{"Del":" .current_dir(tmp_dir.path())\n .stderr(Stdio::piped())\n .stdout(Stdio::piped())\n .stdin(Stdio::null())\n"},{"Del":" .spawn()\n .unwrap();\n"}]}},{"Replacement":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":379,"ins":{"up_context":[{"change":2,"pos":24871}],"down_context":[{"change":2,"pos":25275}],"flag":"BLOCK","start":2741,"end":3049,"inode":{"change":5,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":24871},"to":{"change":2,"start":24871,"end":25275},"introduced_by":2}],"inode":{"change":5,"pos":431834}},"ins_contents":[{"Add":" use tokio::io::AsyncBufReadExt;"},{"Add":" let stdout = tokio::io::BufReader::new(cmd.stdout.take().unwrap());"},{"Add":" let mut stdout = stdout.lines();"},{"Add":" let mut stdout_ok = true;"},{"Add":" let stderr = tokio::io::BufReader::new(cmd.stderr.take().unwrap());"},{"Add":" let mut stderr = stderr.lines();"}],"del_contents":[{"Del":" use tokio::io::AsyncBufReadExt;\n let stdout = tokio::io::BufReader::new(cmd.stdout.take().unwrap());\n let mut stdout = stdout.lines();\n let mut stdout_ok = true;\n let stderr = tokio::io::BufReader::new(cmd.stderr.take().unwrap());\n let mut stderr = stderr.lines();\n"}]}},{"Replacement":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":386,"ins":{"up_context":[{"change":2,"pos":25276}],"down_context":[{"change":2,"pos":25432}],"flag":"BLOCK","start":3050,"end":3176,"inode":{"change":5,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":25276},"to":{"change":2,"start":25276,"end":25432},"introduced_by":2}],"inode":{"change":5,"pos":431834}},"ins_contents":[{"Add":" self.jobs"},{"Add":" .lock()"},{"Add":" .unwrap()"},{"Add":" .insert(id, (kill_tx, status_tx.clone(), status_rx));"}],"del_contents":[{"Del":" jobs.lock()\n .unwrap()\n .insert(id, (kill_tx, status_tx.clone(), status_rx));\n"}]}},{"Replacement":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":391,"ins":{"up_context":[{"change":2,"pos":25433}],"down_context":[{"change":2,"pos":27608}],"flag":"BLOCK","start":3177,"end":4783,"inode":{"change":5,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":25433},"to":{"change":2,"start":25433,"end":25812},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":25812},"to":{"change":3,"start":0,"end":347},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":347},"to":{"change":4,"start":968,"end":1058},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1058},"to":{"change":3,"start":392,"end":624},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":392},"to":{"change":3,"start":392,"end":624},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":624},"to":{"change":4,"start":1059,"end":1149},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1149},"to":{"change":3,"start":669,"end":793},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":669},"to":{"change":3,"start":669,"end":793},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":793},"to":{"change":2,"start":26613,"end":27608},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":26613},"to":{"change":2,"start":26613,"end":27608},"introduced_by":2}],"inode":{"change":5,"pos":431834}},"ins_contents":[{"Add":" let mut stderr_ok = true;"},{"Add":" let mut buf_stdout = String::new();"},{"Add":" let mut last_stdout = std::time::UNIX_EPOCH;"},{"Add":" let mut buf_stderr = String::new();"},{"Add":" let mut last_stderr = std::time::UNIX_EPOCH;"},{"Add":" let bound = std::time::Duration::from_secs(1);"},{"Add":" let mut files = if let Some(ref path) = self.ci.filesystem {"},{"Add":" Some(("},{"Add":" OpenOptions::new()"},{"Add":" .append(true)"},{"Add":" .create(true)"},{"Add":" .open(&path.join(&format!(\"{}.stdout\", id)))"},{"Add":" .await"},{"Add":" .unwrap(),"},{"Add":" OpenOptions::new()"},{"Add":" .append(true)"},{"Add":" .create(true)"},{"Add":" .open(&path.join(&format!(\"{}.stderr\", id)))"},{"Add":" .await"},{"Add":" .unwrap(),"},{"Add":" ))"},{"Add":" } else {"},{"Add":" None"},{"Add":" };"},{"Add":" while stdout_ok || stderr_ok {"},{"Add":" debug!("},{"Add":" \"stdout || stderr {:?} {:?}\","},{"Add":" buf_stdout.len(),"},{"Add":" buf_stderr.len()"},{"Add":" );"},{"Add":" tokio::select! {"},{"Add":" line = stdout.next_line(), if stdout_ok => {"},{"Add":" let n = if let Some(line) = line? {"},{"Add":" buf_stdout.push_str(&line);"},{"Add":" buf_stdout.push('\\n');"},{"Add":" line.len()"},{"Add":" } else {"},{"Add":" 0"},{"Add":" };"},{"Add":" if last_stdout.elapsed().unwrap() >= bound || n == 0 {"},{"Add":" debug!(\"sending stdout to db {:?} {:?}\", buf_stdout.len(), buf_stderr.len());"}],"del_contents":[{"Del":" let mut stderr_ok = true;\n let mut buf_stdout = String::new();\n let mut last_stdout = std::time::UNIX_EPOCH;\n let mut buf_stderr = String::new();\n let mut last_stderr = std::time::UNIX_EPOCH;\n let bound = std::time::Duration::from_secs(1);\n"},{"Del":" let mut files = if let Some(ref path) = ci.filesystem {\n Some((\n OpenOptions::new()\n .append(true)\n .create(true)\n .open(&path.join(&format!(\"{}.stdout\", id)))\n"},{"Del":" .await\n .unwrap(),\n"},{"Del":" OpenOptions::new()\n .append(true)\n .create(true)\n .open(&path.join(&format!(\"{}.stderr\", id)))\n"},{"Del":" .await\n .unwrap(),\n"},{"Del":" ))\n } else {\n None\n };\n"},{"Del":" while stdout_ok || stderr_ok {\n debug!(\n \"stdout || stderr {:?} {:?}\",\n buf_stdout.len(),\n buf_stderr.len()\n );\n tokio::select! {\n line = stdout.next_line(), if stdout_ok => {\n let n = if let Some(line) = line? {\n buf_stdout.push_str(&line);\n buf_stdout.push('\\n');\n line.len()\n } else {\n 0\n };\n if last_stdout.elapsed().unwrap() >= bound || n == 0 {\n debug!(\"sending stdout to db {:?} {:?}\", buf_stdout.len(), buf_stderr.len());\n"}]}},{"Replacement":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":433,"ins":{"up_context":[{"change":2,"pos":27609}],"down_context":[{"change":2,"pos":29617}],"flag":"BLOCK","start":4784,"end":4978,"inode":{"change":5,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":27609},"to":{"change":2,"start":27609,"end":27784},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":27784},"to":{"change":4,"start":1150,"end":1217},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1217},"to":{"change":2,"start":27784,"end":29115},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":27784},"to":{"change":2,"start":27784,"end":29115},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":29115},"to":{"change":4,"start":1218,"end":1285},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1285},"to":{"change":2,"start":29115,"end":29617},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":29115},"to":{"change":2,"start":29115,"end":29617},"introduced_by":2}],"inode":{"change":5,"pos":431834}},"ins_contents":[{"Add":" if let Some((ref mut stdout, _)) = files {"},{"Add":" stdout.write_all(buf_stdout.as_bytes()).await?;"},{"Add":" stdout.flush().await?;"}],"del_contents":[{"Del":" if let Some((ref mut stdout, _)) = files {\n stdout.write_all(buf_stdout.as_bytes()).await?;\n"},{"Del":" stdout.flush().await?;\n"},{"Del":" }\n buf_stdout.clear();\n debug!(\"stdout/stderr {:?} {:?}\", buf_stdout.len(), buf_stderr.len());\n last_stdout = std::time::SystemTime::now();\n }\n if n == 0 {\n stdout_ok = false\n }\n }\n line = stderr.next_line(), if stderr_ok => {\n let n = if let Some(line) = line ?{\n buf_stderr.push_str(&line);\n buf_stderr.push('\\n');\n line.len()\n } else {\n 0\n };\n if last_stderr.elapsed().unwrap() >= bound || n == 0 {\n debug!(\"sending stderr to db {:?}\", buf_stderr.len());\n if let Some((_, ref mut stderr)) = files {\n stderr.write_all(buf_stderr.as_bytes()).await?;\n"},{"Del":" stderr.flush().await?;\n"},{"Del":" }\n buf_stderr.clear();\n last_stderr = std::time::SystemTime::now();\n }\n debug!(\"{:?}\", buf_stderr.len());\n if n == 0 {\n stderr_ok = false\n }\n }\n }\n"}]}},{"Replacement":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":437,"ins":{"up_context":[{"change":2,"pos":29643}],"down_context":[{"change":2,"pos":30743}],"flag":"BLOCK","start":4979,"end":6309,"inode":{"change":5,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":29643},"to":{"change":2,"start":29643,"end":30743},"introduced_by":2}],"inode":{"change":5,"pos":431834}},"ins_contents":[{"Add":" buf_stdout.clear();"},{"Add":" debug!(\"stdout/stderr {:?} {:?}\", buf_stdout.len(), buf_stderr.len());"},{"Add":" last_stdout = std::time::SystemTime::now();"},{"Add":" }"},{"Add":" if n == 0 {"},{"Add":" stdout_ok = false"},{"Add":" }"},{"Add":" }"},{"Add":" line = stderr.next_line(), if stderr_ok => {"},{"Add":" let n = if let Some(line) = line ?{"},{"Add":" buf_stderr.push_str(&line);"},{"Add":" buf_stderr.push('\\n');"},{"Add":" line.len()"},{"Add":" } else {"},{"Add":" 0"},{"Add":" };"},{"Add":" if last_stderr.elapsed().unwrap() >= bound || n == 0 {"},{"Add":" debug!(\"sending stderr to db {:?}\", buf_stderr.len());"},{"Add":" if let Some((_, ref mut stderr)) = files {"},{"Add":" stderr.write_all(buf_stderr.as_bytes()).await?;"},{"Add":" stderr.flush().await?;"},{"Add":" }"},{"Add":" buf_stderr.clear();"},{"Add":" last_stderr = std::time::SystemTime::now();"},{"Add":" }"},{"Add":" debug!(\"{:?}\", buf_stderr.len());"},{"Add":" if n == 0 {"},{"Add":" stderr_ok = false"},{"Add":" }"}],"del_contents":[{"Del":"\n let status = tokio::select! {\n status = cmd.wait() => {\n status?.code()\n }\n _ = kill_rx => {\n cmd.kill().await?;\n None\n }\n };\n debug!(\"process exited with {:?}\", status);\n debug!(\"stderr {}\", buf_stderr);\n debug!(\"stdout {}\", buf_stdout);\n let now = chrono::Utc::now();\n diesel::update(jobs::jobs.find(id))\n .set((jobs::status.eq(status), jobs::ended.eq(&now)))\n .execute(&mut db.get().await.unwrap())\n .await?;\n status_tx.send(Some((now, status))).unwrap();\n jobs.lock().unwrap().remove(&id);\n std::mem::drop(permit);\n Ok::<_, Error>(())\n });\n"}]}},{"Edit":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":468,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":30775},"to":{"change":2,"start":30775,"end":30829},"introduced_by":2}],"inode":{"change":5,"pos":431834}}},"contents":[{"Del":" } else {\n debug!(\"No pijul.toml\");\n"}]}},{"Replacement":{"inode":{"change":5,"pos":431834},"path":"api/src/replication.rs","line":469,"ins":{"up_context":[{"change":2,"pos":30839}],"down_context":[{"change":2,"pos":30854}],"flag":"BLOCK","start":6310,"end":7070,"inode":{"change":5,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":30839},"to":{"change":2,"start":30839,"end":30854},"introduced_by":2}],"inode":{"change":5,"pos":431834}},"ins_contents":[{"Add":""},{"Add":" let status = tokio::select! {"},{"Add":" status = cmd.wait() => {"},{"Add":" status?.code()"},{"Add":" }"},{"Add":" _ = kill_rx => {"},{"Add":" cmd.kill().await?;"},{"Add":" None"},{"Add":" }"},{"Add":" };"},{"Add":" debug!(\"process exited with {:?}\", status);"},{"Add":" debug!(\"stderr {}\", buf_stderr);"},{"Add":" debug!(\"stdout {}\", buf_stdout);"},{"Add":" let now = chrono::Utc::now();"},{"Add":" use crate::db::jobs::dsl as jobs;"},{"Add":" diesel::update(jobs::jobs.find(id))"},{"Add":" .set((jobs::status.eq(status), jobs::ended.eq(&now)))"},{"Add":" .execute(&mut self.db.get().await.unwrap())"},{"Add":" .await?;"},{"Add":" status_tx.send(Some((now, status))).unwrap();"},{"Add":" self.jobs.lock().unwrap().remove(&id);"},{"Add":" Ok::<_, Error>(())"}],"del_contents":[{"Del":" Ok(())\n"}]}}],"owner":"pijul","repo":"nest","token":"wlWjkHEgwrvyWWjHRoZ53I2l0DY6keAmaEWjjj/qCk4=","login":null}

…

Dependencies

Change contents