o
0iPL @ s d dl mZmZ d dlmZ d dlmZ d dlZd dlZd dl Z dZ
dZ dd Z ed g d
Z
d e
_e jd krHd
e
j_de
j_de
j_de
j_G dd deZG dd dedZG dd deZG dd deZG dd deZeed r~G d d d eZeed rG d d! d!eZeed"rG d#d$ d$eZ eed%rG d&d' d'eZ d(d) Z e d%re Z dS e d reZ dS e d"re Z dS e d reZ dS eZ dS )* )ABCMetaabstractmethod)
namedtuple)MappingN c
C sb t | tr | }nzt| }W n tttfy# td| d w |dk r/td||S )NzInvalid file object: {!r}r zInvalid file descriptor: {})
isinstanceintfilenoAttributeError TypeError
ValueErrorformat)fileobjfd r 0/opt/alt/python310/lib64/python3.10/selectors.py_fileobj_to_fd s
r SelectorKey)r 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 Zd Z dd Zdd Zdd Zdd Zd S )
_SelectorMappingc C s
|| _ d S N) _selector)selfselectorr r r __init__@
z_SelectorMapping.__init__c C t | jjS r )lenr
_fd_to_keyr r r r __len__C z_SelectorMapping.__len__c C s: z
| j |}| j j| W S ty td|d w N{!r} is not registered)r _fileobj_lookupr" KeyErrorr )r r r r r r __getitem__F s z _SelectorMapping.__getitem__c C r r )iterr r" r# r r r __iter__M r% z_SelectorMapping.__iter__N)__name__
__module__ __qualname__r r$ r* r, r r r r r = s r c @ sl e Zd Z edddZedd ZdddZeddd Zd
d Zd d
Z edd Z
dd Z dd Z dS ) BaseSelectorNc C t r NotImplementedErrorr r r r r r r register` s zBaseSelector.registerc C r1 r r2 )r r r r r
unregisterw zBaseSelector.unregisterc C s | | | |||S r )r6 r5 r4 r r r modify s
zBaseSelector.modifyc C r1 r r2 )r timeoutr r r select r7 zBaseSelector.selectc C s d S r r r# r r r close s zBaseSelector.closec C sD | }|d u r
tdz|| W S ty! td|d w )NzSelector is closedr' )get_map RuntimeErrorr) r )r r mappingr r r get_key s
zBaseSelector.get_keyc C r1 r r2 r# r r r r< s zBaseSelector.get_mapc C s | S r r r# r r r __enter__ s zBaseSelector.__enter__c G s | d S r )r; )r argsr r r __exit__ r% zBaseSelector.__exit__r )
r- r. r/ r r5 r6 r8 r: r; r? r< r@ rB r r r r r0 Q s
r0 ) metaclassc @ sR e Zd Z dd Zdd ZdddZdd Zdd
d Zd d
Zdd Z dd Z
dS )_BaseSelectorImplc C s i | _ t| | _d S r )r" r _mapr# r r r r s z_BaseSelectorImpl.__init__c C sF zt |W S ty" | j D ]}|j|u r |j Y S q w r )r r
r" valuesr r r r keyr r r r( s
z!_BaseSelectorImpl._fileobj_lookupNc C sb |r |t tB @ rtd|t|| |||}|j| jv r)td||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 rH r r r r5 s
z_BaseSelectorImpl.registerc C s8 z | j | |}W |S ty td|d w r& )r" popr( r) r rG r r r r6 s z _BaseSelectorImpl.unregisterc C s z
| j | | }W n ty td|d w ||jkr-| | | |||}|S ||jkr>|j|d}|| j |j < |S )Nr' )r )
r" r( r) r r r6 r5 r _replacer rK r r r r8 s
z_BaseSelectorImpl.modifyc C s | j d | _d S r )r" clearrE r# r r r r;
s
z_BaseSelectorImpl.closec C s | j S r )rE r# r r r r< s z_BaseSelectorImpl.get_mapc C s$ z| j | W S ty Y d S w r )r" r) )r r r r r _key_from_fd s z _BaseSelectorImpl._key_from_fdr ) r- r. r/ r r( r5 r6 r8 r; r< rO r r r r rD s
rD c s^ e Zd Z fddZd
fdd Z fddZejdkr#d
d d
Zne j Zd
d d Z Z
S )SelectSelectorc s t t | _t | _d S r )superr set_readers_writersr# __class__r r r & s
zSelectSelector.__init__Nc s@ t |||}|t@ r| j|j |t@ r | j|j |S r )rQ r5 rI rS addr rJ rT rK rU r r r5 + s zSelectSelector.registerc s, t |}| j|j | j|j |S r )rQ r6 rS discardr rT rG rU r r r6 3 s zSelectSelector.unregisterZwin32c C s$ t ||||\}}}||| g fS r )r: )r rw_r9 xr r r _select: s zSelectSelector._selectc C s |d u rd nt |d}g }z| | j| jg |\}}}W n ty' | Y S w t|}t|}||B D ]%}d}||v r@|tO }||v rH|tO }| |}|rY| |||j
@ f q4|S Nr ) maxr] rS rT InterruptedErrorrR rI rJ rO appendr ) r r9 readyrY rZ r[ r r rH r r r r: @ s(
zSelectSelector.selectr ) r- r. r/ r r5 r6 sysplatformr] r:
__classcell__r r rU r rP # s
rP c s\ e Zd Z dZdZdZ fddZd fdd Z fddZd fdd Z d d
d Z
Z S )
_PollLikeSelectorNc s t | | _d S r )rQ r
_selector_clsr r# rU r r r \
z_PollLikeSelector.__init__c sd t |||}d}|t@ r|| jO }|t@ r || jO }z | j|j| W |S t | r^ ) rQ r5 rI _EVENT_READrJ _EVENT_WRITEr r r6 )r r r r rH Z
poller_eventsrU r r r5 ` s
z_PollLikeSelector.registerc s6 t |}z
| j|j W |S ty Y |S w r )rQ r6 r r OSErrorrG rU r r r6 n s z _PollLikeSelector.unregisterc s z
| j | | }W n ty t|dd w d}||jkrLd}|t@ r,|| jO }|t@ r5|| jO }z
| j |j
| W n
t | d}||j
krSd}|rb|j||d}|| j |j
< |S )Nz is not registeredFr T)r r )r" r( r) r rI ri rJ rj r r8 r rQ r6 r rM )r r r r rH ZchangedZselector_eventsrU r r r8 x s0
z_PollLikeSelector.modifyc C s |d u rd }n|dkrd}nt |d }g }z| j|}W n ty* | Y S w |D ]+\}}d}|| j @ r=|tO }|| j @ rG|tO }| |}|rX|
|||j @ f q-|S )Nr @@) mathceilr pollr` ri rJ rj rI rO ra r )r r9 rb
fd_event_listr eventr rH r r r r: s,
z_PollLikeSelector.selectr ) r- r. r/ rg ri rj r r5 r6 r8 r: re r r rU r rf V s
rf ro c @ s e Zd Z ejZejZejZ dS ) PollSelectorN)
r- r. r/ r: ro rg POLLINri POLLOUTrj r r r r rr s
rr epollc sB e Zd Z ejZejZejZ dd Z
dddZ fddZ Z S )
EpollSelectorc C
| j S r r r
r# r r r r
r zEpollSelector.filenoNc C s |d u rd}n|dkrd}n t |d d }tt| jd}g }z | j||}W n ty5 | Y S w |D ]+\}}d}|tj @ rH|t
O }|tj @ rR|t O }|
|}|rc||||j@ f q8|S )Nr rl gMbP?r )rm rn r_ r! r" r ro r` r: EPOLLINrJ EPOLLOUTrI rO ra r ) r r9 max_evrb rp r rq r rH r r r r: s.
zEpollSelector.selectc | j t d S r r r; rQ r# rU r r r; rh zEpollSelector.closer )
r- r. r/ r: ru rg rz ri r{ rj r
r; re r r rU r rv s
rv devpollc s8 e Zd Z ejZejZejZ dd Z
fddZ Z S )DevpollSelectorc C rw r rx r# r r r r
r zDevpollSelector.filenoc r} r r~ r# rU r r r; rh zDevpollSelector.close)
r- r. r/ r: r rg rs ri rt rj r
r; re r r rU r r s r kqueuec sV e Zd Z fddZdd Zd fdd Z fdd Zdd
d Z fd d
Z Z S )KqueueSelectorc s t t | _d S r )rQ r r: r r r# rU r r r rh zKqueueSelector.__init__c C rw r rx r# r r r r
r zKqueueSelector.filenoNc s t |||}z4|t@ r t|jtjtj}| j |gdd |t
@ r:t|jtj tj}| j |gdd W |S W |S t | r^ )
rQ r5 rI r: keventr KQ_FILTER_READZ KQ_EV_ADDr controlrJ KQ_FILTER_WRITEr6 )r r r r rH kevrU r r r5 s$ zKqueueSelector.registerc s t |}|jt@ r*t|jtjtj}z | j
|gdd W n t y) Y nw |jt @ rPt|jtj
tj}z | j
|gdd W |S t yO Y |S w |S r^ )rQ r6 r rI r: r r r Z KQ_EV_DELETEr r rk rJ r )r r rH r rU r r r6 s,
zKqueueSelector.unregisterc
C s |d u rd nt |d}t t| jd}g }z
| jd ||}W n ty* | Y S w |D ]-}|j}|j}d}|tj kr@|t
O }|tj krI|t O }|
|} | rZ|| || j@ f q-|S )Nr r )r_ r! r" r r r` Zidentfilterr: r rI r rJ rO ra r )
r r9 r| rb Zkev_listr r flagr rH r r r r: * s*
zKqueueSelector.selectc r} r r~ r# rU r r r; C rh zKqueueSelector.closer )
r- r. r/ r r
r5 r6 r: r; re r r rU r r s
r c C s\ t t| d }|d u r
dS z| }| dkr |d W dS | W dS ty- Y dS w )NFro r T)getattrr: ro r; rk )methodr Z selector_objr r r _can_useH s
r ) abcr r collectionsr Zcollections.abcr rm r: rc rI rJ r r __doc__ version_infor r r r r r0 rD rP rf hasattrrr rv r r r ZDefaultSelectorr r r r sP
~T3
Z
.
M