Skip to content
Snippets Groups Projects
Commit 66fa902c4e59 authored by Pierre-Yves David's avatar Pierre-Yves David :octopus:
Browse files

copies: introduce the hg-cpython wrapper for `combine_changeset_copies`

This patch focus on the `hg-cpython` part of this work. Bridging the python code
with the new rust code in `hg-core`. The next patch will actually plug this in
the python code.

The rust code use multiple Python callback, python related error within this
callback are not expected unless they are a programming error or a data
corruption. In addition, these callback will slowly be replaced by native Rust
code. For these reasons, we use will deal with unexpected error within this
callback using rust Panic and let the `rust-cpython` layer deal with raising a
Python exception.
parent 7b876075388d
No related branches found
No related tags found
No related merge requests found
use cpython::ObjectProtocol;
use cpython::PyBool;
use cpython::PyBytes;
use cpython::PyDict;
use cpython::PyList;
use cpython::PyModule;
use cpython::PyObject;
use cpython::PyResult;
use cpython::PyTuple;
use cpython::Python;
use hg::copy_tracing::combine_changeset_copies;
use hg::copy_tracing::ChangedFiles;
use hg::copy_tracing::RevInfo;
use hg::utils::hg_path::HgPathBuf;
use hg::Revision;
/// combines copies information contained into revision `revs` to build a copy
/// map.
///
/// See mercurial/copies.py for details
pub fn combine_changeset_copies_wrapper(
py: Python,
revs: PyList,
children: PyDict,
target_rev: Revision,
rev_info: PyObject,
is_ancestor: PyObject,
) -> PyResult<PyDict> {
let revs: PyResult<_> =
revs.iter(py).map(|r| Ok(r.extract(py)?)).collect();
let is_ancestor_wrap = |anc: Revision, desc: Revision| -> bool {
is_ancestor
.call(py, (anc, desc), None)
.expect("rust-copy-tracing: python call to `is_ancestor` failed")
.cast_into::<PyBool>(py)
.expect("rust-copy-tracing: python call to `is_ancestor` returned unexpected non-Bool value")
.is_true()
};
let rev_info_maker = |rev: Revision| -> RevInfo {
let res: PyTuple = rev_info
.call(py, (rev,), None)
.expect("rust-copy-tracing: python call to `rev_info` failed")
.cast_into(py)
.expect("rust-copy_tracing: python call to `rev_info` returned unexpected non-Tuple value");
let p1 = res.get_item(py, 0).extract(py).expect("rust-copy-tracing: rev_info return is invalid, first item is a not a revision");
let p2 = res.get_item(py, 1).extract(py).expect("rust-copy-tracing: rev_info return is invalid, first item is a not a revision");
let changes = res.get_item(py, 2);
let files;
if !changes
.hasattr(py, "copied_from_p1")
.expect("rust-copy-tracing: python call to `hasattr` failed")
{
files = ChangedFiles::new_empty();
} else {
let p1_copies: PyDict = changes
.getattr(py, "copied_from_p1")
.expect("rust-copy-tracing: retrieval of python attribute `copied_from_p1` failed")
.cast_into(py)
.expect("rust-copy-tracing: failed to convert `copied_from_p1` to PyDict");
let p1_copies: PyResult<_> = p1_copies
.items(py)
.iter()
.map(|(key, value)| {
let key = key.extract::<PyBytes>(py).expect("rust-copy-tracing: conversion of copy destination to PyBytes failed");
let key = key.data(py);
let value = value.extract::<PyBytes>(py).expect("rust-copy-tracing: conversion of copy source to PyBytes failed");
let value = value.data(py);
Ok((
HgPathBuf::from_bytes(key),
HgPathBuf::from_bytes(value),
))
})
.collect();
let p2_copies: PyDict = changes
.getattr(py, "copied_from_p2")
.expect("rust-copy-tracing: retrieval of python attribute `copied_from_p2` failed")
.cast_into(py)
.expect("rust-copy-tracing: failed to convert `copied_from_p2` to PyDict");
let p2_copies: PyResult<_> = p2_copies
.items(py)
.iter()
.map(|(key, value)| {
let key = key.extract::<PyBytes>(py).expect("rust-copy-tracing: conversion of copy destination to PyBytes failed");
let key = key.data(py);
let value = value.extract::<PyBytes>(py).expect("rust-copy-tracing: conversion of copy source to PyBytes failed");
let value = value.data(py);
Ok((
HgPathBuf::from_bytes(key),
HgPathBuf::from_bytes(value),
))
})
.collect();
let removed: PyObject = changes
.getattr(py, "removed")
.expect("rust-copy-tracing: retrieval of python attribute `removed` failed");
let removed: PyResult<_> = removed
.iter(py)
.expect("rust-copy-tracing: getting a python iterator over the `removed` set failed")
.map(|filename| {
let filename = filename
.expect("rust-copy-tracing: python iteration over the `removed` set failed")
.extract::<PyBytes>(py).expect("rust-copy-tracing: conversion of `removed` item to PyBytes failed");
let filename = filename.data(py);
Ok(HgPathBuf::from_bytes(filename))
})
.collect();
let merged: PyObject = changes
.getattr(py, "merged")
.expect("rust-copy-tracing: retrieval of python attribute `merged` failed");
let merged: PyResult<_> = merged
.iter(py)
.expect("rust-copy-tracing: getting a python iterator over the `merged` set failed")
.map(|filename| {
let filename = filename
.expect("rust-copy-tracing: python iteration over the `merged` set failed")
.extract::<PyBytes>(py).expect("rust-copy-tracing: conversion of `merged` item to PyBytes failed");
let filename = filename.data(py);
Ok(HgPathBuf::from_bytes(filename))
})
.collect();
let salvaged: PyObject = changes
.getattr(py, "salvaged")
.expect("rust-copy-tracing: retrieval of python attribute `salvaged` failed");
let salvaged: PyResult<_> = salvaged
.iter(py)
.expect("rust-copy-tracing: getting a python iterator over the `salvaged` set failed")
.map(|filename| {
let filename = filename
.expect("rust-copy-tracing: python iteration over the `salvaged` set failed")
.extract::<PyBytes>(py).expect("rust-copy-tracing: conversion of `salvaged` item to PyBytes failed");
let filename = filename.data(py);
Ok(HgPathBuf::from_bytes(filename))
})
.collect();
files = ChangedFiles::new(
removed.unwrap(),
merged.unwrap(),
salvaged.unwrap(),
p1_copies.unwrap(),
p2_copies.unwrap(),
);
}
(p1, p2, files)
};
let children: PyResult<_> = children
.items(py)
.iter()
.map(|(k, v)| {
let v: &PyList = v.cast_as(py)?;
let v: PyResult<_> =
v.iter(py).map(|child| Ok(child.extract(py)?)).collect();
Ok((k.extract(py)?, v?))
})
.collect();
let res = combine_changeset_copies(
revs?,
children?,
target_rev,
&rev_info_maker,
&is_ancestor_wrap,
);
let out = PyDict::new(py);
for (dest, source) in res.into_iter() {
out.set_item(
py,
PyBytes::new(py, &dest.into_vec()),
PyBytes::new(py, &source.into_vec()),
)?;
}
Ok(out)
}
/// Create the module, with `__package__` given from parent
pub fn init_module(py: Python, package: &str) -> PyResult<PyModule> {
let dotted_name = &format!("{}.copy_tracing", package);
let m = PyModule::new(py, dotted_name)?;
m.add(py, "__package__", package)?;
m.add(py, "__doc__", "Copy tracing - Rust implementation")?;
m.add(
py,
"combine_changeset_copies",
py_fn!(
py,
combine_changeset_copies_wrapper(
revs: PyList,
children: PyDict,
target_rev: Revision,
rev_info: PyObject,
is_ancestor: PyObject
)
),
)?;
let sys = PyModule::import(py, "sys")?;
let sys_modules: PyDict = sys.get(py, "modules")?.extract(py)?;
sys_modules.set_item(py, dotted_name, &m)?;
Ok(m)
}
......@@ -29,6 +29,7 @@
mod conversion;
#[macro_use]
pub mod ref_sharing;
pub mod copy_tracing;
pub mod dagops;
pub mod debug;
pub mod dirstate;
......@@ -49,6 +50,11 @@
m.add(py, "ancestor", ancestors::init_module(py, &dotted_name)?)?;
m.add(py, "dagop", dagops::init_module(py, &dotted_name)?)?;
m.add(py, "debug", debug::init_module(py, &dotted_name)?)?;
m.add(
py,
"copy_tracing",
copy_tracing::init_module(py, &dotted_name)?,
)?;
m.add(py, "discovery", discovery::init_module(py, &dotted_name)?)?;
m.add(py, "dirstate", dirstate::init_module(py, &dotted_name)?)?;
m.add(py, "revlog", revlog::init_module(py, &dotted_name)?)?;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment