/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 d¢ZG dd„ de ƒZ
ejdkr€d d
„ Zndd
„ Zdd
d„Z
ddd„Zdd„ Zdd„ Zdd„ addd„Zddd„ZdS )é N)Úpartial)Ú monotonic)Útime)ÚNoWayToWaitForSocketErrorÚ
wait_for_readÚwait_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 )ÚfnÚtimeoutr 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 dƒkrvd }W Y d }~qW Y d }~qd }~0 0 qd S )NÚinfr )Úfloatr ÚOSErrorÚselectÚerrorÚargsÚerrnoZEINTR)r r ZdeadlineÚer r r r 0 s
Fc
C sd |s|st dƒ‚g }g }|r&| | ¡ |r4| | ¡ ttj|||ƒ}t||ƒ\}}} t|p`|p`| ƒS )Nú2must specify at least one of read=True, write=True)ÚRuntimeErrorÚappendr r r Úbool)
ÚsockÚreadÚwriter ZrcheckZwcheckr ZrreadyZwreadyZxreadyr r r Úselect_wait_for_socketG s
r! c s^ |s|st dƒ‚d}|r"|tjO }|r0|tjO }t ¡ ‰ ˆ | |¡ ‡ fdd„}tt||ƒƒS )Nr r c s | d ur| d9 } ˆ | ¡S )Niè )Úpoll)Út©Zpoll_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 dƒ‚d 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 ƒ rtanttdƒrtantat| i |¤ŽS )Nr )r- r( Úwait_for_socketÚhasattrr r! r+ r) r r r r. s
r. c C s 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 r r r r r Ž s r c C s t | 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 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&