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

node: Make git daemon listen configurable

This commit is contained in:
Alexis Sellier 2023-01-30 13:44:38 +01:00
parent 498a5c4e4a
commit 03b94c81a0
No known key found for this signature in database
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -14,6 +14,7 @@ use radicle_node::{logger, service};
struct Options { struct Options {
connect: Vec<(NodeId, Address)>, connect: Vec<(NodeId, Address)>,
external_addresses: Vec<Address>, external_addresses: Vec<Address>,
daemon: Option<net::SocketAddr>,
limits: service::config::Limits, limits: service::config::Limits,
listen: Vec<net::SocketAddr>, listen: Vec<net::SocketAddr>,
} }
@ -27,6 +28,7 @@ impl Options {
let mut external_addresses = Vec::new(); let mut external_addresses = Vec::new();
let mut limits = service::config::Limits::default(); let mut limits = service::config::Limits::default();
let mut listen = Vec::new(); let mut listen = Vec::new();
let mut daemon = None;
while let Some(arg) = parser.next()? { while let Some(arg) = parser.next()? {
match arg { match arg {
@ -38,6 +40,10 @@ impl Options {
let addr = parser.value()?.parse()?; let addr = parser.value()?.parse()?;
external_addresses.push(addr); external_addresses.push(addr);
} }
Long("git-daemon") => {
let addr = parser.value()?.parse()?;
daemon = Some(addr);
}
Long("limit-routing-max-age") => { Long("limit-routing-max-age") => {
let secs: u64 = parser.value()?.parse()?; let secs: u64 = parser.value()?.parse()?;
limits.routing_max_age = LocalDuration::from_secs(secs); limits.routing_max_age = LocalDuration::from_secs(secs);
@ -66,6 +72,7 @@ impl Options {
Ok(Self { Ok(Self {
connect, connect,
daemon,
external_addresses, external_addresses,
limits, limits,
listen, listen,
@ -90,7 +97,12 @@ fn execute() -> anyhow::Result<()> {
..service::Config::default() ..service::Config::default()
}; };
let proxy = net::SocketAddr::new(net::Ipv4Addr::LOCALHOST.into(), 9050); let proxy = net::SocketAddr::new(net::Ipv4Addr::LOCALHOST.into(), 9050);
let daemon = ([0, 0, 0, 0], 9418).into(); let daemon = options.daemon.unwrap_or_else(|| {
net::SocketAddr::new(
net::Ipv4Addr::UNSPECIFIED.into(),
radicle::git::PROTOCOL_PORT,
)
});
Runtime::init(home, config, options.listen, proxy, daemon, signer)?.run()?; Runtime::init(home, config, options.listen, proxy, daemon, signer)?.run()?;