o
ai @ s d dl Z d dlZd dlZd dlmZ zd dlmZ W n ey) d dlmZ Y nw g dZG dd de Z
ej dkr@d d
Z nd d
Z dd
dZ
dddZdd Zdd Zdd ad ddZd ddZdS ) N)partial) monotonic)time)NoWayToWaitForSocketError
wait_for_readwait_for_writec @ s e Zd ZdS )r N)__name__
__module__ __qualname__ r r /builddir/build/BUILDROOT/alt-python310-pip-21.3.1-5.el8.x86_64/opt/alt/python310/lib/python3.10/site-packages/pip/_vendor/urllib3/util/wait.pyr s r ) c C s | |S Nr )fntimeoutr r r _retry_on_intr* r c
C s |d u r t d}nt | } z| |W S ttjfyE } z"|jd tjkr( |t }|dk r3d}|t dkr;d }W Y d }~qd }~ww )NinfTr )floatr OSErrorselecterrorargserrnoZEINTR)r r deadlineer r r r 0 s"
Fc
C sd |s|st dg }g }|r|| |r|| ttj|||}t||\}}} t|p0|p0| S )N2must specify at least one of read=True, write=True) RuntimeErrorappendr r r bool)
sockreadwriter rcheckwcheckr rreadywreadyxreadyr r r select_wait_for_socketG s
r) c s^ |s|st dd}|r|tjO }|r|tjO }t | | fdd}tt||S )Nr r c s | d ur| d9 } | S )Ni )poll)tpoll_objr r do_pollf s
z%poll_wait_for_socket..do_poll)r r POLLINPOLLOUTr* registerr r )r! r" r# r maskr. r r, r poll_wait_for_socketZ s
r3 c O s t d)Nz no select-equivalent available)r r kwargsr r r null_wait_for_socketn r r6 c C s4 z
t } t| jd W dS ttfy Y dS w )Nr FT)r r* r AttributeErrorr r, r r r _have_working_pollr s r8 c O s. t rtan
ttdrtantat| i |S )Nr )r8 r3 wait_for_sockethasattrr r) r6 r4 r r r r9 s
r9 c C 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 r9 r! r r r r r r c C r; )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 r< r= r r r r r> r )FFNr )r r sys functoolsr r r ImportError__all__ Exceptionr version_infor r) r3 r6 r8 r9 r r r r r r s*