Struct timely::communication::allocator::zero_copy::bytes_exchange::SendEndpoint

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

A BytesPush wrapper which stages writes.

Implementations

impl<P> SendEndpoint<P>

where P: BytesPush,

pub fn new(queue: P) -> SendEndpoint<P>

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> Drop for SendEndpoint<P>

where P: BytesPush,

fn drop(&mut self)

Executes the destructor for this type.