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

kata-types: validate KataVirtualVolume object

Browse Source 
Implement method validate() for KataVirtualVolume to validate message
format.

Signed-off-by: Jiang Liu <gerry@linux.alibaba.com>
This commit is contained in:
Jiang Liu
2023-08-20 16:54:31 +08:00
parent fa2fdc1057
commit b875e39323
1 changed files with 82 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

82
src/libs/kata-types/src/mount.rs
View File

@@ -258,6 +258,88 @@ impl KataVirtualVolume {
..Default::default()
}
}
/// Validate virtual volume object.
pub fn validate(&self) -> Result<()> {
match self.volume_type.as_str() {
KATA_VIRTUAL_VOLUME_DIRECT_BLOCK => {
if self.source.is_empty() {
return Err(anyhow!(
"missing source device for directly assigned block volume"
));
} else if self.fs_type.is_empty() {
return Err(anyhow!(
"missing filesystem for directly assigned block volume"
));
}
}
KATA_VIRTUAL_VOLUME_IMAGE_RAW_BLOCK | KATA_VIRTUAL_VOLUME_LAYER_RAW_BLOCK => {
if self.source.is_empty() {
return Err(anyhow!("missing source device for raw block volume"));
} else if self.fs_type.is_empty() {
return Err(anyhow!("missing filesystem for raw block volume"));
}
}
KATA_VIRTUAL_VOLUME_IMAGE_NYDUS_BLOCK | KATA_VIRTUAL_VOLUME_LAYER_NYDUS_BLOCK => {
if self.source.is_empty() {
return Err(anyhow!("missing meta blob for nydus block volume"));
} else if self.fs_type.as_str() != "rafsv6" {
return Err(anyhow!("invalid filesystem for nydus block volume"));
}
match self.nydus_image.as_ref() {
None => {
return Err(anyhow!(
"missing nydus configuration info for nydus block volume"
))
}
Some(nydus) => {
if nydus.config.is_empty() {
return Err(anyhow!(
"missing configuration info for nydus block volume"
));
} else if nydus.snapshot_dir.is_empty() {
return Err(anyhow!(
"missing snapshot directory for nydus block volume"
));
}
}
}
}
KATA_VIRTUAL_VOLUME_IMAGE_NYDUS_FS | KATA_VIRTUAL_VOLUME_LAYER_NYDUS_FS => {
if self.source.is_empty() {
return Err(anyhow!("missing meta blob for nydus fs volume"));
} else if self.fs_type.as_str() != "rafsv6" && self.fs_type.as_str() != "rafsv5" {
return Err(anyhow!("invalid filesystem for nydus fs volume"));
}
match self.nydus_image.as_ref() {
None => {
return Err(anyhow!(
"missing nydus configuration info for nydus block volume"
))
}
Some(nydus) => {
if nydus.config.is_empty() {
return Err(anyhow!(
"missing configuration info for nydus block volume"
));
} else if nydus.snapshot_dir.is_empty() {
return Err(anyhow!(
"missing snapshot directory for nydus block volume"
));
}
}
}
}
KATA_VIRTUAL_VOLUME_IMAGE_GUEST_PULL => {
if self.source.is_empty() {
return Err(anyhow!("missing image reference for guest pulling volume"));
}
}
_ => {}
}
Ok(())
}
}
impl TryFrom<&DirectVolumeMountInfo> for KataVirtualVolume {