diff options
| author | tv <tv@krebsco.de> | 2026-11-01 13:34:26 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-01 13:34:26 +0100 |
| commit | 1202c0ba9bf49e7e31492c90b37af3e6c91b98b7 (patch) | |
| tree | 72263c64c60c1d99e6e7b4381c032e8d6a4ec990 /src/node.rs | |
| parent | da76a3fd1eeb01b67cf7e281180bd4b677476d48 (diff) | |
state: drop epoch_tx
The stamp is the only lock-free epoch label.
Diffstat (limited to 'src/node.rs')
| -rw-r--r-- | src/node.rs | 2 |
1 files changed, 0 insertions, 2 deletions
diff --git a/src/node.rs b/src/node.rs index 8224c7a..f6bdbb3 100644 --- a/src/node.rs +++ b/src/node.rs @@ -69,7 +69,6 @@ impl Node { let (sync_tx, sync_rx) = mpsc::unbounded_channel(); let (change_tx, _) = watch::channel(0_u64); let (change_events, _) = broadcast::channel(256); - let (epoch_tx, _) = watch::channel(config.initial_epoch); let firewall = Arc::new(Firewall::default()); let traffic = Arc::new(Traffic::default()); let initial_actor = crate::document::actor(&config.initial_doc); @@ -88,7 +87,6 @@ impl Node { let stamp = replica.stamps(); let state = AppState { doc: Arc::new(crate::document::lock::DocumentLock::new(replica)), - epoch_tx, stamp, lifecycle: Arc::new(RwLock::new(NodeLifecycle::Joining { discovered_swarm_id: None, |
