Viewing File: /opt/alt/python38/lib/python3.8/site-packages/urllib3/util/__pycache__/wait.cpython-38.opt-1.pyc

U

`@sddlZddlZddlZddlmZzddlmZWn ek
rTddlmZYnXdddgZGddde	Z
ejd	krd
dZnddZdddZ
dddZddZddZddadddZdddZdS)N)partial)	monotonic)timeNoWayToWaitForSocketError
wait_for_readwait_for_writec@seZdZdS)rN)__name__
__module____qualname__rrB/opt/alt/python38/lib/python3.8/site-packages/urllib3/util/wait.pyrs)cCs||S)Nr)fntimeoutrrr_retry_on_intr*src
Cs|dkrtd}n
t|}z
||WSttjfk
r}zF|jdtjkrRn.|t}|dkrhd}|tdkrxd}WYqW5d}~XYqXqdS)Ninfr)floatrOSErrorselecterrorargserrnoZEINTR)rrZdeadlineerrrr0s



Fc
Csd|s|stdg}g}|r&|||r4||ttj|||}t||\}}}	t|p`|p`|	S)N2must specify at least one of read=True, write=True)RuntimeErrorappendrrrbool)
sockreadwriterZrcheckZwcheckrZrreadyZwreadyZxreadyrrrselect_wait_for_socketGs

r!cs^|s|stdd}|r"|tjO}|r0|tjO}t||fdd}tt||S)Nrrcs|dk	r|d9}|S)Ni)poll)tZpoll_objrrdo_pollfsz%poll_wait_for_socket.<locals>.do_poll)rrZPOLLINZPOLLOUTr"registerrr)rrr rmaskr%rr$rpoll_wait_for_socketZs

r(cOstddS)Nzno select-equivalent available)rrkwargsrrrnull_wait_for_socketnsr+c	Cs<zt}t|jdWnttfk
r2YdSXdSdS)NrFT)rr"rAttributeErrorrr$rrr_have_working_pollrsr-cOs*trtanttdrtantat||S)Nr)r-r(wait_for_sockethasattrrr!r+r)rrrr.s
r.cCst|d|dS)zWaits for reading to be available on a given socket.
    Returns True if the socket is readable, or False if the timeout expired.
    T)rrr.rrrrrrscCst|d|dS)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 rr0r1rrrrs)FFN)FFN)N)N)rrsys	functoolsrrrImportError__all__	Exceptionrversion_inforr!r(r+r-r.rrrrrr<module>s&







Back to Directory File Manager