{"header":{"message":"Fixing a bug when downloading changes, and making change download more efficient (more async)","description":null,"timestamp":"2021-02-27T19:14:43.311630806Z","authors":[{"full_name":"Pierre-Étienne Meunier","name":"pmeunier"}]},"hash":"TKEVOH7HXON7SOBGXTUDHAHO2U2GPTQRNESP6ERKUQAS526OZIRAC","authors":[],"deps":{"hashes":[["TKEVOH7HXON7SOBGXTUDHAHO2U2GPTQRNESP6ERKUQAS526OZIRAC","Fixing a bug when downloading changes, and making change download more efficient (more async)"],["AA",null],["TZ42DX3BML5C3O5Z6OBVNBCHSIIHT6AOJPD6ICOLOP4LPYFXQN2QC","Properly dropping a channel"],["MU5GSJAW65PEG3BRYUKZ7O37BPHW3MOX3S5E2RFOXKGUOJEEDQ5AC","Partial push and pull (WARNING: breaks the existing protocol)"],["CCLLB7OIFNFYJZTG3UCI7536TOCWSCSXR67VELSB466R24WLJSDAC","Upgrading to Sanakirja 0.15 + version bump"],["X6YFD4WVMUYJCR5IYPJH6UKYVWSA7DKBRVJ6XQFXHOE2TRYUTAHAC","Do not download changes if we already have them"],["GHO6DWPILBBTL6CVZKERJBTFL3EY6ZT4YM4E5R4S6YPGVFKFHCVAC","Refactoring iterators"],["I52XSRUH5RVHQBFWVMAQPTUSPAJ4KNVID2RMI3UGCVKFLYUO6WZAC","Massive cleanup, and simplification"],["UDHP4ZVBQZT2VBURB2MDCU2IZDNMCAFSIUKWRBDQ5BWMFKSN2LYQC","Fixing SSH asynchronicity issues"],["Q45QHPO4HDTEZF2W4UDZSYYQ46BPEIWSW4GJILZR5HTJNLKXJABQC","Feedback on network stuff"],["SZWBLWZ4LUJZHTSYOIGJMXM7KPCGWJFPKLHYA5MHY7UTPNLZV5KQC","Reading ~/.ssh/config"],["FBXYP7QM7SG6P2JDJVQPPCRKJE3GVYXNQ5GVV4GRDUNG6Q4ZRDJQC","Forgot to add remote::http"],["QMTANHVNRPQ5IX66FYQBFRBDCTN6YKMNCO6OHTQ6QCUASPWWXJKAC","Reset: only output changed files"],["IQ4FCHPZYGTZHCQHUIRCMUI5LCHIDSJCM2AZXGRJARWLCPPLXZOQC","HTTP connections: pooling + retry on error"],["BZSC7VMYSFRXDHDDAMCDR6X67FN5VWIBOSE76BQLX7OCVOJFUA3AC","address clippy lints"],["WLUID7NANDWTN5GOECNEKFTLZF3MUVS7K26YWLYLSGJ56G63NV4QC","Do not block when downloading more than 100 changes over SSH"],["L4JXJHWXYNCL4QGJXNKKTOKKTAXKKXBJUUY7HFZGEUZ5A2V5H34QC","pijul/*: reorganize imports and remove extern crate"],["WTZXEWY7IAXJAFNV7STCNQY2SNRDPHX3MKOEZ77NEJUN4MS2VYSQC","Flushing the futures pipeline when downloading over HTTP(S)"],["LGEJSLTYI7Y2CYC3AN6ECMT3D3MTWCAKZPVQEG5MPM2OBW5FQ46AC","Fixing output (including its uses in reset and pull)"],["5XMUEZMZXQ4T4HGZAGBZWT5YKEXOA7IWLZBSREWBHXLMGHXOFXZAC","pijul-clone: avoid panics on parsing remote URLs"],["5QTMRUXNE2XNJCMLN6MQN24UEZ55EFC3LIR4PO6OPNTT5KEL7WXQC","Fixing a race condition between progress bars"],["HXEIH4UQ6EX3MAY33JK4WQUE5GUSZ673OX57JKNFXC2N2QLTXKXAC","Pulling more than 100 changes at once"],["VBMXB443FGZL6DLT6KAP2ICFCCQNXCUMDEUL67HB4CNKFMBBNSSAC","Retrying if the HTTP connection drops while reading the body"],["VO5OQW4W2656DIYYRNZ3PO7TQ4JOKQ3GVWE5ALUTYVMX3WMXJOYQC","Removing anyhow in libpijul"],["KTTKF3RWYAK2YSH2DYYW5QVG4KSNGWUBJBFHKE24OJ7LFCBF5FEAC","Locking stderr and the progress bar in SSH"],["YN63NUZO4LVJ7XPMURDULTXBVJKW5MVCTZ24R7Z52QMHO3HPDUVQC","Sanakirja 1.0"],["367UBQ6KNAKUEWG32R4QRJ6H7IE7NAZFOPTC3ZOE4Z6E44RV3ISQC","Forwarding SSH stderr, and progress bar for push"],["DNQHXWRZF6EWII3RGQ6HPGFD47BOOFH4FCQHSCACBS3RLQO3DNIQC","address clippy hard errors"],["76PCXGML77EZWTRI5E6KHLVRAFTJ2AB5YRN5EKOYNAPKTWY2KCGAC","Pushing to, and pulling from the local repository"],["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","Fixing the bad changes in history (unfortunately, by rebooting)."],["K6GWUOD55G377RVEEMMRPZ4EUAHCM2BGXNRJTE5UZJFFMJGFCEZQC","Styling progress bars"],["6YMDOZIB5LVYLFIDGN2WNT5JTHEAMS4TFPVDEZ3OWXWOKJOC5QDAC","Refactoring apply"]],"deps":["TZ42DX3BML5C3O5Z6OBVNBCHSIIHT6AOJPD6ICOLOP4LPYFXQN2QC"],"known":["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","76PCXGML77EZWTRI5E6KHLVRAFTJ2AB5YRN5EKOYNAPKTWY2KCGAC","L4JXJHWXYNCL4QGJXNKKTOKKTAXKKXBJUUY7HFZGEUZ5A2V5H34QC","UDHP4ZVBQZT2VBURB2MDCU2IZDNMCAFSIUKWRBDQ5BWMFKSN2LYQC","FBXYP7QM7SG6P2JDJVQPPCRKJE3GVYXNQ5GVV4GRDUNG6Q4ZRDJQC","I52XSRUH5RVHQBFWVMAQPTUSPAJ4KNVID2RMI3UGCVKFLYUO6WZAC","Q45QHPO4HDTEZF2W4UDZSYYQ46BPEIWSW4GJILZR5HTJNLKXJABQC","367UBQ6KNAKUEWG32R4QRJ6H7IE7NAZFOPTC3ZOE4Z6E44RV3ISQC","K6GWUOD55G377RVEEMMRPZ4EUAHCM2BGXNRJTE5UZJFFMJGFCEZQC","HXEIH4UQ6EX3MAY33JK4WQUE5GUSZ673OX57JKNFXC2N2QLTXKXAC","WLUID7NANDWTN5GOECNEKFTLZF3MUVS7K26YWLYLSGJ56G63NV4QC","SZWBLWZ4LUJZHTSYOIGJMXM7KPCGWJFPKLHYA5MHY7UTPNLZV5KQC","DNQHXWRZF6EWII3RGQ6HPGFD47BOOFH4FCQHSCACBS3RLQO3DNIQC","BZSC7VMYSFRXDHDDAMCDR6X67FN5VWIBOSE76BQLX7OCVOJFUA3AC","KTTKF3RWYAK2YSH2DYYW5QVG4KSNGWUBJBFHKE24OJ7LFCBF5FEAC","VO5OQW4W2656DIYYRNZ3PO7TQ4JOKQ3GVWE5ALUTYVMX3WMXJOYQC","5QTMRUXNE2XNJCMLN6MQN24UEZ55EFC3LIR4PO6OPNTT5KEL7WXQC","X6YFD4WVMUYJCR5IYPJH6UKYVWSA7DKBRVJ6XQFXHOE2TRYUTAHAC","MU5GSJAW65PEG3BRYUKZ7O37BPHW3MOX3S5E2RFOXKGUOJEEDQ5AC","IQ4FCHPZYGTZHCQHUIRCMUI5LCHIDSJCM2AZXGRJARWLCPPLXZOQC","VBMXB443FGZL6DLT6KAP2ICFCCQNXCUMDEUL67HB4CNKFMBBNSSAC","WTZXEWY7IAXJAFNV7STCNQY2SNRDPHX3MKOEZ77NEJUN4MS2VYSQC","CCLLB7OIFNFYJZTG3UCI7536TOCWSCSXR67VELSB466R24WLJSDAC","GHO6DWPILBBTL6CVZKERJBTFL3EY6ZT4YM4E5R4S6YPGVFKFHCVAC","QMTANHVNRPQ5IX66FYQBFRBDCTN6YKMNCO6OHTQ6QCUASPWWXJKAC","5XMUEZMZXQ4T4HGZAGBZWT5YKEXOA7IWLZBSREWBHXLMGHXOFXZAC","LGEJSLTYI7Y2CYC3AN6ECMT3D3MTWCAKZPVQEG5MPM2OBW5FQ46AC","YN63NUZO4LVJ7XPMURDULTXBVJKW5MVCTZ24R7Z52QMHO3HPDUVQC"]},"hunks":[{"Replacement":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":14,"ins":{"up_context":[{"change":3,"pos":6054}],"down_context":[{"change":3,"pos":276}],"flag":"BLOCK","start":0,"end":32,"inode":{"change":3,"pos":25380}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":80},"to":{"change":3,"start":251,"end":276},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":6054},"to":{"change":3,"start":251,"end":276},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":251},"to":{"change":3,"start":251,"end":276},"introduced_by":3}],"inode":{"change":3,"pos":25380}},"ins_contents":[{"Add":"use log::{debug, error, trace};"}],"del_contents":[{"Del":"use log::{debug, error};\n"}]}},{"Replacement":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":400,"ins":{"up_context":[{"change":3,"pos":1411}],"down_context":[{"change":3,"pos":1466}],"flag":"BLOCK","start":33,"end":88,"inode":{"change":3,"pos":25380}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1411},"to":{"change":3,"start":1411,"end":1466},"introduced_by":3}],"inode":{"change":3,"pos":25380}},"ins_contents":[{"Add":" trace!(\"data {:?} {:?}\", channel, data.len());"}],"del_contents":[{"Del":" debug!(\"data {:?} {:?}\", channel, data.len());\n"}]}},{"Replacement":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":430,"ins":{"up_context":[{"change":3,"pos":2788}],"down_context":[{"change":3,"pos":2833}],"flag":"BLOCK","start":89,"end":134,"inode":{"change":3,"pos":25380}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2788},"to":{"change":3,"start":2788,"end":2833},"introduced_by":3}],"inode":{"change":3,"pos":25380}},"ins_contents":[{"Add":" trace!(\"state changes\");"}],"del_contents":[{"Del":" debug!(\"state changes\");\n"}]}},{"Edit":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":439,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":3260}],"down_context":[{"change":3,"pos":3260}],"flag":"BLOCK","start":135,"end":209,"inode":{"change":3,"pos":25380}}},"contents":[{"Add":" debug!(\"writing {:?} bytes\", *remaining_len);"}]}},{"Edit":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":462,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4400}],"down_context":[{"change":3,"pos":4400}],"flag":"BLOCK","start":210,"end":276,"inode":{"change":3,"pos":25380}}},"contents":[{"Add":" debug!(\"before pop: {:?}\", path);"}]}},{"Edit":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":468,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4701}],"down_context":[{"change":3,"pos":4701}],"flag":"BLOCK","start":277,"end":342,"inode":{"change":3,"pos":25380}}},"contents":[{"Add":" debug!(\"after pop: {:?}\", path);"}]}},{"Replacement":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":484,"ins":{"up_context":[{"change":3,"pos":5504}],"down_context":[{"change":3,"pos":5558}],"flag":"BLOCK","start":343,"end":397,"inode":{"change":3,"pos":25380}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5504},"to":{"change":3,"start":5504,"end":5558},"introduced_by":3}],"inode":{"change":3,"pos":25380}},"ins_contents":[{"Add":" trace!(\"need more data\");"}],"del_contents":[{"Del":" debug!(\"need more data\");\n"}]}},{"Replacement":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":488,"ins":{"up_context":[{"change":3,"pos":5641}],"down_context":[{"change":3,"pos":5707}],"flag":"BLOCK","start":398,"end":464,"inode":{"change":3,"pos":25380}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5641},"to":{"change":3,"start":5641,"end":5707},"introduced_by":3}],"inode":{"change":3,"pos":25380}},"ins_contents":[{"Add":" trace!(\"finished, {:?} {:?}\", p, data.len());"}],"del_contents":[{"Del":" debug!(\"finished, {:?} {:?}\", p, data.len());\n"}]}},{"Replacement":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":797,"ins":{"up_context":[{"change":3,"pos":45470}],"down_context":[{"change":3,"pos":8746}],"flag":"BLOCK","start":465,"end":536,"inode":{"change":3,"pos":25380}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":45470},"to":{"change":3,"start":8706,"end":8746},"introduced_by":3}],"inode":{"change":3,"pos":25380}},"ins_contents":[{"Add":" c: &mut tokio::sync::mpsc::Receiver,"}],"del_contents":[{"Del":" c: &[libpijul::pristine::Hash],\n"}]}},{"Replacement":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":808,"ins":{"up_context":[{"change":3,"pos":208}],"down_context":[{"change":3,"pos":248}],"flag":"BLOCK","start":537,"end":608,"inode":{"change":3,"pos":25380}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":208},"to":{"change":3,"start":208,"end":248},"introduced_by":3}],"inode":{"change":3,"pos":25380}},"ins_contents":[{"Add":" c: &mut tokio::sync::mpsc::Receiver,"}],"del_contents":[{"Del":" c: &[libpijul::pristine::Hash],\n"}]}},{"Edit":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":813,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":426},"to":{"change":3,"start":2585,"end":2648},"introduced_by":3}],"inode":{"change":3,"pos":25380}}},"contents":[{"Del":" if c.is_empty() {\n return Ok(());\n }\n"}]}},{"Edit":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":815,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":8967},"to":{"change":3,"start":8967,"end":9043},"introduced_by":3}],"inode":{"change":3,"pos":25380}}},"contents":[{"Del":" libpijul::changestore::filesystem::push_filename(&mut path, &c[0]);\n"}]}},{"Edit":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":818,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":9094}],"down_context":[{"change":3,"pos":9094}],"flag":"BLOCK","start":609,"end":661,"inode":{"change":3,"pos":25380}}},"contents":[{"Add":" debug!(\"changes_dir = {:?}\", changes_dir);"},{"Add":""}]}},{"Replacement":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":825,"ins":{"up_context":[{"change":3,"pos":9247}],"down_context":[{"change":3,"pos":9279}],"flag":"BLOCK","start":662,"end":694,"inode":{"change":3,"pos":25380}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9247},"to":{"change":3,"start":9247,"end":9279},"introduced_by":3}],"inode":{"change":3,"pos":25380}},"ins_contents":[{"Add":" hashes: Vec::new(),"}],"del_contents":[{"Del":" hashes: c.to_vec(),\n"}]}},{"Replacement":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":829,"ins":{"up_context":[{"change":3,"pos":9350}],"down_context":[{"change":3,"pos":9371}],"flag":"BLOCK","start":695,"end":898,"inode":{"change":3,"pos":25380}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9350},"to":{"change":3,"start":9350,"end":9371},"introduced_by":3}],"inode":{"change":3,"pos":25380}},"ins_contents":[{"Add":" let mut len = 0;"},{"Add":" while let Some(c) = c.recv().await {"},{"Add":" if let State::Changes { ref mut hashes, .. } = *self.state.lock().await {"},{"Add":" hashes.push(c);"},{"Add":" }"},{"Add":""}],"del_contents":[{"Del":" for c in c {\n"}]}},{"Edit":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":845,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":9743}],"down_context":[{"change":3,"pos":9743}],"flag":"BLOCK","start":899,"end":921,"inode":{"change":3,"pos":25380}}},"contents":[{"Add":" len += 1;"}]}},{"Replacement":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":847,"ins":{"up_context":[{"change":3,"pos":9753}],"down_context":[{"change":3,"pos":0}],"flag":"BLOCK","start":922,"end":975,"inode":{"change":3,"pos":25380}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":9753},"to":{"change":3,"start":29,"end":86},"introduced_by":3}],"inode":{"change":3,"pos":25380}},"ins_contents":[{"Add":" let progress = ProgressBar::new(len as u64);"}],"del_contents":[{"Del":" let progress = ProgressBar::new(c.len() as u64);\n"}]}},{"Replacement":{"inode":{"change":3,"pos":25380},"path":"pijul/src/remote/ssh.rs","line":876,"ins":{"up_context":[{"change":3,"pos":49753}],"down_context":[{"change":3,"pos":52441}],"flag":"BLOCK","start":976,"end":1030,"inode":{"change":3,"pos":25380}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":49753},"to":{"change":3,"start":9928,"end":9964},"introduced_by":3}],"inode":{"change":3,"pos":25380}},"ins_contents":[{"Add":" debug!(\"done downloading {:?}\", changes_dir);"}],"del_contents":[{"Del":" debug!(\"done downloading\");\n"}]}},{"Replacement":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":7,"ins":{"up_context":[{"change":3,"pos":393}],"down_context":[{"change":3,"pos":52599}],"flag":"BLOCK","start":1031,"end":1128,"inode":{"change":3,"pos":52474}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":393},"to":{"change":3,"start":516,"end":602},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":439},"to":{"change":3,"start":516,"end":602},"introduced_by":3}],"inode":{"change":3,"pos":52474}},"ins_contents":[{"Add":"use libpijul::pristine::{Base32, ChannelRef, GraphIter, Hash, Merkle, MutTxnT, RemoteRef, TxnT};"}],"del_contents":[{"Del":"use libpijul::pristine::{Base32, ChannelRef, Hash, Merkle, MutTxnT, RemoteRef, TxnT};\n"}]}},{"Replacement":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":350,"ins":{"up_context":[{"change":3,"pos":66710}],"down_context":[{"change":3,"pos":10700}],"flag":"BLOCK","start":1129,"end":1205,"inode":{"change":3,"pos":52474}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":66710},"to":{"change":3,"start":10655,"end":10700},"introduced_by":3}],"inode":{"change":3,"pos":52474}},"ins_contents":[{"Add":" hashes: &mut tokio::sync::mpsc::Receiver,"}],"del_contents":[{"Del":" hashes: &[libpijul::pristine::Hash],\n"}]}},{"Edit":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":363,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":68102},"to":{"change":3,"start":68102,"end":68165},"introduced_by":3}],"inode":{"change":3,"pos":52474}}},"contents":[{"Del":" libpijul::changestore::filesystem::pop_filename(path);\n"}]}},{"Edit":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":376,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":69053}],"down_context":[{"change":3,"pos":69053}],"flag":"BLOCK","start":1206,"end":1698,"inode":{"change":3,"pos":52474}}},"contents":[{"Add":""},{"Add":" let mut self_ = std::mem::replace(self, RemoteRepo::None);"},{"Add":" let (hash_send, mut hash_recv) = tokio::sync::mpsc::channel(100);"},{"Add":" let mut change_path_ = repo.path.clone();"},{"Add":" change_path_.push(DOT_DIR);"},{"Add":" change_path_.push(\"changes\");"},{"Add":" let t = tokio::spawn(async move {"},{"Add":" self_"},{"Add":" .download_changes(&mut hash_recv, &mut send, &mut change_path_, false)"},{"Add":" .await?;"},{"Add":" Ok::<_, anyhow::Error>(self_)"},{"Add":" });"}]}},{"Replacement":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":390,"ins":{"up_context":[{"change":3,"pos":69111}],"down_context":[{"change":3,"pos":231}],"flag":"BLOCK","start":1699,"end":1724,"inode":{"change":3,"pos":52474}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":69111},"to":{"change":3,"start":188,"end":231},"introduced_by":3}],"inode":{"change":3,"pos":52474}},"ins_contents":[{"Add":" let mut len = 0;"}],"del_contents":[{"Del":" let mut to_download_ = Vec::new();\n"}]}},{"Replacement":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":394,"ins":{"up_context":[{"change":3,"pos":402}],"down_context":[{"change":3,"pos":440}],"flag":"BLOCK","start":1725,"end":1793,"inode":{"change":3,"pos":52474}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":402},"to":{"change":3,"start":402,"end":440},"introduced_by":3}],"inode":{"change":3,"pos":52474}},"ins_contents":[{"Add":" hash_send.send(*h).await?;"},{"Add":" len += 1"}],"del_contents":[{"Del":" to_download_.push(*h)\n"}]}},{"Edit":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":399,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":544},"to":{"change":3,"start":544,"end":592},"introduced_by":3}],"inode":{"change":3,"pos":52474}}},"contents":[{"Del":" let to_download = to_download_.clone();\n"}]}},{"Edit":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":400,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1},"to":{"change":3,"start":1,"end":293},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":293},"to":{"change":3,"start":69754,"end":69755},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":11284},"to":{"change":3,"start":69754,"end":69755},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":69754},"to":{"change":3,"start":69754,"end":69755},"introduced_by":3}],"inode":{"change":3,"pos":52474}}},"contents":[{"Del":" let mut self_ = std::mem::replace(self, RemoteRepo::None);\n let t = tokio::spawn(async move {\n self_\n .download_changes(&to_download_, &mut send, &mut change_path_, false)\n .await?;\n Ok::<_, anyhow::Error>(self_)\n });\n"},{"Del":"\n"}]}},{"Replacement":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":403,"ins":{"up_context":[{"change":3,"pos":611}],"down_context":[{"change":3,"pos":905}],"flag":"BLOCK","start":1794,"end":1848,"inode":{"change":3,"pos":52474}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":611},"to":{"change":3,"start":611,"end":686},"introduced_by":3}],"inode":{"change":3,"pos":52474}},"ins_contents":[{"Add":" let p = indicatif::ProgressBar::new(len);"}],"del_contents":[{"Del":" let p = indicatif::ProgressBar::new(to_download.len() as u64);\n"}]}},{"Replacement":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":497,"ins":{"up_context":[{"change":3,"pos":71428}],"down_context":[{"change":3,"pos":71908}],"flag":"BLOCK","start":1849,"end":1986,"inode":{"change":3,"pos":52474}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":71469},"to":{"change":3,"start":71469,"end":71529},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":71529},"to":{"change":3,"start":11285,"end":11427},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":11427},"to":{"change":3,"start":71732,"end":71746},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":71732},"to":{"change":3,"start":71732,"end":71746},"introduced_by":3}],"inode":{"change":3,"pos":52474}},"ins_contents":[{"Add":" self_"},{"Add":" .download_changes(&mut recv_hash, &mut send_signal, &mut change_path_, false)"},{"Add":" .await?;"}],"del_contents":[{"Del":" while let Some(hash) = recv_hash.recv().await {\n"},{"Del":" self_\n .download_changes(&[hash], &mut send_signal, &mut change_path_, false)\n .await?;\n"},{"Del":" }\n"}]}},{"Replacement":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":560,"ins":{"up_context":[{"change":3,"pos":74770}],"down_context":[{"change":3,"pos":74830}],"flag":"BLOCK","start":1987,"end":2056,"inode":{"change":3,"pos":52474}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":74770},"to":{"change":3,"start":798,"end":855},"introduced_by":3}],"inode":{"change":3,"pos":52474}},"ins_contents":[{"Add":" pub async fn complete_changes("}],"del_contents":[{"Del":" pub async fn complete_changes(\n"}]}},{"Edit":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":568,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":75038}],"down_context":[{"change":3,"pos":75038}],"flag":"BLOCK","start":2057,"end":2107,"inode":{"change":3,"pos":52474}}},"contents":[{"Add":" debug!(\"complete changes {:?}\", changes);"}]}},{"Replacement":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":575,"ins":{"up_context":[{"change":3,"pos":75405}],"down_context":[{"change":3,"pos":76064}],"flag":"BLOCK","start":2108,"end":2282,"inode":{"change":3,"pos":52474}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":75446},"to":{"change":3,"start":75446,"end":75562},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":75562},"to":{"change":3,"start":11428,"end":11562},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":11562},"to":{"change":3,"start":75825,"end":75839},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":75825},"to":{"change":3,"start":75825,"end":75839},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":75983},"to":{"change":3,"start":75983,"end":76064},"introduced_by":3}],"inode":{"change":3,"pos":52474}},"ins_contents":[{"Add":" self_"},{"Add":" .download_changes(&mut recv_hash, &mut send_sig, &mut changes_dir, true)"},{"Add":" .await?;"},{"Add":" Ok::<_, anyhow::Error>(self_)"}],"del_contents":[{"Del":" while let Some(h) = recv_hash.recv().await {\n debug!(\"downloading full patch: {:?}\", h);\n"},{"Del":" self_\n .download_changes(&[h], &mut send_sig, &mut changes_dir, true)\n .await?;\n"},{"Del":" }\n"},{"Del":" let result: Result<_, anyhow::Error> = Ok(self_);\n result\n"}]}},{"Edit":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":599,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":76547}],"down_context":[{"change":3,"pos":76547}],"flag":"BLOCK","start":2283,"end":2347,"inode":{"change":3,"pos":52474}}},"contents":[{"Add":" debug!(\"could not find internal for {:?}\", sc);"}]}},{"Replacement":{"inode":{"change":3,"pos":52474},"path":"pijul/src/remote/mod.rs","line":609,"ins":{"up_context":[{"change":3,"pos":76925}],"down_context":[{"change":3,"pos":77531}],"flag":"BLOCK","start":2348,"end":2764,"inode":{"change":3,"pos":52474}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":76925},"to":{"change":3,"start":8315,"end":8360},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":8360},"to":{"change":3,"start":899,"end":942},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":9672},"to":{"change":3,"start":899,"end":942},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":899},"to":{"change":3,"start":899,"end":942},"introduced_by":3}],"inode":{"change":3,"pos":52474}},"ins_contents":[{"Add":" let graph = txn.graph(&channel);"},{"Add":" let mut it = txn.iter_graph(graph, Some(&v))?;"},{"Add":" while let Some(x) = txn.next_graph(&graph, &mut it) {"},{"Add":" let (v, e) = x?;"},{"Add":" if v.change > change {"},{"Add":" break;"},{"Add":" } else if e.flag().is_alive_parent() {"},{"Add":" send_hash.send(*c).await?;"},{"Add":" break;"},{"Add":" }"}],"del_contents":[{"Del":" if txn.is_alive(&channel, &v)? {\n"},{"Del":" send_hash.send(*c).await?;\n"}]}},{"Replacement":{"inode":{"change":3,"pos":79745},"path":"pijul/src/remote/local.rs","line":129,"ins":{"up_context":[{"change":3,"pos":83512}],"down_context":[{"change":3,"pos":11767}],"flag":"BLOCK","start":2765,"end":2841,"inode":{"change":3,"pos":79745}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":83512},"to":{"change":3,"start":11727,"end":11767},"introduced_by":3}],"inode":{"change":3,"pos":79745}},"ins_contents":[{"Add":" hashes: &mut tokio::sync::mpsc::Receiver,"}],"del_contents":[{"Del":" c: &[libpijul::pristine::Hash],\n"}]}},{"Replacement":{"inode":{"change":3,"pos":79745},"path":"pijul/src/remote/local.rs","line":133,"ins":{"up_context":[{"change":3,"pos":83607}],"down_context":[{"change":3,"pos":12057}],"flag":"BLOCK","start":2842,"end":3058,"inode":{"change":3,"pos":79745}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":83607},"to":{"change":3,"start":11872,"end":12057},"introduced_by":3}],"inode":{"change":3,"pos":79745}},"ins_contents":[{"Add":" while let Some(c) = hashes.recv().await {"},{"Add":" libpijul::changestore::filesystem::push_filename(&mut self.changes_dir, &c);"},{"Add":" libpijul::changestore::filesystem::push_filename(&mut path, &c);"}],"del_contents":[{"Del":" for c in c {\n libpijul::changestore::filesystem::push_filename(&mut self.changes_dir, c);\n libpijul::changestore::filesystem::push_filename(&mut path, c);\n"}]}},{"Replacement":{"inode":{"change":3,"pos":79745},"path":"pijul/src/remote/local.rs","line":149,"ins":{"up_context":[{"change":3,"pos":12700}],"down_context":[{"change":3,"pos":3741}],"flag":"BLOCK","start":3059,"end":3092,"inode":{"change":3,"pos":79745}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":12700},"to":{"change":3,"start":157,"end":191},"introduced_by":3}],"inode":{"change":3,"pos":79745}},"ins_contents":[{"Add":" send.send(c).await?;"}],"del_contents":[{"Del":" send.send(*c).await?;\n"}]}},{"Replacement":{"inode":{"change":3,"pos":10},"path":"pijul/src/remote/http.rs","line":74,"ins":{"up_context":[{"change":3,"pos":1135}],"down_context":[{"change":3,"pos":1180}],"flag":"BLOCK","start":3093,"end":3169,"inode":{"change":3,"pos":10}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1135},"to":{"change":3,"start":1135,"end":1180},"introduced_by":3}],"inode":{"change":3,"pos":10}},"ins_contents":[{"Add":" hashes: &mut tokio::sync::mpsc::Receiver,"}],"del_contents":[{"Del":" hashes: &[libpijul::pristine::Hash],\n"}]}},{"Replacement":{"inode":{"change":3,"pos":10},"path":"pijul/src/remote/http.rs","line":79,"ins":{"up_context":[{"change":3,"pos":1338}],"down_context":[{"change":3,"pos":1282}],"flag":"BLOCK","start":3170,"end":3221,"inode":{"change":3,"pos":10}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1338},"to":{"change":3,"start":1254,"end":1316},"introduced_by":3}],"inode":{"change":3,"pos":10}},"ins_contents":[{"Add":" let progress = ProgressBar::new(0 as u64);"}],"del_contents":[{"Del":" let progress = ProgressBar::new(hashes.len() as u64);\n"}]}},{"Replacement":{"inode":{"change":3,"pos":10},"path":"pijul/src/remote/http.rs","line":87,"ins":{"up_context":[{"change":3,"pos":1538}],"down_context":[{"change":3,"pos":322}],"flag":"BLOCK","start":3222,"end":3308,"inode":{"change":3,"pos":10}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":981},"to":{"change":3,"start":432,"end":458},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1338},"to":{"change":3,"start":432,"end":458},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1365},"to":{"change":3,"start":432,"end":458},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1448},"to":{"change":3,"start":432,"end":458},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":1538},"to":{"change":3,"start":432,"end":458},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":432},"to":{"change":3,"start":432,"end":458},"introduced_by":3}],"inode":{"change":3,"pos":10}},"ins_contents":[{"Add":" while let Some(c) = hashes.recv().await {"},{"Add":" progress.inc_length(1);"}],"del_contents":[{"Del":" for c in hashes {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":10},"path":"pijul/src/remote/http.rs","line":97,"ins":{"up_context":[{"change":3,"pos":1774}],"down_context":[{"change":3,"pos":1798}],"flag":"BLOCK","start":3309,"end":3332,"inode":{"change":3,"pos":10}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1774},"to":{"change":3,"start":1774,"end":1798},"introduced_by":3}],"inode":{"change":3,"pos":10}},"ins_contents":[{"Add":" c,"}],"del_contents":[{"Del":" *c,\n"}]}},{"Replacement":{"inode":{"change":3,"pos":531056},"path":"libpijul/src/pristine/sanakirja.rs","line":552,"ins":{"up_context":[{"change":3,"pos":38323}],"down_context":[{"change":3,"pos":38539}],"flag":"BLOCK","start":3333,"end":3663,"inode":{"change":3,"pos":531056}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":38323},"to":{"change":3,"start":38323,"end":38422},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":38422},"to":{"change":3,"start":69108,"end":69176},"introduced_by":3}],"inode":{"change":3,"pos":531056}},"ins_contents":[{"Add":" fn iter_graph("},{"Add":" &self,"},{"Add":" g: &Self::Graph,"},{"Add":" s: Option<&Vertex>,"},{"Add":" ) -> Result> {"},{"Add":" let mut c = ::sanakirja::btree::cursor::Cursor::new(&self.txn, &g)?;"},{"Add":" if let Some(s) = s {"},{"Add":" c.set(&self.txn, s, None)?;"},{"Add":" }"},{"Add":" Ok(c)"}],"del_contents":[{"Del":" fn iter_graph(&self, g: &Self::Graph) -> Result> {\n"},{"Del":" Ok(::sanakirja::btree::cursor::Cursor::new(&self.txn, &g)?)\n"}]}},{"Replacement":{"inode":{"change":3,"pos":531056},"path":"libpijul/src/pristine/sanakirja.rs","line":1643,"ins":{"up_context":[{"change":2,"pos":363}],"down_context":[{"change":2,"pos":445}],"flag":"BLOCK","start":3664,"end":3783,"inode":{"change":3,"pos":531056}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":363},"to":{"change":2,"start":363,"end":445},"introduced_by":2}],"inode":{"change":3,"pos":531056}},"ins_contents":[{"Add":" .map_err(|_| SanakirjaError::ChannelRc {"},{"Add":" c: name0.to_string(),"},{"Add":" })?"}],"del_contents":[{"Del":" .map_err(|_| SanakirjaError::ChannelRc { c: name0.to_string() })?\n"}]}},{"Replacement":{"inode":{"change":3,"pos":586748},"path":"libpijul/src/pristine/mod.rs","line":350,"ins":{"up_context":[{"change":3,"pos":51889}],"down_context":[{"change":3,"pos":102575}],"flag":"BLOCK","start":3784,"end":3943,"inode":{"change":3,"pos":586748}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":51889},"to":{"change":3,"start":51889,"end":51987},"introduced_by":3}],"inode":{"change":3,"pos":586748}},"ins_contents":[{"Add":" fn iter_graph("},{"Add":" &self,"},{"Add":" g: &Self::Graph,"},{"Add":" s: Option<&Vertex>,"},{"Add":" ) -> Result>;"}],"del_contents":[{"Del":" fn iter_graph(&self, g: &Self::Graph) -> Result>;\n"}]}},{"Replacement":{"inode":{"change":3,"pos":586748},"path":"libpijul/src/pristine/mod.rs","line":913,"ins":{"up_context":[{"change":3,"pos":17878}],"down_context":[{"change":3,"pos":45536}],"flag":"BLOCK","start":3944,"end":4006,"inode":{"change":3,"pos":586748}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":17878},"to":{"change":3,"start":54034,"end":54090},"introduced_by":3}],"inode":{"change":3,"pos":586748}},"ins_contents":[{"Add":" let mut cursor = txn.iter_graph(&channel, None).unwrap();"}],"del_contents":[{"Del":" let mut cursor = txn.iter_graph(&channel).unwrap();\n"}]}},{"Replacement":{"inode":{"change":3,"pos":586748},"path":"libpijul/src/pristine/mod.rs","line":961,"ins":{"up_context":[{"change":3,"pos":46782}],"down_context":[{"change":3,"pos":54329}],"flag":"BLOCK","start":4007,"end":4069,"inode":{"change":3,"pos":586748}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":46782},"to":{"change":3,"start":54273,"end":54329},"introduced_by":3}],"inode":{"change":3,"pos":586748}},"ins_contents":[{"Add":" let mut cursor = txn.iter_graph(&channel, None).unwrap();"}],"del_contents":[{"Del":" let mut cursor = txn.iter_graph(&channel).unwrap();\n"}]}},{"Edit":{"inode":{"change":3,"pos":648958},"path":"libpijul/src/pristine/edge.rs","line":53,"atom":{"NewVertex":{"up_context":[{"change":32,"pos":9044}],"down_context":[{"change":32,"pos":9044}],"flag":"BLOCK","start":4070,"end":4071,"inode":{"change":3,"pos":648958}}},"contents":[{"Add":""}]}},{"Edit":{"inode":{"change":3,"pos":648958},"path":"libpijul/src/pristine/edge.rs","line":55,"atom":{"NewVertex":{"up_context":[{"change":32,"pos":9058}],"down_context":[{"change":32,"pos":9058}],"flag":"BLOCK","start":4072,"end":4214,"inode":{"change":3,"pos":648958}}},"contents":[{"Add":" pub fn is_alive_parent(&self) -> bool {"},{"Add":" *self & (EdgeFlags::DELETED | EdgeFlags::PARENT) == EdgeFlags::PARENT"},{"Add":" }"},{"Add":" #[inline]"}]}}],"owner":"irevoire","repo":"pijul","token":"xJL0GlAF7pMzF0jhxNb4xNt8cCJFZ03S0cl7q7xWZxM=","login":null}

…

Dependencies

Change contents