INNER CODE UNIT · Python
_expire_owned_connection
mars-tw/anti-gambling-trader-tw · core/ui/server.py:213
def _expire_owned_connection(self, key: int, generation: int) -> None:
"""Enforce an absolute deadline even when a peer drips bytes forever."""
with self._owned_lock:
deadline = self._owned_request_deadlines.get(key)
if deadline is None or deadline[0] != generation:
return
self._owned_request_deadlines.pop(key, None)
request = self._owned_connections.pop(key, None)
if request is not None:
self._close_owned_socket(request)
def _mark_request_input_complete(self, request: Any) -> None:
"""Switch one validated request from input protection to compute protection."""
key = id(request)
with self._owned_lock:
deadline = self._owned_request_deadlines.pop(key, None)