|
@@ -94,7 +94,7 @@ pub async fn channel_task<H: DhtHandler>(handler: Arc<H>) -> Result<()> {
|
|
|
let ping_res = handler.ping(channel.clone()).await;
|
|
let ping_res = handler.ping(channel.clone()).await;
|
|
|
|
|
|
|
|
if let Err(e) = ping_res {
|
|
if let Err(e) = ping_res {
|
|
|
- warn!(target: "dht::channel_task()", "Error while pinging manual connection (requesting node id) {}: {e}", channel.address());
|
|
|
|
|
|
|
+ warn!(target: "dht::channel_task()", "Error while pinging manual connection (requesting node id) {}: {e}", channel.display_address());
|
|
|
continue;
|
|
continue;
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -262,7 +262,7 @@ pub async fn disconnect_inbounds_task<H: DhtHandler>(handler: Arc<H>) -> Result<
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// Now we can stop it and remove it from the channel cache
|
|
// Now we can stop it and remove it from the channel cache
|
|
|
- info!(target: "dht::disconnect_inbounds_task()", "Closing expired inbound channel [{}]", channel.address());
|
|
|
|
|
|
|
+ info!(target: "dht::disconnect_inbounds_task()", "Closing expired inbound channel [{}]", channel.display_address());
|
|
|
channel.stop().await;
|
|
channel.stop().await;
|
|
|
channel_cache.remove(&channel.info.id);
|
|
channel_cache.remove(&channel.info.id);
|
|
|
}
|
|
}
|