Function read_cstring

src/protocol/codec.rs:414–423

Helper functions

(buf: &mut &[u8])

// Helper functions
fn read_cstring(buf: &mut &[u8]) -> io::Result<String> {
    let null_pos = buf.iter().position(|&b| b == 0)
        .ok_or_else(|| io::Error::new(io::ErrorKind::UnexpectedEof, "Missing null terminator"))?;
    
    let string = String::from_utf8(buf[..null_pos].to_vec())
        .map_err(|e| io::Error::new(io::ErrorKind::InvalidData, e))?;
    
    *buf = &buf[null_pos + 1..];
    Ok(string)
}

fn put_cstring(dst: &mut BytesMut, s: &str) {
    dst.put_slice(s.as_bytes());