File: //opt/saltstack/salt/lib/python3.10/site-packages/libcloud/utils/__pycache__/retry.cpython-310.pyc
o
;j� � @ s� d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZ d dlm Z d dl
m Z ddgZ e�
e�ZdZG d d
� d
e j�Zd Zd Zd Ze ejeje je jefZG d
d� d�ZG dd� de�Z G dd� de �Z dS )� N)�datetime� timedelta��wraps)�httplib)�RateLimitReachedError�Retry� RetryForeverOnRateLimitErrorz The read operation timed outc @ s e Zd ZdZdS )�TransientSSLErrorz-Represent transient SSL errors, e.g. timeoutsN)�__name__�
__module__� __qualname__�__doc__� r r �H/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/utils/retry.pyr
% s r
� � c @ s, e Zd Zeeefdd�Zdd� Zdd� ZdS )� MinimalRetryc C sD |du rt }|du r t}|du rt}t|d�}|| _|| _|| _dS )a�
Wrapper around retrying that helps to handle common transient
exceptions.
This minimalistic version only retries SSL errors and rate limiting.
:param retry_delay: retry delay between the attempts.
:param timeout: maximum time to wait.
:param backoff: multiplier added to delay between attempts.
:Example:
retry_request = MinimalRetry(timeout=1, retry_delay=1, backoff=1)
retry_request(self.connection.request)()
Nr )�
DEFAULT_DELAY�DEFAULT_TIMEOUT�DEFAULT_BACKOFF�max� retry_delay�timeout�backoff)�selfr r r r r r �__init__; s
zMinimalRetry.__init__c �$ dd� �t � �� ��fdd��}|S )Nc
_ �F z| |i |��W S t jy" } z
tt|�v r t|j� �|�d }~ww �N��ssl�SSLError�TRANSIENT_SSL_ERROR�strr
�args��functionr% �kwargs�excr r r �transform_ssl_error_ �
��z2MinimalRetry.__call__.<locals>.transform_ssl_errorc
s� �j }t�� t�jd� }d }t�� |k rhz �� g| �R i |��W S tya } z4|}t|t�rFt� d� |j
r;|j
nd}t � |� �j }n��
|�rVt � |� |�j9 }n� W Y d }~nd }~ww t�� |k s|�)N��secondsz*You are being rate limited, backing off...� )r r �nowr r � Exception�
isinstancer �_logger�debug� retry_after�time�sleep� should_retryr )r% r( �
current_delay�end�last_excr) r4 ��funcr r* r r �
retry_looph s*
�� �z)MinimalRetry.__call__.<locals>.retry_loopr �r r< r= r r; r �__call__^ s zMinimalRetry.__call__c C s dS )NFr �r � exceptionr r r r7 � s zMinimalRetry.should_retryN) r r r
r r r r r? r7 r r r r r : s
�# -r c s. e Zd Zeeeef� fdd� Zdd� Z� Z S )r c s( t � j|||d� |du rt}|| _dS )a�
Wrapper around retrying that helps to handle common transient
exceptions.
This version retries the errors that
`libcloud.utils.retry:MinimalRetry` retries and all errors of the
exception types that are given.
:param retry_exceptions: types of exceptions to retry on.
:param retry_delay: retry delay between the attempts.
:param timeout: maximum time to wait.
:param backoff: multiplier added to delay between attempts.
:Example:
retry_request = Retry(retry_exceptions=(httplib.NotConnected,),
timeout=1, retry_delay=1, backoff=1)
retry_request(self.connection.request)()
)r r r N)�superr �RETRY_EXCEPTIONS�retry_exceptions)r rD r r r �� __class__r r r � s
zRetry.__init__c C s t |t| j��S r )r1 �tuplerD r@ r r r r7 � s zRetry.should_retry)
r r r
rC r r r r r7 �
__classcell__r r rE r r � s � c @ s e Zd ZdZdd� ZdS )r a�
This class is only here for backward compatibility reasons with
pre-Libcloud v3.3.2.
If works by ignoring timeout argument and retrying forever until API
is returning 429 RateLimitReached errors.
In most cases using this class is not a good idea since it can cause code
to hang and retry for ever in case API continues to return retry limit
reached.
c r )Nc
_ r r r r& r r r r* � r+ zBRetryForeverOnRateLimitError.__call__.<locals>.transform_ssl_errorc
s� �j }t�� t�jd� } z �� g| �R i |��W S ty` } z:t|t�r>t� |j
� �j }t�� t|j
�j d� }nt�� |krE� �� |�rUt� |� |�j 9 }n� W Y d }~nd }~ww q)Nr, )
r r r/ r r r0 r1 r r5 r6 r4 r7 r )r% r( r8 r9 r) r; r r r= � s&
���z9RetryForeverOnRateLimitError.__call__.<locals>.retry_loopr r> r r; r r? � s z%RetryForeverOnRateLimitError.__call__N)r r r
r r? r r r r r � s ) r! r5 �socket�loggingr r � functoolsr Zlibcloud.utils.py3r Zlibcloud.common.exceptionsr �__all__� getLoggerr r2 r# r" r
r r r �error�gaierror� NotConnected�ImproperConnectionStaterC r r r r r r r �<module> s6 �
�
U%