]j d dl Z d dlZd dlZd dlmZ d dlmZ n# e$ r d dlmZ Y nw xY wg dZ G d de Z
ej dk rd Z nd
Z dd Z
dd
Zd Zd Zd addZddZdS ) N)partial) monotonic)time)NoWayToWaitForSocketError
wait_for_readwait_for_writec e Zd ZdS )r N)__name__
__module__ __qualname__ H/opt/imunify360/venv/lib64/python3.11/site-packages/urllib3/util/wait.pyr r s Dr r ) c | | S Nr
)fntimeouts r _retry_on_intrr * s r'{{r c < |t d }nt |z } | | S # t t j f$ rT}|j d t j k r |t z
}|dk rd}|t d k rd }Y d }~rd }~ww xY w)NinfTr )floatr OSErrorselecterrorargserrnoEINTR)r r deadlinees r r r 0 s ? U||HH {{W,H
r'{{"V\*
6!9 ++ & 4G {{"# %,,.."& HHHH
s
1 BA
BBFc |s|st d g }g }|r| | |r| | t t j ||| }t || \ }}} t |p|p| S )N2must specify at least one of read=True, write=True) RuntimeErrorappendr r r bool)
sockreadwriter rcheckwcheckr rreadywreadyxreadys
r select_wait_for_socketr/ G s Q QOPPP
F
F
d
d
7 7B +B 8 8FFF *&*F + ++r c |s|st d d}|r|t j z }|r|t j z }t j | | fd}t
t || S )Nr# r c < | | dz } | S )Ni )poll)tpoll_objs r do_pollz%poll_wait_for_socket.<locals>.do_pollf s# =
IA}}Q r )r$ r POLLINPOLLOUTr2 registerr& r )r' r( r) r maskr5 r4 s @r poll_wait_for_socketr: Z s Q QOPPP D
{}}H dD!!!
w00 1 11r c t d )Nz no select-equivalent available)r r kwargss r null_wait_for_socketr> n s
#$D
E
EEr c t j } t | j d dS # t t f$ r Y dS w xY w)Nr TF)r r2 r AttributeErrorr )r4 s r _have_working_pollrA r sT ;==x}a((( t
G $ uus (, A Ac t rt an$t t d rt
ant at | i |S )Nr )rA r: wait_for_sockethasattrr r/ r> r< s r rC rC sJ /. " " /0. D +F + ++r c & t | d| S )zWaits 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 rC r' r s r r r s 4dG < < <<r c & t | d| S )zWaits 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 rF rG s r r r s 4tW = = ==r )FFNr )r r sys functoolsr r r ImportError__all__ Exceptionr version_infor r/ r: r> rA rC r r r
r r <module>rO st
' ' ' '&&&&&&&&' K
J
J 4 v ., , , ,&2 2 2 2(F F F
, , , = = = => > > > > >s ))