eɯ\ d dl mZ d dlZd dlZd dlmZ ddgZ dddZ dddZddZ ddda
dddZ dddZ dS ) ) annotationsN)partial
wait_for_readwait_for_writeFsock
socket.socketreadboolwritetimeout float | Nonereturnc |s|st d g }g }|r| | |r| | t t j ||| } || \ }}} t |p|p| S )N2must specify at least one of read=True, write=True) RuntimeErrorappendr selectr
)
r r r r rcheckwcheckfnrreadywreadyxreadys
c/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/urllib3/util/wait.pyselect_wait_for_socketr ! s Q QOPPP
F
F
d
d
7 7B R[[FFF *&*F + ++ c |s|st d d}|r|t j z }|r|t j z }t j | | dfd }t
|| S ) Nr r tr
r list[tuple[int, int]]c < | | dz } | S )Ni )poll)r poll_objs r do_pollz%poll_wait_for_socket..do_pollJ s# =
IA}}Q r )r r
r r )r r POLLINPOLLOUTr! registerr
)r r r r maskr# r" s @r poll_wait_for_socketr( 9 s Q QOPPP D
{}}H dD!!!
! !!r c t j } | d dS # t t f$ r Y dS w xY w)Nr TF)r r! AttributeErrorOSError)r" s r _have_working_pollr, R sT ;==
a t
G $ uus (, A Ac t rt an t t d rt
at | ||| S )Nr )r, r( wait_for_sockethasattrr r )r r r r s r r. r. _ sD 1. " " 10 4ug 6 66r 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 r. r r s r r r q s 4dG < < <r9 s " " " " " "
,
-8 , , , , ,4 " " " " "2
7 7 7 7 7$= = = = => > > > > > >r