{"header":{"message":"Reproducing record performance issues (mtime?)","description":null,"timestamp":"2026-08-06T05:35:20.116127508Z","authors":[{}]},"hash":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC","authors":[{"login":"pmeunier","key":"AAAAC3NzaC1lZDI1NTE5AAAAILagOJFgwaMNhBWQINinKOXmqS4Gh5NgxgriXwdOoINJ"}],"deps":{"hashes":[["MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC","Reproducing record performance issues (mtime?)"],["AA",null],["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","Fixing the bad changes in history (unfortunately, by rebooting)."],["VO5OQW4W2656DIYYRNZ3PO7TQ4JOKQ3GVWE5ALUTYVMX3WMXJOYQC","Removing anyhow in libpijul"],["CCLLB7OIFNFYJZTG3UCI7536TOCWSCSXR67VELSB466R24WLJSDAC","Upgrading to Sanakirja 0.15 + version bump"],["YN63NUZO4LVJ7XPMURDULTXBVJKW5MVCTZ24R7Z52QMHO3HPDUVQC","Sanakirja 1.0"],["TIPZ7UXNIZ3UMIXDUP2M33FUP7LY3XM2NX424ZE4EO5V7CZTOGXQC","Started fixing the tests for parallel record/output"],["TVVW53HZGYPODAXEQ4BFZNSPBOFG6JEDVOKIYIDZMWFAMOBKOR2QC","Conflict resolution"],["SHSJ3Y5332WHVUDDQZ2P7GH6VMC7XIX5L7BDJUUMF3QCDRZP7NLQC","Fixing more tests"],["V4T4SC7OL6WEZNV4XSFBSXY5HPB7VXPSXWSK4Z63QXKQD4JSFNCQC","Testing binary diff"],["QU6T6J6WEZ6IYZC57YAUCET2V6WHVKJ2Q4UGB2GOK45VIGDPBR2QC","Use the change time in addition to the modified time when detecting untouched files (at least on Unix)"],["7KNPYIDUXCBZ65NA74NL2DIFS6STJWN4XXHXLTIV5QXZSVLARJMAC","Splitting the WorkingCopy trait into a read-only record and a read/write output"],["HOTQHK5URWTJ4IBMSWYPZQOPHA2ZQSPQAN5MAKGUDUAC6LZRDKOQC","Fixing tests"],["QFXBAVXMCWV55XG3F4EGJP7PUCATRUHAARZWUZJRAZ7XLRARYIXQC","Unix modification time in record: use the max of change and modify, not the min"],["N5XHCYVTEDH5SJGWHE76A66KDU5CVHM7U5RXWZDE2TT7L3XPGKEAC","Remove use of unsafe"],["7FP2DFNXGKH2GQIH35BAIHMRORXERI6ARZGVVN7LZKMUYIADIULAC","Optimisation: avoid re-checking the entire repo when recording after an unrecord"],["AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC","Adding tests"],["T46UZK3SOTQGXP2VTHMNBDNQPAGAWHXRQ2LAVG4MR6ENQMNPI2WAC","test: an amended change supersedes its predecessor on apply"],["2TBQL7NI46BBWLKOGDJKR2MLD5SX7N4UHXB23TXR4WKJHKQR2JMQC","Fixing the tests"],["GPKQHSA5ZIJCBZYB33TJEWOU3JFA6KSLYPBBI7DG5HTZTKSPEF4AC","Deleted zombies are zombies too"]],"deps":["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","VO5OQW4W2656DIYYRNZ3PO7TQ4JOKQ3GVWE5ALUTYVMX3WMXJOYQC","CCLLB7OIFNFYJZTG3UCI7536TOCWSCSXR67VELSB466R24WLJSDAC","YN63NUZO4LVJ7XPMURDULTXBVJKW5MVCTZ24R7Z52QMHO3HPDUVQC","TIPZ7UXNIZ3UMIXDUP2M33FUP7LY3XM2NX424ZE4EO5V7CZTOGXQC","TVVW53HZGYPODAXEQ4BFZNSPBOFG6JEDVOKIYIDZMWFAMOBKOR2QC","SHSJ3Y5332WHVUDDQZ2P7GH6VMC7XIX5L7BDJUUMF3QCDRZP7NLQC","V4T4SC7OL6WEZNV4XSFBSXY5HPB7VXPSXWSK4Z63QXKQD4JSFNCQC","QU6T6J6WEZ6IYZC57YAUCET2V6WHVKJ2Q4UGB2GOK45VIGDPBR2QC","7KNPYIDUXCBZ65NA74NL2DIFS6STJWN4XXHXLTIV5QXZSVLARJMAC","HOTQHK5URWTJ4IBMSWYPZQOPHA2ZQSPQAN5MAKGUDUAC6LZRDKOQC","QFXBAVXMCWV55XG3F4EGJP7PUCATRUHAARZWUZJRAZ7XLRARYIXQC","N5XHCYVTEDH5SJGWHE76A66KDU5CVHM7U5RXWZDE2TT7L3XPGKEAC","7FP2DFNXGKH2GQIH35BAIHMRORXERI6ARZGVVN7LZKMUYIADIULAC","AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC","T46UZK3SOTQGXP2VTHMNBDNQPAGAWHXRQ2LAVG4MR6ENQMNPI2WAC"],"known":["2TBQL7NI46BBWLKOGDJKR2MLD5SX7N4UHXB23TXR4WKJHKQR2JMQC","GPKQHSA5ZIJCBZYB33TJEWOU3JFA6KSLYPBBI7DG5HTZTKSPEF4AC"]},"hunks":[{"Edit":{"inode":{"change":2,"pos":198172},"path":"pijul-core/src/working_copy/mod.rs","line":19,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":1728}],"down_context":[{"change":7,"pos":1}],"flag":"BLOCK","start":0,"end":409,"inode":{"change":2,"pos":198172}}},"contents":[{"Add":{"text":" /// Size of `file` in bytes. Paired with [`Self::modified_time`] as a cheap","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:79"}},{"Add":{"text":" /// \"did this file change?\" check by `record`. The default reads the whole","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:158"}},{"Add":{"text":" /// file; on-disk backends should override it with a `stat`.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:223"}},{"Add":{"text":" fn file_size(&self, file: &str) -> Result {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:289"}},{"Add":{"text":" let mut buffer = Vec::new();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:326"}},{"Add":{"text":" self.read_file(file, &mut buffer)?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:370"}},{"Add":{"text":" Ok(buffer.len() as u64)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:402"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:408"}}]}},{"Edit":{"inode":{"change":2,"pos":199222},"path":"pijul-core/src/working_copy/memory.rs","line":249,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":207006}],"down_context":[{"change":11,"pos":526}],"flag":"BLOCK","start":410,"end":664,"inode":{"change":2,"pos":199222}}},"contents":[{"Add":{"text":" fn file_size(&self, file: &str) -> Result {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:475"}},{"Add":{"text":" let m = self.0.lock();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:506"}},{"Add":{"text":" match m.get_file(file) {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:539"}},{"Add":{"text":" Some(Inode::File { contents, .. }) => Ok(contents.lock().len() as u64),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:623"}},{"Add":{"text":" _ => Ok(0),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:647"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:657"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:663"}}]}},{"Edit":{"inode":{"change":2,"pos":208900},"path":"pijul-core/src/working_copy/filesystem.rs","line":412,"atom":{"NewVertex":{"up_context":[{"change":13,"pos":40}],"down_context":[{"change":10,"pos":423}],"flag":"BLOCK","start":665,"end":792,"inode":{"change":2,"pos":208900}}},"contents":[{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:670"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:671"}},{"Add":{"text":" fn file_size(&self, file: &str) -> Result {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:737"}},{"Add":{"text":" Ok(std::fs::metadata(self.path(file))?.len())","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:791"}}]}},{"Edit":{"inode":{"change":2,"pos":248807},"path":"pijul-core/src/tests/unrecord.rs","line":1257,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":15,"pos":9103},"to":{"change":15,"start":9103,"end":9104},"introduced_by":15},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":15,"pos":9104},"to":{"change":16,"start":349,"end":698},"introduced_by":16},{"previous":"","flag":"DELETED","from":{"change":16,"pos":698},"to":{"change":15,"start":9104,"end":9174},"introduced_by":16},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":15,"pos":9104},"to":{"change":15,"start":9104,"end":9174},"introduced_by":15}],"inode":{"change":2,"pos":248807}}},"contents":[{"Del":{"text":"","pos":"7FP2DFNXGKH2GQIH35BAIHMRORXERI6ARZGVVN7LZKMUYIADIULAC:9103"}},{"Del":{"text":" // The CLI `record` command sets the channel's last-modified time (see","pos":"AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC:423"}},{"Del":{"text":" // pijul/src/commands/record.rs); mirror it here so the mtime optimisation in","pos":"AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC:505"}},{"Del":{"text":" // the final `record` is meaningful. Without it, `last_modified` stays 0 and","pos":"AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC:586"}},{"Del":{"text":" // every file is re-read regardless of mtime.","pos":"AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC:636"}},{"Del":{"text":" txn.write().touch_channel(&mut *channel.write(), None);","pos":"AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC:696"}},{"Del":{"text":"","pos":"AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC:697"}},{"Del":{"text":" debug!(\"last {:?}\", txn.read().last_modified(&channel.r.read()));","pos":"7FP2DFNXGKH2GQIH35BAIHMRORXERI6ARZGVVN7LZKMUYIADIULAC:9173"}}]}},{"Replacement":{"inode":{"change":2,"pos":248807},"path":"pijul-core/src/tests/unrecord.rs","line":1258,"ins":{"up_context":[{"change":15,"pos":9175}],"down_context":[{"change":15,"pos":9309}],"flag":"BLOCK","start":793,"end":1268,"inode":{"change":2,"pos":248807}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":15,"pos":9175},"to":{"change":15,"start":9175,"end":9309},"introduced_by":15}],"inode":{"change":2,"pos":248807}},"ins_contents":[{"Add":{"text":" // Modify file2 as well, giving it an mtime one hour in the past. Under the","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:872"}},{"Add":{"text":" // old design (skip files whose mtime predates the channel stamp) this","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:947"}},{"Add":{"text":" // modification would have been *missed*. With the per-inode stat cache","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1023"}},{"Add":{"text":" // (format v2), `record` skips a file only when its `(mtime, size)` still","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1101"}},{"Add":{"text":" // match the cached values; file2's content — and hence size — changed, so it","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1187"}},{"Add":{"text":" // is correctly re-read and recorded regardless of how old its mtime looks.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1267"}}],"del_contents":[{"Del":{"text":" // Modify file2, but set its modification time one hour ago, so we","pos":"7FP2DFNXGKH2GQIH35BAIHMRORXERI6ARZGVVN7LZKMUYIADIULAC:9245"}},{"Del":{"text":" // can check that `unrecord` doesn't read the entire repo.","pos":"7FP2DFNXGKH2GQIH35BAIHMRORXERI6ARZGVVN7LZKMUYIADIULAC:9308"}}]}},{"Replacement":{"inode":{"change":2,"pos":248807},"path":"pijul-core/src/tests/unrecord.rs","line":1274,"ins":{"up_context":[{"change":16,"pos":935}],"down_context":[{"change":16,"pos":1078}],"flag":"BLOCK","start":1269,"end":1404,"inode":{"change":2,"pos":248807}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":16,"pos":935},"to":{"change":16,"start":935,"end":1078},"introduced_by":16}],"inode":{"change":2,"pos":248807}},"ins_contents":[{"Add":{"text":" // next `record` re-reads them (see pijul/src/commands/unrecord.rs). Mirror","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1348"}},{"Add":{"text":" // that here; it invalidates `file`'s cached stat.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1403"}}],"del_contents":[{"Del":{"text":" // next `record` re-reads them, while leaving untouched files (file2) alone","pos":"AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC:1014"}},{"Del":{"text":" // (see pijul/src/commands/unrecord.rs). Mirror that here.","pos":"AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC:1077"}}]}},{"Edit":{"inode":{"change":2,"pos":248807},"path":"pijul-core/src/tests/unrecord.rs","line":1278,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":16,"pos":1151},"to":{"change":16,"start":1151,"end":1222},"introduced_by":16}],"inode":{"change":2,"pos":248807}}},"contents":[{"Del":{"text":" debug!(\"last {:?}\", txn.read().last_modified(&channel.r.read()));","pos":"AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC:1220"}},{"Del":{"text":"","pos":"AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC:1221"}}]}},{"Replacement":{"inode":{"change":2,"pos":248807},"path":"pijul-core/src/tests/unrecord.rs","line":1281,"ins":{"up_context":[{"change":16,"pos":1364}],"down_context":[{"change":16,"pos":1406}],"flag":"BLOCK","start":1405,"end":1673,"inode":{"change":2,"pos":248807}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":16,"pos":1364},"to":{"change":16,"start":1364,"end":1406},"introduced_by":16}],"inode":{"change":2,"pos":248807}},"ins_contents":[{"Add":{"text":" // Both files differ from the pristine now: `file` (its deletion was","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1477"}},{"Add":{"text":" // unrecorded, so the working copy's edit reappears as a change) and `file2`","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1558"}},{"Add":{"text":" // (freshly modified). The stat cache no longer hides file2's edit.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1630"}},{"Add":{"text":" assert_eq!(change1.changes.len(), 2);","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1672"}}],"del_contents":[{"Del":{"text":" assert_eq!(change1.changes.len(), 1);","pos":"AVETKKGLLSKXSXRSR5GGTONHWP64C7XT2FHEGLU24BVPATWVCHVAC:1405"}}]}},{"FileAdd":{"meta":{"basename":"record_reads.rs","metadata":0},"context":[{"change":2,"pos":248792}],"contents":[{"Add":{"text":"//! Regression tests for the mtime optimisation in `record`.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1775"}},{"Add":{"text":"//!","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1779"}},{"Add":{"text":"//! `record` walks the whole tree, but it must only *read* (and diff) files","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1855"}},{"Add":{"text":"//! whose modification time is newer than the channel's last-modified stamp","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:1931"}},{"Add":{"text":"//! (see `modified_since_last_commit` in `crate::record`). Reading a file that","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2010"}},{"Add":{"text":"//! has not changed since the last commit is pure waste — on a large working","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2089"}},{"Add":{"text":"//! copy it turns a one-file commit into a full-tree re-diff (the pathological","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2168"}},{"Add":{"text":"//! case that motivated these tests).","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2206"}},{"Add":{"text":"//!","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2210"}},{"Add":{"text":"//! To pin the invariant down we wrap the in-memory working copy in","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2278"}},{"Add":{"text":"//! [`Guarded`], which **panics** if `record` calls `read_file` on a path that","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2357"}},{"Add":{"text":"//! the test did not explicitly mark as changed. `file_metadata` and","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2426"}},{"Add":{"text":"//! `modified_time` (the cheap probes `record` is *supposed* to use to decide","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2504"}},{"Add":{"text":"//! what to read) are always allowed.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2542"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2543"}},{"Add":{"text":"use super::*;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2557"}},{"Add":{"text":"use crate::working_copy::{WorkingCopy, WorkingCopyRead, memory};","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2622"}},{"Add":{"text":"use std::collections::HashSet;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2653"}},{"Add":{"text":"use std::io::Write;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2673"}},{"Add":{"text":"use std::sync::Arc;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2693"}},{"Add":{"text":"use std::time::{Duration, SystemTime};","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2732"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2733"}},{"Add":{"text":"use parking_lot::Mutex;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2757"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2758"}},{"Add":{"text":"/// A working copy that fails the test if `record` reads a file it should have","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2837"}},{"Add":{"text":"/// skipped thanks to the mtime optimisation.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2883"}},{"Add":{"text":"#[derive(Clone)]","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2900"}},{"Add":{"text":"struct Guarded {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2917"}},{"Add":{"text":" inner: memory::Memory,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2944"}},{"Add":{"text":" state: Arc>,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2979"}},{"Add":{"text":"}","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2981"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:2982"}},{"Add":{"text":"#[derive(Default)]","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3001"}},{"Add":{"text":"struct GuardState {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3021"}},{"Add":{"text":" /// When `false`, reads are unrestricted (used while setting the scene).","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3098"}},{"Add":{"text":" armed: bool,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3115"}},{"Add":{"text":" /// Paths that are legitimately allowed to be read while armed.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3183"}},{"Add":{"text":" allowed: HashSet,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3213"}},{"Add":{"text":" /// Paths actually read while armed (for positive assertions).","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3280"}},{"Add":{"text":" read: HashSet,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3307"}},{"Add":{"text":"}","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3309"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3310"}},{"Add":{"text":"impl Guarded {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3325"}},{"Add":{"text":" fn new() -> Self {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3348"}},{"Add":{"text":" Guarded {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3366"}},{"Add":{"text":" inner: memory::Memory::new(),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3408"}},{"Add":{"text":" state: Arc::new(Mutex::new(GuardState::default())),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3472"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3482"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3488"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3489"}},{"Add":{"text":" /// Arm the guard: from now on, reading any path not in `allowed` panics.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3567"}},{"Add":{"text":" fn arm>(&self, allowed: I) {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3637"}},{"Add":{"text":" let mut st = self.state.lock();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3677"}},{"Add":{"text":" st.armed = true;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3702"}},{"Add":{"text":" st.allowed = allowed.into_iter().map(|s| s.to_string()).collect();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3777"}},{"Add":{"text":" st.read.clear();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3802"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3808"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3809"}},{"Add":{"text":" /// Disarm and return the set of paths that were read while armed.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3880"}},{"Add":{"text":" fn disarm(&self) -> HashSet {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3922"}},{"Add":{"text":" let mut st = self.state.lock();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3962"}},{"Add":{"text":" st.armed = false;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:3988"}},{"Add":{"text":" std::mem::take(&mut st.read)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4025"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4031"}},{"Add":{"text":"}","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4033"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4034"}},{"Add":{"text":"impl WorkingCopyRead for Guarded {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4069"}},{"Add":{"text":" type Error = memory::Error;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4101"}},{"Add":{"text":" fn file_metadata(&self, file: &str) -> Result {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4181"}},{"Add":{"text":" self.inner.file_metadata(file)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4220"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4226"}},{"Add":{"text":" fn read_file(&self, file: &str, buffer: &mut Vec) -> Result<(), Self::Error> {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4313"}},{"Add":{"text":" {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4323"}},{"Add":{"text":" let mut st = self.state.lock();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4367"}},{"Add":{"text":" if st.armed {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4393"}},{"Add":{"text":" assert!(","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4418"}},{"Add":{"text":" st.allowed.contains(file),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4465"}},{"Add":{"text":" \"record read unchanged file {:?}: its mtime is older than the \\","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4549"}},{"Add":{"text":" channel's last-modified stamp, so it should have been skipped\",","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4634"}},{"Add":{"text":" file","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4659"}},{"Add":{"text":" );","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4678"}},{"Add":{"text":" st.read.insert(file.to_string());","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4728"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4742"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4752"}},{"Add":{"text":" self.inner.read_file(file, buffer)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4795"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4801"}},{"Add":{"text":" fn modified_time(&self, file: &str) -> Result {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4878"}},{"Add":{"text":" self.inner.modified_time(file)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4917"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4923"}},{"Add":{"text":" fn file_size(&self, file: &str) -> Result {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:4989"}},{"Add":{"text":" // A cheap stat, not a content read — always allowed.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5053"}},{"Add":{"text":" self.inner.file_size(file)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5088"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5094"}},{"Add":{"text":"}","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5096"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5097"}},{"Add":{"text":"impl WorkingCopy for Guarded {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5128"}},{"Add":{"text":" fn create_dir_all(&self, path: &str) -> Result<(), Self::Error> {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5198"}},{"Add":{"text":" self.inner.create_dir_all(path)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5238"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5244"}},{"Add":{"text":" fn remove_path(&self, name: &str, rec: bool) -> Result<(), Self::Error> {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5322"}},{"Add":{"text":" self.inner.remove_path(name, rec)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5364"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5370"}},{"Add":{"text":" fn rename(&self, former: &str, new: &str) -> Result<(), Self::Error> {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5445"}},{"Add":{"text":" self.inner.rename(former, new)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5484"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5490"}},{"Add":{"text":" fn set_permissions(&self, name: &str, permissions: u16) -> Result<(), Self::Error> {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5579"}},{"Add":{"text":" self.inner.set_permissions(name, permissions)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5633"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5639"}},{"Add":{"text":" type Writer = memory::Writer;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5673"}},{"Add":{"text":" fn write_file(&self, file: &str, inode: Inode) -> Result {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5763"}},{"Add":{"text":" self.inner.write_file(file, inode)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5806"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5812"}},{"Add":{"text":" fn touch(&self, name: &str, time: SystemTime) -> Result<(), Self::Error> {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5891"}},{"Add":{"text":" self.inner.touch(name, time)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5928"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5934"}},{"Add":{"text":"}","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5936"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:5937"}},{"Add":{"text":"/// `SystemTime` `secs` seconds after the epoch (a fixed instant far in the past,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6019"}},{"Add":{"text":"/// so any file stamped with it is unambiguously older than the record walk and","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6099"}},{"Add":{"text":"/// gets cached).","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6117"}},{"Add":{"text":"fn at_secs(secs: u64) -> SystemTime {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6155"}},{"Add":{"text":" SystemTime::UNIX_EPOCH + Duration::from_secs(secs)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6210"}},{"Add":{"text":"}","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6212"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6213"}},{"Add":{"text":"/// Pin every file's mtime to a fixed past instant, so the first `record`","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6287"}},{"Add":{"text":"/// populates the per-inode stat cache with a non-ambiguous value.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6354"}},{"Add":{"text":"fn pin_past(repo: &Guarded, files: &[&str]) -> Result<(), anyhow::Error> {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6429"}},{"Add":{"text":" for f in files {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6450"}},{"Add":{"text":" repo.touch(f, at_secs(100_000))?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6492"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6498"}},{"Add":{"text":" Ok(())","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6509"}},{"Add":{"text":"}","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6511"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6512"}},{"Add":{"text":"/// A no-op second `record` (nothing changed on disk) must not read a single","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6589"}},{"Add":{"text":"/// file: the stat cache populated by the first record makes every file skip.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6667"}},{"Add":{"text":"#[test]","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6675"}},{"Add":{"text":"fn record_skips_unmodified_files() -> Result<(), anyhow::Error> {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6741"}},{"Add":{"text":" env_logger::try_init().unwrap_or(());","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6783"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6784"}},{"Add":{"text":" let repo = Guarded::new();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6815"}},{"Add":{"text":" let changes = changestore::memory::Memory::new();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6869"}},{"Add":{"text":" let files = [\"a\", \"b\", \"c/d\", \"c/e\"];","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6911"}},{"Add":{"text":" for f in files {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6932"}},{"Add":{"text":" repo.inner.add_file(f, b\"one\\ntwo\\nthree\\n\".to_vec());","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:6995"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7001"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7002"}},{"Add":{"text":" let env = pristine::sanakirja::Pristine::new_anon()?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7060"}},{"Add":{"text":" let txn = env.arc_txn_begin().unwrap();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7104"}},{"Add":{"text":" let channel = txn","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7126"}},{"Add":{"text":" .write()","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7143"}},{"Add":{"text":" .open_or_create_channel(&SmallString::from_str(\"main\"))?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7209"}},{"Add":{"text":" for f in files {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7230"}},{"Add":{"text":" txn.write().add_file(f, 0)?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7267"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7273"}},{"Add":{"text":" pin_past(&repo, &files)?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7303"}},{"Add":{"text":" // First record reads everything and caches each file's (mtime, size).","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7378"}},{"Add":{"text":" record_all(&repo, &changes, &txn, &channel, \"\")?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7432"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7433"}},{"Add":{"text":" // Nothing changed on disk: the second record must read nothing.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7502"}},{"Add":{"text":" repo.arm([]);","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7520"}},{"Add":{"text":" let (_, change) = record_all_change(&repo, &changes, &txn, &channel, \"\")?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7599"}},{"Add":{"text":" let read = repo.disarm();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7629"}},{"Add":{"text":" assert!(read.is_empty(), \"expected no reads, got {:?}\", read);","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7696"}},{"Add":{"text":" assert!(","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7709"}},{"Add":{"text":" change.changes.is_empty(),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7744"}},{"Add":{"text":" \"expected an empty change, got {:?}\",","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7790"}},{"Add":{"text":" change.changes","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7813"}},{"Add":{"text":" );","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7820"}},{"Add":{"text":" Ok(())","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7831"}},{"Add":{"text":"}","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7833"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7834"}},{"Add":{"text":"/// When a single file changes, `record` must read that file and *only* that","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7911"}},{"Add":{"text":"/// file — never the untouched neighbours (which the stat cache skips).","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7985"}},{"Add":{"text":"#[test]","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:7993"}},{"Add":{"text":"fn record_reads_only_modified_file() -> Result<(), anyhow::Error> {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8061"}},{"Add":{"text":" env_logger::try_init().unwrap_or(());","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8103"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8104"}},{"Add":{"text":" let repo = Guarded::new();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8135"}},{"Add":{"text":" let changes = changestore::memory::Memory::new();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8189"}},{"Add":{"text":" let files = [\"a\", \"b\", \"c/d\", \"c/e\"];","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8231"}},{"Add":{"text":" for f in files {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8252"}},{"Add":{"text":" repo.inner.add_file(f, b\"one\\ntwo\\nthree\\n\".to_vec());","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8315"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8321"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8322"}},{"Add":{"text":" let env = pristine::sanakirja::Pristine::new_anon()?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8380"}},{"Add":{"text":" let txn = env.arc_txn_begin().unwrap();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8424"}},{"Add":{"text":" let channel = txn","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8446"}},{"Add":{"text":" .write()","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8463"}},{"Add":{"text":" .open_or_create_channel(&SmallString::from_str(\"main\"))?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8529"}},{"Add":{"text":" for f in files {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8550"}},{"Add":{"text":" txn.write().add_file(f, 0)?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8587"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8593"}},{"Add":{"text":" pin_past(&repo, &files)?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8623"}},{"Add":{"text":" record_all(&repo, &changes, &txn, &channel, \"\")?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8677"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8678"}},{"Add":{"text":" // Change exactly one file. Give it a *different* (still past, so","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8748"}},{"Add":{"text":" // unambiguous) mtime so it no longer matches its cached stat.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8815"}},{"Add":{"text":" repo.write_file(\"c/d\", Inode::ROOT)?","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8856"}},{"Add":{"text":" .write_all(b\"one\\ntwo\\nthree\\nfour\\n\")?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8905"}},{"Add":{"text":" repo.touch(\"c/d\", at_secs(200_000))?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8947"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8948"}},{"Add":{"text":" repo.arm([\"c/d\"]);","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:8971"}},{"Add":{"text":" let (_, change) = record_all_change(&repo, &changes, &txn, &channel, \"\")?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9050"}},{"Add":{"text":" let read = repo.disarm();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9080"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9081"}},{"Add":{"text":" assert!(read.contains(\"c/d\"), \"the modified file was not read\");","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9150"}},{"Add":{"text":" assert_eq!(","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9166"}},{"Add":{"text":" read.len(),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9186"}},{"Add":{"text":" 1,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9197"}},{"Add":{"text":" \"record read unrelated files as well: {:?}\",","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9250"}},{"Add":{"text":" read","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9263"}},{"Add":{"text":" );","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9270"}},{"Add":{"text":" assert_eq!(","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9286"}},{"Add":{"text":" change.changes.len(),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9316"}},{"Add":{"text":" 1,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9327"}},{"Add":{"text":" \"expected exactly one hunk, got {:?}\",","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9374"}},{"Add":{"text":" change.changes","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9397"}},{"Add":{"text":" );","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9404"}},{"Add":{"text":" Ok(())","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9415"}},{"Add":{"text":"}","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9417"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9418"}},{"Add":{"text":"/// After materialising the working copy with `output` (as `clone`/`pull`/`reset`","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9500"}},{"Add":{"text":"/// do), the *first* record populates the stat cache and a *second* record reads","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9581"}},{"Add":{"text":"/// nothing — even though `output` wrote every file with a fresh mtime. This is","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9663"}},{"Add":{"text":"/// what stops the pathological full-tree re-diff after a pull.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9727"}},{"Add":{"text":"#[test]","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9735"}},{"Add":{"text":"fn output_then_record_twice_reads_nothing() -> Result<(), anyhow::Error> {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9810"}},{"Add":{"text":" env_logger::try_init().unwrap_or(());","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9852"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9853"}},{"Add":{"text":" let source = working_copy::memory::Memory::new();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9907"}},{"Add":{"text":" let changes = changestore::memory::Memory::new();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:9961"}},{"Add":{"text":" let files = [\"a\", \"b\", \"c/d\", \"c/e\"];","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10003"}},{"Add":{"text":" for f in files {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10024"}},{"Add":{"text":" source.add_file(f, b\"one\\ntwo\\nthree\\n\".to_vec());","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10083"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10089"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10090"}},{"Add":{"text":" let env = pristine::sanakirja::Pristine::new_anon()?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10148"}},{"Add":{"text":" let txn = env.arc_txn_begin().unwrap();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10192"}},{"Add":{"text":" let channel = txn","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10214"}},{"Add":{"text":" .write()","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10231"}},{"Add":{"text":" .open_or_create_channel(&SmallString::from_str(\"main\"))?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10297"}},{"Add":{"text":" for f in files {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10318"}},{"Add":{"text":" txn.write().add_file(f, 0)?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10355"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10361"}},{"Add":{"text":" record_all(&source, &changes, &txn, &channel, \"\")?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10417"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10418"}},{"Add":{"text":" // Simulate `clone`/`pull`: output the whole repository into a fresh working","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10499"}},{"Add":{"text":" // copy (files get whatever mtime `output` writes).","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10555"}},{"Add":{"text":" let dest = Guarded::new();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10586"}},{"Add":{"text":" crate::output::output_repository_no_pending(","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10635"}},{"Add":{"text":" &dest, &changes, &txn, &channel, \"\", true, None, 1, 0,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10698"}},{"Add":{"text":" )?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10706"}},{"Add":{"text":" // Pin the just-written files to a past instant so the first record caches","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10785"}},{"Add":{"text":" // them unambiguously (mirrors a checkout whose files predate the record).","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10864"}},{"Add":{"text":" pin_past(&dest, &files)?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10894"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10895"}},{"Add":{"text":" // First record after checkout: reads everything, populates the cache.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:10970"}},{"Add":{"text":" record_all(&dest, &changes, &txn, &channel, \"\")?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11024"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11025"}},{"Add":{"text":" // Second record: nothing changed → reads nothing.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11082"}},{"Add":{"text":" dest.arm([]);","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11100"}},{"Add":{"text":" let (_, change) = record_all_change(&dest, &changes, &txn, &channel, \"\")?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11179"}},{"Add":{"text":" let read = dest.disarm();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11209"}},{"Add":{"text":" assert!(","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11222"}},{"Add":{"text":" read.is_empty(),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11247"}},{"Add":{"text":" \"record re-diffed unchanged files after a checkout: {:?}\",","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11314"}},{"Add":{"text":" read","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11327"}},{"Add":{"text":" );","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11334"}},{"Add":{"text":" assert!(","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11347"}},{"Add":{"text":" change.changes.is_empty(),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11382"}},{"Add":{"text":" \"expected an empty change, got {:?}\",","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11428"}},{"Add":{"text":" change.changes","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11451"}},{"Add":{"text":" );","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11458"}},{"Add":{"text":" Ok(())","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11469"}},{"Add":{"text":"}","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11471"}}]}},{"FileAdd":{"meta":{"basename":"record_parallel.rs","metadata":0},"context":[{"change":2,"pos":248792}],"contents":[{"Add":{"text":"//! The parallel record walk (`Builder::record` with `n_workers > 1`) must be","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11594"}},{"Add":{"text":"//! *deterministic*: it prepares each file's diff concurrently but commits the","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11673"}},{"Add":{"text":"//! results single-threaded in walk order, so the change it produces is","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11745"}},{"Add":{"text":"//! byte-for-byte identical to the single-threaded path regardless of how the","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11823"}},{"Add":{"text":"//! worker threads are scheduled. See `notes-record-stat-cache.md` §5.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11895"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11896"}},{"Add":{"text":"use super::*;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11910"}},{"Add":{"text":"use crate::record::Builder;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11938"}},{"Add":{"text":"use crate::working_copy::WorkingCopy;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11976"}},{"Add":{"text":"use std::io::Write;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11996"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:11997"}},{"Add":{"text":"/// Record the current (modified) working copy against `channel` with the given","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12077"}},{"Add":{"text":"/// number of workers, without applying, and return the resulting `(contents,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12155"}},{"Add":{"text":"/// actions)`. `force_rediff` is set so every file is diffed (independent of the","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12236"}},{"Add":{"text":"/// stat cache), which is exactly the code path we want to compare.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12304"}},{"Add":{"text":"fn record_with_workers(","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12337"}},{"Add":{"text":" repo: &R,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12351"}},{"Add":{"text":" changes: &P,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12368"}},{"Add":{"text":" txn: &ArcTxn,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12389"}},{"Add":{"text":" channel: &ChannelRef,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12418"}},{"Add":{"text":" n_workers: usize,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12440"}},{"Add":{"text":") -> (","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12447"}},{"Add":{"text":" Vec,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12460"}},{"Add":{"text":" Vec, crate::change::LocalByte>>,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12534"}},{"Add":{"text":")","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12536"}},{"Add":{"text":"where","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12542"}},{"Add":{"text":" T: MutTxnT + Send + Sync + 'static,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12582"}},{"Add":{"text":" R: WorkingCopy + Clone + Send + Sync + 'static,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12634"}},{"Add":{"text":" P: ChangeStore + Clone + Send + 'static,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12679"}},{"Add":{"text":" R::Error: Send + Sync + 'static,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12716"}},{"Add":{"text":"{","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12718"}},{"Add":{"text":" let mut builder = Builder::new();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12756"}},{"Add":{"text":" builder.force_rediff = true;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12789"}},{"Add":{"text":" builder","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12801"}},{"Add":{"text":" .record(","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12818"}},{"Add":{"text":" txn.clone(),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12843"}},{"Add":{"text":" Algorithm::default(),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12877"}},{"Add":{"text":" false,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12896"}},{"Add":{"text":" &crate::DEFAULT_SEPARATOR,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12935"}},{"Add":{"text":" channel.clone(),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12964"}},{"Add":{"text":" repo,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:12982"}},{"Add":{"text":" changes,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13003"}},{"Add":{"text":" \"\",","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13019"}},{"Add":{"text":" n_workers,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13042"}},{"Add":{"text":" )","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13052"}},{"Add":{"text":" .unwrap();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13071"}},{"Add":{"text":" let rec = builder.finish();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13103"}},{"Add":{"text":" let contents = rec.contents.lock().clone();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13151"}},{"Add":{"text":" (contents, rec.actions)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13179"}},{"Add":{"text":"}","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13181"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13182"}},{"Add":{"text":"#[test]","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13190"}},{"Add":{"text":"fn parallel_record_is_deterministic() -> Result<(), anyhow::Error> {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13259"}},{"Add":{"text":" env_logger::try_init().unwrap_or(());","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13301"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13302"}},{"Add":{"text":" let repo = working_copy::memory::Memory::new();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13354"}},{"Add":{"text":" let changes = changestore::memory::Memory::new();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13408"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13409"}},{"Add":{"text":" // A handful of files with multi-line content, so the walk produces several","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13489"}},{"Add":{"text":" // independent diff tasks.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13520"}},{"Add":{"text":" const N_FILES: usize = 12;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13551"}},{"Add":{"text":" for i in 0..N_FILES {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13577"}},{"Add":{"text":" let mut body = String::new();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13615"}},{"Add":{"text":" for j in 0..40 {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13640"}},{"Add":{"text":" body.push_str(&format!(\"file {i} line {j}\\n\"));","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13700"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13710"}},{"Add":{"text":" repo.add_file(&format!(\"dir/file{i}\"), body.into_bytes());","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13777"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13783"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13784"}},{"Add":{"text":" let env = pristine::sanakirja::Pristine::new_anon()?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13842"}},{"Add":{"text":" let txn = env.arc_txn_begin().unwrap();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13886"}},{"Add":{"text":" for i in 0..N_FILES {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13912"}},{"Add":{"text":" txn.write().add_file(&format!(\"dir/file{i}\"), 0).unwrap();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13979"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:13985"}},{"Add":{"text":" let channel = txn","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14007"}},{"Add":{"text":" .write()","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14024"}},{"Add":{"text":" .open_or_create_channel(&SmallString::from_str(\"main\"))","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14088"}},{"Add":{"text":" .unwrap();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14107"}},{"Add":{"text":" // Initial record + apply, so the files exist in the pristine and later","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14183"}},{"Add":{"text":" // re-records go through the existing-file (parallel diff) path.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14252"}},{"Add":{"text":" record_all(&repo, &changes, &txn, &channel, \"\").unwrap();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14314"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14315"}},{"Add":{"text":" // Modify every file: insert, delete and edit lines so each diff is","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14387"}},{"Add":{"text":" // non-trivial.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14407"}},{"Add":{"text":" for i in 0..N_FILES {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14433"}},{"Add":{"text":" let mut w = repo","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14458"}},{"Add":{"text":" .write_file(&format!(\"dir/file{i}\"), crate::Inode::ROOT)","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14527"}},{"Add":{"text":" .unwrap();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14550"}},{"Add":{"text":" for j in 0..40 {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14575"}},{"Add":{"text":" if j % 7 == 0 {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14603"}},{"Add":{"text":" writeln!(w, \"file {i} INSERTED before {j}\").unwrap();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14673"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14687"}},{"Add":{"text":" if j % 5 != 0 {","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14715"}},{"Add":{"text":" writeln!(w, \"file {i} line {j} EDITED\").unwrap();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14781"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14795"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14805"}},{"Add":{"text":" }","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14811"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14812"}},{"Add":{"text":" // Record the same state single-threaded and with 8 workers. Neither record","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14892"}},{"Add":{"text":" // applies, so both see an identical pristine and working copy.","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:14960"}},{"Add":{"text":" let (contents_seq, actions_seq) = record_with_workers(&repo, &changes, &txn, &channel, 1);","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15055"}},{"Add":{"text":" let (contents_par, actions_par) = record_with_workers(&repo, &changes, &txn, &channel, 8);","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15150"}},{"Add":{"text":"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15151"}},{"Add":{"text":" assert!(!actions_seq.is_empty(), \"expected a non-empty change\");","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15220"}},{"Add":{"text":" assert_eq!(","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15236"}},{"Add":{"text":" contents_seq, contents_par,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15272"}},{"Add":{"text":" \"parallel record produced a different contents blob\"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15333"}},{"Add":{"text":" );","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15340"}},{"Add":{"text":" assert_eq!(","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15356"}},{"Add":{"text":" actions_seq, actions_par,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15390"}},{"Add":{"text":" \"parallel record produced different actions\"","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15443"}},{"Add":{"text":" );","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15450"}},{"Add":{"text":" Ok(())","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15461"}},{"Add":{"text":"}","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15463"}}]}},{"Edit":{"inode":{"change":2,"pos":289338},"path":"pijul-core/src/tests/mod.rs","line":19,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":289702}],"down_context":[{"change":17,"pos":3567}],"flag":"BLOCK","start":15465,"end":15504,"inode":{"change":2,"pos":289338}}},"contents":[{"Add":{"text":"mod record_parallel;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15485"}},{"Add":{"text":"mod record_reads;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15503"}}]}},{"Edit":{"inode":{"change":2,"pos":289338},"path":"pijul-core/src/tests/mod.rs","line":71,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":290074}],"down_context":[{"change":2,"pos":290074}],"flag":"BLOCK","start":15505,"end":15553,"inode":{"change":2,"pos":289338}}},"contents":[{"Add":{"text":" let stat_updates = rec.take_stat_updates();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15552"}}]}},{"Edit":{"inode":{"change":2,"pos":289338},"path":"pijul-core/src/tests/mod.rs","line":125,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":22654}],"down_context":[{"change":8,"pos":867}],"flag":"BLOCK","start":15554,"end":15771,"inode":{"change":2,"pos":289338}}},"contents":[{"Add":{"text":" // Persist the per-inode stat cache now that the inodes exist with their","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15630"}},{"Add":{"text":" // final positions (mirrors what the CLI does after applying).","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15697"}},{"Add":{"text":" crate::record::update_stat_cache(&mut *txn.write(), &stat_updates)?;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15770"}}]}},{"Replacement":{"inode":{"change":9,"pos":162},"path":"pijul-core/src/tests/diff.rs","line":92,"ins":{"up_context":[{"change":9,"pos":2883}],"down_context":[{"change":12,"pos":939}],"flag":"BLOCK","start":15772,"end":15820,"inode":{"change":9,"pos":162}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":9,"pos":2883},"to":{"change":14,"start":290,"end":313},"introduced_by":14},{"previous":"","flag":"DELETED","from":{"change":14,"pos":313},"to":{"change":9,"start":2916,"end":2935},"introduced_by":14},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":9,"pos":2916},"to":{"change":9,"start":2916,"end":2935},"introduced_by":9}],"inode":{"change":9,"pos":162}},"ins_contents":[{"Add":{"text":" contents.clone(),","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15801"}},{"Add":{"text":" None,","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15819"}}],"del_contents":[{"Del":{"text":" &contents,","pos":"N5XHCYVTEDH5SJGWHE76A66KDU5CVHM7U5RXWZDE2TT7L3XPGKEAC:312"}},{"Del":{"text":" &None,","pos":"V4T4SC7OL6WEZNV4XSFBSXY5HPB7VXPSXWSK4Z63QXKQD4JSFNCQC:2934"}}]}},{"Replacement":{"inode":{"change":2,"pos":357372},"path":"pijul-core/src/tests/conflict.rs","line":2860,"ins":{"up_context":[{"change":4,"pos":29278}],"down_context":[{"change":2,"pos":440461}],"flag":"BLOCK","start":15821,"end":15902,"inode":{"change":2,"pos":357372}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":29278},"to":{"change":5,"start":41826,"end":41870},"introduced_by":5}],"inode":{"change":2,"pos":357372}},"ins_contents":[{"Add":{"text":" let (&inode, sinode) = x.unwrap();","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15863"}},{"Add":{"text":" let vertex = sinode.position;","pos":"MDPZTMA3SWP3EAQQA47K5RKRWPMTCU3TTCOE2G5GEX47FFEA6SXQC:15901"}}],"del_contents":[{"Del":{"text":" let (&inode, &vertex) = x.unwrap();","pos":"YN63NUZO4LVJ7XPMURDULTXBVJKW5MVCTZ24R7Z52QMHO3HPDUVQC:41869"}}]}}],"owner":"pijul","repo":"pijul","token":"MSjWs9/CoOWD1GpUcQeq4OKP4zKb80HWhQja9GR1mlk=","login":null}

…

Dependencies

Change contents

Review