3
nf\ @ s d dl Z d dlmZ d dlZd dlZyd dlmZ W n ek
rT d dlmZ Y nX dddgZG dd de Z
ej dkrd d Z nd
d Z d ddZ
d ddZdd Zdd Zdd ad ddZd ddZdS ) N)partial) monotonic)timeNoWayToWaitForSocketError
wait_for_readwait_for_writec @ s e Zd ZdS )r N)__name__
__module__ __qualname__ r r /usr/lib/python3.6/wait.pyr
s c C s | |S )Nr )fntimeoutr r r _retry_on_intr) s r c C s |d krt d}n
t | }xry| |S ttjfk
r } zB|jd tjkrR n(|t }|dk rhd}|t dkrxd }w W Y d d }~X q X q W d S )Ninfr )floatr OSErrorselecterrorargserrnoZEINTR)r r Zdeadlineer r r r - s
Fc
C sh | r| rt dg }g }|r*|j| |r8|j| ttj|||}t||\}}} t|pd|pd| S )Nz2must specify at least one of read=True, write=True) RuntimeErrorappendr r r bool)
sockreadwriter ZrcheckZwcheckr ZrreadyZwreadyZxreadyr r r select_wait_for_socketD s
r c sb | r| rt dd}|r&|tjO }|r4|tjO }tj j| | fdd}tt||S )Nz2must specify at least one of read=True, write=Truer c s | d k r| d9 } j | S )Ni )poll)t)poll_objr r do_pollc s z%poll_wait_for_socket..do_poll)r r ZPOLLINZPOLLOUTr! registerr r )r r r r maskr$ r )r# r poll_wait_for_socketW s
r' c O s t dd S )Nz no select-equivalent available)r )r kwargsr r r null_wait_for_socketk s r) c C s: yt j } t| jd W n ttfk
r0 dS X dS d S )Nr FT)r r! r AttributeErrorr )r# r r r _have_working_pollo s r+ c O s* t r tanttdr tantat| |S )Nr )r+ r' wait_for_sockethasattrr r r) )r r( r r r r, | s
r, c C s t | d|dS )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)r r )r, )r r r r r r s c C s t | d|dS )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 r )r, )r r r r r r s )r
r )FFN)FFN)N)N)r functoolsr r sysr r ImportError__all__ Exceptionr version_infor r r' r) r+ r, r r r r r r s&