{"header":{"message":"Making the get_latest_touch function (useful to make archives) public in libpijul","description":null,"timestamp":"2021-01-11T16:34:11.095989961Z","authors":[{"full_name":"Pierre-Étienne Meunier","name":"pmeunier"}]},"hash":"27PYHR6LO4M4RMSMLVMUKSYNQ72V6RRMRXLYQI3JA3LBHJO747YAC","authors":[],"deps":{"hashes":[["27PYHR6LO4M4RMSMLVMUKSYNQ72V6RRMRXLYQI3JA3LBHJO747YAC","Making the get_latest_touch function (useful to make archives) public in libpijul"],["AA",null],["BONBSXAUJKCMVB56LUU6PWXV7KPLB3HXZ5JF6LK43R5J4WYETUHAC","Archive mtimes: optimal complexity in all cases"],["VO5OQW4W2656DIYYRNZ3PO7TQ4JOKQ3GVWE5ALUTYVMX3WMXJOYQC","Removing anyhow in libpijul"],["CCLLB7OIFNFYJZTG3UCI7536TOCWSCSXR67VELSB466R24WLJSDAC","Upgrading to Sanakirja 0.15 + version bump"],["I3OVP3NHSMB2YLU4EPU5BFH7KB54PMQ4WDATGINIJKRIHMSVFUSQC","Archive: set the accurate and deterministic mtime"],["GHO6DWPILBBTL6CVZKERJBTFL3EY6ZT4YM4E5R4S6YPGVFKFHCVAC","Refactoring iterators"],["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","Fixing the bad changes in history (unfortunately, by rebooting)."]],"deps":["BONBSXAUJKCMVB56LUU6PWXV7KPLB3HXZ5JF6LK43R5J4WYETUHAC"],"known":["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","VO5OQW4W2656DIYYRNZ3PO7TQ4JOKQ3GVWE5ALUTYVMX3WMXJOYQC","CCLLB7OIFNFYJZTG3UCI7536TOCWSCSXR67VELSB466R24WLJSDAC","GHO6DWPILBBTL6CVZKERJBTFL3EY6ZT4YM4E5R4S6YPGVFKFHCVAC","I3OVP3NHSMB2YLU4EPU5BFH7KB54PMQ4WDATGINIJKRIHMSVFUSQC"]},"hunks":[{"Replacement":{"inode":{"change":3,"pos":690044},"path":"libpijul/src/output/archive.rs","line":191,"ins":{"up_context":[{"change":3,"pos":694891}],"down_context":[{"change":3,"pos":694891}],"flag":"BLOCK","start":0,"end":381,"inode":{"change":3,"pos":690044}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":694891},"to":{"change":2,"start":0,"end":95},"introduced_by":2}],"inode":{"change":3,"pos":690044}},"ins_contents":[{"Add":" let (_, latest_touch) ="},{"Add":" crate::fs::get_latest_touch(txn, &channel, output_item.pos)?;"},{"Add":" let latest_touch = {"},{"Add":" let ext = txn.get_external(latest_touch)?.unwrap();"},{"Add":" let c = changes.get_header(&ext).map_err(ArchiveError::P)?;"},{"Add":" c.timestamp.timestamp() as u64"},{"Add":" };"}],"del_contents":[{"Del":" let latest_touch = get_latest_touch(changes, txn, &channel, output_item.pos)?;\n"}]}},{"Edit":{"inode":{"change":3,"pos":690044},"path":"libpijul/src/output/archive.rs","line":241,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":696436},"to":{"change":3,"start":696436,"end":696438},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":696438},"to":{"change":2,"start":96,"end":2007},"introduced_by":2}],"inode":{"change":3,"pos":690044}}},"contents":[{"Del":"}\n"},{"Del":"\nfn get_latest_touch<\n 'a,\n T: ChannelTxnT + DepsTxnT::GraphError>,\n P: ChangeStore,\n A: std::error::Error + 'static,\n>(\n changes: &P,\n txn: &T,\n channel: &T::Channel,\n pos: Position,\n) -> Result> {\n let mut latest_touch = 0;\n let mut latest_change = 0;\n let mut touch_iter = Some(txn.iter_touched(pos)?);\n let mut log_iter = changeid_rev_log(txn, &channel, None)?;\n let mut continue_ = true;\n while continue_ {\n continue_ = false;\n if let Some(ref mut it) = touch_iter {\n if let Some(c) = it.next() {\n debug!(\"inode, change = {:?}\", c);\n let (inode, change) = c?;\n if inode > pos {\n touch_iter = None;\n } else if inode == pos {\n if let Some(t) = txn.get_changeset(T::changes(&channel), change)? {\n if t > latest_change || latest_touch == 0 {\n latest_change = t;\n let ext = txn.get_external(change)?.unwrap();\n let c = changes.get_header(&ext).map_err(ArchiveError::P)?;\n latest_touch = c.timestamp.timestamp() as u64\n }\n }\n continue_ = true;\n }\n }\n }\n if let Some(l) = log_iter.next() {\n debug!(\"int = {:?}\", l);\n let (_, (int, _)) = l?;\n if txn.get_touched_files(pos, Some(int))?.is_some() {\n let ext = txn.get_external(int)?.unwrap();\n let c = changes.get_header(&ext).map_err(ArchiveError::P)?;\n latest_touch = c.timestamp.timestamp() as u64;\n break;\n }\n continue_ = true;\n }\n }\n Ok(latest_touch)\n"}]}},{"Replacement":{"inode":{"change":3,"pos":737429},"path":"libpijul/src/fs.rs","line":570,"ins":{"up_context":[{"change":3,"pos":752701}],"down_context":[{"change":3,"pos":752762}],"flag":"BLOCK","start":382,"end":476,"inode":{"change":3,"pos":737429}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":752701},"to":{"change":3,"start":109396,"end":109480},"introduced_by":3}],"inode":{"change":3,"pos":737429}},"ins_contents":[{"Add":" type Item = Result<(Position, ChangeId, InodeMetadata, String), T::GraphError>;"}],"del_contents":[{"Del":" type Item = Result<(Position, InodeMetadata, String), T::GraphError>;\n"}]}},{"Replacement":{"inode":{"change":3,"pos":737429},"path":"libpijul/src/fs.rs","line":600,"ins":{"up_context":[{"change":3,"pos":110553}],"down_context":[{"change":3,"pos":753751}],"flag":"BLOCK","start":477,"end":627,"inode":{"change":3,"pos":737429}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":110553},"to":{"change":3,"start":110553,"end":110618},"introduced_by":3}],"inode":{"change":3,"pos":737429}},"ins_contents":[{"Add":" Some(Ok(("},{"Add":" grandchild.dest,"},{"Add":" grandchild.introduced_by,"},{"Add":" perms,"},{"Add":" basename.to_string(),"},{"Add":" )))"}],"del_contents":[{"Del":" Some(Ok((grandchild.dest, perms, basename.to_string())))\n"}]}},{"Edit":{"inode":{"change":3,"pos":737429},"path":"libpijul/src/fs.rs","line":886,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":763287}],"down_context":[{"change":3,"pos":763287}],"flag":"BLOCK","start":628,"end":2112,"inode":{"change":3,"pos":737429}}},"contents":[{"Add":"}"},{"Add":""},{"Add":"pub fn get_latest_touch<'a, T: ChannelTxnT + DepsTxnT::GraphError>>("},{"Add":" txn: &T,"},{"Add":" channel: &T::Channel,"},{"Add":" pos: Position,"},{"Add":") -> Result<(u64, ChangeId), TxnErr> {"},{"Add":" let mut latest_change = 0;"},{"Add":" let mut id = ChangeId::ROOT;"},{"Add":" let mut touch_iter = Some(txn.iter_touched(pos)?);"},{"Add":" let mut log_iter = changeid_rev_log(txn, &channel, None)?;"},{"Add":" let mut continue_ = true;"},{"Add":" while continue_ {"},{"Add":" continue_ = false;"},{"Add":" if let Some(ref mut it) = touch_iter {"},{"Add":" if let Some(c) = it.next() {"},{"Add":" debug!(\"inode, change = {:?}\", c);"},{"Add":" let (inode, change) = c?;"},{"Add":" if inode > pos {"},{"Add":" touch_iter = None;"},{"Add":" } else if inode == pos {"},{"Add":" if let Some(t) = txn.get_changeset(T::changes(&channel), change)? {"},{"Add":" if t >= latest_change {"},{"Add":" latest_change = t;"},{"Add":" id = change;"},{"Add":" }"},{"Add":" }"},{"Add":" continue_ = true;"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" if let Some(l) = log_iter.next() {"},{"Add":" debug!(\"int = {:?}\", l);"},{"Add":" let (n, (int, _)) = l?;"},{"Add":" if txn.get_touched_files(pos, Some(int))?.is_some() {"},{"Add":" id = int;"},{"Add":" latest_change = n;"},{"Add":" break;"},{"Add":" }"},{"Add":" continue_ = true;"},{"Add":" }"},{"Add":" }"},{"Add":" Ok((latest_change, id))"}]}}],"owner":"irevoire","repo":"pijul","token":"v8JgsADWmUzgfcfz9/l4qFc2Mh27klaJnavS97UzmI0=","login":null}

…

Dependencies

Change contents