Compare commits

..

3 Commits

Author SHA1 Message Date
houseme 61536636ec fix(heal): cleanup consumed MRF replay journals
Do not retain Accepted or Merged replay intents as startup anchors after they have been handed to the heal manager. Only refused or still-pending replay records keep the journal on disk until a successor snapshot can persist them.

This keeps successor snapshots limited to the pending queue, which lets successful replay remove both authoritative and legacy journal paths and restores the crash-boundary tests around successor flush.

Co-Authored-By: heihutu <heihutu@gmail.com>

Co-Authored-By: zhi22915 <qiuzgang@gmail.com>
(cherry picked from commit d5b8f49c9d)
2026-09-08 02:10:06 +08:00
houseme 7937c4c0ad fix(error): merge equivalent api message branches
Combine the MaxVersionsExceeded and internal IO message branches so Clippy no longer flags identical if blocks while preserving the existing response messages.

Co-Authored-By: heihutu <heihutu@gmail.com>

Co-Authored-By: zhi22915 <qiuzgang@gmail.com>
2026-09-08 00:27:01 +08:00
overtrue 7ab93d72d2 ci: refresh replication nightly selection 2026-09-07 23:58:29 +08:00
3 changed files with 6 additions and 13 deletions
+1 -1
View File
@@ -1 +1 @@
sha256=95c8adc016bbc0df9fb2afa24a108bcdf6567ec4d0518725a6cae301593ab556 sha256=0fe8408874ccec3620262a9812d67920ddd72dc9edf0e36e0d0aed3f8bad026e
+3 -6
View File
@@ -68,17 +68,14 @@ pub(super) fn rules() -> Vec<Rule> {
) )
}, },
Rule { Rule {
anchors: strings(["Storage inventory probe failed; current drive health is unknown"]), anchors: strings(["reporting peer disks offline after consecutive storage_info failures"]),
..base( ..base(
"peer-disks-offline", "peer-disks-offline",
P2Degraded, P2Degraded,
"disk", "disk",
"peer 存储清单探测失败", "peer 磁盘被整体判定离线",
any([
contains("Storage inventory probe failed; current drive health is unknown"),
contains("reporting peer disks offline after consecutive storage_info failures"), contains("reporting peer disks offline after consecutive storage_info failures"),
]), "对某 peer 连续 storage_info 失败,判定其磁盘整体离线。",
"某 peer 的 storage_info 探测失败,当前磁盘健康状态未知。",
"检查该 peer 节点存活与 RPC 端口可达。", "检查该 peer 节点存活与 RPC 端口可达。",
) )
}, },
+1 -5
View File
@@ -110,7 +110,7 @@ fn every_rule_has_a_positive_sample() {
("remote-peer-faulty", msg("Remote peer health check failed for node2: marking as faulty")), ("remote-peer-faulty", msg("Remote peer health check failed for node2: marking as faulty")),
( (
"peer-disks-offline", "peer-disks-offline",
msg("Storage inventory probe failed; current drive health is unknown"), msg("reporting peer disks offline after consecutive storage_info failures"),
), ),
("drive-faulty-error", msg("remote drive is faulty")), ("drive-faulty-error", msg("remote drive is faulty")),
( (
@@ -318,10 +318,6 @@ fn smoke_samples_hit_exact_rule_sets() {
&["disk-marked-faulty"], &["disk-marked-faulty"],
); );
exact(&msg("erasure write quorum (required=8, achieved=5)"), &["ec-write-quorum"]); exact(&msg("erasure write quorum (required=8, achieved=5)"), &["ec-write-quorum"]);
exact(
&msg("reporting peer disks offline after consecutive storage_info failures"),
&["peer-disks-offline"],
);
exact( exact(
&Sample { &Sample {
message: "Metacache listing quorum failed", message: "Metacache listing quorum failed",