dirstate.rs
154 lines
| 3.9 KiB
| application/rls-services+xml
|
RustLexer
Raphaël Gomès
|
r42993 | // dirstate module | ||
// | ||||
// Copyright 2019 Raphaël Gomès <rgomes@octobus.net> | ||||
// | ||||
// This software may be used and distributed according to the terms of the | ||||
// GNU General Public License version 2 or any later version. | ||||
Simon Sapin
|
r48126 | use crate::dirstate_tree::on_disk::DirstateV2ParseError; | ||
Simon Sapin
|
r47169 | use crate::errors::HgError; | ||
Simon Sapin
|
r48165 | use crate::revlog::node::NULL_NODE; | ||
Simon Sapin
|
r47337 | use crate::revlog::Node; | ||
Simon Sapin
|
r47894 | use crate::utils::hg_path::{HgPath, HgPathBuf}; | ||
use crate::FastHashMap; | ||||
Simon Sapin
|
r47336 | use bytes_cast::{unaligned, BytesCast}; | ||
Raphaël Gomès
|
r42994 | use std::convert::TryFrom; | ||
Raphaël Gomès
|
r42993 | |||
Raphaël Gomès
|
r42828 | pub mod dirs_multiset; | ||
Raphaël Gomès
|
r42998 | pub mod dirstate_map; | ||
Raphaël Gomès
|
r42828 | pub mod parsers; | ||
Raphaël Gomès
|
r43565 | pub mod status; | ||
Raphaël Gomès
|
r42828 | |||
Simon Sapin
|
r47336 | #[derive(Debug, PartialEq, Clone, BytesCast)] | ||
#[repr(C)] | ||||
Raphaël Gomès
|
r42993 | pub struct DirstateParents { | ||
Simon Sapin
|
r47337 | pub p1: Node, | ||
pub p2: Node, | ||||
Raphaël Gomès
|
r42828 | } | ||
Simon Sapin
|
r48165 | impl DirstateParents { | ||
pub const NULL: Self = Self { | ||||
p1: NULL_NODE, | ||||
p2: NULL_NODE, | ||||
}; | ||||
} | ||||
Raphaël Gomès
|
r42828 | /// The C implementation uses all signed types. This will be an issue | ||
/// either when 4GB+ source files are commonplace or in 2038, whichever | ||||
/// comes first. | ||||
Raphaël Gomès
|
r42993 | #[derive(Debug, PartialEq, Copy, Clone)] | ||
Raphaël Gomès
|
r42828 | pub struct DirstateEntry { | ||
Raphaël Gomès
|
r42994 | pub state: EntryState, | ||
Raphaël Gomès
|
r42828 | pub mode: i32, | ||
pub mtime: i32, | ||||
pub size: i32, | ||||
} | ||||
Simon Sapin
|
r47878 | impl DirstateEntry { | ||
pub fn is_non_normal(&self) -> bool { | ||||
self.state != EntryState::Normal || self.mtime == MTIME_UNSET | ||||
} | ||||
pub fn is_from_other_parent(&self) -> bool { | ||||
self.state == EntryState::Normal && self.size == SIZE_FROM_OTHER_PARENT | ||||
} | ||||
Simon Sapin
|
r47883 | |||
// TODO: other platforms | ||||
#[cfg(unix)] | ||||
pub fn mode_changed( | ||||
&self, | ||||
filesystem_metadata: &std::fs::Metadata, | ||||
) -> bool { | ||||
use std::os::unix::fs::MetadataExt; | ||||
const EXEC_BIT_MASK: u32 = 0o100; | ||||
let dirstate_exec_bit = (self.mode as u32) & EXEC_BIT_MASK; | ||||
let fs_exec_bit = filesystem_metadata.mode() & EXEC_BIT_MASK; | ||||
dirstate_exec_bit != fs_exec_bit | ||||
} | ||||
Simon Sapin
|
r47878 | } | ||
Simon Sapin
|
r47336 | #[derive(BytesCast)] | ||
#[repr(C)] | ||||
struct RawEntry { | ||||
state: u8, | ||||
mode: unaligned::I32Be, | ||||
size: unaligned::I32Be, | ||||
mtime: unaligned::I32Be, | ||||
length: unaligned::I32Be, | ||||
} | ||||
r48310 | pub const V1_RANGEMASK: i32 = 0x7FFFFFFF; | |||
r48308 | pub const MTIME_UNSET: i32 = -1; | |||
Simon Sapin
|
r47878 | |||
Raphaël Gomès
|
r44003 | /// A `DirstateEntry` with a size of `-2` means that it was merged from the | ||
/// other parent. This allows revert to pick the right status back during a | ||||
/// merge. | ||||
pub const SIZE_FROM_OTHER_PARENT: i32 = -2; | ||||
r48300 | /// A special value used for internal representation of special case in | |||
/// dirstate v1 format. | ||||
pub const SIZE_NON_NORMAL: i32 = -1; | ||||
Raphaël Gomès
|
r44003 | |||
Raphaël Gomès
|
r44278 | pub type StateMap = FastHashMap<HgPathBuf, DirstateEntry>; | ||
Simon Sapin
|
r48126 | pub type StateMapIter<'a> = Box< | ||
dyn Iterator< | ||||
Item = Result<(&'a HgPath, DirstateEntry), DirstateV2ParseError>, | ||||
> + Send | ||||
+ 'a, | ||||
>; | ||||
Raphaël Gomès
|
r46185 | |||
Raphaël Gomès
|
r44278 | pub type CopyMap = FastHashMap<HgPathBuf, HgPathBuf>; | ||
Simon Sapin
|
r48126 | pub type CopyMapIter<'a> = Box< | ||
dyn Iterator<Item = Result<(&'a HgPath, &'a HgPath), DirstateV2ParseError>> | ||||
+ Send | ||||
+ 'a, | ||||
>; | ||||
Raphaël Gomès
|
r42828 | |||
Raphaël Gomès
|
r42994 | #[derive(Copy, Clone, Debug, Eq, PartialEq)] | ||
pub enum EntryState { | ||||
Normal, | ||||
Added, | ||||
Removed, | ||||
Merged, | ||||
Unknown, | ||||
} | ||||
Simon Sapin
|
r47876 | impl EntryState { | ||
pub fn is_tracked(self) -> bool { | ||||
use EntryState::*; | ||||
match self { | ||||
Normal | Added | Merged => true, | ||||
Removed | Unknown => false, | ||||
} | ||||
} | ||||
} | ||||
Raphaël Gomès
|
r42994 | impl TryFrom<u8> for EntryState { | ||
Simon Sapin
|
r47169 | type Error = HgError; | ||
Raphaël Gomès
|
r42994 | |||
fn try_from(value: u8) -> Result<Self, Self::Error> { | ||||
match value { | ||||
b'n' => Ok(EntryState::Normal), | ||||
b'a' => Ok(EntryState::Added), | ||||
b'r' => Ok(EntryState::Removed), | ||||
b'm' => Ok(EntryState::Merged), | ||||
b'?' => Ok(EntryState::Unknown), | ||||
Simon Sapin
|
r47169 | _ => Err(HgError::CorruptedRepository(format!( | ||
"Incorrect dirstate entry state {}", | ||||
Raphaël Gomès
|
r42994 | value | ||
))), | ||||
} | ||||
} | ||||
} | ||||
impl Into<u8> for EntryState { | ||||
fn into(self) -> u8 { | ||||
match self { | ||||
EntryState::Normal => b'n', | ||||
EntryState::Added => b'a', | ||||
EntryState::Removed => b'r', | ||||
EntryState::Merged => b'm', | ||||
EntryState::Unknown => b'?', | ||||
} | ||||
} | ||||
} | ||||