a *Na@sddlZddlZddlZddlmZzddlmZWneyRddlmZYn0gdZGddde Z ej dkrd d Z nd d Z dd dZ dddZddZddZddadddZdddZdS)N)partial) monotonic)time)NoWayToWaitForSocketError wait_for_readwait_for_writec@s eZdZdS)rN)__name__ __module__ __qualname__r r l/private/var/folders/js/6pj4vh5d4zd0k6bxv74qrbhr0000gr/T/pip-target-22xwyzbs/lib/python/urllib3/util/wait.pyrsr)cCs||S)Nr )fntimeoutr r r _retry_on_intr*src Cs|durtd}n t|}z ||WSttjfy}zR|jdtjkrPn2|t}|dkrfd}|tdkrvd}WYd}~qWYd}~qd}~00qdS)Ninfr)floatrOSErrorselecterrorargserrnoZEINTR)rrdeadlineer r r r0s     Fc Csd|s|stdg}g}|r&|||r4||ttj|||}t||\}}} t|p`|p`| S)N2must specify at least one of read=True, write=True) RuntimeErrorappendrrrbool) sockreadwriterrcheckwcheckrrreadywreadyxreadyr r r select_wait_for_socketGs  r'cs^|s|stdd}|r"|tjO}|r0|tjO}t||fdd}tt||S)Nrrcs|dur|d9}|S)Ni)poll)tpoll_objr r do_pollfsz%poll_wait_for_socket..do_poll)rrPOLLINPOLLOUTr(registerrr)rr r!rmaskr,r r*r poll_wait_for_socketZs    r1cOs tddS)Nzno select-equivalent available)rrkwargsr r r null_wait_for_socketnsr4c Cs:zt}t|jdWnttfy0YdS0dSdS)NrFT)rr(rAttributeErrorrr*r r r _have_working_pollrs r6cOs.tr tanttdrtantat|i|S)Nr)r6r1wait_for_sockethasattrrr'r4r2r r r r7s  r7cCst|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 rr7rrr r r rsrcCst|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!rr9r:r r r rsr)FFN)FFN)N)N)rrsys functoolsrrr ImportError__all__ Exceptionr version_inforr'r1r4r6r7rrr r r r s&