devices/virtio/block/sys/
linux.rs1use std::cmp::max;
6use std::cmp::min;
7
8use anyhow::Context;
9use base::unix::iov_max;
10use cros_async::Executor;
11use disk::DiskFile;
12
13use crate::virtio::block::DiskOption;
14use crate::virtio::BlockAsync;
15
16pub fn get_seg_max(queue_size: u16) -> u32 {
17 let seg_max = min(max(iov_max(), 1), u32::MAX as usize) as u32;
18
19 min(seg_max, u32::from(queue_size) - 2)
23}
24
25impl DiskOption {
26 pub fn open(&self) -> anyhow::Result<Box<dyn DiskFile>> {
28 disk::open_disk_file(disk::DiskFileParams {
29 path: self.path.clone(),
30 is_read_only: self.read_only,
31 is_sparse_file: self.sparse,
32 is_direct: self.direct,
33 lock: self.lock,
34 ..Default::default()
35 })
36 .context("open_disk_file failed")
37 }
38}
39
40impl BlockAsync {
41 pub fn create_executor(&self) -> Executor {
42 Executor::with_executor_kind(self.executor_kind).expect("Failed to create an executor")
43 }
44}