Function sample_network_totals

packages/server/src/performance.rs:834–861

(pid: i32)

}

async fn sample_network_totals(pid: i32) -> Result<(Option<u64>, Option<u64>), AppError> {
    let output = timeout(
        NETWORK_TOTALS_TIMEOUT,
        Command::new("nettop")
            .args([
                "-P",
                "-L",
                "1",
                "-x",
                "-J",
                "bytes_in,bytes_out",
                "-p",
                &pid.to_string(),
            ])
            .output(),
    )
    .await
    .map_err(|_| AppError::native("Timed out reading process network totals."))?
    .map_err(|error| AppError::native(format!("Unable to read process network totals: {error}")))?;

    if !output.status.success() {
        return Ok((None, None));
    }

    Ok(parse_nettop_network_totals(&String::from_utf8_lossy(
        &output.stdout,
    )))
}

fn parse_nettop_network_totals(output: &str) -> (Option<u64>, Option<u64>) {
    let mut lines = output.lines().filter(|line| !line.trim().is_empty());