U
fG @ 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_readwait_for_writeFz
socket.socketbool float | None)sockreadwritetimeoutreturnc
C sb |s|st dg }g }|r&|| |r4|| ttj|||}||\}}} t|p^|p^| S )N2must specify at least one of read=True, write=True) RuntimeErrorappendr selectr )
r r r
r rcheckwcheckfnrreadywreadyxready r B/opt/alt/python38/lib/python3.8/site-packages/urllib3/util/wait.pyselect_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..do_poll)r r POLLINPOLLOUTr 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 AttributeErrorOSErrorr r r r _have_working_pollR s r& c C s( t r tanttdrtat| |||S )Nr )r& r# wait_for_sockethasattrr 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 s&