ó
    Ð]jG  ã                  óÌ   • S SK Jr  S SKrS SKrS SKJr  SS/r   S         SS jjr   S         SS jjrSS jr	   S         SS	 jjq
SSS
 jjrSSS jjrg)é    )ÚannotationsN)ÚpartialÚwait_for_readÚwait_for_writec                ó"  • U(       d  U(       d  [        S5      e/ n/ nU(       a  UR                  U 5        U(       a  UR                  U 5        [        [        R                  XEU5      nU" U5      u  pxn	[	        U=(       d    U=(       d    U	5      $ )Nú2must specify at least one of read=True, write=True)ÚRuntimeErrorÚappendr   ÚselectÚbool)
ÚsockÚreadÚwriteÚtimeoutÚrcheckÚwcheckÚfnÚrreadyÚwreadyÚxreadys
             ÚN/home/mande/repo/quber/.venv/lib/python3.13/site-packages/urllib3/util/wait.pyÚselect_wait_for_socketr   !   st   € ö žÜÐOÓPÐPØ€FØ€FÞØ�‰�dÔÞØ�‰�dÔô 
”—‘ °Ó	7€BÙ ›[Ñ€F�FÜ�×*˜&×* FÓ+Ð+ó    c                ó   ^• U(       d  U(       d  [        S5      eSnU(       a  U[        R                  -  nU(       a  U[        R                  -  n[        R                  " 5       mTR                  X5        SU4S jjn[        U" U5      5      $ )Nr   r   c                ó6   >• U b  U S-  n TR                  U 5      $ )Niè  )Úpoll)ÚtÚpoll_objs    €r   Údo_pollÚ%poll_wait_for_socket.<locals>.do_pollJ   s    ø€ Ø‰=Ø�‰IˆAØ�}‰}˜QÓÐr   )r   úfloat | NoneÚreturnzlist[tuple[int, int]])r	   r   ÚPOLLINÚPOLLOUTr   Úregisterr   )r   r   r   r   Úmaskr   r   s         @r   Úpoll_wait_for_socketr'   9   sm   ø€ ö žÜÐOÓPÐPØ€DÞØ”—‘ÑˆÞØ”—‘ÑˆÜ�{Š{‹}€HØ×Ñ�dÔ!÷ ô
 ‘˜Ó Ó!Ð!r   c                 ó~   •  [         R                  " 5       n U R                  S5        g! [        [        4 a     gf = f)Nr   TF)r   r   ÚAttributeErrorÚOSError)r   s    r   Ú_have_working_pollr+   R   s<   € ðÜ—;’;“=ˆØ�‰�aÔð øô œGÐ$ó Ùðús   ‚&) ©<»<c                ó|   • [        5       (       a  [        qO[        [        S5      (       a  [
        q[        XX#5      $ )Nr   )r+   r'   Úwait_for_socketÚhasattrr   r   )r   r   r   r   s       r   r-   r-   _   s1   € ô ×ÑÜ.‰Ü	”˜×	"Ñ	"Ü0ˆÜ˜4 uÓ6Ð6r   c                ó   • [        U SUS9$ )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   ©r-   ©r   r   s     r   r   r   q   s   € ô ˜4 d°GÑ<Ð<r   c                ó   • [        U SUS9$ )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   r0   r1   s     r   r   r   x   s   € ô ˜4 t°WÑ=Ð=r   )FFN)
r   úsocket.socketr   r   r   r   r   r!   r"   r   )r"   r   )N)r   r3   r   r!   r"   r   )Ú
__future__r   r   ÚsocketÚ	functoolsr   Ú__all__r   r'   r+   r-   r   r   © r   r   Ú<module>r9      så   ðÝ "ã Û Ý àÐ,Ð
-€ð8 ØØ ð	,Ø
ð,à
ð,ð ð,ð ð	,ð
 
õ,ð4 ØØ ð	"Ø
ð"à
ð"ð ð"ð ð	"ð
 
õ"ô2
ð ØØ ð	7Ø
ð7à
ð7ð ð7ð ð	7ð
 
õ7ö$=÷>r   