Ë
    Eü´j” ã                   ó  — d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm	Z	m
Z
 d dlmZmZmZmZ d dlmZ d dlmZ d dlmZmZmZ d dlmZ d dlmZ d d	lmZmZmZm Z m!Z!m"Z" d dl#Z#d d
l#m$Z$m%Z% ddl&m'Z'm(Z( ddl)m*Z*m+Z+ ddl,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8 ddl9m:Z: ddl;m<Z<m=Z=m>Z> ddl(m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZF ddlGmHZH ddlImJZJ ej–                  dk\  rd dlmLZL n	e!eMeNddf   ZLerd dlOZOeOj                   ZPn	 d dlOZOeOj                   ZP eSdh«      ZT eSddh«      ZU eSddh«      ZVeUeTz  ZWeWeVz  ZXdej–                  cxk  xr dk  nc xs ej–                  dk  ZYd ZZerdd!l[m\Z\ dd"l;m]Z] dd#l^m_Z_  G d$„ d%«      Z`d&eaeeR      d'dfd(„Zb G d)„ d*«      Zc G d+„ d,ec«      Zd G d-„ d.«      Ze G d/„ d0«      Zf G d1„ d2«      Zgd3ehd'ePfd4„Zi eid5«      Zj eid6«      Zk G d7„ d8ef«      Zl G d9„ d:ef«      Zm G d;„ d<ef«      Zny# eQ$ r dZOeRZPY Œøw xY w)=é    N)ÚOrderedDictÚdefaultdictÚdeque)Ú	AwaitableÚCallableÚIteratorÚSequence)Úsuppress)Ú
HTTPStatus)ÚchainÚcycleÚislice)Ú	monotonic)ÚTracebackType)ÚTYPE_CHECKINGÚAnyÚLiteralÚOptionalÚUnionÚcast)ÚAddrInfoTypeÚSocketFactoryTypeé   )ÚhdrsÚhelpers)ÚAbstractResolverÚResolveResult)ÚClientConnectionErrorÚClientConnectorCertificateErrorÚClientConnectorDNSErrorÚClientConnectorErrorÚClientConnectorSSLErrorÚClientHttpProxyErrorÚClientProxyConnectionErrorÚInvalidUrlClientErrorÚServerFingerprintMismatchÚUnixClientConnectorErrorÚcert_errorsÚ
ssl_errors)ÚResponseHandler)ÚClientRequestÚFingerprintÚ_merge_ssl_params)Ú	_SENTINELÚceil_timeoutÚis_canonical_ipv4_addressÚis_ip_addressÚnoopÚsentinelÚset_exceptionÚ
set_result)Úclient_logger)ÚDefaultResolver©é   é   )ÚBufferzmemoryview[int]zmemoryview[bytes]Ú ÚhttpÚhttpsÚwsÚwss)r9   é   r   )r9   rA   r   )r9   r:   é   )ÚBaseConnectorÚTCPConnectorÚUnixConnectorÚNamedPipeConnectorr   r   )ÚClientTimeout)ÚConnectionKey)ÚTracec                   ó:   — e Zd ZdZdee   ddfd„Zdefd„Zdd„Zy)	Ú_DeprecationWaiter©Ú
_awaitableÚ_awaitedÚ	awaitableÚreturnNc                 ó    — || _         d| _        y ©NFrL   )ÚselfrO   s     úO/root/workspace/ytshorts/venv/lib/python3.12/site-packages/aiohttp/connector.pyÚ__init__z_DeprecationWaiter.__init__h   s   € Ø#ˆŒØˆ�ó    c                 óD   — d| _         | j                  j                  «       S )NT)rN   rM   Ú	__await__©rS   s    rT   rX   z_DeprecationWaiter.__await__l   s   € ØˆŒØ�‰×(Ñ(Ó*Ð*rV   c                 óR   — | j                   st        j                  dt        «       y y )NzDConnector.close() is a coroutine, please use await connector.close())rN   ÚwarningsÚwarnÚDeprecationWarningrY   s    rT   Ú__del__z_DeprecationWaiter.__del__p   s"   € Ø�}Š}Ü�M‰Mð5ä"õð rV   ©rP   N)	Ú__name__Ú
__module__Ú__qualname__Ú	__slots__r   r   rU   rX   r^   © rV   rT   rK   rK   e   s/   „ Ø*€Ið )¨C¡.ð °Tó ð+˜3ó +ôrV   rK   ÚwaitersrP   c              ƒ   ó¦   K  — t        j                  | ddiŽƒ d{  –—† }|D ])  }t        |t        «      sŒt	        j
                  d|«       Œ+ y7 Œ3­w)z'Wait for all waiters to finish closing.Úreturn_exceptionsTNz!Error while closing connector: %r)ÚasyncioÚgatherÚ
isinstanceÚ	Exceptionr6   Údebug)re   ÚresultsÚress      rT   Ú_wait_for_closero   y   sN   è ø€ ä—N‘N GÐD¸tÑD×D€GØò JˆÜ�cœ9Õ%Ü×ÑÐ CÀSÕIñJð Eús   ‚A›AœA¶Ac            
       ó0  — e Zd ZdZdddddedej                  ddf
d	„Zdefd
„Z	e
fdeddfd„Zded   fd„Zedej                  fd„«       Zedej"                  dz  fd„«       Zededz  fd„«       Zdeg df   ddfd„Zdd„Zdd„Zdd„Zedefd„«       Zy)Ú
ConnectionNÚ	connectorrC   ÚkeyrH   ÚprotocolÚlooprP   c                 óÆ   — || _         || _        || _        || _        g | _        |j                  «       r.t        j                  t        j                  d«      «      | _
        y y )Nr   )Ú_keyÚ
_connectorÚ_loopÚ	_protocolÚ
_callbacksÚ	get_debugÚ	tracebackÚextract_stackÚsysÚ	_getframeÚ_source_traceback)rS   rr   rs   rt   ru   s        rT   rU   zConnection.__init__…   sR   € ð ˆŒ	Ø#ˆŒØˆŒ
Ø19ˆŒØ46ˆŒà�>‰>ÔÜ%.×%<Ñ%<¼S¿]¹]È1Ó=MÓ%NˆDÕ"ð rV   c                 ó"   — d| j                   › d�S )NzConnection<ú>)rw   rY   s    rT   Ú__repr__zConnection.__repr__•   s   € Ø˜TŸY™Y˜K qÐ)Ð)rV   Ú	_warningsc                 ól  — | j                   �¨d| i} |j                  d| ›�t        fi |¤Ž | j                  j	                  «       ry | j
                  j                  | j                  | j                   d¬«       | ddœ}| j                  �| j                  |d<   | j                  j                  |«       y y )NÚsourcezUnclosed connection T©Úshould_closezUnclosed connection)Úclient_connectionÚmessageÚsource_traceback)
rz   r\   ÚResourceWarningry   Ú	is_closedrx   Ú_releaserw   r�   Úcall_exception_handler)rS   r…   ÚkwargsÚcontexts       rT   r^   zConnection.__del__˜   s¦   € Ø�>‰>Ð%Ø Ð%ˆFØˆI�N‰NÐ1°$°Ð:¼OÑVÈvÒVØ�z‰z×#Ñ#Ô%Øà�O‰O×$Ñ$ T§Y¡Y°·±ÈTÐ$ÔRà,0Ð=RÑSˆGØ×%Ñ%Ð1Ø.2×.DÑ.D�Ð*Ñ+Ø�J‰J×-Ñ-¨gÕ6ð &rV   Tc                  ó   — y)z9Force subclasses to not be falsy, to make checks simpler.Trd   rY   s    rT   Ú__bool__zConnection.__bool__¦   s   € àrV   c                 óR   — t        j                  dt        d¬«       | j                  S )Nz%connector.loop property is deprecatedé   ©Ú
stacklevel)r[   r\   r]   ry   rY   s    rT   ru   zConnection.loopª   s#   € ä�‰Ø3Ô5GÐTUõ	
ð �z‰zÐrV   c                 óH   — | j                   €y | j                   j                  S ©N)rz   Ú	transportrY   s    rT   r›   zConnection.transport±   s   € à�>‰>Ð!ØØ�~‰~×'Ñ'Ð'rV   c                 ó   — | j                   S rš   )rz   rY   s    rT   rt   zConnection.protocol·   s   € à�~‰~ÐrV   Úcallbackc                 ó@   — |�| j                   j                  |«       y y rš   )r{   Úappend)rS   r�   s     rT   Úadd_callbackzConnection.add_callback»   s   € ØÐØ�O‰O×"Ñ" 8Õ,ð  rV   c                 ó–   — | j                   d d  g c}| _         |D ]!  }t        t        «      5   |«        d d d «       Œ# y # 1 sw Y   Œ.xY wrš   )r{   r
   rk   )rS   Ú	callbacksÚcbs      rT   Ú_notify_releasezConnection._notify_release¿   sO   € Ø%)§_¡_±QÐ%7¸Ð"ˆ	�4”?àò 	ˆBÜœ)Ó$ñ Ù”÷ð ñ	÷ð ús	   ¬?¿A	c                 ó°   — | j                  «        | j                  �:| j                  j                  | j                  | j                  d¬«       d | _        y y )NTrˆ   ©r¤   rz   rx   r�   rw   rY   s    rT   ÚclosezConnection.closeÆ   sE   € Ø×ÑÔà�>‰>Ð%Ø�O‰O×$Ñ$ T§Y¡Y°·±ÈTÐ$ÔRØ!ˆD�Nð &rV   c                 ó¬   — | j                  «        | j                  �8| j                  j                  | j                  | j                  «       d | _        y y rš   r¦   rY   s    rT   ÚreleasezConnection.releaseÍ   s@   € Ø×ÑÔà�>‰>Ð%Ø�O‰O×$Ñ$ T§Y¡Y°·±Ô?Ø!ˆD�Nð &rV   c                 óX   — | j                   d u xs | j                   j                  «        S rš   )rz   Úis_connectedrY   s    rT   ÚclosedzConnection.closedÔ   s&   € à�~‰~ Ð%ÒJ¨T¯^©^×-HÑ-HÓ-JÐ)JÐJrV   r_   )r`   ra   rb   r�   r*   rh   ÚAbstractEventLooprU   Ústrr„   r[   r   r^   r   r”   Úpropertyru   Ú	Transportr›   rt   r   r    r¤   r§   r©   Úboolr¬   rd   rV   rT   rq   rq   �   s-  „ àÐðOà"ðOð ðOð "ð	Oð
 ×'Ñ'ðOð 
óOð *˜#ó *ð (0ñ 7 ð 7°Dó 7ð˜' $™-ó ð ð�g×/Ñ/ò ó ðð ð(˜7×,Ñ,¨tÑ3ò (ó ð(ð
 ð˜/¨DÑ0ò ó ðð- X¨b°$¨hÑ%7ð -¸Dó -óó"ó"ð ðK˜ò Kó ñKrV   rq   c                   ó   — e Zd ZdZdd„Zy)Ú_ConnectTunnelConnectiona¨  Special connection wrapper for CONNECT tunnels that must never be pooled.

    This connection wraps the proxy connection that will be upgraded with TLS.
    It must never be released to the pool because:
    1. Its 'closed' future will never complete, causing session.close() to hang
    2. It represents an intermediate state, not a reusable connection
    3. The real connection (with TLS) will be created separately
    Nc                  ó   — y)aa  Do nothing - don't pool or close the connection.

        These connections are an intermediate state during the CONNECT tunnel
        setup and will be cleaned up naturally after the TLS upgrade. If they
        were to be pooled, they would never be properly closed, causing
        session.close() to wait forever for their 'closed' future.
        Nrd   rY   s    rT   r©   z _ConnectTunnelConnection.releaseã   ó   � rV   r_   )r`   ra   rb   Ú__doc__r©   rd   rV   rT   r³   r³   Ù   s   „ ñôrV   r³   c                   óT   — e Zd ZdZdZdej                  edz     ddfd„Zd	d„Z	d	d„Z
y)
Ú_TransportPlaceholderz.placeholder for BaseConnector.connect function©r¬   r›   Úclosed_futureNrP   c                 ó    — || _         d| _        y)z)Initialize a placeholder for a transport.Nr¹   )rS   rº   s     rT   rU   z_TransportPlaceholder.__init__ò   s   € à#ˆŒØˆ�rV   c                  ó   — y)zClose the placeholder.Nrd   rY   s    rT   r§   z_TransportPlaceholder.close÷   rµ   rV   c                  ó   — y)z%Abort the placeholder (does nothing).Nrd   rY   s    rT   Úabortz_TransportPlaceholder.abortú   rµ   rV   r_   )r`   ra   rb   r¶   rc   rh   ÚFuturerk   rU   r§   r¾   rd   rV   rT   r¸   r¸   í   s5   „ Ù8à'€Ið g§n¡n°YÀÑ5EÑ&Fð È4ó ó
%ô4rV   r¸   c                   ób  — e Zd ZdZdZdZdZeZe	ddddddd	œd
e
dz  ez  dededededej                  dz  deddfd„Zefdeddfd„Zd;d„Zdeddfd„Zd;d„Z	 	 	 d<dee   dz  dedz  dedz  ddfd„Zedefd„«       Zedefd„«       Zedefd„«       Zd=d „Zd=d!„Z dd"œd#ede!d   fd$„Z"dd"œd#ede#e!e
      fd%„Z$edefd&„«       Z%d'd(defd)„Z&d*e'de'fd+„Z(d*e'd,e#d-   d.d/de)fd0„Z*d'd(d,e#d-   ddfd1„Z+d'd(d,e#d-   de)dz  fd2„Z,d=d3„Z-d'd(d4e.ddfd5„Z/dd6œd'd(d7e.d8eddfd9„Z0d*e'd,e#d-   d.d/de.fd:„Z1y)>rC   a\  Base connector class.

    keepalive_timeout - (optional) Keep-alive timeout.
    force_close - Set to True to force close and do reconnect
        after each request (and between redirects).
    limit - The total number of simultaneous connections.
    limit_per_host - Number of simultaneous connections to one host.
    enable_cleanup_closed - Enables clean-up closed ssl transports.
                            Disabled by default.
    timeout_ceil_threshold - Trigger ceiling of timeout values when
                             it's above timeout_ceil_threshold.
    loop - Optional event loop.
    TNg       @Féd   r   é   ©Úkeepalive_timeoutÚforce_closeÚlimitÚlimit_per_hostÚenable_cleanup_closedru   Útimeout_ceil_thresholdrÄ   rÅ   rÆ   rÇ   rÈ   ru   rÉ   rP   c                ól  — |r|�|t         urt        d«      ‚|t         u rd}|xs t        j                  «       }|| _        d| _        |j                  «       r-t        j                  t        j                  d«      «      | _        t        t        «      | _        || _        || _        t#        «       | _        t        t"        «      | _        t)        t*        |«      | _        || _        t        t0        «      | _        || _        t7        j8                  t:        |¬«      | _        d | _        d | _         |r5tB        s/tE        jF                  dt        jH                  › �tJ        d¬«       d}| | _&        g | _'        |jQ                  «       | _)        | jR                  jU                  d «       | jW                  «        y )	Nz6keepalive_timeout cannot be set if force_close is Trueg      .@Fr   ©ru   zoenable_cleanup_closed ignored because https://github.com/python/cpython/pull/118960 is fixed in Python version r–   r—   ),r3   Ú
ValueErrorrh   Úget_running_loopÚ_timeout_ceil_thresholdÚ_closedr|   r}   r~   r   r€   r�   r   r   Ú_connsÚ_limitÚ_limit_per_hostÚsetÚ	_acquiredÚ_acquired_per_hostr   ÚfloatÚ_keepalive_timeoutÚ_force_closer   Ú_waitersry   Ú	functoolsÚpartialr*   Ú_factoryÚ_cleanup_handleÚ_cleanup_closed_handleÚNEEDS_CLEANUP_CLOSEDr[   r\   Úversion_infor]   Ú_cleanup_closed_disabledÚ_cleanup_closed_transportsÚcreate_futureÚ_placeholder_futurer5   Ú_cleanup_closed)rS   rÄ   rÅ   rÆ   rÇ   rÈ   ru   rÉ   s           rT   rU   zBaseConnector.__init__  s˜  € ñ Ø Ð,Ð1BÌ(Ñ1RÜ ØLóð ð !¤HÑ,Ø$(Ð!àÒ1”w×/Ñ/Ó1ˆØ'=ˆÔ$àˆŒØ�>‰>ÔÜ%.×%<Ñ%<¼S¿]¹]È1Ó=MÓ%NˆDÔ"ô œÓð 	Œð ˆŒØ-ˆÔÜ/2«uˆŒäœÓð 	Ôô #'¤uÐ.?Ó"@ˆÔØ'ˆÔô œÓ$ð 	Œð ˆŒ
Ü!×)Ñ)¬/ÀÔEˆŒð <@ˆÔð CGˆÔ#á Õ)=Ü�M‰Mð%ä%(×%5Ñ%5Ð$6ð8ô #Øõð %*Ð!à,AÐ(AˆÔ%ØJLˆÔ'à×ÑÓ ð 	Ô ð 	× Ñ ×+Ñ+¨DÔ1Ø×ÑÕrV   r…   c                 óx  — | j                   ry | j                  sy | j                  j                  «       D �cg c]  }t        |«      ‘Œ }}| j	                  «        d| i} |j
                  d| ›�t        fi |¤Ž | |ddœ}| j                  �| j                  |d<   | j                  j                  |«       y c c}w )Nr‡   zUnclosed connector zUnclosed connector)rr   Úconnectionsr‹   rŒ   )
rÏ   rÐ   ÚvaluesÚreprÚ_closer\   r�   r�   ry   r�   )rS   r…   ÚcÚconnsr‘   r’   s         rT   r^   zBaseConnector.__del__b  s°   € Ø�<Š<ØØ�{Š{Øà"&§+¡+×"4Ñ"4Ó"6Ö7˜Q”�a•Ð7ˆÐ7à�‰Œà˜DÐ!ˆØˆ	�‰Ð,¨T¨HÐ5´ÑQÈ&ÒQàØ Ø+ñ
ˆð
 ×!Ñ!Ð-Ø*.×*@Ñ*@ˆGÐ&Ñ'Ø�
‰
×)Ñ)¨'Õ2ùò 8s   ·B7c                 ó:   — t        j                  dt        «       | S )NzH"with Connector():" is deprecated, use "async with Connector():" instead)r[   r\   r]   rY   s    rT   Ú	__enter__zBaseConnector.__enter__w  s   € Ü�‰ð4äô	
ð
 ˆrV   Úexcc                 ó$   — | j                  «        y rš   )rê   )rS   rï   s     rT   Ú__exit__zBaseConnector.__exit__  s   € Ø�‰�rV   c              ƒ   ó   K  — | S ­wrš   rd   rY   s    rT   Ú
__aenter__zBaseConnector.__aenter__‚  s   è ø€ Øˆùs   ‚Úexc_typeÚ	exc_valueÚexc_tracebackc              ƒ   ó@   K  — | j                  «       ƒ d {  –—†  y 7 Œ­wrš   )r§   )rS   rô   rõ   rö   s       rT   Ú	__aexit__zBaseConnector.__aexit__…  s   è ø€ ð �j‰j‹l×Òús   ‚–—c                 ó   — | j                   S )z1Ultimately close connection on releasing if True.)rØ   rY   s    rT   rÅ   zBaseConnector.force_close�  s   € ð × Ñ Ð rV   c                 ó   — | j                   S )z‘The total number for simultaneous connections.

        If limit is 0 the connector has no limit.
        The default limit size is 100.
        )rÑ   rY   s    rT   rÆ   zBaseConnector.limit’  s   € ð �{‰{ÐrV   c                 ó   — | j                   S )z¡The limit for simultaneous connections to the same endpoint.

        Endpoints are the same if they are have equal
        (host, port, is_ssl) triple.
        )rÒ   rY   s    rT   rÇ   zBaseConnector.limit_per_host›  s   € ð ×#Ñ#Ð#rV   c                 óÎ  — | j                   r!| j                   j                  «        d| _         t        «       }| j                  }| j                  rÖt        t        «      }||z
  }| j                  j                  «       D ]ž  \  }}t        «       }|D ]‚  \  }}	|j                  «       r|	|z
  dk\  r|j                  ||	f«       Œ2|j                  }
|j                  «        | j                  rŒ[|j                  sŒh| j                  j                  |
«       Œ„ |sŒš|||<   Œ  || _        | j                  r4t        j                   | d|| j"                  | j$                  ¬«      | _         yy)zCleanup unused transports.Nr   Ú_cleanup©rÉ   )rÝ   Úcancelr   r×   rÐ   r   r   Úitemsr«   rŸ   r›   r§   rá   Úis_sslrâ   r   Úweakref_handlery   rÎ   )rS   ÚnowÚtimeoutrç   Údeadliners   rì   ÚaliveÚprotoÚuse_timer›   s              rT   rý   zBaseConnector._cleanup¤  s@  € à×ÒØ× Ñ ×'Ñ'Ô)ð $(ˆDÔ ä‹kˆØ×)Ñ)ˆà�;Š;Ü%¤eÓ,ˆKØ˜W‘}ˆHØ"Ÿk™k×/Ñ/Ó1ò -‘
��UÜ>C»g�Ø',ò J‘O�E˜8Ø×)Ñ)Ô+°¸8Ñ0CÀqÒ0HØŸ™ e¨XÐ%6Ô7Ø Ø %§¡�IØ—K‘K”MØ×8Ó8¸S¿Z»ZØ×7Ñ7×>Ñ>¸yÕIðJò Ø',�K Ò$ð-ð &ˆDŒKà�;Š;Ü#*×#9Ñ#9ØØØØ—
‘
Ø'+×'CÑ'Cô$ˆDÕ ð rV   c                 ó:  — | j                   r| j                   j                  «        | j                  D ]  }|€Œ|j                  «        Œ g | _        | j                  s>t        j                  | d| j                  | j                  | j                  ¬«      | _         yy)z~Double confirmation for transport close.

        Some broken ssl servers may leave socket open without proper close.
        Nrå   rþ   )
rÞ   rÿ   râ   r¾   rá   r   r  Ú_cleanup_closed_periodry   rÎ   )rS   r›   s     rT   rå   zBaseConnector._cleanup_closedË  sŽ   € ð
 ×&Ò&Ø×'Ñ'×.Ñ.Ô0à×8Ñ8ò 	"ˆIØÑ$Ø—‘Õ!ð	"ð +-ˆÔ'à×,Ò,Ü*1×*@Ñ*@ØØ!Ø×+Ñ+Ø—
‘
Ø'+×'CÑ'Cô+ˆDÕ'ð -rV   ©Ú	abort_sslr  c                ó2  — | j                  |¬«      x}st        t        «       «      S t        |«      }t        j
                  dk\  r-t        j                  || j                  d¬«      }t        |«      S | j                  j                  |«      }t        |«      S )a  Close all opened transports.

        :param abort_ssl: If True, SSL connections will be aborted immediately
                         without performing the shutdown handshake. This provides
                         faster cleanup at the cost of less graceful disconnection.
        r  r8   T©ru   Úeager_start)
rê   rK   r2   ro   r   rà   rh   ÚTaskry   Úcreate_task)rS   r  re   ÚcoroÚtasks        rT   r§   zBaseConnector.closeâ  s‡   € ð  Ÿ;™;°˜;Ó;Ð;�Ð;ô &¤d£fÓ-Ð-Ü˜wÓ'ˆÜ×Ñ˜wÒ&ô —<‘< ¨4¯:©:À4ÔHˆDô " $Ó'Ð'ð —:‘:×)Ñ)¨$Ó/ˆDÜ! $Ó'Ð'rV   c                ó|  — g }| j                   r|S d| _         	 | j                  j                  «       r®|| j                  j	                  «        | j
                  j	                  «        | j                  j                  «       D ]  }|D ]  }|j                  «        Œ Œ | j                  j	                  «        d | _	        | j                  j	                  «        d | _        S | j                  r| j                  j                  «        | j                  r| j                  j                  «        | j                  j                  «       D ]v  }|D ]o  \  }}|r8|j                  r,|j                  j                  d«      �|j                  «        n|j                  «        |j                   x}sŒ_|j#                  |«       Œq Œx | j
                  D ]l  }|r8|j                  r,|j                  j                  d«      �|j                  «        n|j                  «        |j                   x}sŒ\|j#                  |«       Œn | j                  D ]  }	|	€Œ|	j                  «        Œ || j                  j	                  «        | j
                  j	                  «        | j                  j                  «       D ]  }|D ]  }|j                  «        Œ Œ | j                  j	                  «        d | _	        | j                  j	                  «        d | _        S # | j                  j	                  «        | j
                  j	                  «        | j                  j                  «       D ]  }|D ]  }|j                  «        Œ Œ | j                  j	                  «        d | _	        | j                  j	                  «        d | _        w xY w)NTÚ
sslcontext)rÏ   ry   rŽ   rÐ   ÚclearrÔ   rÙ   rè   rÿ   rÝ   râ   rÞ   r›   Úget_extra_infor¾   r§   r¬   rŸ   )
rS   r  re   Úkeyed_waitersÚkeyed_waiterÚdatar  Ú_r¬   r›   s
             rT   rê   zBaseConnector._closeö  s  € Ø+-ˆà�<Š<ØˆNàˆŒð4	/Ø�z‰z×#Ñ#Ô%ØðT �K‰K×ÑÔØ�N‰N× Ñ Ô"Ø!%§¡×!5Ñ!5Ó!7ò *�Ø$1ò *�LØ ×'Ñ'Õ)ñ*ð*ð �M‰M×ÑÔ!Ø#'ˆDÔ Ø×+Ñ+×1Ñ1Ô3Ø*.ˆDÕ'ð_ ×#Ò#Ø×$Ñ$×+Ñ+Ô-ð ×*Ò*Ø×+Ñ+×2Ñ2Ô4àŸ™×*Ñ*Ó,ò /�Ø $ò 
/‘H�E˜1á!Ø!ŸOšOØ!ŸO™O×:Ñ:¸<ÓHÐTàŸ™�àŸ™œØ!&§¡Ð-�vÑ-ØŸ™ vÕ.ñ
/ð/ð Ÿ™ò 
+�áØŸšØŸ™×6Ñ6°|ÓDÐPà—K‘K•Mà—K‘K”MØ"Ÿ\™\Ð)�6Ñ)Ø—N‘N 6Õ*ð
+ð "×<Ñ<ò &�	ØÑ(Ø—O‘OÕ%ð&ð ð �K‰K×ÑÔØ�N‰N× Ñ Ô"Ø!%§¡×!5Ñ!5Ó!7ò *�Ø$1ò *�LØ ×'Ñ'Õ)ñ*ð*ð �M‰M×ÑÔ!Ø#'ˆDÔ Ø×+Ñ+×1Ñ1Ô3Ø*.ˆDÕ'øð �K‰K×ÑÔØ�N‰N× Ñ Ô"Ø!%§¡×!5Ñ!5Ó!7ò *�Ø$1ò *�LØ ×'Ñ'Õ)ñ*ð*ð �M‰M×ÑÔ!Ø#'ˆDÔ Ø×+Ñ+×1Ñ1Ô3Ø*.ˆDÕ'ús&   ™L Ã!C	L Æ+A<L È($L ÉL ÌB.N;c                 ó   — | j                   S )z;Is connector closed.

        A readonly property.
        )rÏ   rY   s    rT   r¬   zBaseConnector.closed4  s   € ð �|‰|ÐrV   rs   rH   c                 óô   — d}| j                   r)| j                   t        | j                  «      z
  x}dk  r|S | j                  x}r2| j                  j                  |«      x}r|t        |«      z  }||kD  r|S |S )zå
        Return number of available connections.

        The limit, limit_per_host and the connection key are taken into account.

        If it returns less than 1 means that there are no connections
        available.
        r   r   )rÑ   ÚlenrÔ   rÒ   rÕ   Úget)rS   rs   Útotal_remainÚhost_remainÚacquireds        rT   Ú_available_connectionsz$BaseConnector._available_connections<  s†   € ð ˆà�;Š;¨D¯K©K¼#¸d¿n¹nÓ:MÑ,MÐM˜LÐRSÒSØÐð ×.Ñ.Ð.ˆ;Ð.Ø×2Ñ2×6Ñ6°sÓ;Ð;ˆxÐ;Øœs 8›}Ñ,�Ø˜kÒ)Ø"Ð"àÐrV   Úreqc                 ó   — |j                   }|€J ‚i }|j                  �|j                  }|j                  t        j                     |t        j                  <   t        t        j                  |||j                  | j                  |j                  ¬«      }|j                  j                  t        j                  d«      }|�L|j                  «       s||j                  t        j                  <   |S ||j                  t        j                  <   |S )znSet Proxy-Authorization header for non-SSL proxy requests and builds the proxy request for SSL proxy requests.N)ÚheadersÚauthru   Ússl)ÚproxyÚproxy_headersr&  r   ÚHOSTr+   ÚMETH_GETÚ
proxy_authry   r(  ÚpopÚAUTHORIZATIONr  ÚPROXY_AUTHORIZATION)rS   r$  Úurlr&  Ú	proxy_reqr'  s         rT   Ú-_update_proxy_auth_header_and_build_proxy_reqz;BaseConnector._update_proxy_auth_header_and_build_proxy_reqU  sä   € ð �i‰iˆØˆÐˆØ"$ˆØ×ÑÐ(Ø×'Ñ'ˆGØ Ÿ[™[¬¯©Ñ3ˆ”—	‘	ÑÜ!Ü�M‰MØØØ—‘Ø—‘Ø—‘ô
ˆ	ð × Ñ ×$Ñ$¤T×%7Ñ%7¸Ó>ˆØÐØ—:‘:”<Ø8<�—‘œD×4Ñ4Ñ5ð Ðð ?C�	×!Ñ!¤$×":Ñ":Ñ;ØÐrV   ÚtracesrI   r  rG   c              ƒ   óˆ  K  — |j                   }| j                  ||«      ƒ d{  –—† x}�|j                  r| j                  |«       |S t	        |j
                  |j                  «      4 ƒd{  –—†  | j                  |«      dk  rf| j                  ||«      ƒ d{  –—†  | j                  ||«      ƒ d{  –—† x}�0|j                  r| j                  |«       |cddd«      ƒd{  –—†  S t        t        t        | j                  «      «      }| j                  j                  |«       | j                  r| j                   |   j                  |«       	 |r|D ]  }|j#                  «       ƒ d{  –—†  Œ | j%                  |||«      ƒ d{  –—† }|r|D ]  }|j'                  «       ƒ d{  –—†  Œ | j(                  r|j+                  «        t-        d«      ‚ddd«      ƒd{  –—†  | j                  j3                  «       | j                  j                  «       | j                  r1| j                   |   }	|	j3                  |«       |	j                  |«       t5        | ||| j6                  «      S 7 �ŒQ7 �Œ
7 �Œß7 �ŒÈ7 �Œš7 �Œ7 Œù7 ŒÜ# t.        $ r | j1                  ||«       ‚ w xY w7 ŒÅ# 1 ƒd{  –—†7  sw Y   ŒÕxY w­w)z'Get from pool or create new connection.Nr   zConnector is closed.)Úconnection_keyÚ_getr)  r3  r/   ÚconnectÚceil_thresholdr#  Ú_wait_for_available_connectionr   r*   r¸   rä   rÔ   ÚaddrÒ   rÕ   Úsend_connection_create_startÚ_create_connectionÚsend_connection_create_endrÏ   r§   r   ÚBaseExceptionÚ_release_acquiredÚremoverq   ry   )
rS   r$  r4  r  rs   ÚconnÚplaceholderÚtracer  Úacquired_per_hosts
             rT   r8  zBaseConnector.connecto  s˜  è ø€ ð × Ñ ˆØŸ)™) C¨Ó0×0Ð0ˆDÐ=ð �yŠyØ×BÑBÀ3ÔGØˆKä §¡°×1GÑ1GÓH÷  	Hñ  	HØ×*Ñ*¨3Ó/°1Ò4Ø×9Ñ9¸#¸vÓF×FÐFØ"&§)¡)¨C°Ó"8×8Ð8�DÐEØ—y’yØ×JÑJÈ3ÔOØ÷ 	H÷  	Hñ  	Hô ÜÔ!6°t×7OÑ7OÓ!PóˆKð �N‰N×Ñ˜{Ô+Ø×#Ò#Ø×'Ñ'¨Ñ,×0Ñ0°Ô=ðHñ Ø!'ò C˜Ø#×@Ñ@ÓB×BÑBðCà"×5Ñ5°c¸6À7ÓK×K�ÙØ!'ò A˜Ø#×>Ñ>Ó@×@Ñ@ðAð —<’<Ø—K‘K”MÜ/Ð0FÓGÐG÷A 	H÷  	HðN 	�‰×Ñ˜kÔ*Ø�‰×Ñ˜5Ô!Ø×ÒØ $× 7Ñ 7¸Ñ <ÐØ×$Ñ$ [Ô1Ø×!Ñ! %Ô(Ü˜$  U¨D¯J©JÓ7Ð7ði 1ùð 	HùàFùØ8ùð 	Hùð* CùØKøð AùÜ ò Ø×&Ñ& s¨KÔ8Øðúð5 	Hø÷  	H÷  	Hñ  	Hüsê   ‚"K¤I5¥A	KÁ.I8Á/KÁ2*J-ÂI;ÂJ-Â6I>Â7$J-ÃKÃ'JÃ(KÃ-A(J-ÅJÅ0JÅ1JÆJÆJÆ,J	Æ-JÆ3'J-ÇKÇ%J+Ç&BKÉ8KÉ;J-É>J-ÊKÊJÊJÊ	JÊJ(Ê(J-Ê+KÊ-J?Ê3J6Ê4J?Ê;Kc              ƒ   ól  K  — d}	 | j                   j                  «       }| j                  |   }d||<   |r|j                  |d¬«       	 |r|D ]  }|j	                  «       ƒ d{  –—†  Œ |ƒ d{  –—†  |r|D ]  }|j                  «       ƒ d{  –—†  Œ |j                  |d«       | j                  j                  |d«      s| j                  |= 	 | j                  |«      dkD  ry|dz  }Œç7 Œˆ7 Œ~7 Œa# |j                  |d«       | j                  j                  |d«      s| j                  |= w w xY w­w)z&Wait for an available connection slot.r   TNF©Úlastr   )	ry   rã   rÙ   Úmove_to_endÚsend_connection_queued_startÚsend_connection_queued_endr.  r  r#  )rS   rs   r4  ÚattemptsÚfutr  rD  s          rT   r:  z,BaseConnector._wait_for_available_connectionª  sK  è ø€ ð ˆØØ(,¯
©
×(@Ñ(@Ó(BˆCØ ŸM™M¨#Ñ.ˆMØ!%ˆM˜#ÑÙð ×)Ñ)¨#°EÐ)Ô:ð+ñ Ø!'ò C˜Ø#×@Ñ@ÓB×BÑBðCà—	�	ÙØ!'ò A˜Ø#×>Ñ>Ó@×@Ñ@ðAð
 ×!Ñ! # tÔ,Ø—}‘}×(Ñ(¨¨dÔ3ØŸ™ cÑ*à×*Ñ*¨3Ó/°!Ò3ØØ˜‰MˆHð; ð CøØøð Aùð ×!Ñ! # tÔ,Ø—}‘}×(Ñ(¨¨dÔ3ØŸ™ cÑ*ð 4üsU   ‚AD4Á
C3 Á$C-Á%C3 Á0C/Á1C3 ÂC1ÂC3 ÂAD4Ã-C3 Ã/C3 Ã1C3 Ã3>D1Ä1D4c              ƒ   óì  K  — | j                   j                  |«      x}€yt        «       }|�r|j                  «       \  }}|j	                  «       r ||z
  | j
                  k  rŽ|s| j                   |= | j                  j                  |«       | j                  r| j                  |   j                  |«       |r |D ]  }	 |j                  «       ƒ d{  –—†  Œ t        | ||| j                  «      S |j                  }|j!                  «        | j"                  s'|j$                  r| j&                  j)                  |«       |r�Œ| j                   |= y7 Œ# t        $ r | j                  ||«       ‚ w xY w­w)znGet next reusable connection for the key or None.

        The connection will be marked as acquired.
        N)rÐ   r  r   Úpopleftr«   r×   rÔ   r;  rÒ   rÕ   Úsend_connection_reuseconnr?  r@  rq   ry   r›   r§   rá   r  râ   rŸ   )	rS   rs   r4  rì   Út1r  Út0rD  r›   s	            rT   r7  zBaseConnector._getÔ  sR  è ø€ ð —[‘[—_‘_ SÓ)Ð)ˆEÐ2Øä‹[ˆÚØŸ™›‰IˆE�2ð ×!Ñ!Ô#¨¨R©°4×3JÑ3JÒ(JÙàŸ™ CÐ(Ø—‘×"Ñ" 5Ô)Ø×'Ò'Ø×+Ñ+¨CÑ0×4Ñ4°UÔ;ÙØ!'ò "˜ð"Ø"'×"AÑ"AÓ"C×CÑCð"ô " $¨¨U°D·J±JÓ?Ð?ð Ÿ™ˆIØ�K‰KŒMà×0Ò0°S·Z²ZØ×/Ñ/×6Ñ6°yÔAó3 ð8 �K‰K˜ÐØð DùÜ,ò "Ø ×2Ñ2°3¸Ô>Ø!ð"üs7   ‚B<E4Â?EÃEÃEÃA+E4ÅE4ÅEÅE1Å1E4c                 óD  — | j                   syt        | j                   «      }t        j                  |«       |D ]d  }| j	                  |«      dk  rŒ| j                   |   }|sŒ*|j                  d¬«      \  }}|j                  «       s|j                  d«        y|rŒ;Œf y)z¼
        Iterates over all waiters until one to be released is found.

        The one to be released is not finished and
        belongs to a host that has available connections.
        Nr   FrG  )rÙ   ÚlistÚrandomÚshuffler#  ÚpopitemÚdoner5   )rS   Úqueuesrs   re   Úwaiterr  s         rT   Ú_release_waiterzBaseConnector._release_waiterþ  s“   € ð �}Š}Øô �d—m‘mÓ$ˆÜ�‰�vÔàò 		ˆCØ×*Ñ*¨3Ó/°!Ò3Øà—m‘m CÑ(ˆGÚØ#ŸO™O°˜OÓ7‘	�˜Ø—{‘{”}Ø×%Ñ% dÔ+Ùó	 ñ		rV   r  c                 ó  — | j                   ry| j                  j                  |«       | j                  r=| j                  j                  |«      x}r |j                  |«       |s| j                  |= | j                  «        y)zRelease acquired connection.N)rÏ   rÔ   ÚdiscardrÒ   rÕ   r  r[  )rS   rs   r  rì   s       rT   r@  zBaseConnector._release_acquired  sk   € à�<Š<àà�‰×Ñ˜uÔ%Ø×Ò¨d×.EÑ.E×.IÑ.IÈ#Ó.NÐ%N UÐ%NØ�M‰M˜%Ô ÙØ×+Ñ+¨CÐ0Ø×ÑÕrV   rˆ   rt   r‰   c                óú  — | j                   ry | j                  ||«       | j                  s|s|j                  rP|j                  }|j                  «        |j                  r'| j                  s| j                  j                  |«       y | j                  |   j                  |t        «       f«       | j                  €>t        j                  | d| j                  | j                   | j"                  ¬«      | _        y y )Nrý   rþ   )rÏ   r@  rØ   r‰   r›   r§   r  rá   râ   rŸ   rÐ   r   rÝ   r   r  r×   ry   rÎ   )rS   rs   rt   r‰   r›   s        rT   r�   zBaseConnector._release%  sÍ   € ð �<Š<àà×Ñ˜s HÔ-à×Ò¡°×0EÒ0EØ ×*Ñ*ˆIØ�N‰NÔà�zŠz $×"?Ò"?Ø×/Ñ/×6Ñ6°yÔAØà�‰�CÑ×Ñ ¬9«;Ð 7Ô8à×ÑÐ'Ü#*×#9Ñ#9ØØØ×'Ñ'Ø—
‘
Ø'+×'CÑ'Cô$ˆDÕ ð (rV   c              ƒ   ó   K  — t        «       ‚­wrš   )ÚNotImplementedError)rS   r$  r4  r  s       rT   r=  z BaseConnector._create_connectionE  s   è ø€ ô "Ó#Ð#ùs   ‚)rP   rC   )NNNr_   )2r`   ra   rb   r¶   rÏ   r�   r
  ÚHIGH_LEVEL_SCHEMA_SETÚallowed_protocol_schema_setr3   ÚobjectrÖ   r±   Úintrh   r­   rU   r[   r   r^   rî   rñ   ró   Útyper?  r   rø   r¯   rÅ   rÆ   rÇ   rý   rå   r   r§   rT  rê   r¬   r#  r+   r3  rq   r8  r:  r7  r[  r*   r@  r�   r=  rd   rV   rT   rC   rC   þ   sö  „ ñð €GØÐð !Ðà"7Ðð
 4<Ø!ØØØ&+Ø15Ø()òKð " D™=¨5Ñ0ðKð ð	Kð
 ðKð ðKð  $ðKð ×'Ñ'¨$Ñ.ðKð !&ðKð 
óKðZ (0ñ 3 ð 3°Dó 3ó*ð˜Sð  Tó óð
 04Ø*.Ø.2ñ	à�}Ñ%¨Ñ,ðð ! 4Ñ'ðð % tÑ+ð	ð
 
óð ð!˜Tò !ó ð!ð ð�sò ó ðð ð$ ò $ó ð$ó%óNð. */ò ( $ð (°9¸T±?ó (ð( +0ò </ 4ð </°D¸À6Ñ9JÑ4Kó </ð| ð˜ò ó ðð¨/ð ¸có ð2Ø ðà	óð498Ø ð98Ø*.¨w©-ð98ØBQð98à	ó98ðv(Ø"ð(Ø,0°©Mð(à	ó(ðT(Ø"ð(Ø,0°©Mð(à	�dÑ	ó(óTð4 _ð ¸_ð ÐQUó ð$ #òàðð "ðð
 ðð 
óð@$Ø ð$Ø*.¨w©-ð$ØBQð$à	ô$rV   rC   c                   ó¸   — e Zd Zddedz  deddfd„Zdedefd„Zde	e
ef   d	ee   ddfd
„Zde	e
ef   ddfd„Zdd„Zde	e
ef   dee   fd„Zde	e
ef   defd„Zy)Ú_DNSCacheTableNÚttlÚmax_sizerP   c                 óL   — t        «       | _        i | _        || _        || _        y rš   )r   Ú	_addrs_rrÚ_timestampsÚ_ttlÚ	_max_size)rS   rh  ri  s      rT   rU   z_DNSCacheTable.__init__L  s(   € ô ‹Mð 	Œð :<ˆÔØˆŒ	Ø!ˆ�rV   Úhostc                 ó   — || j                   v S rš   )rk  )rS   ro  s     rT   Ú__contains__z_DNSCacheTable.__contains__T  s   € Ø�t—~‘~Ð%Ð%rV   rs   Úaddrsc                 óž  — || j                   v r| j                   j                  |«       t        |«      t        |«      f| j                   |<   | j                  �t        «       | j                  |<   t        | j                   «      | j                  kD  r<| j                   j                  d¬«      \  }}| j                  j                  |d «       y y )NFrG  )
rk  rI  r   r  rm  r   rl  rn  rW  r.  )rS   rs   rr  Ú
oldest_keyr  s        rT   r;  z_DNSCacheTable.addW  s¢   € Ø�$—.‘.Ñ Ø�N‰N×&Ñ& sÔ+ä$ U›|¬S°«ZÐ8ˆ�‰�sÑà�9‰9Ð Ü$-£KˆD×Ñ˜SÑ!äˆt�~‰~Ó §¡Ò/Ø ŸN™N×2Ñ2¸Ð2Ó>‰MˆJ˜Ø×Ñ× Ñ  ¨TÕ2ð 0rV   c                 ót   — | j                   j                  |d «       | j                  j                  |d «       y rš   )rk  r.  rl  ©rS   rs   s     rT   rA  z_DNSCacheTable.removed  s,   € Ø�‰×Ñ˜3 Ô%Ø×Ñ×Ñ˜S $Õ'rV   c                 ól   — | j                   j                  «        | j                  j                  «        y rš   )rk  r  rl  rY   s    rT   r  z_DNSCacheTable.clearh  s$   € Ø�‰×ÑÔØ×Ñ×ÑÕ rV   c                 ó    — | j                   |   \  }}t        t        ||«      «      }t        |«       | j                   j	                  |«       |S rš   )rk  rT  r   ÚnextrI  )rS   rs   ru   Úlengthrr  s        rT   Ú
next_addrsz_DNSCacheTable.next_addrsl  sC   € Ø—~‘~ cÑ*‰ˆˆfÜ”V˜D &Ó)Ó*ˆäˆTŒ
Ø�‰×"Ñ" 3Ô'ØˆrV   c                 ój   — | j                   €y| j                  |   | j                   z   t        «       k  S rR   )rm  rl  r   rv  s     rT   Úexpiredz_DNSCacheTable.expiredt  s0   € Ø�9‰9ÐØà×Ñ Ñ$ t§y¡yÑ0´9³;Ñ>Ð>rV   )Néè  r_   )r`   ra   rb   rÖ   rd  rU   rc  r±   rq  Útupler®   rT  r   r;  rA  r  r{  r}  rd   rV   rT   rg  rg  K  sµ   „ ñ"˜E D™Lð "¸3ð "È$ó "ð& ð &¨Dó &ð3�u˜S #˜X‘ð 3¨t°MÑ/Bð 3Àtó 3ð(˜%  S ™/ð (¨dó (ó!ð˜e C¨ H™oð °$°}Ñ2Eó ð?˜5  c ™?ð ?¨tô ?rV   rg  Úverifiedc                 óÔ  — t         €y| rt        j                  «       }n¸t        j                  t         j                  «      }|xj                  t         j
                  z  c_        |xj                  t         j                  z  c_        d|_        t         j                  |_	        |xj                  t         j                  z  c_        |j                  «        |j                  d«       |S )z­Create SSL context.

    This method is not async-friendly and should be called from a thread
    because it will load certificates from disk and do other blocking I/O.
    NF)zhttp/1.1)r(  Úcreate_default_contextÚ
SSLContextÚPROTOCOL_TLS_CLIENTÚoptionsÚOP_NO_SSLv2ÚOP_NO_SSLv3Úcheck_hostnameÚ	CERT_NONEÚverify_modeÚOP_NO_COMPRESSIONÚset_default_verify_pathsÚset_alpn_protocols)r€  r  s     rT   Ú_make_ssl_contextrŽ  {  s¦   € ô €{àÙÜ×/Ñ/Ó1‰
ä—^‘^¤C×$;Ñ$;Ó<ˆ
Ø×ÒœcŸo™oÑ-ÕØ×ÒœcŸo™oÑ-ÕØ$)ˆ
Ô!Ü!$§¡ˆ
ÔØ×Òœc×3Ñ3Ñ3ÕØ×+Ñ+Ô-Ø×!Ñ! -Ô0ØÐrV   TFc            ,       ó˜  ‡ — e Zd ZdZe edh«      z  Zdddddej                  j                  dddde
ddd	ddd
ddde
dœdededz  dededz  dedej                  dedz  deez  ez  deeef   dz  dedz  ddez  ez  dededededej,                  dz  dededz  dedz  d edz  d!edz  ez  f*ˆ fd"„Zdd#œd$ed%eee      fˆ fd&„Zdd#œd$ed%dfˆ fd'„Zed%efd(„«       Zed%efd)„«       Z dLd*edz  d+edz  d%dfd,„Z!	 dMd*ed+ed-e"d.   dz  d%ee#   fd/„Z$d0eeef   d*ed+ed1e%d2   d-e"d.   dz  d%ee#   fd3„Z&d4e'd-ed.   d5d6d%e(fd7„Z)d4e'd%edz  fd8„Z*d4e'd%e+d9   fd:„Z,e-d;œd<e.d=ee/   d4e'd5d6d>e0e1   d?e.d%eejd                  e(f   fd@„Z3e-d;œd<e.d4e'd5d6d>e0e1   d?e.d%eejd                  e(f   fdA„Z4dNdB„Z5dOdC„Z6d%efdD„Z7dEejd                  d4e'd%dfdF„Z8e-fdEejd                  d4e'd5d6d>e0e1   d%eejr                  e(f   f
dG„Z:dHee#   d%ee/   fdI„Z;e-d;œd4e'd-ed.   d5d6d>e0e1   d%eejd                  e(f   f
dJ„Z<d4e'd-ed.   d5d6d%eejr                  e(f   fdK„Z=ˆ xZ>S )PrD   uæ  TCP connector.

    verify_ssl - Set to True to check ssl certifications.
    fingerprint - Pass the binary sha256
        digest of the expected certificate in DER format to verify
        that the certificate the server presents matches. See also
        https://en.wikipedia.org/wiki/HTTP_Public_Key_Pinning
    resolver - Enable DNS lookups and use this
        resolver
    use_dns_cache - Use memory cache for DNS lookups.
    ttl_dns_cache - Max seconds having cached a DNS entry, None forever.
    family - socket address family
    local_addr - local tuple of (host, port) to bind socket to

    keepalive_timeout - (optional) Keep-alive timeout.
    force_close - Set to True to force close and do reconnect
        after each request (and between redirects).
    limit - The total number of simultaneous connections.
    limit_per_host - Number of simultaneous connections to one host.
    enable_cleanup_closed - Enables clean-up closed ssl transports.
                            Disabled by default.
    happy_eyeballs_delay - This is the â€œConnection Attempt Delayâ€�
                           as defined in RFC 8305. To disable
                           the happy eyeballs algorithm, set to None.
    interleave - â€œFirst Address Family Countâ€� as defined in RFC 8305
    loop - Optional event loop.
    socket_factory - A SocketFactoryType function that, if supplied,
                     will be used to create sockets given an
                     AddrInfoType.
    ssl_shutdown_timeout - DEPRECATED. Will be removed in aiohttp 4.0.
                           Grace period for SSL shutdown handshake on TLS
                           connections. Default is 0 seconds (immediate abort).
                           This parameter allowed for a clean SSL shutdown by
                           notifying the remote peer of connection closure,
                           while avoiding excessive delays during connector cleanup.
                           Note: Only takes effect on Python 3.11+.
    ÚtcpTNé
   r~  FrÁ   r   rÂ   g      Ð?)Ú
verify_sslÚfingerprintÚuse_dns_cacheÚttl_dns_cacheÚdns_cache_max_sizeÚfamilyÚssl_contextr(  Ú
local_addrÚresolverrÄ   rÅ   rÆ   rÇ   rÈ   ru   rÉ   Úhappy_eyeballs_delayÚ
interleaveÚsocket_factoryÚssl_shutdown_timeoutr’  r“  r”  r•  r–  r—  r˜  r(  r™  rš  rÄ   rÅ   rÆ   rÇ   rÈ   ru   rÉ   r›  rœ  r�  rž  c          	      ój  •— t         ‰| �  |||||||¬«       t        ||||«      | _        |  |
€#t	        | j
                  ¬«      | _        d| _        n|
| _        d| _        || _        t        ||¬«      | _
        i | _        || _        t        j                  |	«      | _        || _        || _        t%        «       | _        || _        |  |t*        u rd| _        y t/        j0                  dt2        d¬	«       t4        j6                  d
k  r'|�%|dk7  r t/        j0                  d|› d�t8        d¬	«       || _        y )NrÃ   rË   TF)rh  ri  r   zSThe ssl_shutdown_timeout parameter is deprecated and will be removed in aiohttp 4.0r–   r—   ©r9   é   zssl_shutdown_timeout=zd is ignored on Python < 3.11; only ssl_shutdown_timeout=0 is supported. The timeout will be ignored.)ÚsuperrU   r-   Ú_sslr7   ry   Ú	_resolverÚ_resolver_ownerÚ_use_dns_cacherg  Ú_cached_hostsÚ_throttle_dns_futuresÚ_familyÚaiohappyeyeballsÚaddr_to_addr_infosÚ_local_addr_infosÚ_happy_eyeballs_delayÚ_interleaverÓ   Ú_resolve_host_tasksÚ_socket_factoryr3   Ú_ssl_shutdown_timeoutr[   r\   r]   r   rà   ÚRuntimeWarning)rS   r’  r“  r”  r•  r–  r—  r˜  r(  r™  rš  rÄ   rÅ   rÆ   rÇ   rÈ   ru   rÉ   r›  rœ  r�  rž  Ú	__class__s                         €rT   rU   zTCPConnector.__init__Ã  sP  ø€ ô2 	‰ÑØ/Ø#ØØ)Ø"7ØØ#9ð 	ô 	
ô & c¨:°{ÀKÓPˆŒ	áØÐÜ,°$·*±*Ô=ˆDŒNØ#'ˆDÕ à%ˆDŒNØ#(ˆDÔ à+ˆÔÜ+ØÐ(:ô
ˆÔð ð 	Ô"ð ˆŒÜ!1×!DÑ!DÀZÓ!PˆÔØ%9ˆÔ"Ø%ˆÔÜKNË5ˆÔ Ø-ˆÔÙà¤8Ñ+Ø)*ˆDÕ&ô �M‰MØeÜ"Øõô × Ñ  7Ò*Ø(Ð4Ø(¨AÒ-ä—‘Ø+Ð,@Ð+Að B]ð ]ä"Ø õ	ð *>ˆDÕ&rV   r  r  rP   c                ó  •— t        j                  | j                  j                  «       «      D ]  }|j	                  «        Œ t
        ‰| �  |¬«      }| j                  D ]#  }|j	                  «        |j                  |«       Œ% |S )zClose all ongoing DNS calls.r  )	r   Úfrom_iterabler¨  rè   rÿ   r¢  rê   r¯  rŸ   )rS   r  rM  re   Útr³  s        €rT   rê   zTCPConnector._close  sx   ø€ ä×&Ñ& t×'AÑ'A×'HÑ'HÓ'JÓKò 	ˆCØ�J‰J�Lð	ô ‘'‘.¨9�.Ó5ˆà×)Ñ)ò 	ˆAØ�H‰HŒJØ�N‰N˜1Õð	ð ˆrV   c             ƒ   óÆ   •K  — t         ‰| �  |xs | j                  dk(  ¬«      ƒ d{  –—†  | j                  r#| j                  j                  «       ƒ d{  –—†  yy7 Œ47 Œ­w)aÆ  
        Close all opened transports.

        :param abort_ssl: If True, SSL connections will be aborted immediately
                         without performing the shutdown handshake. If False (default),
                         the behavior is determined by ssl_shutdown_timeout:
                         - If ssl_shutdown_timeout=0: connections are aborted
                         - If ssl_shutdown_timeout>0: graceful shutdown is performed
        r   r  N)r¢  r§   r±  r¥  r¤  )rS   r  r³  s     €rT   r§   zTCPConnector.close"  s\   øè ø€ ô ‰g‰m iÒ&R°4×3MÑ3MÐQRÑ3RˆmÓS×SÐSØ×ÒØ—.‘.×&Ñ&Ó(×(Ñ(ð  ð 	Tøà(ús!   ƒ%A!¨A©-A!ÁAÁA!ÁA!c                 ó   — | j                   S )zSocket family like AF_INET.)r©  rY   s    rT   r—  zTCPConnector.family1  s   € ð �|‰|ÐrV   c                 ó   — | j                   S )z%True if local DNS caching is enabled.)r¦  rY   s    rT   r”  zTCPConnector.use_dns_cache6  s   € ð ×"Ñ"Ð"rV   ro  Úportc                 óš   — |� |�| j                   j                  ||f«       y|€|�t        d«      ‚| j                   j                  «        y)z8Remove specified host/port or clear all dns local cache.Nz5either both host and port or none of them are allowed)r§  rA  rÌ   r  )rS   ro  rº  s      rT   Úclear_dns_cachezTCPConnector.clear_dns_cache;  sN   € àÐ Ð 0Ø×Ñ×%Ñ% t¨T lÕ3ØÐ Ð!1ÜÐTÓUÐUà×Ñ×$Ñ$Õ&rV   r4  rI   c              ƒ   óR  K  — t        |«      r/d|vrt        |«      st        |d«      ‚|||| j                  dddœgS | j                  s�|r |D ]  }|j                  |«      ƒ d{  –—†  Œ | j                  rt        d«      ‚| j                  j                  ||| j                  ¬«      ƒ d{  –—† }|r |D ]  }|j                  |«      ƒ d{  –—†  Œ |S ||f}|| j                  v rZ| j                  j                  |«      s?| j                  j                  |«      }|r |D ]  }|j                  |«      ƒ d{  –—†  Œ |S || j                  v r“| j                  |   }| j                   j#                  «       }	|j%                  |	«       |r |D ]  }|j                  |«      ƒ d{  –—†  Œ 	 |	ƒ d{  –—†  |j'                  |	«       | j                  j                  |«      S t)        «       x| j                  |<   }| j+                  |||||«      }
t-        j.                  «       }t0        j2                  dk\  rt-        j4                  |
|d	¬
«      }n|j7                  |
«      }|j9                  «       s@| j:                  j%                  |«       |j=                  | j:                  j&                  «       	 t-        j>                  |«      ƒ d{  –—† S 7 �Œl7 �Œ&7 �Œ	7 �Œ 7 �Œ77 �Œ-# |j'                  |	«       w xY w7 Œ,# t,        j@                  $ r dd„}|j=                  |«       ‚ w xY w­w)z*Resolve host and return list of addresses.ú:zis not a canonical IPv4 addressr   )Úhostnamero  rº  r—  r  ÚflagsNzConnector is closed©r—  r8   Tr  c                 óŠ   — t        t        t        j                  «      5  | j	                  «        d d d «       y # 1 sw Y   y xY wrš   )r
   rk   rh   ÚCancelledErrorÚresult)rM  s    rT   Údrop_exceptionz2TCPConnector._resolve_host.<locals>.drop_exception   s0   € Üœi¬×)?Ñ)?Ó@ñ !Ø—J‘J”L÷!÷ !ñ !ús	   Ÿ9¹A)rM  z#asyncio.Future[list[ResolveResult]]rP   N)!r1   r0   r%   r©  r¦  Úsend_dns_resolvehost_startrÏ   r   r¤  ÚresolveÚsend_dns_resolvehost_endr§  r}  r{  Úsend_dns_cache_hitr¨  ry   rã   r;  r]  rÓ   Ú_resolve_host_with_throttlerh   rÍ   r   rà   r  r  rX  r¯  Úadd_done_callbackÚshieldrÃ  )rS   ro  rº  r4  rD  rn   rs   rÄ  ÚfuturesÚfuturer  ru   Úresolved_host_taskrÅ  s                 rT   Ú_resolve_hostzTCPConnector._resolve_hostD  s  è ø€ ô ˜Ôð ˜$‰Ô'@ÀÔ'FÜ+¨DÐ2SÓTÐTð !%Ø Ø Ø"Ÿl™lØØñð	ð 	ð ×"Ò"áØ#ò A�EØ×:Ñ:¸4Ó@×@Ñ@ðAð �|Š|Ü+Ð,AÓBÐBàŸ™×.Ñ.¨t°TÀ$Ç,Á,Ð.ÓO×OˆCáØ#ò ?�EØ×8Ñ8¸Ó>×>Ñ>ð?ð ˆJà�TˆlˆØ�$×$Ñ$Ñ$¨T×-?Ñ-?×-GÑ-GÈÔ-Là×'Ñ'×2Ñ2°3Ó7ˆFáØ#ò 9�EØ×2Ñ2°4Ó8×8Ñ8ð9àˆMð �$×,Ñ,Ñ,à×0Ñ0°Ñ5ˆGØ+/¯:©:×+CÑ+CÓ+EˆFØ�K‰K˜ÔÙØ#ò 9�EØ×2Ñ2°4Ó8×8Ñ8ð9ð(Ø—�à—‘ Ô'Ø×%Ñ%×0Ñ0°Ó5Ð5ô 58³EÐ9ˆ×"Ñ" 3Ñ'¨'ð ×/Ñ/°°T¸4ÀÈ&ÓQˆÜ×'Ñ'Ó)ˆÜ×Ñ˜wÒ&ä!(§¡¨d¸È4Ô!PÑà!%×!1Ñ!1°$Ó!7Ðà!×&Ñ&Ô(Ø×$Ñ$×(Ñ(Ð);Ô<Ø×0Ñ0°×1IÑ1I×1QÑ1QÔRð		Ü Ÿ™Ð(:Ó;×;Ð;ðA Aùð
 Pùð ?ùð 9ùð" 9ùàúà—‘ Õ'úð. <ùÜ×%Ñ%ò 	ó!ð ×0Ñ0°Ô@Øð	üs²   ‚A"L'Á$KÁ%AL'Â-KÂ.L'ÃKÃA+L'Ä9KÄ:A+L'Æ%KÆ&L'Æ-K" Æ2KÆ3K" Æ7C;L'Ê3K: ËK8ËK: ËL'ËL'ËL'ËL'ËL'ËK" Ë"K5Ë5L'Ë8K: Ë:*L$Ì$L'rs   rÍ  zasyncio.Future[None]c              ƒ   óš  K  — 	 |r@|D ]  }|j                  |«      ƒ d{  –—†  Œ |D ]  }|j                  |«      ƒ d{  –—†  Œ | j                  j                  ||| j                  ¬«      ƒ d{  –—† }|r |D ]  }|j                  |«      ƒ d{  –—†  Œ | j                  j                  ||«       |D ]  }t        |d«       Œ 	 | j                  j                  |«       | j                  j                  |«      S 7 ŒÞ7 ŒÀ7 Œ�7 Œr# t        $ r}	|D ]  }t        ||	«       Œ ‚ d}	~	ww xY w# | j                  j                  |«       w xY w­w)z²Resolve host and set result for all waiters.

        This method must be run in a task and shielded from cancellation
        to avoid cancelling the underlying lookup.
        NrÁ  )Úsend_dns_cache_missrÆ  r¤  rÇ  r©  rÈ  r§  r;  r5   r?  r4   r¨  r.  r{  )
rS   rs   ro  rº  rÍ  r4  rD  rr  rM  Úes
             rT   rÊ  z(TCPConnector._resolve_host_with_throttle§  s\  è ø€ ð	0ÙØ#ò :�EØ×3Ñ3°DÓ9×9Ñ9ð:ð $ò A�EØ×:Ñ:¸4Ó@×@Ñ@ðAð Ÿ.™.×0Ñ0°°tÀDÇLÁLÐ0ÓQ×QˆEÙØ#ò ?�EØ×8Ñ8¸Ó>×>Ñ>ð?ð ×Ñ×"Ñ" 3¨Ô.Øò &�Ü˜3 Õ%ñ&ð ×&Ñ&×*Ñ*¨3Ô/à×!Ñ!×,Ñ,¨SÓ1Ð1ð/ :øð AøàQøð ?ùô
 ò 	ð ò &�Ü˜c 1Õ%ð&àûð	ûð ×&Ñ&×*Ñ*¨3Õ/üsy   ‚E„D ŸC> D ¿D Á 1D Á1DÁ2D ÂDÂ5D Ã6EÃ>D Ä D ÄD ÄD Ä	D(ÄD#Ä#D(Ä(D+ Ä+EÅEr$  r  rG   c              ƒ   óª   K  — |j                   r | j                  |||«      ƒ d{  –—† \  }}|S | j                  |||«      ƒ d{  –—† \  }}|S 7 Œ)7 Œ­w)zcCreate connection.

        Has same keyword arguments as BaseEventLoop.create_connection.
        N)r)  Ú_create_proxy_connectionÚ_create_direct_connection)rS   r$  r4  r  r  r  s         rT   r=  zTCPConnector._create_connectionÐ  s]   è ø€ ð �9Š9Ø!×:Ñ:¸3ÀÈÓP×P‰HˆAˆuð ˆð "×;Ñ;¸CÀÈÓQ×Q‰HˆAˆuàˆð	 QøàQús!   ‚#A¥A¦AÁAÁ
AÁAc                 ó  — |j                  «       syt        €t        d«      ‚|j                  }t        |t        j                  «      r|S |durt
        S | j                  }t        |t        j                  «      r|S |durt
        S t        S )a*  Logic to get the correct SSL context

        0. if req.ssl is false, return None

        1. if ssl_context is specified in req, use it
        2. if _ssl_context is specified in self, use it
        3. otherwise:
            1. if verify_ssl is not specified in req, use self.ssl_context
               (will generate a default context according to self.verify_ssl)
            2. if verify_ssl is True in req, generate a default SSL context
            3. if verify_ssl is False in req, generate a SSL context that
               won't verify
        NzSSL is not supported.T)r  r(  ÚRuntimeErrorrj   rƒ  Ú_SSL_CONTEXT_UNVERIFIEDr£  Ú_SSL_CONTEXT_VERIFIED)rS   r$  r  s      rT   Ú_get_ssl_contextzTCPConnector._get_ssl_contextÞ  s}   € ð �z‰zŒ|Øäˆ;ÜÐ6Ó7Ð7Ø—W‘Wˆ
Ü�j¤#§.¡.Ô1ØÐØ˜TÑ!ä*Ð*Ø—Y‘Yˆ
Ü�j¤#§.¡.Ô1ØÐØ˜TÑ!ä*Ð*Ü$Ð$rV   r,   c                 ó|   — |j                   }t        |t        «      r|S | j                  }t        |t        «      r|S y rš   )r(  rj   r,   r£  )rS   r$  Úrets      rT   Ú_get_fingerprintzTCPConnector._get_fingerprintÿ  s5   € Ø�g‰gˆÜ�cœ;Ô'ØˆJØ�i‰iˆÜ�cœ;Ô'ØˆJØrV   ©Úclient_errorÚargsÚ
addr_infosrà  r‘   c          	   �   óX  K  — 	 t        |j                  |j                  ¬«      4 ƒd {  –—†  t        j                  || j
                  | j                  | j                  | j                  | j                  ¬«      ƒ d {  –—† }|j                  d«      r.| j                  r"t        j                  dk\  r| j                  |d<    | j                  j                  |i |¤d|i¤Žƒ d {  –—† cd d d «      ƒd {  –—†  S 7 ŒÑ7 Œ~7 Œ7 Œ# 1 ƒd {  –—†7  sw Y   y xY w# t        $ r}t!        |j"                  |«      |‚d }~wt$        $ r}t'        |j"                  |«      |‚d }~wt(        $ r@}|j*                  €t-        |t.        j0                  «      r‚  ||j"                  |«      |‚d }~ww xY w­w)N©r9  )râ  Úlocal_addr_infosr›  rœ  ru   r�  r(  r   rž  Úsock)r/   Úsock_connectr9  rª  Ústart_connectionr¬  r­  r®  ry   r°  r  r±  r   rà   Úcreate_connectionr(   r   r6  r)   r"   ÚOSErrorÚerrnorj   rh   ÚTimeoutError)	rS   râ  r$  r  rà  rá  r‘   ræ  rï   s	            rT   Ú_wrap_create_connectionz$TCPConnector._wrap_create_connection  sŠ  è ø€ ð	AÜ#Ø×$Ñ$°W×5KÑ5Kô÷ Vñ Vô .×>Ñ>Ø)Ø%)×%;Ñ%;Ø)-×)CÑ)CØ#×/Ñ/ØŸ™Ø#'×#7Ñ#7ô÷ �ð —J‘J˜uÔ%Ø×2Ò2Ü×(Ñ(¨GÒ3à59×5OÑ5O�FÐ1Ñ2Ø9˜TŸZ™Z×9Ñ9¸4ÐUÀ6ÑUÐPTÒU×U÷%V÷ Vò Vøðøð Vøð%Vø÷ V÷ Vñ Vûô& ò 	TÜ1°#×2DÑ2DÀcÓJÐPSÐSûÜò 	LÜ)¨#×*<Ñ*<¸cÓBÈÐKûÜò 	AØ�y‰yÐ ¤Z°´W×5IÑ5IÔ%JØÙ˜s×1Ñ1°3Ó7¸SÐ@ûð	Aüs·   ‚F*„%D ©C;ªD ­ADÁ>C=Á?A&DÃ%C?Ã&DÃ)D Ã5DÃ6D Ã:F*Ã;D Ã=DÃ?DÄD ÄDÄ	DÄ
DÄD ÄF*ÄD Ä	F'Ä!D8Ä8F'ÅEÅF'Å';F"Æ"F'Æ'F*c             �   ó$  K  — 	 t        |j                  |j                  ¬«      4 ƒd {  –—†   | j                  j                  |i |¤Žƒ d {  –—† cd d d «      ƒd {  –—†  S 7 Œ97 Œ7 Œ	# 1 ƒd {  –—†7  sw Y   y xY w# t
        $ r}t        |j                  |«      |‚d }~wt        $ r}t        |j                  |«      |‚d }~wt        $ r@}|j                  €t        |t        j                  «      r‚  ||j                  |«      |‚d }~ww xY w­w©Nrä  )r/   rç  r9  ry   ré  r(   r   r6  r)   r"   rê  rë  rj   rh   rì  )rS   r$  r  rà  rá  r‘   rï   s          rT   Ú_wrap_existing_connectionz&TCPConnector._wrap_existing_connection.  s  è ø€ ð	AÜ#Ø×$Ñ$°W×5KÑ5Kô÷ Kñ Kð :˜TŸZ™Z×9Ñ9¸4ÐJÀ6ÑJ×J÷K÷ Kò Køð KøðKø÷ K÷ Kñ Kûô ò 	TÜ1°#×2DÑ2DÀcÓJÐPSÐSûÜò 	LÜ)¨#×*<Ñ*<¸cÓBÈÐKûÜò 	AØ�y‰yÐ ¤Z°´W×5IÑ5IÔ%JØÙ˜s×1Ñ1°3Ó7¸SÐ@ûð	Aüs£   ‚D„%A> ©A#ªA> ­ A)ÁA%ÁA)ÁA> ÁA'ÁA> Á"DÁ#A> Á%A)Á'A> Á)A;Á/A2Á0A;Á7A> Á:DÁ;A> Á>	DÂBÂDÂ*CÃDÃ;DÄDÄDc                 ó†   — |j                  «       sy|j                  }|€J ‚|j                  dk7  ry| j                  «        y)zóRaise a :py:exc:`RuntimeError` on missing ``start_tls()``.

        It is necessary for TLS-in-TLS so that it is possible to
        send HTTPS queries through HTTPS proxies.

        This doesn't affect regular HTTP requests, though.
        Nr>   )r  r)  ÚschemeÚ_check_loop_for_start_tls)rS   r$  Ú	proxy_urls      rT   Ú_fail_on_no_start_tlsz"TCPConnector._fail_on_no_start_tlsD  sB   € ð �z‰zŒ|Øà—I‘Iˆ	ØÐ$Ð$Ð$Ø×Ñ˜wÒ&Øà×&Ñ&Õ(rV   c                 ól   — 	 | j                   j                   y # t        $ r}t        d«      |‚d }~ww xY w)Na¶  An HTTPS request is being sent through an HTTPS proxy. This needs support for TLS in TLS but it is not implemented in your runtime for the stdlib asyncio.

Please upgrade to Python 3.11 or higher. For more details, please see:
* https://bugs.python.org/issue37179
* https://github.com/python/cpython/pull/28073
* https://docs.aiohttp.org/en/stable/client_advanced.html#proxy-support
* https://github.com/aio-libs/aiohttp/discussions/6044
)ry   Ú	start_tlsÚAttributeErrorrØ  )rS   Úattr_excs     rT   ró  z&TCPConnector._check_loop_for_start_tlsV  s<   € ð	Ø�J‰J× Ó øÜò 	Üð	Kóð ðûð	ús   ‚ ™	3¢.®3c                 óD   — 	 | j                  «        y# t        $ r Y yw xY w)NTF)ró  rØ  rY   s    rT   Ú_loop_supports_start_tlsz%TCPConnector._loop_supports_start_tlsg  s,   € ð	Ø×*Ñ*Ô,ð øô ò 	Ùð	ús   ‚ “	žÚunderlying_transportc                 óf  — |j                   j                  j                  dk7  ry|j                  �|j                  j                  dk7  ryt	        |«      j
                  j                  d«      ryt        j                  dk\  xs t        |dd«      }|ryt        j                  dt        | d¬	«       y)
z6Issue a warning if the requested URL has HTTPS scheme.r>   NÚuvloopr   Ú_start_tls_compatibleFa  An HTTPS request is being sent through an HTTPS proxy. This support for TLS in TLS is known to be disabled in the stdlib asyncio (Python <3.11). This is why you'll probably see an error in the log below.

It is possible to enable it via monkeypatching. For more details, see:
* https://bugs.python.org/issue37179
* https://github.com/python/cpython/pull/28073

You can temporarily patch this as follows:
* https://docs.aiohttp.org/en/stable/client_advanced.html#proxy-support
* https://github.com/aio-libs/aiohttp/discussions/6044
r9   )r‡   r˜   )Úrequest_infor1  rò  r)  re  ra   Ú
startswithr   rà   Úgetattrr[   r\   r²  )rS   rü  r$  Úasyncio_supports_tls_in_tlss       rT   Ú_warn_about_tls_in_tlsz#TCPConnector._warn_about_tls_in_tlso  s°   € ð ×Ñ×Ñ×&Ñ&¨'Ò1Øð
 �9‰9Ð §	¡	× 0Ñ 0°GÒ ;Øô Ð$Ó%×0Ñ0×;Ñ;¸HÔEØô '*×&6Ñ&6¸'Ñ&Aò '
ÄWØ Ø#ØóF
Ð#ñ 'Øä�‰ð
Gô Øð ö!	
rV   c              ƒ   ó^  K  — | j                  «       }| j                  |«      }t        r|€J ‚	 t        |j                  |j
                  ¬«      4 ƒd{  –—†  	 t        j                  dk\  rf| j                  rZ| j                  j                  ||||j                  xs |j                  |j                  xs d| j                  ¬«      ƒ d{  –—† }nN| j                  j                  ||||j                  xs |j                  |j                  xs d¬«      ƒ d{  –—† }t#        |t$        j&                  «      r%| j)                  |«      }|r	 |j+                  |«       ddd«      ƒd{  –—†  €d}	 ||j4                  t7        |	«      «      ‚|j9                  |«       ||fS 7 �ŒQ7 ŒÚ7 Œ�# t        $ r2 | j                  dk(  r|j                  «        ‚ |j!                  «        ‚ w xY w# t,        $ r9 |j!                  «        | j.                  s| j0                  j3                  |«       ‚ w xY w7 ŒÃ# 1 ƒd{  –—†7  sw Y   ŒÓxY w# t:        $ r}
t=        |j4                  |
«      |
‚d}
~
wt>        $ r}
tA        |j4                  |
«      |
‚d}
~
wt6        $ r@}
|
jB                  €t#        |
t$        jD                  «      r‚  ||j4                  |
«      |
‚d}
~
wtF        $ rN}tI        d|j                  ›d	|jJ                  d
›d|jL                  ›d|jN                  xs d› d|›d�«      |‚d}~ww xY w­w)z$Wrap the raw TCP transport with TLS.Nrä  r   )Úserver_hostnameÚssl_handshake_timeoutrž  )r  r  r   z:Failed to start TLS (possibly caused by closing transport)z2Cannot initialize a TLS-in-TLS connection to host r¾  Údz4 through an underlying connection to an HTTPS proxy z ssl:Údefaultz [ú])(rÜ   rÛ  r   r/   rç  r9  r   rà   r±  ry   r÷  r  ro  Útotalr?  r¾   r§   rj   rh   r°   rÞ  Úcheckr&   rá   râ   rŸ   r6  rê  Úconnection_mader(   r   r)   r"   rë  rì  Ú	TypeErrorr   rº  r)  r(  )rS   rü  r$  r  rà  Ú	tls_protor  Útls_transportr“  Úmsgrï   Útype_errs               rT   Ú_start_tls_connectionz"TCPConnector._start_tls_connection   s$  è ø€ ð —M‘M“Oˆ	Ø×*Ñ*¨3Ó/ˆ
Ýð Ð)Ð)Ð)ðC	Ü#Ø×$Ñ$°W×5KÑ5Kô÷ ("ñ ("ðä×'Ñ'¨7Ò2°t×7QÒ7QØ.2¯j©j×.BÑ.BØ0Ø%Ø&Ø,/×,?Ñ,?Ò,KÀ3Ç8Á8Ø29·-±-Ò2GÀ4Ø15×1KÑ1Kð /Có /÷ )™ð /3¯j©j×.BÑ.BØ0Ø%Ø&Ø,/×,?Ñ,?Ò,KÀ3Ç8Á8Ø29·-±-Ò2GÀ4ð /Có /÷ )˜ô  ˜m¬W×->Ñ->Ô?Ø"&×"7Ñ"7¸Ó"<�KÙ"ð"Ø'×-Ñ-¨mÔ<÷G("÷ ("ðz Ð$ØR�Ù" 3×#5Ñ#5´w¸s³|ÓDÐDØ×%Ñ%Øôð ˜iÐ'Ð'ðI("ùð)øð)ùô %ò ð ×1Ñ1°QÒ6Ø,×2Ñ2Ô4ð ð -×2Ñ2Ô4Øðûô  9ò "Ø)×/Ñ/Ô1Ø#'×#@Ò#@Ø $× ?Ñ ?× FÑ FÀ}Ô UØ!ð	"úðI("ø÷ ("÷ ("ñ ("ûôR ò 	TÜ1°#×2DÑ2DÀcÓJÐPSÐSûÜò 	LÜ)¨#×*<Ñ*<¸cÓBÈÐKûÜò 	AØ�y‰yÐ ¤Z°´W×5IÑ5IÔ%JØÙ˜s×1Ñ1°3Ó7¸SÐ@ûÜò 
	ô
 (ØDØ—8‘8�,˜a §¡¨˜|ð ,%Ø%(§Y¡Y M°°s·w±wÒ7KÀ)Ð6Lð MØ�<˜qð"óð
 ðûð
	üsæ   ‚,L-¯%I ÁF%ÁI ÁH1ÁA3F,ÃF(ÃAF,ÄF*ÄF,Ä!-H1ÅG*Å I Å+H/Å,I Å05L-Æ%I Æ(F,Æ*F,Æ,;G'Ç'H1Ç*AH,È,H1È/I È1IÈ7H:È8IÈ?I É	L*ÉI&É&L*É2J	Ê	L*Ê;KËL*ËA	L%Ì%L*Ì*L-Úhostsc                 ó.  — g }|D ]�  }|d   }d|v }|rt         j                  nt         j                  }| j                  r| j                  |k7  rŒJ|r	||d   ddfn||d   f}|j	                  |t         j
                  t         j                  d|f«       Œ� |S )zÈConverts the list of hosts to a list of addr_infos.

        The list of hosts is the result of a DNS lookup. The list of
        addr_infos is the result of a call to `socket.getaddrinfo()`.
        ro  r¾  rº  r   r<   )ÚsocketÚAF_INET6ÚAF_INETr©  rŸ   ÚSOCK_STREAMÚIPPROTO_TCP)rS   r  râ  Úhinforo  Úis_ipv6r—  Úaddrs           rT   Ú_convert_hosts_to_addr_infosz)TCPConnector._convert_hosts_to_addr_infosö  sŸ   € ð *,ˆ
Øò 		ˆEØ˜‘=ˆDØ˜T�kˆGÙ(/”V—_’_´V·^±^ˆFØ�|Š| §¡°Ò 6ØÙ29�D˜% ™-¨¨AÑ.ÀÀeÈFÁmÐ?TˆDØ×ÑØœ×+Ñ+¬V×-?Ñ-?ÀÀTÐJõð		ð ÐrV   c          	   ƒ   óœ  K  — | j                  |«      }| j                  |«      }|j                  j                  }|€J ‚|j	                  d«      r|j                  d«      dz   }|j                  }|€J ‚	 | j                  |||¬«      ƒ d {  –—† }	d }| j                  |	«      }|r}|r|j                   xs |j                  d«      nd }	 | j#                  | j$                  ||||||¬«      ƒ d {  –—† \  }}|j/                  «       r|r	 |j1                  |«       ||fS ||fS |€J ‚|‚7 Œœ# t        $ rC}
|
j                  €t        |
t        j                  «      r‚ t        |j                  |
«      |
‚d }
~
ww xY w7 ŒŠ# t&        t        j                  f$ r-}
|
}t)        j*                  || j,                  «       Y d }
~
�Œd }
~
ww xY w# t2        $ r{}
|j5                  «        | j6                  s| j8                  j;                  |«       |
}|j=                  d«      }|j?                  «       }t)        j@                  ||«       Y d }
~
�Œ d }
~
ww xY w­w)Nz..ú.)r4  )r  r(  râ  r  r$  rà  r  )!rÛ  rÞ  r1  Úraw_hostÚendswithÚrstriprº  rÐ  rê  rë  rj   rh   rì  r    r6  r  r  rí  rÜ   r!   rª  Úpop_addr_infos_interleaver®  r  r  r&   r§   rá   râ   rŸ   r  ÚgetpeernameÚremove_addr_infos)rS   r$  r4  r  rà  r  r“  ro  rº  r  rï   Úlast_excrâ  r  Útranspr  ræ  Úbad_peers                     rT   rÖ  z&TCPConnector._create_direct_connection  sU  è ø€ ð ×*Ñ*¨3Ó/ˆ
Ø×+Ñ+¨CÓ0ˆà�w‰w×ÑˆØÐÐÐð �=‰=˜ÔØ—;‘;˜sÓ# cÑ)ˆDØ�x‰xˆØÐÐÐð
	Lð ×,Ñ,¨T°4ÀÐ,ÓG×GˆEð &*ˆØ×6Ñ6°uÓ=ˆ
Ùñ >H�×$Ñ$Ò,¨×4Ñ4°SÔ9ÈTð ðØ&*×&BÑ&BØ—M‘MØ#Ø"Ø)Ø$3ØØ!-ð 'Có '÷ !‘�˜ð �z‰zŒ|¡ðØ×%Ñ% fÔ-ð ˜5�=Ð �6˜5�=Ð àÐ'Ð'Ð'ØˆNðc HùÜò 	LØ�y‰yÐ ¤Z°´W×5IÑ5IÔ%JØô *¨#×*<Ñ*<¸cÓBÈÐKûð	Lúð"!ùô )¬'×*>Ñ*>Ð?ò Ø�Ü ×:Ñ:¸:Àt×GWÑGWÔXÝûðûô 1ò 	Ø—L‘L”NØ×8Ò8Ø×7Ñ7×>Ñ>¸vÔFØ"�Hà*0×*?Ñ*?ÀÓ*I�DØ#×/Ñ/Ó1�HÜ$×6Ñ6°zÀ8ÔLÝûð	üs£   ‚A2IÁ5D+ ÂD)ÂD+ Â8IÃ
%E< Ã/E:Ã0E< Ã7IÄ
G ÄIÄ)D+ Ä+	E7Ä4>E2Å2E7Å7IÅ:E< Å<GÆ"F=Æ7IÆ=GÇIÇ	I	ÇA0IÈ>IÉI	É	Ic              ƒ   ó  K  — | j                  |«       | j                  «       }| j                  |«      }| j                  |g |t        ¬«      ƒ d {  –—† \  }}|j                  «       �r|r| j                  ||«       t        j                  |_	        |j                  |_
        |j                  j                  d d d ¬«      }t        | ||| j                  «      }	|j                  |	«      ƒ d {  –—† }
	 |	j                   }|€J ‚|j#                  || j$                  ¬«       |
j'                  |	«      ƒ d {  –—† }d |	_        	 |j(                  dk7  re|j*                  }|€t-        |j(                  «      j.                  }t1        |
j2                  |j4                  |j(                  ||j6                  ¬«      ‚|s0|j9                  dd ¬«      }|€t;        d«      ‚|j=                  «       }|s|jA                  «        	 |sT| jC                  |«      }| jE                  | jF                  |||jH                  |¬	«      ƒ d {  –—† |
jA                  «        S | jK                  |||¬
«      ƒ d {  –—† |
jA                  «        S ||fS 7 �Œ07 �Œ–7 �ŒR# t>        $ r |jA                  «        ‚ w xY w# |s|jA                  «        w w xY w7 Œƒ7 ŒY# t>        $ r" |
jA                  «        |	jA                  «        ‚ w xY w# |
jA                  «        w xY w­w)Nrß  )r)  r-  Úproxy_headers_hash)Úread_until_eofrÉ   éÈ   )Ústatusr‹   r&  r  )r	  z)Transport does not expose socket instance)r  r(  ræ  r  r$  )r$  r  )&rõ  rû  r3  rÖ  r$   r  r  r   ÚMETH_CONNECTÚmethodr1  r6  Ú_replacer³   ry   Úsendrz   Úset_response_paramsrÎ   Ústartr.  Úreasonr   Úphraser#   r   Úhistoryr&  r  rØ  Údupr?  r§   rÛ  rð  rÜ   ro  r  )rS   r$  r4  r  Úruntime_has_start_tlsr2  r›   r  rs   rB  Ú
proxy_resprt   Úrespr‹   Úrawsockr  s                   rT   rÕ  z%TCPConnector._create_proxy_connectionV  s  è ø€ ð 	×"Ñ" 3Ô'Ø $× =Ñ =Ó ?ÐØ×FÑFÀsÓKˆ	ð "&×!?Ñ!?Ø�r˜7Ô1Kð "@ó "
÷ 
Ñˆ	�5ð �:‰:�<Ù$Ø×+Ñ+¨I°sÔ;ô  $×0Ñ0ˆIÔØŸG™GˆIŒMØ×$Ñ$×-Ñ-Ø tÀð .ó ˆCô ,¨D°#°u¸d¿j¹jÓIˆDØ(Ÿ~™~¨dÓ3×3ˆJðD#ØŸ>™>�ØÐ+Ð+Ð+ð
 ×,Ñ,Ø#8Ø+/×+GÑ+Gð -ô ð (×-Ñ-¨dÓ3×3�ð "&�”ð*Ø—{‘{ cÒ)Ø"&§+¡+˜Ø"˜?Ü&0°·±Ó&=×&DÑ&D˜GÜ2Ø&×3Ñ3Ø ŸL™LØ#'§;¡;Ø$+Ø$(§L¡Lôð ñ 1Ø"+×":Ñ":¸8ÈTÐ":Ó"R˜Ø"˜?Ü".Ø Kó#ð ð #*§+¡+£-˜ñ 1Ø!Ÿ™Õ)á,à!%×!6Ñ!6°sÓ!;�JØ!%×!?Ñ!?ØŸ™Ø 'Ø&Ø$Ø(+¯©Øð "@ó "÷ ð" × Ñ Õ"ð "×7Ñ7ð ØØ#ð 8ó ÷ ð × Ñ Õ"à˜%ÐÐð}
ùð. 4ùð 4úô6 %ò ð —O‘OÔ%Øðûñ 1Ø!Ÿ™Õ)ð 1úðøðùôa !ò Ø× Ñ Ô"Ø—
‘
”Øðûðp × Ñ Õ"üs²   ‚ALÁJÁBLÃ.JÃ/LÃ4AK Ä5JÄ6K Ä:K2 ÅB&J
 Ç(AK2 È<K È=K2 É LÉK2 É(KÉ)K2 É,LÊLÊK Ê
J%Ê%J( Ê(J=Ê=K2 ËK2 Ë+K/Ë/K2 Ë2LÌL)NNrš   )r$  r+   rP   Nr_   )?r`   ra   rb   r¶   ra  Ú	frozensetrb  r  ÚAddressFamilyÚ	AF_UNSPECr3   r±   Úbytesrd  rƒ  r,   r  r®   r   rÖ   rc  rh   r­   r   r.   rU   rT  r   rê   r§   r¯   r—  r”  r¼  r	   r   rÐ  rÓ   rÊ  r+   r*   r=  rÛ  r   rÞ  r!   r   r   re  rk   r°   rí  rð  rõ  ró  rû  r  ÚBaseTransportr  r  rÖ  rÕ  Ú__classcell__©r³  s   @rT   rD   rD   š  s[  ø„ ñ$ðL #8¹)ÀUÀGÓ:LÑ"LÐð
  Ø$(Ø"Ø$&Ø"&Ø'-×';Ñ';×'EÑ'EØ)-Ø/3Ø-1Ø,0Ø3;Ø!ØØØ&+Ø15Ø()Ø-1Ø!%Ø37Ø9Aò/P>ð ðP>ð ˜T‘\ð	P>ð
 ðP>ð ˜T‘zðP>ð  ðP>ð ×$Ñ$ðP>ð   $Ñ&ðP>ð �KÑ *Ñ,ðP>ð ˜#˜s˜(‘O dÑ*ðP>ð # TÑ)ðP>ð   %™<¨&Ñ0ðP>ð ðP>ð ðP>ð  ð!P>ð"  $ð#P>ð$ ×'Ñ'¨$Ñ.ð%P>ð& !&ð'P>ð( $ d™lð)P>ð* ˜$‘Jð+P>ð, *¨DÑ0ð-P>ð. (¨$Ñ.°Ñ6õ/P>ðd +0ò  4ð °D¸À6Ñ9JÑ4Kõ ð 05ò )¨ð )¸õ )ð ð˜ò ó ðð ð#˜tò #ó ð#ñ' C¨$¡Jð '¸SÀ4¹Zð 'ÐSWó 'ð HLñaØðaØ"ðaØ,4°WÑ,=ÀÑ,Dðaà	ˆmÑ	óaðF'2à�3˜�8‰_ð'2ð ð'2ð ð	'2ð
 Ð+Ñ,ð'2ð ˜Ñ! DÑ(ð'2ð 
ˆmÑ	ó'2ðRØ ðØ*.¨w©-ðØBQðà	óð% Mð %°jÀ4Ñ6Gó %ðB Mð °h¸}Ñ6Mó ð )=ò$Aàð$Að ˜Ñ&ð$Að ð	$Að
 !ð$Að ˜9‘oð$Að ð$Að 
ˆw× Ñ  /Ð1Ñ	2ó$AðV )=òAàðAð ðAð !ð	Að
 ˜9‘oðAð ðAð 
ˆw× Ñ  /Ð1Ñ	2óAó,)ó$ð"¨$ó ð/
à%×/Ñ/ð/
ð ð/
ð 
ó	/
ðl )=ñT(à%×/Ñ/ðT(ð ðT(ð !ð	T(ð
 ˜9‘oðT(ð 
ˆw×$Ñ$ oÐ5Ñ	6óT(ðlØ˜-Ñ(ðà	ˆlÑ	óð6 )=òIàðIð �W‘ðIð !ð	Ið ˜9‘oðIð 
ˆw× Ñ  /Ð1Ñ	2óIðVf Ø ðf Ø*.¨w©-ðf ØBQðf à	ˆw×$Ñ$ oÐ5Ñ	6÷f rV   rD   c                   ó¾   ‡ — e Zd ZdZe edh«      z  Zdedddfdede	d	e
ez  dz  d
ededej                  dz  ddfˆ fd„Zedefd„«       Zdeded   dddefd„Zˆ xZS )rE   a�  Unix socket connector.

    path - Unix socket path.
    keepalive_timeout - (optional) Keep-alive timeout.
    force_close - Set to True to force close and do reconnect
        after each request (and between redirects).
    limit - The total number of simultaneous connections.
    limit_per_host - Number of simultaneous connections to one host.
    loop - Optional event loop.
    ÚunixFrÁ   r   NÚpathrÅ   rÄ   rÆ   rÇ   ru   rP   c                 ó<   •— t         ‰| �  |||||¬«       || _        y )N©rÅ   rÄ   rÆ   rÇ   ru   )r¢  rU   Ú_path©rS   rF  rÅ   rÄ   rÆ   rÇ   ru   r³  s          €rT   rU   zUnixConnector.__init__Í  s/   ø€ ô 	‰ÑØ#Ø/ØØ)Øð 	ô 	
ð ˆ�
rV   c                 ó   — | j                   S )zPath to unix socket.©rI  rY   s    rT   rF  zUnixConnector.pathß  ó   € ð �z‰zÐrV   r$  r4  rI   r  rG   c              ƒ   óæ  K  — 	 t        |j                  |j                  ¬«      4 ƒd {  –—†  | j                  j	                  | j
                  | j                  «      ƒ d {  –—† \  }}d d d «      ƒd {  –—†  |S 7 ŒQ7 Œ7 Œ
# 1 ƒd {  –—†7  sw Y   S xY w# t        $ rN}|j                  €t        |t        j                  «      r‚ t        | j                  |j                  |«      |‚d }~ww xY w­wrï  )r/   rç  r9  ry   Úcreate_unix_connectionrÜ   rI  rê  rë  rj   rh   rì  r'   rF  r6  ©rS   r$  r4  r  r  r  rï   s          rT   r=  z UnixConnector._create_connectionä  sß   è ø€ ð
	XÜ#Ø×$Ñ$°W×5KÑ5Kô÷ ñ ð "&§¡×!BÑ!BØ—M‘M 4§:¡:ó"÷ ‘��5÷÷ ð ˆðøðøðø÷ ÷ ð ð ˆûô ò 	XØ�y‰yÐ ¤Z°´W×5IÑ5IÔ%JØÜ*¨4¯9©9°c×6HÑ6HÈ#ÓNÐTWÐWûð	XüsŒ   ‚C1„%B ©A;ªB ­4BÁ!A=Á"BÁ)B Á4A?Á5B Á9C1Á;B Á=BÁ?B ÂBÂB
ÂBÂB ÂC1ÂB Â	C.Â A	C)Ã)C.Ã.C1©r`   ra   rb   r¶   ra  r=  rb  r3   r®   r±   rc  rÖ   rd  rh   r­   rU   r¯   rF  r+   rT  r*   r=  rB  rC  s   @rT   rE   rE   ¿  sÎ   ø„ ñ	ð #8¹)ÀVÀHÓ:MÑ"MÐð
 "Ø3;ØØØ15ñàðð ðð " E™>¨DÑ0ð	ð
 ðð ðð ×'Ñ'¨$Ñ.ðð 
õð$ ð�cò ó ððØ ðØ*.¨w©-ðØBQðà	÷rV   rE   c                   ó¾   ‡ — e Zd ZdZe edh«      z  Zdedddfdede	d	e
ez  dz  d
ededej                  dz  ddfˆ fd„Zedefd„«       Zdeded   dddefd„Zˆ xZS )rF   aþ  Named pipe connector.

    Only supported by the proactor event loop.
    See also: https://docs.python.org/3/library/asyncio-eventloop.html

    path - Windows named pipe path.
    keepalive_timeout - (optional) Keep-alive timeout.
    force_close - Set to True to force close and do reconnect
        after each request (and between redirects).
    limit - The total number of simultaneous connections.
    limit_per_host - Number of simultaneous connections to one host.
    loop - Optional event loop.
    ÚnpipeFrÁ   r   NrF  rÅ   rÄ   rÆ   rÇ   ru   rP   c                 óš   •— t         ‰| �  |||||¬«       t        | j                  t        j
                  «      st        d«      ‚|| _        y )NrH  z9Named Pipes only available in proactor loop under windows)r¢  rU   rj   ry   rh   ÚProactorEventLooprØ  rI  rJ  s          €rT   rU   zNamedPipeConnector.__init__  s[   ø€ ô 	‰ÑØ#Ø/ØØ)Øð 	ô 	
ô Ø�J‰JÜ×%Ñ%ô
ô ØKóð ð ˆ�
rV   c                 ó   — | j                   S )zPath to the named pipe.rL  rY   s    rT   rF  zNamedPipeConnector.path   rM  rV   r$  r4  rI   r  rG   c              ƒ   ó(  K  — 	 t        |j                  |j                  ¬«      4 ƒd {  –—†  | j                  j	                  | j
                  | j                  «      ƒ d {  –—† \  }}t        j                  d«      ƒ d {  –—†  d d d «      ƒd {  –—†  t        t         «      S 7 Œ|7 ŒF7 Œ(7 Œ# 1 ƒd {  –—†7  sw Y   Œ*xY w# t        $ rC}|j                  €t        |t        j                  «      r‚ t        |j                  |«      |‚d }~ww xY w­w)Nrä  r   )r/   rç  r9  ry   Úcreate_pipe_connectionrÜ   rI  rh   Úsleeprê  rë  rj   rì  r!   r6  r   r*   rP  s          rT   r=  z%NamedPipeConnector._create_connection%  só   è ø€ ð	IÜ#Ø×$Ñ$°W×5KÑ5Kô÷ 
'ñ 
'ð "&§¡×!BÑ!BØ—M‘M 4§:¡:ó"÷ ‘��5ô —m‘m AÓ&×&Ð&÷
'÷ 
'ô$ ”O UÓ+Ð+ð%
'øðøð 'øð
'ø÷ 
'÷ 
'ñ 
'ûô ò 	IØ�y‰yÐ ¤Z°´W×5IÑ5IÔ%JØÜ& s×'9Ñ'9¸3Ó?ÀSÐHûð	Iüs‘   ‚D„%C ©B&ªC ­4B.Á!B(Á"B.ÂB*ÂB.ÂC ÂB,ÂC ÂDÂ&C Â(B.Â*B.Â,C Â.C Â4B7Â5C Â<C Ã	DÃ>D
Ä
DÄDrQ  rC  s   @rT   rF   rF   ö  sÎ   ø„ ñð #8¹)ÀWÀIÓ:NÑ"NÐð
 "Ø3;ØØØ15ñàðð ðð " E™>¨DÑ0ð	ð
 ðð ðð ×'Ñ'¨$Ñ.ðð 
õð2 ð�cò ó ðð,Ø ð,Ø*.¨w©-ð,ØBQð,à	÷,rV   rF   )orh   rÚ   rU  r  r   r}   r[   Úcollectionsr   r   r   Úcollections.abcr   r   r   r	   Ú
contextlibr
   r=   r   Ú	itertoolsr   r   r   Útimer   Útypesr   Útypingr   r   r   r   r   r   rª  r   r   r<   r   r   Úabcr   r   Úclient_exceptionsr   r   r    r!   r"   r#   r$   r%   r&   r'   r(   r)   Úclient_protor*   Úclient_reqrepr+   r,   r-   r.   r/   r0   r1   r2   r3   r4   r5   Úlogr6   rš  r7   rà   r;   r@  Ú	bytearrayr(  rƒ  ÚImportErrorrc  r=  ÚEMPTY_SCHEMA_SETÚHTTP_SCHEMA_SETÚWS_SCHEMA_SETÚHTTP_AND_EMPTY_SCHEMA_SETra  rß   Ú__all__ÚclientrG   rH   ÚtracingrI   rK   rT  ro   rq   r³   r¸   rC   rg  r±   rŽ  rÚ  rÙ  rD   rE   rF   rd   rV   rT   ú<module>ro     s)  ðÛ Û Û Û Û 
Û Û ß 7Ñ 7ß CÓ CÝ Ý ß *Ñ *Ý Ý ß E× Eã ß <ç ß 0÷÷ ÷ ó õ *ß HÑ H÷	÷ 	ó 	õ Ý %à×Ñ�wÒÞ&à�5˜)Ð%6Ð8KÐKÑL€FáÛà—‘�JðÛà—^‘^ˆ
ñ
 ˜b˜T“?Ð Ù˜V WÐ-Ó.€Ù˜4 ˜-Ó(€à+Ð.>Ñ>Ð Ø1°MÑAÐ à! S×%5Ñ%5ö ð 9ô ò #ð 	×Ñ˜
Ñ"ð	 ð€ñ Ý%Ý,Ý÷ñ ð(J 4¨	°&Ñ(9Ñ#:ð J¸tó J÷UKñ UKôp˜zô ÷(4ñ 4÷"J	$ñ J	$÷Z-?ñ -?ð` ð ¨ó ñ6 *¨$Ó/Ð Ù+¨EÓ2Ð ôb �=ô b ôJ4�Mô 4ônE,˜õ E,øðk5 ò ØˆØŠ
ðús   Ä G= Ç=	H	ÈH	