Gecko [ gtgates.com ]

Linux ams-business-8.hostwindsdns.com 4.18.0-553.80.1.lve.el8.x86_64 #1 SMP Wed Oct 22 19:29:36 UTC 2025 x86_64
LiteSpeed
Server IP : 192.236.177.161 & Your IP : 216.73.216.50
Domains : Cant Read [ /etc/named.conf ]
User : ajzdfbpz

Name	Size	Permission	Date
__pycache__	[ DIR ]	drwxr-xr-x	2024-02-12 23:54
__init__.py	121 B	-rw-r--r--	2020-10-08 18:05
adaptive.py	4.09 KB	-rw-r--r--	2020-10-08 18:05
base.py	813 B	-rw-r--r--	2020-10-08 18:05
bucket.py	3.93 KB	-rw-r--r--	2020-10-08 18:05
quota.py	1.92 KB	-rw-r--r--	2020-10-08 18:05
special.py	1.57 KB	-rw-r--r--	2020-10-08 18:05
standard.py	19.12 KB	-rw-r--r--	2020-10-08 18:05
throttling.py	1.75 KB	-rw-r--r--	2020-10-08 18:05

Rename

"""Retry quota implementation.

"""
import threading

class RetryQuota(object):
    INITIAL_CAPACITY = 500

def __init__(self, initial_capacity=INITIAL_CAPACITY, lock=None):
        self._max_capacity = initial_capacity
        self._available_capacity = initial_capacity
        if lock is None:
            lock = threading.Lock()
        self._lock = lock

def acquire(self, capacity_amount):
        """Attempt to aquire a certain amount of capacity.

If there's not sufficient amount of capacity available, ``False``
        is returned.  Otherwise, ``True`` is returned, which indicates that
        capacity was successfully allocated.

"""
        # The acquire() is only called when we encounter a retryable
        # response so we aren't worried about locking the entire method.
        with self._lock:
            if capacity_amount > self._available_capacity:
                return False
            self._available_capacity -= capacity_amount
            return True

def release(self, capacity_amount):
        """Release capacity back to the retry quota.

The capacity being released will be truncated if necessary
        to ensure the max capacity is never exceeded.

"""
        # Implementation note:  The release() method is called as part
        # of the "after-call" event, which means it gets invoked for
        # every API call.  In the common case where the request is
        # successful and we're at full capacity, we can avoid locking.
        # We can't exceed max capacity so there's no work we have to do.
        if self._max_capacity == self._available_capacity:
            return
        with self._lock:
            amount = min(
                self._max_capacity - self._available_capacity,
                capacity_amount
            )
            self._available_capacity += amount

@property
    def available_capacity(self):
        return self._available_capacity