{"header":{"message":"Proofreading and commenting of this crate (massive bug fixes included)","description":null,"timestamp":"2021-02-20T21:55:56.103460095Z","authors":[{"full_name":"Pierre-Étienne Meunier","name":"pmeunier"}]},"hash":"E4MD6T3LNOYWVFTFFWCUKRNS4M2XVSKRLDWPYHMZHGDNO2T5JREQC","authors":[],"deps":{"hashes":[["E4MD6T3LNOYWVFTFFWCUKRNS4M2XVSKRLDWPYHMZHGDNO2T5JREQC","Proofreading and commenting of this crate (massive bug fixes included)"],["AA",null],["TSMS6W4DOKQNUQ4PEMTLOIODR33VFPN6MMNS73ZPSU4BOQVRGPNAC","Fully commented implementation of Sized nodes + massive cleanup"],["W2MIZD5BNL7A5HVFWTESF57QU7T6QMEF4RBSLFQXMEEU3XD2NU2QC","Single file databases + CRC for the root pages (checking the other pages makes everything very slow)"],["6DMPXOAT5GQ3BQQOMUZN2GMBQPRA4IB7CCPHTQTIFGO3KWWAKF3QC","More debugging"],["S4V4QZ5CF5LUDYWNR2UMWH6CHJDJ5FPGAZCQYM5GY7FJMJV4NN4QC","Debugging reference-counting for put"],["G4JEQLLX6Q7VVFVAEJZAVQXX33MQ36CSCYSMJ5NQM5VZ76DXKU6QC","Debugging synchronisation"],["KMT3MF5NLEQIPZLHCRYDGQ5EA46HJCG3C2ANEPMZGKGHDK77ADPAC","Drop a database"],["WS4ZQM4RMIHZ6XZKSDQJGHN5SSSWFL4H236USOPUA33S6RC53RFAC","Debugging, tests, etc."],["X3QVVQIS7B7L3XYZAWL3OOBUXOJ6RMOKQ45YMLLGAHYPEEKZ45ZAC","More debugging (del seems to work now)"],["YWFYZNLZ5JHLIFVBRKZK4TSWVPROUPRG77ZB5M7UHT2OKPL4ZSRQC","Cleanup + inter-process concurrency"],["OP6SVMOD2GTQ7VNJ4E5KYFG4MIYA7HBMXJTADALMZH4PY7OQRMZQC","Resetting history"],["UAQX27N4PI4LHEW6LSHJETIE5MV7JTEMPLTJFYUBMYVPC43H7VOAC","Tests"],["SO25TWFLSRQIVTJTTSN77LO5FZQVQPIZTSBULH7MWBBDEWSK3OCAC","A few features for integrating it into Pijul"],["EYNN7RLSFVBWDLRTLNNFUAF46Q6OX3BR5SUEJIOOHBSNP7FVBXGAC","Tests++ (including UUID)"],["T7QB6QEPWBXAU3RL7LE4GRDWWNQ65ZU2YNNTWBYLORJOABAQFEZQC","Adding debug.rs"],["XEU2QVLCHPYOOD4TQIPEEVYOVSFMKFPLJYWEJYXYJAZ7S54KWDZAC","Debugging after plugging this into Pijul"],["LSQ6V7M66TEGLJ7QBLRVDX4E7UKJTDQTEXZOS3KGPGFKVXNLPKBQC","Cleanup + docs"],["OHUZ73MKWD7SSB4DKKA532DEQKXQDS6PZ6HJ3EC2DLVJSLQH3NLAC","Versions"],["OTWDDJE7TTE73D6BGF4ZN6BH2NFUFLPME2VJ3CPALH463UGWLEIQC","Trait/type cleanup"],["KM3JAFGPFV7MP7M2LJIYRVAUTU646B3IRXADTRZKOU2RF7LUB62QC","Adding a test for next/prev"],["6UVFCERMGSGNRWCVC3GWO5HWV6MSWE433DXBJVC7KRPP6LLJLCSQC","Formatting, debugging, etc."],["H3FVSQIQGFCFKCPXVOSFHP4OSUOBBURJESCZNGQTNDAAD3WQSBEQC","Unsized pages"],["LROAI3NBBSCU4T2YA6EHJYKKKL75AU5A7C7WIRCGIQ56S6HPLRXQC","Two iterators (convenience functions), along with tests to move cursors (put and del still destroy cursors though)"],["HN6Z5DU4WYMAIOOSNVHLIIMNF6Q53TNJ7YC27SLKWNXVYCTACQKQC","Cleanup"],["MSRWB47YP6L5BVTS53QQPBOHY5SXTSTR5KD6IIF35UWCTEUOCQWQC","Deletions at immutable leaves weren't really deleting anything"],["6DCQHIFPEH4GZKSRRS32GMKDRPZH4MTCGOUEI7YEUVKWENBF3JWAC","Minor changes after benchmarking"],["EAAYH6BQWDK52EC5RG3BEZQU3FJPN5RRRN4U5KDKDVPKXBVJMNDAC","Debugging put"],["AOX2XQISHGWNNAFBYRN44Q6AWG7H5DPBK5YMFHK42HQNZ2TMHEJQC","Actually, with the correct functions, Unsized pages are always slower than Sized pages (especially for writing)"],["UUUVNC4DWEEL7WV5IRPKPZ6HZMYCPA53XM7LJWICUD4E6GN37IRQC","Debugging/cleanup around cursors"],["NXMFNPZ7VWJRLC3M5QJJVTICXCMGE24F3HVIZA7A7RLVMLQMLDVQC","Comments + debugging drop"],["OFINGD26ZWCRDVVDI2ZIBLMHXKEMJA6MRNLANJYUHQPIJLPA7J2AC","implementing prev() on cursors (+ some cleanup)"],["AFKBHYVE25QMIU2WZATEGWG2EXSBQZ44DVDPACKNS3M4QGBF4ONAC","Comparing the two implementations of leaves (sized/unsized). Sized are faster for writes, slower for reads."],["Q7DRIBBRE4MNG4NP3PVIXAJF5PQYLFWYIVK2O4VVLEO6XY3BOSFQC","Debugging replace (which cannot be del+put)"],["KX3WVNZW5KHVEH6EOQTZ4RBEFFJ3SGF5I467X3JWZ74PURRK4HVAC","Testing/debugging \"rebalance causes split of the root\""],["YXKP4AIWDBIWBBUDWF66YIPG5ECMHNKEV3PX6KYXOVXY3EWG3WGQC","New file locks, with multiple sets of free pages"],["52X5P7NDBQHIJDIYNY3XUPDHHOO3PDPPNKGO2PGLXKVNM3EVECTQC","Cleaning up the unsized part"],["QYDGYIZRNFRIQD7RUCY5YAN3F2THZA74E5UOHPIFWSULEJFAFVJQC","Split trait Representable into its mandatory part and an optional part"],["ONES3V466GLO5CXKRF5ENK7VFOQPWM3YXLVRGWB56V5SH3W7XNBQC","reference counting works for put"]],"deps":["TSMS6W4DOKQNUQ4PEMTLOIODR33VFPN6MMNS73ZPSU4BOQVRGPNAC","W2MIZD5BNL7A5HVFWTESF57QU7T6QMEF4RBSLFQXMEEU3XD2NU2QC"],"known":["OP6SVMOD2GTQ7VNJ4E5KYFG4MIYA7HBMXJTADALMZH4PY7OQRMZQC","WS4ZQM4RMIHZ6XZKSDQJGHN5SSSWFL4H236USOPUA33S6RC53RFAC","EAAYH6BQWDK52EC5RG3BEZQU3FJPN5RRRN4U5KDKDVPKXBVJMNDAC","ONES3V466GLO5CXKRF5ENK7VFOQPWM3YXLVRGWB56V5SH3W7XNBQC","UAQX27N4PI4LHEW6LSHJETIE5MV7JTEMPLTJFYUBMYVPC43H7VOAC","X3QVVQIS7B7L3XYZAWL3OOBUXOJ6RMOKQ45YMLLGAHYPEEKZ45ZAC","YXKP4AIWDBIWBBUDWF66YIPG5ECMHNKEV3PX6KYXOVXY3EWG3WGQC","YWFYZNLZ5JHLIFVBRKZK4TSWVPROUPRG77ZB5M7UHT2OKPL4ZSRQC","6DMPXOAT5GQ3BQQOMUZN2GMBQPRA4IB7CCPHTQTIFGO3KWWAKF3QC","S4V4QZ5CF5LUDYWNR2UMWH6CHJDJ5FPGAZCQYM5GY7FJMJV4NN4QC","OTWDDJE7TTE73D6BGF4ZN6BH2NFUFLPME2VJ3CPALH463UGWLEIQC","H3FVSQIQGFCFKCPXVOSFHP4OSUOBBURJESCZNGQTNDAAD3WQSBEQC","6UVFCERMGSGNRWCVC3GWO5HWV6MSWE433DXBJVC7KRPP6LLJLCSQC","AFKBHYVE25QMIU2WZATEGWG2EXSBQZ44DVDPACKNS3M4QGBF4ONAC","AOX2XQISHGWNNAFBYRN44Q6AWG7H5DPBK5YMFHK42HQNZ2TMHEJQC","G4JEQLLX6Q7VVFVAEJZAVQXX33MQ36CSCYSMJ5NQM5VZ76DXKU6QC","KMT3MF5NLEQIPZLHCRYDGQ5EA46HJCG3C2ANEPMZGKGHDK77ADPAC","UUUVNC4DWEEL7WV5IRPKPZ6HZMYCPA53XM7LJWICUD4E6GN37IRQC","6DCQHIFPEH4GZKSRRS32GMKDRPZH4MTCGOUEI7YEUVKWENBF3JWAC","T7QB6QEPWBXAU3RL7LE4GRDWWNQ65ZU2YNNTWBYLORJOABAQFEZQC","KX3WVNZW5KHVEH6EOQTZ4RBEFFJ3SGF5I467X3JWZ74PURRK4HVAC","SO25TWFLSRQIVTJTTSN77LO5FZQVQPIZTSBULH7MWBBDEWSK3OCAC","EYNN7RLSFVBWDLRTLNNFUAF46Q6OX3BR5SUEJIOOHBSNP7FVBXGAC","OFINGD26ZWCRDVVDI2ZIBLMHXKEMJA6MRNLANJYUHQPIJLPA7J2AC","KM3JAFGPFV7MP7M2LJIYRVAUTU646B3IRXADTRZKOU2RF7LUB62QC","LROAI3NBBSCU4T2YA6EHJYKKKL75AU5A7C7WIRCGIQ56S6HPLRXQC","XEU2QVLCHPYOOD4TQIPEEVYOVSFMKFPLJYWEJYXYJAZ7S54KWDZAC","MSRWB47YP6L5BVTS53QQPBOHY5SXTSTR5KD6IIF35UWCTEUOCQWQC","Q7DRIBBRE4MNG4NP3PVIXAJF5PQYLFWYIVK2O4VVLEO6XY3BOSFQC","NXMFNPZ7VWJRLC3M5QJJVTICXCMGE24F3HVIZA7A7RLVMLQMLDVQC","HN6Z5DU4WYMAIOOSNVHLIIMNF6Q53TNJ7YC27SLKWNXVYCTACQKQC","LSQ6V7M66TEGLJ7QBLRVDX4E7UKJTDQTEXZOS3KGPGFKVXNLPKBQC","QYDGYIZRNFRIQD7RUCY5YAN3F2THZA74E5UOHPIFWSULEJFAFVJQC","52X5P7NDBQHIJDIYNY3XUPDHHOO3PDPPNKGO2PGLXKVNM3EVECTQC","OHUZ73MKWD7SSB4DKKA532DEQKXQDS6PZ6HJ3EC2DLVJSLQH3NLAC"]},"hunks":[{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":98,"ins":{"up_context":[{"change":4,"pos":25811}],"down_context":[{"change":4,"pos":4616}],"flag":"BLOCK","start":0,"end":27,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":25811},"to":{"change":4,"start":577,"end":608},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let n = 10_000_000u64;"}],"del_contents":[{"Del":" let n = 10_000_000 as u64;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":115,"ins":{"up_context":[{"change":4,"pos":947}],"down_context":[{"change":4,"pos":977}],"flag":"BLOCK","start":28,"end":54,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":947},"to":{"change":4,"start":947,"end":977},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let n = 1_000_000u64;"}],"del_contents":[{"Del":" let n = 1_000_000 as u64;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":128,"ins":{"up_context":[{"change":4,"pos":25872}],"down_context":[{"change":4,"pos":5256}],"flag":"BLOCK","start":55,"end":79,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":1433},"to":{"change":4,"start":5228,"end":5256},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":25872},"to":{"change":4,"start":5228,"end":5256},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5228},"to":{"change":4,"start":5228,"end":5256},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let n = 100_000u64;"}],"del_contents":[{"Del":" let n = 100_000 as u64;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":157,"ins":{"up_context":[{"change":4,"pos":25933}],"down_context":[{"change":4,"pos":9230}],"flag":"BLOCK","start":80,"end":102,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":1550},"to":{"change":4,"start":9160,"end":9186},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":25933},"to":{"change":4,"start":9160,"end":9186},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":9160},"to":{"change":4,"start":9160,"end":9186},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let n = 2_000u64;"}],"del_contents":[{"Del":" let n = 2_000 as u64;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":175,"ins":{"up_context":[{"change":4,"pos":443}],"down_context":[{"change":4,"pos":10810}],"flag":"BLOCK","start":103,"end":142,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":443},"to":{"change":4,"start":443,"end":490},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let n = 20u64;"},{"Add":" let i0 = 10u64;"}],"del_contents":[{"Del":" let n = 20 as u64;\n let i0 = 10 as u64;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":187,"ins":{"up_context":[{"change":4,"pos":11108}],"down_context":[{"change":4,"pos":11145}],"flag":"BLOCK","start":143,"end":173,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":11108},"to":{"change":4,"start":11108,"end":11145},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" iter(&txn, &db, None)"}],"del_contents":[{"Del":" btree::iter(&txn, &db, None)\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":201,"ins":{"up_context":[{"change":4,"pos":11504}],"down_context":[{"change":4,"pos":490}],"flag":"BLOCK","start":174,"end":215,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":11504},"to":{"change":4,"start":13228,"end":13252},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":13252},"to":{"change":4,"start":11528,"end":11553},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":11528},"to":{"change":4,"start":11528,"end":11553},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let n = 256u64;"},{"Add":" let i0 = 127u64;"}],"del_contents":[{"Del":" let n = 256 as u64;\n"},{"Del":" let i0 = 127 as u64;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":223,"ins":{"up_context":[{"change":4,"pos":788}],"down_context":[{"change":4,"pos":825}],"flag":"BLOCK","start":216,"end":246,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":788},"to":{"change":4,"start":788,"end":825},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" iter(&txn, &db, None)"}],"del_contents":[{"Del":" btree::iter(&txn, &db, None)\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":239,"ins":{"up_context":[{"change":4,"pos":25993}],"down_context":[{"change":4,"pos":6021}],"flag":"BLOCK","start":247,"end":266,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":25993},"to":{"change":4,"start":21018,"end":21041},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let n = 19u64;"}],"del_contents":[{"Del":" let n = 19 as u64;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":335,"ins":{"up_context":[{"change":4,"pos":7597}],"down_context":[{"change":4,"pos":7693}],"flag":"BLOCK","start":267,"end":359,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":7597},"to":{"change":4,"start":15246,"end":15365},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let mut curs: Cursor<_, _, B> = btree::cursor::Cursor::new(txn, &db_free).unwrap();"}],"del_contents":[{"Del":" let mut curs: btree::cursor::Cursor<_, _, B> =\n btree::cursor::Cursor::new(txn, &db_free).unwrap();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":387,"ins":{"up_context":[{"change":4,"pos":835}],"down_context":[{"change":4,"pos":880}],"flag":"BLOCK","start":360,"end":401,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":835},"to":{"change":4,"start":835,"end":880},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let child = unsafe { libc::fork() };"}],"del_contents":[{"Del":" let mut child = unsafe { libc::fork() };\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":391,"ins":{"up_context":[{"change":4,"pos":918}],"down_context":[{"change":4,"pos":988}],"flag":"BLOCK","start":402,"end":475,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":918},"to":{"change":4,"start":918,"end":988},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let env = Env::new(\"/tmp/sanakirja0/db\", 4096 * 20, 2).unwrap();"}],"del_contents":[{"Del":" let env = Env::new(\"/tmp/sanakirja0\", 4096 * 20, 2).unwrap();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":395,"ins":{"up_context":[{"change":4,"pos":1069}],"down_context":[{"change":4,"pos":1139}],"flag":"BLOCK","start":476,"end":570,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1069},"to":{"change":4,"start":1069,"end":1139},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" info!(\"started child mutable txn {:?}\", txn.root);"},{"Add":""},{"Add":" assert_eq!(txn.root, 0);"},{"Add":""}],"del_contents":[{"Del":" info!(\"started child mutable txn {:?}\", txn.env.root.lock());\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":402,"ins":{"up_context":[{"change":4,"pos":15688}],"down_context":[{"change":4,"pos":1360}],"flag":"BLOCK","start":571,"end":638,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":15688},"to":{"change":4,"start":1297,"end":1360},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1297},"to":{"change":4,"start":1297,"end":1360},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" std::thread::sleep(std::time::Duration::from_millis(200));"}],"del_contents":[{"Del":" std::thread::sleep(std::time::Duration::from_secs(2));\n"}]}},{"Edit":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":407,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1522}],"down_context":[{"change":4,"pos":1522}],"flag":"BLOCK","start":639,"end":674,"inode":{"change":4,"pos":11}}},"contents":[{"Add":""},{"Add":" assert_eq!(txn.root, 1);"},{"Add":""}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":413,"ins":{"up_context":[{"change":4,"pos":1689}],"down_context":[{"change":4,"pos":1839}],"flag":"BLOCK","start":675,"end":813,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1689},"to":{"change":4,"start":1689,"end":1839},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" assert!(t.elapsed().unwrap() >= std::time::Duration::from_millis(90));"},{"Add":" info!(\"started child mutable txn {:?}\", txn.root);"}],"del_contents":[{"Del":" assert!(t.elapsed().unwrap() >= std::time::Duration::from_millis(900));\n info!(\"started child mutable txn {:?}\", txn.env.root.lock());\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":418,"ins":{"up_context":[{"change":3,"pos":2593}],"down_context":[{"change":4,"pos":2060}],"flag":"BLOCK","start":814,"end":881,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":2593},"to":{"change":4,"start":1997,"end":2060},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":4,"pos":15757},"to":{"change":4,"start":1997,"end":2060},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1997},"to":{"change":4,"start":1997,"end":2060},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" std::thread::sleep(std::time::Duration::from_millis(100));"}],"del_contents":[{"Del":" std::thread::sleep(std::time::Duration::from_secs(1));\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":424,"ins":{"up_context":[{"change":4,"pos":2156}],"down_context":[{"change":4,"pos":2219}],"flag":"BLOCK","start":882,"end":949,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2156},"to":{"change":4,"start":2156,"end":2219},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" std::thread::sleep(std::time::Duration::from_millis(100));"}],"del_contents":[{"Del":" std::thread::sleep(std::time::Duration::from_secs(1));\n"}]}},{"Edit":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":429,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2312},"to":{"change":4,"start":2312,"end":2365},"introduced_by":4}],"inode":{"change":4,"pos":11}}},"contents":[{"Del":" info!(\"starting parent txn {:?}\", env.root);\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":430,"ins":{"up_context":[{"change":4,"pos":2414}],"down_context":[{"change":4,"pos":2514}],"flag":"BLOCK","start":950,"end":1144,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2414},"to":{"change":4,"start":2414,"end":2514},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" info!(\"started parent txn {:?}\", txn.root);"},{"Add":""},{"Add":" // The child didn't commit yet."},{"Add":" assert_eq!(txn.root, 1);"},{"Add":""},{"Add":" std::thread::sleep(std::time::Duration::from_millis(300));"}],"del_contents":[{"Del":" info!(\"started parent txn\");\n std::thread::sleep(std::time::Duration::from_secs(3));\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":438,"ins":{"up_context":[{"change":4,"pos":2544}],"down_context":[{"change":4,"pos":2587}],"flag":"BLOCK","start":1145,"end":1511,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2544},"to":{"change":4,"start":2544,"end":2587},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" std::thread::sleep(std::time::Duration::from_millis(100));"},{"Add":" let txn = Env::txn_begin(&env).unwrap();"},{"Add":" info!(\"started parent txn {:?}\", txn.root);"},{"Add":""},{"Add":" // The parent committed, this is a new transaction."},{"Add":" assert_eq!(txn.root, 0);"},{"Add":""},{"Add":" let mut status = 1;"},{"Add":" unsafe { libc::wait(&mut status) };"},{"Add":" assert_eq!(status, 0);"}],"del_contents":[{"Del":" unsafe { libc::wait(&mut child) };\n"}]}},{"Edit":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":472,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":52816}],"down_context":[{"change":4,"pos":52816}],"flag":"BLOCK","start":1512,"end":2811,"inode":{"change":4,"pos":11}}},"contents":[{"Add":"}"},{"Add":""},{"Add":"#[test]"},{"Add":"fn more_than_two_versions() {"},{"Add":" env_logger::try_init().unwrap_or(());"},{"Add":" let n = 5;"},{"Add":" let env = Env::new_anon(40960, n).unwrap();"},{"Add":""},{"Add":" let mut txn = Env::mut_txn_begin(&env).unwrap();"},{"Add":""},{"Add":" // Allocate two pages."},{"Add":" for i in 0..n {"},{"Add":" let page = txn.alloc_page().unwrap();"},{"Add":" debug!(\"page = {:?}\", page);"},{"Add":" txn.set_root(i, page.0.offset);"},{"Add":" }"},{"Add":" txn.commit().unwrap();"},{"Add":""},{"Add":" for i in 0..n {"},{"Add":" let mut txn = Env::mut_txn_begin(&env).unwrap();"},{"Add":" // Free one of the pages."},{"Add":" debug!(\"root(0) = {:?}\", txn.root(i));"},{"Add":" txn.decr_rc(txn.root(i).unwrap()).unwrap();"},{"Add":" txn.remove_root(i);"},{"Add":" txn.commit().unwrap();"},{"Add":" }"},{"Add":""},{"Add":" let mut txn = Env::mut_txn_begin(&env).unwrap();"},{"Add":" unsafe {"},{"Add":" let p = &*(env.mmaps.lock()[0].ptr.add(txn.root * PAGE_SIZE) as *const GlobalHeader);"},{"Add":" debug!(\"free page: 0x{:x}\", u64::from_le(p.free_db));"},{"Add":" let db: Db = Db {"},{"Add":" db: u64::from_le(p.free_db),"},{"Add":" k: std::marker::PhantomData,"},{"Add":" v: std::marker::PhantomData,"},{"Add":" p: std::marker::PhantomData,"},{"Add":" };"},{"Add":" for x in iter(&txn, &db, None).unwrap() {"},{"Add":" debug!(\"0x{:x}\", x.unwrap().0);"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" let page = txn.alloc_page().unwrap();"},{"Add":" debug!(\"page = {:?}\", page);"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":535,"ins":{"up_context":[{"change":4,"pos":303}],"down_context":[{"change":4,"pos":353}],"flag":"BLOCK","start":2812,"end":2855,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":303},"to":{"change":4,"start":303,"end":353},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" get(&txn, &db, &i, None).unwrap();"}],"del_contents":[{"Del":" btree::get(&txn, &db, &i, None).unwrap();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":564,"ins":{"up_context":[{"change":4,"pos":651}],"down_context":[{"change":4,"pos":701}],"flag":"BLOCK","start":2856,"end":2899,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":651},"to":{"change":4,"start":651,"end":701},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" get(&txn, &db, &i, None).unwrap();"}],"del_contents":[{"Del":" btree::get(&txn, &db, &i, None).unwrap();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":609,"ins":{"up_context":[{"change":4,"pos":2081}],"down_context":[{"change":4,"pos":2160}],"flag":"BLOCK","start":2900,"end":2972,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2081},"to":{"change":4,"start":2081,"end":2160},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" assert_eq!(get(&txn, &db, &k, None).unwrap(), Some((k, v)))"}],"del_contents":[{"Del":" assert_eq!(btree::get(&txn, &db, &k, None).unwrap(), Some((k, v)))\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":624,"ins":{"up_context":[{"change":4,"pos":2733}],"down_context":[{"change":4,"pos":2812}],"flag":"BLOCK","start":2973,"end":3045,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2733},"to":{"change":4,"start":2733,"end":2812},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" assert_eq!(get(&txn, &db, &k, None).unwrap(), Some((k, v)))"}],"del_contents":[{"Del":" assert_eq!(btree::get(&txn, &db, &k, None).unwrap(), Some((k, v)))\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":765,"ins":{"up_context":[{"change":4,"pos":13516}],"down_context":[{"change":4,"pos":517}],"flag":"BLOCK","start":3046,"end":3070,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":13516},"to":{"change":4,"start":486,"end":517},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":486},"to":{"change":4,"start":486,"end":517},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" P: BTreePage,"}],"del_contents":[{"Del":" P: btree::BTreePage,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":837,"ins":{"up_context":[{"change":4,"pos":1903}],"down_context":[{"change":4,"pos":1971}],"flag":"BLOCK","start":3071,"end":3132,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1903},"to":{"change":4,"start":1903,"end":1971},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" get(&txn, &db, k.as_bytes(), None).unwrap(),"}],"del_contents":[{"Del":" btree::get(&txn, &db, k.as_bytes(), None).unwrap(),\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":856,"ins":{"up_context":[{"change":4,"pos":2643}],"down_context":[{"change":4,"pos":2686}],"flag":"BLOCK","start":3133,"end":3167,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2643},"to":{"change":4,"start":2643,"end":2686},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let k = MDB_val {"}],"del_contents":[{"Del":" let k = lmdb_rs::MDB_val {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":873,"ins":{"up_context":[{"change":4,"pos":3239}],"down_context":[{"change":4,"pos":3278}],"flag":"BLOCK","start":3168,"end":3198,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3239},"to":{"change":4,"start":3239,"end":3278},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let k = MDB_val {"}],"del_contents":[{"Del":" let k = lmdb_rs::MDB_val {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":928,"ins":{"up_context":[{"change":4,"pos":5264}],"down_context":[{"change":4,"pos":5329}],"flag":"BLOCK","start":3199,"end":3257,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5264},"to":{"change":4,"start":5264,"end":5329},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" for (kv, n) in rev_iter(&txn, &db, Some((&i0, None)))"}],"del_contents":[{"Del":" for (kv, n) in btree::rev_iter(&txn, &db, Some((&i0, None)))\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":937,"ins":{"up_context":[{"change":4,"pos":5497}],"down_context":[{"change":4,"pos":10291}],"flag":"BLOCK","start":3258,"end":3333,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5497},"to":{"change":4,"start":5497,"end":5579},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" for (kv, n) in iter(&txn, &db, Some((&i0, None))).unwrap().zip(i0..) {"}],"del_contents":[{"Del":" for (kv, n) in btree::iter(&txn, &db, Some((&i0, None))).unwrap().zip(i0..) {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":943,"ins":{"up_context":[{"change":4,"pos":10334}],"down_context":[{"change":4,"pos":10408}],"flag":"BLOCK","start":3334,"end":3401,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":10334},"to":{"change":4,"start":10334,"end":10408},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let mut it = rev_iter(&txn, &db, Some((&100, None))).unwrap();"}],"del_contents":[{"Del":" let mut it = btree::rev_iter(&txn, &db, Some((&100, None))).unwrap();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":977,"ins":{"up_context":[{"change":4,"pos":11523}],"down_context":[{"change":4,"pos":11545}],"flag":"BLOCK","start":3402,"end":3420,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":11523},"to":{"change":4,"start":11523,"end":11545},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let n = 6u64;"}],"del_contents":[{"Del":" let n = 6 as u64;\n"}]}},{"Edit":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":991,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":11952},"to":{"change":4,"start":11952,"end":11959},"introduced_by":4}],"inode":{"change":4,"pos":11}}},"contents":[{"Del":" /*\n"}]}},{"Edit":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":994,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":12086},"to":{"change":4,"start":12086,"end":12135},"introduced_by":4}],"inode":{"change":4,"pos":11}}},"contents":[{"Del":" // add_refs(&txn, &db3, &mut refs).unwrap();\n"}]}},{"Edit":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":1014,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":12742},"to":{"change":4,"start":12742,"end":12749},"introduced_by":4}],"inode":{"change":4,"pos":11}}},"contents":[{"Del":" */\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/tests.rs","line":1022,"ins":{"up_context":[{"change":4,"pos":4010}],"down_context":[{"change":4,"pos":4059}],"flag":"BLOCK","start":3421,"end":3462,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4010},"to":{"change":4,"start":4010,"end":4059},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" let n = 1000u64;"},{"Add":" let i0 = 10u64;"}],"del_contents":[{"Del":" let n = 1000 as u64;\n let i0 = 10 as u64;\n"}]}},{"Edit":{"inode":{"change":4,"pos":79574},"path":"sanakirja/src/lib.rs","line":1,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":79574}],"down_context":[{"change":3,"pos":2744}],"flag":"BLOCK","start":3463,"end":3591,"inode":{"change":4,"pos":79574}}},"contents":[{"Add":"#![deny("},{"Add":" missing_docs,"},{"Add":" trivial_casts,"},{"Add":" trivial_numeric_casts,"},{"Add":" unused_import_braces,"},{"Add":" unused_qualifications"},{"Add":")]"}]}},{"Edit":{"inode":{"change":4,"pos":79574},"path":"sanakirja/src/lib.rs","line":13,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2979}],"down_context":[{"change":4,"pos":79575}],"flag":"BLOCK","start":3592,"end":6576,"inode":{"change":4,"pos":79574}}},"contents":[{"Add":"//!"},{"Add":"//! The binary format of a Sanakirja database is the following:"},{"Add":"//!"},{"Add":"//! - There is a fixed number of \"current versions\", set at file"},{"Add":"//! initialisation. If a file has n versions, then for all k between 0"},{"Add":"//! and n-1 (included), the k^th page (i.e. the byte positions between"},{"Add":"//! `k * 4096` and `(k+1) * 4096`, also written as `k << 12` and"},{"Add":"//! `(k+1) << 12`) stores the data relative to that version, and is"},{"Add":"//! called the \"root page\" of that version."},{"Add":"//!"},{"Add":"//! This is a way to handle concurrent access: indeed, mutable"},{"Add":"//! transactions do not exclude readers, but readers that started"},{"Add":"//! before the commit of a mutable transaction will keep reading the"},{"Add":"//! database as it was before the commit. However, this means that"},{"Add":"//! older versions of the database have to be kept \"alive\", and the"},{"Add":"//! \"number of current versions\" here is the limit on the number of"},{"Add":"//! versions that can be kept \"alive\" at the same time."},{"Add":"//!"},{"Add":"//! When a reader starts, it takes a shared file lock on the file"},{"Add":"//! representing the youngest committed version. When a writer starts,"},{"Add":"//! it takes an exclusive file lock on the file representing the"},{"Add":"//! oldest committed version. This implies that if readers are still"},{"Add":"//! reading that version, the writer will wait for the exclusive lock."},{"Add":"//!"},{"Add":"//! After taking a lock, the writer (also called \"mutable"},{"Add":"//! transaction\" or [`MutTxn`]) copies the entire root page of the"},{"Add":"//! youngest committed version onto the root page of the oldest"},{"Add":"//! committed version, hence erasing the root page of the oldest"},{"Add":"//! version."},{"Add":"//!"},{"Add":"//! - Root pages have the following format: a 32-bytes header"},{"Add":"//! (described below), followed by 4064 bytes, usable in a more or"},{"Add":"//! less free format. The current implementation defines two methods"},{"Add":"//! on [`MutTxn`], [`MutTxn::set_root`] and [`MutTxn::remove_root`],"},{"Add":"//! treating that space as an array of type `[u64; 510]`. A reasonable"},{"Add":"//! use for these is to point to different datastructures allocated in"},{"Add":"//! the file, such as the offsets in the file to the root pages of B"},{"Add":"//! trees."},{"Add":"//!"},{"Add":"//! Now, about the header, there's a version identifier on the first"},{"Add":"//! 16 bytes, followed by two bytes: `root` is the version used by the"},{"Add":"//! current mutable transaction (if there is current mutable"},{"Add":"//! transaction), or by the next mutable transaction (else). The"},{"Add":"//! `n_roots` field is the total number of versions."},{"Add":"//!"},{"Add":"//! ```"},{"Add":"//! #[repr(C)]"},{"Add":"//! pub struct GlobalHeader {"},{"Add":"//! /// Version of Sanakirja"},{"Add":"//! pub version: u16,"},{"Add":"//! /// Which page is currently the root page? (only valid for page 0)."},{"Add":"//! pub root: u8,"},{"Add":"//! /// Total number of versions (or \"root pages\")"},{"Add":"//! pub n_roots: u8,"},{"Add":"//! /// CRC of this page."},{"Add":"//! pub crc: u32,"},{"Add":"//! /// First free page at the end of the file (only valid for page 0)."},{"Add":"//! pub length: u64,"},{"Add":"//! /// Offset of the free list."},{"Add":"//! pub free_db: u64,"},{"Add":"//! /// Offset of the RC database."},{"Add":"//! pub rc_db: u64,"},{"Add":"//! }"},{"Add":"//! ```"},{"Add":""}]}},{"Replacement":{"inode":{"change":4,"pos":79574},"path":"sanakirja/src/lib.rs","line":81,"ins":{"up_context":[{"change":3,"pos":2997}],"down_context":[{"change":4,"pos":312}],"flag":"BLOCK","start":6577,"end":6717,"inode":{"change":4,"pos":79574}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":2997},"to":{"change":4,"start":176,"end":217},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":79615},"to":{"change":4,"start":176,"end":217},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":217},"to":{"change":4,"start":13517,"end":13607},"introduced_by":4}],"inode":{"change":4,"pos":79574}},"ins_contents":[{"Add":"pub use environment::{Commit, Env, MutTxn, RootDb, Txn};"},{"Add":"pub use sanakirja_core::{btree, direct_repr, LoadPage, Storable, UnsizedStorable};"}],"del_contents":[{"Del":"pub use environment::{Env, MutTxn, Txn};\n"},{"Del":"pub use sanakirja_core::{btree, direct_repr, CowPage, LoadPage, MutPage, Page, Storable};\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":15,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":2774}],"down_context":[{"change":4,"pos":80352}],"flag":"BLOCK","start":6718,"end":6897,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" /// The root page of this transaction, which is 1 + the root"},{"Add":" /// written on page 0. The root written on page 0 changes at"},{"Add":" /// commit time."},{"Add":" pub(crate) root: usize,"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":21,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":2579}],"down_context":[{"change":4,"pos":15956}],"flag":"BLOCK","start":6898,"end":6955,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":""},{"Add":" /// Offset to the root of the B tree of free pages."}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":24,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":15982}],"down_context":[{"change":4,"pos":27437}],"flag":"BLOCK","start":6956,"end":7288,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":""},{"Add":" /// Reference counts use a strange encoding, meant to avoid code"},{"Add":" /// bloat: indeed, the list of free pages uses `Db`, so"},{"Add":" /// we're just reusing the same code here, encoding the reference"},{"Add":" /// counts in the 12 least significant bits of the keys, and the"},{"Add":" /// actual pages in the 52 most significant bits."}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":31,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":27473}],"down_context":[{"change":4,"pos":80470}],"flag":"BLOCK","start":7289,"end":7290,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":""}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":42,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":80851}],"down_context":[{"change":4,"pos":549}],"flag":"BLOCK","start":7291,"end":7603,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" ///"},{"Add":" /// Since we can't reuse them in the same transaction, another"},{"Add":" /// option would be to put them directly into the table of free"},{"Add":" /// pages. However, since calls to `put` may allocate and free"},{"Add":" /// pages, this could recurse infinitely, which is why we store"},{"Add":" /// them outside of the file."}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":52,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":80903}],"down_context":[{"change":4,"pos":99}],"flag":"BLOCK","start":7604,"end":7735,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":"/// When dropping a transaction, we need to unlock the read-write"},{"Add":"/// locks internal to this process, and possibly the file locks."}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":58,"ins":{"up_context":[{"change":4,"pos":81041}],"down_context":[{"change":4,"pos":81129}],"flag":"BLOCK","start":7736,"end":7888,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":81041},"to":{"change":4,"start":81041,"end":81081},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":81081},"to":{"change":4,"start":3039,"end":3091},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":3091},"to":{"change":4,"start":148,"end":317},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":81081},"to":{"change":4,"start":148,"end":317},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" env.mut_txn_unlock().unwrap_or(());"},{"Add":" env.roots[self.root].rw.unlock_exclusive();"},{"Add":" env.unlock(self.root).unwrap_or(())"}],"del_contents":[{"Del":" let root = env.root.lock();\n"},{"Del":" debug!(\"unlock exclusive {:?}\", *root);\n"},{"Del":" env.roots[*root].rw.unlock_exclusive();\n if let Some(ref f) = env.roots[*root].lock_file {\n f.unlock().unwrap_or(())\n }\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":65,"ins":{"up_context":[{"change":4,"pos":81148}],"down_context":[{"change":4,"pos":81188}],"flag":"BLOCK","start":7889,"end":8015,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":81148},"to":{"change":4,"start":81148,"end":81188},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":"/// Transactions that can be committed. This trait is an abstraction"},{"Add":"/// over mutable transactions and their subtransactions."}],"del_contents":[{"Del":"/// Transactions that can be committed.\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":72,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":81284}],"down_context":[{"change":4,"pos":318}],"flag":"BLOCK","start":8016,"end":8146,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":"/// The following is very easy, we're just extending all values of the"},{"Add":"/// current transaction with values of the subtransaction."}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":103,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":403}],"down_context":[{"change":4,"pos":81964}],"flag":"BLOCK","start":8147,"end":8926,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" #[cfg(feature = \"mmap\")]"},{"Add":" fn mut_txn_lock(&self) -> Result<(), Error> {"},{"Add":" self.mut_txn_lock.lock();"},{"Add":" if let Some(ref f) = self.file {"},{"Add":" f.lock_exclusive()?;"},{"Add":" }"},{"Add":" Ok(())"},{"Add":" }"},{"Add":""},{"Add":" #[cfg(not(feature = \"mmap\"))]"},{"Add":" fn mut_txn_lock(&self) -> Result<(), Error> {"},{"Add":" self.mut_txn_lock.lock();"},{"Add":" Ok(())"},{"Add":" }"},{"Add":""},{"Add":" #[cfg(feature = \"mmap\")]"},{"Add":" fn mut_txn_unlock(&self) -> Result<(), Error> {"},{"Add":" unsafe {"},{"Add":" self.mut_txn_lock.unlock();"},{"Add":" }"},{"Add":" if let Some(ref f) = self.file {"},{"Add":" f.unlock()?"},{"Add":" }"},{"Add":" Ok(())"},{"Add":" }"},{"Add":""},{"Add":" #[cfg(not(feature = \"mmap\"))]"},{"Add":" fn mut_txn_unlock(&self) -> Result<(), Error> {"},{"Add":" unsafe {"},{"Add":" self.mut_txn_lock.unlock();"},{"Add":" }"},{"Add":" Ok(())"},{"Add":" }"},{"Add":""}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":141,"ins":{"up_context":[{"change":4,"pos":82179}],"down_context":[{"change":4,"pos":82828}],"flag":"BLOCK","start":8927,"end":8964,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":82179},"to":{"change":4,"start":82179,"end":82396},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":82396},"to":{"change":4,"start":404,"end":578},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":82513},"to":{"change":4,"start":579,"end":623},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":623},"to":{"change":4,"start":3116,"end":3227},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":660},"to":{"change":4,"start":82513,"end":82586},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":3227},"to":{"change":4,"start":82513,"end":82586},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":82513},"to":{"change":4,"start":82513,"end":82586},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":82586},"to":{"change":4,"start":661,"end":808},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":808},"to":{"change":4,"start":3228,"end":3329},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" let env_ = env.borrow();"}],"del_contents":[{"Del":" let (header, free, rc) = {\n let env_ = env.borrow();\n let maps = env_.mmaps.lock()[0].ptr;\n let v = env_.root.lock();\n let n = env_.roots.len();\n"},{"Del":" env_.roots[*v].rw.lock_exclusive();\n if let Some(ref f) = env_.roots[*v].lock_file {\n f.lock_exclusive()?\n }\n"},{"Del":" // Root of the last MutTxn.\n"},{"Del":" let v0 = (*v + n - 1) % env_.roots.len();\n debug!(\"v = {:?} v0 = {:?}\", v, v0);\n"},{"Del":" // Copy the roots of the last transaction onto this one.\n"},{"Del":" let page_ptr = maps.offset((v0 * PAGE_SIZE) as isize);\n let next_page_ptr = maps.offset((*v * PAGE_SIZE) as isize);\n"},{"Del":" std::ptr::copy_nonoverlapping(page_ptr.add(8), next_page_ptr.add(8), PAGE_SIZE - 8);\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":143,"ins":{"up_context":[{"change":4,"pos":82829}],"down_context":[{"change":3,"pos":3051}],"flag":"BLOCK","start":8965,"end":10261,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":82829},"to":{"change":4,"start":82829,"end":82918},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":82918},"to":{"change":3,"start":3014,"end":3051},"introduced_by":3}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" // First, take an exclusive file lock on the whole file to"},{"Add":" // make sure that no other process is starting a mutable"},{"Add":" // transaction at the same time. The worst that can happen"},{"Add":" // here is if the other process commits while we're still"},{"Add":" // waiting for a lock on the current page, because if that"},{"Add":" // happens, this new transaction will erase the"},{"Add":" // transaction in the other process."},{"Add":" env_.mut_txn_lock()?;"},{"Add":""},{"Add":" // Then, we can lock the root page of this transaction."},{"Add":" let maps = env_.mmaps.lock()[0].ptr;"},{"Add":" let root = (&*(maps as *const GlobalHeader)).root as usize;"},{"Add":" debug!(\"BEGIN_TXN root = {:?}\", root);"},{"Add":" env_.roots[root].rw.lock_exclusive();"},{"Add":" env_.lock_exclusive(root)?;"},{"Add":" // Root of the last MutTxn."},{"Add":" let v0 = (root + env_.roots.len() - 1) % env_.roots.len();"},{"Add":" env_.check_crc(v0)?;"},{"Add":" // Copy the root page of the last transaction onto this"},{"Add":" // one."},{"Add":" let page_ptr = maps.offset((v0 * PAGE_SIZE) as isize);"},{"Add":" let next_page_ptr = maps.offset((root * PAGE_SIZE) as isize);"},{"Add":" std::ptr::copy_nonoverlapping(page_ptr.add(8), next_page_ptr.add(8), PAGE_SIZE - 8);"}],"del_contents":[{"Del":" let header = GlobalHeader::from_le(&*(page_ptr as *const GlobalHeader));\n"},{"Del":" env_.check_crc(v0)?;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":167,"ins":{"up_context":[{"change":3,"pos":3052}],"down_context":[{"change":4,"pos":83538}],"flag":"BLOCK","start":10262,"end":10473,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":3052},"to":{"change":4,"start":15983,"end":16026},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":82918},"to":{"change":4,"start":15983,"end":16026},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":16026},"to":{"change":4,"start":83075,"end":83210},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":83075},"to":{"change":4,"start":83075,"end":83210},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":83210},"to":{"change":4,"start":16027,"end":16069},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":16069},"to":{"change":4,"start":52819,"end":52978},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":83388},"to":{"change":4,"start":52819,"end":52978},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":52978},"to":{"change":4,"start":83446,"end":83523},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":83446},"to":{"change":4,"start":83446,"end":83523},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":83523},"to":{"change":4,"start":12750,"end":12926},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":12926},"to":{"change":4,"start":83523,"end":83538},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":83523},"to":{"change":4,"start":83523,"end":83538},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" // Finally, read the header and start the transaction."},{"Add":" let header = GlobalHeader::from_le(&*(next_page_ptr as *const GlobalHeader));"},{"Add":" debug!(\"n_roots = {:?}\", header.n_roots);"}],"del_contents":[{"Del":" let free = header.free_db;\n"},{"Del":" let rc = if header.rc_db == 0 {\n None\n } else {\n Some(btree::Db {\n"},{"Del":" db: header.rc_db,\n"},{"Del":" k: std::marker::PhantomData,\n v: std::marker::PhantomData,\n p: std::marker::PhantomData,\n"},{"Del":" })\n };\n (header, free, rc)\n"},{"Del":" };\n let length = if header.length == 0 {\n (PAGE_SIZE as u64) * (header.n_roots as u64)\n } else {\n header.length\n"},{"Del":" };\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":172,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":83583}],"down_context":[{"change":4,"pos":83583}],"flag":"BLOCK","start":10474,"end":10496,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" root,"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":174,"ins":{"up_context":[{"change":4,"pos":83611}],"down_context":[{"change":4,"pos":83844}],"flag":"BLOCK","start":10497,"end":10899,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":83611},"to":{"change":4,"start":83611,"end":83631},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":83631},"to":{"change":4,"start":12927,"end":12951},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":12951},"to":{"change":4,"start":83822,"end":83844},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":83822},"to":{"change":4,"start":83822,"end":83844},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" rc: if header.rc_db == 0 {"},{"Add":" None"},{"Add":" } else {"},{"Add":" Some(btree::Db::from_page(header.rc_db))"},{"Add":" },"},{"Add":" length: if header.length == 0 {"},{"Add":" (PAGE_SIZE as u64) * (header.n_roots as u64)"},{"Add":" } else {"},{"Add":" header.length"},{"Add":" },"},{"Add":" free: header.free_db,"}],"del_contents":[{"Del":" rc,\n"},{"Del":" length,\n"},{"Del":" free,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":206,"ins":{"up_context":[{"change":4,"pos":84166}],"down_context":[{"change":4,"pos":85021}],"flag":"BLOCK","start":10900,"end":12972,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":84166},"to":{"change":4,"start":84166,"end":84183},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":84183},"to":{"change":4,"start":16070,"end":16153},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":16153},"to":{"change":4,"start":84575,"end":85021},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":3232},"to":{"change":4,"start":84575,"end":85021},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":84575},"to":{"change":4,"start":84575,"end":85021},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" debug!(\"COMMIT\");"},{"Add":""},{"Add":" // If there's no tree of free pages, and no pages to free,"},{"Add":" // don't bother with free pages at all (don't even allocate a"},{"Add":" // tree)."},{"Add":" let free_db ="},{"Add":" if self.free == 0 && self.free_owned_pages.is_empty() && self.free_pages.is_empty() {"},{"Add":" None"},{"Add":" } else {"},{"Add":" // Else, allocate or load the tree of free pages."},{"Add":" let mut free_db: btree::Db = if self.free == 0 {"},{"Add":" btree::create_db(&mut self)?"},{"Add":" } else {"},{"Add":" btree::Db::from_page(self.free)"},{"Add":" };"},{"Add":" debug!(\"free_db = {:?}\", free_db);"},{"Add":" // Adding all the pages freed during the transaction to the"},{"Add":" // tree of free pages. If this call to `btree::put` frees"},{"Add":" // pages, add them again. This converges in at most log n"},{"Add":" // iterations (where n is the total number of free pages)."},{"Add":""},{"Add":" // First, set the free table to 0 in this transaction, to"},{"Add":" // avoid recursing in the calls to `put` below (indeed,"},{"Add":" // the table of free pages is used when allocating new"},{"Add":" // pages, which may happen in a call to `put`)."},{"Add":" self.free = 0;"},{"Add":""},{"Add":" // Then, while there are pages to free, free them. Since"},{"Add":" // the calls to `put` below might free pages (and add"},{"Add":" // pages to these two vectors), the (outer) loop might run"},{"Add":" // for more than one iteration."},{"Add":" while !self.free_pages.is_empty() || !self.free_owned_pages.is_empty() {"},{"Add":" while let Some(p) = self.free_pages.pop() {"},{"Add":" let p = p & !0xfff;"},{"Add":" btree::put(&mut self, &mut free_db, &p.to_le(), &())?;"},{"Add":" }"},{"Add":" while let Some(p) = self.free_owned_pages.pop() {"},{"Add":" let p = p & !0xfff;"},{"Add":" btree::put(&mut self, &mut free_db, &p.to_le(), &())?;"},{"Add":" }"}],"del_contents":[{"Del":" unsafe {\n"},{"Del":" let mut free_db: btree::Db = btree::Db::from_page(self.free);\n"},{"Del":" while !self.free_owned_pages.is_empty() || !self.free_pages.is_empty() {\n let mut free_owned_pages =\n std::mem::replace(&mut self.free_owned_pages, Vec::new());\n let mut free_pages = std::mem::replace(&mut self.free_pages, Vec::new());\n for p in free_owned_pages.drain(..).chain(free_pages.drain(..)) {\n btree::put(&mut self, &mut free_db, &p, &())?;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":247,"ins":{"up_context":[{"change":4,"pos":85039}],"down_context":[{"change":4,"pos":85146}],"flag":"BLOCK","start":12973,"end":13621,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85039},"to":{"change":4,"start":85039,"end":85113},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85113},"to":{"change":3,"start":3233,"end":3265},"introduced_by":3}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" Some(free_db)"},{"Add":" };"},{"Add":" // Clear the dirty bit of all pages we've touched. If they've"},{"Add":" // been freed and have already been flushed by the kernel, we"},{"Add":" // don't want to resurrect them to the main memory, so we"},{"Add":" // check that."},{"Add":" let mut occ = std::mem::replace(&mut self.occupied_owned_pages, Vec::new());"},{"Add":" for p in occ.iter_mut() {"},{"Add":" if let Some(ref free_db) = free_db {"},{"Add":" if let Some((pp, ())) = btree::get(&self, free_db, &p.0.offset, None)? {"},{"Add":" if *pp == p.0.offset {"},{"Add":" continue;"},{"Add":" }"},{"Add":" }"}],"del_contents":[{"Del":" }\n for p in self.occupied_owned_pages.iter_mut() {\n"},{"Del":" clear_dirty(p);\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":262,"ins":{"up_context":[{"change":4,"pos":85160}],"down_context":[{"change":4,"pos":85506}],"flag":"BLOCK","start":13622,"end":13660,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85160},"to":{"change":4,"start":85160,"end":85246},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85246},"to":{"change":4,"start":4445,"end":4489},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4489},"to":{"change":4,"start":3435,"end":3518},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":3518},"to":{"change":4,"start":85383,"end":85441},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85383},"to":{"change":4,"start":85383,"end":85441},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85441},"to":{"change":4,"start":16154,"end":16212},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":16212},"to":{"change":4,"start":3233,"end":3269},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85506},"to":{"change":4,"start":3233,"end":3269},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" clear_dirty(p);"},{"Add":" }"}],"del_contents":[{"Del":" let env = self.env.borrow();\n let mut maps = env.mmaps.lock();\n"},{"Del":" let mut root = env.root.lock();\n"},{"Del":" let globptr = maps[0].ptr.add(*root * PAGE_SIZE) as *mut GlobalHeader;\n"},{"Del":" (&mut *globptr).length = self.length.to_le();\n"},{"Del":" (&mut *globptr).free_db = free_db.db.to_le();\n"},{"Del":" self.free = free_db.db;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":265,"ins":{"up_context":[{"change":4,"pos":85507}],"down_context":[{"change":4,"pos":3663}],"flag":"BLOCK","start":13661,"end":14382,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85507},"to":{"change":4,"start":3519,"end":3663},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" let env = self.env.borrow();"},{"Add":" let mut maps = env.mmaps.lock();"},{"Add":""},{"Add":" // Get this transaction's root page."},{"Add":" let globptr ="},{"Add":" unsafe { &mut *(maps[0].ptr.add(self.root * PAGE_SIZE) as *mut GlobalHeader) };"},{"Add":" // Set the length and free database."},{"Add":" globptr.length = self.length.to_le();"},{"Add":" if let Some(free_db) = free_db {"},{"Add":" debug!(\"COMMIT: free_db = 0x{:x}\", free_db.db);"},{"Add":" globptr.free_db = free_db.db.to_le();"},{"Add":" }"},{"Add":" // Set the \"root databases\" modified by this transaction."},{"Add":" let root_dbs = unsafe {"},{"Add":" std::slice::from_raw_parts_mut("},{"Add":" maps[0].ptr.add(self.root * PAGE_SIZE + GLOBAL_HEADER_SIZE) as *mut u64,"}],"del_contents":[{"Del":" let root_dbs = std::slice::from_raw_parts_mut(\n maps[0].ptr.add(*root * PAGE_SIZE + GLOBAL_HEADER_SIZE) as *mut u64,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":282,"ins":{"up_context":[{"change":4,"pos":3688}],"down_context":[{"change":4,"pos":3918}],"flag":"BLOCK","start":14383,"end":14622,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3688},"to":{"change":4,"start":3688,"end":3894},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3894},"to":{"change":4,"start":12952,"end":13025},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" )"},{"Add":" };"},{"Add":" for (&r, rr) in self.roots.iter().zip(root_dbs.iter_mut()) {"},{"Add":" debug!(\"root_db: {:?}\", rr);"},{"Add":" debug!(\"committing root: {:?} {:?}\", r, rr);"},{"Add":" if r > 0 {"},{"Add":" *rr = r"}],"del_contents":[{"Del":" );\n for (&r, rr) in self.roots.iter().zip(root_dbs.iter_mut()) {\n debug!(\"root_db: {:?}\", rr as *mut u64);\n debug!(\"committing root: {:?} {:?}\", r, rr);\n"},{"Del":" if r > 0 {\n *rr = r\n }\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":290,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":3932}],"down_context":[{"change":4,"pos":3932}],"flag":"BLOCK","start":14623,"end":14633,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" }"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":292,"ins":{"up_context":[{"change":4,"pos":3933}],"down_context":[{"change":3,"pos":3323}],"flag":"BLOCK","start":14634,"end":14758,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":3933},"to":{"change":3,"start":3266,"end":3323},"introduced_by":3}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" // Set the root page's CRC."},{"Add":" unsafe {"},{"Add":" set_crc(maps[0].ptr.add(self.root * PAGE_SIZE));"},{"Add":" }"}],"del_contents":[{"Del":" set_crc(maps[0].ptr.add(*root * PAGE_SIZE));\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":297,"ins":{"up_context":[{"change":3,"pos":3324}],"down_context":[{"change":4,"pos":85828}],"flag":"BLOCK","start":14759,"end":14981,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":3,"pos":3324},"to":{"change":4,"start":85507,"end":85584},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":4,"pos":3933},"to":{"change":4,"start":85507,"end":85584},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85507},"to":{"change":4,"start":85507,"end":85584},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85584},"to":{"change":3,"start":3325,"end":3400},"introduced_by":3}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" // Move the current global root page by one page on page 0."},{"Add":" unsafe {"},{"Add":" (&mut *(maps[0].ptr as *mut GlobalHeader)).root ="},{"Add":" (self.root as u8 + 1) % (env.roots.len() as u8);"},{"Add":" }"}],"del_contents":[{"Del":" // Moving the root page, both on page 0, and on the environment.\n"},{"Del":" (&mut *(maps[0].ptr as *mut GlobalHeader)).root = *root as u8;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":303,"ins":{"up_context":[{"change":4,"pos":85829}],"down_context":[{"change":4,"pos":85985}],"flag":"BLOCK","start":14982,"end":15071,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85829},"to":{"change":4,"start":85829,"end":85909},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85909},"to":{"change":4,"start":3270,"end":3320},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":3320},"to":{"change":4,"start":907,"end":1021},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85909},"to":{"change":4,"start":907,"end":1021},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1021},"to":{"change":4,"start":3321,"end":3368},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":3368},"to":{"change":4,"start":1021,"end":1076},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1021},"to":{"change":4,"start":1021,"end":1076},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1076},"to":{"change":4,"start":85909,"end":85966},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85909},"to":{"change":4,"start":85909,"end":85966},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85966},"to":{"change":4,"start":3369,"end":3420},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":3420},"to":{"change":4,"start":85966,"end":85985},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":85966},"to":{"change":4,"start":85966,"end":85985},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" // Flush all the maps."},{"Add":" for m in maps.iter_mut() {"},{"Add":" m.flush()?"}],"del_contents":[{"Del":" for m in maps.iter_mut() {\n m.flush()?\n }\n"},{"Del":" debug!(\"commit: unlock {:?}\", *root);\n"},{"Del":" env.roots[*root].rw.unlock_exclusive();\n if let Some(ref f) = env.roots[*root].lock_file {\n"},{"Del":" debug!(\"commit: unlock file\");\n"},{"Del":" f.unlock().unwrap_or(())\n }\n"},{"Del":" *env.first_unused_page.lock() = self.length;\n"},{"Del":" *root = (*root + 1) % env.roots.len();\n"},{"Del":" Ok(())\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":307,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":85995}],"down_context":[{"change":4,"pos":85995}],"flag":"BLOCK","start":15072,"end":15481,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":""},{"Add":" // And finally, unlock the root page in the environment."},{"Add":" debug!(\"commit: unlock {:?}\", self.root);"},{"Add":" unsafe { env.roots[self.root].rw.unlock_exclusive() };"},{"Add":" // Unlock the root page on the file lock (if relevant)."},{"Add":" env.unlock(self.root)?;"},{"Add":""},{"Add":" // And unlock the global mutable transaction mutex."},{"Add":" env.mut_txn_unlock()?;"},{"Add":" debug!(\"/COMMIT\");"},{"Add":" Ok(())"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":322,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1116}],"down_context":[{"change":4,"pos":86054}],"flag":"BLOCK","start":15482,"end":15831,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" /// Setting the `num`th element of the initial page, treated as a"},{"Add":" /// `[u64; 510]`, to `value`. This doesn't actually write anything"},{"Add":" /// to that page, since that page is written during the commit."},{"Add":" ///"},{"Add":" /// In the current implementation, `value` is probably going to be"},{"Add":" /// the offset in the file of the root page of a B tree."}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":335,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1567}],"down_context":[{"change":4,"pos":1567}],"flag":"BLOCK","start":15832,"end":15922,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" /// Setting the `num`th element of the initial page, treated as a"},{"Add":" /// [u64; 510]."}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":338,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":1615}],"down_context":[{"change":4,"pos":1615}],"flag":"BLOCK","start":15923,"end":16022,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" if self.roots.get(num).is_none() {"},{"Add":" self.roots.resize(num + 1, 0u64);"},{"Add":" }"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":344,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":86151}],"down_context":[{"change":4,"pos":86151}],"flag":"BLOCK","start":16023,"end":16198,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" /// Add the page at offset `offset` to the list of free pages that"},{"Add":" /// were allocated by this `MutTxn` (and hence can be reallocated"},{"Add":" /// by the same transaction)."}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":352,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":86251}],"down_context":[{"change":4,"pos":86251}],"flag":"BLOCK","start":16199,"end":16375,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" /// Add the page at offset `offset` to the list of free pages"},{"Add":" /// allocated by a previous transaction, and hence may still be"},{"Add":" /// accessible by other transactions."}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":360,"ins":{"up_context":[{"change":4,"pos":86338}],"down_context":[{"change":4,"pos":16213}],"flag":"BLOCK","start":16376,"end":16496,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":86338},"to":{"change":4,"start":86338,"end":86463},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" /// Pop a free page from the B tree of free pages."},{"Add":" fn free_pages_pop(&mut self) -> Result, Error> {"}],"del_contents":[{"Del":" /// Pop a free page from the list of free pages.\n fn free_pages_pop(&mut self) -> Result, crate::Error> {\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":363,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":16241}],"down_context":[{"change":4,"pos":86498}],"flag":"BLOCK","start":16497,"end":16534,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" debug!(\"self.free = 0\");"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":366,"ins":{"up_context":[{"change":4,"pos":86537}],"down_context":[{"change":4,"pos":16242}],"flag":"BLOCK","start":16535,"end":16609,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":86537},"to":{"change":4,"start":27537,"end":27590},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":4093},"to":{"change":4,"start":86624,"end":86651},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":27590},"to":{"change":4,"start":86624,"end":86651},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":86624},"to":{"change":4,"start":86624,"end":86651},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":86651},"to":{"change":4,"start":53115,"end":53238},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":53238},"to":{"change":4,"start":86697,"end":86708},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":86697},"to":{"change":4,"start":86697,"end":86708},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" let mut db: btree::Db = btree::Db::from_page(self.free);"}],"del_contents":[{"Del":" let mut db: btree::Db = btree::Db {\n"},{"Del":" db: self.free,\n"},{"Del":" k: std::marker::PhantomData,\n v: std::marker::PhantomData,\n p: std::marker::PhantomData,\n"},{"Del":" };\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":368,"ins":{"up_context":[{"change":4,"pos":16305}],"down_context":[{"change":4,"pos":86826}],"flag":"BLOCK","start":16610,"end":16676,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":16305},"to":{"change":4,"start":86764,"end":86826},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":86764},"to":{"change":4,"start":86764,"end":86826},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" let mut f = if let Some((f, ())) = curs.set_last(self)? {"}],"del_contents":[{"Del":" let f = if let Some((f, ())) = curs.set_last(self)? {\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":373,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":86898}],"down_context":[{"change":2,"pos":42002}],"flag":"BLOCK","start":16677,"end":17097,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" // Get the last page that is also free in all other versions."},{"Add":" loop {"},{"Add":" debug!(\"trying 0x{:x}\", f);"},{"Add":" if self.free_for_all(f)? {"},{"Add":" break;"},{"Add":" } else if let Some((f_, ())) = curs.prev(self)? {"},{"Add":" f = *f_"},{"Add":" } else {"},{"Add":" debug!(\"no more candidate\");"},{"Add":" return Ok(None);"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" self.free = 0;"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":391,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":87008}],"down_context":[{"change":4,"pos":87008}],"flag":"BLOCK","start":17098,"end":18423,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":""},{"Add":" // Check whether this page is also free for the other"},{"Add":" // versions."},{"Add":" fn free_for_all(&self, f: u64) -> Result {"},{"Add":" let env = self.env.borrow();"},{"Add":" // We already know it's free for the youngest previous"},{"Add":" // transaction and for the current one (because the tree of"},{"Add":" // free pages was copied from there), so we only have"},{"Add":" // `self.roots.len() - 2` root pages to check."},{"Add":" for i in 1..env.roots.len() - 1 {"},{"Add":" let db: btree::Db = unsafe {"},{"Add":" let p = &*(env.mmaps.lock()[0]"},{"Add":" .ptr"},{"Add":" .add(((self.root + i) % env.roots.len()) * PAGE_SIZE)"},{"Add":" as *const GlobalHeader);"},{"Add":" if f >= u64::from_le(p.length) {"},{"Add":" // Page `f` was allocated strictyl after"},{"Add":" // transaction `i`."},{"Add":" continue;"},{"Add":" }"},{"Add":" if p.free_db == 0 {"},{"Add":" // This version doesn't have any free page."},{"Add":" return Ok(false);"},{"Add":" }"},{"Add":" btree::Db::from_page(p.free_db)"},{"Add":" };"},{"Add":" if let Some((&f_, ())) = btree::get(self, &db, &f, None)? {"},{"Add":" if f_ != f {"},{"Add":" return Ok(false);"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" Ok(true)"},{"Add":" }"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":430,"ins":{"up_context":[{"change":4,"pos":87180}],"down_context":[{"change":4,"pos":37524}],"flag":"BLOCK","start":18424,"end":18519,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":87180},"to":{"change":4,"start":87180,"end":87264},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" // If we have allocated and freed a page in this transaction,"},{"Add":" // use it first."}],"del_contents":[{"Del":" // If we have allocated and freed a page in this transaction, use it first.\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":433,"ins":{"up_context":[{"change":4,"pos":37584}],"down_context":[{"change":4,"pos":37584}],"flag":"BLOCK","start":18520,"end":18573,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":37584},"to":{"change":4,"start":13124,"end":13175},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" debug!(\"free owned pop 0x{:x}\", offset);"}],"del_contents":[{"Del":" debug!(\"free owned pop {:?}\", offset);\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":442,"ins":{"up_context":[{"change":4,"pos":37871}],"down_context":[{"change":4,"pos":37871}],"flag":"BLOCK","start":18574,"end":18631,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":37871},"to":{"change":4,"start":13176,"end":13231},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" debug!(\"free pages pop 0x{:x}\", offset);"}],"del_contents":[{"Del":" debug!(\"free pages pop {:?}\", offset);\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":444,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":37948},"to":{"change":4,"start":37948,"end":38010},"introduced_by":4}],"inode":{"change":4,"pos":80166}}},"contents":[{"Del":" let page = MutPage(CowPage { data, offset });\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":445,"ins":{"up_context":[{"change":4,"pos":38052}],"down_context":[{"change":4,"pos":87926}],"flag":"BLOCK","start":18632,"end":18748,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":38052},"to":{"change":4,"start":38052,"end":38114},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":38114},"to":{"change":4,"start":87901,"end":87926},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":87901},"to":{"change":4,"start":87901,"end":87926},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" .push(MutPage(CowPage { data, offset }));"},{"Add":" Ok(MutPage(CowPage { data, offset }))"}],"del_contents":[{"Del":" .push(MutPage(CowPage { offset, data }));\n"},{"Del":" Ok(page)\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":449,"ins":{"up_context":[{"change":4,"pos":88000}],"down_context":[{"change":4,"pos":38115}],"flag":"BLOCK","start":18749,"end":18823,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":88000},"to":{"change":4,"start":88000,"end":88072},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" debug!(\"allocate in the free space 0x{:x}\", self.length);"}],"del_contents":[{"Del":" debug!(\"allocate in the free space {:?}\", self.length);\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":453,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":38235},"to":{"change":4,"start":4094,"end":4156},"introduced_by":4}],"inode":{"change":4,"pos":80166}}},"contents":[{"Del":" let page = MutPage(CowPage { data, offset });\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":455,"ins":{"up_context":[{"change":4,"pos":4260}],"down_context":[{"change":4,"pos":88410}],"flag":"BLOCK","start":18824,"end":18878,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":38418},"to":{"change":4,"start":88385,"end":88410},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":4260},"to":{"change":4,"start":88385,"end":88410},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":88385},"to":{"change":4,"start":88385,"end":88410},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" Ok(MutPage(CowPage { data, offset }))"}],"del_contents":[{"Del":" Ok(page)\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":460,"ins":{"up_context":[{"change":4,"pos":88441}],"down_context":[{"change":4,"pos":88500}],"flag":"BLOCK","start":18879,"end":18995,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":88441},"to":{"change":4,"start":1645,"end":1707},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1707},"to":{"change":4,"start":1509,"end":1560},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" /// Increment the reference count for page `off`."},{"Add":" fn incr_rc(&mut self, off: u64) -> Result {"}],"del_contents":[{"Del":" fn decr_rc(&mut self, off: u64) -> Result {\n"},{"Del":" debug!(\"decr_rc {:?} {:?}\", off, self.rc);\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":464,"ins":{"up_context":[{"change":4,"pos":16374}],"down_context":[{"change":4,"pos":38483}],"flag":"BLOCK","start":18996,"end":19070,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":16374},"to":{"change":2,"start":42065,"end":42106},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":42106},"to":{"change":4,"start":38419,"end":38483},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":88658},"to":{"change":4,"start":38419,"end":38483},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" let rc = if let Some((rc, _)) = curs.set(self, &off, None)? {"}],"del_contents":[{"Del":" curs.set(self, &off, None)?;\n"},{"Del":" let rc = if let Some((rc, ())) = curs.next(self)? {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":466,"ins":{"up_context":[{"change":4,"pos":38524}],"down_context":[{"change":4,"pos":38548}],"flag":"BLOCK","start":19071,"end":19103,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":38524},"to":{"change":4,"start":38524,"end":38548},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" *rc & 0xfff"}],"del_contents":[{"Del":" *rc\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":473,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":38650},"to":{"change":4,"start":625,"end":671},"introduced_by":4}],"inode":{"change":4,"pos":80166}}},"contents":[{"Del":" debug!(\"decr_rc, rc = {:?}\", rc);\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":474,"ins":{"up_context":[{"change":4,"pos":1789}],"down_context":[{"change":4,"pos":89113}],"flag":"BLOCK","start":19104,"end":19175,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":1789},"to":{"change":4,"start":38683,"end":38739},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":38683},"to":{"change":4,"start":38683,"end":38739},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":38739},"to":{"change":4,"start":672,"end":934},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":934},"to":{"change":4,"start":1561,"end":1615},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1752},"to":{"change":4,"start":1935,"end":1992},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":4292},"to":{"change":4,"start":1935,"end":1992},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1615},"to":{"change":4,"start":1935,"end":1992},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":38880},"to":{"change":4,"start":1935,"end":1992},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" btree::del::del_at_cursor(self, &mut rc_, &mut curs)?;"}],"del_contents":[{"Del":" btree::del(self, &mut rc_, &rc, None)?;\n"},{"Del":" if rc & 0xfff > 2 {\n btree::put(self, &mut rc_, &(rc - 1), &())?;\n self.rc = Some(rc_);\n } else {\n // Implicit \"1\".\n self.rc = Some(rc_)\n }\n"},{"Del":" return Ok((rc & 0xfff) as usize - 1);\n"},{"Del":" } else {\n self.rc = Some(rc_)\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":476,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":89127}],"down_context":[{"change":4,"pos":89127}],"flag":"BLOCK","start":19176,"end":19518,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" assert!(rc + 1 <= 0xfff);"},{"Add":" btree::put(self, &mut rc_, &(off | (rc + 1)), &())?;"},{"Add":" self.rc = Some(rc_);"},{"Add":" Ok(rc as usize + 1)"},{"Add":" } else {"},{"Add":" let mut rc = btree::create_db(self)?;"},{"Add":" btree::put(self, &mut rc, &(off | 2), &())?;"},{"Add":" self.rc = Some(rc);"},{"Add":" Ok(2)"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":486,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":89137},"to":{"change":4,"start":89137,"end":89166},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":89166},"to":{"change":4,"start":1753,"end":1767},"introduced_by":4}],"inode":{"change":4,"pos":80166}}},"contents":[{"Del":" self.free_page(off);\n"},{"Del":" Ok(0)\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":488,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":89188}],"down_context":[{"change":4,"pos":1768}],"flag":"BLOCK","start":19519,"end":19705,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" fn decr_rc(&mut self, off: u64) -> Result {"},{"Add":" let rc = self.decr_rc_(off)?;"},{"Add":" if rc == 0 {"},{"Add":" self.free_page(off);"},{"Add":" }"},{"Add":" Ok(rc)"},{"Add":" }"},{"Add":""}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":497,"ins":{"up_context":[{"change":4,"pos":1836}],"down_context":[{"change":4,"pos":89281}],"flag":"BLOCK","start":19706,"end":20318,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1836},"to":{"change":4,"start":1616,"end":1673},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" let rc = self.decr_rc_(off)?;"},{"Add":" if rc == 0 {"},{"Add":" self.free_owned_page(off);"},{"Add":" }"},{"Add":" Ok(rc)"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl, A> MutTxn {"},{"Add":" /// Decrement the reference count of page `off`, freeing that page"},{"Add":" /// if the RC reaches 0 after decrementing it."},{"Add":" fn decr_rc_(&mut self, off: u64) -> Result {"},{"Add":" debug!(\"decr_rc 0x{:x} {:?}\", off, self.rc);"},{"Add":""},{"Add":" // If there's no RC table, free the page. Also, in order to"},{"Add":" // avoid infinite recursion (since `del` and `put` below might"},{"Add":" // free pages), we `take` the reference counter table."}],"del_contents":[{"Del":" debug!(\"decr_rc_owned {:?} {:?}\", off, self.rc);\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":517,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":42148}],"down_context":[{"change":4,"pos":38930}],"flag":"BLOCK","start":20319,"end":20473,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" // The reference count is stored as the 12 LSBs of the"},{"Add":" // keys. If the page isn't in the RC table, the count is"},{"Add":" // 1."}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":529,"ins":{"up_context":[{"change":4,"pos":39178}],"down_context":[{"change":4,"pos":2074}],"flag":"BLOCK","start":20474,"end":20522,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":39178},"to":{"change":4,"start":2037,"end":2074},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" debug!(\"decr_rc, rc = 0x{:x}\", rc);"}],"del_contents":[{"Del":" debug!(\"rc = {:?}\", rc);\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":531,"ins":{"up_context":[{"change":4,"pos":2098}],"down_context":[{"change":4,"pos":39211}],"flag":"BLOCK","start":20523,"end":20682,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2098},"to":{"change":4,"start":1674,"end":1705},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" // If the reference count is strictly more than 2,"},{"Add":" // replace the reference count with a decremented"},{"Add":" // value."}],"del_contents":[{"Del":" debug!(\"del\");\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":535,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":39267},"to":{"change":4,"start":1706,"end":1738},"introduced_by":4}],"inode":{"change":4,"pos":80166}}},"contents":[{"Del":" debug!(\"/del\");\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":539,"ins":{"up_context":[{"change":4,"pos":1102}],"down_context":[{"change":4,"pos":1180}],"flag":"BLOCK","start":20683,"end":20915,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1102},"to":{"change":4,"start":1102,"end":1180},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" // Else, we don't free the page, but don't add the"},{"Add":" // page back, since this is an implicit value of"},{"Add":" // \"1\" for the reference count."},{"Add":" self.rc = Some(rc_)"}],"del_contents":[{"Del":" // Implicit \"1\".\n self.rc = Some(rc_);\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":546,"ins":{"up_context":[{"change":4,"pos":2265}],"down_context":[{"change":4,"pos":89949}],"flag":"BLOCK","start":20916,"end":20952,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2265},"to":{"change":4,"start":2265,"end":2302},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" self.rc = Some(rc_)"}],"del_contents":[{"Del":" self.rc = Some(rc_);\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":549,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90006},"to":{"change":4,"start":90006,"end":90041},"introduced_by":4}],"inode":{"change":4,"pos":80166}}},"contents":[{"Del":" self.free_owned_page(off);\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":550,"atom":{"EdgeMap":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":1896},"to":{"change":4,"start":90056,"end":90063},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90056},"to":{"change":4,"start":90056,"end":90063},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90063},"to":{"change":4,"start":1897,"end":1959},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1959},"to":{"change":4,"start":2303,"end":2340},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90122},"to":{"change":4,"start":2303,"end":2340},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":2340},"to":{"change":4,"start":90122,"end":90170},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90122},"to":{"change":4,"start":90122,"end":90170},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90170},"to":{"change":4,"start":16444,"end":16512},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":16512},"to":{"change":2,"start":42149,"end":42223},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":42223},"to":{"change":4,"start":39474,"end":39547},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":39474},"to":{"change":4,"start":39474,"end":39547},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":39547},"to":{"change":4,"start":90461,"end":90486},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90461},"to":{"change":4,"start":90461,"end":90486},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90486},"to":{"change":4,"start":39548,"end":39570},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":39570},"to":{"change":4,"start":90552,"end":90591},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90552},"to":{"change":4,"start":90552,"end":90591},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90591},"to":{"change":4,"start":39571,"end":39628},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":39628},"to":{"change":2,"start":42224,"end":42295},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":4,"pos":39694},"to":{"change":4,"start":90653,"end":90667},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":2,"pos":42295},"to":{"change":4,"start":90653,"end":90667},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90653},"to":{"change":4,"start":90653,"end":90667},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90667},"to":{"change":4,"start":39695,"end":39798},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":39798},"to":{"change":4,"start":1960,"end":2025},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":2025},"to":{"change":4,"start":2341,"end":2408},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90699},"to":{"change":4,"start":2341,"end":2408},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2408},"to":{"change":4,"start":4325,"end":4382},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":4382},"to":{"change":4,"start":2463,"end":2580},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2463},"to":{"change":4,"start":2463,"end":2580},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2580},"to":{"change":4,"start":2026,"end":2044},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":2044},"to":{"change":4,"start":90699,"end":90709},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":2580},"to":{"change":4,"start":90699,"end":90709},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90699},"to":{"change":4,"start":90699,"end":90709},"introduced_by":4}],"inode":{"change":4,"pos":80166}}},"contents":[{"Del":" }\n\n"},{"Del":" fn incr_rc(&mut self, off: u64) -> Result {\n"},{"Del":" debug!(\"incr_rc {:?}\", off);\n"},{"Del":" if let Some(mut rc_) = self.rc.take() {\n"},{"Del":" let mut curs = btree::cursor::Cursor::new(self, &rc_)?;\n"},{"Del":" let rc = if let Some((rc, _)) = curs.set(self, &off, None)? {\n"},{"Del":" if *rc & !0xfff == off {\n *rc & 0xfff\n"},{"Del":" } else {\n"},{"Del":" 1\n"},{"Del":" }\n } else {\n"},{"Del":" 1\n };\n if rc > 1 {\n"},{"Del":" btree::del::del_at_cursor(self, &mut rc_, &mut curs)?;\n"},{"Del":" }\n"},{"Del":" assert!(rc + 1 <= 0xfff);\n btree::put(self, &mut rc_, &(off | (rc + 1)), &())?;\n"},{"Del":" self.rc = Some(rc_);\n Ok(rc as usize + 1)\n"},{"Del":" } else {\n let mut rc = btree::create_db(self)?;\n"},{"Del":" debug!(\"put in RC: {:?} {:?}\", rc, off | 2);\n"},{"Del":" btree::put(self, &mut rc, &(off | 2), &())?;\n debug!(\"done\");\n self.rc = Some(rc);\n"},{"Del":" Ok(2)\n"},{"Del":" }\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":554,"ins":{"up_context":[{"change":4,"pos":1255}],"down_context":[{"change":4,"pos":39799}],"flag":"BLOCK","start":20953,"end":20977,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":1255},"to":{"change":4,"start":90812,"end":90843},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":90812},"to":{"change":4,"start":90812,"end":90843},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" type Error = Error;"}],"del_contents":[{"Del":" type Error = crate::Error;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":577,"ins":{"up_context":[{"change":4,"pos":4392}],"down_context":[{"change":4,"pos":4672}],"flag":"BLOCK","start":20978,"end":21194,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4392},"to":{"change":4,"start":4392,"end":4442},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4442},"to":{"change":4,"start":13608,"end":13702},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":16648},"to":{"change":4,"start":4529,"end":4562},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":13702},"to":{"change":4,"start":4529,"end":4562},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":12945},"to":{"change":4,"start":4529,"end":4562},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4529},"to":{"change":4,"start":4529,"end":4562},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4562},"to":{"change":4,"start":16649,"end":16704},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":"impl, T> MutTxn {"},{"Add":" /// Low-level method to get the root page number `n`, if that page"},{"Add":" /// isn't a B tree (use the [`RootDb`] trait else)."},{"Add":" pub fn root(&self, n: usize) -> Option {"}],"del_contents":[{"Del":"impl, T> RootDb for MutTxn {\n"},{"Del":" fn root_db>(\n"},{"Del":" &self,\n n: usize,\n"},{"Del":" ) -> Option> {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":582,"ins":{"up_context":[{"change":4,"pos":4718}],"down_context":[{"change":4,"pos":4874}],"flag":"BLOCK","start":21195,"end":21217,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4718},"to":{"change":4,"start":16705,"end":16776},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":16776},"to":{"change":4,"start":53239,"end":53374},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4808},"to":{"change":4,"start":53239,"end":53374},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":53374},"to":{"change":4,"start":16777,"end":16792},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" Some(*db)"}],"del_contents":[{"Del":" Some(sanakirja_core::btree::Db_ {\n db: *db,\n"},{"Del":" k: std::marker::PhantomData,\n v: std::marker::PhantomData,\n p: std::marker::PhantomData,\n"},{"Del":" })\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":587,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4984},"to":{"change":4,"start":4984,"end":5032},"introduced_by":4}],"inode":{"change":4,"pos":80166}}},"contents":[{"Del":" let root = env.root.lock();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":590,"ins":{"up_context":[{"change":4,"pos":13005}],"down_context":[{"change":4,"pos":13082}],"flag":"BLOCK","start":21218,"end":21299,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":13005},"to":{"change":4,"start":13005,"end":13082},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" .add(self.root * PAGE_SIZE + GLOBAL_HEADER_SIZE + 8 * n)"}],"del_contents":[{"Del":" .add(*root * PAGE_SIZE + GLOBAL_HEADER_SIZE + 8 * n)\n"}]}},{"Replacement":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":594,"ins":{"up_context":[{"change":4,"pos":5228}],"down_context":[{"change":4,"pos":5415}],"flag":"BLOCK","start":21300,"end":21329,"inode":{"change":4,"pos":80166}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5228},"to":{"change":4,"start":16793,"end":16875},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":16875},"to":{"change":4,"start":53375,"end":53534},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5333},"to":{"change":4,"start":53375,"end":53534},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":53534},"to":{"change":4,"start":16876,"end":16899},"introduced_by":4}],"inode":{"change":4,"pos":80166}},"ins_contents":[{"Add":" Some(db)"}],"del_contents":[{"Del":" Some(sanakirja_core::btree::Db_ {\n db,\n"},{"Del":" k: std::marker::PhantomData,\n v: std::marker::PhantomData,\n p: std::marker::PhantomData,\n"},{"Del":" })\n"}]}},{"Edit":{"inode":{"change":4,"pos":80166},"path":"sanakirja/src/environment/muttxn.rs","line":599,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":5501}],"down_context":[{"change":4,"pos":5501}],"flag":"BLOCK","start":21330,"end":21781,"inode":{"change":4,"pos":80166}}},"contents":[{"Add":" }"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"impl, T> RootDb for MutTxn {"},{"Add":" // Just call method `root` and convert the result to a `Db`."},{"Add":" fn root_db>("},{"Add":" &self,"},{"Add":" n: usize,"},{"Add":" ) -> Option> {"},{"Add":" if let Some(db) = self.root(n) {"},{"Add":" Some(sanakirja_core::btree::Db_::from_page(db))"},{"Add":" } else {"},{"Add":" None"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":4,"ins":{"up_context":[{"change":4,"pos":1299}],"down_context":[{"change":4,"pos":5550}],"flag":"BLOCK","start":21782,"end":21832,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1299},"to":{"change":4,"start":5512,"end":5550},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":"use parking_lot::lock_api::{RawMutex, RawRwLock};"}],"del_contents":[{"Del":"use parking_lot::lock_api::RawRwLock;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":21,"ins":{"up_context":[{"change":4,"pos":91811}],"down_context":[{"change":4,"pos":91833}],"flag":"BLOCK","start":21833,"end":21866,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":91811},"to":{"change":4,"start":91811,"end":91833},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":"pub(crate) use global_header::*;"}],"del_contents":[{"Del":"use global_header::*;\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":27,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":91909}],"down_context":[{"change":4,"pos":91909}],"flag":"BLOCK","start":21867,"end":21960,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":"/// A chunk of memory, possibly of a memory-mapped file, or allocated"},{"Add":"/// with `std::alloc`."}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":50,"ins":{"up_context":[{"change":4,"pos":92836}],"down_context":[{"change":4,"pos":1534}],"flag":"BLOCK","start":21961,"end":22068,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":93218},"to":{"change":4,"start":93218,"end":93379},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":"/// An environment, which may be either a memory-mapped file, or"},{"Add":"/// memory allocated with [`std::alloc`]."}],"del_contents":[{"Del":"/// Environment, required to start any transactions. Thread-safe, but\n/// opening the same database several times in the same process is not\n/// cross-platform.\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":57,"ins":{"up_context":[{"change":4,"pos":93699}],"down_context":[{"change":4,"pos":93734}],"flag":"BLOCK","start":22069,"end":22110,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":93699},"to":{"change":4,"start":93699,"end":93734},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" mut_txn_lock: parking_lot::RawMutex,"}],"del_contents":[{"Del":" first_unused_page: Mutex,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":59,"ins":{"up_context":[{"change":4,"pos":93735}],"down_context":[{"change":4,"pos":1831}],"flag":"BLOCK","start":22111,"end":22148,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":93735},"to":{"change":4,"start":1552,"end":1617},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1617},"to":{"change":4,"start":5674,"end":5709},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":5709},"to":{"change":4,"start":93799,"end":93802},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":93799},"to":{"change":4,"start":93799,"end":93802},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":93802},"to":{"change":4,"start":1618,"end":1831},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" pub(crate) roots: Vec,"}],"del_contents":[{"Del":" roots: Vec,\n // Root number of the next MutTxn.\n"},{"Del":" pub(crate) root: Mutex,\n"},{"Del":"}\n\n"},{"Del":"struct RootLock {\n /// It is undefined behavior to have a file mmapped for than once.\n #[cfg(feature = \"mmap\")]\n lock_file: Option,\n\n rw: parking_lot::RawRwLock,\n n_txn: AtomicUsize,\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":65,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":93871},"to":{"change":4,"start":93871,"end":93896},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":93896},"to":{"change":4,"start":1891,"end":1911},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1911},"to":{"change":4,"start":93922,"end":93947},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":93922},"to":{"change":4,"start":93922,"end":93947},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":93947},"to":{"change":4,"start":1912,"end":1961},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":1961},"to":{"change":4,"start":94005,"end":94033},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":94005},"to":{"change":4,"start":94005,"end":94033},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":94061},"to":{"change":4,"start":94061,"end":94080},"introduced_by":4}],"inode":{"change":4,"pos":91606}}},"contents":[{"Del":"#[cfg(feature = \"mmap\")]\n"},{"Del":"impl Drop for Env {\n"},{"Del":" fn drop(&mut self) {\n"},{"Del":" for map in self.mmaps.lock().drain(..) {\n"},{"Del":" drop(map.mmap);\n"},{"Del":" }\n }\n}\n\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":75,"ins":{"up_context":[{"change":4,"pos":94324}],"down_context":[{"change":3,"pos":4240}],"flag":"BLOCK","start":22149,"end":22921,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":94324},"to":{"change":4,"start":94324,"end":94354},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":94354},"to":{"change":4,"start":1983,"end":2016},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":2016},"to":{"change":4,"start":94393,"end":94405},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":94393},"to":{"change":4,"start":94393,"end":94405},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":94444},"to":{"change":4,"start":94444,"end":94461},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":94461},"to":{"change":4,"start":94461,"end":94464},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":94464},"to":{"change":3,"start":3457,"end":4240},"introduced_by":3}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":"/// A lock on a root page for this process only, because taking"},{"Add":"/// multiple locks on the same file from a single process isn't"},{"Add":"/// cross-platform (or even properly defined)."},{"Add":"///"},{"Add":"/// Usage is as follows:"},{"Add":"///"},{"Add":"/// - For read-only transactions, we first take a read lock on the `rw`"},{"Add":"/// field, and increment `n_txn`, locking the file if the former value"},{"Add":"/// is 0."},{"Add":"///"},{"Add":"/// - For read-write transactions, we first take a write lock on the"},{"Add":"/// `rw` field, and then take an exclusive lock on the file (this is"},{"Add":"/// valid since only one read-write transaction can be active in a"},{"Add":"/// process at the same time)."},{"Add":"///"},{"Add":"pub(crate) struct RootLock {"},{"Add":" /// It is undefined behavior to have a file mmapped for than once."},{"Add":" #[cfg(feature = \"mmap\")]"},{"Add":" lock_file: Option,"}],"del_contents":[{"Del":"/// An immutable transaction.\n"},{"Del":"pub struct Txn> {\n"},{"Del":" env: E,\n"},{"Del":" root: usize,\n"},{"Del":"}\n\n"},{"Del":"#[cfg(feature = \"mmap\")]\n#[test]\n#[should_panic]\nfn nroots_test() {\n let path = tempfile::tempdir().unwrap();\n let path = path.path().join(\"db\");\n let l0 = 1 << 15; // 8 pages\n Env::new(&path, l0, 19).unwrap();\n}\n\n#[cfg(feature = \"mmap\")]\n#[test]\nfn mmap_growth_test() {\n let path = tempfile::tempdir().unwrap();\n let path = path.path().join(\"db\");\n let l0 = 1 << 15; // 8 pages\n {\n let env = Env::new(&path, l0, 2).unwrap();\n let map1 = env.open_mmap(0, l0).unwrap();\n println!(\"{:?}\", map1);\n let map2 = env.open_mmap(1, l0).unwrap();\n println!(\"{:?}\", map2);\n map1.flush().unwrap();\n map2.flush().unwrap();\n }\n let len = std::fs::metadata(&path).unwrap().len();\n assert_eq!(len, (l0 << 2) - l0);\n}\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":95,"ins":{"up_context":[{"change":3,"pos":4241}],"down_context":[{"change":3,"pos":4301}],"flag":"BLOCK","start":22922,"end":22979,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4241},"to":{"change":3,"start":4241,"end":4301},"introduced_by":3}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" /// Read-write lock."},{"Add":" rw: parking_lot::RawRwLock,"}],"del_contents":[{"Del":"#[cfg(not(feature = \"crc32\"))]\nfn set_crc(_ptr: *mut u8) {}\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":98,"ins":{"up_context":[{"change":3,"pos":4302}],"down_context":[{"change":3,"pos":4618}],"flag":"BLOCK","start":22980,"end":23045,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4302},"to":{"change":3,"start":4302,"end":4618},"introduced_by":3}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" /// Count of read-only transactions."},{"Add":" n_txn: AtomicUsize,"}],"del_contents":[{"Del":"#[cfg(feature = \"crc32\")]\nfn set_crc(ptr: *mut u8) {\n unsafe {\n let root_page = std::slice::from_raw_parts(ptr.add(8), PAGE_SIZE - 8);\n let mut h = HASHER.clone();\n h.update(root_page);\n let globptr = ptr as *mut GlobalHeader;\n (&mut *globptr).crc = h.finalize().to_le();\n }\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":108,"ins":{"up_context":[{"change":4,"pos":94716}],"down_context":[{"change":4,"pos":94800}],"flag":"BLOCK","start":23046,"end":23134,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":94716},"to":{"change":4,"start":94716,"end":94800},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" /// Same as [`new`](#new), but does not create any lock on the"},{"Add":" /// file system."}],"del_contents":[{"Del":" /// Same as [`new`](#new), but does not take a lock on the file\n /// system.\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":111,"ins":{"up_context":[{"change":4,"pos":94808}],"down_context":[{"change":4,"pos":94932}],"flag":"BLOCK","start":23135,"end":23372,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":94808},"to":{"change":4,"start":94808,"end":94932},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" /// The database is very likely to get corrupted if an environment"},{"Add":" /// is opened from multiple processes, or more than once by the"},{"Add":" /// same process, if at least one of these instances can start a"},{"Add":" /// mutable transaction."}],"del_contents":[{"Del":" /// This method is provided because waiting for a lock on the file\n /// system may block the whole process, whereas.\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":116,"ins":{"up_context":[{"change":4,"pos":94940}],"down_context":[{"change":4,"pos":95207}],"flag":"BLOCK","start":23373,"end":23533,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":94940},"to":{"change":4,"start":94940,"end":95207},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" /// The `n_roots` argument is ignored if the database already"},{"Add":" /// exists, and is used to initialise the first `n_roots` pages of"},{"Add":" /// the file else."}],"del_contents":[{"Del":" /// However, the database is very likely to get corrupted if open\n /// more than once at the same time, even within the same process.\n ///\n /// Therefore, do not use this method without another locking\n /// mechanism in place to avoid that situation.\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":125,"ins":{"up_context":[{"change":4,"pos":5849}],"down_context":[{"change":4,"pos":95563}],"flag":"BLOCK","start":23534,"end":23629,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5849},"to":{"change":3,"start":4667,"end":4791},"introduced_by":3}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" let meta = std::fs::metadata(&path);"},{"Add":" let length = if let Ok(ref meta) = meta {"}],"del_contents":[{"Del":" let db_exists = std::fs::metadata(&path).is_ok();\n let length = if let Ok(meta) = std::fs::metadata(&path) {\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":131,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":95677}],"down_context":[{"change":4,"pos":13372}],"flag":"BLOCK","start":23630,"end":23723,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" // Find the next multiple of PAGE_SIZE greater than or equal"},{"Add":" // to `length`."}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":134,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":13444}],"down_context":[{"change":4,"pos":95726}],"flag":"BLOCK","start":23724,"end":23725,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":""}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":143,"ins":{"up_context":[{"change":4,"pos":95982}],"down_context":[{"change":4,"pos":96139}],"flag":"BLOCK","start":23726,"end":23802,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":95982},"to":{"change":3,"start":4820,"end":4897},"introduced_by":3}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" Self::new_nolock_(Some(file), length, mmap, meta.is_err(), n_roots)"}],"del_contents":[{"Del":" Self::new_nolock_mmap(Some(file), length, mmap, !db_exists, n_roots)\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":146,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":96146}],"down_context":[{"change":4,"pos":96146}],"flag":"BLOCK","start":23803,"end":23899,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" /// Create an environment from a file, without creating any lock"},{"Add":" /// on the filesystem."}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":149,"ins":{"up_context":[{"change":4,"pos":96175}],"down_context":[{"change":4,"pos":96206}],"flag":"BLOCK","start":23900,"end":23927,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96175},"to":{"change":4,"start":96175,"end":96206},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" unsafe fn new_nolock_("}],"del_contents":[{"Del":" unsafe fn new_nolock_mmap(\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":156,"ins":{"up_context":[{"change":4,"pos":96356}],"down_context":[{"change":4,"pos":96356}],"flag":"BLOCK","start":23928,"end":24046,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96356},"to":{"change":3,"start":4898,"end":4952},"introduced_by":3}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" assert!(n_roots >= 1);"},{"Add":" assert!(n_roots <= ((length >> 12) as usize));"},{"Add":" assert!(n_roots < 256);"}],"del_contents":[{"Del":" assert!(n_roots < ((length >> 12) as usize));\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":160,"ins":{"up_context":[{"change":4,"pos":96393}],"down_context":[{"change":3,"pos":5105}],"flag":"BLOCK","start":24047,"end":24599,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96393},"to":{"change":3,"start":4953,"end":4977},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":4977},"to":{"change":4,"start":96453,"end":96487},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96453},"to":{"change":4,"start":96453,"end":96487},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96487},"to":{"change":3,"start":4978,"end":5059},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":5059},"to":{"change":4,"start":96570,"end":96645},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":4,"pos":2384},"to":{"change":4,"start":96570,"end":96645},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96570},"to":{"change":4,"start":96570,"end":96645},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96645},"to":{"change":4,"start":2385,"end":2429},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":2429},"to":{"change":4,"start":96674,"end":96702},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96674},"to":{"change":4,"start":96674,"end":96702},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96702},"to":{"change":4,"start":2640,"end":2698},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":2458},"to":{"change":4,"start":96751,"end":96813},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":2698},"to":{"change":4,"start":96751,"end":96813},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96751},"to":{"change":4,"start":96751,"end":96813},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96813},"to":{"change":3,"start":5060,"end":5105},"introduced_by":3}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" let n_roots = if initialise {"},{"Add":" // Initialise the first `n_roots` pages at the start of"},{"Add":" // the file."},{"Add":" init(map, n_roots);"},{"Add":" // Since the first `n_roots` pages are occupied by roots,"},{"Add":" // the first unused page is found at offset `n_roots *"},{"Add":" // PAGE_SIZE`."},{"Add":" n_roots"},{"Add":" } else {"},{"Add":" // Read the root and number of roots from the first page's"},{"Add":" // header."},{"Add":" GlobalHeader::from_le(&*(map as *const GlobalHeader)).n_roots as usize"},{"Add":" };"}],"del_contents":[{"Del":" if initialise {\n"},{"Del":" for i in 0..n_roots {\n"},{"Del":" *(map.add(i * PAGE_SIZE) as *mut GlobalHeader) = (GlobalHeader {\n"},{"Del":" version: CURRENT_VERSION,\n root: 0,\n"},{"Del":" n_roots: n_roots as u8,\n"},{"Del":" crc: 0,\n"},{"Del":" length: (n_roots * PAGE_SIZE) as u64,\n"},{"Del":" free_db: 0,\n rc_db: 0,\n"},{"Del":" })\n .to_le();\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":174,"ins":{"up_context":[{"change":3,"pos":5106}],"down_context":[{"change":4,"pos":97167}],"flag":"BLOCK","start":24600,"end":24644,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5106},"to":{"change":3,"start":5106,"end":5155},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":5155},"to":{"change":4,"start":96832,"end":96846},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96832},"to":{"change":4,"start":96832,"end":96846},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":96846},"to":{"change":3,"start":5156,"end":5240},"introduced_by":3},{"previous":"","flag":"DELETED","from":{"change":3,"pos":5240},"to":{"change":4,"start":2593,"end":2909},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":97004},"to":{"change":4,"start":2593,"end":2909},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":2909},"to":{"change":4,"start":97157,"end":97167},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":97157},"to":{"change":4,"start":97157,"end":97167},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" // Finally, create the environment."}],"del_contents":[{"Del":" set_crc(map.add(i * PAGE_SIZE));\n"},{"Del":" }\n"},{"Del":" }\n let glob = GlobalHeader::from_le(&*(map as *const GlobalHeader));\n"},{"Del":" let mut roots = Vec::with_capacity(glob.n_roots as usize);\n for _ in 0..glob.n_roots {\n roots.push(RootLock {\n rw: ::INIT,\n n_txn: AtomicUsize::new(0),\n lock_file: None,\n })\n"},{"Del":" }\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":182,"ins":{"up_context":[{"change":4,"pos":97367}],"down_context":[{"change":4,"pos":97514}],"flag":"BLOCK","start":24645,"end":24998,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":97396},"to":{"change":4,"start":97396,"end":97442},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":97442},"to":{"change":4,"start":2910,"end":2979},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" mut_txn_lock: RawMutex::INIT,"},{"Add":""},{"Add":" // Initialise a different `RootLock` for each root page."},{"Add":" roots: (0..n_roots)"},{"Add":" .map(|_| RootLock {"},{"Add":" rw: RawRwLock::INIT,"},{"Add":" n_txn: AtomicUsize::new(0),"},{"Add":" lock_file: None,"},{"Add":" })"},{"Add":" .collect(),"}],"del_contents":[{"Del":" first_unused_page: Mutex::new(2),\n"},{"Del":" roots,\n root: Mutex::new(glob.root as usize),\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":196,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":97548}],"down_context":[{"change":4,"pos":97548}],"flag":"BLOCK","start":24999,"end":25042,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" /// No-mmap version of the same thing."}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":198,"ins":{"up_context":[{"change":4,"pos":97582}],"down_context":[{"change":4,"pos":97678}],"flag":"BLOCK","start":25043,"end":25258,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":97582},"to":{"change":4,"start":2980,"end":3065},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" unsafe fn new_nolock_(length: u64, initialise: bool, n_roots: usize) -> Result {"},{"Add":" assert!(n_roots >= 1);"},{"Add":" assert!(n_roots <= ((length >> 12) as usize));"},{"Add":" assert!(n_roots < 256);"}],"del_contents":[{"Del":" unsafe fn new_nolock_mmap(length: u64, initialise: bool) -> Result {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":205,"ins":{"up_context":[{"change":4,"pos":97840}],"down_context":[{"change":4,"pos":98554}],"flag":"BLOCK","start":25259,"end":25287,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":97840},"to":{"change":4,"start":97840,"end":98453},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":98453},"to":{"change":4,"start":3066,"end":3247},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":3247},"to":{"change":4,"start":98544,"end":98554},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":98544},"to":{"change":4,"start":98544,"end":98554},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" init(map, n_roots);"}],"del_contents":[{"Del":" let n_roots = 2;\n for i in 0..n_roots {\n *(map.offset((i * PAGE_SIZE) as isize) as *mut GlobalHeader) = (GlobalHeader {\n version: CURRENT_VERSION,\n root: 0,\n n_roots: n_roots as u8,\n crc: 0,\n length: n_roots as u64 * PAGE_SIZE as u64,\n free_db: 0,\n rc_db: 0,\n })\n .to_le();\n }\n let glob = GlobalHeader::from_le(&*(map as *const GlobalHeader));\n let mut roots = Vec::with_capacity(glob.n_roots as usize);\n for _ in 0..glob.n_roots {\n"},{"Del":" roots.push(RootLock {\n rw: ::INIT,\n n_txn: AtomicUsize::new(0),\n })\n"},{"Del":" }\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":212,"ins":{"up_context":[{"change":4,"pos":98710}],"down_context":[{"change":4,"pos":98874}],"flag":"BLOCK","start":25288,"end":25603,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":98759},"to":{"change":4,"start":98759,"end":98874},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" mut_txn_lock: RawMutex::INIT,"},{"Add":" // Initialise a different `RootLock` for each root page."},{"Add":" roots: (0..n_roots)"},{"Add":" .map(|_| RootLock {"},{"Add":" rw: RawRwLock::INIT,"},{"Add":" n_txn: AtomicUsize::new(0),"},{"Add":" })"},{"Add":" .collect(),"}],"del_contents":[{"Del":" first_unused_page: Mutex::new(2),\n roots,\n root: Mutex::new(glob.root as usize),\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":222,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":98901}],"down_context":[{"change":4,"pos":98901}],"flag":"BLOCK","start":25604,"end":26059,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"unsafe fn init(map: *mut u8, n_roots: usize) {"},{"Add":" for i in 0..n_roots {"},{"Add":" *(map.offset((i * PAGE_SIZE) as isize) as *mut GlobalHeader) = (GlobalHeader {"},{"Add":" version: CURRENT_VERSION,"},{"Add":" root: 0,"},{"Add":" n_roots: n_roots as u8,"},{"Add":" crc: 0,"},{"Add":" length: n_roots as u64 * PAGE_SIZE as u64,"},{"Add":" free_db: 0,"},{"Add":" rc_db: 0,"},{"Add":" })"},{"Add":" .to_le();"},{"Add":" set_crc(map.add(i * PAGE_SIZE));"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":239,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":98907}],"down_context":[{"change":4,"pos":98909}],"flag":"BLOCK","start":26060,"end":26062,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":"}"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":241,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":98910}],"down_context":[{"change":4,"pos":99665}],"flag":"BLOCK","start":26063,"end":26074,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":"impl Env {"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":274,"ins":{"up_context":[{"change":4,"pos":102174}],"down_context":[{"change":4,"pos":102241}],"flag":"BLOCK","start":26075,"end":26147,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":102174},"to":{"change":4,"start":4298,"end":4374},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" unsafe { Self::new_nolock_(None, length, mmap, true, n_roots) }"}],"del_contents":[{"Del":" unsafe { Self::new_nolock_mmap(None, length, mmap, true, n_roots) }\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":280,"ins":{"up_context":[{"change":4,"pos":102404}],"down_context":[{"change":4,"pos":13561}],"flag":"BLOCK","start":26148,"end":26221,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":102404},"to":{"change":4,"start":4375,"end":4432},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" pub fn new_anon(length: u64, n_roots: usize) -> Result {"}],"del_contents":[{"Del":" pub fn new_anon(length: u64) -> Result {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":283,"ins":{"up_context":[{"change":4,"pos":13676}],"down_context":[{"change":4,"pos":102597}],"flag":"BLOCK","start":26222,"end":26282,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":6116},"to":{"change":4,"start":102542,"end":102597},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":13676},"to":{"change":4,"start":102542,"end":102597},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":102542},"to":{"change":4,"start":102542,"end":102597},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" unsafe { Self::new_nolock_(length, true, n_roots) }"}],"del_contents":[{"Del":" unsafe { Self::new_nolock_mmap(length, true) }\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":285,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":102603}],"down_context":[{"change":4,"pos":102605}],"flag":"BLOCK","start":26283,"end":26555,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":""},{"Add":" /// Now, here is how databases grow: when we run out of space, we"},{"Add":" /// allocate a new chunk of memory/disk space, of a size twice as"},{"Add":" /// large as the last chunk. The size of the first chunk is the"},{"Add":" /// size of the file when we first opened the environment."}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":291,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":102606}],"down_context":[{"change":4,"pos":102623}],"flag":"BLOCK","start":26556,"end":26648,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" /// Allocate the memory of the appropriate size and offest for the"},{"Add":" /// `i`th chunk."}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":305,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":103005}],"down_context":[{"change":4,"pos":103005}],"flag":"BLOCK","start":26649,"end":26759,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" /// The same, but for memory-mapped file. If we're doing that, it"},{"Add":" /// means we need to grow the file."}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":334,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":103989}],"down_context":[{"change":4,"pos":103989}],"flag":"BLOCK","start":26760,"end":26952,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" /// Find an offset in a file, possibly mapping more of the file if"},{"Add":" /// necessary (for example if the file has been grown by another"},{"Add":" /// process since we openend this environment)."}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":346,"ins":{"up_context":[{"change":4,"pos":104335}],"down_context":[{"change":4,"pos":104396}],"flag":"BLOCK","start":26953,"end":27011,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":104335},"to":{"change":4,"start":104335,"end":104396},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" return mmaps[i].ptr.add(offset as usize);"}],"del_contents":[{"Del":" return mmaps[i].ptr.offset(offset as isize);\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":350,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":104468},"to":{"change":4,"start":104468,"end":105034},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":105034},"to":{"change":4,"start":4433,"end":4480},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":4480},"to":{"change":4,"start":105090,"end":105116},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":105090},"to":{"change":4,"start":105090,"end":105116},"introduced_by":4}],"inode":{"change":4,"pos":91606}}},"contents":[{"Del":" }\n }\n /// Close this repository, releasing the locks. It is undefined\n /// behaviour to use the environment afterwards. This method can\n /// be used for instance to release the locks before allocating a\n /// new environment (note that `std::mem::replace` followed by\n /// `Drop::drop` of the previous value would not release the locks\n /// in the correct order).\n ///\n /// The safe alternative to this method is to use an `Option`\n /// instead of an `Env`.\n #[cfg(feature = \"mmap\")]\n pub unsafe fn close(&mut self) {\n"},{"Del":" for m in self.mmaps.lock().drain(..) {\n"},{"Del":" drop(m.mmap);\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":351,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":105126},"to":{"change":4,"start":4481,"end":4623},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":4623},"to":{"change":4,"start":105211,"end":105221},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":105211},"to":{"change":4,"start":105211,"end":105221},"introduced_by":4}],"inode":{"change":4,"pos":91606}}},"contents":[{"Del":" for l in self.roots.drain(..) {\n if let Some(ref f) = l.lock_file {\n f.unlock().unwrap_or(())\n }\n"},{"Del":" }\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":362,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":105565}],"down_context":[{"change":4,"pos":105565}],"flag":"BLOCK","start":27012,"end":27948,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" /// If the CRC feature is disabled, we're not checking CRCs."},{"Add":" #[cfg(not(feature = \"crc32\"))]"},{"Add":" fn check_crc(&self, _root: usize) -> Result<(), crate::CRCError> {"},{"Add":" Ok(())"},{"Add":" }"},{"Add":""},{"Add":" /// Else, we are checking CRCs, so return a CRC error if the check"},{"Add":" /// fails (the CRC is a 32 bit integer encoded little-endian at"},{"Add":" /// bytes [8,12[ of the root pages)."},{"Add":" #[cfg(feature = \"crc32\")]"},{"Add":" fn check_crc(&self, root: usize) -> Result<(), crate::CRCError> {"},{"Add":" unsafe {"},{"Add":" let maps = self.mmaps.lock();"},{"Add":" let page_ptr = maps[0].ptr.add(root * PAGE_SIZE);"},{"Add":" let crc = (&*(page_ptr as *const GlobalHeader)).crc;"},{"Add":" let root_page = std::slice::from_raw_parts(page_ptr.add(8), PAGE_SIZE - 8);"},{"Add":" let mut h = HASHER.clone();"},{"Add":" h.update(root_page);"},{"Add":" if h.finalize() != crc {"},{"Add":" return Err(crate::CRCError {});"},{"Add":" }"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":387,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":105575}],"down_context":[{"change":4,"pos":105575}],"flag":"BLOCK","start":27949,"end":27964,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" Ok(())"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":397,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":5838}],"down_context":[{"change":4,"pos":105581}],"flag":"BLOCK","start":27965,"end":29235,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":"}"},{"Add":""},{"Add":"#[cfg(feature = \"mmap\")]"},{"Add":"#[test]"},{"Add":"#[should_panic]"},{"Add":"fn nroots_test() {"},{"Add":" let path = tempfile::tempdir().unwrap();"},{"Add":" let path = path.path().join(\"db\");"},{"Add":" let l0 = 1 << 15; // 8 pages"},{"Add":" Env::new(&path, l0, 19).unwrap();"},{"Add":"}"},{"Add":""},{"Add":"#[cfg(feature = \"mmap\")]"},{"Add":"#[test]"},{"Add":"fn mmap_growth_test() {"},{"Add":" let path = tempfile::tempdir().unwrap();"},{"Add":" let path = path.path().join(\"db\");"},{"Add":" let l0 = 1 << 15; // 8 pages"},{"Add":" {"},{"Add":" let env = Env::new(&path, l0, 2).unwrap();"},{"Add":" let map1 = env.open_mmap(0, l0).unwrap();"},{"Add":" println!(\"{:?}\", map1);"},{"Add":" let map2 = env.open_mmap(1, l0).unwrap();"},{"Add":" println!(\"{:?}\", map2);"},{"Add":" map1.flush().unwrap();"},{"Add":" map2.flush().unwrap();"},{"Add":" }"},{"Add":" let len = std::fs::metadata(&path).unwrap().len();"},{"Add":" assert_eq!(len, (l0 << 2) - l0);"},{"Add":"}"},{"Add":""},{"Add":"#[cfg(not(feature = \"crc32\"))]"},{"Add":"fn set_crc(_ptr: *mut u8) {}"},{"Add":""},{"Add":"#[cfg(feature = \"crc32\")]"},{"Add":"fn set_crc(ptr: *mut u8) {"},{"Add":" unsafe {"},{"Add":" let root_page = std::slice::from_raw_parts(ptr.add(8), PAGE_SIZE - 8);"},{"Add":" let mut h = HASHER.clone();"},{"Add":" h.update(root_page);"},{"Add":" let globptr = ptr as *mut GlobalHeader;"},{"Add":" (&mut *globptr).crc = h.finalize().to_le();"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"/// An immutable transaction."},{"Add":"pub struct Txn> {"},{"Add":" env: E,"},{"Add":" pub(crate) root: usize,"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":451,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4709},"to":{"change":4,"start":3421,"end":3441},"introduced_by":4}],"inode":{"change":4,"pos":91606}}},"contents":[{"Del":" use log::*;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":453,"ins":{"up_context":[{"change":4,"pos":105737}],"down_context":[{"change":4,"pos":3517}],"flag":"BLOCK","start":29236,"end":29895,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":105774},"to":{"change":4,"start":3442,"end":3475},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":3475},"to":{"change":4,"start":105774,"end":105889},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":105774},"to":{"change":4,"start":105774,"end":105889},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":105889},"to":{"change":4,"start":3476,"end":3517},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" // Find the youngest committed version and lock it. Note"},{"Add":" // that there may be processes incrementing the version"},{"Add":" // number in parallel to this process. If that happens,"},{"Add":" // then since we take a shared file lock on a root page"},{"Add":" // (at the end of this function), the only thing that may"},{"Add":" // happen is that we don't open the very last version."},{"Add":" let cur_mut_root ="},{"Add":" unsafe { (&*(env_.mmaps.lock()[0].ptr as *const GlobalHeader)).root as usize };"},{"Add":" // Last committed root page."},{"Add":" let root = (cur_mut_root + env_.roots.len() - 1) % env_.roots.len();"}],"del_contents":[{"Del":" debug!(\"root lock\");\n"},{"Del":" let root = env_.root.lock();\n let root = (*root + env_.roots.len() - 1) % env_.roots.len();\n"},{"Del":" debug!(\"shared {:?}\", root);\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":464,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":3564}],"down_context":[{"change":4,"pos":4711}],"flag":"BLOCK","start":29896,"end":30032,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" // Increase the read-only transaction count for that root,"},{"Add":" // and if the previous value is 0, take a file lock."}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":467,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4794},"to":{"change":4,"start":3565,"end":3615},"introduced_by":4}],"inode":{"change":4,"pos":91606}}},"contents":[{"Del":" debug!(\"old_n_txn: {:?}\", old_n_txn);\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":468,"ins":{"up_context":[{"change":4,"pos":4826}],"down_context":[{"change":4,"pos":4999}],"flag":"BLOCK","start":30033,"end":30073,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4877},"to":{"change":4,"start":4877,"end":4943},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4943},"to":{"change":4,"start":3616,"end":3664},"introduced_by":4},{"previous":"","flag":"DELETED","from":{"change":4,"pos":3664},"to":{"change":4,"start":4943,"end":4999},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":4943},"to":{"change":4,"start":4943,"end":4999},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" env_.lock_shared(root)?"}],"del_contents":[{"Del":" if let Some(ref f) = env_.roots[root].lock_file {\n"},{"Del":" debug!(\"file lock shared\");\n"},{"Del":" f.lock_shared()?;\n }\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":476,"ins":{"up_context":[{"change":3,"pos":5912}],"down_context":[{"change":3,"pos":6018}],"flag":"BLOCK","start":30074,"end":30263,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":5912},"to":{"change":3,"start":5912,"end":6018},"introduced_by":3}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" #[cfg(feature = \"mmap\")]"},{"Add":" fn lock_shared(&self, root: usize) -> Result<(), Error> {"},{"Add":" if let Some(ref f) = self.roots[root].lock_file {"},{"Add":" f.lock_shared()?;"},{"Add":" }"}],"del_contents":[{"Del":" #[cfg(not(feature = \"crc32\"))]\n fn check_crc(&self, _root: usize) -> Result<(), crate::CRCError> {\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":484,"ins":{"up_context":[{"change":3,"pos":6040}],"down_context":[{"change":3,"pos":6586}],"flag":"BLOCK","start":30264,"end":30890,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":6040},"to":{"change":3,"start":6040,"end":6586},"introduced_by":3}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" #[cfg(not(feature = \"mmap\"))]"},{"Add":" fn lock_shared(&self, _root: usize) -> Result<(), Error> {"},{"Add":" Ok(())"},{"Add":" }"},{"Add":""},{"Add":" #[cfg(feature = \"mmap\")]"},{"Add":" fn lock_exclusive(&self, root: usize) -> Result<(), Error> {"},{"Add":" if let Some(ref f) = self.roots[root].lock_file {"},{"Add":" f.lock_exclusive()?;"},{"Add":" }"},{"Add":" Ok(())"},{"Add":" }"},{"Add":""},{"Add":" #[cfg(not(feature = \"mmap\"))]"},{"Add":" fn lock_exclusive(&self, _root: usize) -> Result<(), Error> {"},{"Add":" Ok(())"},{"Add":" }"},{"Add":""},{"Add":" #[cfg(feature = \"mmap\")]"},{"Add":" fn unlock(&self, root: usize) -> Result<(), Error> {"},{"Add":" if let Some(ref f) = self.roots[root].lock_file {"},{"Add":" f.unlock()?"}],"del_contents":[{"Del":" #[cfg(feature = \"crc32\")]\n fn check_crc(&self, root: usize) -> Result<(), crate::CRCError> {\n unsafe {\n let maps = self.mmaps.lock();\n let page_ptr = maps[0].ptr.add(root * PAGE_SIZE);\n let crc = (&*(page_ptr as *const GlobalHeader)).crc;\n let root_page = std::slice::from_raw_parts(page_ptr.add(8), PAGE_SIZE - 8);\n let mut h = HASHER.clone();\n h.update(root_page);\n if h.finalize() != crc {\n return Err(crate::CRCError {});\n }\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":507,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":6596}],"down_context":[{"change":3,"pos":6596}],"flag":"BLOCK","start":30891,"end":31005,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" Ok(())"},{"Add":" }"},{"Add":""},{"Add":" #[cfg(not(feature = \"mmap\"))]"},{"Add":" fn unlock(&self, _root: usize) -> Result<(), Error> {"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":522,"ins":{"up_context":[{"change":4,"pos":5196}],"down_context":[{"change":4,"pos":5380}],"flag":"BLOCK","start":31006,"end":31054,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5259},"to":{"change":4,"start":5259,"end":5380},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" env.unlock(self.root).unwrap_or(())"}],"del_contents":[{"Del":" if let Some(ref f) = env.roots[self.root].lock_file {\n f.unlock().unwrap_or(())\n }\n"}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":528,"ins":{"up_context":[{"change":4,"pos":5450}],"down_context":[{"change":4,"pos":106351}],"flag":"BLOCK","start":31055,"end":31079,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":5450},"to":{"change":4,"start":106320,"end":106351},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":106320},"to":{"change":4,"start":106320,"end":106351},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" type Error = Error;"}],"del_contents":[{"Del":" type Error = crate::Error;\n"}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":543,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":106701}],"down_context":[{"change":4,"pos":16926}],"flag":"BLOCK","start":31080,"end":31310,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":"/// The trait, implemented by [`Txn`] and [`MutTxn`], for treating the"},{"Add":"/// 4064 bytes after the header of root pages as pointers to B trees"},{"Add":"/// (well, actually `Option` of pointers to databases, where `None` is"},{"Add":"/// encoded by 0)."}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":548,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":16945}],"down_context":[{"change":4,"pos":13745}],"flag":"BLOCK","start":31311,"end":31420,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" /// Return the database stored in the root page of the current"},{"Add":" /// transaction at index `n`, if any."}]}},{"Edit":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":557,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":17211}],"down_context":[{"change":4,"pos":13840}],"flag":"BLOCK","start":31421,"end":31499,"inode":{"change":4,"pos":91606}}},"contents":[{"Add":" /// This is a straightforward implementation of just accessing index `n`."}]}},{"Replacement":{"inode":{"change":4,"pos":91606},"path":"sanakirja/src/environment/mod.rs","line":572,"ins":{"up_context":[{"change":4,"pos":17729}],"down_context":[{"change":4,"pos":17969}],"flag":"BLOCK","start":31500,"end":31564,"inode":{"change":4,"pos":91606}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":17729},"to":{"change":4,"start":17729,"end":17969},"introduced_by":4}],"inode":{"change":4,"pos":91606}},"ins_contents":[{"Add":" Some(sanakirja_core::btree::Db_::from_page(db))"}],"del_contents":[{"Del":" Some(sanakirja_core::btree::Db_ {\n db,\n k: std::marker::PhantomData,\n v: std::marker::PhantomData,\n p: std::marker::PhantomData,\n })\n"}]}},{"Edit":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/debug.rs","line":1,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":11},"to":{"change":4,"start":12,"end":39},"introduced_by":4}],"inode":{"change":4,"pos":11}}},"contents":[{"Del":"use sanakirja_core::btree;\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/debug.rs","line":36,"ins":{"up_context":[{"change":4,"pos":14112}],"down_context":[{"change":4,"pos":955}],"flag":"BLOCK","start":31565,"end":31589,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":14112},"to":{"change":4,"start":924,"end":955},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":924},"to":{"change":4,"start":924,"end":955},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" P: BTreePage,"}],"del_contents":[{"Del":" P: btree::BTreePage,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/debug.rs","line":78,"ins":{"up_context":[{"change":4,"pos":14201}],"down_context":[{"change":4,"pos":2027}],"flag":"BLOCK","start":31590,"end":31614,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":4,"pos":14201},"to":{"change":4,"start":1996,"end":2027},"introduced_by":4},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":1996},"to":{"change":4,"start":1996,"end":2027},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" P: BTreePage,"}],"del_contents":[{"Del":" P: btree::BTreePage,\n"}]}},{"Replacement":{"inode":{"change":4,"pos":11},"path":"sanakirja/src/debug.rs","line":81,"ins":{"up_context":[{"change":4,"pos":2043}],"down_context":[{"change":4,"pos":2077}],"flag":"BLOCK","start":31615,"end":31640,"inode":{"change":4,"pos":11}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":2043},"to":{"change":4,"start":2043,"end":2077},"introduced_by":4}],"inode":{"change":4,"pos":11}},"ins_contents":[{"Add":" buf: &mut dyn Write,"}],"del_contents":[{"Del":" buf: &mut dyn std::io::Write,\n"}]}},{"Edit":{"inode":{"change":4,"pos":108411},"path":"sanakirja/Cargo.toml","line":16,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":84}],"down_context":[{"change":4,"pos":5528}],"flag":"BLOCK","start":31641,"end":31706,"inode":{"change":4,"pos":108411}}},"contents":[{"Add":"sanakirja-core = { path = \"../sanakirja-core\", version = \"1.0\" }"}]}},{"Edit":{"inode":{"change":4,"pos":108411},"path":"sanakirja/Cargo.toml","line":19,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5617},"to":{"change":4,"start":85,"end":150},"introduced_by":4}],"inode":{"change":4,"pos":108411}}},"contents":[{"Del":"sanakirja-core = { path = \"../sanakirja-core\", version = \"1.0\" }\n"}]}}],"owner":"pijul","repo":"sanakirja","token":"PsvluzRRjuzm8fKooOKGD7XG5YW+8FaxDhQvusWbgAw=","login":null}

…

Dependencies

Change contents