֦iL r d dl mZmZ d dlmZ d dlmZ d dlZd dlZd dl Z dZ
dZ d Z edg d Z
d
e
_ d e
j _ d e
j _ d
e
j" _ de
j$ _ G d de Z G d de Z G d de Z G d de Z G d de Z eed r G d d e Z eed r G d d e Z eed r G d! d"e Z eed# r G d$ d%e Z d& Z e d# re Z y e d reZ y e d reZ y e d reZ yeZ y)' )ABCMetaabstractmethod)
namedtuple)MappingN c t | t r| }n t | j }|dk rt dj
| |S # t t t
f$ r t dj
| d w xY w)NzInvalid file object: {!r}r zInvalid file descriptor: {})
isinstanceintfilenoAttributeError TypeError
ValueErrorformat)fileobjfds "/usr/lib64/python3.12/selectors.py_fileobj_to_fdr s
'3
?W^^%&B
Av6==bABB
I :6 ? $$*F7O5:>
? ?s A 0B 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.zvOptional opaque data associated to this file object.
For example, this could be used to store a per-client session ID.c & e Zd Z d Zd Zd Zd Zy)_SelectorMappingc || _ y N) _selector)selfselectors r __init__z_SelectorMapping.__init__? s ! c @ t | j j S r )lenr
_fd_to_keyr s r __len__z_SelectorMapping.__len__B s 4>>,,--r c | j j | }| j j | S # t $ r t dj | d w xY wN{!r} is not registered)r _fileobj_lookupr# KeyErrorr )r r r s r __getitem__z _SelectorMapping.__getitem__E s[ O //8B>>,,R0 0 O3::7CD$ N Os 36 %Ac @ t | j j S r )iterr r# r$ s r __iter__z_SelectorMapping.__iter__L s DNN--..r N)__name__
__module__ __qualname__r r% r+ r. r r r r < s 3".O/r r c r e Zd Z ed d Zed Zd dZed d Zd Zd Z ed Z
d Z d
Z y) BaseSelectorNc t r NotImplementedErrorr r r r s r registerzBaseSelector.register_ s & "!r c t r r6 )r r s r
unregisterzBaseSelector.unregisterv "!r c L | j | | j ||| S r )r; r9 r8 s r modifyzBaseSelector.modify s(
}}Wfd33r c t r r6 )r timeouts r selectzBaseSelector.select r< r c y r r2 r$ s r closezBaseSelector.close s
r c | j }| t d || S # t $ r t dj | d w xY w)NzSelector is closedr( )get_map RuntimeErrorr* r )r r mappings r get_keyzBaseSelector.get_key s`
,,. ? 34 4 O7# # O3::7CD$ N Os % %A
c t r r6 r$ s r rE zBaseSelector.get_map s @!!r c | S r r2 r$ s r __enter__zBaseSelector.__enter__ s r c $ | j y r )rC )r argss r __exit__zBaseSelector.__exit__ s
r r )
r/ r0 r1 r r9 r; r> rA rC rH rE rK rN r2 r r r4 r4 P sq " ", " "$4" " "$
O " "r r4 ) metaclassc B e Zd Z d Zd Zd
dZd Zd
dZd Zd Z d Z
y) _BaseSelectorImplc 2 i | _ t | | _ y r )r# r _mapr$ s r r z_BaseSelectorImpl.__init__ s $T* r c t | S # t $ r? | j j D ] }|j |u s|j
c cY S w xY wr )r r r# valuesr r r r keys r r) z!_BaseSelectorImpl._fileobj_lookup sW !'* * --/;;') 66M 0
s
4AAANc F |r|t t z z rt dj | t || j | || }|j | j v r%t dj ||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 rW s r r9 z_BaseSelectorImpl.register s FzK'?%@ @ 3 : :6 BC C'4#7#7#@&$O 66T__ $? "F7CFF 35
5 #&
r c | j j | j | }|S # t $ r t dj | d w xY wr' )r# popr) r* r rV s r r; z _BaseSelectorImpl.unregister sZ O//%%d&:&:7&CDC
O3::7CD$ N Os *. %Ac r | j | j | }||j k7 r&| j | | j
||| }|S ||j k7 r+|j | }|| j |j < |S # t $ r t dj | d w xY w)Nr( )r )
r# r) r* r r r; r9 r _replacer r[ s r r> z_BaseSelectorImpl.modify s O//$"6"6w"?@C SZZ OOG $--6C
SXX
,,D,)C&)DOOCFF #
O3::7CD$ N Os B %B6c F | j j d | _ y r )r# clearrS r$ s r rC z_BaseSelectorImpl.close s r c | j S r )rS r$ s r rE z_BaseSelectorImpl.get_map s yyr c B | j | S # t $ r Y y w xY wr )r# r* )r r s r _key_from_fdz _BaseSelectorImpl._key_from_fd s- ??2& & s r ) r/ r0 r1 r r) r9 r; r> rC rE rd r2 r r rQ rQ s- '+ & r rQ c ~ e Zd Z fdZd fd Z fdZej dk( rddZn e j ZddZ xZ
S )SelectSelectorc ^ t | t | _ t | _ y r )superr set_readers_writersr __class__s r r zSelectSelector.__init__% s
r c t | ||| }|t z r%| j j |j
|t z r%| j j |j
|S r )rh r9 rY rj addr rZ rk )r r r r rW rm s r r9 zSelectSelector.register* sW g w5 J MM cff % K MM cff %
r c t | | }| j j |j | j
j |j |S r )rh r; rj discardr rk r r rW rm s r r; zSelectSelector.unregister2 sC g )
cff%
cff%
r win32c J t j |||| \ }}}|||z g fS r )rA )r rw_r@ xs r _selectzSelectSelector._select9 s, mmAq!W5GAq!a!eR< r c |d n t |d }g } | j | j | j g | \ }}}t | }t | }||z D ]R }d}||v r |t z }||v r |t z }| j | }|s3|j |||j z f T |S # t $ r |cY S w xY wNr ) maxry rj rk InterruptedErrorri rY rZ rd appendr ) r r@ readyru rv rw r r rW s r rA zSelectSelector.select? s !/$s7A ll4==$--WMGAq!
F Fa%BFQw*$Qw+%##B'C c6CJJ#6 78 L s ,B2 2 C ?C r ) r/ r0 r1 r r9 r; sysplatformry rA
__classcell__rm s @r rf rf " s8
||w --r rf c V e Zd Z dZdZdZ fdZd fd Z fdZd fd Z ddZ
xZ S )_PollLikeSelectorNc L t | | j | _ y r )rh r
_selector_clsr rl s r r z_PollLikeSelector.__init__[ s
++-r c t | ||| }d}|t z r|| j z }|t z r|| j
z } | j j |j | |S # t | ! | xY wr{ ) rh r9 rY _EVENT_READrZ _EVENT_WRITEr r r; )r r r r rW
poller_eventsrm s r r9 z_PollLikeSelector.register_ s g w5
J T - - -M K T . . .M NN # #CFFM :
G w ' s &A. .B c t | | } | j j |j |S # t $ r Y |S w xY wr )rh r; r r OSErrorrr s r r; z _PollLikeSelector.unregisterm sO g ) NN % %cff -
s %9 AAc | j | j | }d}||j k7 r[d}|t z r|| j
z }|t z r|| j z } | j j |j | d}||j k7 rd}|r,|j || }|| j |j < |S # t $ r t |d d w xY w# t | 1 | xY w)Nz is not registeredFr T)r r )r# r) r* r rY r rZ r r r> r rh r; r r_ )r r r r rW changedselector_eventsrm s r r> z_PollLikeSelector.modifyw s G//$"6"6w"?@C SZZ O
" 4#3#33 # 4#4#44
%%cffo> G 388 G ,,f4,8C&)DOOCFF #
- Gg[(:;<$ F G
"7+s C %&C* C'*C<c |d }n |dk rd}nt j |dz }g } | j j | }|D ]m \ }}d}|| j
z r |t z }|| j z r |t z }| j | }|sN|j |||j z f o |S # t $ r |cY S w xY w)Nr @@) mathceilr pollr} r rZ r rY rd r~ r )r r@ r
fd_event_listr eventr rW s r rA z_PollLikeSelector.select s ?G
\G ii#
.G NN / / 8M 'IBF((((+%))))*$##B'C c6CJJ#6 78 ' L s B8 8 CCr ) r/ r0 r1 r r r r r9 r; r> rA r r s @r r r U s. FMKL. 6r r r c V e Zd Z ej Zej Zej Z y) PollSelectorN)
r/ r0 r1 rA r r POLLINr POLLOUTr r2 r r r r s "
mm ~~ r r epollc v e Zd Z ej Zej Zej Z d Z
ddZ fdZ xZ S )
EpollSelectorc 6 | j j S r r r r$ s r r zEpollSelector.fileno >>((* *r c |d}n#|dk rd}nt j |dz dz }t t | j d }g } | j
j
|| }|D ]u \ }}d}|t j z r |t z }|t j z r |t z }| j | }|sV|j |||j z f w |S # t $ r |cY S w xY w)Nr r gMbP?r )r r r| r" r# r r r} rA EPOLLINrZ EPOLLOUTrY rd r~ r ) r r@ max_evr r r r r rW s r rA zEpollSelector.select s A ))GcM2T9
T__-q1FE
$ 3 3GV D
+ EFNN?*k)FFOO++j(F''+LL#v
':!;< + L $
s C# # C10C1c V | j j t | y r r rC rh rl s r rC zEpollSelector.close NN " GMOr r )
r/ r0 r1 rA r r r r r r r rC r r s @r r r s6 #
nn + @ r r devpollc n e Zd Z ej Zej Zej Z d Z
fdZ xZ S )DevpollSelectorc 6 | j j S r r r$ s r r zDevpollSelector.fileno r r c V | j j t | y r r rl s r rC zDevpollSelector.close r r )
r/ r0 r1 rA r r r r r r r rC r r s @r r r s0 )
mm ~~ + r r kqueuec N e Zd Z fdZd Zd fd Z fdZddZ fdZ xZ S )KqueueSelectorc b t | t j | _ d| _ y r{ )rh r rA r r _max_eventsrl s r r zKqueueSelector.__init__ s# G #]]_DN D r c 6 | j j S r r r$ s r r zKqueueSelector.fileno r r c : t | ||| } |t z rpt j |j
t j t j }| j j |gdd | xj dz
c_
|t z rpt j |j
t j t j }| j j |gdd | xj dz
c_
|S # t | 5 | xY wNr r )rh r9 rY rA keventr KQ_FILTER_READ KQ_EV_ADDr controlr rZ KQ_FILTER_WRITEr; )r r r r rW kevrm s r r9 zKqueueSelector.register s '"7FD9C
J& --0E0E(.(8(8:CNN**C5!Q7$$)$K' --0F0F(.(8(8:CNN**C5!Q7$$)$ J
"7+s C2D Dc x t | | }|j t z rqt j
|j t j t j }| xj dz c_ | j j |gdd |j t z rst j
|j t j t j }| xj dz c_ | j j |gdd |S |S # t $ r Y w xY w# t $ r Y |S w xY w)Nr r )rh r; r rY rA r r r KQ_EV_DELETEr r r r rZ r )r r rW r rm s r r; zKqueueSelector.unregister s '$W-CzzJ& mmCFFF,A,A$*$7$79 A% NN**C5!Q7
zzK' mmCFFF,B,B$*$7$79 A% NN**C5!Q7 J3J Js$ 7 D ; D, D)(D), D98D9c |d n t |d }| j xs d}g } | j j d || }|D ] }|j
}|j }d}|t j k( r |t z }|t j k( r |t z }| j | } | si|j | || j z f |S # t $ r |cY S w xY wr )r| r r r r} identfilterrA r rY r rZ rd r~ r )
r r@ r r kev_listr r flagr rW s
r rA zKqueueSelector.select. s %od3w?G %%*FE
>>11$H YYzz6000j(F6111k)F''+LL#v
':!;< L $
s C C C c V | j j t | y r r rl s r rC zKqueueSelector.closeG r r r )
r/ r0 r1 r r r9 r; rA rC r r s @r r r s) $ !
+ $ . 2 r r c t t | d }|y | }| dk( r|j d y|j y# t $ r Y yw xY w)NFr r T)getattrrA r rC r )methodr selector_objs r _can_user L sj vvt,H
z V a
s A A AA) abcr r collectionsr collections.abcr r rA r rY rZ r r __doc__r r r r r r4 rQ rf r hasattrr r r r r DefaultSelectorr2 r r r ss ( " #
2 (KL
8 6 R E /w /({W {|Q Qh0& 0fW) Wt 66&( & 67+ ) + \ 69 + 68 O * O d4 H$O
g#O
i%O
f"O$Or