astelm/telemt
1
0
Fork 0
mirror of https://github.com/telemt/telemt.git synced 2026-04-16 01:54:11 +03:00
Code Issues Packages Projects Releases Wiki Activity

Update admission.rs

Browse Source
This commit is contained in:
Alexey
2026-03-09 13:44:27 +03:00
committed by GitHub
parent 6de17ae830
commit 97926b05e8
1 changed files with 5 additions and 5 deletions
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);
let _ = route_runtime.set_mode(RelayRouteMode::Middle);
if initial_ready {
info!("Conditional-admission gate: open (ME pool ready)");
info!("Conditional-admission gate: open / ME pool READY");
} 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();
@@ -96,10 +96,10 @@ pub(crate) async fn configure_admission_gate(
if next_fallback_active {
warn!("Conditional-admission gate opened in ME fallback mode");
} else {
info!("Conditional-admission gate opened (ME pool ready)");
info!("Conditional-admission gate opened / ME pool READY");
}
} 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 {
admission_tx.send_replace(false);
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 {
admission_tx.send_replace(true);