Struct PacketBuilder

Source
pub struct PacketBuilder<B> { /* private fields */ }
Expand description

Builds an aggregate usb packet out of vsock packets and gives readiness notifications when there is room to add another packet or data available to send.

Implementations§

Source§

impl<B> PacketBuilder<B>

Source

pub fn new(buffer: B) -> Self

Creates a new builder from buffer, which is a type that can be used as a mutable slice with space available for storing vsock packets. The readable_notify will have a message sent to it whenever a usb packet could be transmitted.

Source§

impl<B> PacketBuilder<B>
where B: DerefMut<Target = [u8]>,

Source

pub fn available(&self) -> usize

Gets the space currently available for another packet in the buffer

Source

pub fn wait_for_space(&self, bytes: usize) -> SpaceAvailableFuture<'_, B>

Waits for there to be room to write a vsock packet of at least sizeof(Header)+bytes in the buffer. Use Self::write_vsock_packet to write the packet when space becomes available.

§Panics

Panics if the buffer this was built with isn’t big enough to hold the packet even if it were empty.

Source

pub fn wait_for_usb_packet(&self) -> UsbPacketFuture<'_, B>

Waits for a usb packet to be available in the buffer. Use Self::take_usb_packet to get the packet when this returns.

Source

pub fn write_vsock_packet( &mut self, packet: &Packet<'_>, ) -> Result<(), PacketTooBigError>

Writes the given packet into the buffer. The packet and header must be able to fit within the buffer provided at creation time.

Source

pub fn take_usb_packet(&mut self) -> Option<&mut [u8]>

Takes the current usb packet, if there is one. The returned mutable slice will be only the data written to the buffer so far, and packet writing will be reset to the beginning of the buffer.

Auto Trait Implementations§

§

impl<B> !Freeze for PacketBuilder<B>

§

impl<B> !RefUnwindSafe for PacketBuilder<B>

§

impl<B> Send for PacketBuilder<B>
where B: Send,

§

impl<B> Sync for PacketBuilder<B>
where B: Sync,

§

impl<B> Unpin for PacketBuilder<B>
where B: Unpin,

§

impl<B> UnwindSafe for PacketBuilder<B>
where B: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.