Skip to content

Commit 3daa4b5

Browse files
author
“ramfox”
committed
remove unnecessary From impls
1 parent a5bb7e4 commit 3daa4b5

File tree

4 files changed

+26
-19
lines changed

4 files changed

+26
-19
lines changed

iroh-relay/src/relay_map.rs

Lines changed: 16 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -53,18 +53,6 @@ impl RelayMap {
5353
}
5454
}
5555

56-
impl FromIterator<Arc<RelayNode>> for RelayMap {
57-
fn from_iter<T: IntoIterator<Item = Arc<RelayNode>>>(iter: T) -> Self {
58-
Self {
59-
nodes: Arc::new(
60-
iter.into_iter()
61-
.map(|node| (node.url.clone(), node))
62-
.collect(),
63-
),
64-
}
65-
}
66-
}
67-
6856
impl FromIterator<RelayNode> for RelayMap {
6957
fn from_iter<T: IntoIterator<Item = RelayNode>>(iter: T) -> Self {
7058
Self {
@@ -77,6 +65,10 @@ impl FromIterator<RelayNode> for RelayMap {
7765
}
7866
}
7967

68+
/// Create a `RelayMap` from a `RelayUrl`.
69+
///
70+
/// The `RelayNode`s in the `RelayMap` will have the default stun and quic address
71+
/// discovery ports.
8072
impl From<RelayUrl> for RelayMap {
8173
fn from(value: RelayUrl) -> Self {
8274
Self {
@@ -85,6 +77,10 @@ impl From<RelayUrl> for RelayMap {
8577
}
8678
}
8779

80+
/// Create a `RelayMap` from a `RelayUrl` and a stun port.
81+
///
82+
/// The resulting `RelayMap` contains `RelayNode`s with the default quic address
83+
/// discovery port.
8884
impl From<(RelayUrl, u16)> for RelayMap {
8985
fn from(value: (RelayUrl, u16)) -> Self {
9086
Self {
@@ -101,6 +97,10 @@ impl From<RelayNode> for RelayMap {
10197
}
10298
}
10399

100+
/// Create a `RelayMap` from an interator of `RelayUrl`.
101+
///
102+
/// The `RelayNode`s in the `RelayMap` will have the default stun and quic address
103+
/// discovery ports.
104104
impl FromIterator<RelayUrl> for RelayMap {
105105
fn from_iter<T: IntoIterator<Item = RelayUrl>>(iter: T) -> Self {
106106
Self {
@@ -113,6 +113,10 @@ impl FromIterator<RelayUrl> for RelayMap {
113113
}
114114
}
115115

116+
/// Create a `RelayMap` from an iterator of `RelayUrl`s and a stun ports.
117+
///
118+
/// The resulting `RelayMap` contains `RelayNode`s with the default quic address
119+
/// discovery port.
116120
impl FromIterator<(RelayUrl, u16)> for RelayMap {
117121
fn from_iter<T: IntoIterator<Item = (RelayUrl, u16)>>(iter: T) -> Self {
118122
Self {

iroh/examples/transfer.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ use indicatif::HumanBytes;
1010
use iroh::{
1111
discovery::{dns::DnsDiscovery, pkarr::PkarrPublisher},
1212
endpoint::{ConnectionError, PathSelection},
13-
Endpoint, NodeAddr, RelayMap, RelayMode, RelayUrl, SecretKey,
13+
Endpoint, NodeAddr, RelayMode, RelayUrl, SecretKey,
1414
};
1515
use iroh_base::ticket::NodeTicket;
1616
use tracing::info;

iroh/src/net_report.rs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -877,11 +877,9 @@ pub(crate) mod stun_utils {
877877
mod test_utils {
878878
//! Creates a relay server against which to perform tests
879879
880-
use std::sync::Arc;
881-
882880
use iroh_relay::{server, RelayNode, RelayQuicConfig};
883881

884-
pub(crate) async fn relay() -> (server::Server, Arc<RelayNode>) {
882+
pub(crate) async fn relay() -> (server::Server, RelayNode) {
885883
let server = server::Server::spawn(server::testing::server_config())
886884
.await
887885
.expect("should serve relay");
@@ -895,7 +893,7 @@ mod test_utils {
895893
quic,
896894
};
897895

898-
(server, Arc::new(node_desc))
896+
(server, node_desc)
899897
}
900898

901899
/// Create a [`crate::RelayMap`] of the given size.

iroh/src/net_report/reportgen.rs

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1455,6 +1455,8 @@ mod tests {
14551455
let (_server_b, relay_b) = test_utils::relay().await;
14561456

14571457
let mut report = Report::default();
1458+
let relay_a = Arc::new(relay_a);
1459+
let relay_b = Arc::new(relay_b);
14581460

14591461
// A STUN IPv4 probe from the the first relay server.
14601462
let probe_report_a = ProbeReport {
@@ -1539,6 +1541,8 @@ mod tests {
15391541
async fn test_update_report_icmp() {
15401542
let (_server_a, relay_a) = test_utils::relay().await;
15411543
let (_server_b, relay_b) = test_utils::relay().await;
1544+
let relay_a = Arc::new(relay_a);
1545+
let relay_b = Arc::new(relay_b);
15421546

15431547
let mut report = Report::default();
15441548

@@ -1652,7 +1656,7 @@ mod tests {
16521656
let addr = server.stun_addr().expect("test relay serves stun");
16531657
let probe = Probe::IcmpV4 {
16541658
delay: Duration::from_secs(0),
1655-
node,
1659+
node: Arc::new(node),
16561660
};
16571661

16581662
// A single ICMP packet might get lost. Try several and take the first.
@@ -1717,6 +1721,7 @@ mod tests {
17171721
#[traced_test]
17181722
async fn test_quic_probe() -> TestResult {
17191723
let (server, relay) = test_utils::relay().await;
1724+
let relay = Arc::new(relay);
17201725
let client_config = iroh_relay::client::make_dangerous_client_config();
17211726
let ep = quinn::Endpoint::client(SocketAddr::new(Ipv4Addr::LOCALHOST.into(), 0))?;
17221727
let client_addr = ep.local_addr()?;
@@ -1730,7 +1735,7 @@ mod tests {
17301735
let port = server.quic_addr().unwrap().port();
17311736
let probe = Probe::QuicIpv4 {
17321737
delay: Duration::from_secs(0),
1733-
node: relay.clone(),
1738+
node: relay,
17341739
};
17351740
let probe = match run_quic_probe(
17361741
quic_addr_disc,

0 commit comments

Comments
 (0)