diff --git a/performance-metrics/src/main.rs b/performance-metrics/src/main.rs index 2e42cc03c..5192a4406 100644 --- a/performance-metrics/src/main.rs +++ b/performance-metrics/src/main.rs @@ -378,7 +378,7 @@ mod adjuster { } } -const TEST_LIST: [PerformanceTest; 98] = [ +const TEST_LIST: [PerformanceTest; 100] = [ PerformanceTest { name: "boot_time_ms", func_ptr: performance_boot_time, @@ -1685,6 +1685,30 @@ const TEST_LIST: [PerformanceTest; 98] = [ }, unit_adjuster: adjuster::s_to_us, }, + PerformanceTest { + name: "micro_block_qcow_batch_write_128_us", + func_ptr: micro_bench_block::micro_bench_qcow_batch_write, + control: PerformanceTestControl { + test_timeout: 10, + test_iterations: 20, + warmup_iterations: 5, + num_ops: Some(128), + ..PerformanceTestControl::default() + }, + unit_adjuster: adjuster::s_to_us, + }, + PerformanceTest { + name: "micro_block_qcow_batch_write_256_us", + func_ptr: micro_bench_block::micro_bench_qcow_batch_write, + control: PerformanceTestControl { + test_timeout: 10, + test_iterations: 20, + warmup_iterations: 5, + num_ops: Some(256), + ..PerformanceTestControl::default() + }, + unit_adjuster: adjuster::s_to_us, + }, ]; fn run_test_with_timeout( diff --git a/performance-metrics/src/micro_bench_block.rs b/performance-metrics/src/micro_bench_block.rs index f545facda..aab20308c 100644 --- a/performance-metrics/src/micro_bench_block.rs +++ b/performance-metrics/src/micro_bench_block.rs @@ -549,3 +549,45 @@ pub fn micro_bench_qcow_async_l2_cache_miss(control: &PerformanceTestControl) -> drain_async_completions(async_io.as_mut(), num_ops); start.elapsed().as_secs_f64() } + +/// Measure QCOW2 batch write submission via io_uring. +/// +/// Builds a batch of num_ops write requests and submits them all at once +/// through submit_batch_requests. Writes in QcowAsync are synchronous +/// (COW path), so this measures whether batching reduces per-request +/// overhead compared to individual write_vectored calls. +/// +/// Returns the total wall clock time in seconds. +pub fn micro_bench_qcow_batch_write(control: &PerformanceTestControl) -> f64 { + let num_ops = control.num_ops.expect("num_ops required") as usize; + let (_tmp, disk) = util::empty_qcow_async_tempfile(num_ops); + let mut async_io = disk + .new_async_io(num_ops as u32) + .expect("new_async_io failed"); + + let buf = vec![0xA5u8; num_ops * QCOW_CLUSTER_SIZE as usize]; + + let batch: Vec = (0..num_ops) + .map(|i| { + let slice = &buf[i * QCOW_CLUSTER_SIZE as usize..(i + 1) * QCOW_CLUSTER_SIZE as usize]; + BatchRequest { + offset: (i as u64 * QCOW_CLUSTER_SIZE) as libc::off_t, + iovecs: vec![libc::iovec { + iov_base: slice.as_ptr() as *mut libc::c_void, + iov_len: QCOW_CLUSTER_SIZE as usize, + }] + .into(), + user_data: i as u64, + request_type: RequestType::Out, + } + }) + .collect(); + + let start = Instant::now(); + async_io + .submit_batch_requests(&batch) + .expect("submit_batch_requests failed"); + + drain_async_completions(async_io.as_mut(), num_ops); + start.elapsed().as_secs_f64() +}