Struct timely_communication::allocator::zero_copy::bytes_exchange::SendEndpoint

pub struct SendEndpoint<P: BytesPush> { /* private fields */ }

A BytesPush wrapper which stages writes.

Implementations

impl<P: BytesPush> SendEndpoint<P>

pub fn new(queue: P) -> Self

Allocates a new BytesSendEndpoint from a shared queue.

pub fn make_valid(&mut self, bytes: usize)

Makes the next bytes bytes valid.

The current implementation also sends the bytes, to ensure early visibility.

pub fn reserve(&mut self, capacity: usize) -> &mut [u8]

Acquires a prefix of self.empty() of length at least capacity.

pub fn publish(&mut self)

Marks all written data as valid, makes visible.

Trait Implementations

impl<P: BytesPush> Drop for SendEndpoint<P>

fn drop(&mut self)

Executes the destructor for this type.