mirror of
https://github.com/kata-containers/kata-containers.git
synced 2025-09-25 02:40:04 +00:00
Merge pull request #7821 from jiangliu/storage-leak
agent: avoid possible leakage of storage device
This commit is contained in:
@@ -71,6 +71,10 @@ impl StorageState {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub fn path(&self) -> &str {
|
||||||
|
self.device.path()
|
||||||
|
}
|
||||||
|
|
||||||
pub async fn ref_count(&self) -> u32 {
|
pub async fn ref_count(&self) -> u32 {
|
||||||
self.count.load(Ordering::Relaxed)
|
self.count.load(Ordering::Relaxed)
|
||||||
}
|
}
|
||||||
|
@@ -103,6 +103,10 @@ pub async fn add_storages(
|
|||||||
let path = storage.mount_point.clone();
|
let path = storage.mount_point.clone();
|
||||||
let state = sandbox.lock().await.add_sandbox_storage(&path).await;
|
let state = sandbox.lock().await.add_sandbox_storage(&path).await;
|
||||||
if state.ref_count().await > 1 {
|
if state.ref_count().await > 1 {
|
||||||
|
let path = state.path();
|
||||||
|
if !path.is_empty() {
|
||||||
|
mount_list.push(path.to_string());
|
||||||
|
}
|
||||||
// The device already exists.
|
// The device already exists.
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user