change app.py

app.py

@@ -524,9 +524,11 @@ def auto_start_recording(session):
         
         # Check if we've hit max concurrent sessions - kill all if so
         with _sessions_lock:
-            at_capacity = len(_active_sessions) >= MAX_CONCURRENT_SESSIONS
+            active_at_capacity = len(_active_sessions) >= MAX_CONCURRENT_SESSIONS
+        with _registry_lock:
+            registry_over = len(_session_registry) > MAX_CONCURRENT_SESSIONS
         
-        if at_capacity:
+        if active_at_capacity or registry_over:
             kill_all_sessions()
             session.status_message = "error"
             return get_transcription_html("Server reset due to capacity. Please click the microphone to restart.", "error", "")
@@ -630,13 +632,17 @@ def process_audio(audio, session_id):
     """Process incoming audio and queue for streaming."""
     # Check capacity - if at or above max, kill ALL sessions to reset
     with _sessions_lock:
-        current_count = len(_active_sessions)
-        # Check if THIS user is already active (they can continue)
+        active_count = len(_active_sessions)
         is_active_user = session_id and any(s.session_id == session_id for s in _active_sessions.values())
     
-    # Kill all if at capacity AND this is a new user trying to join
-    # OR if we've exceeded capacity (shouldn't happen, but safety check)
-    if current_count > MAX_CONCURRENT_SESSIONS or (current_count >= MAX_CONCURRENT_SESSIONS and not is_active_user):
+    with _registry_lock:
+        registry_count = len(_session_registry)
+    
+    # Kill all if:
+    # 1. Registry exceeds limit (memory safety)
+    # 2. Active sessions exceed limit
+    # 3. At active capacity AND new user trying to join
+    if registry_count > MAX_CONCURRENT_SESSIONS or active_count > MAX_CONCURRENT_SESSIONS or (active_count >= MAX_CONCURRENT_SESSIONS and not is_active_user):
         kill_all_sessions()
         return get_transcription_html(
             "Server reset due to capacity. Please click the microphone to restart.",