Method borrow_connection

cassandra/pool.py:424–453

(self, timeout)

        return conn

    def borrow_connection(self, timeout):
        conn = self._get_connection()
        if conn.orphaned_threshold_reached:
            with self._lock:
                if not self._is_replacing:
                    self._is_replacing = True
                    self._session.submit(self._replace, conn)
                    log.debug(
                        "Connection to host %s reached orphaned stream limit, replacing...",
                        self.host
                    )

        start = time.time()
        remaining = timeout
        while True:
            with conn.lock:
                if not (conn.orphaned_threshold_reached and conn.is_closed) and conn.in_flight < conn.max_request_id:
                    conn.in_flight += 1
                    return conn, conn.get_request_id()
            if timeout is not None:
                remaining = timeout - time.time() + start
                if remaining < 0:
                    break
            with self._stream_available_condition:
                if conn.orphaned_threshold_reached and conn.is_closed:
                    conn = self._get_connection()
                else:
                    self._stream_available_condition.wait(remaining)

        raise NoConnectionsAvailable("All request IDs are currently in use")

    def return_connection(self, connection, stream_was_orphaned=False):
        if not stream_was_orphaned: