INNER CODE UNIT · Python

process_request

mars-tw/anti-gambling-trader-tw · core/ui/server.py:163

    def process_request(self, request: Any, client_address: Any) -> None:
        """Start only a bounded, tracked handler for this exact server."""

        key = id(request)
        with self._owned_lock:
            if self._owned_closing or len(self._owned_connections) >= _MAX_ACTIVE_HANDLERS:
                reject = True
                worker: threading.Thread | None = None
            else:
                reject = False
                self._owned_connections[key] = request
                worker = threading.Thread(
                    target=self._process_owned_request_thread,
                    args=(request, client_address, key),
                    name=f"ui-request-{key:x}",
                    daemon=False,
                )
                self._owned_handler_threads[key] = worker

View source record →