Skip to content

Commit

Permalink
dnm: more logging to debug connection issues
Browse files Browse the repository at this point in the history
  • Loading branch information
teskje committed Jan 13, 2025
1 parent 1293981 commit 14b40f4
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 1 deletion.
4 changes: 3 additions & 1 deletion src/service/src/grpc.rs
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ where
metrics: G::STATS,
params: &GrpcClientParameters,
) -> Result<Self, anyhow::Error> {
debug!("GrpcClient {}: Attempt to connect", addr);
tracing::error!(?params, "GrpcClient {}: Attempt to connect", addr);

let channel = match SocketAddrType::guess(&addr) {
SocketAddrType::Inet => {
Expand All @@ -112,6 +112,7 @@ where
if let Some(keep_alive_interval) = params.http2_keep_alive_interval {
endpoint = endpoint.http2_keep_alive_interval(keep_alive_interval);
}
tracing::error!("waiting for inet connect");
endpoint.connect().await?
}
SocketAddrType::Unix => {
Expand Down Expand Up @@ -303,6 +304,7 @@ where
info!("Starting to listen on {}", listen_addr);

async {
tracing::error!("Starting to listen on {}", listen_addr);
let listener = Listener::bind(listen_addr).await?;

Server::builder()
Expand Down
1 change: 1 addition & 0 deletions src/storage-controller/src/instance.rs
Original file line number Diff line number Diff line change
Expand Up @@ -355,6 +355,7 @@ where
async fn connect(&self) -> ReplicaClient<T> {
let try_connect = |retry: RetryState| {
let addrs = &self.config.location.ctl_addrs;
tracing::error!("trying to connect to {addrs:?}");
let dests = addrs
.iter()
.map(|addr| (addr.clone(), self.metrics.clone()))
Expand Down

0 comments on commit 14b40f4

Please sign in to comment.