Struct devices::virtio::vhost::user::device::handler::DeviceRequestHandler

pub struct DeviceRequestHandler<T: VhostUserDevice> {
    vrings: Vec<Vring>,
    owned: bool,
    vmm_maps: Option<Vec<MappingInfo>>,
    mem: Option<GuestMemory>,
    acked_features: u64,
    acked_protocol_features: VhostUserProtocolFeatures,
    backend: T,
    backend_req_connection: Arc<Mutex<VhostBackendReqConnectionState>>,
    device_state_thread: Option<DeviceStateThread>,
}

An adapter that implements vmm_vhost::Backend for any type implementing VhostUserDevice.

Fields

vrings: Vec<Vring>

owned: bool

vmm_maps: Option<Vec<MappingInfo>>

mem: Option<GuestMemory>

acked_features: u64

acked_protocol_features: VhostUserProtocolFeatures

backend: T

backend_req_connection: Arc<Mutex<VhostBackendReqConnectionState>>

device_state_thread: Option<DeviceStateThread>

Implementations

impl<T: VhostUserDevice> DeviceRequestHandler<T>

pub(crate) fn new(backend: T) -> Self

Creates a vhost-user handler instance for backend.

fn all_queues_stopped(&self) -> bool

Check if all queues are stopped.

The device can be suspended with enter_suspended_state() only when all queues are stopped.

Trait Implementations

impl<T: VhostUserDevice> AsMut<T> for DeviceRequestHandler<T>

fn as_mut(&mut self) -> &mut T

Converts this type into a mutable reference of the (usually inferred) input type.

impl<T: VhostUserDevice> AsRef<T> for DeviceRequestHandler<T>

fn as_ref(&self) -> &T

Converts this type into a shared reference of the (usually inferred) input type.

impl<T: VhostUserDevice> Backend for DeviceRequestHandler<T>

fn set_owner(&mut self) -> VhostResult<()>

fn reset_owner(&mut self) -> VhostResult<()>

fn get_features(&mut self) -> VhostResult<u64>

fn set_features(&mut self, features: u64) -> VhostResult<()>

fn get_protocol_features(&mut self) -> VhostResult<VhostUserProtocolFeatures>

fn set_protocol_features(&mut self, features: u64) -> VhostResult<()>

fn set_mem_table( &mut self, contexts: &[VhostUserMemoryRegion], files: Vec<File> ) -> VhostResult<()>

fn get_queue_num(&mut self) -> VhostResult<u64>

fn set_vring_num(&mut self, index: u32, num: u32) -> VhostResult<()>

fn set_vring_addr( &mut self, index: u32, _flags: VhostUserVringAddrFlags, descriptor: u64, used: u64, available: u64, _log: u64 ) -> VhostResult<()>

fn set_vring_base(&mut self, index: u32, base: u32) -> VhostResult<()>

fn get_vring_base(&mut self, index: u32) -> VhostResult<VhostUserVringState>

fn set_vring_kick(&mut self, index: u8, file: Option<File>) -> VhostResult<()>

fn set_vring_call(&mut self, index: u8, file: Option<File>) -> VhostResult<()>

fn set_vring_err(&mut self, _index: u8, _fd: Option<File>) -> VhostResult<()>

fn set_vring_enable(&mut self, index: u32, enable: bool) -> VhostResult<()>

fn get_config( &mut self, offset: u32, size: u32, _flags: VhostUserConfigFlags ) -> VhostResult<Vec<u8>>

fn set_config( &mut self, offset: u32, buf: &[u8], _flags: VhostUserConfigFlags ) -> VhostResult<()>

fn set_backend_req_fd(&mut self, ep: Connection<BackendReq>)

fn get_inflight_fd( &mut self, _inflight: &VhostUserInflight ) -> VhostResult<(VhostUserInflight, File)>

fn set_inflight_fd( &mut self, _inflight: &VhostUserInflight, _file: File ) -> VhostResult<()>

fn get_max_mem_slots(&mut self) -> VhostResult<u64>

fn add_mem_region( &mut self, _region: &VhostUserSingleMemoryRegion, _fd: File ) -> VhostResult<()>

fn remove_mem_region( &mut self, _region: &VhostUserSingleMemoryRegion ) -> VhostResult<()>

fn set_device_state_fd( &mut self, transfer_direction: VhostUserTransferDirection, migration_phase: VhostUserMigrationPhase, fd: File ) -> VhostResult<Option<File>>

fn check_device_state(&mut self) -> VhostResult<()>

fn get_shared_memory_regions( &mut self ) -> VhostResult<Vec<VhostSharedMemoryRegion>>