Файловый менеджер - Редактировать - /usr/lib/rads/venv/lib/python3.13/site-packages/botocore/retries/__pycache__/bucket.cpython-313.pyc
Ðазад
� � �i� � �L � S r SSKrSSKrSSKJr " S S5 r " S S5 rg)zEThis module implements token buckets used for client side throttling.� N)�CapacityNotAvailableErrorc �& � \ rS rSrS rS rS rSrg)�Clock� c � � g �N� ��selfs �J/usr/lib/rads/venv/lib/python3.13/site-packages/botocore/retries/bucket.py�__init__�Clock.__init__ s � � � c �0 � [ R " U5 g r )�time�sleep�r �amounts r r � Clock.sleep s � � � � �6�r c �, � [ R " 5 $ r )r r s r � current_time�Clock.current_time s � ��y�y�{�r r N)�__name__� __module__� __qualname__�__firstlineno__r r r �__static_attributes__r r r r r s � � ��r r c � � \ rS rSrSr\4S jr\S 5 r\R S 5 r\S 5 r \S 5 r SS jr S r S r S rS rg )� TokenBucket� g �?c �� � S U l S U l SU l X l S U l X0l [ R " 5 U l [ R " U R 5 U l Xl g )Nr ) � _fill_rate� _max_capacity�_current_capacity�_clock�_last_timestamp� _min_rate� threading�Lock�_lock� Condition�_new_fill_rate_condition�max_rate)r r- �clock�min_rates r r �TokenBucket.__init__ sU � � ��� !���!"�� �� � #�� �!�� �^�^�%�� �(1�(;�(;�D�J�J�(G��%� � r c � � U R $ r )r" r s r r- �TokenBucket.max_rate" s � ���� r c �J � U R U R 5 [ XR 5 U l US:� a Xl OSU l [ U R U R 5 U l U R R 5 S S S 5 g ! , ( d f g = f)N� ) r, �_refill�maxr' r" r# �minr$ �notify)r �values r r- r2 & s{ � � � *� *� �L�L�N� !�%� � � 8�D�O���z�%*�"�%&��"� &)��&�&��(:�(:�&�D� "� � )� )� 0� 0� 2�# +� *� *�s �A>B� B"c � � U R $ r )r# r s r � max_capacity�TokenBucket.max_capacity; s � ��!�!�!r c � � U R $ r )r$ r s r �available_capacity� TokenBucket.available_capacity? s � ��%�%�%r c �n � U R U R XS9sSSS5 $ ! , ( d f g= f)a" Acquire token or return amount of time until next token available. If block is True, then this method will block until there's sufficient capacity to acquire the desired amount. If block is False, then this method will return True is capacity was successfully acquired, False otherwise. )r �blockN)r, �_acquire)r r rA s r �acquire�TokenBucket.acquireC s' � � � *� *��=�=��=�<� +� *� *�s �&� 4c �p � U R 5 XR :: a U =R U- sl gU( d [ 5 eU R U5 nUS:� aD U R R U5 U R 5 U R U5 nUS:� a MD U =R U- sl g)NTr )r5 r$ r � _sleep_amountr, �wait)r r rA � sleep_amounts r rB �TokenBucket._acquireP s� � � � � �� �+�+� +� � "� "�f� ,� "���/�1�1� �-�-�f�5�L� ��"� �-�-�2�2�<�@�� � �� #� 1� 1�&� 9� � ��"� � "� "�f� ,� "�r c �8 � XR - U R - $ r )r$ r" r s r rF �TokenBucket._sleep_amountg s � ��/�/�/�4�?�?�B�Br c � � U R R 5 nU R c Xl g U R nXR - U R - n[ U R X#- 5 nX@l Xl g r )r% r r& r$ r" r7 r# )r � timestamp�current_capacity� fill_amount� new_capacitys r r5 �TokenBucket._refillj sn � ��K�K�,�,�.� � � � � '�#,� � � �1�1�� �#7�#7�7�4�?�?�J� ��4�-�-�/?�/M�N� �!-� � (� r ) r% r$ r" r& r* r# r' r, r- N)r4 T)r r r r � _MIN_RATEr �propertyr- �setterr; r> rC rB rF r5 r r r r r r sx � ��I�1:� !� � � � � �_�_�3� �3�( �"� �"� �&� �&� =��.C� )r r )�__doc__r( r �botocore.exceptionsr r r r r r �<module>rW s' �� K� � � 9�� �_)� _)r
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка