owning.rs
91 lines
| 2.3 KiB
| application/rls-services+xml
|
RustLexer
Raphaël Gomès
|
r49864 | use crate::{DirstateError, DirstateParents}; | ||
Simon Sapin
|
r48766 | use super::dirstate_map::DirstateMap; | ||
Raphaël Gomès
|
r51575 | use self_cell::self_cell; | ||
Simon Sapin
|
r48766 | use std::ops::Deref; | ||
Raphaël Gomès
|
r51575 | self_cell!( | ||
/// Keep a `DirstateMap<'owner>` next to the `owner` buffer that it | ||||
/// borrows. | ||||
pub struct OwningDirstateMap { | ||||
owner: Box<dyn Deref<Target = [u8]> + Send>, | ||||
#[covariant] | ||||
dependent: DirstateMap, | ||||
} | ||||
); | ||||
Simon Sapin
|
r48766 | |||
impl OwningDirstateMap { | ||||
pub fn new_empty<OnDisk>(on_disk: OnDisk) -> Self | ||||
where | ||||
Raphaël Gomès
|
r49864 | OnDisk: Deref<Target = [u8]> + Send + 'static, | ||
Simon Sapin
|
r48766 | { | ||
let on_disk = Box::new(on_disk); | ||||
Raphaël Gomès
|
r51575 | OwningDirstateMap::new(on_disk, |bytes| DirstateMap::empty(bytes)) | ||
Simon Sapin
|
r48766 | } | ||
Raphaël Gomès
|
r49864 | pub fn new_v1<OnDisk>( | ||
on_disk: OnDisk, | ||||
Raphaël Gomès
|
r51140 | identity: Option<u64>, | ||
Raphaël Gomès
|
r49864 | ) -> Result<(Self, DirstateParents), DirstateError> | ||
where | ||||
OnDisk: Deref<Target = [u8]> + Send + 'static, | ||||
{ | ||||
let on_disk = Box::new(on_disk); | ||||
let mut parents = DirstateParents::NULL; | ||||
Simon Sapin
|
r48766 | |||
Raphaël Gomès
|
r49864 | Ok(( | ||
Raphaël Gomès
|
r51575 | OwningDirstateMap::try_new(on_disk, |bytes| { | ||
DirstateMap::new_v1(bytes, identity).map(|(dmap, p)| { | ||||
parents = p.unwrap_or(DirstateParents::NULL); | ||||
dmap | ||||
}) | ||||
})?, | ||||
Raphaël Gomès
|
r49864 | parents, | ||
)) | ||||
Simon Sapin
|
r48766 | } | ||
Raphaël Gomès
|
r49864 | pub fn new_v2<OnDisk>( | ||
on_disk: OnDisk, | ||||
data_size: usize, | ||||
metadata: &[u8], | ||||
Raphaël Gomès
|
r51138 | uuid: Vec<u8>, | ||
Raphaël Gomès
|
r51140 | identity: Option<u64>, | ||
Raphaël Gomès
|
r49864 | ) -> Result<Self, DirstateError> | ||
where | ||||
OnDisk: Deref<Target = [u8]> + Send + 'static, | ||||
{ | ||||
let on_disk = Box::new(on_disk); | ||||
Raphaël Gomès
|
r51575 | OwningDirstateMap::try_new(on_disk, |bytes| { | ||
DirstateMap::new_v2(bytes, data_size, metadata, uuid, identity) | ||||
}) | ||||
Simon Sapin
|
r48766 | } | ||
Raphaël Gomès
|
r49864 | pub fn with_dmap_mut<R>( | ||
&mut self, | ||||
f: impl FnOnce(&mut DirstateMap) -> R, | ||||
) -> R { | ||||
Raphaël Gomès
|
r51575 | self.with_dependent_mut(|_owner, dmap| f(dmap)) | ||
Raphaël Gomès
|
r49864 | } | ||
pub fn get_map(&self) -> &DirstateMap { | ||||
Raphaël Gomès
|
r51575 | self.borrow_dependent() | ||
Raphaël Gomès
|
r49864 | } | ||
pub fn on_disk(&self) -> &[u8] { | ||||
Raphaël Gomès
|
r51575 | self.borrow_owner() | ||
Simon Sapin
|
r48766 | } | ||
Raphaël Gomès
|
r51138 | |||
pub fn old_uuid(&self) -> Option<&[u8]> { | ||||
self.get_map().old_uuid.as_deref() | ||||
} | ||||
Raphaël Gomès
|
r51140 | pub fn old_identity(&self) -> Option<u64> { | ||
self.get_map().identity | ||||
} | ||||
Raphaël Gomès
|
r51138 | pub fn old_data_size(&self) -> usize { | ||
self.get_map().old_data_size | ||||
} | ||||
Simon Sapin
|
r48766 | } | ||