mirror/Easytier
1
0
Fork 0
mirror of https://github.com/EasyTier/EasyTier.git synced 2026-08-07 04:59:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

server: use select! for run

Browse Source
This commit is contained in:
Luna Yao
2026-02-23 00:05:11 +01:00
parent 0c8da66a74
commit 238858ebab
1 changed files with 36 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files
easytier/src/dns/server.rs
+36 -30
View File
@@ -225,40 +225,46 @@ impl DnsServer {
let dirty = &self.mgr.dirty;
let mut runtime = None;
tokio::join!(
async {
loop {
dirty.catalog.notified().await;
if dirty.catalog.reset() {
self.catalog.replace(self.mgr.catalog()).await;
}
tokio::time::sleep(Duration::from_secs(1)).await;
let reload_catalog = async {
loop {
dirty.catalog.notified().await;
if dirty.catalog.reset() {
self.catalog.replace(self.mgr.catalog()).await;
}
},
async {
loop {
dirty.addresses.notified().await;
if dirty.addresses.reset() {
self.reload_addresses(self.mgr.iter_addresses()).await;
}
tokio::time::sleep(Duration::from_secs(1)).await;
tokio::time::sleep(Duration::from_secs(1)).await;
}
};
let reload_addresses = async {
loop {
dirty.addresses.notified().await;
if dirty.addresses.reset() {
self.reload_addresses(self.mgr.iter_addresses()).await;
}
},
async {
loop {
dirty.listeners.notified().await;
if dirty.listeners.reset() {
if let Err(e) = self
.reload_listeners(self.mgr.iter_listeners(), &mut runtime)
.await
{
tracing::error!("failed to reload listeners: {:?}", e);
dirty.listeners.mark();
}
tokio::time::sleep(Duration::from_secs(1)).await;
}
};
let reload_listeners = async {
loop {
dirty.listeners.notified().await;
if dirty.listeners.reset() {
if let Err(e) = self
.reload_listeners(self.mgr.iter_listeners(), &mut runtime)
.await
{
tracing::error!("failed to reload listeners: {:?}", e);
dirty.listeners.mark();
}
tokio::time::sleep(Duration::from_secs(1)).await;
}
},
tokio::time::sleep(Duration::from_secs(1)).await;
}
};
tokio::select!(
_ = reload_catalog => {},
_ = reload_addresses => {},
_ = reload_listeners => {},
);
self.reload_addresses(iter::empty()).await;