Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/botocore/retries/__pycache__/adaptive.cpython-39.pyc
Ðазад
a q�h_ � @ sr d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ e�e�Z dd� Z G dd� de �Z G d d � d e �Z dS ) � N)�bucket)� throttling)�standardc C sz t �� }tjd|�� d�}t jd|d�}t|�}tjt� � d�}t |||||d�}| j j � d|j� | j j � d|j� |S ) Nr )Zstarting_max_rate� start_time� )�max_rate�clock)Zretry_event_adapter)� rate_adjustor� rate_clocker� token_bucket�throttling_detectorr z before-sendz needs-retry)r ZClockr ZCubicCalculator� current_timeZ TokenBucket� RateClockerr ZThrottlingErrorDetectorZRetryEventAdapter�ClientRateLimiter�meta�events�register�on_sending_request�on_receiving_response)�clientr r r r r Zlimiter� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/botocore/retries/adaptive.py�register_retry_handler s. �����r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) r g @c C s2 || _ || _|| _|| _|| _d| _t�� | _d S )NF) �_rate_adjustor� _rate_clocker� _token_bucket�_throttling_detector�_clock�_enabled� threading�Lock�_lock)�selfr r r r r r r r �__init__* s zClientRateLimiter.__init__c K s | j r| j�� d S �N)r r �acquire)r" �request�kwargsr r r r 4 s z$ClientRateLimiter.on_sending_requestc K s� | j �� }| j�� }| j�� | jjf i |��s@d}| j�|�}nFd}| j sP|}nt || j j �}| j� ||�}t�d||| j j� d| _ t || j| �| j _ W d � n1 s�0 Y d S )NFTzfThrottling response received, new send rate: %s measured rate: %s, token bucket capacity available: %s)r �recordr r r! r Zis_throttling_errorr Zsuccess_receivedr �minr r Zerror_received�logger�debugZavailable_capacity�_MAX_RATE_ADJUST_SCALE)r" r' � measured_rate� timestampr Znew_rateZ rate_to_user r r r 9 s* �� �z'ClientRateLimiter.on_receiving_responseN)�__name__� __module__� __qualname__r, r# r r r r r r r & s r c @ s< e Zd ZdZdZdZeefdd�Zd dd�Zed d � �Z d S ) r z7Tracks the rate at which a client is sending a request.g�������?g �?c C sD || _ d| _|| _t�| j �� �| _d| j | _d| _ t � � | _ d S )Nr r ) r �_measured_rate� _smoothing�math�floorr � _last_bucket�_TIME_BUCKET_RANGE�_time_bucket_scale�_countr r r! )r" r Z smoothingZtime_bucket_ranger r r r# X s zRateClocker.__init__r c C s� | j �� | j�� }t�|| j �| j }| j|7 _|| jkr|| jt|| j � }|| j | j d| j | _ d| _|| _| j W d � S 1 s�0 Y d S )Nr r ) r! r r r4 r5 r8 r9 r6 �floatr3 r2 )r" �amount�tr Z current_rater r r r( b s& �� ���zRateClocker.recordc C s | j S r$ )r2 )r" r r r r- s s zRateClocker.measured_rateN)r ) r/ r0 r1 �__doc__Z_DEFAULT_SMOOTHINGr7 r# r( �propertyr- r r r r r Q s � r )r4 �loggingr Zbotocore.retriesr r r � getLoggerr/ r* r �objectr r r r r r �<module> s +
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка