github/kata-containers
1
0
Fork 2
mirror of https://github.com/kata-containers/kata-containers.git synced 2025-10-22 20:39:41 +00:00
Code Issues Projects Releases Wiki Activity

runtime-rs: ad the block device hot unplug for clh

Browse Source 
Since runtime-rs support the block device hotplug with
creating new containers, and the device would also be
removed when the container stopped, thus add the block
device unplug for clh.

Signed-off-by: Fupan Li <fupan.lfp@antgroup.com>
This commit is contained in:
Fupan Li
2025-09-29 10:23:54 +08:00
committed by Fupan Li
parent afbec780a9
commit 4002a91452
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/runtime-rs/crates/hypervisor/src/ch/inner_device.rs
View File

@@ -108,7 +108,10 @@ impl CloudHypervisorInner {
pub(crate) async fn remove_device(&mut self, device: DeviceType) -> Result<()> { pub(crate) async fn remove_device(&mut self, device: DeviceType) -> Result<()> {
match device { match device {
DeviceType::Vfio(vfiodev) => self.remove_vfio_device(&vfiodev).await, DeviceType::Vfio(vfiodev) => self.inner_remove_device(vfiodev.device_id.as_str()).await,
DeviceType::Block(blockdev) => {
self.inner_remove_device(blockdev.device_id.as_str()).await
}
_ => Ok(()), _ => Ok(()),
} }
} }
@@ -226,8 +229,8 @@ impl CloudHypervisorInner {
Ok(DeviceType::Vfio(vfio_device)) Ok(DeviceType::Vfio(vfio_device))
} }
async fn remove_vfio_device(&mut self, device: &VfioDevice) -> Result<()> { async fn inner_remove_device(&mut self, device_id: &str) -> Result<()> {
let clh_device_id = self.device_ids.get(&device.device_id); let clh_device_id = self.device_ids.get(device_id);
if clh_device_id.is_none() { if clh_device_id.is_none() {
return Err(anyhow!( return Err(anyhow!(
@@ -253,7 +256,7 @@ impl CloudHypervisorInner {
.await?; .await?;
if let Some(detail) = response { if let Some(detail) = response {
debug!(sl!(), "vfio remove response: {:?}", detail); debug!(sl!(), "device remove response: {:?}", detail);
} }
Ok(()) Ok(())