B

L��g�@s�dd
lZdd
l
Z
dd
lZddlmZ
yddlmZ
Wn ek
rT


ddlmZ
YnXdddgZGdd�de	�Z
ejd	kr�d
d�Zndd�Zddd�
Z
ddd�
Zdd�Zdd�Zdd�addd�
Zddd�
Zd
S)�N)
�partial)
�	monotonic)
�time�NoWayToWaitForSocketError�
wait_for_read�wait_for_writec
@seZ
dZd
S)rN)�__name__�
__module__�__qualname__�rr�A/tmp/pip-unpacked-wheel-hv55ucu3/pip/_vendor/urllib3/util/wait.pyrs
)��cCs||
�
S)
Nr)�fn�timeoutrrr�_retry_on_intr*s
rc
Cs�|
dkrtd
�
}n
t
�|
}xry||
�
Sttjfk
r�
}
z@|jdtjkrR�n(|t
�}
|
dkrhd}
|
td
�
krxd}
wWdd}~XYqXqWdS)N�infr
)�floatr�OSError�select�error�args�errnoZEINTR)rr�deadline�
errrr/s












Fc
Csd|
s|std
�
�
g}g}|
r&|�
|�

|r4|�
|�

ttj|||�}t||�\}}}	t|p`|p`|	�
S)Nz2must specify at least one of read=True, write=True)�RuntimeError�appendrrr�bool)
�sock�read�writer�rcheck�wcheckr�rready�wready�xreadyrrr�select_wait_for_socketFs











r&cs^|
s|std
�
�
d}|
r"|t
jO}|r0|t
jO}t
�����||�
�f
dd�}tt||��
S)Nz2must specify at least one of read=True, write=Truer
c

s|dk	r|d
9}��|�
S)Ni�)
�poll)
�
t)
�poll_objrr�do_polles


z%poll_wait_for_socket.<locals>.do_poll)rr�POLLIN�POLLOUTr'�registerrr)rrr r�maskr*r)
r)r�poll_wait_for_socketYs










r/cOstd
�
�
dS)Nzno select-equivalent available)
r)r�kwargsrrr�null_wait_for_socketms
r1c
	Cs:yt�
�}t|j
d
�
Wnttfk
r0


dSXdSdS)Nr
FT)rr'r�AttributeErrorr)
r)rrr�_have_working_pollqs



r3cOs*t�rt
anttd
�rtantat||
�
S)Nr)r3r/�wait_for_socket�hasattrrr&r1)rr0rrrr4~s




r4cCst|d
|
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)rr)
r4)rrrrrr�scCst|d
|
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)
r4)rrrrrr�s)FFN)FFN)
N)
N)rr�sys�	functoolsrrr�ImportError�__all__�	Exceptionr�version_inforr&r/r1r3r4rrrrrr�<module>
s&