diff --git a/src/runtime-rs/config/configuration-clh-runtime-rs.toml.in b/src/runtime-rs/config/configuration-clh-runtime-rs.toml.in index 49fbd1bb71..928130ea37 100644 --- a/src/runtime-rs/config/configuration-clh-runtime-rs.toml.in +++ b/src/runtime-rs/config/configuration-clh-runtime-rs.toml.in @@ -97,6 +97,9 @@ virtio_fs_daemon = "@DEFVIRTIOFSDAEMON@" # Default size of DAX cache in MiB virtio_fs_cache_size = @DEFVIRTIOFSCACHESIZE@ +# Default size of virtqueues +virtio_fs_queue_size = @DEFVIRTIOFSQUEUESIZE@ + # Extra args for virtiofsd daemon # # Format example: diff --git a/src/runtime-rs/crates/hypervisor/src/ch/inner_device.rs b/src/runtime-rs/crates/hypervisor/src/ch/inner_device.rs index c0c621d886..2337d50ebe 100644 --- a/src/runtime-rs/crates/hypervisor/src/ch/inner_device.rs +++ b/src/runtime-rs/crates/hypervisor/src/ch/inner_device.rs @@ -45,9 +45,6 @@ use std::path::PathBuf; const VIRTIO_FS: &str = "virtio-fs"; -pub const DEFAULT_FS_QUEUES: usize = 1; -const DEFAULT_FS_QUEUE_SIZE: u16 = 1024; - impl CloudHypervisorInner { pub(crate) async fn add_device(&mut self, device: DeviceType) -> Result { if self.state != VmmState::VmRunning { @@ -143,17 +140,8 @@ impl CloudHypervisorInner { )); } - let num_queues: usize = if device.config.queue_num > 0 { - device.config.queue_num as usize - } else { - DEFAULT_FS_QUEUES - }; - - let queue_size: u16 = if device.config.queue_num > 0 { - u16::try_from(device.config.queue_size)? - } else { - DEFAULT_FS_QUEUE_SIZE - }; + let num_queues = device.config.queue_num as usize; + let queue_size = u16::try_from(device.config.queue_size)?; let socket_path = if device.config.sock_path.starts_with('/') { PathBuf::from(device.config.sock_path) @@ -545,17 +533,8 @@ impl TryFrom for FsConfig { let cfg = settings.cfg; let vm_path = settings.vm_path; - let num_queues: usize = if cfg.queue_num > 0 { - cfg.queue_num as usize - } else { - DEFAULT_FS_QUEUES - }; - - let queue_size: u16 = if cfg.queue_num > 0 { - u16::try_from(cfg.queue_size)? - } else { - DEFAULT_FS_QUEUE_SIZE - }; + let num_queues = cfg.queue_num as usize; + let queue_size = u16::try_from(cfg.queue_size)?; let socket_path = if cfg.sock_path.starts_with('/') { PathBuf::from(cfg.sock_path)