| Server IP : 127.0.1.1 / Your IP : 216.73.216.17 Web Server : Apache/2.4.58 (Ubuntu) System : Linux dalsi.io 6.8.0-117-generic #117-Ubuntu SMP PREEMPT_DYNAMIC Tue May 5 19:26:24 UTC 2026 x86_64 User : www-data ( 33) PHP Version : 8.3.6 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /lib/python3/dist-packages/redis/__pycache__/ |
Upload File : |
�
���bo
� � � d dl Z d dlmZmZ G d� de� Z G d� de� Z G d� de� Z G d � d
e� Z G d � d e� Z G d
� de� Z G d� de� Z
y)� N)�ABC�abstractmethodc �& � e Zd ZdZd� Zed� � Zy)�AbstractBackoffzBackoff interfacec � � y)z�
Reset internal state before an operation.
`reset` is called once at the beginning of
every call to `Retry.call_with_retry`
N� ��selfs �//usr/lib/python3/dist-packages/redis/backoff.py�resetzAbstractBackoff.reset s � �
� c � � y)z'Compute backoff in seconds upon failureNr �r
�failuress r �computezAbstractBackoff.compute s � �
r
N)�__name__�
__module__� __qualname__�__doc__r r r r r
r r r s � ��
� �
� �
r
r c � � e Zd ZdZd� Zd� Zy)�ConstantBackoffz Constant backoff upon failurec � � || _ y)z"`backoff`: backoff time in secondsN��_backoff)r
�backoffs r �__init__zConstantBackoff.__init__ s � � ��
r
c � � | j S )Nr r s r r zConstantBackoff.compute s � ��}�}� r
N�r r r r r r r r
r r r s � �'� � r
r c �" � � e Zd ZdZ� fd�Z� xZS )� NoBackoffzNo backoff upon failurec �$ �� t �| � d� y �Nr )�superr )r
� __class__s �r r zNoBackoff.__init__$ s �� �
����r
)r r r r r �
__classcell__)r$ s @r r r ! s �� �!� � r
r c � � e Zd ZdZd� Zd� Zy)�ExponentialBackoffz Exponential backoff upon failurec � � || _ || _ y��e
`cap`: maximum backoff time in seconds
`base`: base backoff time in seconds
N��_cap�_base�r
�cap�bases r r zExponentialBackoff.__init__+ � � �
�� ���
r
c �N � t | j | j d|z z � S )N� )�minr, r- r s r r zExponentialBackoff.compute3 s � ��4�9�9�d�j�j�1�h�;� 6�7�7r
Nr r r
r r' r' ( s � �*��8r
r' c � � e Zd ZdZd� Zd� Zy)�FullJitterBackoffz Full jitter backoff upon failurec � � || _ || _ yr) r+ r. s r r zFullJitterBackoff.__init__: r1 r
c �v � t j dt | j | j d|z z � � S )Nr r3 )�random�uniformr4 r, r- r s r r zFullJitterBackoff.computeB s+ � ��~�~�a��T�Y�Y��
�
�Q��[�0H�!I�J�Jr
Nr r r
r r6 r6 7 s � �*��Kr
r6 c � � e Zd ZdZd� Zd� Zy)�EqualJitterBackoffz!Equal jitter backoff upon failurec � � || _ || _ yr) r+ r. s r r zEqualJitterBackoff.__init__I r1 r
c � � t | j | j d|z z � dz }|t j d|� z S )Nr3 r )r4 r, r- r9 r: )r
r �temps r r zEqualJitterBackoff.computeQ s: � ��4�9�9�d�j�j�1�h�;� 6�7�!�;���f�n�n�Q��-�-�-r
Nr r r
r r< r< F s � �+��.r
r< c �" � e Zd ZdZd� Zd� Zd� Zy)�DecorrelatedJitterBackoffz(Decorrelated jitter backoff upon failurec �. � || _ || _ d| _ y)r* r N)r, r- �_previous_backoffr. s r r z"DecorrelatedJitterBackoff.__init__Y s � �
�� ���
�!"�� r
c � � d| _ y r" )rC r s r r z DecorrelatedJitterBackoff.resetb s
� �!"�� r
c �� � t | j | j dz � }t j | j |� }t | j |� | _ | j S )N� )�maxr- rC r9 r: r4 r, )r
r � max_backoffr? s r r z!DecorrelatedJitterBackoff.computee sP � ��$�*�*�d�&<�&<�q�&@�A� ��~�~�d�j�j�+�6��!$�T�Y�Y��!5�� ��%�%�%r
N)r r r r r r r r r
r rA rA V s � �2�#�#�&r
rA ) r9 �abcr r r r r r' r6 r< rA r r
r �<module>rJ sa ��
� #�
�c�
�" �o� � �� � 8� � 8� K�� K�
.� �
.� &�� &r