From 5247296250355b7f75a993856d3675f73114d253 Mon Sep 17 00:00:00 2001 From: tv Date: Mon, 26 Oct 2026 20:38:07 +0100 Subject: remove some dead comments --- src/state/mod.rs | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) (limited to 'src/state/mod.rs') diff --git a/src/state/mod.rs b/src/state/mod.rs index beac886..787fd8c 100644 --- a/src/state/mod.rs +++ b/src/state/mod.rs @@ -57,8 +57,6 @@ pub(crate) struct AppState { pub(crate) lifecycle: Arc>, - // Serializes swarm-ID establishment, peer membership, and readiness transitions. - //[concurrent]swarm_validation: Arc>, pub(crate) peer_states: Arc>>>>, pub(crate) transport: Arc, pub(crate) firewall: Arc, @@ -69,7 +67,8 @@ pub(crate) struct AppState { pub(crate) sync_events: mpsc::UnboundedSender, - // TODO see key_watchers.md ("Use a per-key notification registry instead of the global `watch`") + /// The document's version: bumped after every change (`notify_store_changed`). The + /// change publisher (`swarm::sync`) waits on it; a measurement compares it. pub(crate) change_tx: watch::Sender, pub(crate) initial_sync_done: Arc, @@ -212,7 +211,6 @@ impl AppState { // Record the expected swarm without making the node Ready. Bootstrap owns readiness. pub(crate) async fn set_expected_swarm_id(&self, swarm_id: String) -> Result<()> { - //[concurrent]let _guard = self.swarm_validation.lock().await; let mut lifecycle = self.lifecycle.write().await; match &*lifecycle { NodeLifecycle::Joining { @@ -256,7 +254,6 @@ impl AppState { // Only bootstrap should call this, after validating document metadata. pub(crate) async fn mark_ready(&self, swarm_id: String) -> Result<()> { - //[concurrent]let _guard = self.swarm_validation.lock().await; let mut lifecycle = self.lifecycle.write().await; match &*lifecycle { NodeLifecycle::Joining { -- cgit v1.3.1