kata-containers/cloud-hypervisor
1
0
Fork 0
mirror of https://github.com/cloud-hypervisor/cloud-hypervisor.git synced 2026-08-05 02:19:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

virtio-devices: console: Handle output queue errors gracefully

Browse Source 
Address translation, guest memory read, write, and flush failures on
the transmitq propagated errors that killed the console device thread.
A host-side I/O error such as a PTY disconnect would permanently
disable the console. Log warnings and continue processing instead.

Signed-off-by: Rob Bradford <rbradford@meta.com>
Assisted-by: Claude:claude-opus-4-6
This commit is contained in:
Rob Bradford
2026-05-06 15:09:26 +01:00
parent 4725a997cc
commit 56c18b51cc
1 changed files with 26 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
virtio-devices/src/console.rs
View File

@@ -51,12 +51,6 @@ const VIRTIO_CONSOLE_F_SIZE: u64 = 0;
#[derive(Error, Debug)]
enum Error {
#[error("Failed to read from guest memory")]
GuestMemoryRead(#[source] vm_memory::guest_memory::Error),
#[error("Failed to write_all output")]
OutputWriteAll(#[source] io::Error),
#[error("Failed to flush output")]
OutputFlush(#[source] io::Error),
#[error("Failed to add used index")]
QueueAddUsed(#[source] virtio_queue::Error),
}
@@ -266,21 +260,28 @@ impl ConsoleEpollHandler {
continue;
}
if let Some(out) = &mut self.out {
let addr = match desc
.addr()
.translate_gva(self.access_platform.as_deref(), desc.len() as usize)
{
Ok(a) => a,
Err(e) => {
warn!("Failed to translate transmitq descriptor address: {e}");
continue;
}
};
let mut buf: Vec<u8> = Vec::new();
desc_chain
.memory()
.write_volatile_to(
desc.addr()
.translate_gva(self.access_platform.as_deref(), desc.len() as usize)
.map_err(|e| {
Error::GuestMemoryRead(vm_memory::GuestMemoryError::IOError(e))
})?,
&mut buf,
desc.len() as usize,
)
.map_err(Error::GuestMemoryRead)?;
out.write_all(&buf).map_err(Error::OutputWriteAll)?;
if let Err(e) =
desc_chain
.memory()
.write_volatile_to(addr, &mut buf, desc.len() as usize)
{
warn!("Failed to read from transmitq descriptor: {e}");
continue;
}
if let Err(e) = out.write_all(&buf) {
warn!("Failed to write console output: {e}");
}
}
}
trans_queue
@@ -289,8 +290,11 @@ impl ConsoleEpollHandler {
used_descs = true;
}
if used_descs && let Some(out) = &mut self.out {
out.flush().map_err(Error::OutputFlush)?;
if used_descs
&& let Some(out) = &mut self.out
&& let Err(e) = out.flush()
{
warn!("Failed to flush console output: {e}");
}
Ok(used_descs)