3
Re @ s d dl Z d dlmZ d dlZd dlZyd dlmZ W n ek
rT d dlmZ Y nX dddgZG dd de Z
ej dkrd d Z nd
d Z d ddZ
d ddZdd Zdd Zdd ad ddZd ddZdS ) N)partial) monotonic)timeNoWayToWaitForSocketError
wait_for_readwait_for_writec @ s e Zd ZdS )r N)__name__
__module__ __qualname__ r r /builddir/build/BUILDROOT/alt-python36-pip-20.2.4-5.el8.x86_64/opt/alt/python36/lib/python3.6/site-packages/pip/_vendor/urllib3/util/wait.pyr s c C s | |S )Nr )fntimeoutr r r _retry_on_intr* s r c C s |d krt d}n
t | }xry| |S ttjfk
r } zB|jd tjkrR n(|t }|dk rhd}|t dkrxd }w W Y d d }~X q X q W d S )Ninfr )floatr OSErrorselecterrorargserrnoZEINTR)r r deadlineer r r r 0 s
Fc
C sh | r| rt dg }g }|r*|j| |r8|j| ttj|||}t||\}}} t|pd|pd| S )Nz2must 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 sb | r| rt dd}|r&|tjO }|r4|tjO }tj j| | fdd}tt||S )Nz2must specify at least one of read=True, write=Truer c s | d k r| d9 } j | S )Ni )poll)t)poll_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
r/ c O s t dd S )Nz no select-equivalent available)r )r kwargsr r r null_wait_for_socketn s r1 c C s: yt j } t| jd W n ttfk
r0 dS X dS d S )Nr FT)r r' r AttributeErrorr )r) r r r _have_working_pollr s r3 c O s* t r tanttdr tantat| |S )Nr )r3 r/ wait_for_sockethasattrr r& r1 )r r0 r r r r4 s
r4 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 )r4 )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 )r4 )r r r r r r s )r
r )FFN)FFN)N)N)r functoolsr r sysr r ImportError__all__ Exceptionr version_infor r& r/ r1 r3 r4 r r r r r r s&