Method start_cleanup_thread

apps/proxy/hls_proxy/server.py:302–340

Start background thread for client activity monitoring

(self)

            logging.info(f"First client connected to channel {self.channel_id}")

    def start_cleanup_thread(self):
        """Start background thread for client activity monitoring"""
        def cleanup_loop():
            # Wait for initial connection window
            start_time = time.time()
            while self.cleanup_running and (time.time() - start_time) < Config.INITIAL_CONNECTION_WINDOW:
                if self.first_client_connected:
                    break
                time.sleep(1)
                
            if not self.first_client_connected:
                logging.info(f"Channel {self.channel_id}: No clients connected within {Config.INITIAL_CONNECTION_WINDOW}s window")
                self.proxy_server.stop_channel(self.channel_id)
                return
                
            # Normal client activity monitoring
            while self.cleanup_running and self.running:
                try:
                    timeout = self.target_duration * Config.CLIENT_TIMEOUT_FACTOR
                    if self.client_manager.cleanup_inactive(timeout):
                        logging.info(f"Channel {self.channel_id}: All clients disconnected for {timeout:.1f}s")
                        self.proxy_server.stop_channel(self.channel_id)
                        break
                except Exception as e:
                    logging.error(f"Cleanup error: {e}")
                    if "cannot join current thread" not in str(e):
                        time.sleep(Config.CLIENT_CLEANUP_INTERVAL)
                time.sleep(Config.CLIENT_CLEANUP_INTERVAL)

        if not self.cleanup_started:
            self.cleanup_started = True
            self.cleanup_running = True
            self.cleanup_thread = threading.Thread(
                target=cleanup_loop,
                name=f"Cleanup-{self.channel_id}",
                daemon=True
            )
            self.cleanup_thread.start()
            logging.info(f"Started cleanup thread for channel {self.channel_id}")

class StreamFetcher:
    """