U
|
ý°dG ã @ s² d dl mZ d dlZd dlZd dlmZ ddgZddddd dd
|
d d Zddddd dd
|
d dZddddZ ddddd dd
|
dda
|
ddd ddddZ ddd ddddZ dS ) é )Ú annotationsN)ÚpartialÚ wait_for_readÚwait_for_writeFz socket.socketÚboolú float | None)ÚsockÚreadÚwriteÚtimeoutÚreturnc
|
C sb |s|st dg }g }|r&| | ¡ |r4| | ¡ ttj|||}||\}}} t|p^|p^| S )Nú2must specify at least one of read=True, write=True)Ú RuntimeErrorÚappendr Úselectr )
|
r r r
|
r ÚrcheckÚwcheckÚfnÚrreadyÚwreadyÚxready© r úHd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\urllib3/util/wait.pyÚselect_wait_for_socket! s
|
|
r c sd |s|st dd}|r"|tjO }|r0|tjO }t ¡ | |¡ ddd fdd }t||S )Nr r r zlist[tuple[int, int]])Útr c s | d k r| d9 } | ¡S )Niè )Úpoll)r ©Úpoll_objr r Údo_pollJ s z%poll_wait_for_socket.<locals>.do_poll)r r ÚPOLLINÚPOLLOUTr Úregisterr )r r r
|
r Úmaskr r r r Úpoll_wait_for_socket9 s
|
|
r# )r c C s: zt ¡ } | d¡ W n ttfk
|
r0 Y dS X dS d S )Nr FT)r r ÚAttributeErrorÚOSErrorr r r r Ú_have_working_pollR s r& c C s( t r tanttdrtat| |||S )Nr )r& r# Úwait_for_socketÚhasattrr r )r r r
|
r r r r r' _ s
|
|
r' )r r r c C s t | 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 r ©r' ©r r r r r r q s c C s t | 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
|
r r) r* r r r r x s )FFN)FFN)FFN)N)N) Ú
|
__future__r r ÚsocketÚ functoolsr Ú__all__r r# r& r' r r r r r r Ú<module> s& ü ü ü
|
