Struct tlspuffin::tls::rustls::msgs::deframer::MessageDeframer

pub struct MessageDeframer {
    pub frames: VecDeque<OpaqueMessage>,
    pub desynced: bool,
    buf: Box<[u8; 18437]>,
    used: usize,
}

This deframer works to reconstruct TLS messages from arbitrary-sized reads, buffering as necessary. The input is read(), the output is the frames deque.

Fields

frames: VecDeque<OpaqueMessage>

Completed frames for output.

desynced: bool

Set to true if the peer is not talking TLS, but some other protocol. The caller should abort the connection, because the deframer cannot recover.

buf: Box<[u8; 18437]>

A fixed-size buffer containing the currently-accumulating TLS message.

used: usize

What size prefix of buf is used.

Implementations

impl MessageDeframer

pub fn new() -> Self

pub fn read(&mut self, rd: &mut dyn Read) -> Result<usize>

Read some bytes from rd, and add them to our internal buffer. If this means our internal buffer contains full messages, decode them all.

pub fn has_pending(&self) -> bool

Returns true if we have messages for the caller to process, either whole messages in our output queue or partial messages in our buffer.

fn try_deframe_one(&mut self) -> BufferContents

Does our buf contain a full message? It does if it is big enough to contain a header, and that header has a length which falls within buf. If so, deframe it and place the message onto the frames output queue.

fn buf_consume(&mut self, taken: usize)

Trait Implementations

impl Default for MessageDeframer

fn default() -> Self

Returns the “default value” for a type.

impl ProtocolMessageDeframer<TLSProtocolTypes> for MessageDeframer

type OpaqueProtocolMessage = OpaqueMessage

fn pop_frame(&mut self) -> Option<OpaqueMessage>

fn read(&mut self, rd: &mut dyn Read) -> Result<usize>