+
    IV-jG  ã                  ó’   € ^ RI Ht ^ RIt^ RIt^ RIHt RR.tRR R lltRR R	 lltR
 R lt	RR R lls
RR R lltRR R lltR# )é    )ÚannotationsN)ÚpartialÚwait_for_readÚwait_for_writec          
     ó,   € V ^8„  d   QhRRRRRRRRRR/# ©	é   Úsockúsocket.socketÚreadÚboolÚwriteÚtimeoutúfloat | NoneÚreturn© )Úformats   "Úb/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/urllib3/util/wait.pyÚ__annotate__r   !   s:   € ÷ ,ñ ,Ø
ð,à
ð,ð ð,ð ð	,ð
 
ñ,ó    c                ó.  € V'       g   V'       g   \        R 4      h. p. pV'       d   VP                  V 4       V'       d   VP                  V 4       \        \        P                  WEV4      pV! V4      w  rxp	\	        T;'       g    T;'       g    T	4      # )ú2must specify at least one of read=True, write=True)ÚRuntimeErrorÚappendr   Úselectr   )
r
   r   r   r   ÚrcheckÚwcheckÚfnÚrreadyÚwreadyÚxreadys
   &&&&      r   Úselect_wait_for_socketr"   !   sz   € ÷ ŸÜÐOÓPÐPØ€FØ€FßØ�‰�dÔßØ�‰�dÔô 
”—‘ °Ó	7€BÙ ›[Ñ€F�FÜ�×*Ð*˜&×*Ð* FÓ+Ð+r   c          
     ó,   € V ^8„  d   QhRRRRRRRRRR/# r   r   )r   s   "r   r   r   9   s:   € ÷ "ñ "Ø
ð"à
ð"ð ð"ð ð	"ð
 
ñ"r   c                ó:  a€ V'       g   V'       g   \        R 4      h^ pV'       d   V\        P                  ,          pV'       d   V\        P                  ,          p\        P                  ! 4       oSP                  W4       R V3R llp\        V! V4      4      # )r   c               ó    € V ^8„  d   QhRRRR/# )r	   Útr   r   zlist[tuple[int, int]]r   )r   s   "r   r   Ú*poll_wait_for_socket.<locals>.__annotate__J   s   € ÷  ñ  �<ð  Ð$9ñ  r   c                ó@   <€ V e
   V R,          p SP                  V 4      # )Niè  )Úpoll)r&   Úpoll_objs   &€r   Údo_pollÚ%poll_wait_for_socket.<locals>.do_pollJ   s    ø€ ØŠ=Ø��IˆAØ�}‰}˜QÓÐr   )r   r   ÚPOLLINÚPOLLOUTr)   Úregisterr   )r
   r   r   r   Úmaskr+   r*   s   &&&&  @r   Úpoll_wait_for_socketr1   9   sr   ø€ ÷ ŸÜÐOÓPÐPØ€DßØ”—‘ÕˆßØ”—‘ÕˆÜ�{Š{‹}€HØ×Ñ�dÔ!÷ ð  ô
 ‘˜Ó Ó!Ð!r   c               ó   € V ^8„  d   QhRR/# )r	   r   r   r   )r   s   "r   r   r   R   s   € ÷ 
ñ 
˜Dñ 
r   c                 ó„   €  \         P                  ! 4       p V P                  ^ 4       R#   \        \        3 d     R# i ; i)r   TF)r   r)   ÚAttributeErrorÚOSError)r*   s    r   Ú_have_working_pollr6   R   s<   € ðÜ—;’;“=ˆØ�‰�aÔñ øô œGÐ$ô Úðús   ‚&* ª?¾?c          
     ó,   € V ^8„  d   QhRRRRRRRRRR/# r   r   )r   s   "r   r   r   _   s:   € ÷ 7ñ 7Ø
ð7à
ð7ð ð7ð ð	7ð
 
ñ7r   c                ó€   € \        4       '       d   \        sM\        \        R 4      '       d   \
        s\        WW#4      # )r   )r6   r1   Úwait_for_socketÚhasattrr   r"   )r
   r   r   r   s   &&&&r   r9   r9   _   s1   € ô ×ÒÜ.‰Ü	”˜×	"Ò	"Ü0ˆÜ˜4 uÓ6Ð6r   c               ó$   € V ^8„  d   QhRRRRRR/# ©r	   r
   r   r   r   r   r   r   )r   s   "r   r   r   q   s!   € ÷ =ñ =˜ð =°ð =Èñ =r   c                ó   € \        V RVR7      # )z~Waits for reading to be available on a given socket.
Returns True if the socket is readable, or False if the timeout expired.
T)r   r   ©r9   ©r
   r   s   &&r   r   r   q   s   € ô ˜4 d°GÔ<Ð<r   c               ó$   € V ^8„  d   QhRRRRRR/# r<   r   )r   s   "r   r   r   x   s!   € ÷ >ñ >˜ð >°ð >Èñ >r   c                ó   € \        V RVR7      # )z~Waits for writing to be available on a given socket.
Returns True if the socket is readable, or False if the timeout expired.
T)r   r   r>   r?   s   &&r   r   r   x   s   € ô ˜4 t°WÔ=Ð=r   )FFN)N)Ú
__future__r   r   ÚsocketÚ	functoolsr   Ú__all__r"   r1   r6   r9   r   r   r   r   r   Ú<module>rF      s?   ðÝ "ã Û Ý àÐ,Ð
-€÷4,÷0"õ2
÷7÷$=÷>ñ >r   