kata-containers/cloud-hypervisor
1
0
Fork 0
mirror of https://github.com/cloud-hypervisor/cloud-hypervisor.git synced 2026-08-05 02:19:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

block: raw_async_aio: Use query_device_size() for size queries

Browse Source 
Use query_device_size() instead of seek(End(0)) and metadata().len()
to correctly handle block device and regular file handles.

Signed-off-by: Anatol Belski <anbelski@linux.microsoft.com>
This commit is contained in:
Anatol Belski
2026-03-25 23:21:36 +01:00
committed by Rob Bradford
parent 290f57a6e3
commit 1b92af5534
1 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
block/src/raw_async_aio.rs
+7 -9
View File
@@ -7,7 +7,6 @@
use std::collections::VecDeque; use std::collections::VecDeque;
use std::fs::File; use std::fs::File;
use std::io::{Seek, SeekFrom};
use std::os::unix::io::{AsRawFd, RawFd}; use std::os::unix::io::{AsRawFd, RawFd};
use libc::{FALLOC_FL_KEEP_SIZE, FALLOC_FL_PUNCH_HOLE, FALLOC_FL_ZERO_RANGE}; use libc::{FALLOC_FL_KEEP_SIZE, FALLOC_FL_PUNCH_HOLE, FALLOC_FL_ZERO_RANGE};
@@ -18,7 +17,7 @@ use vmm_sys_util::eventfd::EventFd;
use crate::async_io::{ use crate::async_io::{
AsyncIo, AsyncIoError, AsyncIoResult, BorrowedDiskFd, DiskFile, DiskFileError, DiskFileResult, AsyncIo, AsyncIoError, AsyncIoResult, BorrowedDiskFd, DiskFile, DiskFileError, DiskFileResult,
}; };
use crate::{DiskTopology, SECTOR_SIZE, probe_sparse_support}; use crate::{DiskTopology, SECTOR_SIZE, probe_sparse_support, query_device_size};
pub struct RawFileDiskAio { pub struct RawFileDiskAio {
file: File, file: File,
@@ -32,16 +31,15 @@ impl RawFileDiskAio {
impl DiskFile for RawFileDiskAio { impl DiskFile for RawFileDiskAio {
fn logical_size(&mut self) -> DiskFileResult<u64> { fn logical_size(&mut self) -> DiskFileResult<u64> {
self.file Ok(query_device_size(&self.file)
.seek(SeekFrom::End(0)) .map_err(DiskFileError::Size)?
.map_err(DiskFileError::Size) .0)
} }
fn physical_size(&mut self) -> DiskFileResult<u64> { fn physical_size(&mut self) -> DiskFileResult<u64> {
self.file Ok(query_device_size(&self.file)
.metadata() .map_err(DiskFileError::Size)?
.map(|m| m.len()) .1)
.map_err(DiskFileError::Size)
} }
fn new_async_io(&self, ring_depth: u32) -> DiskFileResult<Box<dyn AsyncIo>> { fn new_async_io(&self, ring_depth: u32) -> DiskFileResult<Box<dyn AsyncIo>> {