Struct UsbConnection

pub(crate) struct UsbConnection {
    pub(crate) vsock_service: Arc<VsockService<Vec<u8>>>,
    pub(crate) usb_socket_reader: ReadHalf<Socket>,
    pub(crate) usb_socket_writer: WriteHalf<Socket>,
    pub(crate) connection_tx: Sender<ConnectionRequest>,
}

Processes a connection to the underlying USB device through a datagram socket where each packet received or sent corresponds to a USB bulk transfer buffer. It will call the callback with a new link and close the old one whenever a magic reset packet is received from the host.

Fields

vsock_service: Arc<VsockService<Vec<u8>>>

usb_socket_reader: ReadHalf<Socket>

usb_socket_writer: WriteHalf<Socket>

connection_tx: Sender<ConnectionRequest>

Implementations

impl UsbConnection

pub(crate) fn new( vsock_service: Arc<VsockService<Vec<u8>>>, usb_socket: Socket, connection_tx: Sender<ConnectionRequest>, ) -> Self

pub(crate) async fn clear_host_requests( &mut self, found_magic: &[u8], ) -> Option<()>

pub(crate) async fn next_socket( &mut self, found_magic: Option<Vec<u8>>, ) -> Option<u32>

Waits for an PacketType::Sync packet and sends the reply back, and then returns the negotiated device CID for the connection.

pub(crate) async fn run(self, synchronized: Option<Sender<()>>)