{"header":{"message":"Pre-tags cleanup + fast Sanakirja","description":null,"timestamp":"2021-03-07T16:35:23.400583153Z","authors":[{"full_name":"Pierre-Étienne Meunier","name":"pmeunier"}]},"hash":"MFTN7GBWZNQAFHKER57MLZAJGVEAHV2GYAQN2QTDHTPCEURDVIGQC","authors":[],"deps":{"hashes":[["MFTN7GBWZNQAFHKER57MLZAJGVEAHV2GYAQN2QTDHTPCEURDVIGQC","Pre-tags cleanup + fast Sanakirja"],["AA",null],["ZBNKSYA6PW4DSPC3NCRUZLVHW2GNXMCSDSAGEIKHGHDGGZRBH7ZQC","Fixing a bus error when starting a transaction on a full disk"],["HDGRZISM2SS4TK5BMNGDIYG22SOXAZRTTC6YFIOPY4LSO53QDWZQC","Version updates"],["VO5OQW4W2656DIYYRNZ3PO7TQ4JOKQ3GVWE5ALUTYVMX3WMXJOYQC","Removing anyhow in libpijul"],["UFCZKKLXVYQYQBYENCAFHY3ZPPSDAJJAIREZSYNQM4QNXV6G6RXAC","Upgrading to the latest Sanakirja/Rand"],["H23LO7U7MNB5GTLOUIFYAJ6DP57DM3VFBR4IBOAVPMHS356AYFPQC","a few more clippy lints addressed"],["WI5BS6BSRA7T3BCDF6EGB2JZHTZRX4SLT5EG4D67PVRBTZH5YIXAC","New published versions"],["ZHABNS3S6FSINO74FOI5KHYXYDTBPO4FQTTYTUS7NNKEVVNLYC4AC","Canonicalize all paths"],["CCLLB7OIFNFYJZTG3UCI7536TOCWSCSXR67VELSB466R24WLJSDAC","Upgrading to Sanakirja 0.15 + version bump"],["YTQS4ES362EJ27OE45CE5HLY7ZU57YLVKRMDRJ2OXT623VM5WOBQC","Fixing a parsing problem (related to permissions), and the associated permissions"],["IIV3EL2XYI2X7HZWKXEXQFAE3R3KC2Q7SGOT3Q332HSENMYVF32QC","Cleanup, formatting, and fixing the Git feature"],["G6S6PWZEFJK7ARWBIFKDU6VYC5DCJ2YFJMWZOLLWWKU52R2QPXZAC","Do not touch the channel if this is a partial record"],["6DOXSHWGKJIMIPFCNLASGKBAJCJMJULW5HFRZAZ67EYSMXXGJ3KAC","Cleanup, and version bump"],["X243Z3Y54ULINQMMRIKLHRV5T237B7VUOAHVJ7DMPOQ6A6GQXY2AC","Recording only the required metadata (can even be changed later!)"],["7ZFRYVVQQGJYG3POPWJWL3CDW37YDXZYZQC3OSWFHWEUSEMYQ4EQC","Cargo.nix and formatting"],["GHO6DWPILBBTL6CVZKERJBTFL3EY6ZT4YM4E5R4S6YPGVFKFHCVAC","Refactoring iterators"],["33SQMZYXPV2A3F7P6WBFKFO2BTQV6THSQXOLV3PCZASC6OTKVHTQC","New versions of dependencies"],["3AMEP2Y5J6GA4AWQONF4JVA3XSR3ASLHHKMYG44R72SOUY3UQCDAC","More convenient interface for channels"],["A3DMBJJAPLS6ASSZ7JVVVULRQNZCF2WKYTRUD7EY7PKVYABSATFAC","Upgrading the `git` subcommand to the latest Sanakirja and Libpijul"],["JL4WKA5PBKXRNAMETYO4I52QKASQ3COYHH2JKGA7W5YLIRZZH53AC","Implement the Sanakirja concurrency model in a cross-process way"],["DJYHARZ7CSRMX6ZFM6P52SM2EC57VTSHWAIMFSD7Q3EL7UYZGLXQC","Skipping old files when recording"],["WZVCLZKY34KQBQU6YBGJLQCDADBQ67LQVDNRVCMQVY3O3C3EIWSQC","address clippy lints"],["B3QWIGDERNMB3M6P5WTWP5CN2DB3KCS7MVTEPC2XVJ237ZXVQGMAC","Fixing the Git features with the latest Pijul (+ conflicts in Cargo.toml)"],["PJ7T2VFLV5PYG3CV23GC2GIQETXKGC6CO74JBGREV3JC3LG5OXUAC","Do not hang on locked repositories"],["KUMJITTFBIAA7MFVPE6O7ZKIRSX553JNM72LF3KQJ6U3CXZI6MMQC","Version bump in the lockfiles"],["VE2UWMW42VWMOYZWJCJZBX4NYJO37E6WNISFBUXZFLQ5HWN3B4VQC","Trying to fix channel touch"],["G734WNM64AR5BLAZMN5MDPKSFTYXTUQR6MAGB32NRBC5FXFRWSJAC","flake.nix: use crate2nix"],["QQZNSB26UHFC4EFFREJX2J7SWAKCB3UAI6OKKIOZ4BLXBK6M54VAC","Permission update (after #X243)"],["Q7CAYX5N2GFOGMZL3VXVWORMAPWEOECXE22BLXK7Q4WEPS4CE2SAC","Fixing Windows compilation"],["YN63NUZO4LVJ7XPMURDULTXBVJKW5MVCTZ24R7Z52QMHO3HPDUVQC","Sanakirja 1.0"],["ERV3644QELKOHAVNMZGRWYCPPN3XELTAH4PPFR6QKGWW73XBOOKQC","Adding the block module"],["JRENVH5DF2F4SOV7UNJENFA7VDI3H63XK76R3LFZK6QCW7JIBLSQC","Reqwest 0.11"],["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","Fixing the bad changes in history (unfortunately, by rebooting)."],["G65S7FAW4OHBGC6ROVPPZ6PPACKOFEM4KSMAWMYKNQF5OLVDJR2QC","Version bump and cleanup"],["TPEH2XNBS5RO4IEVKENVF6P65AH7IX64KK2JAYMSJT3J5GXO67EAC","1.0.0-alpha.28, with Tokio 1.0"],["HKEOO4QJ5EACX37IJG76GEUMNSZMFW4VRKA4IVBCGR52ZQSYTN6QC","Version bump"],["VYHHOEYHO67JNJEODX5L3CQFIV3DAXZBBIQUOMCWJDYF3VWICDNQC","Versions and formatting"],["I52XSRUH5RVHQBFWVMAQPTUSPAJ4KNVID2RMI3UGCVKFLYUO6WZAC","Massive cleanup, and simplification"],["RXNT67OTDNFTBYXS6ECDAZ26PRTDROASNYTR6IEXYQUO4K5YNXYQC","Sanakirja version, and removing an unwrap"]],"deps":["ZBNKSYA6PW4DSPC3NCRUZLVHW2GNXMCSDSAGEIKHGHDGGZRBH7ZQC"],"known":["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","G734WNM64AR5BLAZMN5MDPKSFTYXTUQR6MAGB32NRBC5FXFRWSJAC","PJ7T2VFLV5PYG3CV23GC2GIQETXKGC6CO74JBGREV3JC3LG5OXUAC","Q7CAYX5N2GFOGMZL3VXVWORMAPWEOECXE22BLXK7Q4WEPS4CE2SAC","I52XSRUH5RVHQBFWVMAQPTUSPAJ4KNVID2RMI3UGCVKFLYUO6WZAC","ERV3644QELKOHAVNMZGRWYCPPN3XELTAH4PPFR6QKGWW73XBOOKQC","WI5BS6BSRA7T3BCDF6EGB2JZHTZRX4SLT5EG4D67PVRBTZH5YIXAC","H23LO7U7MNB5GTLOUIFYAJ6DP57DM3VFBR4IBOAVPMHS356AYFPQC","WZVCLZKY34KQBQU6YBGJLQCDADBQ67LQVDNRVCMQVY3O3C3EIWSQC","VO5OQW4W2656DIYYRNZ3PO7TQ4JOKQ3GVWE5ALUTYVMX3WMXJOYQC","ZHABNS3S6FSINO74FOI5KHYXYDTBPO4FQTTYTUS7NNKEVVNLYC4AC","UFCZKKLXVYQYQBYENCAFHY3ZPPSDAJJAIREZSYNQM4QNXV6G6RXAC","6DOXSHWGKJIMIPFCNLASGKBAJCJMJULW5HFRZAZ67EYSMXXGJ3KAC","CCLLB7OIFNFYJZTG3UCI7536TOCWSCSXR67VELSB466R24WLJSDAC","GHO6DWPILBBTL6CVZKERJBTFL3EY6ZT4YM4E5R4S6YPGVFKFHCVAC","TPEH2XNBS5RO4IEVKENVF6P65AH7IX64KK2JAYMSJT3J5GXO67EAC","KUMJITTFBIAA7MFVPE6O7ZKIRSX553JNM72LF3KQJ6U3CXZI6MMQC","A3DMBJJAPLS6ASSZ7JVVVULRQNZCF2WKYTRUD7EY7PKVYABSATFAC","B3QWIGDERNMB3M6P5WTWP5CN2DB3KCS7MVTEPC2XVJ237ZXVQGMAC","JRENVH5DF2F4SOV7UNJENFA7VDI3H63XK76R3LFZK6QCW7JIBLSQC","33SQMZYXPV2A3F7P6WBFKFO2BTQV6THSQXOLV3PCZASC6OTKVHTQC","HKEOO4QJ5EACX37IJG76GEUMNSZMFW4VRKA4IVBCGR52ZQSYTN6QC","DJYHARZ7CSRMX6ZFM6P52SM2EC57VTSHWAIMFSD7Q3EL7UYZGLXQC","G6S6PWZEFJK7ARWBIFKDU6VYC5DCJ2YFJMWZOLLWWKU52R2QPXZAC","3AMEP2Y5J6GA4AWQONF4JVA3XSR3ASLHHKMYG44R72SOUY3UQCDAC","VYHHOEYHO67JNJEODX5L3CQFIV3DAXZBBIQUOMCWJDYF3VWICDNQC","JL4WKA5PBKXRNAMETYO4I52QKASQ3COYHH2JKGA7W5YLIRZZH53AC","YN63NUZO4LVJ7XPMURDULTXBVJKW5MVCTZ24R7Z52QMHO3HPDUVQC","G65S7FAW4OHBGC6ROVPPZ6PPACKOFEM4KSMAWMYKNQF5OLVDJR2QC","IIV3EL2XYI2X7HZWKXEXQFAE3R3KC2Q7SGOT3Q332HSENMYVF32QC","7ZFRYVVQQGJYG3POPWJWL3CDW37YDXZYZQC3OSWFHWEUSEMYQ4EQC","X243Z3Y54ULINQMMRIKLHRV5T237B7VUOAHVJ7DMPOQ6A6GQXY2AC","QQZNSB26UHFC4EFFREJX2J7SWAKCB3UAI6OKKIOZ4BLXBK6M54VAC","HDGRZISM2SS4TK5BMNGDIYG22SOXAZRTTC6YFIOPY4LSO53QDWZQC","YTQS4ES362EJ27OE45CE5HLY7ZU57YLVKRMDRJ2OXT623VM5WOBQC","VE2UWMW42VWMOYZWJCJZBX4NYJO37E6WNISFBUXZFLQ5HWN3B4VQC","RXNT67OTDNFTBYXS6ECDAZ26PRTDROASNYTR6IEXYQUO4K5YNXYQC"]},"hunks":[{"Edit":{"inode":{"change":3,"pos":101759},"path":"pijul/src/commands/record.rs","line":154,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":105252},"to":{"change":3,"start":110,"end":298},"introduced_by":3}],"inode":{"change":3,"pos":101759}}},"contents":[{"Del":" let oldest = if let Ok(t) = oldest.duration_since(std::time::SystemTime::UNIX_EPOCH) {\n t.as_secs() as u64\n } else {\n 0\n };\n"}]}},{"Edit":{"inode":{"change":3,"pos":101759},"path":"pijul/src/commands/record.rs","line":156,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":82}],"down_context":[{"change":3,"pos":82}],"flag":"BLOCK","start":0,"end":699,"inode":{"change":3,"pos":101759}}},"contents":[{"Add":" let mut oldest = oldest"},{"Add":" .duration_since(std::time::SystemTime::UNIX_EPOCH)"},{"Add":" .unwrap()"},{"Add":" .as_secs() as u64;"},{"Add":" if oldest == 0 {"},{"Add":" // If no diff was done at all, it means that no"},{"Add":" // existing file changed since last time (some"},{"Add":" // files may have been added, deleted or moved,"},{"Add":" // but `touch` isn't about those)."},{"Add":" oldest = std::time::SystemTime::now()"},{"Add":" .duration_since(std::time::SystemTime::UNIX_EPOCH)"},{"Add":" .unwrap()"},{"Add":" .as_secs() as u64;"},{"Add":" }"}]}},{"Edit":{"inode":{"change":3,"pos":196374},"path":"pijul/Cargo.toml","line":37,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":197209},"to":{"change":3,"start":1996,"end":2059},"introduced_by":3}],"inode":{"change":3,"pos":196374}}},"contents":[{"Del":"\"src/repository/unix_lock.rs\",\n\"src/repository/basic_lock.rs\",\n"}]}},{"Replacement":{"inode":{"change":3,"pos":196374},"path":"pijul/Cargo.toml","line":68,"ins":{"up_context":[{"change":3,"pos":197874}],"down_context":[{"change":3,"pos":197895}],"flag":"BLOCK","start":700,"end":758,"inode":{"change":3,"pos":196374}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":197874},"to":{"change":2,"start":1141,"end":1199},"introduced_by":2}],"inode":{"change":3,"pos":196374}},"ins_contents":[{"Add":"sanakirja = { version = \"1.1.7\", features = [ \"crc32\" ] }"}],"del_contents":[{"Del":"sanakirja = { version = \"1.1.6\", features = [ \"crc32\" ] }\n"}]}},{"FileDel":{"deleted_names":[{"basename":"channel_dump.rs","metadata":0},{"basename":"channel_dump.rs","metadata":420}],"del":{"EdgeMap":{"edges":[{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":525229},"to":{"change":3,"start":1160,"end":1177},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":1177},"to":{"change":3,"start":650052,"end":650052},"introduced_by":3},{"previous":"BLOCK | FOLDER | DELETED","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":525229},"to":{"change":3,"start":650034,"end":650051},"introduced_by":3},{"previous":"BLOCK | FOLDER","flag":"BLOCK | FOLDER | DELETED","from":{"change":3,"pos":650051},"to":{"change":3,"start":650052,"end":650052},"introduced_by":3}],"inode":{"change":3,"pos":650052}}},"content_edges":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":650052},"to":{"change":3,"start":650053,"end":650093},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":19477},"to":{"change":3,"start":650093,"end":650094},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":650093},"to":{"change":3,"start":650093,"end":650094},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":650094},"to":{"change":3,"start":77766,"end":77789},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":77789},"to":{"change":3,"start":56412,"end":56497},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":56497},"to":{"change":3,"start":77862,"end":77903},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":77862},"to":{"change":3,"start":77862,"end":77903},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":77903},"to":{"change":3,"start":650167,"end":650408},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":650167},"to":{"change":3,"start":650167,"end":650408},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":650408},"to":{"change":3,"start":56498,"end":56530},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":56530},"to":{"change":3,"start":650495,"end":650588},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":650495},"to":{"change":3,"start":650495,"end":650588},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":650588},"to":{"change":3,"start":56531,"end":56616},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":56616},"to":{"change":3,"start":650608,"end":650645},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":77977},"to":{"change":3,"start":650608,"end":650645},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":650608},"to":{"change":3,"start":650608,"end":650645},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":650645},"to":{"change":3,"start":56617,"end":56662},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":56662},"to":{"change":3,"start":650707,"end":651272},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":650707},"to":{"change":3,"start":650707,"end":651272},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":651272},"to":{"change":3,"start":56663,"end":56752},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":56752},"to":{"change":3,"start":651296,"end":651345},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":78055},"to":{"change":3,"start":651296,"end":651345},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":651296},"to":{"change":3,"start":651296,"end":651345},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":651345},"to":{"change":3,"start":56753,"end":56802},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":56802},"to":{"change":3,"start":651411,"end":651454},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":651411},"to":{"change":3,"start":651411,"end":651454},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":651454},"to":{"change":3,"start":78056,"end":78114},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":78114},"to":{"change":3,"start":651481,"end":651789},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":651481},"to":{"change":3,"start":651481,"end":651789},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":651789},"to":{"change":3,"start":78115,"end":78364},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":78364},"to":{"change":3,"start":651854,"end":652501},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":651854},"to":{"change":3,"start":651854,"end":652501},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":652501},"to":{"change":3,"start":78365,"end":78431},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":78431},"to":{"change":3,"start":652563,"end":652611},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":652563},"to":{"change":3,"start":652563,"end":652611},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":652611},"to":{"change":3,"start":78432,"end":78872},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":78872},"to":{"change":3,"start":652750,"end":652955},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":652750},"to":{"change":3,"start":652750,"end":652955},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":652955},"to":{"change":3,"start":78873,"end":79079},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":79079},"to":{"change":3,"start":653024,"end":653253},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":653024},"to":{"change":3,"start":653024,"end":653253},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":653253},"to":{"change":3,"start":79080,"end":79143},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":79143},"to":{"change":3,"start":653312,"end":653409},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":653312},"to":{"change":3,"start":653312,"end":653409},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":653409},"to":{"change":3,"start":4073,"end":4168},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":4168},"to":{"change":3,"start":56892,"end":56936},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":56892},"to":{"change":3,"start":56892,"end":56936},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":56936},"to":{"change":3,"start":79278,"end":79372},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":79278},"to":{"change":3,"start":79278,"end":79372},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":79372},"to":{"change":3,"start":653681,"end":653890},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":653681},"to":{"change":3,"start":653681,"end":653890},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":653890},"to":{"change":3,"start":56937,"end":56969},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":56969},"to":{"change":3,"start":653921,"end":654008},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":653921},"to":{"change":3,"start":653921,"end":654008},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":654008},"to":{"change":3,"start":567,"end":740},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":740},"to":{"change":3,"start":79425,"end":79598},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":4272},"to":{"change":3,"start":79425,"end":79598},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":57067},"to":{"change":3,"start":79425,"end":79598},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":79425},"to":{"change":3,"start":79425,"end":79598},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":79598},"to":{"change":3,"start":654065,"end":654202},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":654065},"to":{"change":3,"start":654065,"end":654202},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":654202},"to":{"change":3,"start":57068,"end":57108},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":57108},"to":{"change":3,"start":654241,"end":655267},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":654241},"to":{"change":3,"start":654241,"end":655267},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":655267},"to":{"change":3,"start":57109,"end":57149},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":57149},"to":{"change":3,"start":655306,"end":655490},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":655306},"to":{"change":3,"start":655306,"end":655490},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":655490},"to":{"change":3,"start":79599,"end":79666},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":79666},"to":{"change":3,"start":655553,"end":656049},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":655553},"to":{"change":3,"start":655553,"end":656049},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":656049},"to":{"change":3,"start":57150,"end":57190},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":57190},"to":{"change":3,"start":656088,"end":656272},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":656088},"to":{"change":3,"start":656088,"end":656272},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":656272},"to":{"change":3,"start":79667,"end":79733},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":79733},"to":{"change":3,"start":656334,"end":656845},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":656334},"to":{"change":3,"start":656334,"end":656845},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":656845},"to":{"change":3,"start":79734,"end":79796},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":79796},"to":{"change":3,"start":656903,"end":657034},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":656903},"to":{"change":3,"start":656903,"end":657034},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657034},"to":{"change":3,"start":57191,"end":57276},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":57276},"to":{"change":3,"start":657054,"end":657099},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":79870},"to":{"change":3,"start":657054,"end":657099},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657054},"to":{"change":3,"start":657054,"end":657099},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657099},"to":{"change":3,"start":57277,"end":57322},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":57322},"to":{"change":3,"start":657161,"end":657193},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657161},"to":{"change":3,"start":657161,"end":657193},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657193},"to":{"change":3,"start":79871,"end":79952},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":79952},"to":{"change":3,"start":657240,"end":657288},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657240},"to":{"change":3,"start":657240,"end":657288},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657288},"to":{"change":3,"start":79953,"end":80015},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":55702},"to":{"change":3,"start":657352,"end":657455},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":80015},"to":{"change":3,"start":657352,"end":657455},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657352},"to":{"change":3,"start":657352,"end":657455},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657455},"to":{"change":3,"start":80016,"end":80023},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":80023},"to":{"change":3,"start":657461,"end":657464},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657461},"to":{"change":3,"start":657461,"end":657464},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657464},"to":{"change":3,"start":80024,"end":80076},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":80076},"to":{"change":3,"start":657516,"end":660741},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":657516},"to":{"change":3,"start":657516,"end":660741},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":660741},"to":{"change":3,"start":80077,"end":80201},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":80201},"to":{"change":3,"start":660794,"end":661301},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":660794},"to":{"change":3,"start":660794,"end":661301},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":661301},"to":{"change":3,"start":80202,"end":80284},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":19547},"to":{"change":3,"start":661375,"end":661853},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":80284},"to":{"change":3,"start":661375,"end":661853},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":661375},"to":{"change":3,"start":661375,"end":661853},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":661853},"to":{"change":3,"start":80285,"end":80351},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":80351},"to":{"change":3,"start":661918,"end":661958},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":661918},"to":{"change":3,"start":661918,"end":661958},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":661958},"to":{"change":3,"start":80352,"end":80422},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":55772},"to":{"change":3,"start":662026,"end":662172},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":80422},"to":{"change":3,"start":662026,"end":662172},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":662026},"to":{"change":3,"start":662026,"end":662172},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":662172},"to":{"change":3,"start":4273,"end":4335},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":4335},"to":{"change":3,"start":662223,"end":664478},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":57379},"to":{"change":3,"start":662223,"end":664478},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":662223},"to":{"change":3,"start":662223,"end":664478},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":664478},"to":{"change":3,"start":57380,"end":57486},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":57486},"to":{"change":3,"start":664555,"end":664926},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":664555},"to":{"change":3,"start":664555,"end":664926},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":664926},"to":{"change":3,"start":80423,"end":80468},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":80468},"to":{"change":3,"start":664964,"end":664981},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":664964},"to":{"change":3,"start":664964,"end":664981},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":664981},"to":{"change":3,"start":57487,"end":57517},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":57517},"to":{"change":3,"start":665011,"end":665110},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":665011},"to":{"change":3,"start":665011,"end":665110},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":665110},"to":{"change":3,"start":80469,"end":80510},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":19576},"to":{"change":3,"start":665143,"end":665380},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":80510},"to":{"change":3,"start":665143,"end":665380},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":665143},"to":{"change":3,"start":665143,"end":665380},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":665380},"to":{"change":3,"start":4744,"end":4767},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":4767},"to":{"change":3,"start":580,"end":617},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":665411},"to":{"change":3,"start":580,"end":617},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":617},"to":{"change":3,"start":665456,"end":665488},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":665456},"to":{"change":3,"start":665456,"end":665488},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":665488},"to":{"change":3,"start":57518,"end":57571},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":57571},"to":{"change":3,"start":665538,"end":666411},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":665538},"to":{"change":3,"start":665538,"end":666411},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":650093},"to":{"change":3,"start":19272,"end":19475},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":19475},"to":{"change":3,"start":77592,"end":77765},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":77765},"to":{"change":3,"start":19475,"end":19477},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":19475},"to":{"change":3,"start":19475,"end":19477},"introduced_by":3}],"inode":{"change":3,"pos":650052}},"content":[{"Del":"use super::*;\nuse byteorder::ByteOrder;\n"},{"Del":"\n"},{"Del":"enum DumpChannelState<\n"},{"Del":" T: ChannelTxnT + GraphIter + DepsTxnT::GraphError>,\n"},{"Del":" RT: std::ops::Deref,\n> {\n"},{"Del":" Changes {\n log: crate::pristine::Cursor,\n current: ChangeId,\n deps: Option>,\n },\n Graph {\n"},{"Del":" cursor: T::GraphCursor,\n"},{"Del":" current: Vertex,\n is_first: bool,\n },\n}\n\npub struct DumpChannel<\n"},{"Del":" T: ChannelTxnT + GraphIter + DepsTxnT::GraphError>,\n"},{"Del":" RT: std::ops::Deref,\n"},{"Del":" C: std::ops::Deref,\n"},{"Del":"> {\n state: Option>,\n txn: RT,\n channel: C,\n}\n\npub enum DumpChunk {\n Dep([u8; 9]),\n Hash([u8; 42]),\n Edge([u8; 50]),\n End([u8; 25]),\n}\n\nimpl std::ops::Deref for DumpChunk {\n type Target = [u8];\n fn deref(&self) -> &Self::Target {\n match *self {\n DumpChunk::Dep(ref h) => h,\n DumpChunk::Hash(ref h) => h,\n DumpChunk::Edge(ref e) => e,\n DumpChunk::End(ref e) => e,\n }\n }\n}\n\n#[repr(u8)]\nenum Msg {\n Hash = 253,\n Dep = 254,\n Vertex = 255,\n}\n\nimpl<\n"},{"Del":" T: ChannelTxnT + GraphIter + DepsTxnT::GraphError>,\n"},{"Del":" RT: std::ops::Deref + Clone,\n"},{"Del":" C: std::ops::Deref,\n"},{"Del":" > Iterator for DumpChannel\n{\n"},{"Del":" type Item = Result>;\n"},{"Del":" fn next(&mut self) -> Option {\n loop {\n match self.state.take() {\n Some(DumpChannelState::Changes {\n mut log,\n current,\n deps,\n }) => {\n if let Some(mut deps) = deps {\n"},{"Del":" while let Some(x) = deps.next() {\n let (h, dep) = match x {\n Ok(x) => x,\n Err(e) => return Some(Err(e)),\n };\n"},{"Del":" if h > current {\n break;\n } else if h < current {\n continue;\n }\n let mut msg = [Msg::Dep as u8; 9];\n byteorder::BigEndian::write_u64(&mut msg[1..], dep.0);\n self.state = Some(DumpChannelState::Changes {\n log,\n current,\n deps: Some(deps),\n });\n debug!(\"dep msg = {:?}\", msg);\n"},{"Del":" return Some(Ok(DumpChunk::Dep(msg)));\n"},{"Del":" }\n }\n"},{"Del":" if let Some(x) = log.next() {\n let (_, (h, _)) = match x {\n Ok(e) => e,\n Err(e) => return Some(Err(e)),\n };\n let deps = match T::iter_dep_ref(self.txn.clone(), h) {\n Ok(e) => Some(e),\n Err(e) => return Some(Err(e)),\n };\n"},{"Del":" self.state = Some(DumpChannelState::Changes {\n log,\n current: h,\n deps,\n });\n"},{"Del":" let ext = match self.txn.get_external(h) {\n Ok(ext) => ext.unwrap(),\n Err(e) => return Some(Err(e)),\n };\n"},{"Del":"\n let mut msg = [Msg::Hash as u8; 1 + 33 + 8];\n (&mut msg[1..34]).clone_from_slice(&ext.to_bytes()[..]);\n byteorder::BigEndian::write_u64(&mut msg[34..], h.0);\n"},{"Del":" return Some(Ok(DumpChunk::Hash(msg)));\n"},{"Del":" } else {\n self.state = Some(DumpChannelState::Graph {\n"},{"Del":" cursor: match self.txn.iter_graph(self.txn.graph(&self.channel)) {\n"},{"Del":" Ok(c) => c,\n"},{"Del":" Err(e) => return Some(Err(e)),\n },\n"},{"Del":" current: Vertex::ROOT,\n is_first: true,\n })\n }\n }\n Some(DumpChannelState::Graph {\n"},{"Del":" mut cursor,\n"},{"Del":" mut current,\n is_first,\n }) => {\n"},{"Del":" if let Some(x) = self\n .txn\n .next_graph(self.txn.graph(&self.channel), &mut cursor)\n {\n"},{"Del":" let (v, e) = match x {\n Err(e) => return Some(Err(e)),\n Ok(x) => x,\n };\n"},{"Del":" if !e.flag.contains(EdgeFlags::PARENT) {\n self.state = Some(DumpChannelState::Graph {\n"},{"Del":" cursor,\n"},{"Del":" current,\n is_first,\n });\n continue;\n }\n if v != current || is_first {\n let mut buf = [Msg::Vertex as u8; 50];\n byteorder::LittleEndian::write_u64(&mut buf[1..], v.change.0);\n byteorder::LittleEndian::write_u64(&mut buf[9..], v.start.0);\n byteorder::LittleEndian::write_u64(&mut buf[17..], v.end.0);\n current = v;\n buf[25] = e.flag.bits();\n byteorder::LittleEndian::write_u64(&mut buf[26..], e.dest.change.0);\n byteorder::LittleEndian::write_u64(&mut buf[34..], e.dest.pos.0);\n byteorder::LittleEndian::write_u64(&mut buf[42..], e.introduced_by.0);\n self.state = Some(DumpChannelState::Graph {\n"},{"Del":" cursor,\n"},{"Del":" current,\n is_first: false,\n });\n debug!(\"sending {:?}\", &buf[..]);\n"},{"Del":" return Some(Ok(DumpChunk::Edge(buf)));\n"},{"Del":" } else {\n let mut buf = [0; 25];\n buf[0] = e.flag.bits();\n byteorder::LittleEndian::write_u64(&mut buf[1..], e.dest.change.0);\n byteorder::LittleEndian::write_u64(&mut buf[9..], e.dest.pos.0);\n byteorder::LittleEndian::write_u64(&mut buf[17..], e.introduced_by.0);\n self.state = Some(DumpChannelState::Graph {\n"},{"Del":" cursor,\n"},{"Del":" current,\n is_first: false,\n });\n debug!(\"sending {:?}\", &buf[..]);\n"},{"Del":" return Some(Ok(DumpChunk::End(buf)));\n"},{"Del":" }\n } else {\n self.state = None;\n let mut buf = [Msg::Vertex as u8; 25];\n byteorder::LittleEndian::write_u64(&mut buf[1..], Vertex::BOTTOM.change.0);\n byteorder::LittleEndian::write_u64(&mut buf[9..], Vertex::BOTTOM.start.0);\n byteorder::LittleEndian::write_u64(&mut buf[17..], Vertex::BOTTOM.end.0);\n debug!(\"sending {:?}\", buf);\n"},{"Del":" return Some(Ok(DumpChunk::End(buf)));\n"},{"Del":" }\n }\n None => return None,\n }\n }\n }\n}\n\npub fn dump_channel<\n"},{"Del":" T: ChannelTxnT + GraphIter + DepsTxnT::GraphError>,\n"},{"Del":" RT: std::ops::Deref + Clone,\n"},{"Del":" C: std::ops::Deref,\n"},{"Del":">(\n txn: RT,\n channel: C,\n"},{"Del":") -> Result, TxnErr> {\n Ok(DumpChannel {\n"},{"Del":" state: Some(DumpChannelState::Changes {\n"},{"Del":" log: changeid_log_ref(txn.clone(), &channel, 0)?,\n"},{"Del":" current: ChangeId::ROOT,\n deps: None,\n }),\n txn,\n channel,\n"},{"Del":" })\n"},{"Del":"}\n\n"},{"Del":"pub struct ChannelFromDump<'a, T: ChannelMutTxnT> {\n"},{"Del":" txn: &'a mut T,\n channel: ChannelRef,\n buf: Buf,\n current: Vertex,\n reverses: Vec<(Vertex, Edge)>,\n starts: HashMap, ChangePosition>,\n current_changeid: Option,\n local_changeid: HashMap,\n pub alive: HashSet,\n}\n\n/// The following type does zero-copy buffering: if there are enough\n/// bytes in the part we just read, we just return these bytes. Else,\n/// we copy the bytes in cache, and complete the cache once we have\n/// enough bytes.\n///\n/// The size of the cache could be generic, but since edges and\n/// vertices take 25 bytes, hashes 33, and [u8; 33] doesn't implement\n/// AsMut<[u8]>, we just use a fixed-sized array of length 33.\npub struct Buf {\n /// Internal cache.\n buf: [u8; 68],\n /// Length of the internal cache that is currently used.\n buf_len: usize,\n /// Position in the last buffer that was read. The `read` method\n /// must be called with the same buffer until that method returns\n /// `None`.\n pos: usize,\n}\n\nimpl Buf {\n /// Create a new buffer.\n fn new() -> Self {\n Buf {\n buf: [0; 68],\n buf_len: 0,\n pos: 0,\n }\n }\n\n /// Read `wanted` number of bytes from `bytes` using the internal\n /// cache if needed. This method must be called with the same\n /// `bytes` buffer until it returns `None`.\n fn read<'a>(&'a mut self, bytes: &'a [u8], wanted: usize) -> Option<&'a [u8]> {\n trace!(\n \"bytes = {:?}, self.buf = {:?} {:?} {:?}\",\n bytes,\n &self.buf[..],\n self.buf_len,\n self.pos\n );\n assert!(wanted < self.buf.len());\n if self.buf_len > 0 {\n let needs = wanted - self.buf_len;\n if self.pos + needs > bytes.len() {\n // Not enough bytes to complete the internal buffer,\n // we need to save these extra bytes.\n let len = self.buf_len + bytes.len();\n (&mut self.buf[self.buf_len..len]).clone_from_slice(&bytes[self.pos..]);\n self.buf_len = len;\n self.pos = 0;\n None\n } else {\n // There are enough bytes, output them.\n (&mut self.buf[self.buf_len..wanted])\n .clone_from_slice(&bytes[self.pos..self.pos + needs]);\n self.buf_len = 0;\n self.pos += needs;\n Some(&self.buf[..wanted])\n }\n } else if bytes.len() - self.pos >= wanted {\n // The internal buffer is empty, and `bytes` is long enough.\n let buf = &bytes[self.pos..self.pos + wanted];\n self.pos += wanted;\n Some(buf)\n } else {\n // The internal buffer is empty and `bytes` is too short,\n // save the extra bytes.\n self.buf_len = bytes.len() - self.pos;\n (&mut self.buf[..self.buf_len]).clone_from_slice(&bytes[self.pos..]);\n self.pos = 0;\n None\n }\n }\n\n fn current<'a>(&self, bytes: &'a [u8]) -> Option<&'a u8> {\n // debug!(\"self.pos = {:?}\", self.pos);\n bytes.get(self.pos)\n }\n}\n\n"},{"Del":"impl<'a, T: ChannelMutTxnT + DepsMutTxnT + DepsTxnT::GraphError>>\n ChannelFromDump<'a, T>\n{\n"},{"Del":" pub fn new(txn: &'a mut T, channel: ChannelRef) -> Self {\n let mut starts = HashMap::with_capacity(4096);\n starts.insert(Position::ROOT, Position::ROOT.pos);\n ChannelFromDump {\n txn,\n channel,\n buf: Buf::new(),\n current: Vertex::ROOT,\n reverses: Vec::with_capacity(4096),\n starts,\n current_changeid: None,\n local_changeid: HashMap::new(),\n alive: HashSet::new(),\n }\n }\n\n"},{"Del":" pub fn read(&mut self, bytes: &[u8]) -> Result> {\n"},{"Del":" let mut channel = self.channel.borrow_mut();\n while let Some(&cur) = self.buf.current(bytes) {\n debug!(\"cur = {:?}\", cur);\n if cur == Msg::Hash as u8 {\n if let Some(buf) = self.buf.read(bytes, 42) {\n let hash = Hash::from_bytes(&buf[1..34]).unwrap();\n let mut p = ChangeId(byteorder::BigEndian::read_u64(&buf[34..]));\n // Test if `p` is already taken for another hash.\n"},{"Del":" if let Some(hh) = self.txn.get_external(p)? {\n"},{"Del":" if hh != hash {\n"},{"Del":" let pp = make_changeid(self.txn, &hash)?;\n"},{"Del":" self.local_changeid.insert(p, pp);\n p = pp\n }\n }\n"},{"Del":" let t = self.txn.apply_counter(&channel);\n"},{"Del":" debug!(\"hash = {:?} {:?}\", hash, p);\n self.txn.put_external(p, hash)?;\n self.txn.put_internal(hash, p)?;\n self.txn.put_changes(&mut channel, p, t, &hash)?;\n self.current_changeid = Some(p);\n }\n } else if cur == Msg::Dep as u8 {\n debug!(\"dep\");\n if let Some(buf) = self.buf.read(bytes, 9) {\n let mut a = ChangeId(byteorder::BigEndian::read_u64(&buf[1..9]));\n if let Some(aa) = self.local_changeid.get(&a) {\n a = *aa\n }\n if let Some(cur) = self.current_changeid {\n self.txn.put_dep(cur, a)?;\n self.txn.put_revdep(a, cur)?;\n }\n debug!(\"cur = {:?}, a = {:?}\", self.current_changeid, a);\n }\n } else if cur == Msg::Vertex as u8 {\n // New vertex\n if let Some(buf) = self.buf.read(bytes, 25) {\n self.current = read_vertex(buf);\n debug!(\"new vertex {:?}\", self.current);\n if self.current == Vertex::BOTTOM {\n finish_channel(self.txn, &mut channel, &self.reverses, &self.starts)?;\n return Ok(true);\n }\n if let Some(aa) = self.local_changeid.get(&self.current.change) {\n self.current.change = *aa\n }\n } else {\n break;\n }\n } else if let Some(buf) = self.buf.read(bytes, 25) {\n // Edge\n let mut edge = read_edge(buf);\n if let Some(aa) = self.local_changeid.get(&edge.dest.change) {\n edge.dest.change = *aa\n }\n if let Some(aa) = self.local_changeid.get(&edge.introduced_by) {\n edge.introduced_by = *aa\n }\n if !edge.flag.contains(EdgeFlags::DELETED) {\n self.alive.insert(edge.dest.change);\n }\n debug!(\"put edge {:?} {:?}\", self.current, edge);\n"},{"Del":" self.txn\n .put_graph(T::graph_mut(&mut channel), self.current, edge)?;\n"},{"Del":" self.reverses.push((self.current, edge));\n self.starts\n .insert(self.current.end_pos(), self.current.start);\n } else {\n break;\n }\n }\n self.buf.pos = 0;\n Ok(false)\n }\n\n pub fn edges(&self) -> &[(Vertex, Edge)] {\n &self.reverses[..]\n }\n}\n\n"},{"Del":"fn finish_channel(\n"},{"Del":" txn: &mut T,\n"},{"Del":" channel: &mut T::Channel,\n"},{"Del":" reverses: &[(Vertex, Edge)],\n ends: &HashMap, ChangePosition>,\n"},{"Del":") -> Result<(), TxnErr> {\n"},{"Del":" debug!(\"ends: {:?}\", ends);\n for &(v, e) in reverses {\n debug!(\"{:?}\", e);\n let u = Vertex {\n change: e.dest.change,\n start: *ends.get(&e.dest).unwrap(),\n end: e.dest.pos,\n };\n"},{"Del":" let mut e = e;\n"},{"Del":" e.flag ^= EdgeFlags::PARENT;\n"},{"Del":" e.dest = v.start_pos();\n"},{"Del":" txn.put_graph(T::graph_mut(channel), u, e)?;\n"},{"Del":" }\n Ok(())\n}\n\nfn read_vertex(bytes: &[u8]) -> Vertex {\n let change = byteorder::LittleEndian::read_u64(&bytes[1..]);\n let start = byteorder::LittleEndian::read_u64(&bytes[9..]);\n let end = byteorder::LittleEndian::read_u64(&bytes[17..]);\n Vertex {\n change: ChangeId(change),\n start: ChangePosition(start),\n end: ChangePosition(end),\n }\n}\n\nfn read_edge(bytes: &[u8]) -> Edge {\n let flag = EdgeFlags::from_bits(bytes[0]).unwrap();\n let change = byteorder::LittleEndian::read_u64(&bytes[1..]);\n let p = byteorder::LittleEndian::read_u64(&bytes[9..]);\n let introduced_by = byteorder::LittleEndian::read_u64(&bytes[17..]);\n Edge {\n flag,\n dest: Position {\n change: ChangeId(change),\n pos: ChangePosition(p),\n },\n introduced_by: ChangeId(introduced_by),\n }\n}\n"},{"Del":"\n#[derive(Debug, Error)]\npub enum ChannelDumpError {\n #[error(transparent)]\n Txn(T),\n #[error(\"Channel name already exists: {0}\")]\n ChannelNameExists(String),\n"},{"Del":"}\n\nimpl std::convert::From> for ChannelDumpError {\n fn from(e: TxnErr) -> Self {\n ChannelDumpError::Txn(e.0)\n }\n"},{"Del":"}\n"}]}},{"Edit":{"inode":{"change":3,"pos":586748},"path":"libpijul/src/pristine/mod.rs","line":24,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":587220},"to":{"change":3,"start":98621,"end":98674},"introduced_by":3}],"inode":{"change":3,"pos":586748}}},"contents":[{"Del":"// #[cfg(feature = \"dump\")]\n// pub mod channel_dump;\n"}]}},{"Edit":{"inode":{"change":3,"pos":1020742},"path":"libpijul/Cargo.toml","line":48,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1021836},"to":{"change":3,"start":1021836,"end":1021868},"introduced_by":3}],"inode":{"change":3,"pos":1020742}}},"contents":[{"Del":"\"src/pristine/channel_dump.rs\",\n"}]}},{"Replacement":{"inode":{"change":3,"pos":1020742},"path":"libpijul/Cargo.toml","line":97,"ins":{"up_context":[{"change":3,"pos":1022980}],"down_context":[{"change":3,"pos":1023001}],"flag":"BLOCK","start":759,"end":817,"inode":{"change":3,"pos":1020742}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1022980},"to":{"change":2,"start":3621,"end":3679},"introduced_by":2}],"inode":{"change":3,"pos":1020742}},"ins_contents":[{"Add":"sanakirja = { version = \"1.1.7\", features = [ \"crc32\" ] }"}],"del_contents":[{"Del":"sanakirja = { version = \"1.1.6\", features = [ \"crc32\" ] }\n"}]}},{"Replacement":{"inode":{"change":3,"pos":12},"path":"Cargo.nix","line":4561,"ins":{"up_context":[{"change":3,"pos":144463}],"down_context":[{"change":3,"pos":144491}],"flag":"BLOCK","start":818,"end":845,"inode":{"change":3,"pos":12}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":144463},"to":{"change":2,"start":3680,"end":3707},"introduced_by":2}],"inode":{"change":3,"pos":12}},"ins_contents":[{"Add":" version = \"1.1.7\";"}],"del_contents":[{"Del":" version = \"1.1.6\";\n"}]}},{"Replacement":{"inode":{"change":3,"pos":12},"path":"Cargo.nix","line":4563,"ins":{"up_context":[{"change":3,"pos":144517}],"down_context":[{"change":3,"pos":144590}],"flag":"BLOCK","start":846,"end":919,"inode":{"change":3,"pos":12}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":144517},"to":{"change":2,"start":3708,"end":3781},"introduced_by":2}],"inode":{"change":3,"pos":12}},"ins_contents":[{"Add":" sha256 = \"1v73b74y36jyqjab2qmycchbqkkg4flwybzwij2v7lazc77qfbgi\";"}],"del_contents":[{"Del":" sha256 = \"0vpannz78bnayw7874jdymsz3rz6l1liy6vxcaxdd7bykkhwh1s5\";\n"}]}},{"Replacement":{"inode":{"change":3,"pos":1030385},"path":"Cargo.lock","line":1587,"ins":{"up_context":[{"change":3,"pos":1072132}],"down_context":[{"change":3,"pos":1072151}],"flag":"BLOCK","start":920,"end":938,"inode":{"change":3,"pos":1030385}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1072132},"to":{"change":2,"start":3782,"end":3800},"introduced_by":2}],"inode":{"change":3,"pos":1030385}},"ins_contents":[{"Add":"version = \"1.1.7\""}],"del_contents":[{"Del":"version = \"1.1.6\"\n"}]}},{"Replacement":{"inode":{"change":3,"pos":1030385},"path":"Cargo.lock","line":1589,"ins":{"up_context":[{"change":3,"pos":1072216}],"down_context":[{"change":3,"pos":1072294}],"flag":"BLOCK","start":939,"end":1017,"inode":{"change":3,"pos":1030385}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1072216},"to":{"change":2,"start":3801,"end":3879},"introduced_by":2}],"inode":{"change":3,"pos":1030385}},"ins_contents":[{"Add":"checksum = \"f12d87cf615fd1b3858cfc2fcfa9236f4ebc2063be62b194c45e9ae1c959e3ec\""}],"del_contents":[{"Del":"checksum = \"4507c8e19c7e9dd6ba627d1b1f69a0e6e7f175f54d92830ef7ca2e74beb5ea6e\"\n"}]}}],"owner":"irevoire","repo":"pijul","token":"8pA8FlAeF3Di7Y410HoTIzPMXeh2PsTQ6OHnQfm5L40=","login":null}

…

Dependencies

Change contents