/usr/lib/python3.9/site-packages/urllib3/util/__pycache__
Edit: /usr/lib/python3.9/site-packages/urllib3/util/__pycache__/wait.cpython-39.pyc (3084B)
a
t~` @ s d dl Z d dlZd dlZd dlmZ zd dlmZ W n eyR d dlmZ Y n0 g dZG dd de Z
ejdkrd d
Zndd
Zdd
dZ
dddZdd Zdd Zdd adddZdddZdS ) N)partial) monotonic)time)NoWayToWaitForSocketError
wait_for_readwait_for_writec @ s e Zd ZdS )r N)__name__
__module____qualname__ r r 5/usr/lib/python3.9/site-packages/urllib3/util/wait.pyr s r ) c C s | |S )Nr )fntimeoutr r r _retry_on_intr* s r c
C s |d u rt d}n
t | }z
| |W S ttjfy } zR|jd tjkrP n2|t }|dk rfd}|t dkrvd }W Y d }~qW Y d }~qd }~0 0 qd S )Ninfr )floatr OSErrorselecterrorargserrnoZEINTR)r r Zdeadlineer r r r 0 s
Fc
C sd |s|st dg }g }|r&|| |r4|| ttj|||}t||\}}} t|p`|p`| S )N2must specify at least one of read=True, write=True)RuntimeErrorappendr r r bool)
sockreadwriter ZrcheckZwcheckr ZrreadyZwreadyZxreadyr r r select_wait_for_socketG s
r! c s^ |s|st dd}|r"|tjO }|r0|tjO }t | | fdd}tt||S )Nr r c s | d ur| d9 } | S )Ni )poll)tZpoll_objr r do_pollf s z%poll_wait_for_socket.
.do_poll)r r ZPOLLINZPOLLOUTr" registerr r )r r r r maskr% r r$ r poll_wait_for_socketZ s
r( c O s t dd S )Nzno select-equivalent available)r r kwargsr r r null_wait_for_socketn s r+ c C s: zt } t| jd W n ttfy0 Y dS 0 dS d S )Nr FT)r r" r AttributeErrorr r$ r r r _have_working_pollr s r- c O s. t rtanttdrtantat| i |S )Nr )r- r( wait_for_sockethasattrr r! r+ r) r r r r. s
r. c C s t | 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)r r r. r r r r r r s r c C s t | 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 r r0 r1 r r r r s r )FFN)FFN)N)N)r r sys functoolsr r r ImportError__all__ Exceptionr version_infor r! r( r+ r- r. r r r r r r s&