eɯ\ddlmZddlZddlZddlmZddgZ dddZ dddZddZ ddda dddZ dddZ dS)) annotationsN)partial wait_for_readwait_for_writeFsock socket.socketreadboolwritetimeout float | Nonereturnc|s|stdg}g}|r|||r||ttj|||}||\}}} t |p|p| S)N2must specify at least one of read=True, write=True) RuntimeErrorappendrselectr ) rr r r rcheckwcheckfnrreadywreadyxreadys /srv/buildsys-work-dir/castor/build_node/builder-2/WGSG1/unpkd_srcs/cloudlinux-venv-1.0.6/venv/lib/python3.11/site-packages/urllib3/util/wait.pyselect_wait_for_socketr!s QQOPPP F F  d  d  7 7BR[[FFF *&*F + ++c|s|stdd}|r|tjz}|r|tjz}tj||dfd }t ||S) Nrrtr rlist[tuple[int, int]]c<||dz}|S)Ni)poll)rpoll_objs rdo_pollz%poll_wait_for_socket..do_pollJs# = IA}}Qr)rr rr)rrPOLLINPOLLOUTr!registerr )rr r r maskr#r"s @rpoll_wait_for_socketr(9s QQOPPP D     {}}H dD!!!        ! !!rc tj}|ddS#ttf$rYdSwxYw)NrTF)rr!AttributeErrorOSError)r"s r_have_working_pollr,RsT;== at G $uus(,AActrtanttdrt at||||S)Nr)r,r(wait_for_sockethasattrrr)rr r r s rr.r._sD1.  " "10 4ug 6 66rc&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.rr s rrrqs 4dG < < <r9s""""""  , -8 ,,,,,4 """""2     77777$=====>>>>>>>r