diff -r b6339a993b91 -r 9aba0cde0ed9 rust/hg-cpython/src/dirstate/dirstate_map.rs --- a/rust/hg-cpython/src/dirstate/dirstate_map.rs Fri Apr 30 15:40:11 2021 +0200 +++ b/rust/hg-cpython/src/dirstate/dirstate_map.rs Fri Apr 30 18:13:31 2021 +0200 @@ -32,8 +32,9 @@ revlog::Node, utils::files::normalize_case, utils::hg_path::{HgPath, HgPathBuf}, - DirsMultiset, DirstateEntry, DirstateMap as RustDirstateMap, - DirstateMapError, DirstateParents, EntryState, StateMapIter, + DirsMultiset, DirstateEntry, DirstateError, + DirstateMap as RustDirstateMap, DirstateMapError, DirstateParents, + EntryState, StateMapIter, }; // TODO @@ -51,13 +52,25 @@ py_class!(pub class DirstateMap |py| { @shared data inner: Box; - def __new__(_cls, use_dirstate_tree: bool) -> PyResult { - let inner = if use_dirstate_tree { - Box::new(hg::dirstate_tree::dirstate_map::DirstateMap::new()) as _ + /// Returns a `(dirstate_map, parents)` tuple + @staticmethod + def new(use_dirstate_tree: bool, on_disk: PyBytes) -> PyResult { + let dirstate_error = |_: DirstateError| { + PyErr::new::(py, "Dirstate error".to_string()) + }; + let bytes = on_disk.data(py); + let (inner, parents) = if use_dirstate_tree { + let mut map = hg::dirstate_tree::dirstate_map::DirstateMap::new(); + let parents = map.read(bytes).map_err(dirstate_error)?; + (Box::new(map) as _, parents) } else { - Box::new(RustDirstateMap::default()) as _ + let mut map = RustDirstateMap::default(); + let parents = map.read(bytes).map_err(dirstate_error)?; + (Box::new(map) as _, parents) }; - Self::create_instance(py, inner) + let map = Self::create_instance(py, inner)?; + let parents = parents.map(|p| dirstate_parents_to_pytuple(py, &p)); + Ok((map, parents).to_py_object(py).into_object()) } def clear(&self) -> PyResult { @@ -271,21 +284,6 @@ .to_py_object(py)) } - def read(&self, st: PyObject) -> PyResult> { - match self.inner(py).borrow_mut() - .read(st.extract::(py)?.data(py)) - { - Ok(Some(parents)) => Ok(Some( - dirstate_parents_to_pytuple(py, parents) - .into_object() - )), - Ok(None) => Ok(Some(py.None())), - Err(_) => Err(PyErr::new::( - py, - "Dirstate error".to_string(), - )), - } - } def write( &self, p1: PyObject,