test(irtt-stats): rename internal date-time helper and update test case name
Rename system_time_ns to unix_time_ns_after_epoch for better clarity on output behavior and update a continuous mode test case name to more accurately reflect its purpose.
This commit is contained in:
2 files changed
+4
-4
No files matched your search
@@ -54,9 +54,9 @@ pub fn reply(seq: u32, raw_ms: u64, effective_ms: i128) -> ClientEvent {
|
|||||||
received_at,
|
received_at,
|
||||||
rtt: rtt(raw_ms, effective_ms),
|
rtt: rtt(raw_ms, effective_ms),
|
||||||
server_timing: Some(ServerTiming {
|
server_timing: Some(ServerTiming {
|
||||||
receive_wall_ns: Some(system_time_ns(sent_at.wall) as i64 + 1_000_000),
|
receive_wall_ns: Some(unix_time_ns_after_epoch(sent_at.wall) as i64 + 1_000_000),
|
||||||
receive_mono_ns: Some(seq as i64 * 10_000_000 + 1_000_000),
|
receive_mono_ns: Some(seq as i64 * 10_000_000 + 1_000_000),
|
||||||
send_wall_ns: Some(system_time_ns(sent_at.wall) as i64 + 2_000_000),
|
send_wall_ns: Some(unix_time_ns_after_epoch(sent_at.wall) as i64 + 2_000_000),
|
||||||
send_mono_ns: Some(seq as i64 * 10_000_000 + 2_000_000),
|
send_mono_ns: Some(seq as i64 * 10_000_000 + 2_000_000),
|
||||||
midpoint_wall_ns: None,
|
midpoint_wall_ns: None,
|
||||||
midpoint_mono_ns: None,
|
midpoint_mono_ns: None,
|
||||||
@@ -107,7 +107,7 @@ pub fn late_reply(seq: u32, raw_ms: u64, effective_ms: i128) -> ClientEvent {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn system_time_ns(time: std::time::SystemTime) -> i128 {
|
fn unix_time_ns_after_epoch(time: std::time::SystemTime) -> i128 {
|
||||||
time.duration_since(UNIX_EPOCH)
|
time.duration_since(UNIX_EPOCH)
|
||||||
.map(|duration| duration.as_nanos() as i128)
|
.map(|duration| duration.as_nanos() as i128)
|
||||||
.unwrap()
|
.unwrap()
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ fn disabled_median_avoids_finite_retention() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
#[test]
|
#[test]
|
||||||
fn continuous_mode_bounds_sequence_tracking() {
|
fn continuous_mode_tracks_samples_without_exact_medians() {
|
||||||
let mut collector = StatsCollector::new(StatsConfig::continuous());
|
let mut collector = StatsCollector::new(StatsConfig::continuous());
|
||||||
for seq in 0..4104 {
|
for seq in 0..4104 {
|
||||||
collector.process(&reply(seq, 10, 10));
|
collector.process(&reply(seq, 10, 10));
|
||||||
|
|||||||
Reference in new issue
Block a user