This commit is contained in:
Floris Bruynooghe
2025-06-27 13:07:22 +02:00
parent a25872eab8
commit 5ca6498ffe
3 changed files with 5 additions and 6 deletions
+1 -1
View File
@@ -271,7 +271,7 @@ fn multipath_cid_rotation() {
let each_round: u64 = MAX_PATHS as u64 * CidQueue::LEN as u64;
// The final round only pushes one set of CIDs with expires_before, the round is not run
// to completion to wait for the expiry messages from the client.
let final_round: u64 = MAX_PATHS as u64 * 1;
let final_round: u64 = MAX_PATHS as u64;
let path_new_cids = initial_batch + (round - 2) * each_round + final_round;
debug_assert_eq!(path_new_cids, 73);
assert_eq!(stats.frame_tx.path_new_connection_id, path_new_cids);
+3 -3
View File
@@ -176,7 +176,7 @@ mod tests {
if rng.random_bool(0.666) {
// store
let token = Bytes::from(vec![i]);
println!("STORE {} {:?}", server_name, token);
println!("STORE {server_name} {token:?}");
if let Some((j, _)) = cache_1
.iter()
.enumerate()
@@ -199,7 +199,7 @@ mod tests {
cache_2.insert(&server_name.to_string(), token);
} else {
// take
println!("TAKE {}", server_name);
println!("TAKE {server_name}");
let expecting = cache_1
.iter()
.enumerate()
@@ -213,7 +213,7 @@ mod tests {
}
token
});
println!("EXPECTING {:?}", expecting);
println!("EXPECTING {expecting:?}");
assert_eq!(cache_2.take(&server_name.to_string()), expecting);
}
}
+1 -2
View File
@@ -47,8 +47,7 @@ pub fn criterion_benchmark(c: &mut Criterion) {
for (gso_enabled, gro_enabled, recvmmsg_enabled) in permutations {
let mut group = c.benchmark_group(format!(
"gso_{}_gro_{}_recvmmsg_{}",
gso_enabled, gro_enabled, recvmmsg_enabled
"gso_{gso_enabled}_gro_{gro_enabled}_recvmmsg_{recvmmsg_enabled}"
));
group.throughput(criterion::Throughput::Bytes(TOTAL_BYTES as u64));