6=g;BSSKJr 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) SyncBackend) SOCKET_OPTIONNetworkBackend)ConnectionNotAvailableUnsupportedProtocol)OriginProxyRequestResponse)EventShieldCancellation ThreadLock)HTTPConnection)ConnectionInterfaceRequestInterfacecR\rSrSrS SjrS SjrS SjrS S SjjrSSjrSr g) PoolRequestc<XlSUl[5UlgN)request connectionr_connection_acquired)selfrs @/usr/lib/python3/dist-packages/httpcore/_sync/connection_pool.py__init__PoolRequest.__init__s 6:$)G!cDXlURR5 gr)rrset)rrs rassign_to_connection PoolRequest.assign_to_connections$ !!%%'r!c0SUl[5Ulgr)rrrrs rclear_connectionPoolRequest.clear_connections$)G!r!NcURcURRUS9 URceUR$)Ntimeout)rrwait)rr,s rwait_for_connectionPoolRequest.wait_for_connections? ?? "  % % * *7 * ;***r!cURSL$r)rr's r is_queuedPoolRequest.is_queued's$&&r!)rrr)rr returnNone)rzConnectionInterface | Noner3r4r3r4r)r, float | Noner3r)r3bool) __name__ __module__ __qualname____firstlineno__rr$r(r.r1__static_attributes__r!rrrs0, (, '+# 'r!rc\rSrSrSrSSSjjrSSjr\SSj5rSSjr SSjr SS jr SS jr SS jr SSS jjrSS jrSrg)ConnectionPool+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 rrConnectionPool.__init__0sX( *2CKK  )0 KK* ' +.  ! !4#B#B+ '"2   + -4KM/  .8:,. &0\"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)Socks5Connection) proxy_origin proxy_auth remote_originrTrXrYrZr^shttp)ForwardHTTPConnection)rc proxy_headersproxy_ssl_contextrerXr^)TunnelHTTPConnection) rcrgrhrerTrXrYrZr^) originrTrXrYrZr[r\r]r^r_)rCurlscheme socks_proxyrbrjauthrBrIrJrKrO http_proxyrfheadersrTrirrLrMrNrP)rrjrbrfris rcreate_connection ConnectionPool.create_connections ;; "{{%%)@@9'!%!7!7#{{//"( $ 1 1%)%;%;++++$($9$9  ')=,!%!7!7"&++"5"5&*kk&=&="(%)%;%;$($9$9  9'![[__33"kk11"&++"9"9$ --!%!7!7kkkk $ 5 5  ))!33++++MM--  11//  r!c,[UR5$)al Return a list of the connections currently in the pool. For example: ```python >>> pool.connections [ , , , ] ``` )listrQr's r connectionsConnectionPool.connectionss D%%&&r!c xURRR5nUS:Xa [S5eUS;a[SUS35eURR S05nUR SS5nUR  [U5nURRU5 SSS5 UR  UR5nSSS5 URW5 WRUS 9nURUR5n['UR([*R,5(de[/UR0UR2[5UR(XPS 9URS 9$!,(df  N=f!,(df  N=f![a UR!5 Of=fGM!["akn UR  URR%W5 UR5nSSS5 O!,(df  O=fURW5 U SeSn A ff=f) 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_requestrrr( BaseExceptionremove isinstancer~typingIterabler rrpPoolByteStream) rrrltimeoutsr,rclosingrresponseexcs rrConnectionPool.handle_requests ##**, R<%M  7 7%;F85I %%)))R8,,vt,  ' '&w/L NN ! !, /( ! //#BBDG0''0*==g=N  )88$,, H(//6??;;;;??$$"\ **   W( '0/.4 !113 40 ++%%l3>>@ ,++  # #G ,4  sr'E?5 GF(G<F!? F  FG!F>;G=F>>G H9 H4,H H4 H H44H9c /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 rr.ConnectionPool._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 UHnUR5 M SSS5 g!,(df  g=fr)rclose)rrrs rr!ConnectionPool._close_connectionsUs*  !%   "&" ! !s. <cUR [UR5n/UlSSS5 URW5 g!,(df  N =fr)rSrtrQr)rrs rrConnectionPool.close[sE ' '"&t'8'8"9  "D (  34( 's A AcU$rr=r's r __enter__ConnectionPool.__enter__cs r!c$UR5 gr)r)rexc_type exc_value tracebacks r__exit__ConnectionPool.__exit__fs r!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__ConnectionPool.__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=QN2 N2`3 j''"E NE#N# 5 04*.04 ,(.   Gr!r?cB\rSrSrSSjrSSjrS SjrSrg) ric6XlX lX0lSUlg)NF)_stream _pool_request_pool_closed)rr~rr}s rrPoolByteStream.__init__s  )  r!c## URHnUv M g![anUR5 USeSnAff=f7fr)rrr)rpartrs r__iter__PoolByteStream.__iter__s=   % JJL4  sAA >9>AcUR(dSUl[5 [URS5(aURR 5 SSS5 UR R  UR RRUR5 UR R5nSSS5 UR RW5 gg!,(df  N=f!,(df  N<=f)NTr) rrhasattrrrrrSrRrrrr)rrs rrPoolByteStream.closes||DL#%4<<11LL&&(&11 $$++D,>,>?**DDF2 JJ ) )' 2%%21s6C&7A C7& C47 D)rrrrN)r~ztyping.Iterable[bytes]rrr}r?r3r4)r3ztyping.Iterator[bytes]r5)r8r9r:r;rrrr<r=r!rrrs7 & "      3r!r) __future__rsslrDtypesr_backends.syncr_backends.baserr _exceptionsrr _modelsr r r r _synchronizationrrrrr interfacesrrrr?rr=r!rrsU" (:E66DD&=''4WG%WGt 33r!