mab122
/
radicle-heartwood-lfs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

node: Connect to preferred seeds 

Make sure we connect to and keep connected to preferred seeds.
This commit is contained in:
Alexis Sellier 2024-03-19 17:12:28 +01:00 committed by cloudhead
parent 3aca2a11b0
commit 8b1dc8f168
No known key found for this signature in database
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
radicle-node/src/main.rs
View File

@ -103,15 +103,19 @@ fn execute() -> anyhow::Result<()> {
log::info!(target: "node", "Node ID is {}", signer.public_key()); log::info!(target: "node", "Node ID is {}", signer.public_key());
let config = options.config.unwrap_or_else(|| home.config()); let config = options.config.unwrap_or_else(|| home.config());
let config = profile::Config::load(&config)?.node; let mut config = profile::Config::load(&config)?;
// Add the preferred seeds as persistent peers so that we reconnect to them automatically.
config.node.connect.extend(config.preferred_seeds);
let proxy = net::SocketAddr::new(net::Ipv4Addr::LOCALHOST.into(), 9050); let proxy = net::SocketAddr::new(net::Ipv4Addr::LOCALHOST.into(), 9050);
let listen: Vec<std::net::SocketAddr> = if !options.listen.is_empty() { let listen: Vec<std::net::SocketAddr> = if !options.listen.is_empty() {
options.listen.clone() options.listen.clone()
} else { } else {
config.listen.clone() config.node.listen.clone()
}; };
if let Err(e) = radicle::io::set_file_limit(config.limits.max_open_files as u64) { if let Err(e) = radicle::io::set_file_limit(config.node.limits.max_open_files as u64) {
log::warn!(target: "node", "Unable to set process open file limit: {e}"); log::warn!(target: "node", "Unable to set process open file limit: {e}");
} }
@ -122,7 +126,7 @@ fn execute() -> anyhow::Result<()> {
log::debug!(target: "node", "Removing existing control socket.."); log::debug!(target: "node", "Removing existing control socket..");
fs::remove_file(home.socket()).ok(); fs::remove_file(home.socket()).ok();
} }
Runtime::init(home, config, listen, proxy, signals, signer)?.run()?; Runtime::init(home, config.node, listen, proxy, signals, signer)?.run()?;
Ok(()) Ok(())
} }