diff options
Diffstat (limited to 'src/state.rs')
| -rw-r--r-- | src/state.rs | 8 |
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 |