Struct virtual_net::tcp_pair::SocketBuffer

pub(crate) struct SocketBuffer {
    state: Arc<Mutex<SocketBufferState>>,
    dead_on_drop: bool,
}

Fields

state: Arc<Mutex<SocketBufferState>>

dead_on_drop: bool

Implementations

impl SocketBuffer

fn new(max_size: usize) -> Self

pub fn set_push_handler(&self, handler: ArcInterestHandler)

pub fn set_pull_handler(&self, handler: ArcInterestHandler)

pub fn clear_push_handler(&self)

pub fn clear_pull_handler(&self)

pub fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<Result<usize>>

pub fn poll_write_ready(&self, cx: &mut Context<'_>) -> Poll<Result<usize>>

fn set_state(&self, new_state: State)

fn state(&self) -> State

pub fn try_send( &self, data: &[u8], all_or_nothing: bool, waker: Option<&Waker>, ) -> Result<usize>

pub async fn send(&self, data: Bytes) -> Result<()>

pub fn try_read( &self, buf: &mut [MaybeUninit<u8>], waker: Option<&Waker>, ) -> Result<usize>

pub fn set_max_size(&self, new_size: usize)

pub fn max_size(&self) -> usize

Trait Implementations

impl AsyncRead for SocketBuffer

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl AsyncWrite for SocketBuffer

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from buf into the object.

fn poll_flush( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl Clone for SocketBuffer

fn clone(&self) -> SocketBuffer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SocketBuffer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for SocketBuffer

fn drop(&mut self)

Executes the destructor for this type.