Start9/start-os
2
0
Fork 0
mirror of https://github.com/Start9Labs/start-os.git synced 2026-03-30 20:14:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix dns

Browse Source
This commit is contained in:
Aiden McClelland
2025-08-25 19:29:39 -06:00
parent d6d91822cc
commit f4cf94acd2
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
core/startos/src/net/dns.rs
View File

@@ -173,7 +173,7 @@ impl DnsClient {
let mut prev_nameservers = Vec::new(); let mut prev_nameservers = Vec::new();
let mut bg = BTreeMap::<SocketAddr, BoxFuture<_>>::new(); let mut bg = BTreeMap::<SocketAddr, BoxFuture<_>>::new();
loop { loop {
let nameservers = dbg!(&conf) let nameservers = conf
.lines() .lines()
.map(|l| l.trim()) .map(|l| l.trim())
.filter_map(|l| l.strip_prefix("nameserver ")) .filter_map(|l| l.strip_prefix("nameserver "))
@@ -263,7 +263,6 @@ impl DnsClient {
) -> Vec<hickory_client::proto::xfer::DnsExchangeSend> { ) -> Vec<hickory_client::proto::xfer::DnsExchangeSend> {
self.client.peek(|c| { self.client.peek(|c| {
c.iter() c.iter()
.map(|(k, v)| (dbg!(k), v))
.map(|(_, c)| c.lookup(query.clone(), options.clone())) .map(|(_, c)| c.lookup(query.clone(), options.clone()))
.collect() .collect()
}) })
@@ -418,16 +417,16 @@ impl RequestHandler for Resolver {
let query = query.original().clone(); let query = query.original().clone();
let mut streams = self let mut streams = self
.client .client
.lookup(dbg!(query), DnsRequestOptions::default()); .lookup(query, DnsRequestOptions::default());
let mut err = None; let mut err = None;
for stream in streams.iter_mut() { for stream in streams.iter_mut() {
match dbg!(tokio::time::timeout(Duration::from_secs(5), stream.next()).await) { match tokio::time::timeout(Duration::from_secs(5), stream.next()).await {
Ok(Some(Err(e))) => err = Some(e), Ok(Some(Err(e))) => err = Some(e),
Ok(Some(Ok(msg))) => { Ok(Some(Ok(msg))) => {
return response_handle return response_handle
.send_response( .send_response(
MessageResponseBuilder::from_message_request(&*request).build( MessageResponseBuilder::from_message_request(&*request).build(
msg.header().clone(), Header::response_from_request(request.header()),
msg.answers(), msg.answers(),
msg.name_servers(), msg.name_servers(),
&msg.soa().map(|s| s.to_owned().into_record_of_rdata()), &msg.soa().map(|s| s.to_owned().into_record_of_rdata()),