Struct devices::virtio::snd::vios_backend::worker::Worker

pub struct Worker {
    pub control_queue: Arc<Mutex<Queue>>,
    pub event_queue: Option<Queue>,
    vios_client: Arc<Mutex<VioSClient>>,
    streams: Vec<StreamProxy>,
    pub tx_queue: Arc<Mutex<Queue>>,
    pub rx_queue: Arc<Mutex<Queue>>,
    io_thread: Option<JoinHandle<Result<()>>>,
    io_kill: Event,
    pub saved_stream_state: Vec<StreamSnapshot>,
}

Fields

control_queue: Arc<Mutex<Queue>>

event_queue: Option<Queue>

vios_client: Arc<Mutex<VioSClient>>

streams: Vec<StreamProxy>

tx_queue: Arc<Mutex<Queue>>

rx_queue: Arc<Mutex<Queue>>

io_thread: Option<JoinHandle<Result<()>>>

io_kill: Event

saved_stream_state: Vec<StreamSnapshot>

Implementations

impl Worker

pub fn try_new( vios_client: Arc<Mutex<VioSClient>>, control_queue: Arc<Mutex<Queue>>, event_queue: Queue, tx_queue: Arc<Mutex<Queue>>, rx_queue: Arc<Mutex<Queue>>, saved_stream_state: Vec<StreamSnapshot>, ) -> Result<Worker>

Creates a new virtio-snd worker.

pub fn control_loop(&mut self, kill_evt: Event) -> Result<()>

Emulates the virtio-snd device. It won’t return until something is written to the kill_evt event or an unrecoverable error occurs.

fn stop_io_thread(&mut self)

fn process_controlq_buffers(&mut self) -> Result<()>

fn process_event_triggered(&mut self, event_queue: &mut Queue) -> Result<()>

fn parse_info_query(&mut self, read_buf: &[u8]) -> Option<(u32, u32)>

fn process_set_params( &mut self, desc: DescriptorChain, read_buf: &[u8], ) -> Result<()>

fn try_parse_pcm_hdr_and_send_msg( &mut self, read_buf: &[u8], msg: StreamMsg, ) -> Result<()>

fn send_info_reply<T: Immutable + IntoBytes>( &mut self, desc: DescriptorChain, code: u32, info_vec: Vec<T>, ) -> Result<()>

Trait Implementations

impl Drop for Worker

fn drop(&mut self)

Executes the destructor for this type.