leyoda/rqbit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix debug repr for URLs in tracker comms

Browse source
This commit is contained in:
Igor Katson 2025-02-27 14:36:44 +00:00
parent 29508014b8
commit 75354069f0
No known key found for this signature in database
GPG key ID: B4EC22B66D61A3F5
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
crates/tracker_comms/src/tracker_comms.rs
View file

@ -187,7 +187,7 @@ impl TrackerComms {
async fn task_single_tracker_monitor_http(&self, mut tracker_url: Url) -> anyhow::Result<()> { async fn task_single_tracker_monitor_http(&self, mut tracker_url: Url) -> anyhow::Result<()> {
let mut event = Some(tracker_comms_http::TrackerRequestEvent::Started); let mut event = Some(tracker_comms_http::TrackerRequestEvent::Started);
trace!(url=?tracker_url, "starting monitor"); trace!(url=%tracker_url, "starting monitor");
loop { loop {
let stats = self.stats.get(); let stats = self.stats.get();
let request = tracker_comms_http::TrackerRequest { let request = tracker_comms_http::TrackerRequest {
@ -231,7 +231,7 @@ impl TrackerComms {
} }
async fn tracker_one_request_http(&self, tracker_url: Url) -> anyhow::Result<u64> { async fn tracker_one_request_http(&self, tracker_url: Url) -> anyhow::Result<u64> {
debug!(url = ?tracker_url, "calling tracker over http"); debug!(url = %tracker_url, "calling tracker over http");
let response: reqwest::Response = self.reqwest_client.get(tracker_url).send().await?; let response: reqwest::Response = self.reqwest_client.get(tracker_url).send().await?;
if !response.status().is_success() { if !response.status().is_success() {
anyhow::bail!("tracker responded with {:?}", response.status()); anyhow::bail!("tracker responded with {:?}", response.status());
@ -310,7 +310,7 @@ impl TrackerComms {
sleep_interval = Some(self.force_tracker_interval.unwrap_or(new_interval)); sleep_interval = Some(self.force_tracker_interval.unwrap_or(new_interval));
} }
Err(e) => { Err(e) => {
debug!(url = ?url, "error reading announce response: {e:#}"); debug!(url = %url, "error reading announce response: {e:#}");
if sleep_interval.is_none() { if sleep_interval.is_none() {
sleep_interval = Some( sleep_interval = Some(
self.force_tracker_interval self.force_tracker_interval