github/kata-containers
1
0
Fork 1
mirror of https://github.com/kata-containers/kata-containers.git synced 2025-08-15 06:34:03 +00:00
Code Issues Projects Releases Wiki Activity

runtime-rs: support hotplugging memory in Qmp

Browse Source 
The algorithm is rather simple - we query qemu for existing memory devices
to figure out the index of the one we're about to add.  Then we add a
backend object and a corresponding frontend device.

Signed-off-by: Pavel Mores <pmores@redhat.com>
This commit is contained in:
Pavel Mores 2024-07-04 16:09:55 +02:00 committed by Pavel Mores
parent 0e0b146b87
commit 4a1c828bf8
1 changed files with 57 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
src/runtime-rs/crates/hypervisor/src/qemu/qmp.rs
View File

@ -10,6 +10,7 @@ use std::os::unix::net::UnixStream;
use std::time::Duration;
use qapi::qmp;
use qapi_qmp;
use qapi_spec::Dictionary;
pub struct Qmp {
@ -149,6 +150,62 @@ impl Qmp {
pub fn guest_memory_block_size(&self) -> u64 {
self.guest_memory_block_size
}
#[allow(dead_code)]
pub fn hotplug_memory(&mut self, size: u64) -> Result<()> {
let memdev_idx = self
.qmp
.execute(&qapi_qmp::query_memory_devices {})?
.into_iter()
.filter(|memdev| {
if let qapi_qmp::MemoryDeviceInfo::dimm(dimm_info) = memdev {
return dimm_info.data.hotpluggable && dimm_info.data.hotplugged;
}
false
})
.count();
let memory_backend_id = format!("hotplugged-{}", memdev_idx);
let memory_backend = qmp::object_add(qapi_qmp::ObjectOptions::memory_backend_file {
id: memory_backend_id.clone(),
memory_backend_file: qapi_qmp::MemoryBackendFileProperties {
base: qapi_qmp::MemoryBackendProperties {
dump: None,
host_nodes: None,
merge: None,
policy: None,
prealloc: None,
prealloc_context: None,
prealloc_threads: None,
reserve: None,
share: Some(true),
x_use_canonical_path_for_ramblock_id: None,
size,
},
align: None,
discard_data: None,
offset: None,
pmem: None,
readonly: None,
mem_path: "/dev/shm".to_owned(),
},
});
self.qmp.execute(&memory_backend)?;
let memory_frontend_id = format!("frontend-to-{}", memory_backend_id);
let mut mem_frontend_args = Dictionary::new();
mem_frontend_args.insert("memdev".to_owned(), memory_backend_id.into());
self.qmp.execute(&qmp::device_add {
bus: None,
id: Some(memory_frontend_id),
driver: "pc-dimm".to_owned(),
arguments: mem_frontend_args,
})?;
Ok(())
}
}
fn vcpu_id_from_core_id(core_id: i64) -> String {