6=gCSSKJr SSKrSSKrSSKrSSKrSSKJr SSKJ r J r SSK J r J r SSKJrJrJrJr SSKJrJrJr S S KJr S S KJrJr "S S 5r"SS\5r"SS5rg)) annotationsN) AutoBackend) SOCKET_OPTIONAsyncNetworkBackend)ConnectionNotAvailableUnsupportedProtocol)OriginProxyRequestResponse) AsyncEventAsyncShieldCancellationAsyncThreadLock)AsyncHTTPConnection)AsyncConnectionInterfaceAsyncRequestInterfacecR\rSrSrS SjrS SjrS SjrS S SjjrSSjrSr g)AsyncPoolRequestc<XlSUl[5UlgN)request connectionr_connection_acquired)selfrs A/usr/lib/python3/dist-packages/httpcore/_async/connection_pool.py__init__AsyncPoolRequest.__init__s ;?$.L!cDXlURR5 gr)rrset)rrs rassign_to_connection%AsyncPoolRequest.assign_to_connections$ !!%%'r!c0SUl[5Ulgr)rrrrs rclear_connection!AsyncPoolRequest.clear_connections$.L!r!Nc# URc!URRUS9IShvN URceUR$N7f)Ntimeout)rrwait)rr,s rwait_for_connection$AsyncPoolRequest.wait_for_connectionsN ?? "++000A A A*** Bs*AA  AcURSL$r)rr's r is_queuedAsyncPoolRequest.is_queued's$&&r!)rrr)rr returnNone)rzAsyncConnectionInterface | Noner3r4r3r4r)r, float | Noner3r)r3bool) __name__ __module__ __qualname____firstlineno__rr$r(r.r1__static_attributes__r!rrrs01 (1 '+# !'r!rc\rSrSrSrSSSjjrSSjr\SSj5rSSjr SSjr SS jr SS jr SS jr SSS jjrSS jrSrg)AsyncConnectionPool+z- A connection pool for making HTTP requests. Nc XlX lUc[ROUUlUc[ROUUl[ URUR 5UlXPlX`lXpl Xl Xl Xl U c [5OU UlXl/Ul/Ul[%5Ulg)aC A connection pool for making HTTP requests. Parameters: ssl_context: An SSL context to use for verifying connections. If not specified, the default `httpcore.default_ssl_context()` will be used. max_connections: The maximum number of concurrent HTTP connections that the pool should allow. Any attempt to send a request on a pool that would exceed this amount will block until a connection is available. max_keepalive_connections: The maximum number of idle HTTP connections that will be maintained in the pool. keepalive_expiry: The duration in seconds that an idle HTTP connection may be maintained for before being expired from the pool. http1: A boolean indicating if HTTP/1.1 requests should be supported by the connection pool. Defaults to True. http2: A boolean indicating if HTTP/2 requests should be supported by the connection pool. Defaults to False. retries: The maximum number of retries when trying to establish a connection. local_address: Local address to connect from. Can also be used to connect using a particular address family. Using `local_address="0.0.0.0"` will connect using an `AF_INET` address (IPv4), while using `local_address="::"` will connect using an `AF_INET6` address (IPv6). uds: Path to a Unix Domain Socket to use instead of TCP sockets. network_backend: A backend instance to use for handling network I/O. socket_options: Socket options that have to be included in the TCP socket when the connection was established. N) _ssl_context_proxysysmaxsize_max_connections_max_keepalive_connectionsmin_keepalive_expiry_http1_http2_retries_local_address_udsr_network_backend_socket_options _connections _requestsr_optional_thread_lock) r ssl_contextproxymax_connectionsmax_keepalive_connectionskeepalive_expiryhttp1http2retries local_addressudsnetwork_backendsocket_optionss rrAsyncConnectionPool.__init__0sX( *2CKK  )0 KK* ' +.  ! !4#B#B+ '"2   + -4KM/  .=?13 &5%6"r!c :URGbURRRS;awSSKJn U"URRR URR UURURURURURS9$URS:XakSSK J n U"URRR URRURRUURURS9$SSK Jn U"URRR URRURRUURURURURURS 9 $[#UURURURURUR$UR&UR(URUR*S 9 $) N)ssocks5ssocks5hr)AsyncSocks5Connection) proxy_origin proxy_auth remote_originrTrXrYrZr^shttp)AsyncForwardHTTPConnection)rc proxy_headersproxy_ssl_contextrerXr^)AsyncTunnelHTTPConnection) rcrgrhrerTrXrYrZr^) originrTrXrYrZr[r\r]r^r_)rCurlscheme socks_proxyrbrjauthrBrIrJrKrO http_proxyrfheadersrTrirrLrMrNrP)rrjrbrfris rcreate_connection%AsyncConnectionPool.create_connections ;; "{{%%)@@>,!%!7!7#{{//"( $ 1 1%)%;%;++++$($9$9  ')B1!%!7!7"&++"5"5&*kk&=&="(%)%;%;$($9$9  >,![[__33"kk11"&++"9"9$ --!%!7!7kkkk $ 5 5  #))!33++++MM--  11//  r!c,[UR5$)a{ Return a list of the connections currently in the pool. For example: ```python >>> pool.connections [ , , , ] ``` )listrQr's r connectionsAsyncConnectionPool.connectionss D%%&&r!c # URRR5nUS:Xa [S5eUS;a[SUS35eURR S05nUR SS5nUR  [U5nURRU5 SSS5 UR  UR5nSSS5 URW5IShvN WRUS 9IShvN nURUR5IShvN n['UR([*R,5(de[/UR0UR2[5UR(XPS 9URS 9$!,(df  N=f!,(df  N=fNNN![a UR!5 Of=fGM,!["atn UR  URR%W5 UR5nSSS5 O!,(df  O=fURW5IShvN U SeSn A ff=f7f) z Send an HTTP request, and return an HTTP response. This is the core implementation that is called into by `.request()` or `.stream()`. z;Request URL is missing an 'http://' or 'https://' protocol.)httphttpswswssz)Request URL has an unsupported protocol 'z://'.r,poolNr+)stream pool_requestr})statusrpcontent extensions)rkrldecoder rgetrSrrRappend_assign_requests_to_connections_close_connectionsr.handle_async_requestrrr( BaseExceptionremove isinstancer~typing AsyncIterabler rrpPoolByteStream) rrrltimeoutsr,rclosingrresponseexcs rr(AsyncConnectionPool.handle_async_requests/ ##**, R<%M  7 7%;F85I %%)))R8,,vt,  ' '+G4L NN ! !, /( ! //#BBDG0--g666$0#C#CG#C#TT  %/%D%D$,,& H(//6+?+?@@@@??$$"\ **   W( '0/7U .4 !113 40 ++%%l3>>@ ,++ ))'2 2 24  sBI%'F.I%7 G$F*G$1F;2G$F= G$G,F?-G1A(I% F'#I%* F84G$=G$?GGG$GG$$ I". I:,H/& I/ H= 9IIII""I%c /n[UR5HnUR5(aURRU5 M5UR 5(a.URRU5 UR U5 MxUR 5(dM[URVs/sHo"R 5PM sn5UR:dMURRW5 UR U5 GM URVs/sHo3R5(dMUPM nnUGHnURRRnURVs/sH4nURU5(dMUR5(dM2UPM6 nnURVs/sHo"R 5(dMUPM nnU(aUSnUR!U5 M[UR5UR":a@UR%U5nURR U5 UR!U5 GM#U(dGM-USnURRU5 UR U5 UR%U5nURR U5 UR!U5 GM U$s snfs snfs snfs snf)a Manage the state of the connection pool, assigning incoming requests to connections as available. Called whenever a new request is added or removed from the pool. Any closing connections are returned, allowing the I/O for closing those connections to be handled seperately. r)rtrQ is_closedr has_expiredris_idlelenrGrRr1rrkrjcan_handle_request is_availabler$rFrq) rclosing_connectionsrrqueued_requestsrrjavailable_connectionsidle_connectionss rr3AsyncConnectionPool._assign_requests_to_connectionss!t001J##%%!!((4''))!!((4#**:6""$$@Q@QR@Q*++-@QRS112!!((4#**:62$37..X.wDUDUDW7.X+L!))--44F#'"3"3%"3J008=G=T=T=V"3 "% .2->-> ->zBTBTBV ->  %215 11*=T&&'$*?*??!33F; !!((411*=!!-a0 !!((4#**:6!33F; !!((411*=E,H#"[SY%  s0:K1 )K6K6K;K;6K; L(Lc# [5 UHnUR5IShvN M SSS5 gN!,(df  g=f7fr)raclose)rrrs rr&AsyncConnectionPool._close_connectionsUs: $ &%  '')))&' &)' &s% A :8: A : AA c# UR [UR5n/UlSSS5 URW5IShvN g!,(df  N(=fN7fr)rSrtrQr)rrs rrAsyncConnectionPool.aclose[sS ' '"&t'8'8"9  "D (%%&9:::( ' ;s' A!AA!A A! AA!c# U$7frr=r's r __aenter__AsyncConnectionPool.__aenter__cs  sc@# UR5IShvN gN7fr)r)rexc_type exc_value tracebacks r __aexit__AsyncConnectionPool.__aexit__fs kkms cURRnUR URVs/sHo"R 5PM nnUR Vs/sHoDR 5PM nnURS5nURS5nURS5nURS5n SSS5 SWSWS3n SWSW S3n SUS U S U S 3$s snfs snf!,(df  N6=f) NFTz Requests: z active, z queuedz Connections: z idle) __class__r8rSrRr1rQrcount) r class_namerrequest_is_queuedrconnection_is_idlenum_active_requestsnum_queued_requestsnum_active_connectionsnum_idle_connections requests_infoconnection_infos r__repr__AsyncConnectionPool.__repr__ns^^,,  ' 'DHNN SN!2!2!4N  S7;7H7H"7H""$7H "#4"9"9%"@ "3"9"9$"? %7%=%=e%D "#5#;#;D#A (,-Y7J6K7 S 239=QN7 N7`3 j''"E NE#N* ; 04*.04 ,(.   Gr!r?cB\rSrSrSSjrSSjrS SjrSrg) ric6XlX lX0lSUlg)NF)_stream _pool_request_pool_closed)rr~rr}s rrPoolByteStream.__init__s  )  r!c# URShvN nU7v MN g![a!nUR5IShvN USeSnAff=f7fr)rrr)rpartrs r __aiter__PoolByteStream.__aiter__sJ "ll d  l ++-  4  sHA $" "$"$A AA AA  AAc@# UR(dSUl[5 [URS5(a"URR 5IShvN SSS5 UR R  UR RRUR5 UR R5nSSS5 UR RW5IShvN ggN!,(df  N=f!,(df  NF=fN*7f)NTr) rrhasattrrrrrSrRrrrr)rrs rrPoolByteStream.acloses||DL(*4<<22,,--///+11 $$++D,>,>?**DDF2**//8 8 80+*21 9sS#D9C:C8C:#DA D  &D1D2D8C:: DD DD)rrrrN)r~ztyping.AsyncIterable[bytes]rrr}r?r3r4)r3ztyping.AsyncIterator[bytes]r5)r8r9r:r;rrrr<r=r!rrrs7 + ' "     9r!r) __future__rsslrDtypesr_backends.autor_backends.baserr _exceptionsrr _modelsr r r r _synchronizationrrrrr interfacesrrrr?rr=r!rrsU" (?E66SS+G''4WG/WGt 99r!