+
    € ’e|¿  ã                   ó  € R t Rt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RI	t	^ RI
t
 ^ RIt^RIHt ^RIHt ^RIHt ^RIHt ^RIHt ^RIHt ^R	IHt ^R
IHt ^RIHt ]! ]P                  R4      t]'       d    ]P4                  ! R4      tR t ! R R]P<                  4      t ! R R]P@                  ]PB                  4      t" ! R R]"4      t# ! R R]"]PH                  4      t%R#   ] d    Rt LÊi ; i  ] d    Rt Lui ; i)zÄEvent loop using a selector and related classes.

A selector is a "notify-when-ready" multiplexer.  For a subclass which
also includes support for signal handling, see the unix_events sub-module.
ÚBaseSelectorEventLoopN)Úbase_events)Ú	constants)Úevents)Úfutures)Ú	protocols)Ússlproto)Ú
transports)Útrsock)ÚloggerÚsendmsgÚ
SC_IOV_MAXFc                 ó‚   €  V P                  V4      p\        VP                  V,          4      #   \         d     R # i ; i)F)Úget_keyÚboolr   ÚKeyError)ÚselectorÚfdÚeventÚkeys   &&& Úe/home/ubuntu/.hermes/tools/python-3.14.9+20261021-linux-x64/lib/python3.14/asyncio/selector_events.pyÚ_test_selector_eventr   *   sA   € ð(Ø×Ñ˜rÓ"ˆô �C—J‘J Õ&Ó'Ð'øô ô Úðús   ‚/ ¯>½>c                   óJ  a a€ ] tR t^5t oRtR7V 3R lltR7RRRR/R lltR7RRR	RRRRRR
]P                  R]P                  /R llt
R8R ltV 3R ltR tR tR tR tR tRR^d]P                  ]P                  3R ltRR^d]P                  ]P                  3R ltRR]P                  ]P                  3R ltR tR tR tR tR tR tR tR tR tR  tR7R! ltR" t R# t!R$ t"R% t#R& t$R9R' lt%R( t&R) t'R* t(R+ t)R, t*R- t+R. t,R7R/ lt-R0 t.R1 t/R2 t0R3 t1R4 t2R5 t3R6t4Vt5V ;t6# ):r   zBSelector event loop.

See events.EventLoop for API specification.
Nc                ó  <€ \         SV `  4        Vf   \        P                  ! 4       p\        P
                  ! RVP                  P                  4       Wn        V P                  4        \        P                  ! 4       V n        R # )NzUsing selector: %s)ÚsuperÚ__init__Ú	selectorsÚDefaultSelectorr   ÚdebugÚ	__class__Ú__name__Ú	_selectorÚ_make_self_pipeÚweakrefÚWeakValueDictionaryÚ_transports)Úselfr   r   s   &&€r   r   ÚBaseSelectorEventLoop.__init__;   s_   ø€ Ü‰ÑÔàÒÜ ×0Ò0Ó2ˆHÜ�ŠÐ)¨8×+=Ñ+=×+FÑ+FÔGØ!ŒØ×ÑÔÜ"×6Ò6Ó8ˆÖó    ÚextraÚserverc               ó>   € V P                  V4       \        WW#WE4      # ©N)Ú_ensure_fd_no_transportÚ_SelectorSocketTransport)r&   ÚsockÚprotocolÚwaiterr)   r*   s   &&&&$$r   Ú_make_socket_transportÚ,BaseSelectorEventLoop._make_socket_transportE   s$   € à×$Ñ$ TÔ*Ü'¨°HØ(-ó7ð 	7r(   Úserver_sideFÚserver_hostnameÚssl_handshake_timeoutÚssl_shutdown_timeoutc               óŽ   € V P                  V4       \        P                  ! WW4WVV	V
R 7      p\        WVWxR7       VP                  # ))r6   r7   )r)   r*   )r-   r   ÚSSLProtocolr.   Ú_app_transport)r&   Úrawsockr0   Ú
sslcontextr1   r4   r5   r)   r*   r6   r7   Ússl_protocols   &&&&&$$$$$$ r   Ú_make_ssl_transportÚ)BaseSelectorEventLoop._make_ssl_transportK   sM   € ð 	×$Ñ$ WÔ-Ü×+Ò+Ø˜JØØ"7Ø!5ô	
ˆô 	! °Ø',õ	=à×*Ñ*Ð*r(   c                ó@   € V P                  V4       \        WVW4V4      # r,   )r-   Ú_SelectorDatagramTransport)r&   r/   r0   Úaddressr1   r)   s   &&&&&&r   Ú_make_datagram_transportÚ.BaseSelectorEventLoop._make_datagram_transport]   s(   € à×$Ñ$ TÔ*Ü)¨$°hØ*1¸5óBð 	Br(   c                ó  <€ V P                  4       '       d   \        R 4      hV P                  4       '       d   R# V P                  4        \        SV `  4        V P                  e$   V P                  P                  4        RV n        R# R# )z!Cannot close a running event loopN)Ú
is_runningÚRuntimeErrorÚ	is_closedÚ_close_self_piper   Úcloser!   ©r&   r   s   &€r   rJ   ÚBaseSelectorEventLoop.closec   sg   ø€ Ø�?‰?×ÒÜÐBÓCÐCØ�>‰>×ÒÙØ×ÑÔÜ‰‰ŒØ�>‰>Ò%Ø�N‰N× Ñ Ô"Ø!ˆDŽNñ &r(   c                ó  € V P                  V P                  P                  4       4       V P                  P                  4        R V n        V P                  P                  4        R V n        V ;P
                  ^,          un        R # r,   )Ú_remove_readerÚ_ssockÚfilenorJ   Ú_csockÚ_internal_fds©r&   s   &r   rI   Ú&BaseSelectorEventLoop._close_self_pipen   s\   € Ø×Ñ˜DŸK™K×.Ñ.Ó0Ô1Ø�‰×ÑÔØˆŒØ�‰×ÑÔØˆŒØ×Ò˜aÕ×r(   c                óP  € \         P                  ! 4       w  V n        V n        V P                  P	                  R 4       V P                  P	                  R 4       V ;P
                  ^,          un        V P                  V P                  P                  4       V P                  4       R# )FN)	ÚsocketÚ
socketpairrO   rQ   ÚsetblockingrR   Ú_add_readerrP   Ú_read_from_selfrS   s   &r   r"   Ú%BaseSelectorEventLoop._make_self_pipev   sq   € ä#)×#4Ò#4Ó#6Ñ ˆŒ�T”[Ø�‰×Ñ Ô&Ø�‰×Ñ Ô&Ø×Ò˜aÕÕØ×Ñ˜Ÿ™×+Ñ+Ó-¨t×/CÑ/CÖDr(   c                ó   € R # r,   © ©r&   Údatas   &&r   Ú_process_self_dataÚ(BaseSelectorEventLoop._process_self_data~   s   € Ùr(   c                ó´   €   V P                   P                  R4      pV'       g   R# V P                  V4       K:    \         d     KH  \         d     R# i ; i)Ti   N)rO   Úrecvr`   ÚInterruptedErrorÚBlockingIOErrorr^   s   & r   rZ   Ú%BaseSelectorEventLoop._read_from_self�   sO   € ØðØ—{‘{×'Ñ'¨Ó-�ßÙØ×'Ñ'¨Ö-øÜ#ô ÚÜ"ô Úðús   ƒ"; ¨; »AÁ	AÁAÁAc                óÌ   € V P                   pVf   R #  VP                  R4       R #   \         d2    T P                  '       d   \        P
                  ! RRR7        R #  R # i ; i)Nó    z3Fail to write a null byte into the self-pipe socketT©Úexc_info)rQ   ÚsendÚOSErrorÚ_debugr   r   )r&   Úcsocks   & r   Ú_write_to_selfÚ$BaseSelectorEventLoop._write_to_self�   s\   € ð —‘ˆØŠ=Ùð	,Ø�J‰J�uÖøÜô 	,Ø�{�{ˆ{Ü—’ð 0à&*÷,ð ,ò ð	,ús   ”' §A#ÁA#Á"A#c                ób   € V P                  VP                  4       V P                  WW4VWg4	       R # r,   )rY   rP   Ú_accept_connection)r&   Úprotocol_factoryr/   r<   r*   Úbacklogr6   r7   s   &&&&&&&&r   Ú_start_servingÚ$BaseSelectorEventLoop._start_servingŸ   s-   € ð 	×Ñ˜Ÿ™›¨×(?Ñ(?Ø)°ÀWØ.ö	Fr(   c                ó(  € \        V^,           4       Fz  p VP                  4       w  ršV P                  '       d   \        P                  ! RWJV	4       V	P                  R4       RV
/pV P                  WW³VWg4      pV P                  V4       K|  	  R#   \         d     KŽ  \        \        3 d      R# \         dÓ   pTP                  \        P                  \        P                  \        P                  \        P                   39   d€   T P#                  RRRTR\$        P&                  ! T4      /4       T P)                  TP+                  4       4       T P-                  \.        P0                  T P2                  YY4YVT4	        Rp?EKx  h Rp?ii ; i)	é   z#%r got a new connection from %r: %rFÚpeernameNÚmessagez&socket.accept() out of system resourceÚ	exceptionrV   )ÚrangeÚacceptrm   r   r   rX   Ú_accept_connection2Úcreate_taskÚConnectionAbortedErrorre   rd   rl   ÚerrnoÚEMFILEÚENFILEÚENOBUFSÚENOMEMÚcall_exception_handlerr
   ÚTransportSocketrN   rP   Ú
call_laterr   ÚACCEPT_RETRY_DELAYru   )r&   rs   r/   r<   r*   rt   r6   r7   Ú_ÚconnÚaddrr)   r}   Úexcs   &&&&&&&&      r   rr   Ú(BaseSelectorEventLoop._accept_connection§   s^  € ô �w •{Ö#ˆAð&)Ø!Ÿ[™[›]‘
�Ø—;—;�;Ü—L’LÐ!FØ!'¨tô5à× Ñ  Ô'ð: $ TÐ*�Ø×1Ñ1Ø$¨E¸vØ)óA�ð × Ñ  Ö(óO $øô *ô âÜ#Ô%5Ð6ô ó Üô à—9‘9¤§¡¬u¯|©|Ü!&§¡´·±ð!>ô >ð
 ×/Ñ/Ø!Ð#KØ# SØ ¤&×"8Ò"8¸Ó">ð1ô ð
 ×'Ñ'¨¯©«Ô6Ø—O‘O¤I×$@Ñ$@Ø$(×$7Ñ$7Ø$4¸JØ$+Ø$8÷	:ó :ð ûð'ús7   —ABÂFÂ!FÂ0FÂ5FÂ>FÂ?CFÆFÆFc              ƒ  óÞ  "  € R pR p	 V! 4       pV P                  4       p
V'       d   V P                  W(WJRW5VVR7	      p	MV P                  W(W£VR7      p	 V
G R j  x€L
  R #  L  \         d    T	P	                  4        R p
h i ; i  \
        \        3 d    h \         dK   pT P                  '       d.   RRRT/pTe   YŒR&   T	e   YœR&   T P                  T4        R p?R #  R p?R # R p?ii ; i5i)	NT)r1   r4   r)   r*   r6   r7   )r1   r)   r*   rz   z3Error on transport creation for incoming connectionr{   r0   Ú	transport)	Úcreate_futurer>   r2   ÚBaseExceptionrJ   Ú
SystemExitÚKeyboardInterruptrm   r†   )r&   rs   r‹   r)   r<   r*   r6   r7   r0   r�   r1   r�   Úcontexts   &&&&&&&&     r   r~   Ú)BaseSelectorEventLoop._accept_connection2Ù   s  é € ð
 ˆØˆ	ð&	5Ù'Ó)ˆHØ×'Ñ'Ó)ˆFßØ ×4Ñ4Ø JØ $¨EØ*?Ø)=ð	 5ó ?‘	ð !×7Ñ7Ø¨6Ø!ð 8ó #�	ðØ—”øÜ ô Ø—‘Ô!ð �Øðûô Ô-Ð.ô 	ØÜô 	5Ø�{�{ˆ{àØMØ ð�ð
 Ò'Ø*2˜JÑ'ØÒ(Ø+4˜KÑ(Ø×+Ñ+¨G×4Ò4õ ûð	5üsY   ‚C-ˆAB ÁA" ÁA ÁA" ÁC-Á A" Á"BÂB ÂC*ÂC*Â 9C%ÃC-Ã%C*Ã*C-c                óZ  € Tp\        V\        4      '       g    \        VP                  4       4      pV P                  P                  V4      pV'       d,   VP                  4       '       g   \        RV: RV: 24      hR# R#   \        \        \
        3 d    \        R T: 24      Rhi ; i)zInvalid file object: NzFile descriptor z is used by transport )
Ú
isinstanceÚintrP   ÚAttributeErrorÚ	TypeErrorÚ
ValueErrorr%   ÚgetÚ
is_closingrG   )r&   r   rP   r�   s   &&  r   r-   Ú-BaseSelectorEventLoop._ensure_fd_no_transport  sª   € ØˆÜ˜&¤#×&Ò&ðKÜ˜VŸ]™]›_Ó-�ð ×$Ñ$×(Ñ(¨Ó0ˆ	ß˜Y×1Ñ1×3Ò3ÜØ" 2¡&Ð(>Ø‘-ð!ó"ð "ñ 4‰9øô	 #¤I¬zÐ:ô Kä Ð#8¸¹Ð!?Ó@ÀdÐJðKús   šB Â'B*c                óÐ  € V P                  4        \        P                  ! W#V R 4      pV P                  P	                  4       P                  V4      pVf0   V P                  P                  V\        P                  VR 34       V# VP                  VP                  upw  rxV P                  P                  W\        P                  ,          WH34       Ve   VP                  4        V# r,   )Ú_check_closedr   ÚHandler!   Úget_mapr�   Úregisterr   Ú
EVENT_READr_   ÚmodifyÚcancel©	r&   r   ÚcallbackÚargsÚhandler   ÚmaskÚreaderÚwriters	   &&&*     r   rY   Ú!BaseSelectorEventLoop._add_reader  s¾   € Ø×ÑÔÜ—’˜x¨t°TÓ:ˆØ�n‰n×$Ñ$Ó&×*Ñ*¨2Ó.ˆØŠ;Ø�N‰N×#Ñ# B¬	×(<Ñ(<Ø%+¨T Nô4ð ˆð &)§Z¡Z°·±Ð"ˆDÑ"�6Ø�N‰N×!Ñ! "¬Y×-AÑ-AÕ&AØ#)Ð"2ô4àÒ!Ø—‘”Øˆr(   c                óª  € V P                  4       '       d   R # V P                  P                  4       P                  V4      pVf   R # VP                  VP
                  upw  rEV\        P                  ( ,          pV'       g   V P                  P                  V4       MV P                  P                  WRV34       Ve   VP                  4        R# R # )FNT)rH   r!   r£   r�   r   r_   r   r¥   Ú
unregisterr¦   r§   ©r&   r   r   r¬   r­   r®   s   &&    r   rN   Ú$BaseSelectorEventLoop._remove_reader%  s£   € Ø�>‰>×ÒÙØ�n‰n×$Ñ$Ó&×*Ñ*¨2Ó.ˆØŠ;ÙØ!$§¡¨S¯X©XÐˆÑˆvØ”×%Ñ%Ð%Õ%ˆßØ�N‰N×%Ñ% bÕ)à�N‰N×!Ñ! "¨T°6¨NÔ;àÒØ�M‰MŒOÙár(   c                óÐ  € V P                  4        \        P                  ! W#V R 4      pV P                  P	                  4       P                  V4      pVf0   V P                  P                  V\        P                  R V34       V# VP                  VP                  upw  rxV P                  P                  W\        P                  ,          Wt34       Ve   VP                  4        V# r,   )r¡   r   r¢   r!   r£   r�   r¤   r   ÚEVENT_WRITEr_   r¦   r§   r¨   s	   &&&*     r   Ú_add_writerÚ!BaseSelectorEventLoop._add_writer8  s¾   € Ø×ÑÔÜ—’˜x¨t°TÓ:ˆØ�n‰n×$Ñ$Ó&×*Ñ*¨2Ó.ˆØŠ;Ø�N‰N×#Ñ# B¬	×(=Ñ(=Ø%)¨6 Nô4ð ˆð &)§Z¡Z°·±Ð"ˆDÑ"�6Ø�N‰N×!Ñ! "¬Y×-BÑ-BÕ&BØ#)Ð"2ô4àÒ!Ø—‘”Øˆr(   c                óª  € V P                  4       '       d   R# V P                  P                  4       P                  V4      pVf   R# VP                  VP
                  upw  rEV\        P                  ( ,          pV'       g   V P                  P                  V4       MV P                  P                  WVR34       Ve   VP                  4        R# R# )úRemove a writer callback.FNT)rH   r!   r£   r�   r   r_   r   rµ   r±   r¦   r§   r²   s   &&    r   Ú_remove_writerÚ$BaseSelectorEventLoop._remove_writerG  s£   € à�>‰>×ÒÙØ�n‰n×$Ñ$Ó&×*Ñ*¨2Ó.ˆØŠ;ÙØ!$§¡¨S¯X©XÐˆÑˆvà”×&Ñ&Ð&Õ&ˆßØ�N‰N×%Ñ% bÕ)à�N‰N×!Ñ! "¨V°T¨NÔ;àÒØ�M‰MŒOÙár(   c                óP   € V P                  V4       V P                  ! W.VO5!   R# )zAdd a reader callback.N)r-   rY   ©r&   r   r©   rª   s   &&&*r   Ú
add_readerÚ BaseSelectorEventLoop.add_reader\  ó#   € à×$Ñ$ RÔ(Ø×Ò˜Ð-¨Ö-r(   c                óF   € V P                  V4       V P                  V4      # )zRemove a reader callback.)r-   rN   ©r&   r   s   &&r   Úremove_readerÚ#BaseSelectorEventLoop.remove_readera  ó!   € à×$Ñ$ RÔ(Ø×"Ñ" 2Ó&Ð&r(   c                óP   € V P                  V4       V P                  ! W.VO5!   R# )zAdd a writer callback..N)r-   r¶   r½   s   &&&*r   Ú
add_writerÚ BaseSelectorEventLoop.add_writerf  rÀ   r(   c                óF   € V P                  V4       V P                  V4      # )r¹   )r-   rº   rÂ   s   &&r   Úremove_writerÚ#BaseSelectorEventLoop.remove_writerk  rÅ   r(   c              ƒ  ó   "  € \         P                  ! V4       V P                  '       d!   VP                  4       ^ 8w  d   \	        R4      h VP                  V4      #   \        \        3 d     Mi ; iT P                  4       pTP                  4       pT P                  T4       T P                  Y@P                  Y1T4      pTP                  \        P                  ! T P                   YER7      4       TG Rj  x€L 
 # 5i)z¬Receive data from the socket.

The return value is a bytes object representing the data received.
The maximum amount of data to be received at once is specified by
nbytes.
úthe socket must be non-blocking©r«   N)r   Ú_check_ssl_socketrm   Ú
gettimeoutrœ   rc   re   rd   r‘   rP   r-   rY   Ú
_sock_recvÚadd_done_callbackÚ	functoolsÚpartialÚ_sock_read_done)r&   r/   ÚnÚfutr   r«   s   &&&   r   Ú	sock_recvÚBaseSelectorEventLoop.sock_recvp  sÑ   é € ô 	×%Ò% dÔ+Ø�;�;ˆ;˜4Ÿ?™?Ó,°Ô1ÜÐ>Ó?Ð?ð	Ø—9‘9˜Q“<ÐøÜÔ!1Ð2ô 	Ùð	úà× Ñ Ó"ˆØ�[‰[‹]ˆØ×$Ñ$ RÔ(Ø×!Ñ! "§o¡o°sÀ!ÓDˆØ×ÑÜ×Ò˜d×2Ñ2°BÔFô	Hà�yˆyÐùó7   ‚A	C>ÁA ÁC>ÁA1Á.C>Á0A1Á1BC>Ã8C;Ã9C>c                ó`   € Ve   VP                  4       '       g   V P                  V4       R # R # r,   )Ú	cancelledrÃ   ©r&   r   r×   r«   s   &&&&r   rÕ   Ú%BaseSelectorEventLoop._sock_read_done†  ó(   € ØŠ> ×!1Ñ!1×!3Ò!3Ø×Ñ˜rÖ"ñ "4r(   c                ó  € VP                  4       '       d   R #  VP                  V4      pVP                  V4       R #   \        \        3 d     R # \
        \        3 d    h \         d   pTP                  T4        R p?R # R p?ii ; ir,   )	Údonerc   Ú
set_resultre   rd   r“   r”   r’   Úset_exception)r&   r×   r/   rÖ   r_   r�   s   &&&&  r   rÑ   Ú BaseSelectorEventLoop._sock_recvŠ  sw   € ð �8‰8�:Š:Ùð		!Ø—9‘9˜Q“<ˆDð �N‰N˜4Ö øô  Ô!1Ð2ô 	ÚÜÔ-Ð.ô 	ØÜô 	#Ø×Ñ˜c×"Ò"ûð	#úó'   š> ¾B	ÁB	Á!
B	Á,B	Á-BÂB	c              ƒ  ó   "  € \         P                  ! V4       V P                  '       d!   VP                  4       ^ 8w  d   \	        R4      h VP                  V4      #   \        \        3 d     Mi ; iT P                  4       pTP                  4       pT P                  T4       T P                  Y@P                  Y1T4      pTP                  \        P                  ! T P                   YER7      4       TG Rj  x€L 
 # 5i)z�Receive data from the socket.

The received data is written into *buf* (a writable buffer).
The return value is the number of bytes written.
rÍ   rÎ   N)r   rÏ   rm   rÐ   rœ   Ú	recv_intore   rd   r‘   rP   r-   rY   Ú_sock_recv_intorÒ   rÓ   rÔ   rÕ   )r&   r/   Úbufr×   r   r«   s   &&&   r   Úsock_recv_intoÚ$BaseSelectorEventLoop.sock_recv_intoš  sÔ   é € ô 	×%Ò% dÔ+Ø�;�;ˆ;˜4Ÿ?™?Ó,°Ô1ÜÐ>Ó?Ð?ð	Ø—>‘> #Ó&Ð&øÜÔ!1Ð2ô 	Ùð	úà× Ñ Ó"ˆØ�[‰[‹]ˆØ×$Ñ$ RÔ(Ø×!Ñ! "×&:Ñ&:¸CÀsÓKˆØ×ÑÜ×Ò˜d×2Ñ2°BÔFô	Hà�yˆyÐùrÚ   c                ó  € VP                  4       '       d   R #  VP                  V4      pVP                  V4       R #   \        \        3 d     R # \
        \        3 d    h \         d   pTP                  T4        R p?R # R p?ii ; ir,   )	rá   rç   râ   re   rd   r“   r”   r’   rã   )r&   r×   r/   ré   Únbytesr�   s   &&&&  r   rè   Ú%BaseSelectorEventLoop._sock_recv_into¯  sx   € ð �8‰8�:Š:Ùð		#Ø—^‘^ CÓ(ˆFð �N‰N˜6Ö"øô  Ô!1Ð2ô 	ÚÜÔ-Ð.ô 	ØÜô 	#Ø×Ñ˜c×"Ò"ûð	#úrå   c              ƒ  ó   "  € \         P                  ! V4       V P                  '       d!   VP                  4       ^ 8w  d   \	        R4      h VP                  V4      #   \        \        3 d     Mi ; iT P                  4       pTP                  4       pT P                  T4       T P                  Y@P                  Y1T4      pTP                  \        P                  ! T P                   YER7      4       TG Rj  x€L 
 # 5i)zçReceive a datagram from a datagram socket.

The return value is a tuple of (bytes, address) representing the
datagram received and the address it came from.
The maximum amount of data to be received at once is specified by
nbytes.
rÍ   rÎ   N)r   rÏ   rm   rÐ   rœ   Úrecvfromre   rd   r‘   rP   r-   rY   Ú_sock_recvfromrÒ   rÓ   rÔ   rÕ   )r&   r/   Úbufsizer×   r   r«   s   &&&   r   Úsock_recvfromÚ#BaseSelectorEventLoop.sock_recvfromÀ  sÔ   é € ô 	×%Ò% dÔ+Ø�;�;ˆ;˜4Ÿ?™?Ó,°Ô1ÜÐ>Ó?Ð?ð	Ø—=‘= Ó)Ð)øÜÔ!1Ð2ô 	Ùð	úà× Ñ Ó"ˆØ�[‰[‹]ˆØ×$Ñ$ RÔ(Ø×!Ñ! "×&9Ñ&9¸3ÀgÓNˆØ×ÑÜ×Ò˜d×2Ñ2°BÔFô	Hà�yˆyÐùrÚ   c                ó  € VP                  4       '       d   R #  VP                  V4      pVP                  V4       R #   \        \        3 d     R # \
        \        3 d    h \         d   pTP                  T4        R p?R # R p?ii ; ir,   )	rá   rð   râ   re   rd   r“   r”   r’   rã   )r&   r×   r/   rò   Úresultr�   s   &&&&  r   rñ   Ú$BaseSelectorEventLoop._sock_recvfrom×  sx   € ð �8‰8�:Š:Ùð		#Ø—]‘] 7Ó+ˆFð �N‰N˜6Ö"øô  Ô!1Ð2ô 	ÚÜÔ-Ð.ô 	ØÜô 	#Ø×Ñ˜c×"Ò"ûð	#úrå   c              ƒ  ó(  "  € \         P                  ! V4       V P                  '       d!   VP                  4       ^ 8w  d   \	        R4      hV'       g   \        V4      p VP                  W#4      #   \        \        3 d     Mi ; iT P                  4       pTP                  4       pT P                  T4       T P                  YPP                  YATT4      pTP                  \        P                   ! T P"                  YVR7      4       TG Rj  x€L 
 # 5i)zŸReceive data from the socket.

The received data is written into *buf* (a writable buffer).
The return value is a tuple of (number of bytes written, address).
rÍ   rÎ   N)r   rÏ   rm   rÐ   rœ   ÚlenÚrecvfrom_intore   rd   r‘   rP   r-   rY   Ú_sock_recvfrom_intorÒ   rÓ   rÔ   rÕ   )r&   r/   ré   rí   r×   r   r«   s   &&&&   r   Úsock_recvfrom_intoÚ(BaseSelectorEventLoop.sock_recvfrom_intoè  sç   é € ô 	×%Ò% dÔ+Ø�;�;ˆ;˜4Ÿ?™?Ó,°Ô1ÜÐ>Ó?Ð?ßÜ˜“XˆFð	Ø×%Ñ% cÓ2Ð2øÜÔ!1Ð2ô 	Ùð	úà× Ñ Ó"ˆØ�[‰[‹]ˆØ×$Ñ$ RÔ(Ø×!Ñ! "×&>Ñ&>ÀÈ3Ø"(ó*ˆà×ÑÜ×Ò˜d×2Ñ2°BÔFô	Hà�yˆyÐùs=   ‚ADÁDÁA0 Á/DÁ0BÂDÂBÂBDÄDÄDc                ó  € VP                  4       '       d   R #  VP                  W44      pVP                  V4       R #   \        \        3 d     R # \
        \        3 d    h \         d   pTP                  T4        R p?R # R p?ii ; ir,   )	rá   rú   râ   re   rd   r“   r”   r’   rã   )r&   r×   r/   ré   rò   rö   r�   s   &&&&&  r   rû   Ú)BaseSelectorEventLoop._sock_recvfrom_into  sz   € ð �8‰8�:Š:Ùð		#Ø×'Ñ'¨Ó5ˆFð �N‰N˜6Ö"øô  Ô!1Ð2ô 	ÚÜÔ-Ð.ô 	ØÜô 	#Ø×Ñ˜c×"Ò"ûð	#úrå   c           	   ƒ  ó@  "  € \         P                  ! V4       V P                  '       d!   VP                  4       ^ 8w  d   \	        R4      h VP                  V4      pV\        V4      8X  d   R# V P                  4       pVP                  4       pV P                  V4       V P                  WPP                  WA\        V4      V.4      pVP                  \         P"                  ! V P$                  WVR7      4       VG Rj  x€L
 #   \        \        3 d    ^ p L»i ; i L5i)am  Send data to the socket.

The socket must be connected to a remote socket.  This method
continues to send data from data until either all data has been
sent or an error occurs.  None is returned on success.  On error,
an exception is raised, and there is no way to determine how much
data, if any, was successfully processed by the receiving end of
the connection.
rÍ   NrÎ   )r   rÏ   rm   rÐ   rœ   rk   re   rd   rù   r‘   rP   r-   r¶   Ú_sock_sendallÚ
memoryviewrÒ   rÓ   rÔ   Ú_sock_write_done)r&   r/   r_   rÖ   r×   r   r«   s   &&&    r   Úsock_sendallÚ"BaseSelectorEventLoop.sock_sendall  sõ   é € ô 	×%Ò% dÔ+Ø�;�;ˆ;˜4Ÿ?™?Ó,°Ô1ÜÐ>Ó?Ð?ð	Ø—	‘	˜$“ˆAð ”�D“	Œ>áà× Ñ Ó"ˆØ�[‰[‹]ˆØ×$Ñ$ RÔ(à×!Ñ! "×&8Ñ&8¸#Ü",¨TÓ"2°Q°Có9ˆà×ÑÜ×Ò˜d×3Ñ3°RÔGô	Ià�yÐøô  Ô!1Ð2ô 	ØŠAð	úñ ùs7   ‚A	DÁD ÁB!DÃ>DÃ?DÄDÄDÄDÄDc                ój  € VP                  4       '       d   R # V^ ,          p VP                  W5R  4      pYV,          pT\        T4      8X  d   TP                  R 4       R # YT^ &   R #   \        \        3 d     R # \        \
        3 d    h \         d   pTP                  T4        R p?R # R p?ii ; ir,   )
rá   rk   re   rd   r“   r”   r’   rã   rù   râ   )r&   r×   r/   ÚviewÚposÚstartrÖ   r�   s   &&&&&   r   r  Ú#BaseSelectorEventLoop._sock_sendall2  s�   € Ø�8‰8�:Š:áØ�A•ˆð	Ø—	‘	˜$˜v˜,Ó'ˆAð 	�
ˆà”C˜“IÔØ�N‰N˜4Ö à�‹Føô  Ô!1Ð2ô 	ÚÜÔ-Ð.ô 	ØÜô 	Ø×Ñ˜cÔ"Ýûð	ús)   £A' Á'B2Á;B2Â

B2ÂB2ÂB-Â-B2c              ƒ  ó  "  € \         P                  ! V4       V P                  '       d!   VP                  4       ^ 8w  d   \	        R4      h VP                  W#4      #   \        \        3 d     Mi ; iT P                  4       pTP                  4       pT P                  T4       T P                  YPP                  YATT4      pTP                  \        P                  ! T P                   YVR7      4       TG Rj  x€L 
 # 5i)z©Send a datagram from sock to address.

The socket does not have to be connected. This method sends the
whole datagram in a single call. Return the number of bytes sent.
rÍ   rÎ   N)r   rÏ   rm   rÐ   rœ   Úsendtore   rd   r‘   rP   r-   r¶   Ú_sock_sendtorÒ   rÓ   rÔ   r  )r&   r/   r_   rB   r×   r   r«   s   &&&&   r   Úsock_sendtoÚ!BaseSelectorEventLoop.sock_sendtoH  sÛ   é € ô 	×%Ò% dÔ+Ø�;�;ˆ;˜4Ÿ?™?Ó,°Ô1ÜÐ>Ó?Ð?ð	Ø—;‘;˜tÓ-Ð-øÜÔ!1Ð2ô 	Ùð	úð × Ñ Ó"ˆØ�[‰[‹]ˆØ×$Ñ$ RÔ(à×!Ñ! "×&7Ñ&7¸ÀDØ")ó+ˆà×ÑÜ×Ò˜d×3Ñ3°RÔGô	Ià�yˆyÐùs7   ‚A	C?ÁA ÁC?ÁA1Á.C?Á0A1Á1BC?Ã9C<Ã:C?c                ó  € VP                  4       '       d   R #  VP                  V^ V4      pVP                  V4       R #   \        \        3 d     R # \
        \        3 d    h \         d   pTP                  T4        R p?R # R p?ii ; ir,   )	rá   r  râ   re   rd   r“   r”   r’   rã   )r&   r×   r/   r_   rB   rÖ   r�   s   &&&&&  r   r  Ú"BaseSelectorEventLoop._sock_sendto`  sz   € Ø�8‰8�:Š:áð		Ø—‘˜D ! WÓ-ˆAð �N‰N˜1Öøô  Ô!1Ð2ô 	ÚÜÔ-Ð.ô 	ØÜô 	#Ø×Ñ˜c×"Ò"ûð	#ús)   šA  Á BÁBÁ#
BÁ.BÁ/BÂBc              ƒ  óH  "  € \         P                  ! V4       V P                  '       d!   VP                  4       ^ 8w  d   \	        R4      hVP
                  \        P                  8X  g6   \         P                  '       di   VP
                  \        P                  8X  dJ   V P                  W!P
                  VP                  VP                  V R7      G Rj  x€L
 pV^ ,          w     rBV P                  4       pV P                  WQV4        VG Rj  x€L
 Rp#  LA L  Rpi ; i5i)zDConnect to a remote socket at address.

This method is a coroutine.
rÍ   )ÚfamilyÚtypeÚprotoÚloopN)r   rÏ   rm   rÐ   rœ   r  rV   ÚAF_INETÚ	_HAS_IPv6ÚAF_INET6Ú_ensure_resolvedr  r  r‘   Ú_sock_connect)r&   r/   rB   ÚresolvedrŠ   r×   s   &&&   r   Úsock_connectÚ"BaseSelectorEventLoop.sock_connecto  sè   é € ô
 	×%Ò% dÔ+Ø�;�;ˆ;˜4Ÿ?™?Ó,°Ô1ÜÐ>Ó?Ð?à�;‰;œ&Ÿ.™.Ô(Ü×%×%Ð%¨$¯+©+¼¿¹Ô*HØ!×2Ñ2Ø§¡°$·)±)À4Ç:Á:Øð 3ó ÷ ˆHð #+¨1¥+ÑˆAˆq�!�Qà× Ñ Ó"ˆØ×Ñ˜3 gÔ.ð	Ø—9ð ‰Cññ øð ‰CüsC   ‚A=D"Â AD"ÃDÃ4D"ÄD ÄDÄD ÄD"ÄD ÄDÄD"c           	     óÔ  € VP                  4       p VP                  V4       VP                  R 4       R pR #   \        \        3 dc    T P                  T4       T P                  Y@P                  YT4      pTP                  \        P                  ! T P                  YER7      4        Lv\        \        3 d    h \         d   pTP                  T4        R p?L§R p?ii ; i  R pi ; i)NrÎ   )rP   Úconnectrâ   re   rd   r-   r¶   Ú_sock_connect_cbrÒ   rÓ   rÔ   r  r“   r”   r’   rã   )r&   r×   r/   rB   r   r«   r�   s   &&&&   r   r  Ú#BaseSelectorEventLoop._sock_connectˆ  sÎ   € Ø�[‰[‹]ˆð	Ø�L‰L˜Ô!ð  �N‰N˜4Ô àŠCøô#  Ô!1Ð2ô 		Mð
 ×(Ñ(¨Ô,Ø×%Ñ%Ø×)Ñ)¨3°gó?ˆFà×!Ñ!Ü×!Ò! $×"7Ñ"7¸ÔKöMäÔ-Ð.ô 	ØÜô 	#Ø×Ñ˜c×"Ñ"ûð	#ûð
 ‰CúsE   ’8 £C# ¸A0C Â(C# Â*C Â9
C ÃC ÃCÃC# ÃC Ã C# Ã#C'c                ó`   € Ve   VP                  4       '       g   V P                  V4       R # R # r,   )rÜ   rÊ   rÝ   s   &&&&r   r  Ú&BaseSelectorEventLoop._sock_write_doneŸ  rß   r(   c                óŽ  € VP                  4       '       d   R #  VP                  \        P                  \        P                  4      pV^ 8w  d   \        VRV 24      h VP                  R 4       R pR #   \        \        3 d     L\        \        3 d    h \         d   pTP                  T4        R p?LHR p?ii ; i  R pi ; i)NzConnect call failed )rá   Ú
getsockoptrV   Ú
SOL_SOCKETÚSO_ERRORrl   râ   re   rd   r“   r”   r’   rã   )r&   r×   r/   rB   Úerrr�   s   &&&&  r   r!  Ú&BaseSelectorEventLoop._sock_connect_cb£  s°   € Ø�8‰8�:Š:Ùð	Ø—/‘/¤&×"3Ñ"3´V·_±_ÓEˆCØ�aŒxä˜cÐ%9¸'¸Ð#CÓDÐDð ð �N‰N˜4Ô àŠCøô  Ô!1Ð2ô 	áÜÔ-Ð.ô 	ØÜô 	#Ø×Ñ˜c×"Ñ"ûð	#ûð
 ‰CúsH   šAA4 ÁC  Á4B=ÂC  ÂB=Â
B=Â!B=Â"B8Â3C  Â8B=Â=C  Ã Cc              ƒ  óô   "  € \         P                  ! V4       V P                  '       d!   VP                  4       ^ 8w  d   \	        R4      hV P                  4       pV P                  W!4       VG Rj  x€L
 #  L5i)a0  Accept a connection.

The socket must be bound to an address and listening for
connections.  The return value is a pair (conn, address) where
conn is a new socket object usable to send and receive data on the
connection, and address is the address bound to the socket on the
other end of the connection.
rÍ   N)r   rÏ   rm   rÐ   rœ   r‘   Ú_sock_accept)r&   r/   r×   s   && r   Úsock_acceptÚ!BaseSelectorEventLoop.sock_accept¸  s^   é € ô 	×%Ò% dÔ+Ø�;�;ˆ;˜4Ÿ?™?Ó,°Ô1ÜÐ>Ó?Ð?Ø× Ñ Ó"ˆØ×Ñ˜#Ô$Ø�yÐ‰yùs   ‚A/A8Á1A6Á2A8c           	     ó  € VP                  4       '       d   R # VP                  4       p VP                  4       w  rEVP                  R4       VP	                  WE34       R #   \
        \        3 dc    T P                  T4       T P                  Y0P                  Y4      pTP                  \        P                  ! T P                  Y6R7      4        R # \        \        3 d    h \          d   pTP#                  T4        R p?R # R p?ii ; i)NFrÎ   )rá   rP   r}   rX   râ   re   rd   r-   rY   r,  rÒ   rÓ   rÔ   rÕ   r“   r”   r’   rã   )r&   r×   r/   r   r‹   rB   r«   r�   s   &&&     r   r,  Ú"BaseSelectorEventLoop._sock_acceptÈ  sÙ   € à�8‰8�:Š:ÙØ�[‰[‹]ˆð	,Ø ŸK™K›M‰MˆDØ×Ñ˜UÔ#ð �N‰N˜D˜?Ö+øô  Ô!1Ð2ô 	LØ×(Ñ(¨Ô,Ø×%Ñ% b×*;Ñ*;¸SÓGˆFØ×!Ñ!Ü×!Ò! $×"6Ñ"6¸ÔJ÷LäÔ-Ð.ô 	ØÜô 	#Ø×Ñ˜c×"Ò"ûð	#ús*   ª#A! Á!A/D
ÃD
Ã"
D
Ã-D
Ã.DÄD
c              ƒ  ó
  "  € V P                   VP                   VP                  4       pVP                  4        VP	                  4       G R j  x€L
   V P                  VP                  W#VRR7      G R j  x€L
 VP                  4        V'       d   VP                  4        WP                   VP                  &   #  Ll LF  TP                  4        T'       d   TP                  4        YP                   TP                  &   i ; i5i)NF)Úfallback)	r%   Ú_sock_fdÚ
is_readingÚpause_readingÚ_make_empty_waiterÚsock_sendfileÚ_sockÚ_reset_empty_waiterÚresume_reading)r&   ÚtranspÚfileÚoffsetÚcountr:  s   &&&&& r   Ú_sendfile_nativeÚ&BaseSelectorEventLoop._sendfile_nativeÜ  sÖ   é € Ø×Ñ˜VŸ_™_Ð-Ø×*Ñ*Ó,ˆØ×ÑÔØ×'Ñ'Ó)×)Ð)ð	7Ø×+Ñ+¨F¯L©L¸$ÈØ5:ð ,ó <÷ <ð ×&Ñ&Ô(ßØ×%Ñ%Ô'Ø06×Ñ˜VŸ_™_Ò-ñ 	*ñ<øð ×&Ñ&Ô(ßØ×%Ñ%Ô'Ø06×Ñ˜VŸ_™_Ò-üs>   ‚ADÁB:ÁDÁ"B> Á5B<Á6B> Á9ADÂ<B> Â>AD Ä Dc                ó´  € V FÑ  w  r#VP                   VP                  upw  rVV\        P                  ,          '       d:   Ve6   VP                  '       d   V P                  V4       MV P                  V4       V\        P                  ,          '       g   K•  Vf   K›  VP                  '       d   V P                  V4       KÀ  V P                  V4       KÓ  	  R # r,   )	Úfileobjr_   r   r¥   Ú
_cancelledrN   Ú_add_callbackrµ   rº   )r&   Ú
event_listr   r¬   rB  r­   r®   s   &&     r   Ú_process_eventsÚ%BaseSelectorEventLoop._process_eventsê  s¡   € Û#‰IˆCØ(+¯©°S·X±XÐ%ˆGÑ%�fØ”i×*Ñ*×*Ô*¨vÒ/AØ×$×$Ð$Ø×'Ñ'¨Õ0à×&Ñ& vÔ.Ø”i×+Ñ+×+Ö+°Ô0BØ×$×$Ð$Ø×'Ñ'¨Ö0à×&Ñ& vÖ.ó $r(   c                ód   € V P                  VP                  4       4       VP                  4        R # r,   )rN   rP   rJ   )r&   r/   s   &&r   Ú_stop_servingÚ#BaseSelectorEventLoop._stop_servingø  s   € Ø×Ñ˜DŸK™K›MÔ*Ø�
‰
Žr(   )rQ   r!   rO   r%   r,   ©NNN)é    )7r    Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r   r2   r   ÚSSL_HANDSHAKE_TIMEOUTÚSSL_SHUTDOWN_TIMEOUTr>   rC   rJ   rI   r"   r`   rZ   ro   ru   rr   r~   r-   rY   rN   r¶   rº   r¾   rÃ   rÇ   rÊ   rØ   rÕ   rÑ   rê   rè   ró   rñ   rü   rû   r  r  r  r  r  r  r  r!  r-  r,  r?  rF  rI  Ú__static_attributes__Ú__classdictcell__Ú__classcell__©r   Ú__classdict__s   @@r   r   r   5   s”  ù‡ € ñ÷
9ñ7Ø%)ð7Ø26õ7ñ+à ð+à26ð+ð ð+ð  $ð+ð #,×"AÑ"Að	+ð
 "+×!?Ñ!?õ+ô$Bõ	"ò òEòò
ò,ð& #'¨t¸SØ-6×-LÑ-LØ,5×,JÑ,JôFð  D°#Ø"+×"AÑ"AØ!*×!?Ñ!?ô	0)ðh  DØ"+×"AÑ"AØ!*×!?Ñ!?ô	-5ò^"òòò&òò*.ò
'ò
.ò
'ò
ô,#ò!ò ò*#ò"ò.#ô"ò2#ò"ò@ò,ò0òò2ô.#òò*ò ,ò(7ò/÷ò r(   c                   ó¶   a a€ ] tR tRt oRtRtRV 3R lltR tR tR t	R t
R tR	 tR
 tR tR t]P"                  3R ltRR ltR tR tR tR tRtVtV ;t# )Ú_SelectorTransportiý  Nc                óì  <€ \         SV `  WA4       \        P                  ! V4      V P                  R &    VP                  4       V P                  R&   RV P                  9  d    VP                  4       V P                  R&   W n
        VP                  4       V n        RV n        V P                  V4       WPn        \         P"                  ! 4       V n        ^ V n        RV n        RV n        V P                  e   V P                  P-                  V 4       WP.                  V P                  &   R#   \         d    RT P                  R&    Löi ; i  \        P                   d    RT P                  R&    Lñi ; i)rV   ÚsocknameNry   F)r   r   r
   r‡   Ú_extraÚgetsocknamerl   ÚgetpeernamerV   Úerrorr8  rP   r3  Ú_protocol_connectedÚset_protocolÚ_serverÚcollectionsÚdequeÚ_bufferÚ
_conn_lostÚ_closingÚ_pausedÚ_attachr%   )r&   r  r/   r0   r)   r*   r   s   &&&&&&€r   r   Ú_SelectorTransport.__init__  s2  ø€ Ü‰Ñ˜Ô%Ü &× 6Ò 6°tÓ <ˆ�‰�HÑð	+Ø&*×&6Ñ&6Ó&8ˆD�K‰K˜
Ñ#ð ˜TŸ[™[Ô(ð/Ø*.×*:Ñ*:Ó*<�—‘˜JÑ'ð Œ
ØŸ™›ˆŒà#(ˆÔ Ø×Ñ˜(Ô#àŒÜ"×(Ò(Ó*ˆŒØˆŒØˆŒØˆŒà�<‰<Ò#Ø�L‰L× Ñ  Ô&Ø*.×Ñ˜Ÿ™Ó'øô+ ô 	+Ø&*ˆD�K‰K˜
Ó#ð	+ûô
 —<‘<ô /Ø*.�—‘˜JÓ'ð/ús#   µD, Á$E Ä,E	ÅE	Å$E3Å2E3c                ó2  € V P                   P                  .pV P                  f   VP                  R4       M#V P                  '       d   VP                  R4       VP                  RV P
                   24       V P                  eó   V P                  P                  4       '       gÓ   \        V P                  P                  V P
                  \        P                  4      pV'       d   VP                  R4       MVP                  R4       \        V P                  P                  V P
                  \        P                  4      pV'       d   RpMRpV P                  4       pVP                  RV R	V R
24       RP                  RP                  V4      4      # )NÚclosedÚclosingzfd=zread=pollingz	read=idleÚpollingÚidlezwrite=<z
, bufsize=Ú>z<{}>Ú )r   r    r8  Úappendrg  r3  Ú_looprH   r   r!   r   r¥   rµ   Úget_write_buffer_sizeÚformatÚjoin)r&   Úinforn  Ústaterò   s   &    r   Ú__repr__Ú_SelectorTransport.__repr__#  s)  € Ø—‘×'Ñ'Ð(ˆØ�:‰:ÒØ�K‰K˜Õ!Ø�]�]ˆ]Ø�K‰K˜	Ô"Ø�‰�c˜$Ÿ-™-˜Ð)Ô*à�:‰:Ò!¨$¯*©*×*>Ñ*>×*@Ò*@Ü*¨4¯:©:×+?Ñ+?Ø+/¯=©=¼)×:NÑ:NóPˆGçØ—‘˜NÕ+à—‘˜KÔ(ä*¨4¯:©:×+?Ñ+?Ø+/¯=©=Ü+4×+@Ñ+@óBˆG÷ Ø!‘à�à×0Ñ0Ó2ˆGØ�K‰K˜' % ¨
°7°)¸1Ð=Ô>Ø�}‰}˜SŸX™X d›^Ó,Ð,r(   c                ó(   € V P                  R 4       R # r,   )Ú_force_closerS   s   &r   ÚabortÚ_SelectorTransport.abort?  s   € Ø×Ñ˜$Ör(   c                ó    € Wn         R V n        R# )TN)Ú	_protocolr`  )r&   r0   s   &&r   ra  Ú_SelectorTransport.set_protocolB  s   € Ø!ŒØ#'ˆÖ r(   c                ó   € V P                   # r,   )r€  rS   s   &r   Úget_protocolÚ_SelectorTransport.get_protocolF  s   € Ø�~‰~Ðr(   c                ó   € V P                   # r,   )rg  rS   s   &r   rž   Ú_SelectorTransport.is_closingI  s   € Ø�}‰}Ðr(   c                ó^   € V P                  4       '       * ;'       d    V P                  '       * # r,   )rž   rh  rS   s   &r   r4  Ú_SelectorTransport.is_readingL  s!   € Ø—?‘?Ó$Ô$×9Ð9¨T¯\©\Ô)9Ð9r(   c                ó   € V P                  4       '       g   R # RV n        V P                  P                  V P                  4       V P                  P                  4       '       d   \        P                  ! RV 4       R # R # )NTz%r pauses reading)r4  rh  rs  rN   r3  Ú	get_debugr   r   rS   s   &r   r5  Ú _SelectorTransport.pause_readingO  sV   € Ø�‰× Ò ÙØˆŒØ�
‰
×!Ñ! $§-¡-Ô0Ø�:‰:×Ñ×!Ò!Ü�LŠLÐ,¨dÖ3ñ "r(   c                ó  € V P                   '       g   V P                  '       g   R # RV n        V P                  V P                  V P                  4       V P
                  P                  4       '       d   \        P                  ! RV 4       R # R # )NFz%r resumes reading)	rg  rh  rY   r3  Ú_read_readyrs  rŠ  r   r   rS   s   &r   r:  Ú!_SelectorTransport.resume_readingW  s^   € Ø�=�=ˆ= §§ ÙØˆŒØ×Ñ˜Ÿ™¨×(8Ñ(8Ô9Ø�:‰:×Ñ×!Ò!Ü�LŠLÐ-¨tÖ4ñ "r(   c                óv  € V P                   '       d   R # RV n         V P                  P                  V P                  4       V P                  '       gg   V ;P
                  ^,          un        V P                  P                  V P                  4       V P                  P                  V P                  R 4       R # R # ©NT)	rg  rs  rN   r3  re  rf  rº   Ú	call_soonÚ_call_connection_lostrS   s   &r   rJ   Ú_SelectorTransport.close_  sw   € Ø�=�=ˆ=ÙØˆŒØ�
‰
×!Ñ! $§-¡-Ô0Ø�|�|ˆ|Ø�OŠO˜qÕ �OØ�J‰J×%Ñ% d§m¡mÔ4Ø�J‰J× Ñ  ×!;Ñ!;¸TÖBñ r(   c                óÖ   € V P                   e[   V! RV : 2\        V R7       V P                   P                  4        V P                  e   V P                  P	                  V 4       R # R # R # )Nzunclosed transport )Úsource)r8  ÚResourceWarningrJ   rb  Ú_detach)r&   Ú_warns   &&r   Ú__del__Ú_SelectorTransport.__del__i  sV   € Ø�:‰:Ò!ÙÐ'¨¡xÐ0´/È$ÕOØ�J‰J×ÑÔØ�|‰|Ò'Ø—‘×$Ñ$ TÖ*ñ (ñ "r(   c           
     ó"  € \        V\        4      '       d;   V P                  P                  4       '       d   \        P
                  ! R WRR7       M-V P                  P                  RVRVRV RV P                  /4       V P                  V4       R# )z%r: %sTri   rz   r{   r�   r0   N)	r˜   rl   rs  rŠ  r   r   r†   r€  r|  )r&   r�   rz   s   &&&r   Ú_fatal_errorÚ_SelectorTransport._fatal_errorp  sr   € ä�cœ7×#Ò#Ø�z‰z×#Ñ#×%Ò%Ü—’˜X t¸tÕDøà�J‰J×-Ñ-Ø˜7Ø˜SØ˜TØ˜DŸN™Nð	/ô ð 	×Ñ˜#Ör(   c                óÊ  € V P                   '       d   R # V P                  '       d@   V P                  P                  4        V P                  P	                  V P
                  4       V P                  '       g-   RV n        V P                  P                  V P
                  4       V ;P                   ^,          un         V P                  P                  V P                  V4       R # r�  )
rf  re  Úclearrs  rº   r3  rg  rN   r‘  r’  )r&   r�   s   &&r   r|  Ú_SelectorTransport._force_close~  s‹   € Ø�?�?ˆ?ÙØ�<�<ˆ<Ø�L‰L×ÑÔ Ø�J‰J×%Ñ% d§m¡mÔ4Ø�}�}ˆ}Ø ˆDŒMØ�J‰J×%Ñ% d§m¡mÔ4Ø�Š˜1Õ�Ø�
‰
×Ñ˜T×7Ñ7¸Ö=r(   c                óÎ  €  V P                   '       d   V P                  P                  V4       V P                  P	                  4        R V n        R V n        R V n        V P                  pVe   VP                  V 4       R V n        R # R #   T P                  P	                  4        R T n        R T n        R T n        T P                  pTe   TP                  T 4       R T n        i i ; ir,   )r`  r€  Úconnection_lostr8  rJ   rs  rb  r—  )r&   r�   r*   s   && r   r’  Ú(_SelectorTransport._call_connection_lostŠ  sÁ   € ð	$Ø×'×'Ð'Ø—‘×.Ñ.¨sÔ3à�J‰J×ÑÔØˆDŒJØ!ˆDŒNØˆDŒJØ—\‘\ˆFØÒ!Ø—‘˜tÔ$Ø#�–ñ "øð �J‰J×ÑÔØˆDŒJØ!ˆDŒNØˆDŒJØ—\‘\ˆFØÒ!Ø—‘˜tÔ$Ø#�•ð "ús   ‚B
 ”B
 Â
AC$c                óH   € \        \        \        V P                  4      4      # r,   )ÚsumÚmaprù   re  rS   s   &r   rt  Ú(_SelectorTransport.get_write_buffer_size˜  s   € Ü”3”s˜DŸL™LÓ)Ó*Ð*r(   c                ór   € V P                  4       '       g   R # V P                  P                  ! W.VO5!   R # r,   )r4  rs  rY   r½   s   &&&*r   rY   Ú_SelectorTransport._add_reader›  s)   € Ø�‰× Ò ÙØ�
‰
×Ò˜rÐ3¨dÖ3r(   )
re  rg  rf  rs  rh  r€  r`  rb  r8  r3  i   )NN)zFatal error on transport)r    rM  rN  rO  Úmax_sizer8  r   ry  r}  ra  rƒ  rž   r4  r5  r:  rJ   ÚwarningsÚwarnr™  rœ  r|  r’  rt  rY   rS  rT  rU  rV  s   @@r   rY  rY  ý  sr   ù‡ € ð €Hð
 €E÷/ò8-ò8 ò(òòò:ò4ò5òCð %ŸM™Mô +ôò
>ò$ò+÷4ò 4r(   rY  c                   óê   a a€ ] tR tRt oRt]P                  P                  tRV 3R llt	V 3R lt
R tR tR tR tR	 tR
 tR tV3R lR ltR tR tR tR tV 3R ltR tR tV 3R ltRtVtV ;t# )r.   i¡  Tc                ó*  <€ R V n         \        SV `	  WW5V4       RV n        R V n        \
        '       d   V P                  V n        MV P                  V n        \        P                  ! V P                  4       V P                  P                  V P                  P                  V 4       V P                  P                  V P                   V P"                  V P$                  4       Ve.   V P                  P                  \&        P(                  VR 4       R # R # )NF)Ú_read_ready_cbr   r   Ú_eofÚ_empty_waiterÚ_HAS_SENDMSGÚ_write_sendmsgÚ_write_readyÚ_write_sendr   Ú_set_nodelayr8  rs  r‘  r€  Úconnection_maderY   r3  r�  r   Ú_set_result_unless_cancelled)r&   r  r/   r0   r1   r)   r*   r   s   &&&&&&&€r   r   Ú!_SelectorSocketTransport.__init__¦  sÓ   ø€ ð #ˆÔÜ‰Ñ˜ X°fÔ=ØˆŒ	Ø!ˆÔß‹<Ø $× 3Ñ 3ˆDÕà $× 0Ñ 0ˆDÔô 	× Ò  §¡Ô,à�
‰
×Ñ˜TŸ^™^×;Ñ;¸TÔBà�
‰
×Ñ˜T×-Ñ-Ø!Ÿ]™]¨D×,<Ñ,<ô	>àÒà�J‰J× Ñ ¤×!EÑ!EØ!'¨ö/ñ r(   c                ó¬   <€ \        V\        P                  4      '       d   V P                  V n        MV P
                  V n        \        SV `  V4       R # r,   )r˜   r   ÚBufferedProtocolÚ_read_ready__get_bufferr¯  Ú_read_ready__data_receivedr   ra  )r&   r0   r   s   &&€r   ra  Ú%_SelectorSocketTransport.set_protocol¿  s?   ø€ Ü�h¤	× :Ñ :×;Ò;Ø"&×">Ñ">ˆDÕà"&×"AÑ"AˆDÔä‰Ñ˜XÖ&r(   c                ó&   € V P                  4        R # r,   )r¯  rS   s   &r   r�  Ú$_SelectorSocketTransport._read_readyÇ  s   € Ø×ÑÖr(   c                óÒ  € V P                   '       d   R #  V P                  P                  R4      p\        V4      '       g   \	        R4      h  T P                  P                  T4      pT'       g   T P                  4        R #  T P                  P                  T4       R #   \
        \        3 d    h \         d   pT P                  TR4        R p?R # R p?ii ; i  \        \        3 d     R # \
        \        3 d    h \         d   pT P                  TR4        R p?R # R p?ii ; i  \
        \        3 d    h \         d   pT P                  TR4        R p?R # R p?ii ; i)Nz%get_buffer() returned an empty bufferz/Fatal error: protocol.get_buffer() call failed.ú$Fatal read error on socket transportz3Fatal error: protocol.buffer_updated() call failed.éÿÿÿÿ)rf  r€  Ú
get_bufferrù   rG   r“   r”   r’   rœ  r8  rç   re   rd   Ú_read_ready__on_eofÚbuffer_updated)r&   ré   r�   rí   s   &   r   r¼  Ú0_SelectorSocketTransport._read_ready__get_bufferÊ  sG  € Ø�?�?ˆ?Ùð		Ø—.‘.×+Ñ+¨BÓ/ˆCÜ�s—8’8Ü"Ð#JÓKÐKð ð	Ø—Z‘Z×)Ñ)¨#Ó.ˆF÷ Ø×$Ñ$Ô&Ùð	LØ�N‰N×)Ñ)¨&Ö1øô- Ô-Ð.ô 	ØÜô 	Ø×ÑØÐFôHåûð	ûô  Ô!1Ð2ô 	ÚÜÔ-Ð.ô 	ØÜô 	Ø×Ñ˜cÐ#IÔJÝûð	ûô Ô-Ð.ô 	ØÜô 	LØ×ÑØÐJ÷Lò Lûð	Lúse   –7B" ÁC ÂD- Â"CÂ=CÂ>CÃCÃD*Ã2D*Ä
D*ÄD*ÄD%Ä%D*Ä-E&ÅE&Å	E!Å!E&c                óü  € V P                   '       d   R #  V P                  P                  V P                  4      pT'       g   T P                  4        R #  T P                  P                  T4       R #   \        \
        3 d     R # \        \        3 d    h \         d   pT P                  TR4        R p?R # R p?ii ; i  \        \        3 d    h \         d   pT P                  TR4        R p?R # R p?ii ; i)NrÂ  z2Fatal error: protocol.data_received() call failed.)rf  r8  rc   rª  re   rd   r“   r”   r’   rœ  rÅ  r€  Údata_received)r&   r_   r�   s   &  r   r½  Ú3_SelectorSocketTransport._read_ready__data_receivedï  sÜ   € Ø�?�?ˆ?Ùð	Ø—:‘:—?‘? 4§=¡=Ó1ˆD÷ Ø×$Ñ$Ô&Ùð	KØ�N‰N×(Ñ(¨Ö.øô  Ô!1Ð2ô 	ÚÜÔ-Ð.ô 	ØÜô 	Ø×Ñ˜cÐ#IÔJÝûð	ûô Ô-Ð.ô 	ØÜô 	KØ×ÑØÐI÷Kò Kûð	KúsG   –%A3 ÁC Á3B?ÂB?Â
B?Â!B?Â"B:Â:B?ÃC;ÃC;ÃC6Ã6C;c                ó   € V P                   P                  4       '       d   \        P                  ! R V 4        V P                  P                  4       pT'       d(   T P                   P                  T P                  4       R# T P                  4        R#   \        \        3 d    h \         d   pT P                  TR4        Rp?R# Rp?ii ; i)z%r received EOFz1Fatal error: protocol.eof_received() call failed.N)rs  rŠ  r   r   r€  Úeof_receivedr“   r”   r’   rœ  rN   r3  rJ   )r&   Ú	keep_openr�   s   &  r   rÅ  Ú,_SelectorSocketTransport._read_ready__on_eof  sœ   € Ø�:‰:×Ñ×!Ò!Ü�LŠLÐ*¨DÔ1ð	ØŸ™×3Ñ3Ó5ˆI÷ ð �J‰J×%Ñ% d§m¡mÖ4à�J‰JŽLøô Ô-Ð.ô 	ØÜô 	Ø×ÑØÐHôJåûð	ús   ¹B ÂCÂ/CÂ0CÃCc                ó°  € \        V\        \        \        34      '       g#   \	        R \        V4      P                  : 24      hV P                  '       d   \        R4      hV P                  e   \        R4      hV'       g   R# V P                  '       dQ   V P                  \        P                  8¼  d   \        P                  ! R4       V ;P                  ^,          un
        R# V P                  '       gf    V P                   P#                  V4      p\        V4      VR pV'       g   R#  T P0                  P3                  T P4                  T P6                  4       V P                  P9                  V4       V P;                  4        R#   \$        \&        3 d     Lp\(        \*        3 d    h \,         d   pT P/                  TR4        Rp?R# Rp?ii ; i)zDdata argument must be a bytes, bytearray, or memoryview object, not z%Cannot call write() after write_eof()Nz(unable to write; sendfile is in progressúsocket.send() raised exception.ú%Fatal write error on socket transport)r˜   ÚbytesÚ	bytearrayr  r›   r  r    r°  rG   r±  rf  r   Ú!LOG_THRESHOLD_FOR_CONNLOST_WRITESr   Úwarningre  r8  rk   re   rd   r“   r”   r’   rœ  rs  r¶   r3  r´  rr  Ú_maybe_pause_protocol)r&   r_   rÖ   r�   s   &&  r   ÚwriteÚ_SelectorSocketTransport.write  sr  € Ü˜$¤¬	´:Ð >×?Ò?Üð +Ü+/°«:×+>Ñ+>Ñ*AðCó Dð Dà�9�9ˆ9ÜÐFÓGÐGØ×ÑÒ)ÜÐIÓJÐJßÙà�?�?ˆ?Ø�‰¤)×"MÑ"MÔMÜ—’Ð@ÔAØ�OŠO˜qÕ �OÙà�|�|ˆ|ðØ—J‘J—O‘O DÓ)�ô " $Ó'¨¨Ð+�ßÙð ð �J‰J×"Ñ" 4§=¡=°$×2CÑ2CÔDð 	�‰×Ñ˜DÔ!Ø×"Ñ"Ö$øô! $Ô%5Ð6ô ÙÜÔ 1Ð2ô ØÜ ô Ø×!Ñ! #Ð'NÔOÝûðús*   Ã9F
 Æ
GÆGÆ,
GÆ7GÆ8GÇGc                óL   € \         P                  ! V P                  \        4      # r,   )Ú	itertoolsÚislicere  r   rS   s   &r   Ú_get_sendmsg_bufferÚ,_SelectorSocketTransport._get_sendmsg_bufferD  s   € Ü×Ò §¡¬jÓ9Ð9r(   c                óN  € V P                   '       g   Q R 4       hV P                  '       d   R#  V P                  P                  V P	                  4       4      pV P                  V4       V P                  4        V P                   '       gÞ   V P                  P                  V P                  4       V P                  e   V P                  P                  R4       V P                  '       d?   V P                  '       g-   V ;P                  ^,          un        V P                  R4       R# V P                  '       d,   V P                  P                  \         P"                  4       R# R# R#   \$        \&        3 d     R# \(        \*        3 d    h \,         dŒ   pT P                  P                  T P                  4       T P                   P/                  4        T P1                  TR4       T P                  e"   T P                  P3                  T4        Rp?R#  Rp?R# Rp?ii ; i©zData should not be emptyNrÑ  )re  rf  r8  r   rÜ  Ú_adjust_leftover_bufferÚ_maybe_resume_protocolrs  rº   r3  r±  râ   rg  r’  r°  ÚshutdownrV   ÚSHUT_WRre   rd   r“   r”   r’   rŸ  rœ  rã   )r&   rí   r�   s   &  r   r³  Ú'_SelectorSocketTransport._write_sendmsgG  sˆ  € Ø�|�|ˆ|Ð7Ð7Ó7ˆ|Ø�?�?ˆ?Ùð	8Ø—Z‘Z×'Ñ'¨×(@Ñ(@Ó(BÓCˆFØ×(Ñ(¨Ô0ð ×'Ñ'Ô)Ø—<—<�<Ø—
‘
×)Ñ)¨$¯-©-Ô8Ø×%Ñ%Ò1Ø×&Ñ&×1Ñ1°$Ô7à—=—=�=¨¯¯¨Ø—O’O qÕ(•OØ×.Ñ.¨tÖ4Ø—Y—Y�YØ—J‘J×'Ñ'¬¯©Ö7ñ ñ  øô  Ô!1Ð2ô 	ÚÜÔ-Ð.ô 	ØÜô 	6Ø�J‰J×%Ñ% d§m¡mÔ4Ø�L‰L×ÑÔ Ø×Ñ˜cÐ#JÔKØ×!Ñ!Ò-Ø×"Ñ"×0Ñ0°×5Ò5õ .ûð		6ús*   ¯:E* Å*H$Å>H$Æ
H$ÆH$ÆA:HÈH$c                ó$   <€ V ^8„  d   QhRS[ RR/# )é   rí   ÚreturnN)r™   )ru  rW  s   "€r   Ú__annotate__Ú%_SelectorSocketTransport.__annotate__e  s   ø€ ÷ 	ñ 	©cð 	°dñ 	r(   c                ó®   € V P                   pV'       dA   VP                  4       p\        V4      pWA8:  d   W,          pK3  VP                  W1R  4       R # R # r,   )re  Úpopleftrù   Ú
appendleft)r&   rí   ÚbufferÚbÚb_lens   &&   r   rà  Ú0_SelectorSocketTransport._adjust_leftover_buffere  sI   € Ø—‘ˆßØ—‘Ó ˆAÜ˜“FˆEØŒØ•’à×!Ñ! ! G *Ô-Ùñ r(   c                óž  € V P                   '       g   Q R 4       hV P                  '       d   R#  V P                   P                  4       pV P                  P	                  V4      pV\        V4      8w  d   V P                   P                  WR 4       V P                  4        V P                   '       gÞ   V P                  P                  V P                  4       V P                  e   V P                  P                  R4       V P                  '       d?   V P                  '       g-   V ;P                  ^,          un        V P                  R4       R# V P                  '       d,   V P                  P!                  \"        P$                  4       R# R# R#   \&        \(        3 d     R# \*        \,        3 d    h \.         dŒ   pT P                  P                  T P                  4       T P                   P1                  4        T P3                  TR4       T P                  e"   T P                  P5                  T4        Rp?R#  Rp?R# Rp?ii ; irß  )re  rf  rë  r8  rk   rù   rì  rá  rs  rº   r3  r±  râ   rg  r’  r°  râ  rV   rã  re   rd   r“   r”   r’   rŸ  rœ  rã   )r&   rí  rÖ   r�   s   &   r   rµ  Ú$_SelectorSocketTransport._write_sendp  s£  € Ø�|�|ˆ|Ð7Ð7Ó7ˆ|Ø�?�?ˆ?Ùð	8Ø—\‘\×)Ñ)Ó+ˆFØ—
‘
—‘ Ó'ˆAØ”C˜“KÔà—‘×'Ñ'¨¨r¨
Ô3ð ×'Ñ'Ô)Ø—<—<�<Ø—
‘
×)Ñ)¨$¯-©-Ô8Ø×%Ñ%Ò1Ø×&Ñ&×1Ñ1°$Ô7à—=—=�=¨¯¯¨Ø—O’O qÕ(•OØ×.Ñ.¨tÖ4Ø—Y—Y�YØ—J‘J×'Ñ'¬¯©Ö7ñ ñ  øô  Ô!1Ð2ô 	ÚÜÔ-Ð.ô 	ØÜô 	6Ø�J‰J×%Ñ% d§m¡mÔ4Ø�L‰L×ÑÔ Ø×Ñ˜cÐ#JÔKØ×!Ñ!Ò-Ø×"Ñ"×0Ñ0°×5Ò5õ .ûð		6ús+   ¯A"F ÆIÆ&IÆ5
IÇ IÇA:IÉIc                óÚ   € V P                   '       g   V P                  '       d   R # RV n        V P                  '       g,   V P                  P	                  \
        P                  4       R # R # r�  )rg  r°  re  r8  râ  rV   rã  rS   s   &r   Ú	write_eofÚ"_SelectorSocketTransport.write_eof‘  sA   € Ø�=�=ˆ=˜DŸIŸI˜IÙØˆŒ	Ø�|�|ˆ|Ø�J‰J×Ñ¤§¡Ö/ñ r(   c                ó¾  € V P                   '       d   \        R 4      hV P                  e   \        R4      hV'       g   R# V P                  '       dQ   V P                  \        P
                  8¼  d   \        P                  ! R4       V ;P                  ^,          un        R# V P                  P                  V Uu. uF  q"'       g   K  \        V4      NK  	  up4       V P                  '       g   R# V P                  4        V P                  '       dC   V P                  P                  V P                  V P                  4       V P                  4        R# R# u upi )z*Cannot call writelines() after write_eof()Nz-unable to writelines; sendfile is in progressrÐ  )r°  rG   r±  rf  r   rÔ  r   rÕ  re  Úextendr  r´  rs  r¶   r3  rÖ  )r&   Úlist_of_datar_   s   && r   Ú
writelinesÚ#_SelectorSocketTransport.writelines˜  sõ   € Ø�9�9ˆ9ÜÐKÓLÐLØ×ÑÒ)ÜÐNÓOÐOßÙà�?�?ˆ?Ø�‰¤)×"MÑ"MÔMÜ—’Ð@ÔAØ�OŠO˜qÕ �OÙð 	�‰×ÑÙ*6Ó?©, $»$ÔŒZ˜Ö©,Ñ?ô	Aà�|�|ˆ|ÙØ×ÑÔà�<�<ˆ<Ø�J‰J×"Ñ" 4§=¡=°$×2CÑ2CÔDØ×&Ñ&Ö(ñ ùò @s   Â<	EÃ
Ec                ó   € R # )Tr]   rS   s   &r   Úcan_write_eofÚ&_SelectorSocketTransport.can_write_eof±  s   € Ùr(   c                ó8  <€  \         SV `  V4       R V n        R V n        V P                  e'   V P                  P                  \        R4      4       R # R #   R T n        R T n        T P                  e&   T P                  P                  \        R4      4       i i ; i)NzConnection is closed by peer)r   r’  r´  r¯  r±  rã   ÚConnectionError)r&   r�   r   s   &&€r   r’  Ú._SelectorSocketTransport._call_connection_lost´  s˜   ø€ ð	EÜ‰GÑ)¨#Ô.à $ˆDÔØ"&ˆDÔØ×!Ñ!Ò-Ø×"Ñ"×0Ñ0Ü#Ð$BÓCöEñ .øð !%ˆDÔØ"&ˆDÔØ×!Ñ!Ò-Ø×"Ñ"×0Ñ0Ü#Ð$BÓCõEð .ús   ƒA ÁABc                óä   € V P                   e   \        R4      hV P                  P                  4       V n         V P                  '       g   V P                   P                  R 4       V P                   # )NzEmpty waiter is already set)r±  rG   rs  r‘   re  râ   rS   s   &r   r6  Ú+_SelectorSocketTransport._make_empty_waiter¾  sX   € Ø×ÑÒ)ÜÐ<Ó=Ð=Ø!ŸZ™Z×5Ñ5Ó7ˆÔØ�|�|ˆ|Ø×Ñ×)Ñ)¨$Ô/Ø×!Ñ!Ð!r(   c                ó   € R V n         R # r,   )r±  rS   s   &r   r9  Ú,_SelectorSocketTransport._reset_empty_waiterÆ  s
   € Ø!ˆÖr(   c                ó2   <€ R V n         \        SV `	  4        R # r,   )r¯  r   rJ   rK   s   &€r   rJ   Ú_SelectorSocketTransport.closeÉ  s   ø€ Ø"ˆÔÜ‰‰Žr(   )r±  r°  r¯  r´  rK  )r    rM  rN  rO  Ú_start_tls_compatibler   Ú_SendfileModeÚ
TRY_NATIVEÚ_sendfile_compatibler   ra  r�  r¼  r½  rÅ  r×  rÜ  r³  rà  rµ  rô  rù  rü  r’  r6  r9  rJ   rS  rT  rU  rV  s   @@r   r.   r.   ¡  s‡   ù‡ € à ÐØ$×2Ñ2×=Ñ=Ð÷/õ2'òò#LòJKò2ò*%%òN:ò8÷<	ð 	ò8òB0ò)ò2õEò"ò"÷õ r(   r.   c                   ón   a a€ ] tR tRt o]P
                  t^tRV 3R lltR t	R t
R	R ltR tRtVtV ;t# )
rA   iÎ  c                óz  <€ \         SV `  WW64       W@n        ^ V n        V P                  P                  V P                  P                  V 4       V P                  P                  V P                  V P                  V P                  4       Ve.   V P                  P                  \        P                  VR4       R# R# )rL  N)r   r   Ú_addressÚ_buffer_sizers  r‘  r€  r·  rY   r3  r�  r   r¸  )r&   r  r/   r0   rB   r1   r)   r   s   &&&&&&&€r   r   Ú#_SelectorDatagramTransport.__init__Ó  s�   ø€ ä‰Ñ˜ XÔ5ØŒØˆÔØ�
‰
×Ñ˜TŸ^™^×;Ñ;¸TÔBà�
‰
×Ñ˜T×-Ñ-Ø!Ÿ]™]¨D×,<Ñ,<ô	>àÒà�J‰J× Ñ ¤×!EÑ!EØ!'¨ö/ñ r(   c                ó   € V P                   # r,   )r  rS   s   &r   rt  Ú0_SelectorDatagramTransport.get_write_buffer_sizeá  s   € Ø× Ñ Ð r(   c                ó°  € V P                   '       d   R #  V P                  P                  V P                  4      w  rV P                  P                  W4       R #   \        \        3 d     R # \         d'   pT P                  P                  T4        R p?R # R p?i\        \        3 d    h \         d   pT P                  TR4        R p?R # R p?ii ; i)Nz&Fatal read error on datagram transport)rf  r8  rð   rª  r€  Údatagram_receivedre   rd   rl   Úerror_receivedr“   r”   r’   rœ  ©r&   r_   rŒ   r�   s   &   r   r�  Ú&_SelectorDatagramTransport._read_readyä  s©   € Ø�?�?ˆ?Ùð	9ØŸ™×,Ñ,¨T¯]©]Ó;‰JˆDð �N‰N×,Ñ,¨TÖ8øô  Ô!1Ð2ô 	ÚÜô 	/Ø�N‰N×)Ñ)¨#×.Ò.ûÜÔ-Ð.ô 	ØÜô 	MØ×Ñ˜cÐ#K×LÒLûð	Mús;   –'A ÁCÁ.CÁ7CÁ8BÂCÂ,
CÂ7CÂ8CÃCc                óþ  € \        V\        \        \        34      '       g#   \	        R \        V4      P                  : 24      hV P                  '       d8   VRV P                  39  d   \        RV P                   24      hV P                  pV P                  '       dc   V P                  '       dQ   V P                  \        P                  8¼  d   \        P                  ! R4       V ;P                  ^,          un	        R# V P                  '       gU    V P                  R,          '       d   V P                   P#                  V4       R# V P                   P%                  W4       R# V P                  PA                  \        V4      V34       V ;PB                  \E        V4      V PF                  ,           ,          un!        V PI                  4        R#   \&        \(        3 d4    T P*                  P-                  T P.                  T P0                  4        L®\2         d'   pT P4                  P7                  T4        Rp?R# Rp?i\8        \:        3 d    h \<         d   pT P?                  TR4        Rp?R# Rp?ii ; i)z/data argument must be a bytes-like object, not Nz!Invalid address: must be None or rÐ  ry   ú'Fatal write error on datagram transport)%r˜   rÒ  rÓ  r  r›   r  r    r  rœ   rf  r   rÔ  r   rÕ  re  r\  r8  rk   r  re   rd   rs  r¶   r3  Ú_sendto_readyrl   r€  r  r“   r”   r’   rœ  rr  r  rù   Ú_header_sizerÖ  r  s   &&& r   r  Ú!_SelectorDatagramTransport.sendtoô  sØ  € Ü˜$¤¬	´:Ð >×?Ò?Üð #Ü#'¨£:×#6Ñ#6Ñ"9ð;ó <ð <ð �=�=ˆ=Ø˜D $§-¡-Ð0Ô0Ü Ø7¸¿¹°ÐGóIð Ià—=‘=ˆDà�?�?ˆ?˜tŸ}Ÿ}˜}Ø�‰¤)×"MÑ"MÔMÜ—’Ð@ÔAØ�OŠO˜qÕ �OÙà�|�|ˆ|ðØ—;‘;˜z×*Ô*Ø—J‘J—O‘O DÔ)ñ ð —J‘J×%Ñ% dÔ1Ùð 	�‰×ÑœU 4›[¨$Ð/Ô0Ø×ÒœS ›Y¨×):Ñ):Õ:Õ:ÕØ×"Ñ"Ö$øô $Ô%5Ð6ô JØ—
‘
×&Ñ& t§}¡}°d×6HÑ6HÖIÜô Ø—‘×-Ñ-¨cÔ2ÝûÜÔ 1Ð2ô ØÜ ô Ø×!Ñ!ØÐBôDåûðúsI   ÄG Ä-G Å
G ÇAI<ÈI<ÈI<ÈI É I<É
I<ÉI<ÉI7É7I<c                óæ  € V P                   '       d¤   V P                   P                  4       w  rV ;P                  \        V4      V P                  ,           ,          un         V P
                  R ,          '       d   V P                  P                  V4       K˜  V P                  P                  W4       Kµ  V P'                  4        V P                   '       gM   V P(                  P+                  V P,                  4       V P.                  '       d   V P1                  R4       R# R# R#   \        \        3 dT    T P                   P                  Y34       T ;P                  \        T4      T P                  ,           ,          un         KÓ  \         d'   pT P                  P                  T4        Rp?R# Rp?i\        \         3 d    h \"         d   pT P%                  TR4        Rp?R# Rp?ii ; i)ry   Nr  )re  rë  r  rù   r  r\  r8  rk   r  re   rd   rì  rl   r€  r  r“   r”   r’   rœ  rá  rs  rº   r3  rg  r’  r  s   &   r   r  Ú(_SelectorDatagramTransport._sendto_ready  sa  € Ø�l�lˆlØŸ™×-Ñ-Ó/‰JˆDØ×Ò¤ T£¨T×->Ñ->Õ!>Õ>ÕðØ—;‘;˜z×*Ô*Ø—J‘J—O‘O DÖ)à—J‘J×%Ñ% dÖ1ð 	×#Ñ#Ô%Ø�|�|ˆ|Ø�J‰J×%Ñ% d§m¡mÔ4Ø�}�}ˆ}Ø×*Ñ*¨4Ö0ñ ñ øô $Ô%5Ð6ô Ø—‘×'Ñ'¨¨Ô5Ø×!Ò!¤S¨£Y°×1BÑ1BÕ%BÕBÕ!ÚÜô Ø—‘×-Ñ-¨cÔ2ÝûÜÔ 1Ð2ô ØÜ ô Ø×!Ñ!ØÐBôDåûðúsC   Á#4D& ÂD& Ä&A G0Æ	G0ÆG0ÆF4Æ4G0Ç
G0ÇG0ÇG+Ç+G0)r  r  rK  r,   )r    rM  rN  rO  rc  rd  Ú_buffer_factoryr  r   rt  r�  r  r  rS  rT  rU  rV  s   @@r   rA   rA   Î  s4   ù‡ € à!×'Ñ'€OØ€L÷/ò!ò9ô (%÷T1ò 1r(   rA   )r   )&rP  Ú__all__rc  r�   rÓ   rÚ  Úosr   rV   r«  r#   ÚsslÚImportErrorÚ r   r   r   r   r   r   r	   r
   Úlogr   Úhasattrr²  Úsysconfr   rl   r   ÚBaseEventLoopr   Ú_FlowControlMixinÚ	TransportrY  r.   ÚDatagramTransportrA   r]   r(   r   Ú<module>r+     s  ðñð #€ã Û Û Û Û 	Û Û Û Û ðÛõ Ý Ý Ý Ý Ý Ý Ý Ý á�v—}‘} iÓ0€çðØ—Z’Z Ó-ˆ
ò
(ôE˜K×5Ñ5ô EôPa4˜×5Ñ5Ø#×-Ñ-ôa4ôHjÐ1ô jôZ	k1Ð!3°Z×5QÑ5Qö k1øðu% ô Ø
‚Cðûð$ ô àŠðús#   ªC- Â C< Ã-	C9Ã8C9Ã<	DÄD