Name	Size	Mode	Actions
connection.cpython-310.pyc	3376	0644	editdlrm
proxy.cpython-310.pyc	1294	0644	editdlrm
queue.cpython-310.pyc	981	0644	editdlrm
request.cpython-310.pyc	3415	0644	editdlrm
response.cpython-310.pyc	2300	0644	editdlrm
retry.cpython-310.pyc	15875	0644	editdlrm
ssltransport.cpython-310.pyc	7362	0644	editdlrm
ssl_.cpython-310.pyc	11228	0644	editdlrm
timeout.cpython-310.pyc	8885	0644	editdlrm
url.cpython-310.pyc	10585	0644	editdlrm
wait.cpython-310.pyc	3045	0644	editdlrm
__init__.cpython-310.pyc	1061	0644	editdlrm

o �~�`�@s�dd
lZdd
l
Z
dd
lZddlmZ
zddlmZ
Wney)


ddlmZ
Yn
wgd�
ZGdd�de �Z ejdkr@d d �Zndd �Zdd d�
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�3/usr/lib/python3/dist-packages/urllib3/util/wait.pyrs
r)��cCs||
�
S�
Nr)�fn�timeoutrrr�_retry_on_intr*�
rc Cs�|
dur td
�
}nt
�|
} z||
�
WSttjfyE
}
z"|jdtjkr(�|t
�}
|
dkr3d}
|
td
�
kr;d}
WYd}~qd}~w
w)N�infTr
)�floatr�OSError�select�error�args�errno�EINTR)rr�deadline�
errrr0s"








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

|r|�
|�

ttj|||�}t||�\}}} t|p0|p0| �
S)N�2must specify at least one of read=True, write=True)�RuntimeError�appendrrr�bool) �sock�read�writer�rcheck�wcheckr�rready�wready�xreadyrrr�select_wait_for_socketGs









r*cs^|
s|std
�
�
d}|
r|t
jO}|r|t
jO}t
�����||�
�f
dd�}tt||��
S)Nrr
c

s|du
r|d
9}��|�
S)Ni�)
�poll)
�
t�
�poll_objrr�do_pollfs


z%poll_wait_for_socket..do_poll)rr�POLLIN�POLLOUTr+�registerr!r)r"r#r$r�maskr/rr-r�poll_wait_for_socketZs








r4cOstd
�
�
)Nzno select-equivalent available)
r�r�kwargsrrr�null_wait_for_socketnrr7c
Cs4z t�
�}t|j
d
�
WdSttfy


YdSw)Nr
FT)rr+r�AttributeErrorrr-rrr�_have_working_pollrs

�
�r9cOs.t�rt
an ttd
�rtantat|i|
�
�
S)Nr)r9r4�wait_for_socket�hasattrrr*r7r5rrrr:s



r:cC�t|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)r#r�
r:�r"rrrrr��rcCr<)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$rr=r>rrrr�r?r)FFNr)rr�sys� functoolsrrr�ImportError�__all__� Exceptionr�version_inforr*r4r7r9r:rrrrrr�
s*





�