# HG changeset patch # User Georges Racinet # Date 1558051017 -7200 # Node ID 1c4b5689bef5b41e13d81247eaa37d2430662573 # Parent 8041a1b45163339bd1dc0b07d8684c6c1383240f rust-discovery: exposing sampling to python Differential Revision: https://phab.mercurial-scm.org/D6425 diff -r 8041a1b45163 -r 1c4b5689bef5 rust/hg-cpython/src/discovery.rs --- a/rust/hg-cpython/src/discovery.rs Fri May 17 01:56:57 2019 +0200 +++ b/rust/hg-cpython/src/discovery.rs Fri May 17 01:56:57 2019 +0200 @@ -18,7 +18,7 @@ exceptions::GraphError, }; use cpython::{ - ObjectProtocol, PyDict, PyModule, PyObject, PyResult, Python, + ObjectProtocol, PyDict, PyModule, PyObject, PyResult, PyTuple, Python, PythonObject, ToPyObject, }; use hg::discovery::PartialDiscovery as CorePartialDiscovery; @@ -111,6 +111,32 @@ .map_err(|e| GraphError::pynew(py, e))? ) } + + def takefullsample(&self, _headrevs: PyObject, + size: usize) -> PyResult { + let mut inner = self.inner(py).borrow_mut(); + let sample = inner.take_full_sample(size) + .map_err(|e| GraphError::pynew(py, e))?; + let as_vec: Vec = sample + .iter() + .map(|rev| rev.to_py_object(py).into_object()) + .collect(); + Ok(PyTuple::new(py, as_vec.as_slice()).into_object()) + } + + def takequicksample(&self, headrevs: PyObject, + size: usize) -> PyResult { + let mut inner = self.inner(py).borrow_mut(); + let revsvec: Vec = rev_pyiter_collect(py, &headrevs)?; + let sample = inner.take_quick_sample(revsvec, size) + .map_err(|e| GraphError::pynew(py, e))?; + let as_vec: Vec = sample + .iter() + .map(|rev| rev.to_py_object(py).into_object()) + .collect(); + Ok(PyTuple::new(py, as_vec.as_slice()).into_object()) + } + }); /// Create the module, with __package__ given from parent