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:22:55 +0200
commit215735c94b57fc190ec2adc77f9af500c00f0d41 (patch)
tree3f3313c2ba03eab41b9bc25af148e812b2c58637 /src/state.rs
parent13d3fa4ca2d50b61cab8a9410d097f93797defce (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 9db5ce9..0f981e6 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