github/kata-containers
1
0
Fork 2
mirror of https://github.com/kata-containers/kata-containers.git synced 2025-09-17 23:07:55 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #10683 from justxuewei/nxw/remove-mut

Browse Source
This commit is contained in:
Xuewei Niu
2024-12-29 00:49:38 +08:00
committed by GitHub
parent 2068801b80 ecf98e4db8
commit 6400295940
8 changed files with 13 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/runtime-rs/crates/hypervisor/src/ch/mod.rs
View File

@@ -46,7 +46,7 @@ impl CloudHypervisor {
}
}
pub async fn set_hypervisor_config(&mut self, config: HypervisorConfig) {
pub async fn set_hypervisor_config(&self, config: HypervisorConfig) {
let mut inner = self.inner.write().await;
inner.set_hypervisor_config(config)
}

2
src/runtime-rs/crates/hypervisor/src/device/device_manager.rs
View File

@@ -629,7 +629,7 @@ mod tests {
.get(hypervisor_name)
.ok_or_else(|| anyhow!("failed to get hypervisor for {}", &hypervisor_name))?;
let mut hypervisor = Qemu::new();
let hypervisor = Qemu::new();
hypervisor
.set_hypervisor_config(hypervisor_config.clone())
.await;

4
src/runtime-rs/crates/hypervisor/src/dragonball/mod.rs
View File

@@ -56,12 +56,12 @@ impl Dragonball {
}
}
pub async fn set_hypervisor_config(&mut self, config: HypervisorConfig) {
pub async fn set_hypervisor_config(&self, config: HypervisorConfig) {
let mut inner = self.inner.write().await;
inner.set_hypervisor_config(config)
}
pub async fn set_passfd_listener_port(&mut self, port: u32) {
pub async fn set_passfd_listener_port(&self, port: u32) {
let mut inner = self.inner.write().await;
inner.set_passfd_listener_port(port)
}

2
src/runtime-rs/crates/hypervisor/src/firecracker/mod.rs
View File

@@ -51,7 +51,7 @@ impl Firecracker {
}
}
pub async fn set_hypervisor_config(&mut self, config: HypervisorConfig) {
pub async fn set_hypervisor_config(&self, config: HypervisorConfig) {
let mut inner = self.inner.write().await;
inner.set_hypervisor_config(config)
}

2
src/runtime-rs/crates/hypervisor/src/qemu/mod.rs
View File

@@ -45,7 +45,7 @@ impl Qemu {
}
}
pub async fn set_hypervisor_config(&mut self, config: HypervisorConfig) {
pub async fn set_hypervisor_config(&self, config: HypervisorConfig) {
let mut inner = self.inner.write().await;
inner.set_hypervisor_config(config)
}

2
src/runtime-rs/crates/hypervisor/src/remote/mod.rs
View File

@@ -35,7 +35,7 @@ impl Remote {
}
}
pub async fn set_hypervisor_config(&mut self, config: HypervisorConfig) {
pub async fn set_hypervisor_config(&self, config: HypervisorConfig) {
let mut inner = self.inner.write().await;
inner.set_hypervisor_config(config)
}

2
src/runtime-rs/crates/resource/src/network/endpoint/endpoints_test.rs
View File

@@ -36,7 +36,7 @@ mod tests {
.get(hypervisor_name)
.ok_or_else(|| anyhow!("failed to get hypervisor for {}", &hypervisor_name))?;
let mut hypervisor = Qemu::new();
let hypervisor = Qemu::new();
hypervisor
.set_hypervisor_config(hypervisor_config.clone())
.await;

12
src/runtime-rs/crates/runtimes/virt_container/src/lib.rs
View File

@@ -158,7 +158,7 @@ async fn new_hypervisor(toml_config: &TomlConfig) -> Result<Arc<dyn Hypervisor>>
match hypervisor_name.as_str() {
#[cfg(all(feature = "dragonball", not(target_arch = "s390x")))]
HYPERVISOR_DRAGONBALL => {
let mut hypervisor = Dragonball::new();
let hypervisor = Dragonball::new();
hypervisor
.set_hypervisor_config(hypervisor_config.clone())
.await;
@@ -170,7 +170,7 @@ async fn new_hypervisor(toml_config: &TomlConfig) -> Result<Arc<dyn Hypervisor>>
Ok(Arc::new(hypervisor))
}
HYPERVISOR_QEMU => {
let mut hypervisor = Qemu::new();
let hypervisor = Qemu::new();
hypervisor
.set_hypervisor_config(hypervisor_config.clone())
.await;
@@ -178,7 +178,7 @@ async fn new_hypervisor(toml_config: &TomlConfig) -> Result<Arc<dyn Hypervisor>>
}
#[cfg(not(target_arch = "s390x"))]
HYPERVISOR_FIRECRACKER => {
let mut hypervisor = Firecracker::new();
let hypervisor = Firecracker::new();
hypervisor
.set_hypervisor_config(hypervisor_config.clone())
.await;
@@ -186,16 +186,14 @@ async fn new_hypervisor(toml_config: &TomlConfig) -> Result<Arc<dyn Hypervisor>>
}
#[cfg(all(feature = "cloud-hypervisor", not(target_arch = "s390x")))]
HYPERVISOR_NAME_CH => {
let mut hypervisor = CloudHypervisor::new();
let hypervisor = CloudHypervisor::new();
hypervisor
.set_hypervisor_config(hypervisor_config.clone())
.await;
Ok(Arc::new(hypervisor))
}
HYPERVISOR_REMOTE => {
let mut hypervisor = Remote::new();
let hypervisor = Remote::new();
hypervisor
.set_hypervisor_config(hypervisor_config.clone())
.await;