Method _timeout_connections

dshell/core.py:688–707

Checks for and force closes connections that have been alive for too long. It also closes the oldest connections if too many connections are open.

(self, timestamp: datetime.datetime)

        return True

    def _timeout_connections(self, timestamp: datetime.datetime):
        """
        Checks for and force closes connections that have been alive for too long.
        It also closes the oldest connections if too many connections are open.
        """
        # Force close any connections that have timed out.
        # This is based on comparing the time of the current packet, minus
        # self.timeout, to each connection's current endtime value.
        for conn in list(self._connection_tracker.values()):
            if conn.endtime < (timestamp - self.timeout):
                self._close_connection(conn)

        # Force close oldest connections if we have too many.
        if len(self._connection_tracker) > self.max_open_connections:
            connections = sorted(self._connection_tracker.values(), key=lambda conn: conn.endtime, reverse=True)
            for conn in connections[self.max_open_connections:]:
                self._close_connection(conn)

        # We can produce connections again, now that we have handled lingering old connections.
        self._production_ready = True

    def _cleanup_connections(self):
        """