‹“Re ã
@ s, d d l Z d d l m Z d d l Z d d l Z y d d l m Z Wn" e k
rl d d l m Z Yn Xd d d g Z Gd d „ d e ƒ Z
e j d k r° d d „ Z n d
d „ Z d d d d d „ Z
d d d d d „ Z d d „ Z d d „ Z d d „ a d d d „ Z d d d „ Z d S) é N)Úpartial)Ú monotonic)ÚtimeÚNoWayToWaitForSocketErrorÚ
wait_for_readÚwait_for_writec @ s e Z d Z d S)r N)Ú__name__Ú
__module__Ú __qualname__© r r úŒ/builddir/build/BUILDROOT/alt-python35-pip-20.2.4-5.el8.x86_64/opt/alt/python35/lib/python3.5/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 k r t d ƒ } n
t ƒ | } x™ y | | ƒ SWq+ t t j f k
r¿ } z[ | j d t j k rs ‚ n: | t ƒ } | d k r’ d } | t d ƒ k rª d } w+ WYd d } ~ Xq+ Xq+ Wd S)NÚinfr )Úfloatr ÚOSErrorÚselectÚerrorÚargsÚerrnoZEINTR)r r ÚdeadlineÚer r r r 0 s
Fc
C s’ | r | r t d ƒ ‚ g } g } | r9 | j | ƒ | rL | j | ƒ t t j | | | ƒ } t | | ƒ \ } } } t | pŽ | pŽ | ƒ S)Nz2must 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‡ | r | r t d ƒ ‚ d } | r3 | t j O} | rF | t j O} t j ƒ ‰ ˆ j | | ƒ ‡ f d d † } t t | | ƒ ƒ S)Nz2must specify at least one of read=True, write=Truer c s# | d k r | d 9} ˆ j | ƒ S)Niè )Úpoll)Út)Úpoll_objr r Údo_pollf s
z%poll_wait_for_socket..do_poll)r r ÚPOLLINÚPOLLOUTr' Úregisterr r )r r r r Úmaskr* r )r) r Úpoll_wait_for_socketZ s
r/ c O s t d ƒ ‚ d S)Nz no select-equivalent available)r )r Úkwargsr r r Únull_wait_for_socketn s r1 c C sG y t j ƒ } t | j d ƒ Wn t t f k
r> d SYn Xd Sd S)Nr FT)r r' r ÚAttributeErrorr )r) r r r Ú_have_working_pollr s r3 c O s= t ƒ r t a n t t d ƒ r* t a n t a t | | Ž S)Nr )r3 r/ Úwait_for_socketÚhasattrr r& r1 )r r0 r r r r4 s r4 c C s t | d 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.
r Tr )r4 )r r r r r r Ž s c C s t | d 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.
r Tr )r4 )r r r r r r • s )r
r )r Ú functoolsr r Úsysr r Ú ImportErrorÚ__all__Ú Exceptionr Ú version_infor r& r/ r1 r3 r4 r r r r r r Ú s&