summaryrefslogtreecommitdiffstats
path: root/src/state.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-21 03:22:55 +0200
committertv <tv@krebsco.de>2026-10-21 03:31:44 +0200
commit2c2bcf761fda888844a8538e756c8dbb9986a51f (patch)
tree3711b6a9988b6203455f80e704f8c393e5d3d2c9 /src/state.rs
parent55acf6f276efa952da7bb6f8e0377791549f3ea1 (diff)
reorganize all the modules
Diffstat (limited to 'src/state.rs')
-rw-r--r--src/state.rs8
1 files changed, 4 insertions, 4 deletions
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