nbiw`ddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddlm Z ddl m Z m Z mZddlmZddlmZddlmZddlmZd d lmZd d lmZmZmZmZmZd d lm Z d d l!m"Z"m#Z#m$Z$m%Z%m&Z&d dl'm(Z(m)Z)d dl*m+Z+d dl,m-Z-d dl.m/Z/d dl0m1Z1m2Z2m3Z3d dl4mZd dl5m6Z6d dl7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHd dlImJZJmKZKd dlLmMZMd dlNmOZOd dlPmQZQmRZRd dlSmTZTd dlUmVZVd dlWmXZXmYZYd dlZm[Z[m\Z\d dlZm-Z]d dlZm^Z^d dl_m`Z`dd l*maZambZbmcZcmdZddd!l*meZedd"lfmgZge jhrddliZidd#ljmkZkd d$l5mlZlejmenZoe jpd%ZqGd&d'ZrejsejthZud(eefd;d2ZvGd3d*ere ZwGd4d5ewZxdK|d{VdS)NF)close)rZrhrjrls r[ __aexit__zAsyncConnectionPool.__aexit__s- jjllur]c KdSzD Close all pooled connections and disable the pool. Nrfrbs r[rpzAsyncConnectionPool.closes r]boolctre)NotImplementedErrorrbs r[is_idlezAsyncConnectionPool.is_idles!!r]re)rOrPrQrRrSrTrSrP)rZrJrSrJ)rhrirjrkrlrmrSrnrSrTrSrt)ra __module__ __qualname____doc__rN__annotations__r3QueueClsr\rcrgrqrppropertyrwrfr]r[rLrLesF!H M M M M MPPPP    """X"""r]rLg@poolAsyncHTTPConnectionPool waiting_delay float | intkeepalive_delayint | float | Nonekeepalive_idle_windowrSrTcK |j |xjdz c_tj|d{V|jdS |j23d{V}|jdurt j}|j}||z }|dkr7| d{V|b|`|j }|W||z } | |krL||krF|xj dz c_ | d{V| dd{V6n#t$rYdSwxYw|jdSdS#ttjf$rYdSwxYw)zeDiscrete background task that monitor incoming data and dispatch message to registered callbacks.NrAFg?T) expect_frame)rnum_background_watch_iterasynciosleep iter_idle is_connectedtime monotonic last_used_atpeek_and_react connected_at num_pingspingAttributeErrorReferenceErrorCancelledError) rrrrconnnow last_used idle_delayrsince_connection_delays r[idle_conn_watch_taskrs(i#  * *a / * *- .. . . . . . . .y  "&)"5"5"7"7QQQQQQQ$(E11 .**C $ 1I!$yJ"C'' --/////////(31='+'8 '358<5G25HH#-1F#F#F$(NNa$7NN*.))++$5$5$5$5$5$5$5*.*=*=4*=*P*P$P$P$P$P$P$P$P7#8"78"    Ii#####L G2 3sB9D.DDB1DD. DD.D D..EEcLeZdZUdZdZeZded<deddddddddde e e fdpd%Z e dqd'Ze dqd(Zdd)drd-Z dsdd)dtd/Zdud2Zdud3Zdud4Zdvd7Zdwd<Zdd=dxdAZej dydzdXZej dydBdYd{d\Zdddeddd]d]d]dddddfd|daZd}dbZd~dcZej ddBdYddlZej dddmZdddd]d]eddddd]d]dddddfddnZddoZdS)ra Task-safe async connection pool for one host. :param host: Host used for this HTTP Connection (e.g. "localhost"), passed into :class:`http.client.HTTPConnection`. :param port: Port used for this HTTP Connection (None is equivalent to 80), passed into :class:`http.client.HTTPConnection`. :param timeout: Socket timeout in seconds for each individual connection. This can be a float or integer, which sets the timeout for the HTTP request, or an instance of :class:`urllib3.util.Timeout` which gives you more fine-grained control over request timeouts. After the constructor has been parsed, this is always a `urllib3.util.Timeout` object. :param maxsize: Number of connections to save that can be reused. More than 1 is useful in multithreaded situations. If ``block`` is set to False, more connections will be created but they will not be saved once they've been used. :param block: If set to True, no more than ``maxsize`` connections will be used at a time. When no free connections are available, the call will block until a connection has been released. This is a useful side effect for particular multithreaded situations where one does not want to use more than maxsize connections per host to prevent flooding. :param headers: Headers to include with all requests, unless other headers are given explicitly. :param retries: Retry configuration to use by default with requests in this pool. :param _proxy: Parsed proxy URL, should not be used directly, instead, see :class:`urllib3.ProxyManager` :param _proxy_headers: A dictionary with proxy headers, should not be used directly, instead, see :class:`urllib3.AsyncProxyManager` :param resolver: A manual configuration to use for DNS resolution. Can be a support DSN/str (e.g. "doh+cloudflare://") or a :class:`urllib3.AsyncResolverDescription` or a list of DSN/str or :class:`urllib3.AsyncResolverDescription` :param happy_eyeballs: Enable IETF Happy Eyeballs algorithm when trying to connect by concurrently try multiple IPv4/IPv6 endpoints. By default, tries at most 4 endpoints simultaneously. You may specify an int that override this default. Default, set to False. :param background_watch_delay: The window delay used by our discrete scheduler that run in dedicated task to collect unsolicited incoming data and react if necessary. :param keepalive_delay: The delay expressed in seconds on how long we should make sure the connection is kept alive by sending pings to the remote peer. Set it to None to void this feature. :param keepalive_idle_window: Immediately related to the parameter keepalive_delay. This one, expressed in seconds, specify how long after a connection is marked as idle we should send out a ping to the remote peer. :param \**conn_kw: Additional parameters are used to create fresh :class:`urllib3._async.connection.AsyncHTTPConnection`, :class:`urllib3._async.connection.AsyncHTTPSConnection` instances. httpz6type[AsyncHTTPConnection] | type[AsyncHTTPSConnection] ConnectionClsNrAFrOrPrQrRr _TYPE_TIMEOUT | Nonemaxsizeintblockrtheaderstyping.Mapping[str, str] | NoneretriesRetry | bool | int | None_proxy Url | None_proxy_headers _proxy_configProxyConfig | NoneresolverfAsyncResolverDescription | list[AsyncResolverDescription] | str | list[str] | AsyncBaseResolver | Nonehappy_eyeballs bool | intbackground_watch_delayrrrconn_kw typing.Anyc Xt|||tj||t|tst j|}| t j}||_||_ | |_ ||_ |j tur@t|j ts&tjdt"t|_ | ||_||_||_| pi|_| |_d|_d|_d|_d|_||_|jr9|jdg|j|jd<|j|jd<t| t: |_| t?t@j!g} nCt| tDrt?j#| g} nt| t>r| g} g|_$t| t:sd}| D]}t|tDrO|j$%t?j#||j$dj&t@j!krd}f|j$%||j$dj&t@j!krd}|s,|j$%t?j#d |j$D];}d |vrd |vr |d |d <d |vrd |vr |d |d <d |vrd |vr |d |d <z4AsyncHTTPConnectionPool.__init__..s AAAAAAAr]rr).rLr\r isinstancer< from_floatr9DEFAULTr rr_maxsizerr3 issubclasswarningswarnDeprecationWarningrrr proxy_headersrnum_connections num_requestsrrr setdefaultr _own_resolverr rSYSTEMrPfrom_url _resolversappendprotocolr _resolver_background_watch_delay_keepalive_delay_keepalive_idle_windowr_background_monitoring)rZrOrQr rrrrrrrrrrrrrcan_resolve_localhostresolver_descriptionrds r[r\z AsyncHTTPConnectionPool.__init__(s0 $$T4666$T7333'7++ 2(11G ?mG  , = 2 2 2: M-< < 2 MV#    /DMDHMM E E    +1r) !)*& : = L # #$4b 9 9 9$(JDL !+/+* G++$B..,3M,B=)((!++)0)<:h(9::  AAAAA B B  $(> Z *9 &''=$ /&;#  ' 3+.KKK*GD ';?###r]rSc,|jdup |jjSre)r bag_only_idlerbs r[rwzAsyncHTTPConnectionPool.is_idlesyD ;DI$;;r]c,|jduo |jjSre)rbag_only_saturatedrbs r[ is_saturatedz$AsyncHTTPConnectionPool.is_saturatedsy$E)EEr] heb_timeoutrTimeout | NonerBc  K|jt|d|j\|jU|jtkrEt jtt||j|j |j |_|xj dz c_ t d|j |j|jpdd}|j4d{V}|jrt d|j|jpd||j}|j(t)|jt*t,fr|jnd}t/jt2j}| t%|4d{V|j|j|jd |jvr t<jn |jd t<j d d{V}dddd{Vn#1d{VswxYwYn#tB$r7t=j"d |jd |d}tG|j||wxYw|j|j|jd |jvr t<jn |jd t<j d d{V}t/jt2j|z }tI|dkrg} g} |D]C} | dt<j%kr| &| .| &| D| rs| rqt d|j|jpdg} tO| | D]3\} }| r| &| |r| &|4| }n(t d|j|jpdg}t)|jtPrdn|j}|d|D]} |j)}| dt<j%krd| dddn | dd}tUj+d|jd|,|d<| d|d <d|vr|d|dddf|d<|&|j-d"|j|j|d|dt]|D}d}g}t_} t j0|s|n|t j1|d{V\}}|rV|2}|3|}|3rA|&||V|s|sn|D]}|4|K|rd|dnd}tk|dd |jd|j||d3||6|}|j7r ||j7_8tI|r8|D]5}||6|9d{V6n(t d!|j|jpd|*|j-d"|j|j|jjd|j}||d{Vdddd{Vn#1d{VswxYwY|S)#z9 Return a fresh :class:`HTTPConnection`. NPool is closedrAz(Starting new HTTP connection (%d): %s:%s80Attempting Happy-Eyeball %s:%s443tz socket_familyFquic_upgrade_via_dns_rrunable to resolve ' ' within srHappy-Eyeball Dual-Stack %s:%s Happy-Eyeball Single-Stack %s:%s[r]in-memory://default?hosts=:rsource_address)rOrQr c`g|]+\}}tj|,Srfr create_taskconnectri challengers r[rz5AsyncHTTPConnectionPool._new_conn..^C)Az +J,>,>,@,@AAr]T return_whenr  within kFailed to establish a new connection: No suitable address to connect to using Happy Eyeballs algorithm for Happy-Eyeball Ineligible %s:%srf):rr#rrrrrrr rrrlogdebugrOrQlocate_or_holdrr connect_timeoutrfloatrrrrutcr getaddrinforsocket AF_UNSPEC SOCK_STREAMr2gaierrorr+lenAF_INET6rrrtcopyr rrr enumeratesetwaitFIRST_COMPLETEDpop exceptioncancelr,index conn_inforesolution_latencyrp)rZrrswapperoverride_timeoutdt_pre_resolve ip_addressesnew_errdelta_post_resolveipv6_addressesipv4_addresses ip_addressintermediary_addresses ipv6_entry ipv4_entry challengersmax_taskrtarget_solo_addrtasks winner_task remnant_taskspendingdone finished_tasktaskwithin_delay_msgdisposable_remnants r[ _new_connz!AsyncHTTPConnectionPool._new_conns 9 !$(899 9  ' /,8,0OOO*1*=$$KK0)/ ++D ' ! 6  I I     9++--@ @ @ @ @ @ @  "p  4II& &"&,K#2>";#> MM? // !"*!>!>!>#/L#*+;#<#<        151K1K $ $ #2$,#F#F!' 0 0%)\/%B & 28=2L22,,,,,,L                           (LLL"(/Y$)YYFVYYY##2$)T7KKK L *.)C)C  *$,>>((!\/:*05*D**$$$$$$L&.\X\%B%B%B^%S"|$$q((%'N%'N&2>> %a=FO;;*11*====*11*====%. < I I. 24.6A*N77JJ2J  *J 6 = =j I I I)J 6 = =j I I I'=  > I I. #%K&d&94@@1!0 '39H9&= "&,"3"3"5"5 *!}??5 2q 14444!+B!2) /G.OWWWEUWW//#%% +4>a=0-77 '(8 9 E!((8 9! < !9G$45 $**.D.%)Y%)Y(8#* -6{-C-CE #'K$&M/2uuG".5l)0=EEg(/(?$4///)))))) g # @,0HHJJM,6688@.; ,6688) ()00???# @'"g"!'"*!(&& "*>NV:'7::::TV)1'NtKOKTttW[W`tbrtt %Qx11334 'u{{;'?'?@D~OAG*G<* G4 4G<7G4 8G<;[Pool reached maximum size and no more connections are allowed.zwConnection pool is full, temporary increase, keeping connection, multiplexed and not idle: %s. Connection pool size: %srAzLConnection pool is full, discarding connection: %s. Connection pool size: %s)rr@rr=Fullrwrprr%rwarningrOqsizer _put_connrrZrs r[rGz!AsyncHTTPConnectionPool._put_conns 9 ' immDm666666666!   :! ! ! +|+"jjll*******::'X   :  5 5 U I IOO--  9,8 I--2--%)^^D%9%9999999999 bIIOO%% $$)$$C! H  &**,,         A %  & &s"0 EC EAEEcPK|jr|d{VdSdS)U Called right before a request is made, after the socket is created. N) is_closedrrHs r[_validate_connz&AsyncHTTPConnectionPool._validate_connsB > !,,..  ! !r]c KdSrerfrHs r[_prepare_proxyz&AsyncHTTPConnectionPool._prepare_proxys  r]rr<c|tur|jSt|tr|jSt j|S)z:Helper that always returns a :class:`urllib3.util.Timeout`)r;r clonerr<r)rZr s r[ _get_timeoutz$AsyncHTTPConnectionPool._get_timeout sU & & &<%%'' ' gw ' ' / 7=?? "%g.. .r]err&BaseSSLError | OSError | SocketTimeouturl timeout_valuect|trt||d|d|t|dr$|jt vrt||d|d|dSdS)zAIs the error actually a timeout? Will raise a ReadTimeout or passRead timed out. (read timeout=r_errnoN)r SocketTimeoutr/hasattrrX_blocking_errnos)rZrRrTrUs r[_raise_timeoutz&AsyncHTTPConnectionPool._raise_timeout,s c= ) ) "cLMLLL  3  SY2B%B%B"cLMLLL   %B%Br]promiser^ResponsePromise | NoneAsyncHTTPResponse | NonecK|jt|d|5t|ts t dt |dd} |j|pt|du|du4d{V } |||jd{V}ni#ttf$rU}|.tj t| d}nd }||||j d}~wwxYw dddd{Vn#1d{VswxYwYn#t $rYdSt"tt$tt&t(t*t,f$r}d }|}t|tt(frt'|}t|tt.t"t&fr+|r)|jr"|jst5||jj}n%t|trt%d |}|tj t8| d }tj t| d} tj t| d}|| |||t=jd}| d{Vn||} Yd}~nd}~wwxYw|s9tB"d|| ||#|d{VS||tId|dSd} |r|} n4|j%r-tM|j%dr|j%j'r |j%j'} | tId|j(| tj t| d} tj tR| d} | o|*} | r`tj t| d}tj tj+tX| d}tj tZ| d}tj tR| d}tj tR| d}tj tj+t\| d}tj tR| d}| d}tj tj/ttj0f| d}tj tR| d}tj tb| d }tj t8| d }|j2d!kr2d"} d}t[|}tfD]}|4| || |||#}n4#tj$r'|j6r|7d{V|cYSwxYw|7d{V|8|d{VtB9d$|| |j:| | ||f|| |||d||||dd% |d{V}|#|r|ndd{VStS|j;<d&}tj t8| d }|=| |j2|rtj t| d}tj tj+tX| d}tj tZ| d}tj tR| d}tj tR| d}tj tj+t\| d}tj tR| d}| d}tj tj/ttj0f| d}tj tR| d}tj tb| d } || |||#}n4#tj$r'|j>r|7d{V|cYSwxYw|7d{V| |d{VtB9d'||j:| |||f|| |||d ||||dd% |d{V}|#|r|ndd{VS| d(}|\|j2d)ksd*|j2cxkrd+kr?nn<| d,ks|4|td}|@|d{V|S)-z Retrieve the first response available in the pool. This method should be called after issuing at least one request with ``multiplexed=True``. If none available, return None. Nrz7get_response only support ResponsePromise but received z] instead. This may occur if you expected the remote peer to support multiplexing but did not.T)r not_idle_only)r^police_officerrTrrRrTrUFConnection aborted.rmethodr error_pool _stacktrace1Retrying (%r) after connection broken by '%r': %sr]zJInvoked get_response with promise=... that no connection in pool recognize from_promisezPInternal: Unable to identify originating ResponsePromise from a LowLevelResponseredirectbodyrpreload_contentdecode_contentr assert_same_host pool_timeout response_kwchunkedbody_pos/GETresponseriRedirecting %s -> %s rrmrqr rr release_connrtrurorp multiplexed Retry-After Retry: %s extensione,CONNECT)Arr#rrr?r`borrow getresponser"OSErrortypingcastrP get_parameterr\r r4r2r-r1r:r.r0r,r has_connected_to_proxyrrNr9 incrementsysexc_info async_sleeprrE get_response ValueError_fprZrlforgetrtget_redirect_locationOptionalrr rMutableMappingAnyrstatusr7discardr)raise_on_redirect drain_connasync_sleep_for_retryrurlopenrr<is_retryraise_on_statusr!start_extension)rZr^ clean_exitrryerTnew_errfrRrlrmredirect_locationrnrrorpr rqrrrsrtrushould_be_removed_header new_promisehas_retry_afterrs r[rz$AsyncHTTPConnectionPool.get_response?s  9 !$(899 9  z'?'K'K g$w--ggg   > y''*?T)%o(         %)%5%5 ' &6&&      HH%g.*$k#w/D/DU/K/KLL ''A3dl'SSS                              "   44          + + + J E!l,<=>> $  &   D D!J D04/J D*%1BCCE7++ D%&;UCC" +eW-B-B9-M-MNNS'*?*?*I*IJJk#w'<'>,OO$<==== !++FC(RV+WW    ,"--/////////  %%'' ' ' ' ' ' ' '//99 9 9 9 9 9 9 9 II,c3D E E E , ! !  !!1)!! /- !! !!!K&**'3S;;t*TTTTTTTT Tx/33MBBCC+e\%?%? %J%JKK   FHO_ E E; U+c<#=#=e#D#DEEC; +\-G-G-O-ODk.,2L2LY2W2WXXG$kl001BCCO$[l001ABBNk . 0J0J90U0UG &{l001CDD   (55nEEL +%c6:o6**=99Kk$ (B(B9(M(MNNG{#\%?%? %K%KH !++FC(RV+WW    *"--/////////  %%'' ' ' ' ' ' ' '%%h// / / / / / / / IIk3 ' ' ' ,  !  !!1)"! /- !! !!!K&**'3S;;t*TTTTTTTT T ..{;;  #%%x,,,,,,,,,y((I,A$ 4t 4 4 6 6I..y999999999s.D7D$"B('D$(D9AD  DD$D7$ D..D71D.2D77 L5L9FK>>L/[ .[:9[:h00.i! i!.rfrn$_TYPE_BODY | _TYPE_ASYNC_BODY | None Retry | Nonert response_connAsyncHTTPConnection | Nonerorpenforce_content_lengthon_post_connection@typing.Callable[[ConnectionInfo], typing.Awaitable[None]] | Noneon_upload_bodyFtyping.Callable[[int, int | None, bool, bool], typing.Awaitable[None]]on_early_responseCtyping.Callable[[AsyncHTTPResponse], typing.Awaitable[None]] | NonerAsyncExtensionFromHTTP | Noner} Literal[True]rc KdSrerfrZrrfrTrnrrr rtrrorprrrrrr}s r[ _make_requestz%AsyncHTTPConnectionPool._make_requestOs 2#r])r}rnrGc KdSrerfrs r[rz%AsyncHTTPConnectionPool._make_requestjs 2 Cr]TMtyping.Callable[[int, int | None, bool, bool], typing.Awaitable[None]] | NoneLiteral[False] | Literal[True]#AsyncHTTPResponse | ResponsePromisec T K|xjdz c_||}|tj|j|_ ||d{Vn7#ttf$r#}| |||jd}~wwxYwn#ttttttf$r}|}t!|ttfrt|}t!|ttttfr*|r(|jr!|jst'||jj}|d}~wwxYw| |jt-|dr|j|jjrt3|j_|jjrt3|j_|jjrt3|j_|jjr d|j_| |jd{V|jdur|durd}||j|jj||jj}|r||}nt-|dr*| }|!|nstE}|#D]\}}|$|||#D]\}}|$|||}nd} |%|||||| | | | d{V}nH#tL$r}|j'}Yd}~n2d}~wt$r"}d}|j(tPj)krYd}~nd}~wwxYw|j*}|rM|t|+d ||+d ||+d ||S|j,s"|d krt[||d |d||_|jduo |j.duo|du}|r |j./|||0|d{V|j.1|4d{V} |2|j.|d{V}n2#ttf$r}| |||d}~wwxYw |j.3|n#|j.3|wxYw dddd{Vn#1d{VswxYwYnV |2|j.|d{V}n2#ttf$r}| |||d}~wwxYw|j4}||_5||_6|j7dksd|j7cxkrdkr?nn<|dks|4|tqd}|9|d{Vtt;d|j|j<|j=||||j7|j> |S)a8 Perform a request on a given urllib connection object taken from our pool. :param conn: a connection from one of our connection pools :param method: HTTP request method (such as GET, POST, PUT, etc.) :param url: The URL to perform the request on. :param body: Data to send in the request body, either :class:`str`, :class:`bytes`, an iterable of :class:`str`/:class:`bytes`, or a file-like object. :param headers: Dictionary of custom headers to send, such as User-Agent, If-None-Match, etc. If None, pool headers are used. If provided, these headers completely replace any pool-specific headers. :param retries: Configure the number of retries to allow before raising a :class:`~urllib3.exceptions.MaxRetryError` exception. Pass ``None`` to retry until you receive a response. Pass a :class:`~urllib3.util.retry.Retry` object for fine-grained control over different types of retries. Pass an integer number to retry connection errors that many times, but no other types of errors. Pass zero to never retry. If ``False``, then retries are disabled and any exception is raised immediately. Also, instead of raising a MaxRetryError on redirects, the redirect response will be returned. :type retries: :class:`~urllib3.util.retry.Retry`, False, or an int. :param timeout: If specified, overrides the default timeout for this one request. It may be a float (in seconds) or an instance of :class:`urllib3.util.Timeout`. :param chunked: If True, urllib3 will send the body using chunked transfer encoding. Otherwise, urllib3 will send the body using the standard content-length form. Defaults to False. :param response_conn: Set this to ``None`` if you will handle releasing the connection or set the connection to have the response release it. :param preload_content: If True, the response's body will be preloaded during construction. :param decode_content: If True, will attempt to decode the body based on the 'content-encoding' header. :param enforce_content_length: Enforce content length checking. Body returned by server must match value of Content-Length header, if present. Otherwise, raise error. rANrd_start_last_requestFTr)rnrrtrorprr read_timeoutrrrrWr_)rcearly_response_callbackrrrrz%s://%s:%s "%s %s %s" %s %s)?rrQ start_connectr<resolve_default_timeoutr r rLrYr"r\rr,r2r:r1rr rrrNrrZrtls_handshake_latencyrestablished_latencyrrequest_sent_latencyis_multiplexed http_versionrrupdater itemsaddrequestrDr^rX EPROTOTYPEr set_parameterrKr/rmemorizerGrrr _http_vsn_strrrirr!rrrrOrQlength_remaining)rZrrfrTrnrrr rtrrorprrrrrr} timeout_objrrextension_headersmerged_headerskvrprcan_shelve_connry http_vsn_strs r[rz%AsyncHTTPConnectionPool._make_requestsJp Q''00 !!###6{7RSS   ))$//////////!<0   ##s$,#OOO 0            !E!l,<=>> $  !3\8L D D J D/3/J D*%1BCCK# &  )dn.H344 ?,8>7G;D;;DN8>5E9BDN6>4D8A DN5>6?:>DN7$$T^44 4 4 4 4 4 4 4  % ' 'K4,?,?K  !*+7 ) 1 1$.2M N N   -?/GGWf-- -%llnnGNN#45555%3%5%5N ' 111&**1a0000 1 7 7 9 9111&**1a0000,GI || /-'=-$        BB   BBBBBB   Bw%***+****  #/  z   ^\ : : :   02C D D D   [) 4 4 4I~ ( q  &#O OOO(DL  4 ' TDIT,A TbPTn    I  r4 ( ( (..&& & & & & & & &y''++ ) ) ) ) ) ) )t )%)%5%5'+y0A&6&&      HH%g.''A3l'SSS I$$R((((DI$$R((((( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) !%!1!1#'9FW"2""!'*   ##s,#OOO     # ?c ! ! 8? ( ( ( (S ( ( ( ( (9$$ (= 0N40022 **955 5 5 5 5 5 5 5 ) K I I    O  % sA87B08B, B''B,,B00)EBEE$L99 M>M M>M99M>/T1"RS"S%R>>SS"T"S>>T T!T'"U U9U44U9cK|jdS|jdc}|_|d{V|jQ|j |jd{Vn#tj$rYnwxYwd|_n #d|_wxYw|jr:|jr#|j d{VdSdSdSrs) rclearrrrrrr is_availablerp)rZold_pools r[rpzAsyncHTTPConnectionPool.closes2 9  F#i$)nn  & 2  ' . . 0 0 0 3111111111)    /3++d+2222   )$."="="?"? ).&&(( ( ( ( ( ( ( ( ( ( ) ) ) )s* A$#B$A63B5A66B B c:|drdSt|^}}}}}|pd}|t||}|jr|st j|}n!|js|t j|krd}|||f|j|j|jfkS)zj Check if the given ``url`` is a member of the same host as this connection pool. /TrNrV) startswithr?rrQrFr<rNrO)rZrTrN_rOrQs r[ is_same_hostz$AsyncHTTPConnectionPool.is_same_hosts >>#   4%.cNN!4!6  "4777D 9 T !%f--DD t~'9&'A'AAADd# TY 'JJJr]rmrqrrr| bool | Noneru_TYPE_BODY_POSITION | Nonersc KdSrerfrZrfrTrnrrrmrqr rrr|rtrurorprrrrr}rss r[rzAsyncHTTPConnectionPool.urlopens 8 Cr]c KdSrerfrs r[rzAsyncHTTPConnectionPool.urlopens 8#r]cXK|jt|dt|}|j}||j}t |t st j|||j}| d} |r&| |st|||| drtt|}nt|j}d}| }t|j|j|}|s.|}||jd}d}t+|| } ||}|jd{V|| |d{V}|j|_|jm|rk|jrd ||d{VnG#t:t<t>f$r-}| ||jj|jd}~wwxYw| s|nd}|!|||||||| || |d||||| d{V}t |tDsd}|r$|#|||||| ||||| || | d d}n#tH$rd}d}tJt<tLt:tNtPtRtTf$rY}d}|} t |t:tPfrtO|} t | t<tVtJtNfr+|r)|jr"|j,st[| |jj} n%t | t<rtMd | } |.||| |t_j0d  }|1d{Vt | tdrF|Dd|j3vrti|j3d<|j3d5|j6|}Yd}~nd}~wwxYw|s |r|7d{Vd}d}|j|dur`|^t |tDdurG|j8|||jj9 |jj98|||durZ|9|j:|dur|;|d{Vn|j<d{Vn#|s |r|7d{Vd}d}|j|dur`|^t |tDdurG|j8|||jj9 |jj98|||dur\|9|j:|dur|;|d{Vww|j<d{VwwwxYw|sCtz>d||||j?|||||||f|| | | | | |||||d |d{VS|rt |tDsJ|St |tsJ|r)|Ar|A}!|jBdkr2d}d}t|}tD]}"|E|" |.||||}n4#t$r'|jGr|Hd{V|cYSwxYw|Hd{V|I|d{VtzJd||!|j?||!f||||||| | | | | |dd |d{VSt|jLd}#|M||jB|#r |.||||}n4#t$r'|jNr|Hd{V|cYSwxYw|Hd{V|1|d{VtzJd||j?||||f||||| | | | | |dd |d{VS|S)a Get a connection from the pool and perform an HTTP request. This is the lowest level call for making a request, so you'll need to specify all the raw details. .. note:: More commonly, it's appropriate to use a convenience method such as :meth:`request`. .. note:: `release_conn` will only behave as expected if `preload_content=False` because we want to make `preload_content=False` the default behaviour someday soon without breaking backwards compatibility. :param method: HTTP request method (such as GET, POST, PUT, etc.) :param url: The URL to perform the request on. :param body: Data to send in the request body, either :class:`str`, :class:`bytes`, an iterable of :class:`str`/:class:`bytes`, or a file-like object. :param headers: Dictionary of custom headers to send, such as User-Agent, If-None-Match, etc. If None, pool headers are used. If provided, these headers completely replace any pool-specific headers. :param retries: Configure the number of retries to allow before raising a :class:`~urllib3.exceptions.MaxRetryError` exception. Pass ``None`` to retry until you receive a response. Pass a :class:`~urllib3.util.retry.Retry` object for fine-grained control over different types of retries. Pass an integer number to retry connection errors that many times, but no other types of errors. Pass zero to never retry. If ``False``, then retries are disabled and any exception is raised immediately. Also, instead of raising a MaxRetryError on redirects, the redirect response will be returned. :type retries: :class:`~urllib3.util.retry.Retry`, False, or an int. :param redirect: If True, automatically handle redirects (status codes 301, 302, 303, 307, 308). Each redirect counts as a retry. Disabling retries will disable redirect, too. :param assert_same_host: If ``True``, will make sure that the host of the pool requests is consistent else will raise HostChangedError. When ``False``, you can use the pool on an HTTP proxy and request foreign hosts. :param timeout: If specified, overrides the default timeout for this one request. It may be a float (in seconds) or an instance of :class:`urllib3.util.Timeout`. :param pool_timeout: If set and the pool is set to block=True, then this method will block for ``pool_timeout`` seconds and raise EmptyPoolError if no connection is available within the time period. :param bool preload_content: If True, the response's body will be preloaded into memory. :param bool decode_content: If True, will attempt to decode the body based on the 'content-encoding' header. :param release_conn: If False, then the urlopen call will not release the connection back into the pool once a response is received (but will release if you read the entire contents of the response such as when `preload_content=True`). This is useful if you're not preloading the response's content immediately. You will need to call ``r.release_conn()`` on the response ``r`` to return the connection back into the pool. If None, it takes the value of ``preload_content`` which defaults to ``True``. :param bool chunked: If True, urllib3 will send the body using chunked transfer encoding. Otherwise, urllib3 will send the body using the standard content-length form. Defaults to False. :param int body_pos: Position to seek to in file-like body in the event of a retry or redirect. Typically this won't need to be set because urllib3 will auto-populate the value when needed. :param on_post_connection: Callable to be invoked that will inform you of the connection specifications for the request to be sent. See ``urllib3.ConnectionInfo`` class for more. :param on_upload_body: Callable that will be invoked upon body upload in order to be able to track the progress. The values are expressed in bytes. It is possible that the total isn't available, thus set to None. In order, arguments are: (total_sent, total_to_be_sent, completed, any_error) :param on_early_response: Callable that will be invoked upon early responses, can be invoked one or several times. All informational responses except HTTP/102 (Switching Protocol) are concerned here. The callback takes only one positional argument, the fully constructed HTTPResponse. Those responses never have bodies, only headers. :param multiplexed: Dispatch the request in a non-blocking way, this means that the response will be retrieved in the future with the get_response() method. Nr)rmdefaultTrF)r rrd)rnrrr rtrrorprrrrrr})rfrTrnrrrorpr rmrsrrrqrtrurer rg disabled_svnrk) r rrr|rtrurorprrrr}rvrwrxrz) rnrrrmrqr rrr|rtrurorpr}r~rr{)Orr#r?rNrrr9from_intrrr&rr@r>rTr6r rrrrr8rQ&wait_for_unallocated_or_available_slotrAr r rKrNr"rrYr\rrupdate_parametersr$r2r-r1r:r.r0r,rrrrrrr*rrr_svnrprparentis_heldrG kill_cursorrrErrGrrr r7rr)rrrrrtr<rr)$rZrfrTrnrrrmrqr rrr|rtrurorprrrrr}rs parsed_urldestination_schemerrelease_this_connhttp_tunnel_requiredrRrrrrryrrrrs$ r[rzAsyncHTTPConnectionPool.urlopens ` 9 !$(899 9s^^ '. ?lG'5)) WnWxVVVG   L  7D$5$5c$:$: 7"4g66 6 >>#   ),,--CC((C)> J)+=  $ /llnnG NN4- . . . %T844[ 6++G44K)BBDD D D D D D D D +VVVVVVVVD&6DLz%*>%4>%--d3333333333$g}=''4:>( )5>DD$M"//#+ /-'+#5-"3#'#0H*h88 $#  **"(" $#*#*+:*8#*$,'2(4,<#*$,(JJ   J %            - - - J E!l,<=>> $  &   D D!J D04/J D*%1BCCE7++ D%&;UCC''5#,..QRBS(G%%'' ' ' ' ' ' ' ' %!344 <9I!553655DL0 ^,00;;;CCCCCC[- ` )  **,,&&&&&&&D$(!y$$&&("8_==EEI&&x666y'3 (11(DAAA$,,' 9,,T22d::"&.."6"66666666"i33555555555; )  **,,&&&&&&&D$(!y$$&&("8_==EEI&&x666y'3 (11(DAAA$,,' 9,,T22d::"&.."6"666666666;#i335555555555'%-  KKCWcSV   &  ))! /-"3-#5'%&' ,  h88 8 8 8O($566666 * 6688*  ( > > @ @ #%%(110G>>,OO$<==== !++FC(RV+WW    ,"--/////////  %%'' ' ' ' ' ' ' '//99 9 9 9 9 9 9 9 II,c3D E E E%!!!1))! /-! ! (x/33MBBCC   FHO_ E E  !++FC(RV+WW    *"--/////////  %%'' ' ' ' ' ' ' '%%h// / / / / / / / IIk3 ' ' '%   !!1))! /-! ! &s}A-J.G J H!(H  HA4JTAP!EPTP!!TC/W?#[==.\.-\.)`.`43`4c@d|jd|jpdd|jpddS)NzrOrQrrbs r[__repr__z AsyncHTTPConnectionPool.__repr__s3_ty__49?__TYE\R\____r]) rOrPrQrRr rrrrrtrrrrrrrrrrrrrrrrrrrrrrrz)rrrSrBre)r r8rrrSrBrrBrSrT)r rrSr<)rRrSrTrPrUrrSrT)r^r_rSr`) .............)$rrBrfrPrTrPrnrrrrrr rrtrtrrrortrprtrrtrrrrrrrrr}rrSr)$rrBrfrPrTrPrnrrrrrr rrtrtrrrortrprtrrtrrrrrrrrr}rnrSrG)$rrBrfrPrTrPrnrrrrrr rrtrtrrrortrprtrrtrrrrrrrrr}rrSrry)rTrPrSrt)................)*rfrPrTrPrnrrrrrrmrtrqrtr rrrrRr|rrtrtrurrortrprtrrrrrrrrr}rnrsrrSrG)*rfrPrTrPrnrrrrrrmrtrqrtr rrrrRr|rrtrtrurrortrprtrrrrrrrrr}rrsrrSr)*rfrPrTrPrnrrrrrrmrtrqrtr rrrrRr|rrtrtrurrortrprtrrrrrrrrr}rtrsrrSrrx)rar{r|r}rNrBrr~r;rrrr\rrwrr7rArGrLrNrQr\rroverloadrrprrrrfr]r[rrs#NN`F (837-1!:>,0 %*5T.E4Q+N@N@N@N@N@`<<<X<FFFXF04ccccccL'+0MQ000000d<&<&<&<&|!!!!     / / / /(48NNNNNN` _ 6936 #!$47 #"'* 36+_4 _ 6936 #!$47 #"'* 36+ .'*/     _ >6:37 $!148 $#'+376;/RRRRRh))))4KKKK, _ 6936-0!$!$#&$'/2 #" 36/ 2'*3     _ : _ 6936-0!$!$#&$'/2 #" 36/_B6:37-1!%!1#'$(/3 $#37!3ZZZZZx``````r]ceZdZUdZdZeZded<dedddddddddddddddddddddfd=fd2 Z d>d5Z dd6d?d9Z d@fd; Z dAd<Z xZS)BAsyncHTTPSConnectionPoola Same as :class:`.HTTPConnectionPool`, but HTTPS. :class:`.HTTPSConnection` uses one of ``assert_fingerprint``, ``assert_hostname`` and ``host`` in this order to verify connections. If ``assert_hostname`` is False, no verification is done. The ``key_file``, ``cert_file``, ``cert_reqs``, ``ca_certs``, ``ca_cert_dir``, ``ssl_version``, ``key_password`` are only used if :mod:`ssl` is available and are fed into :meth:`urllib3.util.ssl_wrap_socket` to upgrade the connection socket into an SSL socket. httpsztype[AsyncHTTPSConnection]rNrAFrOrPrQrRr rrrrrtrrrrrrrkey_filerM cert_file cert_reqsint | str | None key_passwordr ssl_versionssl_minimum_versionssl.TLSVersion | Nonessl_maximum_versionassert_hostnamestr | Literal[False] | Noneassert_fingerprintrrNone | str | bytes cert_datastr | bytes | Nonekey_dataciphersrrrSrTc tj||||||||| f i|| |_| |_| |_| |_||_||_||_||_ ||_ ||_ ||_ ||_ ||_||_||_dSre)superr\rrrrrrrr rrrrr r r)rZrOrQr rrrrrrrrrrrrrrr r rrr rrr __class__s r[r\z!AsyncHTTPSConnectionPool.__init__s8            ! ""(  &("  &#6 #6 ."4 r]rrCcK|jr|jjdkrd}nd}|||j|j|j|d{VdS)z5Establishes a tunnel connection through HTTP CONNECT.rr)rNrOrQrN)r rN set_tunnelrYrQrr)rZr tunnel_schemes r[rNz'AsyncHTTPSConnectionPool._prepare_proxy/s : #$*+w66#MM"M  "&    llnnr]rrrc K|jt|d|jO|jH|jtkr8t jt||j|j|j |_|xj dz c_ t d|j |j |jpd|jr|jt urt#d|j }|j}|j$|jj |jj }|jj}d}|j|j4d{V}|jr8t d|j |jpd||j}|j(t1|jt2t4fr|jnd}t7jt:j }| t-|4d{V|j ||d |j!vr tDj#n |j!d tDj$d d{V}dddd{Vn#1d{VswxYwYn#tJ$r-tEj&d |d|d} tO||| wxYw|j ||d |j!vr tDj#n |j!d tDj$d d{V}t7jt:j |z } i} d|j!vr|j!d |j!d} tQd|Dr-|j |jf| vr|j |jf| |j |jf<tS|dkrg} g} |D]C}|dtDj*kr| +|.| +|D| rs| rqt d|j |jpdg}tY| | D]3\}}|r|+||r|+|4|}n(t d|j |jpdg}t1|jtZrdn|j}|d|D]7}|j!.}|dtDj*krd|dddn |dd}t_j0d|j d|1|d<|d|d <| |d<|+|jd4id|d|d|d|j2d |j3d!|j4d"|j5d#|j6d$|j7d%|j8d&|j9d'|j:d(|j;d)|j<d*|j=d+|j>d,|j?d-|j@|9d.t|D}d}g}t} t jC|s|n|t jD|/d{V\}}|rV|E}|F|}|FrA|+||V|s|sn|D]}|G|A|rd0|dnd1}t|dd2|d|||dF||I|}|jJr | |jJ_KtS|r8|D]5}||I|Ld{V6n(t d3|j |jpd||jd4id|d|d|jjd|j2d |j3d!|j4d"|j5d#|j6d$|j7d%|j8d&|j9d'|j:d(|j;d)|j<d*|j=d+|j>d,|j?d-|j@|j!}||d{Vdddd{Vn#1d{VswxYwY|S)5zL Return a fresh :class:`urllib3.connection.HTTPConnection`. NrrAz)Starting new HTTPS connection (%d): %s:%srzCCan't connect to HTTPS URL because the SSL module is not available.rCrrrTrrrrpreemptive_quic_cachec3BK|]}|dtjkVdS)rAN)r SOCK_DGRAM)rrs r[ z5AsyncHTTPSConnectionPool._new_conn..s.GGQqtv00GGGGGGr]rrrrrrrrrrrOrQr rrrrrrrr r rrrr rrc`g|]+\}}tj|,Srfrrs r[rz6AsyncHTTPSConnectionPool._new_conn..rr]rrrrrrf)Mrr#rrrrrrrrrrrrOrQrrE ImportErrorr r rrr r rr rrrrr rr rrrrr2rr+anyrrrrrtrr rrrrrrrrrr r rrrr rrrrrrrrrr,rrrrp)rZr actual_host actual_portrrr r!r"r#r$ target_pqcr%r&r'r(r)r*r+r,rr-r.r/r0r1r2r3r4r5r6s r[r7z"AsyncHTTPSConnectionPool._new_conn>s~ 9 !$(899 9  ' /,8,0OOO*1*=$0)/ ++D ' ! 7  I I     ! T%7?%J%JU  9 i : !djo&A*/K*/K9++$*+==m m m m m m m "S  4II& &"&,K#2>";#> MM? // !"*!>!>!>#/N#*+;#<#<        151K1K + +#2$,#F#F!' 0 0%)\/%B & 28<2L 2 2 , , , , , ,L                           (NNN"(/[+[[HX[[[##2+tWMMM N*.)C)C##*$,>>((!\/:*04*D * * $ $ $ $ $ $L&.\X\%B%B%B^%S" ,t|;; %<=I!%.E!FJGG,GGGGGT 49-Z??>Bi=S DIty#9:|$$q((%'N%'N&2>> %a=FO;;*11*====*11*====&. < I I. 24.6A*N77JJ2J  *J 6 = =j I I I)J 6 = =j I I I'=  > I I. #%K&d&94@@1!0 '39H9&=## "&,"3"3"5"5 *!}??5 2q 14444!+B!2) /G.OWWWEUWW//#%% +4>a=0;E 78#**.D.%0[%0[)9(8+/..  *.  .2->-> +/..*.-1,<,<.2->->150D0D483J3J-1,<,<594L4L594L4L +/..!"*.#$)- ")'0-6{-C-CE #'K$&M/2uuG".5l)0=EEg(/(?$4///)))))) g # @,0HHJJM,6688@.; ,6688) ()00???# @'"g"!'",!(&& "*>NV:'7::::TV)1' !xKVxxYdxfvxx  %Qx1133 4'u{{;'?'?@D~O'>!% 0 0)-(@(@)-(@(@ #nn!""]]#$!LLl','$--       [m m m m m m m m m m m m m m m m m m m m m m m m m m m ^ sQ3B `6I AH7%I 7 I I I I `6 7JV$`66 aarBcKt|d{V|js,|js't jd|jdtdSdSdS)rJNz0Unverified HTTPS request is being made to host 'z'. Adding certificate verification is strongly advised. See: https://urllib3future.readthedocs.io/en/latest/advanced-usage.html#tls-warnings)rrL is_verifiedproxy_is_verifiedrrrOr')rZrrs r[rLz'AsyncHTTPSConnectionPool._validate_connY sgg$$T********* (>  M$ty$$$ '         r]c@d|jd|jpdd|jpddS)Nz# $&*#'#(,59597;)-"&+/(,'+"37777777r     04YYYYYYv"bbbbbbbbr]rrTrPkwrc t|^}}}}}|pd}|ptj|d}|dkrt|fd|i|St |fd|i|S)a} Given a url, return an :class:`.ConnectionPool` instance of its host. This is a shortcut for not having to parse out the scheme, host, and port of the url before creating an :class:`.ConnectionPool` instance. :param url: Absolute URL string that must include the scheme. Port is optional. :param kw: Passes additional parameters to the constructor of the appropriate :class:`.ConnectionPool`. Useful for specifying things like timeout, maxsize, headers, etc. Example:: >>> conn = connection_from_url('http://google.com/') >>> r = conn.request('GET', '/') rrrrQ)r?rFr<rr)rTr'rNrrOrQs r[connection_from_urlr)n s|(!*#FAtTA  vF  1>%fb11D '>>4>2>>>&t==$="===r]) rrrrrrrrrSrT)rTrPr'rrSr)z __future__rrrXloggingr=rrrrrrrrr itertoolsrr rYtypesr weakrefr _collectionsr _constantrrrrr_request_methodsr_typingrrrrrbackendrr connectionrconnectionpoolrcontrib.resolverrcontrib.resolver._asyncrrr contrib.ssa._timeoutcontrib.webextensions._asyncr! exceptionsr"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2util._async.traffic_policer3r4util.connectionr5 util.proxyr6 util.requestr7r8 util.retryr9util.ssl_match_hostnamer: util.timeoutr;r<util.urlr=r>rWr? util.utilr@rBrCrDrErFryrG TYPE_CHECKINGssltyping_extensionsrHrI getLoggerrarTypeVarrJrLEAGAIN EWOULDBLOCKr[rrrr)rfr]r[rKs""""""  2222222222!!!!!!++++++))))))32222265555555******,,,,,,////// +*****999999&433333888888EEEEEEEE66666644444444********888888  988888'''''' FJJJ))))))EEEEEEg!!  ! !2"2"2"2"2"2"2"2"lL%"34 "%*A0M 11111hP`P`P`P`P`13FP`P`P`f8FbFbFbFbFb6FbFbFbR >>>>>>r]