From 45fd51652fcafd77f75aadbc7e1d55e80dd876a5 Mon Sep 17 00:00:00 2001 From: Anatol Belski Date: Fri, 24 Apr 2026 17:42:58 +0200 Subject: [PATCH] block: raw: Rename RawFileAsyncAio to RawAio Apply the consistent naming convention. No functional change. Signed-off-by: Anatol Belski --- block/src/raw_async_aio.rs | 14 +++++++------- block/src/raw_disk.rs | 7 ++----- 2 files changed, 9 insertions(+), 12 deletions(-) diff --git a/block/src/raw_async_aio.rs b/block/src/raw_async_aio.rs index a1c9e1439..ce1877fb6 100644 --- a/block/src/raw_async_aio.rs +++ b/block/src/raw_async_aio.rs @@ -18,20 +18,20 @@ use crate::error::{BlockError, BlockErrorKind, BlockResult}; use crate::sparse::{punch_hole, write_zeroes}; use crate::{SECTOR_SIZE, is_block_device}; -pub struct RawFileAsyncAio { +pub struct RawAio { fd: RawFd, data_io: AioDataIo, alignment: u64, is_block_device: bool, } -impl RawFileAsyncAio { +impl RawAio { pub fn new(fd: RawFd, queue_depth: u32) -> BlockResult { let data_io = AioDataIo::new(queue_depth).map_err(|e| BlockError::new(BlockErrorKind::Io, e))?; let is_block_device = is_block_device(fd); - Ok(RawFileAsyncAio { + Ok(RawAio { fd, data_io, alignment: SECTOR_SIZE, @@ -40,7 +40,7 @@ impl RawFileAsyncAio { } } -impl AsyncIo for RawFileAsyncAio { +impl AsyncIo for RawAio { fn notifier(&self) -> &EventFd { self.data_io.notifier() } @@ -113,7 +113,7 @@ mod unit_tests { fn test_punch_hole() { let temp_file = TempFile::new().unwrap(); let mut file = temp_file.into_file(); - let mut async_io = RawFileAsyncAio::new(file.as_raw_fd(), 128).unwrap(); + let mut async_io = RawAio::new(file.as_raw_fd(), 128).unwrap(); raw_async_io_tests::test_punch_hole(&mut async_io, &mut file); } @@ -121,7 +121,7 @@ mod unit_tests { fn test_write_zeroes() { let temp_file = TempFile::new().unwrap(); let mut file = temp_file.into_file(); - let mut async_io = RawFileAsyncAio::new(file.as_raw_fd(), 128).unwrap(); + let mut async_io = RawAio::new(file.as_raw_fd(), 128).unwrap(); raw_async_io_tests::test_write_zeroes(&mut async_io, &mut file); } @@ -129,7 +129,7 @@ mod unit_tests { fn test_punch_hole_multiple_operations() { let temp_file = TempFile::new().unwrap(); let mut file = temp_file.into_file(); - let mut async_io = RawFileAsyncAio::new(file.as_raw_fd(), 128).unwrap(); + let mut async_io = RawAio::new(file.as_raw_fd(), 128).unwrap(); raw_async_io_tests::test_punch_hole_multiple_operations(&mut async_io, &mut file); } } diff --git a/block/src/raw_disk.rs b/block/src/raw_disk.rs index 4b5d294bc..703b68a5c 100644 --- a/block/src/raw_disk.rs +++ b/block/src/raw_disk.rs @@ -13,7 +13,7 @@ use crate::async_io::{AsyncIo, BorrowedDiskFd, DiskFileError}; use crate::error::{BlockError, BlockErrorKind, BlockResult}; #[cfg(feature = "io_uring")] use crate::raw_async::RawAsync; -use crate::raw_async_aio::RawFileAsyncAio; +use crate::raw_async_aio::RawAio; use crate::raw_sync::RawSync; use crate::{DiskTopology, disk_file, probe_sparse_support, query_device_size}; @@ -132,10 +132,7 @@ impl disk_file::AsyncDiskFile for RawDisk { RawBackend::Sync => Ok(Box::new(RawSync::new(self.file.as_raw_fd()))), #[cfg(feature = "io_uring")] RawBackend::IoUring => Ok(Box::new(RawAsync::new(self.file.as_raw_fd(), ring_depth)?)), - RawBackend::Aio => Ok(Box::new(RawFileAsyncAio::new( - self.file.as_raw_fd(), - ring_depth, - )?)), + RawBackend::Aio => Ok(Box::new(RawAio::new(self.file.as_raw_fd(), ring_depth)?)), } } }