a

��b�@s6dd
lZddl
mZ
ddlmZmZ
Gdd�d�Zd
S)�N)
�sleep)�ConnectionError�TimeoutErrorc@s:eZ
dZd
Zeeejff
dd�
Ze	d�
dd�Z
dd�Zd	S)
�Retryz0Retry a specific number of times after a failurecCs|
|_||_
||_d
S)a'

        Initialize a `Retry` object with a `Backoff` object
        that retries a maximum of `retries` times.
        `retries` can be negative to retry forever.
        You can specify the types of supported errors which trigger
        a retry with the `supported_errors` parameter.
        N)�_backoff�_retries�_supported_errors)�self�backoffZretriesZsupported_errors�r�//usr/lib/python3.9/site-packages/redis/retry.py�__init__
s


zRetry.__init__)
�specified_errorscCstt
|jt|
�
�
�
|_d
S)zM
        Updates the supported errors with the specified error types
        N)�tuple�setr)r	rrrr�update_supported_errorss
�zRetry.update_supported_errorsc
Cs�|j�
�
d
}z|
�WS|jy�
}
zP|d7}||�

|jd
krP||jkrP|�
|j�|�
}|d
krlt|�

WYd}~qd}~00qdS)a&

        Execute an operation that might fail and returns its result, or
        raise the exception that was thrown depending on the `Backoff` object.
        `do`: the operation to call. Expects no argument.
        `fail`: the failure handler, expects the last error that was thrown
        r
�
N)r�resetrrZcomputer)r	ZdoZfailZfailures�errorr
rrr�call_with_retry#s










zRetry.call_with_retryN)�__name__�
__module__�__qualname__�__doc__rr�socket�timeoutr
�listrrrrrrrs


�
r)r�timerZredis.exceptionsrrrrrrr�<module>
s