§
    VøÁiJ(  ã                   óÞ   — 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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mZmZ  G d„ de¦  «        Z G d„ de¦  «        Z G d„ de¦  «        ZdS )	é    N)ÚQUIC_MAX_DATAGRAMÚAsyncQuicConnectionÚAsyncQuicManagerÚBaseQuicStreamÚUnexpectedEOFc                   óX   ‡ — e Zd Zˆ fd„Zd„ Zd„ Zd„ Zdd„Zdd„Zd	„ Z	d
„ Z
d„ Zd„ Zˆ xZS )ÚAsyncioQuicStreamc                 ó|   •— t          ¦   «                              ||¦  «         t          j        ¦   «         | _        d S ©N)ÚsuperÚ__init__ÚasyncioÚ	ConditionÚ_wake_up)ÚselfÚ
connectionÚ	stream_idÚ	__class__s      €ú[/var/www/html/jarvis.com/web/backend/venv/lib/python3.11/site-packages/dns/quic/_asyncio.pyr   zAsyncioQuicStream.__init__   s1   ø€ Ý‰Œ×Ò˜ YÑ/Ô/Ð/ÝÔ)Ñ+Ô+ˆŒˆˆó    c              ƒ   ó¬   K  — | j         4 ƒd {V —† | j                              ¦   «         ƒ d {V —† d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S r   )r   Úwait©r   s    r   Ú_wait_for_wake_upz#AsyncioQuicStream._wait_for_wake_up    sò   è è € Ø”=ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'Ø”-×$Ò$Ñ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&ð	'ð 	'ð 	'ñ 	'ô 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'ð 	'øøøð 	'ð 	'ð 	'ð 	'ð 	'ð 	's   � AÁ
AÁAc              ƒ   ó$  K  — 	 |                       |¦  «        }| j                             |¦  «        rd S || _        	 t	          j        |                      ¦   «         |¦  «        ƒ d {V —† n# t          $ r t          j	        j
        ‚w xY wd| _        ŒŽ)NTr   )Ú_timeout_from_expirationÚ_bufferÚhaveÚ
_expectingr   Úwait_forr   ÚTimeoutErrorÚdnsÚ	exceptionÚTimeout)r   ÚamountÚ
expirationÚtimeouts       r   r    zAsyncioQuicStream.wait_for$   s­   è è € ð		 Ø×3Ò3°JÑ?Ô?ˆGØŒ|× Ò  Ñ(Ô(ð Ø�Ø$ˆDŒOð,ÝÔ& t×'=Ò'=Ñ'?Ô'?ÀÑIÔIÐIÐIÐIÐIÐIÐIÐIÐIøÝð ,ð ,ð ,Ý”mÔ+Ð+ð,øøøàˆDŒOð		 s   ½-A+ Á+Bc              ƒ   ó  K  — 	 |                       |¦  «        }| j                             ¦   «         rd S 	 t          j        |                      ¦   «         |¦  «        ƒ d {V —† n# t          $ r t          j        j	        ‚w xY wŒr   )
r   r   Úseen_endr   r    r   r!   r"   r#   r$   )r   r&   r'   s      r   Úwait_for_endzAsyncioQuicStream.wait_for_end0   s�   è è € ð	,Ø×3Ò3°JÑ?Ô?ˆGØŒ|×$Ò$Ñ&Ô&ð Ø�ð,ÝÔ& t×'=Ò'=Ñ'?Ô'?ÀÑIÔIÐIÐIÐIÐIÐIÐIÐIÐIøÝð ,ð ,ð ,Ý”mÔ+Ð+ð,øøøð	,s   µ-A# Á#A?Nc              ƒ   óÌ  K  — |                       |¦  «        }| j                             ¦   «         r4|                      |¦  «        ƒ d {V —† | j                             ¦   «         S |                      d|¦  «        ƒ d {V —† t          j        d| j         	                    d¦  «        ¦  «        \  }|                      ||¦  «        ƒ d {V —† | j         	                    |¦  «        S )Né   z!H)
Ú_expiration_from_timeoutÚ_connectionÚis_h3r*   r   Úget_allr    ÚstructÚunpackÚget)r   r'   r&   Úsizes       r   ÚreceivezAsyncioQuicStream.receive:   sï   è è € Ø×2Ò2°7Ñ;Ô;ˆ
ØÔ×!Ò!Ñ#Ô#ð 	*Ø×#Ò# JÑ/Ô/Ð/Ð/Ð/Ð/Ð/Ð/Ð/Ø”<×'Ò'Ñ)Ô)Ð)à—-’-  :Ñ.Ô.Ð.Ð.Ð.Ð.Ð.Ð.Ð.Ý”m D¨$¬,×*:Ò*:¸1Ñ*=Ô*=Ñ>Ô>‰GˆTØ—-’-  jÑ1Ô1Ð1Ð1Ð1Ð1Ð1Ð1Ð1Ø”<×#Ò# DÑ)Ô)Ð)r   Fc              ƒ   ó‚   K  — |                       |¦  «        }| j                             | j        ||¦  «        ƒ d {V —† d S r   )Ú_encapsulater.   ÚwriteÚ
_stream_id)r   ÚdatagramÚis_endÚdatas       r   ÚsendzAsyncioQuicStream.sendE   sN   è è € Ø× Ò  Ñ*Ô*ˆØÔ×$Ò$ T¤_°d¸FÑCÔCÐCÐCÐCÐCÐCÐCÐCÐCÐCr   c              ƒ   óÐ   K  — |                       ||¦  «        rM| j        4 ƒd {V —† | j                             ¦   «          d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S d S r   )Ú_common_add_inputr   Únotify)r   r<   r;   s      r   Ú
_add_inputzAsyncioQuicStream._add_inputI   s  è è € Ø×!Ò! $¨Ñ/Ô/ð 	'Ø”}ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'Ø”×$Ò$Ñ&Ô&Ð&ð'ð 'ð 'ñ 'ô 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'ð 'øøøð 'ð 'ð 'ð 'ð 'ð 'ð	'ð 	's   ¦AÁ
AÁ Ac              ƒ   ó2   K  — |                       ¦   «          d S r   )Ú_closer   s    r   ÚclosezAsyncioQuicStream.closeN   s   è è € Ø�Š‰Œˆˆˆr   c              ƒ   ó
   K  — | S r   © r   s    r   Ú
__aenter__zAsyncioQuicStream.__aenter__S   ó   è è € Øˆr   c              ƒ   óÒ   K  — |                       ¦   «         ƒ d {V —† | j        4 ƒd {V —† | j                             ¦   «          d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   dS ©NF)rD   r   r@   )r   Úexc_typeÚexc_valÚexc_tbs       r   Ú	__aexit__zAsyncioQuicStream.__aexit__V   sö   è è € Ø�jŠj‰lŒlÐÐÐÐÐÐÐØ”=ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ØŒM× Ò Ñ"Ô"Ð"ð	#ð 	#ð 	#ñ 	#ô 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#ð 	#øøøð 	#ð 	#ð 	#ð 	#àˆus   ªAÁ
A Á#A r   ©F)Ú__name__Ú
__module__Ú__qualname__r   r   r    r*   r5   r=   rA   rD   rG   rN   Ú__classcell__©r   s   @r   r	   r	      sÍ   ø€ € € € € ð,ð ,ð ,ð ,ð ,ð'ð 'ð 'ð
 ð 
 ð 
 ð,ð ,ð ,ð	*ð 	*ð 	*ð 	*ðDð Dð Dð Dð'ð 'ð 'ð
ð ð ð
ð ð ðð ð ð ð ð ð r   r	   c                   óZ   ‡ — e Zd Zdˆ fd„	Zd„ Zd„ Zd„ Zd„ Zd„ Zdd	„Z	d
„ Z
dd„Zd„ Zˆ xZS )ÚAsyncioQuicConnectionNc                 ó  •— t          ¦   «                              ||||||¦  «         d | _        t          j        ¦   «         | _        t          j        ¦   «         | _        t          j        ¦   «         | _        d | _	        d | _
        d| _        d S rJ   )r   r   Ú_socketr   ÚEventÚ_handshake_completeÚ_socket_createdr   Ú_wake_timerÚ_receiver_taskÚ_sender_taskÚ_wake_pending)r   r   ÚaddressÚportÚsourceÚsource_portÚmanagerr   s          €r   r   zAsyncioQuicConnection.__init__^   sw   ø€ Ý‰Œ×Ò˜ W¨d°F¸KÈÑQÔQÐQØˆŒÝ#*¤=¡?¤?ˆÔ Ý&œ}™œˆÔÝ"Ô,Ñ.Ô.ˆÔØ"ˆÔØ ˆÔØ"ˆÔÐÐr   c           	   ƒ   ó,  K  — 	 t           j                             | j        ¦  «        }t           j                             d¦  «        }|                     |t          j        d| j	        | j
        d         | j
        d         f¦  «        ƒ d {V —†| _        | j                             ¦   «          | j        4 ƒd {V —† | j        s¦| j                             t           d ¦  «        ƒ d {V —†\  }}|d         | j
        d         k    s|d         | j
        d         k    rŒ_| j                             ||t'          j        ¦   «         ¦  «         |                      ¦   «         ƒ d {V —† | j        ¯¦	 d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   n# t*          $ r Y nw xY wd| _        |                      ¦   «         ƒ d {V —† | j                             ¦   «          d S # d| _        |                      ¦   «         ƒ d {V —† | j                             ¦   «          w xY w)Nr   r   é   T)r"   ÚinetÚaf_for_addressÚ_addressÚasyncbackendÚget_backendÚmake_socketÚsocketÚ
SOCK_DGRAMÚ_sourceÚ_peerrX   r[   ÚsetÚ_doneÚrecvfromr   r.   Úreceive_datagramÚtimeÚ_wakeupÚ	ExceptionrZ   )r   ÚafÚbackendr:   r`   s        r   Ú	_receiverzAsyncioQuicConnection._receiverh   sÖ  è è € ð	+Ý”×(Ò(¨¬Ñ7Ô7ˆBÝÔ&×2Ò2°9Ñ=Ô=ˆGð ")×!4Ò!4Ø•FÔ% q¨$¬,¸¼ÀA¼ÈÌ
ÐSTÌÐ8Vñ"ô "ð ð ð ð ð ð ˆDŒLð Ô ×$Ò$Ñ&Ô&Ð&Ø”|ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)Øœ*ð 	)Ø04´×0EÒ0EÝ)¨4ñ1ô 1ð +ð +ð +ð +ð +ð +Ñ'�X˜wð ˜q”z T¤Z°¤]Ò2Ð2°g¸a´jÀDÄJÈqÄMÒ6QÐ6QØ ØÔ$×5Ò5°hÀÍÌÉÌÑUÔUÐUð Ÿ,š,™.œ.Ð(Ð(Ð(Ð(Ð(Ð(Ð(ð œ*ð 	)ð 	)ð
)ð 
)ð 
)ñ 
)ô 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)ð 
)øøøð 
)ð 
)ð 
)ð 
)øøõ ð 	ð 	ð 	ØˆDð	øøøð ˆDŒJØ—,’,‘.”.Ð Ð Ð Ð Ð Ð Ð ØÔ$×(Ò(Ñ*Ô*Ð*Ð*Ð*øð ˆDŒJØ—,’,‘.”.Ð Ð Ð Ð Ð Ð Ð ØÔ$×(Ò(Ñ*Ô*Ð*Ð*øøøsO   „B4F Â8B.E9Å'F Å9
FÆF ÆFÆF Æ
G Æ
FÆG ÆFÆG Ç<Hc              ƒ   ó®   K  — d| _         | j        4 ƒd {V —† | j                             ¦   «          d d d ¦  «        ƒd {V —† d S # 1 ƒd {V —†swxY w Y   d S )NT)r_   r\   Ú
notify_allr   s    r   rv   zAsyncioQuicConnection._wakeup„   sê   è è € Ø!ˆÔØÔ#ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ØÔ×'Ò'Ñ)Ô)Ð)ð	*ð 	*ð 	*ñ 	*ô 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*ð 	*øøøð 	*ð 	*ð 	*ð 	*ð 	*ð 	*s   —AÁ
AÁAc              ƒ   óÆ   K  — | j         4 ƒd {V —† | j        s| j                              ¦   «         ƒ d {V —† d d d ¦  «        ƒd {V —† n# 1 ƒd {V —†swxY w Y   d| _        d S rJ   )r\   r_   r   r   s    r   Ú_wait_for_wake_timerz*AsyncioQuicConnection._wait_for_wake_timer‰   s   è è € ØÔ#ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ØÔ%ð .ØÔ&×+Ò+Ñ-Ô-Ð-Ð-Ð-Ð-Ð-Ð-Ð-ð	.ð 	.ð 	.ñ 	.ô 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.ð 	.øøøð 	.ð 	.ð 	.ð 	.ð #ˆÔÐÐs   �'A	Á	
AÁAc              ƒ   óR  K  — | j                              ¦   «         ƒ d {V —† | j        sþ| j                             t          j        ¦   «         ¦  «        }|D ]B\  }}|| j        k    sJ ‚| j        €J ‚| j                             || j        d ¦  «        ƒ d {V —† ŒC|  	                    ¦   «         \  }}	 t          j        |                      ¦   «         |¦  «        ƒ d {V —† n# t          $ r Y nw xY w|                      |¦  «         |                      ¦   «         ƒ d {V —† | j        ¯üd S d S r   )r[   r   rr   r.   Údatagrams_to_sendru   rp   rX   ÚsendtoÚ_get_timer_valuesr   r    r~   rw   Ú_handle_timerÚ_handle_events)r   Ú	datagramsr:   r`   r&   Úintervals         r   Ú_senderzAsyncioQuicConnection._sender�   s‚  è è € ØÔ"×'Ò'Ñ)Ô)Ð)Ð)Ð)Ð)Ð)Ð)Ð)Ø”*ð 	(ØÔ(×:Ò:½4¼9¹;¼;ÑGÔGˆIØ%.ð Fð FÑ!�˜'Ø $¤*Ò,Ð,Ð,Ð,Ø”|Ð/Ð/Ð/Ø”l×)Ò)¨(°D´JÀÑEÔEÐEÐEÐEÐEÐEÐEÐEÐEØ%)×%;Ò%;Ñ%=Ô%=Ñ"ˆZ˜ðÝÔ& t×'@Ò'@Ñ'BÔ'BÀHÑMÔMÐMÐMÐMÐMÐMÐMÐMÐMøÝð ð ð Ø�ðøøøà×Ò˜zÑ*Ô*Ð*Ø×%Ò%Ñ'Ô'Ð'Ð'Ð'Ð'Ð'Ð'Ð'ð ”*ð 	(ð 	(ð 	(ð 	(ð 	(s   Â1-C Ã
C,Ã+C,c              ƒ   ó¼  K  — d}	 | j                              ¦   «         }|€d S t          |t          j        j        j        ¦  «        �r‚|                      ¦   «         �r%| j        €J ‚| j         	                    |¦  «        }|D ]ý}t          |t          j
        j        j        ¦  «        rl| j                             |j        ¦  «        }|rJ|j        €|j        |_        n|j        €|j        |_        |j        r|                     dd¦  «        ƒ d {V —† Œ’t          |t          j
        j        j        ¦  «        rG| j                             |j        ¦  «        }|r&|                     |j        |j        ¦  «        ƒ d {V —† Œþ�n3| j                             |j        ¦  «        }|r&|                     |j        |j        ¦  «        ƒ d {V —† nët          |t          j        j        j        ¦  «        r| j                             ¦   «          n­t          |t          j        j        j        ¦  «        r(d| _        | j        �| j                             ¦   «          nat          |t          j        j        j        ¦  «        r=| j                             |j        ¦  «        }|r|                     dd¦  «        ƒ d {V —† |dz  }|dk    rd}t?          j         d¦  «        ƒ d {V —† �ŒØ)Nr   Tr   rf   é
   )!r.   Ú
next_eventÚ
isinstanceÚaioquicÚquicÚeventsÚStreamDataReceivedr/   Ú_h3_connÚhandle_eventÚh3ÚHeadersReceivedÚ_streamsr3   r   Ú_headersÚheadersÚ	_trailersÚstream_endedrA   ÚDataReceivedr<   Ú
end_streamÚHandshakeCompletedrZ   rq   ÚConnectionTerminatedrr   r]   ÚcancelÚStreamResetr   Úsleep)r   ÚcountÚeventÚ	h3_eventsÚh3_eventÚstreams         r   r„   z$AsyncioQuicConnection._handle_eventsŸ   s  è è € Øˆð+	'ØÔ$×/Ò/Ñ1Ô1ˆEØˆ}Ø�Ý˜%¥¤Ô!4Ô!GÑHÔHñ !7Ø—:’:‘<”<ñ NØœ=Ð4Ð4Ð4Ø $¤× :Ò :¸5Ñ AÔ A�IØ$-ð "ð "˜Ý% hµ´
Ô0AÔ0QÑRÔRð "Ø%)¤]×%6Ò%6°u´Ñ%GÔ%G˜FØ%ð GØ#)¤?Ð#:Ø6>Ô6F F¤O OØ%+Ô%5Ð%=Ø7?Ô7G FÔ$4Ø#+Ô#8ð !GØ*0×*;Ò*;¸CÀÑ*FÔ*FÐ$FÐ$FÐ$FÐ$FÐ$FÐ$FÐ$FøÝ'¨µ'´*Ô2CÔ2PÑQÔQð "Ø%)¤]×%6Ò%6°u´Ñ%GÔ%G˜FØ%ð "Ø&,×&7Ò&7Ø$,¤M°8Ô3Hñ'"ô '"ð !"ð !"ð !"ð !"ð !"ð !"ð !"øñ"ð" "œ]×.Ò.¨u¬Ñ?Ô?�FØð NØ$×/Ò/°´
¸EÔ<LÑMÔMÐMÐMÐMÐMÐMÐMÐMøÝ˜E¥7¤<Ô#6Ô#IÑJÔJð 	7ØÔ(×,Ò,Ñ.Ô.Ð.Ð.Ý˜E¥7¤<Ô#6Ô#KÑLÔLð 7Ø!�”
ØÔ&Ð2ØÔ'×.Ò.Ñ0Ô0Ð0øÝ˜E¥7¤<Ô#6Ô#BÑCÔCð 7Øœ×*Ò*¨5¬?Ñ;Ô;�Øð 7Ø ×+Ò+¨C°Ñ6Ô6Ð6Ð6Ð6Ð6Ð6Ð6Ð6à�Q‰JˆEØ�rŠzˆzà�Ý”m AÑ&Ô&Ð&Ð&Ð&Ð&Ð&Ð&Ð&ñW+	'r   Fc              ƒ   óv   K  — | j                              |||¦  «         |                      ¦   «         ƒ d {V —† d S r   )r.   Úsend_stream_datarv   )r   r¤   r<   r;   s       r   r8   zAsyncioQuicConnection.writeÎ   sG   è è € ØÔ×)Ò)¨&°$¸Ñ?Ô?Ð?Ø�lŠl‰nŒnÐÐÐÐÐÐÐÐÐr   c                 óÄ   — | j         rd S t          j        |                      ¦   «         ¦  «        | _        t          j        |                      ¦   «         ¦  «        | _        d S r   )Ú_closedr   ÚTaskrz   r]   r‡   r^   r   s    r   ÚrunzAsyncioQuicConnection.runÒ   sM   € ØŒ<ð 	ØˆFÝ%œl¨4¯>ª>Ñ+;Ô+;Ñ<Ô<ˆÔÝ#œL¨¯ª©¬Ñ8Ô8ˆÔÐÐr   c              ƒ   ó4  K  — 	 t          j        | j                             ¦   «         |¦  «        ƒ d {V —† n# t          $ r t
          j        j        ‚w xY w| j        rt          ‚| j
                             d¦  «        }t          | |¦  «        }|| j        |<   |S rJ   )r   r    rZ   r   r!   r"   r#   r$   rr   r   r.   Úget_next_available_stream_idr	   r”   )r   r'   r   r¤   s       r   Úmake_streamz!AsyncioQuicConnection.make_streamØ   s®   è è € ð	(ÝÔ" 4Ô#;×#@Ò#@Ñ#BÔ#BÀGÑLÔLÐLÐLÐLÐLÐLÐLÐLÐLøÝð 	(ð 	(ð 	(Ý”-Ô'Ð'ð	(øøøàŒ:ð 	 ÝÐØÔ$×AÒAÀ%ÑHÔHˆ	Ý" 4¨Ñ3Ô3ˆØ#)ˆŒ�iÑ Øˆs	   „27 ·Ac              ƒ   ó0  K  — | j         �s	| j        �1| j                             | j        d         | j        d         ¦  «         d| _         | j                             ¦   «          | j                             ¦   «          |                      ¦   «         ƒ d {V —† 	 | j	        �| j	        ƒ d {V —† n# t          j        $ r Y nw xY w	 | j        �| j        ƒ d {V —† n# t          j        $ r Y nw xY w| j        �#| j                             ¦   «         ƒ d {V —† d S d S d S )Nr   rf   T)r¨   Ú_managerÚclosedrp   r.   rD   r[   rq   rv   r]   r   ÚCancelledErrorr^   rX   r   s    r   rD   zAsyncioQuicConnection.closeä   sm  è è € ØŒ|ñ 	+ØŒ}Ð(Ø”×$Ò$ T¤Z°¤]°D´J¸q´MÑBÔBÐBØˆDŒLØÔ×"Ò"Ñ$Ô$Ð$àÔ ×$Ò$Ñ&Ô&Ð&Ø—,’,‘.”.Ð Ð Ð Ð Ð Ð Ð ðØÔ&Ð2ØÔ-Ð-Ð-Ð-Ð-Ð-Ð-Ð-øøÝÔ)ð ð ð Ø�ðøøøðØÔ$Ð0ØÔ+Ð+Ð+Ð+Ð+Ð+Ð+Ð+øøÝÔ)ð ð ð Ø�ðøøøàŒ|Ð'Ø”l×(Ò(Ñ*Ô*Ð*Ð*Ð*Ð*Ð*Ð*Ð*Ð*Ð*ð'	+ð 	+ð$ (Ð's$   ÂB, Â,B>Â=B>ÃC ÃC)Ã(C)r   rO   )rP   rQ   rR   r   rz   rv   r~   r‡   r„   r8   rª   r­   rD   rS   rT   s   @r   rV   rV   ]   sÏ   ø€ € € € € ð#ð #ð #ð #ð #ð #ð+ð +ð +ð8*ð *ð *ð
#ð #ð #ð(ð (ð (ð -'ð -'ð -'ð^ð ð ð ð9ð 9ð 9ð
ð 
ð 
ð 
ð+ð +ð +ð +ð +ð +ð +r   rV   c                   óH   ‡ — e Zd Zdej        ddfˆ fd„	Z	 d
d„Zd„ Zd	„ Zˆ xZ	S )ÚAsyncioQuicManagerNFc                 ó\   •— t          ¦   «                              ||t          ||¦  «         d S r   )r   r   rV   )r   ÚconfÚverify_modeÚserver_namer’   r   s        €r   r   zAsyncioQuicManager.__init__ü   s-   ø€ õ 	‰Œ×Ò˜˜{Õ,AÀ;ÐPRÑSÔSÐSÐSÐSr   éU  r   Tc                 ój   — |                       |||||¦  «        \  }}|r|                     ¦   «          |S r   )Ú_connectrª   )r   r`   ra   rb   rc   Úwant_session_ticketr   Ústarts           r   ÚconnectzAsyncioQuicManager.connect  sH   € ð #ŸmšmØ�T˜6 ;Ð0Cñ
ô 
Ñˆ�Uð ð 	Ø�NŠNÑÔÐØÐr   c              ƒ   ó
   K  — | S r   rF   r   s    r   rG   zAsyncioQuicManager.__aenter__  rH   r   c              ƒ   ó”   K  — t          | j                             ¦   «         ¦  «        }|D ]}|                     ¦   «         ƒ d {V —† ŒdS rJ   )ÚlistÚ_connectionsÚvaluesrD   )r   rK   rL   rM   Úconnectionsr   s         r   rN   zAsyncioQuicManager.__aexit__  s_   è è € õ ˜4Ô,×3Ò3Ñ5Ô5Ñ6Ô6ˆØ%ð 	%ð 	%ˆJØ×"Ò"Ñ$Ô$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Ð$Øˆur   )r¸   Nr   T)
rP   rQ   rR   ÚsslÚCERT_REQUIREDr   r½   rG   rN   rS   rT   s   @r   r³   r³   û   sˆ   ø€ € € € € à SÔ%6ÀDÈUðTð Tð Tð Tð Tð Tð RVðð ð ð ðð ð ðð ð ð ð ð ð r   r³   )r   rm   rÄ   r1   ru   Úaioquic.h3.connectionrŒ   Úaioquic.h3.eventsÚaioquic.quic.configurationÚaioquic.quic.connectionÚaioquic.quic.eventsÚdns.asyncbackendr"   Údns.exceptionÚdns.inetÚdns.quic._commonr   r   r   r   r   r	   rV   r³   rF   r   r   ú<module>rÏ      sk  ðð €€€Ø €€€Ø 
€
€
€
Ø €€€Ø €€€à Ð Ð Ð Ø Ð Ð Ð Ø !Ð !Ð !Ð !Ø Ð Ð Ð Ø Ð Ð Ð à Ð Ð Ð Ø Ð Ð Ð Ø €€€ðð ð ð ð ð ð ð ð ð ð ð ð ð ð?ð ?ð ?ð ?ð ?˜ñ ?ô ?ð ?ðD[+ð [+ð [+ð [+ð [+Ð/ñ [+ô [+ð [+ð|ð ð ð ð Ð)ñ ô ð ð ð r   