Mercurial > public > mercurial-scm > hg-stable
view rust/hg-core/src/dirstate_tree/owning.rs @ 49703:dbe09fb038fc stable
rhg: remember the inode of .hg/dirstate
This allows us to detect changes of `.hg/dirstate`, which is either the
full dirstate (in dirstate-v1) or the docket file (v2) without relying on
data inside the file. It only works on UNIX systems.
This fixes a race condition for dirstate-v1 (as demonstrated by
the test changes) and adds a confortable layer of sanity for dirstate-v2.
author | Rapha?l Gom?s <rgomes@octobus.net> |
---|---|
date | Wed, 01 Mar 2023 16:48:09 +0100 |
parents | 6cce0afc1454 |
children | a6b8b1ab9116 |
line wrap: on
line source
use crate::{DirstateError, DirstateParents}; use super::dirstate_map::DirstateMap; use std::ops::Deref; use ouroboros::self_referencing; /// Keep a `DirstateMap<'on_disk>` next to the `on_disk` buffer that it /// borrows. #[self_referencing] pub struct OwningDirstateMap { on_disk: Box<dyn Deref<Target = [u8]> + Send>, #[borrows(on_disk)] #[covariant] map: DirstateMap<'this>, } impl OwningDirstateMap { pub fn new_empty<OnDisk>(on_disk: OnDisk) -> Self where OnDisk: Deref<Target = [u8]> + Send + 'static, { let on_disk = Box::new(on_disk); OwningDirstateMapBuilder { on_disk, map_builder: |bytes| DirstateMap::empty(&bytes), } .build() } pub fn new_v1<OnDisk>( on_disk: OnDisk, identity: Option<u64>, ) -> Result<(Self, DirstateParents), DirstateError> where OnDisk: Deref<Target = [u8]> + Send + 'static, { let on_disk = Box::new(on_disk); let mut parents = DirstateParents::NULL; Ok(( OwningDirstateMapTryBuilder { on_disk, map_builder: |bytes| { DirstateMap::new_v1(&bytes, identity).map(|(dmap, p)| { parents = p.unwrap_or(DirstateParents::NULL); dmap }) }, } .try_build()?, parents, )) } pub fn new_v2<OnDisk>( on_disk: OnDisk, data_size: usize, metadata: &[u8], uuid: Vec<u8>, identity: Option<u64>, ) -> Result<Self, DirstateError> where OnDisk: Deref<Target = [u8]> + Send + 'static, { let on_disk = Box::new(on_disk); OwningDirstateMapTryBuilder { on_disk, map_builder: |bytes| { DirstateMap::new_v2( &bytes, data_size, metadata, uuid, identity, ) }, } .try_build() } pub fn with_dmap_mut<R>( &mut self, f: impl FnOnce(&mut DirstateMap) -> R, ) -> R { self.with_map_mut(f) } pub fn get_map(&self) -> &DirstateMap { self.borrow_map() } pub fn on_disk(&self) -> &[u8] { self.borrow_on_disk() } pub fn old_uuid(&self) -> Option<&[u8]> { self.get_map().old_uuid.as_deref() } pub fn old_identity(&self) -> Option<u64> { self.get_map().identity } pub fn old_data_size(&self) -> usize { self.get_map().old_data_size } }