R`i d dl Z d dlZd dlZd dlmZ d dlmZ g dZ G d de Z
ej dk\ rd Z nd
Z dd Z
dd Zd
Zd Zd addZddZy# e$ r d dlmZ Y Lw xY w) N)partial) monotonic)time)NoWayToWaitForSocketError
wait_for_readwait_for_writec e Zd Zy)r N)__name__
__module__ __qualname__ /builddir/build/BUILDROOT/alt-python312-pip-23.3.1-3.el8.x86_64/opt/alt/python312/lib/python3.12/site-packages/pip/_vendor/urllib3/util/wait.pyr r s r r ) c | | S Nr
)fntimeouts r _retry_on_intrr * s '{r c " | t d }n
t |z } | | S # t t j f$ rO}|j
d t j k7 r |t z
}|dk rd}|t d k( rd }Y d }~md }~ww xY w)Ninfr )floatr OSErrorselecterrorargserrnoEINTR)r r deadlinees r r r / s ? U|H {W,H
'{"V\\*
66!9 + & 4G {"# %,."&
s & BAB Bc |s
|s t d g }g }|r|j | |r|j | t t j ||| }t || \ }}} t |xs |xs | S )N2must specify at least one of read=True, write=True) RuntimeErrorappendr r r bool)
sockreadwriter rcheckwcheckr rreadywreadyxreadys
r select_wait_for_socketr/ F sy OPP
F
F
d
d
7B +B 8FFF *&*F ++r c |s
|s t d d}|r|t j z }|r|t j z }t j j | | fd}t
t || S )Nr# r c 4 | | dz } j | S )Ni )poll)tpoll_objs r do_pollz%poll_wait_for_socket..do_polle s =
IA}}Q r )r$ r POLLINPOLLOUTr2 registerr& r )r' r( r) r maskr5 r4 s @r poll_wait_for_socketr: Y so OPP D
{{}H dD!
w0 11r c t d )Nz no select-equivalent available)r r kwargss r null_wait_for_socketr> m s
#$D
EEr c t j } t | j d y# t t f$ r Y yw xY w)Nr TF)r r2 r AttributeErrorr )r4 s r _have_working_pollrA q s> ;;=x}}a(
G $ s *- ??c t t rt an t t d rt
ant at | i |S )Nr )rA r: wait_for_sockethasattrr r/ r> r< s r rC rC ~ s3 . "0. D +F ++r c t | d| S )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 rC r' r s r r r s 4dG < rA rC r r r
r r rO s
' K 4 v
.,&2(F
, =>Y '&'s A A'&A'