U cUh@sddlZddlZddlZddlmZzddlmZWn ek rTddlmZYnXdddgZGddde Z ej d krd d Z nd d Z dddZ dddZddZddZddadddZdddZdS)N)partial) monotonic)timeNoWayToWaitForSocketError wait_for_readwait_for_writec@s eZdZdS)rN)__name__ __module__ __qualname__r r ]/opt/bot/vods_filmes/script/venv/lib/python3.8/site-packages/pip/_vendor/urllib3/util/wait.pyrs)cCs||S)Nr )fntimeoutr r r _retry_on_intr*src Cs|dkrtd}n t|}z ||WSttjfk r}zF|jdtjkrRn.|t}|dkrhd}|tdkrxd}WYqW5d}~XYqXqdS)Ninfr)floatrOSErrorselecterrorargserrnoZEINTR)rrdeadlineer r r r/s     Fc Csd|s|stdg}g}|r&|||r4||ttj|||}t||\}}} t|p`|p`| S)N2must specify at least one of read=True, write=True) RuntimeErrorappendrrrbool) sockreadwriterZrcheckZwcheckrZrreadyZwreadyZxreadyr r r select_wait_for_socketFs  r"cs^|s|stdd}|r"|tjO}|r0|tjO}t||fdd}tt||S)Nrrcs|dk r|d9}|S)Ni)poll)tZpoll_objr r do_pollesz%poll_wait_for_socket..do_poll)rrPOLLINPOLLOUTr#registerrr)rr r!rmaskr&r r%r poll_wait_for_socketYs    r+cOs tddS)Nzno select-equivalent available)rrkwargsr r r null_wait_for_socketmsr.c Cs<zt}t|jdWnttfk r2YdSXdSdS)NrFT)rr#rAttributeErrorrr%r r r _have_working_pollqs r0cOs*tr tanttdrtantat||S)Nr)r0r+wait_for_sockethasattrrr"r.r,r r r r1~s  r1cCst|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 rr1rrr r r rscCst|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!rr3r4r r r rs)FFN)FFN)N)N)rrsys functoolsrrr ImportError__all__ Exceptionr version_inforr"r+r.r0r1rrr r r r s&