DoxigAlpha
std › crypto.tls › Decoder › readAtLeast

readAtLeast

Use this function to increase their_end.

Function parameters

Parameters

#
d:*Decoder
stream:*std.io.Reader
their_amt:usize

Type definitions in this namespace

Types

#
ApplicationCipher
Encryption parameters for application traffic.
Decoder
An abstraction to ensure that protocol-parsing code does not perform an

Functions in this namespace

Functions

#

= 5

Values

#
max_ciphertext_len
= max_ciphertext_inner_record_len + 256
max_ciphertext_record_len
= max_ciphertext_len + record_header_len
hello_retry_request_sequence
= [32]u8{ 0xCF, 0x21, 0xAD, 0x74, 0xE5, 0x9A, 0x61, 0x11, 0xBE, 0x1D, 0x8C, 0x02, 0x1E, 0x65, 0xB8, 0x91, 0xC2, 0xA2, 0x11, 0x16, 0x7A, 0xBB, 0x8C, 0x5E, 0x07, 0x9E, 0x09, 0xE2, 0xC8, 0xA8, 0x33, 0x9C, }
close_notify_alert
= [_]u8{ @intFromEnum(Alert.Level.warning), @intFromEnum(Alert.Description.close_notify), }

Source

Implementation

#
pub fn readAtLeast(d: *Decoder, stream: *std.io.Reader, their_amt: usize) !void {
    assert(!d.disable_reads);
    const existing_amt = d.cap - d.idx;
    d.their_end = d.idx + their_amt;
    if (their_amt <= existing_amt) return;
    const request_amt = their_amt - existing_amt;
    const dest = d.buf[d.cap..];
    if (request_amt > dest.len) return error.TlsRecordOverflow;
    stream.readSlice(dest[0..request_amt]) catch |err| switch (err) {
        error.EndOfStream => return error.TlsConnectionTruncated,
        error.ReadFailed => return error.ReadFailed,
    };
    d.cap += request_amt;
}