Struct VsockService

pub struct VsockService<B> {
    connection: Mutex<Option<Weak<Connection<B>>>>,
    callback: CallbacksProxy,
    scope: Scope,
}

Implements the fuchsia.hardware.vsock service against a Connection.

Fields

connection: Mutex<Option<Weak<Connection<B>>>>

callback: CallbacksProxy

scope: Scope

Implementations

impl<B: PacketBuffer> VsockService<B>

pub async fn wait_for_start( incoming_connections: Receiver<ConnectionRequest>, requests: &mut DeviceRequestStream, ) -> Result<Self, Error>

Waits for the start message from the client and returns a constructed VsockService

pub async fn set_connection(&self, conn: Arc<Connection<B>>)

Set the current connection to be used by the vsock service server.

Panics

Panics if the current socket is already set.

fn get_connection(&self) -> Option<Arc<Connection<B>>>

Gets the current connection if one is set.

async fn send_request(&self, addr: Addr, data: Socket) -> Result<(), Status>

async fn send_shutdown(&self, addr: Addr) -> Result<(), Status>

async fn send_rst(&self, addr: Addr) -> Result<(), Status>

async fn send_response(&self, addr: Addr, data: Socket) -> Result<(), Status>

async fn run_incoming_loop( incoming_connections: Receiver<ConnectionRequest>, proxy: CallbacksProxy, )

pub async fn run(&self, requests: DeviceRequestStream) -> Result<(), Error>

Runs the request loop for vsock::DeviceRequest against whatever the current Connection is.