style: rustfmt warm_domain

This commit is contained in:
Razvan Dimescu
2026-04-12 11:09:20 +03:00
parent f705f8c49f
commit 700cca9cb6

View File

@@ -763,7 +763,12 @@ async fn warm_domain(ctx: &ServerCtx, domain: &str) {
if ctx.upstream_mode == numa::config::UpstreamMode::Recursive { if ctx.upstream_mode == numa::config::UpstreamMode::Recursive {
let query = numa::packet::DnsPacket::query(0, domain, qtype); let query = numa::packet::DnsPacket::query(0, domain, qtype);
match numa::recursive::resolve_recursive( match numa::recursive::resolve_recursive(
domain, qtype, &ctx.cache, &query, &ctx.root_hints, &ctx.srtt, domain,
qtype,
&ctx.cache,
&query,
&ctx.root_hints,
&ctx.srtt,
) )
.await .await
{ {
@@ -781,13 +786,20 @@ async fn warm_domain(ctx: &ServerCtx, domain: &str) {
} }
let pool = ctx.upstream_pool.lock().unwrap().clone(); let pool = ctx.upstream_pool.lock().unwrap().clone();
match numa::forward::forward_with_failover_raw( match numa::forward::forward_with_failover_raw(
buf.filled(), &pool, &ctx.srtt, ctx.timeout, ctx.hedge_delay, buf.filled(),
&pool,
&ctx.srtt,
ctx.timeout,
ctx.hedge_delay,
) )
.await .await
{ {
Ok(wire) => { Ok(wire) => {
ctx.cache.write().unwrap().insert_wire( ctx.cache.write().unwrap().insert_wire(
domain, qtype, &wire, numa::cache::DnssecStatus::Indeterminate, domain,
qtype,
&wire,
numa::cache::DnssecStatus::Indeterminate,
); );
log::debug!("cache warm: {} {:?}", domain, qtype); log::debug!("cache warm: {} {:?}", domain, qtype);
} }