U
ʗRe @ s d dl Z d dlZd dlZd dlmZ zd 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)timeNoWayToWaitForSocketError
wait_for_readwait_for_writec @ s e Zd ZdS )r N)__name__
__module__ __qualname__ r r /builddir/build/BUILDROOT/alt-python38-pip-22.2.1-2.el8.x86_64/opt/alt/python38/lib/python3.8/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 | }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 )Ninfr )floatr OSErrorselecterrorargserrnoZEINTR)r r deadlineer r r r / s
Fc
C sd |s|st dg }g }|r&|| |r4|| ttj|||}t||\}}} t|p`|p`| S )N2must specify at least one of read=True, write=True) RuntimeErrorappendr r r bool)
sockreadwriter rcheckwcheckr rreadywreadyxreadyr r r select_wait_for_socketF 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)tpoll_objr r do_polle s z%poll_wait_for_socket..do_poll)r r POLLINPOLLOUTr( registerr r )r r r! r maskr, r r* r poll_wait_for_socketY s
r1 c O s t dd S )Nz no select-equivalent available)r r kwargsr r r null_wait_for_socketm 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_pollq s r6 c O s* t r tanttdr tantat| |S )Nr )r6 r1 wait_for_sockethasattrr r' r4 r2 r r r r7 ~ s
r7 c C s 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 r7 r r r r r r s c C s t | d|dS )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 r9 r: r r r r s )FFN)FFN)N)N)r r sys functoolsr r r ImportError__all__ Exceptionr version_infor r' r1 r4 r6 r7 r r r r r r s&