trending/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-10-02 05:14:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

test(connect): expose typed drive measurement failure context (#8099)

Browse Source 
Co-authored-by: Hauser <housemecn@gmail.com>
This commit is contained in:
Chris
2026-09-27 05:11:47 +08:00
committed by GitHub
co-authored by Hauser
parent cf096b3c22
commit 2c5c43b0e0
1 changed files with 22 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
rustfs/tests/connect_perf_drive.rs
+22 -1
View File
@@ -85,7 +85,17 @@ async fn real_local_write_read_is_measured_and_scratch_is_removed() {
.await
.expect("real drive benchmark");
assert_eq!(measurement.result.outcome(), DriveOutcome::Succeeded);
assert_eq!(
measurement.result.outcome(),
DriveOutcome::Succeeded,
"drive measurement: result_reason={:?}, target_reason={:?}, duration_millis={}, read_bytes={}, write_bytes={}, io_count={}",
measurement.result.reason_code(),
measurement.target.reason_code,
measurement.target.duration_millis,
measurement.target.read_bytes,
measurement.target.write_bytes,
measurement.target.io_count,
);
assert_eq!(measurement.result.reason_code(), DriveReasonCode::Complete);
let data = measurement.result.data().expect("aggregate data");
assert_eq!(data.read_bytes, 32_768);
@@ -335,6 +345,17 @@ async fn successful_result_has_signed_bounded_private_offline_export() {
let measurement = measure_drive(&request, &CancellationToken::new())
.await
.expect("drive measurement");
assert_eq!(
measurement.result.outcome(),
DriveOutcome::Succeeded,
"drive measurement before signed export: result_reason={:?}, target_reason={:?}, duration_millis={}, read_bytes={}, write_bytes={}, io_count={}",
measurement.result.reason_code(),
measurement.target.reason_code,
measurement.target.duration_millis,
measurement.target.read_bytes,
measurement.target.write_bytes,
measurement.target.io_count,
);
let identity = connect::DeviceIdentity::generate();
let export = sign_drive_export(&request, &measurement, &identity, &CancellationToken::new()).expect("signed export");
assert!(export.result_json.len() <= perf_drive::MAX_RESULT_BYTES);