⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
botocore
/
__pycache__
/
View File Name :
retryhandler.cpython-312.pyc
Pel9 Z d dl Z d dlZd dlZd dlmZ d dlmZmZmZm Z m Z ej e Z deee e giZd Zd Zd dZd dZd d Zd Zd Zd Z G d d Z G d d Z G d de Z G d de Z G d de Z G d de Z G d de Z G d d e Z y) N)crc32) ChecksumErrorConnectionClosedErrorConnectionErrorEndpointConnectionErrorReadTimeoutErrorGENERAL_CONNECTION_ERRORc v | dk( rt j } n| dk rt d| | ||dz z z }|S )a1 Calculate time to sleep based on exponential function. The format is:: base * growth_factor ^ (attempts - 1) If ``base`` is set to 'rand' then a random number between 0 and 1 will be used as the base. Base must be greater than 0, otherwise a ValueError will be raised. randr z.The 'base' param must be greater than 0, got: )random ValueError)base growth_factorattempts time_to_sleeps 7/usr/lib/python3/dist-packages/botocore/retryhandler.pydelay_exponentialr + sO v~}} <TF C Mhl ;<M c : t j t | | S )zCreate an exponential delay function based on the attempts. This is used so that you only have to pass it the attempts parameter to calculate the delay. r r ) functoolspartialr r s r !create_exponential_delay_functionr B s M r c P t | | }t | | }t || S )N)operation_name)checkeraction) create_checker_from_retry_config create_retry_action_from_config RetryHandler)configr r r s r create_retry_handlerr# N s1 .~G -~F 77r c J | d d }|d dk( rt |d |d S y )N __default__delaytype exponentialr r r )r )r" r delay_configs r r r X sB -(1LF},0 f%&7 -r c g }d }g }d| v rb| d j dg }| d d }|D ]@ }|| }|j t | t | }|0|j | B |_| j | N| | d } | D ]A }|j t | | t | | }|1|j | C t | dk( rt |d | S t | } t | |t | S )Nr% policies max_attemptsr r )r, )r, retryable_exceptions) getappend_create_single_checker _extract_retryable_exceptionextendlenMaxAttemptsDecorator MultiCheckertuple) r" r checkersr, r- r+ keycurrent_configretry_exceptionoperation_policies multi_checkers r r r e s8 HL -(,,Z< m,^< C %c]N OO 2> B C :> JO *$++O< !fjj &@&L #N 3J ?%C OO 23Ec3J K L :"3' O *$++O< & 8}#HQKlKK$X. # %!&';!< r c V d| d v rt | d d S d| d v r t S y )Nresponse applies_when socket_errors) _create_single_response_checkerExceptionRaiser)r" s r r0 r0 sF VN++. > ": . F> 2 2 3r c d| v rt | d | d }|S d| v rt | d }|S d| v rt | d }|S t d )Nservice_error_codehttp_status_code) status_code error_code)rF crc32body)headerzUnknown retry policy)ServiceErrorCodeCheckerHTTPStatusCodeChecker CRC32Checkerr )r> r s r rA rA s x') !34 45 N x '' !34 N h{&;< N /00r c | d }d|j di v rt gS d|v r&g }|d D ] }|j t | |S y )Nr? rH r> r@ )r. r r2 EXCEPTION_MAP)r" r? exceptionsnames r r1 r1 sc .)Ll&&z266 L ( 1D mD 1 2 2 )r c e Zd ZdZd Zd Zy)r! a Retry handler. The retry handler takes two params, ``checker`` object and an ``action`` object. The ``checker`` object must be a callable object and based on a response and an attempt number, determines whether or not sufficient criteria for a retry has been met. If this is the case then the ``action`` object (which also is a callable) determines what needs to happen in the event of a retry. c || _ || _ y N)_checker_action)selfr r s r __init__zRetryHandler.__init__ s r c : |||d}t | j t r*|d d j d }|j d|i | j d i |r*| j | }t j d| |S t j d y ) zHandler for a retry. Intended to be hooked up to an event handler (hence the **kwargs), this will process retries appropriately. )attempt_numberr> caught_exception request_dictcontextretriesretries_context)r zRetry needed, action of: %szNo retry needed.N ) isinstancerT r4 r. updaterU loggerdebug)rV r r> rZ kwargschecker_kwargsr^ results r __call__zRetryHandler.__call__ s ' 0 dmm%9 : $^ 4Y ? C CI NO ! !#4o"F G 4== *> *\\8\4F LL6 ?M '(r N)__name__ __module__ __qualname____doc__rW rg r_ r r r! r! s )r r! c " e Zd ZdZd Zd Zd Zy) BaseCheckerzBase class for retry checkers. Each class is responsible for checking a single criteria that determines whether or not a retry should not happen. c h || j || S || j || S t d )a Determine if retry criteria matches. Note that either ``response`` is not None and ``caught_exception`` is None or ``response`` is None and ``caught_exception`` is not None. :type attempt_number: int :param attempt_number: The total number of times we've attempted to send the request. :param response: The HTTP response (if one was received). :type caught_exception: Exception :param caught_exception: Any exception that was caught while trying to send the HTTP response. :return: True, if the retry criteria matches (and therefore a retry should occur. False if the criteria does not match. z,Both response and caught_exception are None.)_check_response_check_caught_exceptionr )rV rY r> rZ s r rg zBaseChecker.__call__ sJ , ''A A )// 0 KL Lr c y rS r_ rV rY r> s r ro zBaseChecker._check_response r c y rS r_ rV rY rZ s r rp z#BaseChecker._check_caught_exception rs r N)rh ri rj rk rg ro rp r_ r r rm rm s M> r rm c $ e Zd ZdZddZd Zd Zy)r4 a Allow retries up to a maximum number of attempts. This will pass through calls to the decorated retry checker, provided that the number of attempts does not exceed max_attempts. It will also catch any retryable_exceptions passed in. Once max_attempts has been exceeded, then False will be returned or the retryable_exceptions that was previously being caught will be raised. Nc . || _ || _ || _ y rS )rT _max_attempts_retryable_exceptions)rV r r, r- s r rW z MaxAttemptsDecorator.__init__ s )%9"r c |r)t |j dd | j |d< | j ||| }|r<|| j k\ r+|d|d v r d|d d d< t j d| y|S y) Nmaxr ResponseMetadatar TMaxAttemptsReachedz0Reached the maximum number of retry attempts: %sF)r{ r. rx _should_retryrb rc )rV rY r> rZ r^ should_retrys r rg z MaxAttemptsDecorator.__call__ s %( ##E1-t/A/A&OE " )) H&6 !3!33',>(1+,M QK 23, F" ##r c | j r#|| j k r | j ||| S | j ||| S # | j $ r"}t j d|d Y d }~yd }~ww xY w)Nz,retry needed, retryable exception caught: %sT)exc_info)ry rx rT rb rc )rV rY r> rZ es r r~ z"MaxAttemptsDecorator._should_retry0 s % %.4;M;M*M }}"H.> == ;KL L -- B ! s A A4A//A4rS )rh ri rj rk rW rg r~ r_ r r r4 r4 s : 8Mr r4 c e Zd Zd Zd Zy)rK c || _ y rS ) _status_code)rV rF s r rW z HTTPStatusCodeChecker.__init__D s 'r c ~ |d j | j k( r!t j d| j yy)Nr z5retry needed: retryable HTTP status code received: %sTF)rF r rb rc rr s r ro z%HTTPStatusCodeChecker._check_responseG s: A; " "d&7&7 7 LLG!! r Nrh ri rj rW ro r_ r r rK rK C s (r rK c e Zd Zd Zd Zy)rJ c || _ || _ y rS )r _error_code)rV rF rG s r rW z ServiceErrorCodeChecker.__init__S s '%r c |d j | j k( r_|d j di j d }|| j k( r,t j d| j | j yy)Nr r ErrorCodez>retry needed: matching HTTP status and error code seen: %s, %sTF)rF r r. r rb rc )rV rY r> actual_error_codes r ro z'ServiceErrorCodeChecker._check_responseW ss A; " "d&7&7 7 ( < @ @ H D$4$44 %%$$ r Nr r_ r r rJ rJ R s & r rJ c e Zd Zd Zd Zy)r5 c || _ y rS _checkers)rV r7 s r rW zMultiChecker.__init__f s !r c F | j D ] } |||| }|s|c S y)NFr )rV rY r> rZ r checker_responses r rg zMultiChecker.__call__i s3 ~~G & *: '' & r N)rh ri rj rW rg r_ r r r5 r5 e s "r r5 c e Zd Zd Zd Zy)rL c || _ y rS ) _header_name)rV rI s r rW zCRC32Checker.__init__t s "r c ^ |d }|j j | j }|!t j d| j y t |d j dz }|t | k( s7t j dt | | t dt | | y )Nr z?crc32 check skipped, the %s header is not in the http response.l z>retry needed: crc32 check failed, expected != actual: %s != %sr ) checksum_typeexpected_checksumactual_checksum) headersr. r rb rc r contentintr )rV rY r> http_response expected_crc actual_crc32s r ro z CRC32Checker._check_responsex s $,,001B1BC LL(!! !!!4!45 BL 3|#44 % $")&),&7$0 5r Nr r_ r r rL rL s s #r rL c e Zd ZdZd Zy)rB z`Raise any caught exceptions. This class will raise any non None ``caught_exception``. c |rS r_ ru s r rp z'ExceptionRaiser._check_caught_exception s r N)rh ri rj rk rp r_ r r rB rB s r rB rS ) r loggingr binasciir botocore.exceptionsr r r r r getLoggerrh rb rN r r r# r r r0 rA r1 r! rm r4 rK rJ r5 rL rB r_ r r <module>r s 8 $ ! . 8 D!$&) &)R+ + \<M; <M~ K k & ; ; < k r