{"header":{"message":"Test replication","description":null,"timestamp":"2022-05-06T06:42:03.725526772Z","authors":[{}]},"hash":"3YOGOAKUFTRSFYT2BY5ZA5TRTIO3YIWT7DASZLT4QH62QZEG4IOAC","authors":[{"login":"pmeunier","key":"FZQ2g7VfnzLYM4mtTVDk9HAZjA8Jk9ndkwN1icgbtWUr"}],"deps":{"hashes":[["3YOGOAKUFTRSFYT2BY5ZA5TRTIO3YIWT7DASZLT4QH62QZEG4IOAC","Test replication"],["AA",null],["UZXIRPR3NPWWFX7R2PB7TI2GPHH6XYQWCY5IOFZ2ALHGSWGYI37AC","Restarting after various failures"],["FIIWK33FEEUURH7QGHQPHGQHSVN7XXLDDPLI5CKKWRK2DGIAHLGAC","Fixing lock issues"],["QISO3HXB5IMBL4FPEYONMIBBD4XMF65UBDQZKFTRH2QH62G7ZDTAC","Debug++"],["6Z6PYXTSU3DYKZKXWSZ5JZXAO2MO4KJADTYNDLUYMD4LROXRREZAC","Testing and debugging"],["ENEREHTW2UEXJGIOSSKZA2FQKFDLWQEIOAD6NIT2EH6BJW6E3AZQC","Restart and rewind the server during failover (requires policykit)"],["NPSWSVZNDMXYBVCBFSHZ2PVLUSX45LZVUMD6ROS3KLHNMBTYASZQC","Init"]],"deps":["UZXIRPR3NPWWFX7R2PB7TI2GPHH6XYQWCY5IOFZ2ALHGSWGYI37AC"],"known":["NPSWSVZNDMXYBVCBFSHZ2PVLUSX45LZVUMD6ROS3KLHNMBTYASZQC","QISO3HXB5IMBL4FPEYONMIBBD4XMF65UBDQZKFTRH2QH62G7ZDTAC","6Z6PYXTSU3DYKZKXWSZ5JZXAO2MO4KJADTYNDLUYMD4LROXRREZAC","ENEREHTW2UEXJGIOSSKZA2FQKFDLWQEIOAD6NIT2EH6BJW6E3AZQC","FIIWK33FEEUURH7QGHQPHGQHSVN7XXLDDPLI5CKKWRK2DGIAHLGAC"]},"hunks":[{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":113,"ins":{"up_context":[{"change":3,"pos":1943}],"down_context":[{"change":3,"pos":1366}],"flag":"BLOCK","start":0,"end":84,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1943},"to":{"change":3,"start":836,"end":965},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":965},"to":{"change":2,"start":81,"end":111},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":111},"to":{"change":3,"start":965,"end":973},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":965},"to":{"change":3,"start":965,"end":973},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":" let mut race = tokio::spawn(race(host.clone(), is_leader.clone(), db.clone()));"}],"del_contents":[{"Del":" let mut race = tokio::spawn(race(\n host.clone(),\n path.clone(),\n is_leader.clone(),\n db.clone(),\n"},{"Del":" process_lock.clone(),\n"},{"Del":" ));\n"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":120,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2258}],"down_context":[{"change":3,"pos":2258}],"flag":"BLOCK","start":85,"end":323,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" ));"},{"Add":" let mut check = tokio::spawn(check_postgres("},{"Add":" host.clone(),"},{"Add":" port,"},{"Add":" password.clone(),"},{"Add":" db_name.clone(),"},{"Add":" path.clone(),"},{"Add":" lead.clone(),"},{"Add":" db.clone(),"},{"Add":" process_lock.clone(),"}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":152,"ins":{"up_context":[{"change":3,"pos":3589}],"down_context":[{"change":3,"pos":1590}],"flag":"BLOCK","start":324,"end":339,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3589},"to":{"change":3,"start":3589,"end":3603},"introduced_by":3}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":" },"}],"del_contents":[{"Del":" }\n"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":157,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":3736}],"down_context":[{"change":3,"pos":3736}],"flag":"BLOCK","start":340,"end":467,"inode":{"change":3,"pos":17}}},"contents":[{"Add":" e = &mut check => {"},{"Add":" error!(\"check postgres stopped: {:?}\", e);"},{"Add":" break"},{"Add":" }"}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":182,"ins":{"up_context":[{"change":2,"pos":130}],"down_context":[{"change":2,"pos":182}],"flag":"BLOCK","start":468,"end":498,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":130},"to":{"change":2,"start":130,"end":182},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":" leader: Receiver,"}],"del_contents":[{"Del":" path: String,\n mut leader: Receiver,\n"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":184,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":236},"to":{"change":2,"start":236,"end":270},"introduced_by":2}],"inode":{"change":3,"pos":17}}},"contents":[{"Del":" process_lock: Arc>,\n"}]}},{"Replacement":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":186,"ins":{"up_context":[{"change":2,"pos":285}],"down_context":[{"change":2,"pos":481}],"flag":"BLOCK","start":499,"end":571,"inode":{"change":3,"pos":17}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":285},"to":{"change":2,"start":285,"end":481},"introduced_by":2}],"inode":{"change":3,"pos":17}},"ins_contents":[{"Add":" match race_(host.clone(), leader.clone(), pool.clone()).await {"}],"del_contents":[{"Del":" match race_(\n host.clone(),\n path.clone(),\n leader.clone(),\n pool.clone(),\n process_lock.clone(),\n )\n .await\n {\n"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":199,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1067},"to":{"change":3,"start":1067,"end":1085},"introduced_by":3}],"inode":{"change":3,"pos":17}}},"contents":[{"Del":" path: String,\n"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":201,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1173},"to":{"change":2,"start":747,"end":781},"introduced_by":2}],"inode":{"change":3,"pos":17}}},"contents":[{"Del":" process_lock: Arc>,\n"}]}},{"Edit":{"inode":{"change":3,"pos":17},"path":"src/main.rs","line":301,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":3137}],"down_context":[{"change":2,"pos":1105}],"flag":"BLOCK","start":572,"end":1573,"inode":{"change":3,"pos":17}}},"contents":[{"Add":"async fn check_postgres("},{"Add":" host: String,"},{"Add":" port: u16,"},{"Add":" password: String,"},{"Add":" db_name: String,"},{"Add":" path: String,"},{"Add":" leader: Arc>,"},{"Add":" pool: Arc>>,"},{"Add":" process_lock: Arc>,"},{"Add":") -> Result<(), anyhow::Error> {"},{"Add":" loop {"},{"Add":" let leader = leader.borrow().to_string();"},{"Add":" if leader != host {"},{"Add":" let mut needs_rewind = false;"},{"Add":" let pool_ = { pool.lock().await.take() };"},{"Add":" if let Some(pool_) = pool_ {"},{"Add":" needs_rewind = pool_"},{"Add":" .query_opt(\"SELECT 1 FROM pg_stat_wal_receiver\", &[])"},{"Add":" .await?"},{"Add":" .is_none();"},{"Add":" *pool.lock().await = Some(pool_);"},{"Add":" }"},{"Add":" if needs_rewind {"},{"Add":" debug!(\"leader: {:?}\", leader);"},{"Add":" rewind(&process_lock, &path, port, &db_name, &leader, &password).await"},{"Add":" }"},{"Add":" }"},{"Add":" tokio::time::sleep(std::time::Duration::from_secs(10)).await"},{"Add":" }"},{"Add":"}"},{"Add":""}]}}],"owner":"pmeunier","repo":"postrep","token":"DSUOp3w8CN5ilf3SJzEqt4SItXCka1k6iZSCKjEahUY=","login":null}

…

Dependencies

Change contents