<6hddlZddlZddlZddlmZ ddlmZgdZGdde Z ejdk\rd Z nd Z dd Z dd Zd ZdZdaddZddZy#e$r ddlmZYLwxYw)N)partial) monotonic)time)NoWayToWaitForSocketError wait_for_readwait_for_writec eZdZy)rN)__name__ __module__ __qualname__b/var/www/panel.atabookie.online/venv/lib/python3.12/site-packages/pip/_vendor/urllib3/util/wait.pyrrsrr)c||SNr )fntimeouts r_retry_on_intrr*s '{rc"| td}n t|z} ||S#ttjf$rO}|j dt jk7r|tz }|dkrd}|tdk(rd}Yd}~md}~wwxYw)Ninfr)floatrOSErrorselecterrorargserrnoEINTR)rrdeadlinees rrr/s ?U|H {W,H '{"V\\* 66!9 +&4G{"#%,."& s&BAB  Bc|s |s tdg}g}|r|j||r|j|ttj|||}t ||\}}} t |xs|xs| S)N2must specify at least one of read=True, write=True) RuntimeErrorappendrrrbool) sockreadwriterrcheckwcheckrrreadywreadyxreadys rselect_wait_for_socketr/Fsy OPP F F  d  d  7B+B8FFF *&*F ++rc|s |s tdd}|r|tjz}|r|tjz}tjj ||fd}t t||S)Nr#rc4||dz}j|S)Ni)poll)tpoll_objs rdo_pollz%poll_wait_for_socket..do_polles = IA}}Qr)r$rPOLLINPOLLOUTr2registerr&r)r'r(r)rmaskr5r4s @rpoll_wait_for_socketr:Yso OPP D     {{}H dD! w0 11rctd)Nzno select-equivalent available)rrkwargss rnull_wait_for_socketr>ms #$D EErc tj}t|jdy#ttf$rYywxYw)NrTF)rr2rAttributeErrorr)r4s r_have_working_pollrAqs>;;=x}}a( G $s *-??cttrtanttdrt ant at|i|S)Nr)rAr:wait_for_sockethasattrrr/r>r<s rrCrC~s3 .  "0. D +F ++rct|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(rrCr'rs rrrs 4dG <rArCrrr rrrOs ' K  4v .,&2(F  ,=>Y'&'sA A'&A'