Function read_frame

atomic-cli/src/commands/agent/owner.rs:1327–1339

(stream: &mut S)

}

async fn read_frame<T, S>(stream: &mut S) -> anyhow::Result<T>
where
    T: for<'de> Deserialize<'de>,
    S: AsyncRead + Unpin,
{
    let length = stream.read_u32().await? as usize;
    if length == 0 || length > MAX_FRAME_BYTES {
        return Err(anyhow!("invalid database-owner frame length {length}"));
    }
    let mut payload = vec![0; length];
    stream.read_exact(&mut payload).await?;
    serde_json::from_slice(&payload).context("invalid database-owner JSON frame")
}

async fn write_frame<T, S>(stream: &mut S, value: &T) -> anyhow::Result<()>
where