wedb_standalone 0.1.1

单机网络服务底座：RESP 协议帧、AOF 逻辑层与节点服务编排（对标 Garnet libs/server 单机半区）
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

use hdrhistogram::Histogram;

use super::latency_metrics_entry::time_stamp::seconds;

/// 会话侧延迟条目：双缓冲直方图 + 进行中操作的起始时间戳。
///
/// 版本 0/1 由监视器迭代计数奇偶切换；合并方向取"上一版本"。
///（对标 libs/server/Metrics/Latency/LatencyMetricsEntrySession.cs:LatencyMetricsEntrySession）
#[derive(Clone)]
pub struct LatencyMetricsEntrySession {
  /// 进行中操作的起始 Stopwatch tick（0 = 无进行中操作）。
  pub start_timestamp: u64,
  /// 双版本延迟直方图。
  pub latency: [Histogram<u64>; 2],
}

impl Default for LatencyMetricsEntrySession {
  fn default() -> Self {
    Self::new()
  }
}

impl LatencyMetricsEntrySession {
  /// 直方图下界：1 tick。
  pub const HISTOGRAM_LOWER_BOUND: u64 = 1;
  /// 直方图上界：100 秒（tick 计量）。
  pub const HISTOGRAM_UPPER_BOUND: u64 = seconds(100);

  /// libs/server/Metrics/Latency/LatencyMetricsEntrySession.cs:LatencyMetricsEntrySession（构造）。
  pub fn new() -> Self {
    let hist = || {
      Histogram::new_with_bounds(Self::HISTOGRAM_LOWER_BOUND, Self::HISTOGRAM_UPPER_BOUND, 2)
        .expect("直方图边界为编译期常量，构造必成功")
    };
    Self {
      start_timestamp: 0,
      latency: [hist(), hist()],
    }
  }

  /// libs/server/Metrics/Latency/LatencyMetricsEntrySession.cs:Return
  ///
  /// 归还双缓冲直方图（池化语义在 Rust 侧为重置）。
  pub fn return_to_pool(&mut self) {
    self.latency[0].reset();
    self.latency[1].reset();
  }

  /// libs/server/Metrics/Latency/LatencyMetricsEntrySession.cs:Start
  ///
  /// 记录起始时间戳（以当前单调时钟为准，由调用方传入 tick）。
  #[inline]
  pub fn start(&mut self, now_ticks: u64) {
    self.start_timestamp = now_ticks;
  }

  /// libs/server/Metrics/Latency/LatencyMetricsEntrySession.cs:RecordValue(ver)
  ///
  /// 以当前时钟结束进行中的操作并记入版本 `ver`；无进行中操作时忽略。
  /// 与双参重载不同：此处 elapsed == 0 时 `IsValidRange` 必假，按 C# 语义
  /// 饱和记入上界（而非跳过）。
  #[inline]
  pub fn record_value(&mut self, ver: usize, now_ticks: u64) {
    if self.start_timestamp == 0 {
      return;
    }
    let elapsed = now_ticks.saturating_sub(self.start_timestamp) as i64;
    let value = if Self::is_valid_range(elapsed) {
      elapsed as u64
    } else {
      Self::HISTOGRAM_UPPER_BOUND
    };
    // 记录失败仅可能因越界，已收敛上界，故忽略返回值。
    let _ = self.latency[ver].record(value);
    self.start_timestamp = 0;
  }

  /// libs/server/Metrics/Latency/LatencyMetricsEntrySession.cs:RecordValue(ver, elapsed)
  ///
  /// 直接记录一段耗时；越界值收敛到直方图上界（对齐 C# 饱和记录）。
  #[inline]
  pub fn record_elapsed(&mut self, ver: usize, elapsed: i64) {
    if elapsed == 0 {
      return;
    }
    let value = if Self::is_valid_range(elapsed) {
      elapsed as u64
    } else {
      Self::HISTOGRAM_UPPER_BOUND
    };
    // 记录失败仅可能因越界，已收敛上界，故忽略返回值。
    let _ = self.latency[ver].record(value);
  }

  /// libs/server/Metrics/Latency/LatencyMetricsEntrySession.cs:IsValidRange
  ///
  /// 耗时是否落在直方图可表达区间 [1, 100s) 内。
  #[inline]
  pub fn is_valid_range(value: i64) -> bool {
    value >= Self::HISTOGRAM_LOWER_BOUND as i64 && (value as u64) < Self::HISTOGRAM_UPPER_BOUND
  }
}