
    hG                        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      $ )N2must specify at least one of read=True, write=True)RuntimeErrorappendr   selectbool)
sockreadwritetimeoutrcheckwcheckfnrreadywreadyxreadys
             C/var/www/html/env/lib/python3.13/site-packages/urllib3/util/wait.pyselect_wait_for_socketr   !   st     OPPFFdd 
	7B[FF*&*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     =IA}}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4u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     4dG<<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     4tW==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   