Mercurial > public > mercurial-scm > hg
comparison rust/hg-core/src/dirstate_tree/owning.rs @ 47954:4afd6cc447b9
rust: Make OwningDirstateMap generic and move it into hg-core
This will enable using it in rhg too.
The `OwningDirstateMap::new_empty` constructor is generic and accepts a value
of any type that gives acces to a bytes buffer. That buffer must stay valid
as long as the value hasn?t been dropped, and must keep its memory address
even if the value is moved. The `StableDeref` marker trait encodes those
constraints. Previously no trait was needed because the value was always
of type `PyBytes` which we know satisfies those constraints.
The buffer type is ereased in the struct itself through boxing and
dynamic dispatch, in order to simplify other signatures that mention
`OwningDirstateMap`.
Differential Revision: https://phab.mercurial-scm.org/D11396
author | Simon Sapin <simon.sapin@octobus.net> |
---|---|
date | Thu, 09 Sep 2021 18:07:40 +0200 |
parents | rust/hg-cpython/src/dirstate/owning.rs@78f7f0d490ee |
children | 37a41267d000 |
comparison
equal
deleted
inserted
replaced
47953:8f031a274cd6 | 47954:4afd6cc447b9 |
---|---|
1 use super::dirstate_map::DirstateMap; | |
2 use stable_deref_trait::StableDeref; | |
3 use std::ops::Deref; | |
4 | |
5 /// Keep a `DirstateMap<'on_disk>` next to the `on_disk` buffer that it | |
6 /// borrows. | |
7 /// | |
8 /// This is similar to [`OwningRef`] which is more limited because it | |
9 /// represents exactly one `&T` reference next to the value it borrows, as | |
10 /// opposed to a struct that may contain an arbitrary number of references in | |
11 /// arbitrarily-nested data structures. | |
12 /// | |
13 /// [`OwningRef`]: https://docs.rs/owning_ref/0.4.1/owning_ref/struct.OwningRef.html | |
14 pub struct OwningDirstateMap { | |
15 /// Owned handle to a bytes buffer with a stable address. | |
16 /// | |
17 /// See <https://docs.rs/owning_ref/0.4.1/owning_ref/trait.StableAddress.html>. | |
18 on_disk: Box<dyn Deref<Target = [u8]> + Send>, | |
19 | |
20 /// Pointer for `Box<DirstateMap<'on_disk>>`, typed-erased because the | |
21 /// language cannot represent a lifetime referencing a sibling field. | |
22 /// This is not quite a self-referencial struct (moving this struct is not | |
23 /// a problem as it doesn’t change the address of the bytes buffer owned | |
24 /// by `PyBytes`) but touches similar borrow-checker limitations. | |
25 ptr: *mut (), | |
26 } | |
27 | |
28 impl OwningDirstateMap { | |
29 pub fn new_empty<OnDisk>(on_disk: OnDisk) -> Self | |
30 where | |
31 OnDisk: Deref<Target = [u8]> + StableDeref + Send + 'static, | |
32 { | |
33 let on_disk = Box::new(on_disk); | |
34 let bytes: &'_ [u8] = &on_disk; | |
35 let map = DirstateMap::empty(bytes); | |
36 | |
37 // Like in `bytes` above, this `'_` lifetime parameter borrows from | |
38 // the bytes buffer owned by `on_disk`. | |
39 let ptr: *mut DirstateMap<'_> = Box::into_raw(Box::new(map)); | |
40 | |
41 // Erase the pointed type entirely in order to erase the lifetime. | |
42 let ptr: *mut () = ptr.cast(); | |
43 | |
44 Self { on_disk, ptr } | |
45 } | |
46 | |
47 pub fn get_mut_pair<'a>( | |
48 &'a mut self, | |
49 ) -> (&'a [u8], &'a mut DirstateMap<'a>) { | |
50 // SAFETY: We cast the type-erased pointer back to the same type it had | |
51 // in `new`, except with a different lifetime parameter. This time we | |
52 // connect the lifetime to that of `self`. This cast is valid because | |
53 // `self` owns the same `PyBytes` whose buffer `DirstateMap` | |
54 // references. That buffer has a stable memory address because the byte | |
55 // string value of a `PyBytes` is immutable. | |
56 let ptr: *mut DirstateMap<'a> = self.ptr.cast(); | |
57 // SAFETY: we dereference that pointer, connecting the lifetime of the | |
58 // new `&mut` to that of `self`. This is valid because the | |
59 // raw pointer is to a boxed value, and `self` owns that box. | |
60 (&self.on_disk, unsafe { &mut *ptr }) | |
61 } | |
62 | |
63 pub fn get_mut<'a>(&'a mut self) -> &'a mut DirstateMap<'a> { | |
64 self.get_mut_pair().1 | |
65 } | |
66 | |
67 pub fn get<'a>(&'a self) -> &'a DirstateMap<'a> { | |
68 // SAFETY: same reasoning as in `get_mut` above. | |
69 let ptr: *mut DirstateMap<'a> = self.ptr.cast(); | |
70 unsafe { &*ptr } | |
71 } | |
72 | |
73 pub fn on_disk<'a>(&'a self) -> &'a [u8] { | |
74 &self.on_disk | |
75 } | |
76 } | |
77 | |
78 impl Drop for OwningDirstateMap { | |
79 fn drop(&mut self) { | |
80 // Silence a "field is never read" warning, and demonstrate that this | |
81 // value is still alive. | |
82 let _ = &self.on_disk; | |
83 // SAFETY: this cast is the same as in `get_mut`, and is valid for the | |
84 // same reason. `self.on_disk` still exists at this point, drop glue | |
85 // will drop it implicitly after this `drop` method returns. | |
86 let ptr: *mut DirstateMap<'_> = self.ptr.cast(); | |
87 // SAFETY: `Box::from_raw` takes ownership of the box away from `self`. | |
88 // This is fine because drop glue does nothig for `*mut ()` and we’re | |
89 // in `drop`, so `get` and `get_mut` cannot be called again. | |
90 unsafe { drop(Box::from_raw(ptr)) } | |
91 } | |
92 } | |
93 | |
94 fn _static_assert_is_send<T: Send>() {} | |
95 | |
96 fn _static_assert_fields_are_send() { | |
97 _static_assert_is_send::<Box<DirstateMap<'_>>>(); | |
98 } | |
99 | |
100 // SAFETY: we don’t get this impl implicitly because `*mut (): !Send` because | |
101 // thread-safety of raw pointers is unknown in the general case. However this | |
102 // particular raw pointer represents a `Box<DirstateMap<'on_disk>>` that we | |
103 // own. Since that `Box` is `Send` as shown in above, it is sound to mark | |
104 // this struct as `Send` too. | |
105 unsafe impl Send for OwningDirstateMap {} |