آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ U طص`م@sذddlZddlZddlZddlmZzddlmZWn ek rTddlmZYnXdddgZGdd„de ƒZ ejd kr„d d„Zndd„Zddd„Z ddd„Zdd„Zdd„Zdd„addd„Zddd„ZdS)éN)عpartial)ع monotonic)عtimeعNoWayToWaitForSocketErrorع wait_for_readعwait_for_writec@seZdZdS)rN)ع__name__ع __module__ع__qualname__©rrْB/opt/alt/python38/lib/python3.8/site-packages/urllib3/util/wait.pyrs)éécCs||ƒS)Nr)عfnعtimeoutrrrع_retry_on_intr*src Csک|dkrtdƒ}n tƒ|}z ||ƒWSttjfk rگ}zF|jdtjkrR‚n.|tƒ}|dkrhd}|tdƒkrxd}WY¢qW5d}~XYqXqdS)Nعinfr)عfloatrعOSErrorعselectعerrorعargsعerrnoZEINTR)rrZdeadlineعerrrr0s Fc Csd|s|stdƒ‚g}g}|r&| |،|r4| |،ttj|||ƒ}t||ƒ\}}} t|p`|p`| ƒS)Nْ2must specify at least one of read=True, write=True)عRuntimeErrorعappendrrrعbool) عsockعreadعwriterZrcheckZwcheckrZrreadyZwreadyZxreadyrrrعselect_wait_for_socketGs r!cs^|s|stdƒ‚d}|r"|tjO}|r0|tjO}t ،‰ˆ ||،‡fdd„}tt||ƒƒS)Nrrcs|dk r|d9}ˆ |،S)Niè)عpoll)عt©Zpoll_objrrعdo_pollfsz%poll_wait_for_socket..do_poll)rrعPOLLINعPOLLOUTr"عregisterrr)rrr rعmaskr%rr$rعpoll_wait_for_socketZs r*cOstdƒ‚dS)Nzno select-equivalent available)r©rعkwargsrrrعnull_wait_for_socketnsr-c Cs<zt ،}t|jdƒWnttfk r2YdSXdSdS)NrFT)rr"rعAttributeErrorrr$rrrع_have_working_pollrsr/cOs*tƒrtanttdƒrtantat||ژS)Nr)r/r*عwait_for_socketعhasattrrr!r-r+rrrr0s r0cCst|d|dچS)z†Waits for reading to be available on a given socket. Returns True if the socket is readable, or False if the timeout expired. T)rr©r0©rrrrrrژscCst|d|dچS)z†Waits for writing to be available on a given socket. Returns True if the socket is readable, or False if the timeout expired. T)r rr2r3rrrr•s)FFN)FFN)N)N)rrعsysع functoolsrrrعImportErrorع__all__ع Exceptionrعversion_inforr!r*r-r/r0rrrrrrعs&