Function resolve_tcp

src/resolver.rs:185–211

(
    globals: &Globals,
    packet: &mut [u8],
    packet_qname: &[u8],
    tid: u16,
)

}

pub async fn resolve_tcp(
    globals: &Globals,
    packet: &mut [u8],
    packet_qname: &[u8],
    tid: u16,
) -> Result<Vec<u8>, Error> {
    let mut last_error = None;
    for upstream_addr in &globals.upstream_addrs {
        match resolve_tcp_single(
            *upstream_addr,
            globals.external_addr,
            packet,
            packet_qname,
            tid,
            globals.tcp_timeout,
        )
        .await
        {
            Ok(response) => return Ok(response),
            Err(e) => {
                trace!("Upstream {} TCP failed: {}", upstream_addr, e);
                last_error = Some(e);
            }
        }
    }
    Err(last_error.unwrap_or_else(|| anyhow!("No upstream servers configured")))
}

pub async fn resolve(
    globals: &Globals,