@@ -418,12 +418,12 @@ impl Actor {
418
418
let res = fut. await ;
419
419
let res = match res {
420
420
Some ( Ok ( Ok ( report) ) ) => Ok ( report) ,
421
- Some ( Ok ( Err ( ProbeError :: Error ( err, _probe ) ) ) ) => {
421
+ Some ( Ok ( Err ( ProbeError :: Error ( err) ) ) ) => {
422
422
warn ! ( "probe failed: {:#}" , err) ;
423
423
Err ( err)
424
424
}
425
- Some ( Ok ( Err ( ProbeError :: AbortSet ( err, probe ) ) ) ) => {
426
- debug ! ( ?probe , "probe set aborted: {:#}" , err) ;
425
+ Some ( Ok ( Err ( ProbeError :: AbortSet ( err) ) ) ) => {
426
+ debug ! ( "probe set aborted: {:#}" , err) ;
427
427
set_token. cancel ( ) ;
428
428
Err ( err)
429
429
}
@@ -478,9 +478,9 @@ impl ProbeReport {
478
478
#[ derive( Debug ) ]
479
479
enum ProbeError {
480
480
/// Abort the current set.
481
- AbortSet ( anyhow:: Error , Probe ) ,
481
+ AbortSet ( anyhow:: Error ) ,
482
482
/// Continue the other probes in the set.
483
- Error ( anyhow:: Error , Probe ) ,
483
+ Error ( anyhow:: Error ) ,
484
484
}
485
485
486
486
/// Pieces needed to do QUIC address discovery.
@@ -532,7 +532,7 @@ async fn run_probe(
532
532
}
533
533
Ok ( report)
534
534
}
535
- Err ( err) => Err ( ProbeError :: Error ( err, probe ) ) ,
535
+ Err ( err) => Err ( ProbeError :: Error ( err) ) ,
536
536
}
537
537
}
538
538
@@ -550,7 +550,7 @@ async fn run_probe(
550
550
_ => unreachable ! ( ) ,
551
551
}
552
552
. context ( "no relay node addr" )
553
- . map_err ( |e| ProbeError :: AbortSet ( e , probe . clone ( ) ) ) ?;
553
+ . map_err ( ProbeError :: AbortSet ) ?;
554
554
555
555
let url = node. url . clone ( ) ;
556
556
let report = run_quic_probe (
@@ -563,10 +563,10 @@ async fn run_probe(
563
563
. await ?;
564
564
Ok ( report)
565
565
}
566
- None => Err ( ProbeError :: AbortSet (
567
- anyhow ! ( "No QUIC endpoint for {}" , probe . proto ( ) ) ,
568
- probe,
569
- ) ) ,
566
+ None => Err ( ProbeError :: AbortSet ( anyhow ! (
567
+ "No QUIC endpoint for {}" ,
568
+ probe. proto ( )
569
+ ) ) ) ,
570
570
}
571
571
}
572
572
}
@@ -602,18 +602,17 @@ async fn run_quic_probe(
602
602
let host = match url. host_str ( ) {
603
603
Some ( host) => host,
604
604
None => {
605
- return Err ( ProbeError :: Error (
606
- anyhow ! ( "URL must have 'host' to use QUIC address discovery probes" ) ,
607
- probe. clone ( ) ,
608
- ) ) ;
605
+ return Err ( ProbeError :: Error ( anyhow ! (
606
+ "URL must have 'host' to use QUIC address discovery probes"
607
+ ) ) ) ;
609
608
}
610
609
} ;
611
610
let quic_client = iroh_relay:: quic:: QuicClient :: new ( quic_config. ep , quic_config. client_config )
612
- . map_err ( |e| ProbeError :: Error ( e , probe . clone ( ) ) ) ?;
611
+ . map_err ( ProbeError :: Error ) ?;
613
612
let ( addr, latency) = quic_client
614
613
. get_addr_and_latency ( relay_addr, host)
615
614
. await
616
- . map_err ( |e| ProbeError :: Error ( e , probe . clone ( ) ) ) ?;
615
+ . map_err ( ProbeError :: Error ) ?;
617
616
let mut result = ProbeReport :: new ( probe. clone ( ) ) ;
618
617
if matches ! ( probe, Probe :: QadIpv4 { .. } ) {
619
618
result. ipv4_can_send = true ;
@@ -935,7 +934,7 @@ mod tests {
935
934
{
936
935
Ok ( probe) => probe,
937
936
Err ( e) => match e {
938
- ProbeError :: AbortSet ( err, _ ) | ProbeError :: Error ( err, _ ) => {
937
+ ProbeError :: AbortSet ( err) | ProbeError :: Error ( err) => {
939
938
return Err ( err. into ( ) ) ;
940
939
}
941
940
} ,
0 commit comments