3
PfR @ sz d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZmZ y
ej Z W n e
e fk
rh ejZ Y nX d(Z d)Z
dZe ZdaG dd deZdd Zejd*krd d Znd
d ZedddddgZG dd deZG dd deZeedrG dd deZeedr G dd d eZ eed r:G d d d eZ eed rVG d!d" d"eZ eedsfd#Zd$d% Z d&d' Z dS )+ N)
namedtupleMapping Tc s, e Zd Z fddZdd Zdd Z ZS )
SelectorErrorc s t t| j || _d S )N)superr __init__errno)selferrcode) __class__ /usr/lib/python3.6/selectors.pyr s zSelectorError.__init__c C s dj | jS )Nz)formatr )r r r r
__repr__" s zSelectorError.__repr__c C s | j S )N)r )r r r r
__str__% s zSelectorError.__str__)__name__
__module__ __qualname__r r r
__classcell__r r )r r
r s r c
C sd t | tr| }n:yt| j }W n( tttfk
rH tdj| Y nX |dk r`tdj||S )zl Return a file descriptor from a file object. If
given an integer will simply return that integer back. zInvalid file object: {0!r}r z Invalid file descriptor: {0})
isinstanceintfilenoAttributeError TypeError
ValueErrorr )fileobjfdr r r
_fileobj_to_fd) s
r c O sV y
| ||S t ttjfk
rP } z"d}t|dr8|j}t|W Y dd}~X nX dS )z This is the short-circuit version of the below logic
because in Python 3.5+ all system calls automatically restart
and recalculate their timeouts. Nr )OSErrorIOErrorselecterrorhasattrr r )func_argskwargser
r r r
_syscall_wrapper; s
r* c O sR |j dd}|dkr d}d}n t|}|dk r4d}n
t | }t|}|rZd|krZtdt}x|tkrLy| ||}W q` tttj fk
rH } zd}t
|dr|j }nt
|dr|j d }|t j
kpt
t d o|t jk} | r&|dk r$t }
|
|krtt jd
|r$d|kr$||
|d< w`|r6t|n W Y dd}~X q`X q`W |S ) z Wrapper function for syscalls that could fail due to EINTR.
All functions should be retried if there is time left in the timeout
in accordance with PEP 475. timeoutNFg z4Timeout must be in args or kwargs to be recalculatedr r' r WSAEINTR)r )getfloat monotoniclistr _SYSCALL_SENTINELr r! r" r# r$ r r' ZEINTRr, Z ETIMEDOUTr ) r% Zrecalc_timeoutr' r( r+ Zexpiresresultr) r
Z is_interruptZ current_timer r r
r* G sJ
SelectorKeyr r eventsdatac @ s0 e Zd ZdZdd Zdd Zdd Zdd Zd
S ) _SelectorMappingz* Mapping of file objects to selector keys c C s
|| _ d S )N) _selector)r Zselectorr r r
r s z_SelectorMapping.__init__c C s t | jjS )N)lenr7
_fd_to_key)r r r r
__len__ s z_SelectorMapping.__len__c C s@ y| j j|}| j j| S tk
r: tdj|Y nX d S )Nz{0!r} is not registered.)r7 _fileobj_lookupr9 KeyErrorr )r r r r r r
__getitem__ s
z _SelectorMapping.__getitem__c C s t | jjS )N)iterr7 r9 )r r r r
__iter__ s z_SelectorMapping.__iter__N)r r r __doc__r r: r= r? r r r r
r6 s
r6 c @ sv e Zd ZdZdd Zdd ZdddZd d
Zd d d Zd d
dZ dd Z
dd Z dd Z dd Z
dd Zdd ZdS ) BaseSelectora/ Abstract Selector class
A selector supports registering file objects to be monitored
for specific I/O events.
A file object is a file descriptor or any object with a
`fileno()` method. An arbitrary object can be attached to the
file object which can be used for example to store context info,
a callback, etc.
A selector can use various implementations (select(), poll(), epoll(),
and kqueue()) depending on the platform. The 'DefaultSelector' class uses
the most efficient implementation for the current platform.
c C s i | _ t| | _d S )N)r9 r6 _map)r r r r
r s zBaseSelector.__init__c C sH yt |S tk
rB x"| jj D ]}|j|kr$|jS q$W Y nX dS )aa Return a file descriptor from a file object.
This wraps _fileobj_to_fd() to do an exhaustive
search in case the object is invalid but we still
have it in our map. Used by unregister() so we can
unregister an object that was previously registered
even if it is closed. It is also used by _SelectorMapping
N)r r r9 valuesr r )r r keyr r r
r; s
z BaseSelector._fileobj_lookupNc C sd | s|t tB @ r"tdj|t|| j|||}|j| jkrTtdj||j|| j|j< |S )z8 Register a file object for a set of events to monitor. zInvalid events: {0!r}z${0!r} (FD {1}) is already registered)
EVENT_READ EVENT_WRITEr r r3 r; r r9 r< )r r r4 r5 rD r r r
register s zBaseSelector.registerc C s y| j j| j|}W n tk
r8 tdj|Y np tjk
r } zR|jtjkrZ n| j|kr| || j@ f|| j< q>|| j d }
| ||
B | j@ f|| j< q>W t|j S )Nr Tr )r` r8 r9 r* ru rx Zidentfilterr" rw rE ry rF rT r r4 r0 rC ) r r+ rr Z ready_fdsZ kevent_listrv r rh r4 rD Z
old_eventsr r r
r" s*
zKqueueSelector.selectc s | j j tt| j d S )N)ru rO r rt )r )r r r
rO s
zKqueueSelector.close)N)N) r r r r@ r r rG rJ r" rO r r r )r r
rt s
rt Fc C sZ y0| dkr t j }|jd ntt | j dS ttfk
rT } zdS d}~X nX dS )a
Checks that select structs can be allocated by the underlying
operating system, not just advertised by the select module. We don't
check select() because we'll be hopeful that most platforms that
don't have it available will not advertise it. (ie: GAE) rc r TFN)r" rc getattrrO r r )structpr) r r r
_can_allocate s r c C sP t dkrJtdrta n4tdr$ta n&tdr2ta nttdrBta ntdt S )z This function serves as a first call for DefaultSelector to
detect if the select module is being monkey-patched incorrectly
by eventlet, greenlet, and preserve proper behavior. Nrs rm rc r" z!Platform does not have a selector) _DEFAULT_SELECTORr rt rn rd r$ r" rW r r r r r
DefaultSelector5 s
r r rz )r r )!r ri r" rI sysZtime collectionsr r r/ r ImportErrorrE rF Z
HAS_SELECTobjectr1 r Exceptionr r version_infor* r3 r6 rA r$ rW rd rn rt r r r r r r
sH
8 1 4 B R