Skip to content
This repository was archived by the owner on Dec 10, 2022. It is now read-only.

Commit 46e9699

Browse files
committed
refactor(node): rename server to udp_server
1 parent 7a66862 commit 46e9699

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

src/main.rs

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -237,19 +237,19 @@ fn run_udp(cli_config: &CliConfig, dht_pk: PublicKey, dht_sk: &SecretKey, udp_on
237237
Either::B(future::empty())
238238
};
239239

240-
let mut server = UdpServer::new(tx, dht_pk, dht_sk.clone());
240+
let mut udp_server = UdpServer::new(tx, dht_pk, dht_sk.clone());
241241
let counters = Counters::new(tcp_stats, udp_stats.clone());
242242
let motd = Motd::new(cli_config.motd.clone(), counters);
243-
server.set_bootstrap_info(version(), Box::new(move |_| motd.format().as_bytes().to_owned()));
244-
server.enable_lan_discovery(cli_config.lan_discovery_enabled);
245-
server.set_tcp_onion_sink(udp_onion.tx);
246-
server.enable_ipv6_mode(udp_addr.is_ipv6());
243+
udp_server.set_bootstrap_info(version(), Box::new(move |_| motd.format().as_bytes().to_owned()));
244+
udp_server.enable_lan_discovery(cli_config.lan_discovery_enabled);
245+
udp_server.set_tcp_onion_sink(udp_onion.tx);
246+
udp_server.enable_ipv6_mode(udp_addr.is_ipv6());
247247

248-
let server_c = server.clone();
248+
let udp_server_c = udp_server.clone();
249249
let udp_onion_future = udp_onion.rx
250250
.map_err(|()| unreachable!("rx can't fail"))
251251
.for_each(move |(onion_request, addr)|
252-
server_c.handle_tcp_onion_request(onion_request, addr).or_else(|err| {
252+
udp_server_c.handle_tcp_onion_request(onion_request, addr).or_else(|err| {
253253
warn!("Failed to handle TCP onion request: {:?}", err);
254254
future::ok(())
255255
})
@@ -260,12 +260,12 @@ fn run_udp(cli_config: &CliConfig, dht_pk: PublicKey, dht_sk: &SecretKey, udp_on
260260
}
261261

262262
for node in cli_config.bootstrap_nodes.iter().flat_map(|node| node.resolve()) {
263-
server.add_initial_bootstrap(node);
263+
udp_server.add_initial_bootstrap(node);
264264
}
265265

266266
info!("Running DHT server on {}", udp_addr);
267267

268-
Either::B(server.run_socket(socket, rx, udp_stats).map_err(Error::from)
268+
Either::B(udp_server.run_socket(socket, rx, udp_stats).map_err(Error::from)
269269
.select(lan_discovery_future).map(|_| ()).map_err(|(e, _)| e)
270270
.join(udp_onion_future).map(|_| ()))
271271
}

0 commit comments

Comments
 (0)