astelm
/
telemt
mirror of https://github.com/telemt/telemt.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #380 from telemt/maestro 

Update admission.rs
This commit is contained in:
Alexey 2026-03-09 13:44:39 +03:00 committed by GitHub
parent 6de17ae830 97926b05e8
commit 4b49b1b4f0
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/maestro/admission.rs
View File

@ -22,9 +22,9 @@ pub(crate) async fn configure_admission_gate(
admission_tx.send_replace(initial_ready); admission_tx.send_replace(initial_ready);
let _ = route_runtime.set_mode(RelayRouteMode::Middle); let _ = route_runtime.set_mode(RelayRouteMode::Middle);
if initial_ready { if initial_ready {
info!("Conditional-admission gate: open (ME pool ready)"); info!("Conditional-admission gate: open / ME pool READY");
} else { } else {
warn!("Conditional-admission gate: closed (ME pool is not ready)"); warn!("Conditional-admission gate: closed / ME pool is NOT ready)");
} }
let pool_for_gate = pool.clone(); let pool_for_gate = pool.clone();
@ -96,10 +96,10 @@ pub(crate) async fn configure_admission_gate(
if next_fallback_active { if next_fallback_active {
warn!("Conditional-admission gate opened in ME fallback mode"); warn!("Conditional-admission gate opened in ME fallback mode");
} else { } else {
info!("Conditional-admission gate opened (ME pool ready)"); info!("Conditional-admission gate opened / ME pool READY");
} }
} else { } else {
warn!("Conditional-admission gate closed (ME pool is not ready)"); warn!("Conditional-admission gate closed / ME pool is NOT ready");
} }
} }
} }
@ -107,7 +107,7 @@ pub(crate) async fn configure_admission_gate(
} else { } else {
admission_tx.send_replace(false); admission_tx.send_replace(false);
let _ = route_runtime.set_mode(RelayRouteMode::Direct); let _ = route_runtime.set_mode(RelayRouteMode::Direct);
warn!("Conditional-admission gate: closed (ME pool is unavailable)"); warn!("Conditional-admission gate: closed / ME pool is UNAVAILABLE");
} }
} else { } else {
admission_tx.send_replace(true); admission_tx.send_replace(true);