From 2c2bcf761fda888844a8538e756c8dbb9986a51f Mon Sep 17 00:00:00 2001 From: tv Date: Wed, 21 Oct 2026 03:22:55 +0200 Subject: reorganize all the modules --- src/state.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'src/state.rs') diff --git a/src/state.rs b/src/state.rs index e7c1767..18bface 100644 --- a/src/state.rs +++ b/src/state.rs @@ -13,10 +13,10 @@ use tokio::time::Instant; use tracing::{debug, error, warn}; use crate::compaction::{Compaction, Host, PeerSummary}; -use crate::firewall::Firewall; -use crate::replica::{Epoch, Replica}; -use crate::sync::{ChangeSet, SyncEvent}; +use crate::document::replica::{Epoch, Replica}; +use crate::swarm::sync::{ChangeSet, SyncEvent}; use crate::transport; +use crate::transport::firewall::Firewall; #[derive(Debug, Clone, PartialEq, Eq)] pub(crate) enum NodeLifecycle { @@ -539,7 +539,7 @@ impl AppState { // Tell peers about the new epoch now instead of with the next keepalive (up to a // keepalive interval later): sync with peers already on it resumes right away, // and peers that never saw the commit start catching up. - let keepalive = crate::peer::local_keepalive(self).await; + let keepalive = crate::swarm::peer::local_keepalive(self).await; for (id, _) in &peers { if let Err(error) = self .transport -- cgit v1.3.1