pub struct NetBackend<T: TapT + IntoAsync> {
tap: T,
avail_features: u64,
acked_features: u64,
acked_protocol_features: VhostUserProtocolFeatures,
mtu: u16,
workers: [Option<(TaskHandle<Queue>, Sender<()>)>; 3],
}
Fields§
§tap: T
§avail_features: u64
§acked_features: u64
§acked_protocol_features: VhostUserProtocolFeatures
§mtu: u16
§workers: [Option<(TaskHandle<Queue>, Sender<()>)>; 3]
Implementations§
source§impl<T> NetBackend<T>where
T: TapT + IntoAsync + 'static,
impl<T> NetBackend<T>where T: TapT + IntoAsync + 'static,
fn new_from_config(config: &TapConfig) -> Result<Self>
pub fn new_from_tap_fd(tap_fd: RawDescriptor) -> Result<Self>
pub fn new(tap: T) -> Result<Self>
source§impl<T> NetBackend<T>where
T: TapT + IntoAsync + 'static,
impl<T> NetBackend<T>where T: TapT + IntoAsync + 'static,
fn max_vq_pairs() -> usize
Trait Implementations§
source§impl<T> AsRawDescriptors for NetBackend<T>where
T: TapT + IntoAsync + AsRawDescriptors + 'static,
impl<T> AsRawDescriptors for NetBackend<T>where T: TapT + IntoAsync + AsRawDescriptors + 'static,
source§fn as_raw_descriptors(&self) -> Vec<RawDescriptor>
fn as_raw_descriptors(&self) -> Vec<RawDescriptor>
Returns the underlying raw descriptors. Read more
source§impl<T> VhostUserDevice for NetBackend<T>where
T: TapT + IntoAsync + 'static,
impl<T> VhostUserDevice for NetBackend<T>where T: TapT + IntoAsync + 'static,
source§fn max_queue_num(&self) -> usize
fn max_queue_num(&self) -> usize
The maximum number of queues that this backend can manage.
source§fn ack_features(&mut self, value: u64) -> Result<()>
fn ack_features(&mut self, value: u64) -> Result<()>
Acknowledges that this set of features should be enabled.
source§fn acked_features(&self) -> u64
fn acked_features(&self) -> u64
Returns the set of enabled features.
source§fn protocol_features(&self) -> VhostUserProtocolFeatures
fn protocol_features(&self) -> VhostUserProtocolFeatures
The set of protocol feature bits that this backend supports.
source§fn ack_protocol_features(&mut self, features: u64) -> Result<()>
fn ack_protocol_features(&mut self, features: u64) -> Result<()>
Acknowledges that this set of protocol features should be enabled.
source§fn acked_protocol_features(&self) -> u64
fn acked_protocol_features(&self) -> u64
Returns the set of enabled protocol features.
source§fn read_config(&self, offset: u64, data: &mut [u8])
fn read_config(&self, offset: u64, data: &mut [u8])
Reads this device configuration space at
offset
.source§fn start_queue(
&mut self,
idx: usize,
queue: Queue,
mem: GuestMemory,
doorbell: Interrupt
) -> Result<()>
fn start_queue( &mut self, idx: usize, queue: Queue, mem: GuestMemory, doorbell: Interrupt ) -> Result<()>
Indicates that the backend should start processing requests for virtio queue number
idx
.
This method must not block the current thread so device backends should either spawn an
async task or another thread to handle messages from the Queue.source§fn stop_queue(&mut self, idx: usize) -> Result<Queue>
fn stop_queue(&mut self, idx: usize) -> Result<Queue>
Indicates that the backend should stop processing requests for virtio queue number
idx
.
This method should return the queue passed to start_queue
for the corresponding idx
.
This method will only be called for queues that were previously started by start_queue
.fn restore(&mut self, data: Vec<u8>) -> Result<()>
source§fn write_config(&self, _offset: u64, _data: &[u8])
fn write_config(&self, _offset: u64, _data: &[u8])
writes
data
to this device’s configuration space at offset
.Returns the device’s shared memory region if present.
source§fn set_backend_req_connection(&mut self, _conn: Arc<VhostBackendReqConnection>)
fn set_backend_req_connection(&mut self, _conn: Arc<VhostBackendReqConnection>)
Accepts
VhostBackendReqConnection
to conduct Vhost backend to frontend message
handling. Read moresource§fn stop_non_queue_workers(&mut self) -> Result<()>
fn stop_non_queue_workers(&mut self) -> Result<()>
Used to stop non queue workers that
VhostUserDevice::stop_queue
can’t stop. May or may
not also stop all queue workers.Auto Trait Implementations§
impl<T> !RefUnwindSafe for NetBackend<T>
impl<T> Send for NetBackend<T>
impl<T> Sync for NetBackend<T>where T: Sync,
impl<T> Unpin for NetBackend<T>where T: Unpin,
impl<T> !UnwindSafe for NetBackend<T>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere T: Any,
§fn into_any(self: Box<T, Global>) -> Box<dyn Any, Global>
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>
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)
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)
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.