Ë
    R>{iG  ã                  ó¶   — d dl mZ d dlZd dlZd dlmZ ddgZ	 	 	 d	 	 	 	 	 	 	 	 	 dd„Z	 	 	 d	 	 	 	 	 	 	 	 	 dd„Zdd„Z		 	 	 d	 	 	 	 	 	 	 	 	 dd	„a
ddd
„Zddd„Zy)é    )ÚannotationsN)ÚpartialÚwait_for_readÚwait_for_writec                óê   — |s|st        d«      ‚g }g }|r|j                  | «       |r|j                  | «       t        t        j                  |||«      } ||«      \  }}}	t	        |xs |xs |	«      S )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
             úO/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/urllib3/util/wait.pyÚselect_wait_for_socketr   !   sx   € ñ ™ÜÐOÓPÐPØ€FØ€FÙØ�‰�dÔÙØ�‰�dÔô 
”—‘ ¨°Ó	7€BÙ ›[Ñ€FˆF�FÜ�Ò*˜&Ò* FÓ+Ð+ó    c                óô   ‡— |s|st        d«      ‚d}|r|t        j                  z  }|r|t        j                  z  }t        j                  «       Š‰j                  | |«       dˆfd„}t         ||«      «      S )Nr   r   c                ó4   •— | �| dz  } ‰j                  | «      S )Niè  )Úpoll)ÚtÚpoll_objs    €r   Údo_pollz%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   so   ø€ ñ ™ÜÐOÓPÐPØ€DÙØ”—‘ÑˆÙØ”—‘ÑˆÜ�{‰{‹}€HØ×Ñ�d˜DÔ!õ ô
 ‘˜Ó Ó!Ð!r   c                 óz   — 	 t        j                  «       } | j                  d«       y# t        t        f$ r Y yw xY w)Nr   TF)r   r   ÚAttributeErrorÚOSError)r   s    r   Ú_have_working_pollr*   R   s<   € ðÜ—;‘;“=ˆØ�‰�aÔð øô œGÐ$ò Ùðús   ‚%( ¨:¹:c                ól   — t        «       rt        ant        t        d«      rt
        at        | |||«      S )Nr   )r*   r&   Úwait_for_socketÚhasattrr   r   )r   r   r   r   s       r   r,   r,   _   s/   € ô ÔÜ.‰Ü	”˜Ô	"Ü0ˆÜ˜4  u¨gÓ6Ð6r   c                ó   — t        | d|¬«      S )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                ó   — t        | d|¬«      S )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/   r0   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   r2   r   r    r!   r   )Ú
__future__r   r   ÚsocketÚ	functoolsr   Ú__all__r   r&   r*   r,   r   r   © r   r   ú<module>r8      så   ðÝ "ã Û Ý àÐ,Ð
-€ð8 ØØ ð	,Ø
ð,à
ð,ð ð,ð ð	,ð
 
ó,ð4 ØØ ð	"Ø
ð"à
ð"ð ð"ð ð	"ð
 
ó"ó2
ð ØØ ð	7Ø
ð7à
ð7ð ð7ð ð	7ð
 
ó7ô$=õ>r   