| hg-reviewers |
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | rust/hg-core/src/operations/list_tracked_files.rs (7 lines) | |||
| M | rust/hg-core/src/revlog/revlog.rs (5 lines) |
| } | } | ||||
| pub fn run( | pub fn run( | ||||
| &mut self, | &mut self, | ||||
| ) -> Result<impl Iterator<Item = &HgPath>, ListRevTrackedFilesError> { | ) -> Result<impl Iterator<Item = &HgPath>, ListRevTrackedFilesError> { | ||||
| let changelog_entry = match self.rev.parse::<Revision>() { | let changelog_entry = match self.rev.parse::<Revision>() { | ||||
| Ok(rev) => self.changelog.get_rev(rev)?, | Ok(rev) => self.changelog.get_rev(rev)?, | ||||
| _ => { | _ => { | ||||
| let changelog_node = hex::decode(&self.rev).map_err(|_| { | let changelog_node = hex::decode(&self.rev) | ||||
| ListRevTrackedFilesErrorKind::InvalidRevision | .or(Err(ListRevTrackedFilesErrorKind::InvalidRevision))?; | ||||
| })?; | |||||
| self.changelog.get_node(&changelog_node)? | self.changelog.get_node(&changelog_node)? | ||||
| } | } | ||||
| }; | }; | ||||
| let manifest_node = hex::decode(&changelog_entry.manifest_node()?) | let manifest_node = hex::decode(&changelog_entry.manifest_node()?) | ||||
| .map_err(|_| ListRevTrackedFilesErrorKind::CorruptedRevlog)?; | .or(Err(ListRevTrackedFilesErrorKind::CorruptedRevlog))?; | ||||
| self.manifest_entry = Some(self.manifest.get_node(&manifest_node)?); | self.manifest_entry = Some(self.manifest.get_node(&manifest_node)?); | ||||
| if let Some(ref manifest_entry) = self.manifest_entry { | if let Some(ref manifest_entry) = self.manifest_entry { | ||||
| Ok(manifest_entry.files()) | Ok(manifest_entry.files()) | ||||
| } else { | } else { | ||||
| panic!( | panic!( | ||||
| "manifest entry should have been stored in self.manifest_node to ensure its lifetime since references are returned from it" | "manifest entry should have been stored in self.manifest_node to ensure its lifetime since references are returned from it" | ||||
| ) | ) | ||||
| } | } | ||||
| } | } | ||||
| } | } | ||||
| /// snapshot to rebuild the final data. | /// snapshot to rebuild the final data. | ||||
| #[timed] | #[timed] | ||||
| pub fn get_rev_data(&self, rev: Revision) -> Result<Vec<u8>, RevlogError> { | pub fn get_rev_data(&self, rev: Revision) -> Result<Vec<u8>, RevlogError> { | ||||
| // Todo return -> Cow | // Todo return -> Cow | ||||
| let mut entry = self.get_entry(rev)?; | let mut entry = self.get_entry(rev)?; | ||||
| let mut delta_chain = vec![]; | let mut delta_chain = vec![]; | ||||
| while let Some(base_rev) = entry.base_rev { | while let Some(base_rev) = entry.base_rev { | ||||
| delta_chain.push(entry); | delta_chain.push(entry); | ||||
| entry = self | entry = | ||||
| .get_entry(base_rev) | self.get_entry(base_rev).or(Err(RevlogError::Corrupted))?; | ||||
| .map_err(|_| RevlogError::Corrupted)?; | |||||
| } | } | ||||
| // TODO do not look twice in the index | // TODO do not look twice in the index | ||||
| let index_entry = self | let index_entry = self | ||||
| .index | .index | ||||
| .get_entry(rev) | .get_entry(rev) | ||||
| .ok_or(RevlogError::InvalidRevision)?; | .ok_or(RevlogError::InvalidRevision)?; | ||||