wbase 0.1.1

wbase
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

//! 高吞吐 CRC32 校验和工具（硬件指令加速）
//!
//! 统一收敛存储引擎的 WAL 预写日志校验、Checkpoint 元数据封签与段完整性验证，
//! 杜绝上层模块散落手写整数标量字节切片更新逻辑。

/// 计算给定字节切片的 CRC32 校验和
#[inline(always)]
pub fn crc32(data: &[u8]) -> u32 {
  crc32fast::hash(data)
}

/// 流式 CRC32 摘要累加器
#[derive(Debug, Default, Clone)]
pub struct Crc32Hasher {
  hasher: crc32fast::Hasher,
}

impl Crc32Hasher {
  #[inline(always)]
  pub fn new() -> Self {
    Self {
      hasher: crc32fast::Hasher::new(),
    }
  }

  /// 喂入原始字节切片
  #[inline(always)]
  pub fn update(&mut self, bytes: &[u8]) {
    self.hasher.update(bytes);
  }

  /// 以小端字节序喂入 64 位整型（无堆分配）
  #[inline(always)]
  pub fn update_u64(&mut self, val: u64) {
    self.hasher.update(&val.to_le_bytes());
  }

  /// 以小端字节序喂入 32 位整型（无堆分配）
  #[inline(always)]
  pub fn update_u32(&mut self, val: u32) {
    self.hasher.update(&val.to_le_bytes());
  }

  /// 以小端字节序喂入 16 位整型（无堆分配）
  #[inline(always)]
  pub fn update_u16(&mut self, val: u16) {
    self.hasher.update(&val.to_le_bytes());
  }

  /// 喂入单字节
  #[inline(always)]
  pub fn update_u8(&mut self, val: u8) {
    self.hasher.update(&[val]);
  }

  /// 完成计算并返回 32 位校验码
  #[inline(always)]
  pub fn finalize(self) -> u32 {
    self.hasher.finalize()
  }

  /// 读取当前累计的 32 位校验码（不消耗 Hasher）
  #[inline(always)]
  pub fn current_crc(&self) -> u32 {
    self.hasher.clone().finalize()
  }
}