pub struct DeviceRequestHandler<T: VhostUserDevice> {
    vrings: Vec<Vring>,
    owned: bool,
    vmm_maps: Option<Vec<MappingInfo>>,
    mem: Option<GuestMemory>,
    backend: T,
    backend_req_connection: Arc<Mutex<VhostBackendReqConnectionState>>,
}
Expand description

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>§backend: T§backend_req_connection: Arc<Mutex<VhostBackendReqConnectionState>>

Implementations§

source§

impl<T: VhostUserDevice> DeviceRequestHandler<T>

source

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

Creates a vhost-user handler instance for backend.

Trait Implementations§

source§

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

source§

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

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

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

source§

fn as_ref(&self) -> &T

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

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

source§

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

Request the device to sleep by stopping their workers. This should NOT be called if the device is already asleep.
source§

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

Request the device to wake up by starting up their workers. This should NOT be called if the device is already awake.
source§

fn snapshot(&mut self) -> VhostResult<Vec<u8>>

source§

fn restore( &mut self, data_bytes: &[u8], queue_evts: Vec<File> ) -> VhostResult<()>

Auto Trait Implementations§

§

impl<T> !RefUnwindSafe for DeviceRequestHandler<T>

§

impl<T> Send for DeviceRequestHandler<T>where T: Send,

§

impl<T> Sync for DeviceRequestHandler<T>where T: Sync,

§

impl<T> Unpin for DeviceRequestHandler<T>where T: Unpin,

§

impl<T> !UnwindSafe for DeviceRequestHandler<T>

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Backend for Twhere T: AsMut<dyn Backend>,

source§

fn set_owner(&mut self) -> Result<(), Error>

source§

fn reset_owner(&mut self) -> Result<(), Error>

source§

fn get_features(&mut self) -> Result<u64, Error>

source§

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

source§

fn set_mem_table( &mut self, ctx: &[VhostUserMemoryRegion], files: Vec<File, Global> ) -> Result<(), Error>

source§

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

source§

fn set_vring_addr( &mut self, index: u32, flags: VhostUserVringAddrFlags, descriptor: u64, used: u64, available: u64, log: u64 ) -> Result<(), Error>

source§

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

source§

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

source§

fn set_vring_kick(&mut self, index: u8, fd: Option<File>) -> Result<(), Error>

source§

fn set_vring_call(&mut self, index: u8, fd: Option<File>) -> Result<(), Error>

source§

fn set_vring_err(&mut self, index: u8, fd: Option<File>) -> Result<(), Error>

source§

fn get_protocol_features(&mut self) -> Result<VhostUserProtocolFeatures, Error>

source§

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

source§

fn get_queue_num(&mut self) -> Result<u64, Error>

source§

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

source§

fn get_config( &mut self, offset: u32, size: u32, flags: VhostUserConfigFlags ) -> Result<Vec<u8, Global>, Error>

source§

fn set_config( &mut self, offset: u32, buf: &[u8], flags: VhostUserConfigFlags ) -> Result<(), Error>

source§

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

source§

fn get_inflight_fd( &mut self, inflight: &VhostUserInflight ) -> Result<(VhostUserInflight, File), Error>

source§

fn set_inflight_fd( &mut self, inflight: &VhostUserInflight, file: File ) -> Result<(), Error>

source§

fn get_max_mem_slots(&mut self) -> Result<u64, Error>

source§

fn add_mem_region( &mut self, region: &VhostUserSingleMemoryRegion, fd: File ) -> Result<(), Error>

source§

fn remove_mem_region( &mut self, region: &VhostUserSingleMemoryRegion ) -> Result<(), Error>

source§

fn get_shared_memory_regions( &mut self ) -> Result<Vec<VhostSharedMemoryRegion, Global>, Error>

source§

fn sleep(&mut self) -> Result<(), Error>

Request the device to sleep by stopping their workers. This should NOT be called if the device is already asleep.
source§

fn wake(&mut self) -> Result<(), Error>

Request the device to wake up by starting up their workers. This should NOT be called if the device is already awake.
source§

fn snapshot(&mut self) -> Result<Vec<u8, Global>, Error>

source§

fn restore( &mut self, data_bytes: &[u8], queue_evts: Vec<File, Global> ) -> Result<(), Error>

source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

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

Mutably borrows from an owned value. Read more
§

impl<T> Downcast for Twhere T: Any,

§

fn into_any(self: Box<T, Global>) -> Box<dyn Any, Global>

Convert Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.
§

fn into_any_rc(self: Rc<T, Global>) -> Rc<dyn Any, Global>

Convert Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait.
§

fn as_any(&self) -> &(dyn Any + 'static)

Convert &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s.
§

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Convert &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s.
§

impl<T> DowncastSync for Twhere T: Any + Send + Sync,

§

fn into_any_arc(self: Arc<T, Global>) -> Arc<dyn Any + Sync + Send, Global>

Convert Arc<Trait> (where Trait: Downcast) to Arc<Any>. Arc<Any> can then be further downcast into Arc<ConcreteType> where ConcreteType implements Trait.
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

§

fn vzip(self) -> V