Function read_v1_header

gateway/src/pp.rs:160–178

(mut stream: I, buffer: &mut [u8; READ_BUFFER_LEN])

}

async fn read_v1_header<I>(mut stream: I, buffer: &mut [u8; READ_BUFFER_LEN]) -> Result<()>
where
    I: AsyncRead + Unpin,
{
    let mut end_found = false;
    for i in V1_PREFIX_LEN..V1_MAX_LENGTH {
        buffer[i] = stream.read_u8().await?;

        if [buffer[i - 1], buffer[i]] == V1_TERMINATOR {
            end_found = true;
            break;
        }
    }
    if !end_found {
        bail!("no valid proxy protocol header detected (v1 terminator not found)");
    }

    Ok(())
}

#[cfg(test)]
mod tests {