summaryrefslogtreecommitdiffstats
path: root/src/state
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-26 19:21:13 +0100
committertv <tv@krebsco.de>2026-10-26 19:21:13 +0100
commit9a165fd06a1b52bb943a84f26adf8dec72056143 (patch)
treede83e9ab1a64e99b370e7102aceccb49b5def43c /src/state
parentf819296674debea160f19a61d09ac1eea4462820 (diff)
add pull queue
Diffstat (limited to 'src/state')
-rw-r--r--src/state/mod.rs4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/state/mod.rs b/src/state/mod.rs
index 962d62a..04bdb3c 100644
--- a/src/state/mod.rs
+++ b/src/state/mod.rs
@@ -117,8 +117,8 @@ pub(crate) struct AppState {
pub(crate) rtt: Arc<std::sync::Mutex<crate::swarm::rtt::RttTable>>,
/// Sync throughput with peers (`swarm::throughput`).
pub(crate) throughput: Arc<std::sync::Mutex<ThroughputTable>>,
- /// The neighbour we are pulling changes from, and since when (`swarm::relay`).
- pub(crate) pulling: Arc<std::sync::Mutex<Option<(String, Instant)>>>,
+ /// Pulls of changes from neighbours (`swarm::relay`).
+ pub(crate) pulling: Arc<std::sync::Mutex<crate::swarm::relay::Pulling>>,
/// An announcement round is scheduled, for changes from these peers
/// (`swarm::relay`).
pub(crate) announce_pending: Arc<std::sync::Mutex<Option<std::collections::HashSet<String>>>>,