Struct abi::bbqueue_ipc::bbbuffer::Producer

pub struct Producer<'a> {
    bbq: NonNull<BBBuffer>,
    pd: PhantomData<&'a ()>,
}

Producer is the primary interface for pushing data into a BBBuffer. There are various methods for obtaining a grant to write to the buffer, with different potential tradeoffs. As all grants are required to be a contiguous range of data, different strategies are sometimes useful when making the decision between maximizing usage of the buffer, and ensuring a given grant is successful.

As a short summary of currently possible grants:

• grant_exact(N)
  • User will receive a grant sz == N (or receive an error)
  • This may cause a wraparound if a grant of size N is not available at the end of the ring.
  • If this grant caused a wraparound, the bytes that were “skipped” at the end of the ring will not be available until the reader reaches them, regardless of whether the grant commited any data or not.
  • Maximum possible waste due to skipping: N - 1 bytes
• grant_max_remaining(N)
  • User will receive a grant 0 < sz <= N (or receive an error)
  • This will only cause a wrap to the beginning of the ring if exactly zero bytes are available at the end of the ring.
  • Maximum possible waste due to skipping: 0 bytes

See this github issue for a discussion of grant methods that could be added in the future.

Fields

bbq: NonNull<BBBuffer>

pd: PhantomData<&'a ()>

Implementations

impl<'a> Producer<'a>

pub fn grant_exact(&self, sz: usize) -> Result<GrantW<'a>>

Request a writable, contiguous section of memory of exactly sz bytes. If the buffer size requested is not available, an error will be returned.

This method may cause the buffer to wrap around early if the requested space is not available at the end of the buffer, but is available at the beginning

pub fn grant_max_remaining(&self, sz: usize) -> Result<GrantW<'a>>

Request a writable, contiguous section of memory of up to sz bytes. If a buffer of size sz is not available without wrapping, but some space (0 < available < sz) is available without wrapping, then a grant will be given for the remaining size at the end of the buffer. If no space is available for writing, an error will be returned.

Trait Implementations

impl<'a> Send for Producer<'a>

impl<'a> Sync for Producer<'a>