U
|
I=®d ã @ sÐ d dl Z d dlmZ d dlZd dlZzd dlmZ W n ek
|
rT d dlmZ Y nX dddgZG dd de Z
|
ej d krd
|
d Z nd d Z dddZ dddZdd Zdd Zdd ad ddZd ddZdS ) é N)Úpartial)Ú monotonic)ÚtimeÚNoWayToWaitForSocketErrorÚ wait_for_readÚwait_for_writec @ s e Zd ZdS )r N)Ú__name__Ú
|
__module__Ú __qualname__© r r úTD:\z\workplace\VsCode\pyvenv\venv\Lib\site-packages\pip/_vendor/urllib3/util/wait.pyr s )é é c C s | |S )Nr )ÚfnÚtimeoutr r r Ú_retry_on_intr* s r c
|
C s |d krt d}n
|
t | }z
|
| |W S ttjfk
|
r } zF|jd tjkrR n.|t }|dk rhd}|t dkrxd }W Y ¢q W 5 d }~X Y q X q d S )NÚinfr )Úfloatr ÚOSErrorÚselectÚerrorÚargsÚerrnoZEINTR)r r ÚdeadlineÚer r r r 0 s
|
|
|
|
Fc
|
C sd |s|st dg }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 ÚrcheckÚwcheckr ÚrreadyÚwreadyÚxreadyr 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 k r| d9 } | ¡S )Niè )Úpoll)Út©Úpoll_objr r Údo_pollf s z%poll_wait_for_socket.<locals>.do_poll)r r ÚPOLLINÚPOLLOUTr( Úregisterr r )r r r! r Úmaskr, r r* r Úpoll_wait_for_socketZ s
|
|
r1 c O s t dd S )Nz no select-equivalent available)r ©r Úkwargsr r r Únull_wait_for_socketn s r4 c C s< zt ¡ } t| jd W n ttfk
|
r2 Y dS X dS d S )Nr FT)r r( r ÚAttributeErrorr r* r r r Ú_have_working_pollr s r6 c O s* t r tanttdr tantat| |S )Nr )r6 r1 Úwait_for_socketÚhasattrr r' r4 r2 r r r r7 s
|
r7 c C s t | d|dS )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 ©r7 ©r r r r r r s c C s t | d|dS )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 r9 r: r r r r s )FFN)FFN)N)N)r Ú functoolsr r Úsysr r Ú ImportErrorÚ__all__Ú Exceptionr Ú version_infor r' r1 r4 r6 r7 r r r r r r Ú<module> s&
|
|
|
|
|
|
|
