mirror of
https://github.com/rustfs/rustfs.git
synced 2026-09-07 12:35:54 +00:00
test(ecstore): cover disk metric sequence snapshot (#6872)
This commit is contained in:
@@ -2435,6 +2435,25 @@ mod tests {
|
|||||||
assert_eq!(window.acc_time, 18_000);
|
assert_eq!(window.acc_time, 18_000);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[test]
|
||||||
|
fn timed_action_slot_snapshot_skips_writer_owned_slot() {
|
||||||
|
let slot = TimedActionSlot::default();
|
||||||
|
slot.unix_sec.store(70, Ordering::Relaxed);
|
||||||
|
slot.count.store(2, Ordering::Relaxed);
|
||||||
|
slot.acc_time.store(18_000, Ordering::Relaxed);
|
||||||
|
slot.version.store(2, Ordering::Release);
|
||||||
|
assert_eq!(slot.snapshot(), Some((70, 2, 18_000)));
|
||||||
|
|
||||||
|
assert_eq!(slot.version.compare_exchange(2, 3, Ordering::AcqRel, Ordering::Relaxed), Ok(2));
|
||||||
|
slot.unix_sec.store(71, Ordering::Relaxed);
|
||||||
|
slot.count.store(1, Ordering::Relaxed);
|
||||||
|
slot.acc_time.store(11_000, Ordering::Relaxed);
|
||||||
|
assert_eq!(slot.snapshot(), None);
|
||||||
|
|
||||||
|
slot.version.store(4, Ordering::Release);
|
||||||
|
assert_eq!(slot.snapshot(), Some((71, 1, 11_000)));
|
||||||
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn disk_health_metrics_snapshot_exports_waiting_errors_and_operation_windows() {
|
fn disk_health_metrics_snapshot_exports_waiting_errors_and_operation_windows() {
|
||||||
let metrics = DiskHealthMetricEpoch::default();
|
let metrics = DiskHealthMetricEpoch::default();
|
||||||
|
|||||||
Reference in New Issue
Block a user