]K @ s$ d d l m Z m Z d d l m Z m Z d d l Z d d l Z d d l Z d( Z d) Z
d d Z e d d d d
d g Z d e _
e j d* k r d e j _
d e j _
d e j _
d e j _
Gd d d e Z Gd d d d e Z Gd d d e Z Gd d d e Z e e d rKGd d d e Z e e d rpGd d! d! e Z e e d" rGd# d$ d$ e Z e e d% rGd& d' d' e Z d' e k re Z nN d! e k re Z n6 d$ e k re Z n d e k re Z n e Z d S)+ )ABCMetaabstractmethod)
namedtupleMappingN c
C s t | t r | } nL y t | j } Wn3 t t t f k
rc t d j | d Yn X| d k r t d j | | S)NzInvalid file object: {!r}r zInvalid file descriptor: {})
isinstanceintfilenoAttributeError TypeError
ValueErrorformat)fileobjfd r ./opt/alt/python35/lib64/python3.5/selectors.py_fileobj_to_fd s r SelectorKeyr r eventsdatazSelectorKey(fileobj, fd, events, data)
Object used to associate a file object to its backing
file descriptor, selected event mask, and attached data.
zFile object registered.zUnderlying file descriptor.z3Events that must be waited for on this file object.zzOptional opaque data associated to this file object.
For example, this could be used to store a per-client session ID.c @ s@ e Z d Z d d Z d d Z d d Z d d Z d S)
_SelectorMappingc C s
| | _ d S)N) _selector)selfselectorr r r __init__> s z_SelectorMapping.__init__c C s t | j j S)N)lenr
_fd_to_key)r r r r __len__A s z_SelectorMapping.__len__c C sU y$ | j j | } | j j | SWn* t k
rP t d j | d Yn Xd S)Nz{!r} is not registered)r _fileobj_lookupr KeyErrorr
)r r r r r r __getitem__D s
z _SelectorMapping.__getitem__c C s t | j j S)N)iterr r )r r r r __iter__K s z_SelectorMapping.__iter__N)__name__
__module__ __qualname__r r r" r$ r r r r r ; s r c @ s e Z d Z e d d d Z e d d Z d d d Z e d d d Z d
d Z d d
Z e d d Z
d d Z d d Z d S) BaseSelectorNc C s
t d S)N)NotImplementedError)r r r r r r r register^ s zBaseSelector.registerc C s
t d S)N)r) )r r r r r
unregisteru s zBaseSelector.unregisterc C s | j | | j | | | S)N)r+ r* )r r r r r r r modify s
zBaseSelector.modifyc C s
t d S)N)r) )r timeoutr r r select s zBaseSelector.selectc C s d S)Nr )r r r r close s zBaseSelector.closec C sa | j } | d k r$ t d y | | SWn* t k
r\ t d j | d Yn Xd S)NzSelector is closedz{!r} is not registered)get_map RuntimeErrorr! r
)r r mappingr r r get_key s
zBaseSelector.get_keyc C s
t d S)N)r) )r r r r r0 s zBaseSelector.get_mapc C s | S)Nr )r r r r __enter__ s zBaseSelector.__enter__c G s | j d S)N)r/ )r argsr r r __exit__ s zBaseSelector.__exit__)
r% r& r' r r* r+ r, r. r/ r3 r0 r4 r6 r r r r r( O s r( metaclassc @ sv e Z d Z d d Z d d Z d d d Z d d Z d d
d Z d d
Z d d Z d d Z
d S)_BaseSelectorImplc C s i | _ t | | _ d S)N)r r _map)r r r r r s z_BaseSelectorImpl.__init__c C sZ y t | SWnE t k
rU x- | j j D] } | j | k r. | j Sq. W Yn Xd S)N)r r r valuesr r )r r keyr r r r s
z!_BaseSelectorImpl._fileobj_lookupNc C s | s | t t B@r+ t d j | t | | j | | | } | j | j k rv t d j | | j | | j | j <| S)NzInvalid events: {!r}z"{!r} (FD {}) is already registered)
EVENT_READ EVENT_WRITEr r
r r r r r! )r r r r r; r r r r* s z_BaseSelectorImpl.registerc C sP y | j j | j | } Wn* t k
rK t d j | d Yn X| S)Nz{!r} is not registered)r popr r! r
)r r r; r r r r+ s
z _BaseSelectorImpl.unregisterc C s y | j | j | } Wn* t k
rF t d j | d Yn X| | j k r{ | j | | j | | | } n1 | | j k r | j d | } | | j | j <| S)Nz{!r} is not registeredr )
r r r! r
r r+ r* r _replacer )r r r r r; r r r r, s
z_BaseSelectorImpl.modifyc C s | j j d | _ d S)N)r clearr9 )r r r r r/ s
z_BaseSelectorImpl.closec C s | j S)N)r9 )r r r r r0 s z_BaseSelectorImpl.get_mapc C s, y | j | SWn t k
r' d SYn Xd S)N)r r! )r r r r r _key_from_fd s
z _BaseSelectorImpl._key_from_fd) r% r& r' r r r* r+ r, r/ r0 rA r r r r r8 s
r8 c s e Z d Z f d d Z d f d d Z f d d Z e j d k rf d d d
Z n e j Z d d d Z S)
SelectSelectorc s) t j t | _ t | _ d S)N)superr set_readers_writers)r ) __class__r r r % s
zSelectSelector.__init__Nc sV t j | | | } | t @r5 | j j | j | t @rR | j j | j | S)N)rC r* r< rE addr r= rF )r r r r r; )rG r r r* * s
zSelectSelector.registerc s< t j | } | j j | j | j j | j | S)N)rC r+ rE discardr rF )r r r; )rG r r r+ 2 s zSelectSelector.unregisterwin32c C s2 t j | | | | \ } } } | | | g f S)N)r. )r rw_r- xr r r _select9 s !zSelectSelector._selectc
C s | d k r d n t | d } g } y+ | j | j | j g | \ } } } Wn t k
rj | SYn Xt | } t | } xs | | BD]g } d } | | k r | t O} | | k r | t O} | j | } | r | j | | | j
@f q W| S)Nr ) maxrO rE rF InterruptedErrorrD r< r= rA appendr ) r r- readyrK rL rM r r r; r r r r. ? s$ !+
zSelectSelector.select)
r% r& r' r r* r+ sysplatformrO r. r r )rG r rB " s rB pollc sX e Z d Z f d d Z d f d d Z f d d Z d d d Z S)
PollSelectorc s t j t j | _ d S)N)rC r r. rV _poll)r )rG r r r Z s
zPollSelector.__init__Nc sf t j | | | } d } | t @r5 | t j O} | t @rL | t j O} | j j | j | | S)Nr ) rC r* r< r. POLLINr= POLLOUTrX r )r r r r r; poll_events)rG r r r* ^ s
zPollSelector.registerc s) t j | } | j j | j | S)N)rC r+ rX r )r r r; )rG r r r+ h s zPollSelector.unregisterc
C s | d k r d } n( | d k r* d } n t j | d } g } y | j j | } Wn t k
rq | SYn Xxy | D]q \ } } d } | t j @r | t O} | t j @r | t O} | j
| } | ry | j | | | j @f qy W| S)Nr g @@)
mathceilrX rV rQ r. rY r= rZ r< rA rR r )r r- rS
fd_event_listr eventr r; r r r r. m s(
zPollSelector.select)r% r& r' r r* r+ r. r r )rG r rW W s
rW epollc sv e Z d Z f d d Z d d Z d f d d Z f d d Z d d
d Z f d d
Z S)
EpollSelectorc s t j t j | _ d S)N)rC r r. r` _epoll)r )rG r r r s
zEpollSelector.__init__c C s
| j j S)N)rb r )r r r r r s zEpollSelector.filenoNc s t j | | | } d } | t @r5 | t j O} | t @rL | t j O} y | j j | j | Wn% t k
r t j
| Yn X| S)Nr ) rC r* r< r. EPOLLINr= EPOLLOUTrb r
BaseExceptionr+ )r r r r r; epoll_events)rG r r r* s
zEpollSelector.registerc sB t j | } y | j j | j Wn t k
r= Yn X| S)N)rC r+ rb r OSError)r r r; )rG r r r+ s
zEpollSelector.unregisterc
C s | d k r d } n, | d k r* d } n t j | d d } t t | j d } g } y | j j | | } Wn t k
r | SYn Xxy | D]q \ } } d } | t j @r | t
O} | t j @r | t O} | j
| } | r | j | | | j @f q W| S)Nr r g @@gMbP?)r\ r] rP r r rb rV rQ r. rc r= rd r< rA rR r ) r r- max_evrS r^ r r_ r r; r r r r. s*
zEpollSelector.selectc s | j j t j d S)N)rb r/ rC )r )rG r r r/ s
zEpollSelector.close) r% r& r' r r r* r+ r. r/ r r )rG r ra s
ra devpollc sv e Z d Z f d d Z d d Z d f d d Z f d d Z d d
d Z f d d
Z S)DevpollSelectorc s t j t j | _ d S)N)rC r r. rj _devpoll)r )rG r r r s
zDevpollSelector.__init__c C s
| j j S)N)rl r )r r r r r s zDevpollSelector.filenoNc sf t j | | | } d } | t @r5 | t j O} | t @rL | t j O} | j j | j | | S)Nr ) rC r* r< r. rY r= rZ rl r )r r r r r; r[ )rG r r r* s
zDevpollSelector.registerc s) t j | } | j j | j | S)N)rC r+ rl r )r r r; )rG r r r+ s zDevpollSelector.unregisterc
C s | d k r d } n( | d k r* d } n t j | d } g } y | j j | } Wn t k
rq | SYn Xxy | D]q \ } } d } | t j @r | t O} | t j @r | t O} | j
| } | ry | j | | | j @f qy W| S)Nr g @@)
r\ r] rl rV rQ r. rY r= rZ r< rA rR r )r r- rS r^ r r_ r r; r r r r. s(
zDevpollSelector.selectc s | j j t j d S)N)rl r/ rC )r )rG r r r/ s
zDevpollSelector.close) r% r& r' r r r* r+ r. r/ r r )rG r rk s
rk kqueuec sv e Z d Z f d d Z d d Z d f d d Z f d d Z d d
d Z f d d
Z S)KqueueSelectorc s t j t j | _ d S)N)rC r r. rm _kqueue)r )rG r r r s
zKqueueSelector.__init__c C s
| j j S)N)ro r )r r r r r s zKqueueSelector.filenoNc s t j | | | } y | t @r\ t j | j t j t j } | j j | g d d | t
@r t j | j t j t j } | j j | g d d Wn% t k
r t j
| Yn X| S)Nr )rC r* r< r. keventr KQ_FILTER_READZ KQ_EV_ADDro controlr= KQ_FILTER_WRITEre r+ )r r r r r; kev)rG r r r* s
zKqueueSelector.registerc s t j | } | j t @ro t j | j t j t j } y | j j
| g d d Wn t k
rn Yn X| j t @r t j | j t j
t j } y | j j
| g d d Wn t k
r Yn X| S)Nr )rC r+ r r< r. rp r rq Z KQ_EV_DELETEro rr rg r= rs )r r r; rt )rG r r r+ ' s
zKqueueSelector.unregisterc
C s | d k r d n t | d } t | j } g } y | j j d | | } Wn t k
rj | SYn Xx | D] } | j } | j } d } | t j k r | t
O} | t j k r | t O} | j
| } | rr | j | | | j @f qr W| S)Nr )rP r r ro rr rQ identfilterr. rq r< rs r= rA rR r )
r r- ri rS Zkev_listrt r flagr r; r r r r. < s& !
zKqueueSelector.selectc s | j j t j d S)N)ro r/ rC )r )rG r r r/ R s
zKqueueSelector.close) r% r& r' r r r* r+ r. r/ r r )rG r rn
s rn r )r r ) abcr r collectionsr r r\ r. rT r< r= r r __doc__ version_infor r r r r r( r8 rB hasattrrW ra rk rn globalsDefaultSelectorr r r r sF ~U31G8M