Function write_node_file

crates/hyperqueue/src/worker/start/program.rs:253–268

(ctx: &TaskBuildContext, path: &Path, short_names: bool)

}

fn write_node_file(ctx: &TaskBuildContext, path: &Path, short_names: bool) -> std::io::Result<()> {
    let file = File::create(path)?;
    let mut file = BufWriter::new(file);
    for worker_id in ctx.node_list() {
        let hostname = ctx.worker_hostname(*worker_id).unwrap();
        let node_name = if short_names && !is_ip_address(hostname) {
            hostname.split_once('.').map(|x| x.0).unwrap_or(hostname)
        } else {
            hostname
        };
        file.write_all(node_name.as_bytes())?;
        file.write_all(b"\n")?;
    }
    file.flush()?;
    Ok(())
}

fn insert_resources_into_env(ctx: &TaskBuildContext, program: &mut ProgramDefinition) {
    let (resource_map, resource_rq_map) = ctx.get_resource_maps();