mirror/Easytier
1
0
Fork 0
mirror of https://github.com/EasyTier/EasyTier.git synced 2026-09-02 09:09:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

peer_mgr: rename cache to peers, extract ttl as a const

Browse Source
This commit is contained in:
Luna Yao
2026-04-06 11:54:01 +02:00
parent 070332b9a7
commit 7b1b651a46
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
easytier/src/dns/peer_mgr.rs
+9 -7
View File
@@ -30,13 +30,15 @@ impl DnsPeerInfo {
} }
} }
const DNS_PEER_TTL: Duration = Duration::from_secs(3);
#[derive(Derivative, Deref)] #[derive(Derivative, Deref)]
#[derivative(Debug)] #[derivative(Debug)]
pub struct DnsPeerMgr { pub struct DnsPeerMgr {
#[deref] #[deref]
mgr: Arc<PeerManager>, mgr: Arc<PeerManager>,
cache: Cache<PeerId, DnsPeerInfo>, peers: Cache<PeerId, DnsPeerInfo>,
pub(super) dirty: AtomicBool, pub(super) dirty: AtomicBool,
} }
@@ -44,8 +46,8 @@ impl DnsPeerMgr {
pub fn new(peer_mgr: Arc<PeerManager>) -> Self { pub fn new(peer_mgr: Arc<PeerManager>) -> Self {
Self { Self {
mgr: peer_mgr.clone(), mgr: peer_mgr.clone(),
cache: Cache::builder() peers: Cache::builder()
.time_to_live(Duration::from_secs(5)) .time_to_live(DNS_PEER_TTL)
.build() .build()
.into(), .into(),
dirty: AtomicBool::new(true), dirty: AtomicBool::new(true),
@@ -61,7 +63,7 @@ impl DnsPeerMgr {
zones.extend(config.zones.iter().map(Into::into)); zones.extend(config.zones.iter().map(Into::into));
zones.extend(global_ctx.dns_self_zone().as_ref().map(Into::into)); zones.extend(global_ctx.dns_self_zone().as_ref().map(Into::into));
for (_, info) in self.cache.iter() { for (_, info) in self.peers.iter() {
zones.extend(info.config.zones.clone().into_iter()); zones.extend(info.config.zones.clone().into_iter());
} }
@@ -83,7 +85,7 @@ impl DnsPeerMgr {
} }
pub(super) async fn refresh(&self, peer_id: PeerId, digest: Vec<u8>) { pub(super) async fn refresh(&self, peer_id: PeerId, digest: Vec<u8>) {
if let Some(info) = self.cache.get(&peer_id).await { if let Some(info) = self.peers.get(&peer_id).await {
if info.digest == *digest { if info.digest == *digest {
return; return;
} }
@@ -91,11 +93,11 @@ impl DnsPeerMgr {
match self.fetch(peer_id).await { match self.fetch(peer_id).await {
Ok(config) => { Ok(config) => {
self.cache.insert(peer_id, DnsPeerInfo::new(config)).await; self.peers.insert(peer_id, DnsPeerInfo::new(config)).await;
} }
Err(e) => { Err(e) => {
tracing::warn!("failed to fetch dns config from peer {}: {:?}", peer_id, e); tracing::warn!("failed to fetch dns config from peer {}: {:?}", peer_id, e);
self.cache.invalidate(&peer_id).await; self.peers.invalidate(&peer_id).await;
} }
} }