a
iPL @ 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 krd
e
j_de
j_de
j_de
j_G dd deZG dd dedZG dd deZG dd deZG dd deZeed rG d d d eZeed rG d d! d!eZeed"r2G d#d$ d$eZ eed%rNG d&d' d'eZ d(d) Z e d%rfe Z n4e d rveZ n$e d"re Z ne d reZ neZ dS )* )ABCMetaabstractmethod)
namedtuple)MappingN c
C sd t | tr| }n:zt| }W n( tttfyH td| d Y n0 |dk r`td||S )NzInvalid file object: {!r}r zInvalid file descriptor: {})
isinstanceintfilenoAttributeError TypeError
ValueErrorformat)fileobjfd r !/usr/lib64/python3.9/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 Zdd Zdd Zdd Zdd Zd S )
_SelectorMappingc C s
|| _ d S N) _selector)selfselectorr r r __init__@ s z_SelectorMapping.__init__c C s t | jjS r )lenr
_fd_to_keyr r r r __len__C s z_SelectorMapping.__len__c C sB z| j |}| j j| W S ty< td|d Y n0 d S N{!r} is not registered)r _fileobj_lookupr KeyErrorr )r r r r r r __getitem__F s
z _SelectorMapping.__getitem__c C s t | jjS r )iterr r r! r r r __iter__M s z_SelectorMapping.__iter__N)__name__
__module__ __qualname__r r" r' r) r r r r r = s r c @ sj e Zd ZedddZedd ZdddZeddd Zd
d Zd d
Z edd Z
dd Z dd Z dS ) BaseSelectorNc C s t d S r NotImplementedErrorr r r r r r r register` s zBaseSelector.registerc C s t d S r r. )r r r r r
unregisterw s zBaseSelector.unregisterc C s | | | |||S r )r2 r1 r0 r r r modify s
zBaseSelector.modifyc C s t d S r r. )r timeoutr r r select s zBaseSelector.selectc C s d S r r r! r r r close s zBaseSelector.closec C sJ | }|d u rtdz
|| W S tyD td|d Y n0 d S )NzSelector is closedr$ )get_map RuntimeErrorr& r )r r mappingr r r get_key s
zBaseSelector.get_keyc C s t d S r r. r! r r r r7 s zBaseSelector.get_mapc C s | S r r r! r r r __enter__ s zBaseSelector.__enter__c G s | d S r )r6 )r argsr r r __exit__ s zBaseSelector.__exit__)N)N)N)
r* r+ r, r r1 r2 r3 r5 r6 r: r7 r; r= r r r r r- Q s
r- ) metaclassc @ sP e Zd Zdd 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 sL z
t |W S tyF | j D ] }|j|u r"|j Y S q" Y n0 d S r )r r
r valuesr r r r keyr r r r% s
z!_BaseSelectorImpl._fileobj_lookupNc C sb |r|t tB @ r td|t|| |||}|j| jv rRtd||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 rC r r r r1 s z_BaseSelectorImpl.registerc C s> z| j | |}W n" ty8 td|d Y n0 |S r# )r popr% r& r rB r r r r2 s
z _BaseSelectorImpl.unregisterc C s z| j | | }W n" ty6 td|d Y n0 ||jkr\| | | |||}n"||jkr~|j|d}|| j |j < |S )Nr$ )r )
r r% r& r r r2 r1 r _replacer rF r r r r3 s
z_BaseSelectorImpl.modifyc C s | j d | _d S r )r clearr@ r! r r r r6
s
z_BaseSelectorImpl.closec C s | j S r )r@ r! r r r r7 s z_BaseSelectorImpl.get_mapc C s& z | j | W S ty Y d S 0 d S r )r r& )r r r r r _key_from_fd s z _BaseSelectorImpl._key_from_fd)N)N) r* r+ r, r r% r1 r2 r3 r6 r7 rJ r r r r r? s
r? c s\ e Zd Z fddZd
fdd Z fddZejdkrDdd d
Zne j Zdd 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 )rL r1 rD rN addr rE rO rF rP r r r1 + s zSelectSelector.registerc s, t |}| j|j | j|j |S r )rL r2 rN discardr rO rB rP r r r2 3 s zSelectSelector.unregisterwin32c C s$ t ||||\}}}||| g fS r )r5 )r rw_r4 xr r r _select: s zSelectSelector._selectc C s |d u r d nt |d}g }z | | j| jg |\}}}W n tyN | Y S 0 t|}t|}||B D ]J}d}||v r|tO }||v r|tO }| |}|rh| |||j
@ f qh|S Nr ) maxrY rN rO InterruptedErrorrM rD rE rJ appendr ) r r4 readyrU rV rW r r rC r r r r5 @ s$
zSelectSelector.select)N)N)N) r* r+ r, r r1 r2 sysplatformrY r5
__classcell__r r rP r rK # s
rK c sZ e Zd ZdZdZdZ fddZd fdd Z fddZd
fdd Z dd
d Z
Z S )_PollLikeSelectorNc s t | | _d S r )rL r
_selector_clsr r! rP r r r \ s
z_PollLikeSelector.__init__c sl t |||}d}|t@ r&|| jO }|t@ r8|| jO }z| j|j| W n t | Y n0 |S rZ ) rL r1 rD _EVENT_READrE _EVENT_WRITEr r r2 )r r r r rC
poller_eventsrP r r r1 ` s
z_PollLikeSelector.registerc s6 t |}z| j|j W n ty0 Y n0 |S r )rL r2 r r OSErrorrB rP r r r2 n s z _PollLikeSelector.unregisterc s z| j | | }W n" ty6 t|dd Y n0 d}||jkrd}|t@ r\|| jO }|t@ rn|| jO }z| j |j
| W n t | Y n0 d}||j
krd}|r|j||d}|| j |j
< |S )Nz is not registeredFr T)r r )r r% r& r rD rd rE re r r3 r rL r2 r rH )r r r r rC changedselector_eventsrP r r r3 x s.
z_PollLikeSelector.modifyc C s |d u rd }n |dkr d}nt |d }g }z| j|}W n tyT | Y S 0 |D ]V\}}d}|| j @ rz|tO }|| j @ r|tO }| |}|rZ|
|||j @ f qZ|S )Nr @@) mathceilr pollr\ rd rE re rD rJ r] r )r r4 r^
fd_event_listr eventr rC r r r r5 s(
z_PollLikeSelector.select)N)N)N) r* r+ r, rc rd re r r1 r2 r3 r5 ra r r rP r rb V s
rb rm c @ s e Zd ZejZejZejZ dS ) PollSelectorN)
r* r+ r, r5 rm rc POLLINrd POLLOUTre r r r r rp s rp epollc s@ e Zd ZejZejZejZ dd Z
dddZ fddZ Z S )
EpollSelectorc C s
| j S r r r
r! r r r r
s zEpollSelector.filenoNc C s |d u rd}n |dkr d}nt |d d }tt| jd}g }z| j||}W n tyj | Y S 0 |D ]V\}}d}|tj @ r|t
O }|tj @ r|t O }|
|}|rp||||j@ f qp|S )Nr rj gMbP?r )rk rl r[ r r r rm r\ r5 EPOLLINrE EPOLLOUTrD rJ r] r ) r r4 max_evr^ rn r ro r rC r r r r5 s*
zEpollSelector.selectc s | j t d S r r r6 rL r! rP r r r6 s
zEpollSelector.close)N)
r* r+ r, r5 rs rc rw rd rx re r
r6 ra r r rP r rt s
rt devpollc s6 e Zd ZejZejZejZ dd Z
fddZ Z S )DevpollSelectorc C s
| j S r ru r! r r r r
s zDevpollSelector.filenoc s | j t d S r rz r! rP r r r6 s
zDevpollSelector.close)
r* r+ r, r5 r{ rc rq rd rr re r
r6 ra r r rP r r| s
r| kqueuec sT e Zd Z fddZdd Zd fdd Z fdd Zdd
d Z fd d
Z Z S )KqueueSelectorc s t t | _d S r )rL r r5 r} r r! rP r r r s
zKqueueSelector.__init__c C s
| j S r ru r! r r r r
s zKqueueSelector.filenoNc s t |||}z`|t@ r@t|jtjtj}| j |gdd |t
@ rnt|jtj tj}| j |gdd W n t | Y n0 |S rZ )
rL r1 rD r5 keventr KQ_FILTER_READZ KQ_EV_ADDr controlrE KQ_FILTER_WRITEr2 )r r r r rC kevrP r r r1 s zKqueueSelector.registerc s t |}|jt@ rTt|jtjtj}z| j
|gdd W n t yR Y n0 |jt @ rt|jtj
tj}z| j
|gdd W n t y Y n0 |S rZ )rL r2 r rD r5 r r r Z KQ_EV_DELETEr r rg rE r )r r rC r rP r r r2 s$
zKqueueSelector.unregisterc
C s |d u r d nt |d}t t| jd}g }z| jd ||}W n tyT | Y S 0 |D ]Z}|j}|j}d}|tj kr|t
O }|tj kr|t O }|
|} | rZ|| || j@ f qZ|S )Nr r )r[ r r r r r\ identfilterr5 r rD r rE rJ r] r )
r r4 ry r^ Zkev_listr r flagr rC r r r r5 * s&
zKqueueSelector.selectc s | j t d S r rz r! rP r r r6 C s
zKqueueSelector.close)N)N)
r* r+ r, r r
r1 r2 r5 r6 ra r r rP r r~ s
r~ c C sZ t t| d }|d u rdS z(| }| dkr4|d n| W dS tyT Y dS 0 d S )NFrm r T)getattrr5 rm r6 rg )methodr selector_objr r r _can_useH s r ) abcr r collectionsr collections.abcr rk r5 r_ rD rE r r __doc__ version_infor r r r r r- r? rK rb hasattrrp rt r| r~ r DefaultSelectorr r r r