summary refs log tree commit diff
path: root/rust/src/http/resolver.rs
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2022-12-15 14:05:59 +0000
committerErik Johnston <erik@matrix.org>2022-12-15 14:05:59 +0000
commitf5817281f8bc707ed60562706091dadccf55efe5 (patch)
treea653fae7ca87a579fc261a746ba68910b52d2e9b /rust/src/http/resolver.rs
parentFixup (diff)
downloadsynapse-github/erikj/rust_http.tar.xz
Diffstat (limited to 'rust/src/http/resolver.rs')
-rw-r--r--rust/src/http/resolver.rs6
1 files changed, 5 insertions, 1 deletions
diff --git a/rust/src/http/resolver.rs b/rust/src/http/resolver.rs

index 77e9bf5c20..0a2641ebdf 100644 --- a/rust/src/http/resolver.rs +++ b/rust/src/http/resolver.rs
@@ -20,7 +20,7 @@ use hyper::service::Service; use hyper::Client; use hyper_tls::HttpsConnector; use hyper_tls::MaybeHttpsStream; -use log::info; +use log::{debug, info}; use native_tls::TlsConnector; use serde::Deserialize; use tokio::io::{AsyncRead, AsyncWrite, ReadBuf}; @@ -28,6 +28,7 @@ use tokio::net::TcpStream; use tokio_native_tls::TlsConnector as AsyncTlsConnector; use trust_dns_resolver::error::ResolveErrorKind; +#[derive(Debug, Clone)] pub struct Endpoint { pub host: String, pub port: u16, @@ -213,6 +214,7 @@ impl Service<Uri> for MatrixConnector { let resolver = self.resolver.clone(); if dst.scheme_str() != Some("matrix") { + debug!("Got non-matrix scheme"); return HttpsConnector::new() .call(dst) .map_err(|e| Error::msg(e)) @@ -227,6 +229,8 @@ impl Service<Uri> for MatrixConnector { ) .await?; + debug!("Got endpoints: {:?}", endpoints); + for endpoint in endpoints { match try_connecting(&dst, &endpoint).await { Ok(r) => return Ok(r),