aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2023-03-09 16:49:56 +0100
committerAlex Auvolat <alex@adnab.me>2023-03-09 16:49:56 +0100
commitc96aec520dbf18f11455001f1db9b4f068c10528 (patch)
tree7fe50bf0fadae3d362213869bcb639d4a6396291 /src
parent43eced6e9aa5935b4553251604207f72bf0214c1 (diff)
downloadwgautomesh-c96aec520dbf18f11455001f1db9b4f068c10528.tar.gz
wgautomesh-c96aec520dbf18f11455001f1db9b4f068c10528.zip
persist gossip state to disk
Diffstat (limited to 'src')
-rw-r--r--src/main.rs39
1 files changed, 37 insertions, 2 deletions
diff --git a/src/main.rs b/src/main.rs
index 7b95d4d..04e655c 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -21,6 +21,8 @@ const TIMEOUT: Duration = Duration::from_secs(300);
/// Interval at which to gossip last_seen info
const GOSSIP_INTERVAL: Duration = Duration::from_secs(300);
+const PERSIST_INTERVAL: Duration = Duration::from_secs(600);
+
const LAN_BROADCAST_INTERVAL: Duration = Duration::from_secs(60);
const IGD_INTERVAL: Duration = Duration::from_secs(60);
@@ -37,6 +39,8 @@ struct Config {
/// The secret to use to authenticate nodes between them
gossip_secret: Option<String>,
gossip_secret_file: Option<String>,
+ /// The file where to persist known peer addresses
+ persist_file: Option<String>,
/// Enable LAN discovery
#[serde(default)]
@@ -187,6 +191,14 @@ impl Daemon {
let (our_pubkey, listen_port, _peers) = wg_dump(&config)?;
let socket = UdpSocket::bind(SocketAddr::new("0.0.0.0".parse()?, config.gossip_port))?;
socket.set_broadcast(true)?;
+
+ let gossip = config
+ .persist_file
+ .as_ref()
+ .and_then(|x| std::fs::read(x).ok())
+ .and_then(|x| bincode::deserialize(&x).ok())
+ .unwrap_or_default();
+
Ok(Daemon {
config,
gossip_key,
@@ -195,7 +207,7 @@ impl Daemon {
socket,
state: Mutex::new(State {
peers: HashMap::new(),
- gossip: HashMap::new(),
+ gossip,
}),
})
}
@@ -216,6 +228,7 @@ impl Daemon {
thread::scope(|s| {
s.spawn(|| self.wg_loop());
s.spawn(|| self.recv_loop());
+ s.spawn(|| self.persist_loop());
s.spawn(|| self.lan_broadcast_loop());
s.spawn(|| self.igd_loop());
});
@@ -335,6 +348,23 @@ impl Daemon {
Ok((src, gossip))
}
+ fn persist_loop(&self) {
+ if let Some(file) = &self.config.persist_file {
+ loop {
+ if let Err(e) = self.persist_state(file) {
+ error!("Could not write persistent state to disk: {}", e);
+ }
+ std::thread::sleep(PERSIST_INTERVAL);
+ }
+ }
+ }
+
+ fn persist_state(&self, file: &str) -> Result<()> {
+ let data = bincode::serialize(&self.state.lock().unwrap().gossip)?;
+ std::fs::write(file, &data)?;
+ Ok(())
+ }
+
fn lan_broadcast_loop(&self) {
if self.config.lan_discovery {
loop {
@@ -603,7 +633,12 @@ impl State {
if !endpoints.is_empty() {
let endpoint = endpoints[i % endpoints.len()].0;
- if self.peers.get(&peer_cfg.pubkey).map(|x| x.endpoint == Some(endpoint)).unwrap_or(false) {
+ if self
+ .peers
+ .get(&peer_cfg.pubkey)
+ .map(|x| x.endpoint == Some(endpoint))
+ .unwrap_or(false)
+ {
// Skip if we are already using that endpoint
continue;
}