!A?hL 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 dS e d reZ dS e d reZ dS e d reZ dS eZ dS )' )ABCMetaabstractmethod)
namedtuple)MappingN c J t | t r| }na t | }n># t t t
f$ r$ t d | d w xY w|dk r"t d | |S )NzInvalid file object: {!r}r zInvalid file descriptor: {})
isinstanceintfilenoAttributeError TypeError
ValueErrorformat)fileobjfds 6/opt/alt/python-internal/lib64/python3.11/selectors.py_fileobj_to_fdr s
'3 ?
?W^^%%&&BB :6 ? ? ? $$*F7OO5 5:>
? ?
Avv6==bAABBB
Is != ;A8 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 ZdS )_SelectorMappingc || _ d S N) _selector)selfselectors r __init__z_SelectorMapping.__init__? s
! c 4 t | j j S r )lenr
_fd_to_keyr s r __len__z_SelectorMapping.__len__B s 4>,---r c | j | }| j j | S # t $ r$ t d | d w xY wN{!r} is not registered)r _fileobj_lookupr# KeyErrorr )r r r s r __getitem__z _SelectorMapping.__getitem__E sk O //88B>,R0 0 O O O3::7CCDD$ N Os +. .A c 4 t | j j S r )iterr r# r$ s r __iter__z_SelectorMapping.__iter__L s DN-...r N)__name__
__module__ __qualname__r r% r+ r. r r r r < sV 3" " ". . .O O O/ / / / /r r c e Zd Z ed d Zed Zd dZed d Zd Zd Z ed Z
d Z d
Z dS ) 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 \ | | | ||| S r )r; r9 r8 s r modifyzBaseSelector.modify s1
}}Wfd333r c t r r6 )r timeouts r selectzBaseSelector.select r< r c d S r r2 r$ s r closezBaseSelector.close s
r c | }|t d || S # t $ r$ t d | d w xY w)NzSelector is closedr( )get_map RuntimeErrorr* r )r r mappings r get_keyzBaseSelector.get_key sy
,,.. ? 344 4 O7# # O O O3::7CCDD$ N Os 0 .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 . | d S 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 s " " " ^", " " ^"$4 4 4 4" " " " ^"$
O O O " " ^" r r4 ) metaclassc D e Zd Z d Zd Zd
dZd Zd
dZd Zd Z d Z
dS ) _BaseSelectorImplc < i | _ t | | _ d S r )r# r _mapr$ s r r z_BaseSelectorImpl.__init__ s $T** r c t | S # t $ r2 | j D ]}|j |u r |j c cY S w xY wr )r r r# valuesr r r r keys r r) z!_BaseSelectorImpl._fileobj_lookup sx !'** * --//
"
";')) 6MMMMM *
s 7A ANc H |r|t t z z r"t d | t || | || }|j | j v r(t d ||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 DFzK'?%@ @ D 3 : :6 B BCC C'4#7#7#@#@&$OO 6T_ $ $? "F7CF 3 35 5
5 #&
r c | j | | }n1# t $ r$ t d | d w xY w|S r' )r# popr) r* r rV s r r; z _BaseSelectorImpl.unregister sp O/%%d&:&:7&C&CDDCC O O O3::7CCDD$ N O
s -0 .A c | | j | | }n1# t $ r$ t d | d w xY w||j k r-| | | ||| }n0||j k r%| | }|| j |j < |S )Nr( )r )
r# r) r* r r r; r9 r _replacer r[ s r r> z_BaseSelectorImpl.modify s O/$"6"6w"?"?@CC O O O3::7CCDD$ N O SZ OOG $ $ $--66CC
SX
,,D,))C&)DOCF #
s # .Ac F | j d | _ d S 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
yr c B | j | S # t $ r Y d S w xY wr )r# r* )r r s r _key_from_fdz _BaseSelectorImpl._key_from_fd s; ?2& & 44 s
r ) r/ r0 r1 r r) r9 r; r> rC rE rd r2 r r rQ rQ s '+ + + & r rQ c l e Zd Z fdZd fd Z fdZej dk rddZne j ZddZ xZ
S ) SelectSelectorc t t | _ t | _ d S r )superr set_readers_writersr __class__s r r zSelectSelector.__init__% s3
r Nc t ||| }|t z r | j |j |t z r | j |j |S r )rh r9 rY rj addr rZ rk )r r r r rW rm s r r9 zSelectSelector.register* sm gg w55 J & M cf % % % K & M cf % % %
r c t | }| j |j | j |j |S r )rh r; rj discardr rk r r rW rm s r r; zSelectSelector.unregister2 sO gg ))
cf%%%
cf%%%
r win32c H t j |||| \ }}}|||z g fS r )rA )r rw_r@ xs r _selectzSelectSelector._select9 s- mAq!W55GAq!a!eR< r c |d nt |d }g } | | j | j g | \ }}}n# t $ r |cY S w xY wt | }t | }||z D ]V}d}||v r
|t z }||v r
|t z }| | }|r | |||j
z f W|S Nr ) maxry rj rk InterruptedErrorri rY rZ rd appendr ) r r@ readyru rv rw r r rW s r rA zSelectSelector.select? s !/$$s7A ll4=$-WMMGAq!! LLL FF FFa% 9 9BFQww*$Qww+%##B''C
9 c6CJ#6 7888 s &? A
Ar ) r/ r0 r1 r r9 r; sysplatformry rA
__classcell__rm s @r rf rf " s
|w - r rf c V e Zd Z dZdZdZ fdZd fd Z fdZd fd Z ddZ
xZ S )_PollLikeSelectorNc z t | | _ d S r )rh r
_selector_clsr rl s r r z_PollLikeSelector.__init__[ s0
++--r c 4 t ||| }d}|t z r
|| j z }|t z r
|| j z } | j |j | n'# t | xY w|S r{ ) rh r9 rY _EVENT_READrZ _EVENT_WRITEr r r; )r r r r rW
poller_eventsrm s r r9 z_PollLikeSelector.register_ s gg w55
J . T - -M K / T . .M N # #CFM : : : : GG w ' ' '
s A1 1$Bc t | } | j |j n# t $ r Y nw xY w|S r )rh r; r r OSErrorrr s r r; z _PollLikeSelector.unregisterm sc gg )) N % %cf - - - -
D
s A
AAc | j | | }n!# t $ r t |d d w xY wd}||j k rud}|t z r
|| j z }|t z r
|| j z } | j |j
| n'# t | xY wd}||j
k rd}|r&| || }|| j |j
< |S )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 s7 G/$"6"6w"?"?@CC G G Gg;;;<<$ F G SZ O
"
4 4#33 #
5 4#44
%%cfo>>>>
""7+++G 38 G *,,f4,88C&)DOCF #
s $ A= B $Cc |d }n |dk rd}nt j |dz }g } | j | }n# t $ r |cY S w xY w|D ]g\ }}d}|| j z r
|t z }|| j z r
|t z }| | }|r |
|||j z f h|S )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 ?GG
\\GG i#
..G N / / 8 8MM LLL & 9 9IBF(((
&+%)))
%*$##B''C
9 c6CJ#6 7888 s A AAr ) r/ r0 r1 r r r r r9 r; r> rA r r s @r r r U s FMKL. . . . . 6 r r r c : e Zd Z ej Zej Zej Z dS ) PollSelectorN)
r/ r0 r1 rA r r POLLINr POLLOUTr r2 r r r r s& "
m ~ r r epollc X e Zd Z ej Zej Zej Z d Z
ddZ fdZ xZ S )
EpollSelectorc 4 | j S r r r r$ s r r zEpollSelector.fileno >((** *r Nc |d}n#|dk rd}nt j |dz dz }t t | j d }g } | j || }n# t $ r |cY S w xY w|D ]q\ }}d}|t j z r
|t z }|t j z r
|t z }|
| }|r | |||j z f r|S )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 )GcM22T9
T_--q11FE
$ 3 3GV D D
#
*
=
= EFN?* *k)FFO++ )j(F''++ =LL#v
':!;<<<Ls A* * A98A9c z | j t d S r r rC rh rl s r rC zEpollSelector.close , N " " " GGMMOOOOOr r )
r/ r0 r1 rA r r r r r r r rC r r s @r r r st #
n + + + @ r r devpollc P e Zd Z ej Zej Zej Z d Z
fdZ xZ S )DevpollSelectorc 4 | j S r r r$ s r r zDevpollSelector.fileno r r c z | j t d S 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 s_ )
m ~ + + + r r kqueuec N e Zd Z fdZd Zd fd Z fdZddZ fdZ xZ S ) KqueueSelectorc t t j | _ d| _ d S r{ )rh r rA r r _max_eventsrl s r r zKqueueSelector.__init__ s4 GG #]__DN D r c 4 | j S r r r$ s r r zKqueueSelector.fileno r r Nc 8 t ||| } |t z r\t j |j t j t j }| j |gdd | xj
dz
c_
|t z r\t j |j t j t j }| j |gdd | xj
dz
c_
n'# t
| xY w|S Nr 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 ''""7FD99C
J& * -0E(.(8: :CN**C5!Q777$$)$$K' * -0F(.(8: :CN**C5!Q777$$)$$
""7+++Js C C3 3$Dc > t | }|j t z rnt j |j t j t j }| xj dz c_ | j
|gdd n# t $ r Y nw xY w|j t z rnt j |j t j t j }| xj dz c_ | j
|gdd n# t $ r Y nw xY w|S )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 s3 ''$$W--CzJ&
mCFF,A$*$79 9 A% N**C5!Q7777 D zK'
mCFF,B$*$79 9 A% N**C5!Q7777 D Js$ 2 B
B B / D
DDc |d nt |d }| j pd}g } | j d || }n# t $ r |cY S w xY w|D ]|}|j }|j }d}|t j k r
|t z }|t j
k r
|t z }| | } | r |
| || j z f }|S r )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 %odd3w??G %*FE
>11$HH#
=
=Yz6000j(F6111k)F''++ =LL#v
':!;<<<Ls > A
A
c z | j t d S 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 }|dS | }| dk r| d n| dS # t $ r Y dS w xY w)NFr r T)getattrrA r rC r )methodr selector_objs r _can_user L s vvt,,Hu
xzz V a
t uus :A
A'&A') 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 s] ( ' ' ' ' ' ' ' " " " " " " # # # # # #
2 j (K(K(KLL
8 6 R E / / / / /w / / /({ { { { {W { { { {|Q Q Q Q Q Q Q Qh0 0 0 0 0& 0 0 0fW W W W W) W W Wt 766 && & & & &( & & & 767 - + + + + + ) + + + \ 769
+ 768 Q O O O O O * O O O d 4 8H %$OOO
Xg %#OOO
Xi %%OOO
Xf %"OOO$OOOr