Struct VringMutex

pub struct VringMutex<M: GuestAddressSpace = GuestMemoryAtomic<GuestMemoryMmap>> { /* private fields */ }

A VringState object protected by Mutex for multi-threading context.

Trait Implementations

impl<M: Clone + GuestAddressSpace> Clone for VringMutex<M>

fn clone(&self) -> VringMutex<M>

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a, M: 'a + GuestAddressSpace> VringStateGuard<'a, M> for VringMutex<M>

type G = MutexGuard<'a, VringState<M>>

Type for guard returned by VringT::get_ref().

impl<'a, M: 'a + GuestAddressSpace> VringStateMutGuard<'a, M> for VringMutex<M>

type G = MutexGuard<'a, VringState<M>>

Type for guard returned by VringT::get_mut().

impl<M: 'static + GuestAddressSpace> VringT<M> for VringMutex<M>

fn new(mem: M, max_queue_size: u16) -> Result<Self, VirtQueError>

Create a new instance of Vring.

fn get_ref(&self) -> <Self as VringStateGuard<'_, M>>::G

Get an immutable reference to the kick event fd.

fn get_mut(&self) -> <Self as VringStateMutGuard<'_, M>>::G

Get a mutable reference to the kick event fd.

fn add_used(&self, desc_index: u16, len: u32) -> Result<(), VirtQueError>

Add an used descriptor into the used queue.

fn signal_used_queue(&self) -> Result<()>

Notify the vhost-user frontend that used descriptors have been put into the used queue.

fn enable_notification(&self) -> Result<bool, VirtQueError>

Enable event notification for queue.

fn disable_notification(&self) -> Result<(), VirtQueError>

Disable event notification for queue.

fn needs_notification(&self) -> Result<bool, VirtQueError>

Check whether a notification to the guest is needed.

fn set_enabled(&self, enabled: bool)

Set vring enabled state.

fn set_queue_info( &self, desc_table: u64, avail_ring: u64, used_ring: u64, ) -> Result<(), VirtQueError>

Set queue addresses for descriptor table, available ring and used ring.

fn queue_next_avail(&self) -> u16

Get queue next avail head.

fn set_queue_next_avail(&self, base: u16)

Set queue next avail head.

fn set_queue_next_used(&self, idx: u16)

Set queue next used head.

fn queue_used_idx(&self) -> Result<u16, VirtQueError>

Get queue next used head index from the guest memory.

fn set_queue_size(&self, num: u16)

Set configured queue size.

fn set_queue_event_idx(&self, enabled: bool)

Enable/disable queue event index feature.

fn set_queue_ready(&self, ready: bool)

Set queue enabled state.

fn set_kick(&self, file: Option<File>)

Set EventFd for kick.

fn read_kick(&self) -> Result<bool>

Read event from the kick EventFd.

fn set_call(&self, file: Option<File>)

Set EventFd for call.

fn set_err(&self, file: Option<File>)

Set EventFd for err.