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

Implement background cleanup task for user-stats 

Added a background task to clean up stale user-stats entries, improving performance under high connection counts.
This commit is contained in:
Talya 2026-03-23 01:42:31 +01:00 committed by GitHub
parent 8d82a1597f
commit c2432da61d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/maestro/mod.rs
View File

@ -220,6 +220,12 @@ pub async fn run() -> std::result::Result<(), Box<dyn std::error::Error>> {
let stats = Arc::new(Stats::new()); let stats = Arc::new(Stats::new());
stats.apply_telemetry_policy(TelemetryPolicy::from_config(&config.general.telemetry)); stats.apply_telemetry_policy(TelemetryPolicy::from_config(&config.general.telemetry));
// Spawn background task to periodically clean up stale user-stats entries.
// This replaces per-packet maybe_cleanup_user_stats() calls that were removed
// from the I/O hot path to reduce DashMap write-lock contention under high
// connection counts.
let _stats_cleanup_task = stats.spawn_cleanup_task();
let upstream_manager = Arc::new(UpstreamManager::new( let upstream_manager = Arc::new(UpstreamManager::new(
config.upstreams.clone(), config.upstreams.clone(),
config.general.upstream_connect_retry_attempts, config.general.upstream_connect_retry_attempts,