Struct PendingStdin 

pub(super) struct PendingStdin {
    chunks: VecDeque<Bytes>,
    tail: BytesMut,
    bytes: usize,
    pub(super) closed: bool,
    close_pending: bool,
}

Stdin of a client which the container did not take yet, bounded by PENDING_STDIN_MAX_BYTES. Small stdin gets merged and large stdin split into entries of at most STDIN_CHUNK_SIZE, each counts STDIN_ENTRY_OVERHEAD on top of its bytes. Empty stdin carries nothing, and nothing takes stdin after the close, both get dropped. The entries of large stdin keep its message until the container took the last one, stdin goes to the container in order, so only the oldest message is partly taken.

Fields

chunks: VecDeque<Bytes>

Stdin of at least STDIN_MERGE_SIZE bytes and merged small stdin, the oldest first.

tail: BytesMut

Small stdin after the chunks, merged.

bytes: usize

The bytes and the overhead of the chunks.

closed: bool

Whether the client closed its stdin.

close_pending: bool

Whether the close still has to be taken, after the stdin before it.

Implementations

impl PendingStdin

pub(super) fn is_empty(&self) -> bool

pub(super) fn len(&self) -> usize

What the pending stdin counts against PENDING_STDIN_MAX_BYTES.

pub(super) fn is_full(&self) -> bool

Whether the client has to wait, which stops reading the socket.

pub(super) fn push(&mut self, stdin: Stdin)

fn flush_tail(&mut self)

The merged stdin becomes a chunk, so that later stdin goes behind it.

fn take_tail(&mut self) -> Bytes

The merged stdin in a buffer of its own. A part of the buffer of the tail would keep all of it, which can be far more than the stdin it counts. The tail keeps its buffer, of at most twice STDIN_CHUNK_SIZE, for the next stdin.

fn push_chunk(&mut self, chunk: Bytes)

pub(super) fn pop(&mut self) -> Stdin

The oldest stdin, callers check that there is some.

pub(super) fn clear(&mut self)

Drop the stdin, nothing takes it anymore.

Trait Implementations

impl Debug for PendingStdin

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

Formats the value using the given formatter.

impl Default for PendingStdin

fn default() -> Self

Returns the “default value” for a type.