INNER CODE UNIT · Python

_close_owned_socket

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

    def _close_owned_socket(request: Any) -> None:
        try:
            request.shutdown(socket.SHUT_RDWR)
        except (AttributeError, OSError, ValueError):
            pass
        try:
            request.close()
        except (AttributeError, OSError, ValueError):
            pass

    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

View source record →