{"header":{"message":"Restarting after various failures","description":null,"timestamp":"2022-04-17T16:09:46.609473016Z","authors":[{}]},"hash":"UZXIRPR3NPWWFX7R2PB7TI2GPHH6XYQWCY5IOFZ2ALHGSWGYI37AC","authors":[{"login":"pmeunier","key":"FZQ2g7VfnzLYM4mtTVDk9HAZjA8Jk9ndkwN1icgbtWUr"}],"deps":{"hashes":[["UZXIRPR3NPWWFX7R2PB7TI2GPHH6XYQWCY5IOFZ2ALHGSWGYI37AC","Restarting after various failures"],["AA",null],["UEGA35KU63HPNZLXVR5CS2BNMCVOV7HOBTDR4K6YZSPDFWXIKKZQC","Signalling the postgres server when the leader changes, but does not become this node"],["6Z6PYXTSU3DYKZKXWSZ5JZXAO2MO4KJADTYNDLUYMD4LROXRREZAC","Testing and debugging"],["FIIWK33FEEUURH7QGHQPHGQHSVN7XXLDDPLI5CKKWRK2DGIAHLGAC","Fixing lock issues"],["NPSWSVZNDMXYBVCBFSHZ2PVLUSX45LZVUMD6ROS3KLHNMBTYASZQC","Init"],["ENEREHTW2UEXJGIOSSKZA2FQKFDLWQEIOAD6NIT2EH6BJW6E3AZQC","Restart and rewind the server during failover (requires policykit)"]],"deps":["UEGA35KU63HPNZLXVR5CS2BNMCVOV7HOBTDR4K6YZSPDFWXIKKZQC"],"known":["NPSWSVZNDMXYBVCBFSHZ2PVLUSX45LZVUMD6ROS3KLHNMBTYASZQC","6Z6PYXTSU3DYKZKXWSZ5JZXAO2MO4KJADTYNDLUYMD4LROXRREZAC","ENEREHTW2UEXJGIOSSKZA2FQKFDLWQEIOAD6NIT2EH6BJW6E3AZQC","FIIWK33FEEUURH7QGHQPHGQHSVN7XXLDDPLI5CKKWRK2DGIAHLGAC"]},"hunks":[{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":102,"ins":{"up_context":[{"change":3,"pos":1073}],"down_context":[{"change":3,"pos":1757}],"flag":"BLOCK","start":0,"end":49,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1073},"to":{"change":3,"start":1073,"end":1074},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":" let process_lock = Arc::new(Mutex::new(()));"}],"del_contents":[{"Del":"\n"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":111,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":1935}],"down_context":[{"change":3,"pos":1935}],"flag":"BLOCK","start":50,"end":80,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" process_lock.clone(),"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":118,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":965}],"down_context":[{"change":3,"pos":965}],"flag":"BLOCK","start":81,"end":111,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" process_lock.clone(),"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":173,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":1049}],"down_context":[{"change":3,"pos":1049}],"flag":"BLOCK","start":112,"end":746,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" host: String,"},{"Add":" path: String,"},{"Add":" mut leader: Receiver,"},{"Add":" pool: Arc>>,"},{"Add":" process_lock: Arc>,"},{"Add":") {"},{"Add":" loop {"},{"Add":" match race_("},{"Add":" host.clone(),"},{"Add":" path.clone(),"},{"Add":" leader.clone(),"},{"Add":" pool.clone(),"},{"Add":" process_lock.clone(),"},{"Add":" )"},{"Add":" .await"},{"Add":" {"},{"Add":" Ok(()) => {"},{"Add":" error!(\"race stopped\")"},{"Add":" }"},{"Add":" Err(e) => {"},{"Add":" error!(\"race_ error {:?}\", e);"},{"Add":" }"},{"Add":" }"},{"Add":" tokio::time::sleep(std::time::Duration::from_secs(1)).await;"},{"Add":" }"},{"Add":"}"},{"Add":"async fn race_("}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":204,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":1173}],"down_context":[{"change":3,"pos":1173}],"flag":"BLOCK","start":747,"end":781,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" process_lock: Arc>,"}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":236,"ins":{"up_context":[{"change":3,"pos":1475}],"down_context":[{"change":3,"pos":5486}],"flag":"BLOCK","start":782,"end":830,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1475},"to":{"change":3,"start":1475,"end":1505},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":" // promote(&process_lock, &path).await;"}],"del_contents":[{"Del":" promote(&path).await;\n"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":261,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2476}],"down_context":[{"change":3,"pos":6132}],"flag":"BLOCK","start":831,"end":865,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" process_lock: Arc>,"}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":280,"ins":{"up_context":[{"change":3,"pos":2939}],"down_context":[{"change":3,"pos":1766}],"flag":"BLOCK","start":866,"end":914,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2939},"to":{"change":3,"start":2939,"end":2972},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":" promote(&process_lock, &path).await"}],"del_contents":[{"Del":" promote(&path).await\n"}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":292,"ins":{"up_context":[{"change":3,"pos":2226}],"down_context":[{"change":2,"pos":72}],"flag":"BLOCK","start":915,"end":1002,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2226},"to":{"change":2,"start":0,"end":72},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":" rewind(&process_lock, &path, port, &db_name, leader, &password).await;"}],"del_contents":[{"Del":" rewind(&path, port, &db_name, leader, &password).await;\n"}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":294,"ins":{"up_context":[{"change":2,"pos":93}],"down_context":[{"change":3,"pos":2287}],"flag":"BLOCK","start":1003,"end":1055,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":93},"to":{"change":2,"start":93,"end":130},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":" reload(&process_lock, &path).await;"}],"del_contents":[{"Del":" reload(&path).await;\n"}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":297,"ins":{"up_context":[{"change":2,"pos":148}],"down_context":[{"change":3,"pos":3173}],"flag":"BLOCK","start":1056,"end":1104,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":148},"to":{"change":2,"start":148,"end":181},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":" reload(&process_lock, &path).await;"}],"del_contents":[{"Del":" reload(&path).await;\n"}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":305,"ins":{"up_context":[{"change":3,"pos":3137}],"down_context":[{"change":3,"pos":2302}],"flag":"BLOCK","start":1105,"end":1162,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3137},"to":{"change":3,"start":3137,"end":3168},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":"async fn promote(process_lock: &Mutex<()>, path: &str) {"}],"del_contents":[{"Del":"async fn promote(path: &str) {\n"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":308,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":3201}],"down_context":[{"change":3,"pos":2328}],"flag":"BLOCK","start":1163,"end":1206,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" let guard = process_lock.lock().await;"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":317,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2500}],"down_context":[{"change":3,"pos":6959}],"flag":"BLOCK","start":1207,"end":1234,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" std::mem::drop(guard);"}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":320,"ins":{"up_context":[{"change":3,"pos":3348}],"down_context":[{"change":2,"pos":212}],"flag":"BLOCK","start":1235,"end":1291,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3348},"to":{"change":2,"start":182,"end":212},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":"async fn reload(process_lock: &Mutex<()>, path: &str) {"}],"del_contents":[{"Del":"async fn reload(path: &str) {\n"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":323,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":3451}],"down_context":[{"change":2,"pos":235}],"flag":"BLOCK","start":1292,"end":1335,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" let guard = process_lock.lock().await;"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":332,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2702}],"down_context":[{"change":2,"pos":311}],"flag":"BLOCK","start":1336,"end":1363,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" std::mem::drop(guard);"}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":335,"ins":{"up_context":[{"change":2,"pos":314}],"down_context":[{"change":2,"pos":400}],"flag":"BLOCK","start":1364,"end":1503,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":314},"to":{"change":2,"start":314,"end":400},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":"async fn rewind("},{"Add":" process_lock: &Mutex<()>,"},{"Add":" path: &str,"},{"Add":" port: u16,"},{"Add":" db_name: &str,"},{"Add":" leader: &str,"},{"Add":" password: &str,"},{"Add":") {"}],"del_contents":[{"Del":"async fn rewind(path: &str, port: u16, db_name: &str, leader: &str, password: &str) {\n"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":344,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":425}],"down_context":[{"change":2,"pos":425}],"flag":"BLOCK","start":1504,"end":1547,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" let guard = process_lock.lock().await;"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":403,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":1664}],"down_context":[{"change":3,"pos":4112}],"flag":"BLOCK","start":1548,"end":1575,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" std::mem::drop(guard);"}]}}],"owner":"pmeunier","repo":"postrep","token":"w0pIc518nS4kxtuxG/sDJ3U7eQ4Hy94AfC3H5vGMkC4=","login":null}

…

Dependencies

Change contents