comparison rust/hg-core/src/revlog/revlog.rs @ 48198:61ce70fd420e

rhg: handle null changelog and manifest revisions

Differential Revision: https://phab.mercurial-scm.org/D11650

48197:63e86fc9bfec

        data_path: Option<&Path>,
    ) -> Result<Self, HgError> {
        let index_path = index_path.as_ref();
        let index_mmap = repo.store_vfs().mmap_open(&index_path)?;

        let version = get_version(&index_mmap);
        if version != 1 {
            // A proper new version should have had a repo/store requirement.
            return Err(HgError::corrupted("corrupted revlog"));
        }

    /// All entries required to build the final data out of deltas will be
    /// retrieved as needed, and the deltas will be applied to the inital
    /// snapshot to rebuild the final data.
    #[timed]
    pub fn get_rev_data(&self, rev: Revision) -> Result<Vec<u8>, RevlogError> {
        // Todo return -> Cow
        let mut entry = self.get_entry(rev)?;
        let mut delta_chain = vec![];
        while let Some(base_rev) = entry.base_rev {
            delta_chain.push(entry);

        self.base_rev.is_some()
    }
}

/// Format version of the revlog.
pub fn get_version(index_bytes: &[u8]) -> u16 {
    BigEndian::read_u16(&index_bytes[2..=3])
}

/// Calculate the hash of a revision given its data and its parents.
fn hash(
    data: &[u8],

48198:61ce70fd420e

        data_path: Option<&Path>,
    ) -> Result<Self, HgError> {
        let index_path = index_path.as_ref();
        let index_mmap = repo.store_vfs().mmap_open(&index_path)?;

        let version = get_version(&index_mmap)?;
        if version != 1 {
            // A proper new version should have had a repo/store requirement.
            return Err(HgError::corrupted("corrupted revlog"));
        }

    /// All entries required to build the final data out of deltas will be
    /// retrieved as needed, and the deltas will be applied to the inital
    /// snapshot to rebuild the final data.
    #[timed]
    pub fn get_rev_data(&self, rev: Revision) -> Result<Vec<u8>, RevlogError> {
        if rev == NULL_REVISION {
            return Ok(vec![]);
        };
        // Todo return -> Cow
        let mut entry = self.get_entry(rev)?;
        let mut delta_chain = vec![];
        while let Some(base_rev) = entry.base_rev {
            delta_chain.push(entry);

        self.base_rev.is_some()
    }
}

/// Format version of the revlog.
pub fn get_version(index_bytes: &[u8]) -> Result<u16, HgError> {
    if index_bytes.len() == 0 {
        return Ok(1);
    };
    if index_bytes.len() < 4 {
        return Err(HgError::corrupted(
            "corrupted revlog: can't read the index format header",
        ));
    };
    Ok(BigEndian::read_u16(&index_bytes[2..=3]))
}

/// Calculate the hash of a revision given its data and its parents.
fn hash(
    data: &[u8],