cj g d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl m Z ddl m
Z
mZ ddlmZ ej" Z ddlZddlmZmZmZmZ d Zd
Z e j8 Z d Z d gZ e ed rd Z e d gz
Z ej2 dk( rd
Z e d
gz
Z efdZ!d Z"d Z#d Z$d Z% G d d Z&er G d de& Z' G d de& Z( G d de) Z*dCdZ+ej2 dk7 rdDd Z,ndDd Z, G d d e) Z-d Z.ej2 dk( r G d! d"e) Z/d# Z0d$Z1d%Z2d&Z3d'Z4 e5h d( Z6 e7d) e6D Z8d*Z9d+Z:e9e:fZ;d, ZdEd/e?fd0Z@d/e?fd1ZA G d2 d3e) ZBd4 ZCd5 ZD G d6 d7e* ZEd8 ZFej2 dk( r d9 ZGej ej hZJdFd:ZKn*ddlLZL e eLd; r
eLj ZNn eLj ZNdFd<ZKej2 dk( r3d= ZPd> ZQ ej e(eP d? ZSd@ ZT ej e'eS ydA ZPdB ZQ ej e(eP y# e$ r ej2 dk( r dZY w xY w)G)ClientListenerPipewait N )util)AuthenticationErrorBufferTooShort) reduction)
WAIT_OBJECT_0WAIT_ABANDONED_0 WAIT_TIMEOUTINFINITEwin32i g 4@AF_INETAF_UNIXAF_PIPEc 0 t j | z S Ntime monotonic)timeouts 3/usr/lib64/python3.12/multiprocessing/connection.py
_init_timeoutr < s >> g %% c 0 t j | kD S r r )ts r _check_timeoutr ? s >> a r c | dk( ry| dk( r)t j dt j S | dk( r;t j dt j
t
t fz d S t d )
z?
Return an arbitrary free address for the given family
r ) localhostr r z listener-)prefixdirr z\\.\pipe\pyc-%d-%d- zunrecognized family) tempfilemktempr get_temp_dirosgetpidnext
_mmap_counter
ValueErrorfamilys r arbitrary_addressr/ F sy 9 kt7H7H7JKK 9 &< " T--@ A'BGIK K .//r c t j dk7 r| dk( rt d| z t j dk( r%| dk( r t t | st d| z yyy)zD
Checks if the family is valid for the current environment.
r r z Family %s is not recognized.r N)sysplatformr, hasattrsocketr- s r _validate_familyr5 T sc ||w 6Y#67&@AA
||w 6Y#6vv& ;f DE E ' $7 r c t | t k( ryt | t u r| j d ryt | t u st j
| ryt
d| z )z]
Return the types of the address
This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE'
r z\\r r z address type of %r unrecognized)typetuplestr
startswithr is_abstract_socket_namespacer, )addresss r address_typer= ` s\ G}
g # '"4"4V"<
g # !B!B7!K:WDEEr c e Zd ZdZddZd Zd Zd Zd Zd Z e
d Z e
d Z e
d
Z
d Zd Zdd
Zd ZddZddZd ZddZd Zd Zy)_ConnectionBaseNc |j }|dk r t d |s
|s t d || _ || _ || _ y )Nr zinvalid handlez6at least one of `readable` and `writable` must be True) __index__r, _handle _readable _writable)selfhandlereadablewritables r __init__z_ConnectionBase.__init__v sO !!# A: -. . HJ
J !!r c > | j | j y y r rB _closerE s r __del__z_ConnectionBase.__del__ s << # KKM $r c 2 | j t d y )Nhandle is closed)rB OSErrorrM s r
_check_closedz _ConnectionBase._check_closed s << ,- - r c 2 | j s t d y )Nzconnection is write-only)rC rQ rM s r _check_readablez _ConnectionBase._check_readable s ~~45 5 r c 2 | j s t d y )Nzconnection is read-only)rD rQ rM s r _check_writablez _ConnectionBase._check_writable s ~~34 4 r c t | j rd| _ t d | j t d )NFzbad message length)rD rC closerQ rM s r _bad_message_lengthz#_ConnectionBase._bad_message_length s5 >> "DN *++
JJL*++r c | j du S )z True if the connection is closedNrB rM s r closedz_ConnectionBase.closed s ||t##r c | j S )z"True if the connection is readable)rC rM s r rG z_ConnectionBase.readable ~~ r c | j S )z"True if the connection is writable)rD rM s r rH z_ConnectionBase.writable r^ r c : | j | j S )z+File descriptor or handle of the connection)rR rB rM s r filenoz_ConnectionBase.fileno s ||r c f | j | j d| _ yy# d| _ w xY w)zClose the connectionNrK rM s r rX z_ConnectionBase.close s1 << #
$
# $ $ s ' 0c v | j | j t | }|j dkD r|j d }|j
}|dk r t
d ||k r t
d |||z
}n#|dk r t
d ||z |kD r t
d | j ||||z y) z,Send the bytes data from a bytes-like objectr Br zoffset is negativezbuffer length < offsetNzsize is negativez buffer length < offset + size)rR rV
memoryviewitemsizecastnbytesr, _send_bytes)rE bufoffsetsizemns r
send_bytesz_ConnectionBase.send_bytes s sO ::>s A
HH A: 12 2 v: 56 6 <v:D
AX /0 0
d]Q
<= = 6&4-01r c | j | j | j t j | y)zSend a (picklable) objectN)rR rV ri _ForkingPicklerdumpsrE objs r sendz_ConnectionBase.send s3 ..s34r c | j | j ||dk r t d | j | }|| j |j S )z7
Receive bytes data as a bytes object.
r znegative maxlength)rR rT r, _recv_bytesrY getvalue)rE maxlengthrj s r
recv_bytesz_ConnectionBase.recv_bytes sa
Y] 12 2 y) ; $ $ &||~ r c | j | j t | 5 }|j }|t | z }|dk r t d ||kD r t d | j
}|j }|||z k rt |j |j d |j |||z ||z |z |cddd S # 1 sw Y yxY w)zq
Receive bytes data into a writeable bytes-like object.
Return the number of bytes read.
r znegative offsetzoffset too largeN) rR rT re rf lenr, rw tellr
rx seekreadinto)rE rj rk rm rf bytesizeresultrl s r recv_bytes_intoz _ConnectionBase.recv_bytes_into s
_zzH #a&(Hz !233(" !344%%'F;;=D&4-'$V__%677 KKN OOAf 0 %} 9 ;
<! __s B+C!!C*c | j | j | j }t j |j S )z Receive a (picklable) object)rR rT rw rq loads getbuffer)rE rj s r recvz_ConnectionBase.recv s? $$S]]_55r c d | j | j | j | S )z/Whether there is any input available to be read)rR rT _pollrE r s r pollz_ConnectionBase.poll s) zz'""r c | S r rM s r __enter__z_ConnectionBase.__enter__ r c $ | j y r rX rE exc_type exc_valueexc_tbs r __exit__z_ConnectionBase.__exit__
r )TT)r Nr )r )g )__name__
__module__ __qualname__rB rI rN rR rT rV rY propertyr\ rG rH ra rX ro ru rz r r r r r r r r r? r? s s G ".65, $ $
$2(5 26# r r? c P e Zd ZdZdZdZej fdZd Z d dZ
d Z d Z y)
PipeConnectionz
Connection class based on a Windows named pipe.
Overlapped I/O is used, so the handles must have been created
with FILE_FLAG_OVERLAPPED.
FNc d | j }||j || j y r )_send_ovcancelrB )rE _CloseHandleovs r rL zPipeConnection._close s% B~ &r c | j t d t j | j |d \ }}|| _ |t j
k( r&t j |j gdt }d | _ |j d \ }}|t j k( rt t j d y # |j xY w# d | _ |j d \ }}w xY w)Nz/concurrent send_bytes() calls are not supportedT
overlappedFrP )r r, _winapi WriteFilerB ERROR_IO_PENDINGWaitForMultipleObjectseventr r GetOverlappedResultERROR_OPERATION_ABORTEDrQ errnoEPIPE)rE rj r errwaitresnwrittens r ri zPipeConnection._send_bytes s }}( "5 6 6 '' cdKGB DM
='222 % < <
E8 5G !%
" 6 6t <
#g555 ekk+=>> 6
$
" 6 6t <
#s 9C CC C:c | j rd| _ t j S |dn t |d } t j
| j |d \ }} |t j k( r&t j |j gdt }|j d \ }}|dk( r5t j }|j |j |S |t j k( r| j! || S t+ d # |j xY w# |j d \ }}|dk( r9t j }|j |j |c cY S |t j k( r| j! || c cY S w xY w# t" $ r)}|j$ t j& k( rt( d }~ww xY w)NF Tr r z.shouldn't get here; expected KeyboardInterrupt)_got_empty_messageioBytesIOminr ReadFilerB r r r r r r writer ERROR_MORE_DATA_get_more_datarQ winerrorERROR_BROKEN_PIPEEOFError RuntimeError) rE maxsizebsizer r r nreadfes r rw zPipeConnection._recv_bytes6 s &&*/'zz|# &C4E % . .t||U;? AGBD '":"::&-&D&D!#
E8'=G &(%;%;D%A
s !8 "
A GGBLLN 3#$H G$;$; ;#'#6#6r7#C C < OP P! %'%;%;D%A
s !8 "
A GGBLLN 3#$H G$;$; ;#'#6#6r7#C C < zzW%>%>> & s[ %F- 9D A
F- &$F- D**D- -AF*>F- 'F*'F- )F**F- - G 6$GG c | j s%t j | j d dk7 ryt t | g| S )Nr T)r r
PeekNamedPiperB boolr r s r r zPipeConnection._pollV s> '' --dll;A>!CdVW-. .r c |j }t j }|j | t j
| j d }|!t | |z |kD r| j t j | j |d \ }}|j d \ }}|j |j |S )Nr Tr ) r r r r r r rB r| rY r r )rE r r rj r leftr rbytess r r z PipeConnection._get_more_data\ s ,,.C
A
GGCL(( 6q9D"s3x$'@((* &&t||TdKGB 006KFC
GGBLLN #Hr r )
r r r __doc__r r r CloseHandlerL ri rw r r r r r r r s8
#&-&9&9 ' (4 Q@ /
r r c e Zd ZdZer(ej fdZej Z ej Z n'e j fdZe j Z e j Z e fdZe fdZd Zd
dZd Zy)
Connectionzo
Connection class based on an arbitrary file descriptor (Unix only), or
a socket handle (Windows).
c ( || j y r r[ rE rL s r rL zConnection._closes 4<< r c ( || j y r r[ r s r rL zConnection._closex r r c b t | } || j | }||z }|dk( ry ||d }$Nr )r| rB )rE rj r remainingrn s r _sendzConnection._send} sA H dllC(A NIA~ab'C r c t j }| j }|}|dkD rK ||| }t | }|dk( r||k( rt t d |j
| ||z }|dkD rK|S )Nr z got end of file during message)r r rB r| r rQ r )rE rl readrj rF r chunkrn s r _recvzConnection._recv s| jjl !m+EE
AAv $"N!"BCC IIe NI !m
r c t | }|dkD r`t j dd }t j d| }| j | | j | | j | y t j d| }|dkD r#| j | | j | y | j ||z y )Ni!i!Qi @ )r| structpackr )rE rj rn
pre_headerheaders r ri zConnection._send_bytes s H z> T2.J[[q)F JJz " JJv JJsO [[q)F5y
6"
3
6C<(r Nc | j d }t j d|j \ }|dk( r7| j d }t j d|j \ }|||kD ry | j | S )N r r r )r r unpackrx )rE r rj rl s r rw zConnection._recv_bytes sq jjm
dCLLN3 2:**Q-CMM$ 7ED 4'>zz$ r c 2 t | g| }t | S r )r r )rE r rs r r zConnection._poll s $ !Awr r )r r r r r _multiprocessing closesocketrL ru _writer _readr( rX r r r r ri rw r r r r r r l so
0 < < !!&& %% " ! % % ). r r c P e Zd ZdZd
dZd Zd Zed Zed Z d Z
d Z y) r z
Returns a listener object.
This is a wrapper for a bound socket which is 'listening' for
connections, or for a Windows named pipe.
Nc |xs |xr t | xs t }|xs t | }t | |dk( rt || | _ nt
||| | _ |t |t s t d || _
y )Nr authkey should be a byte string) r= default_familyr/ r5 PipeListener _listenerSocketListener
isinstancebytes TypeError_authkey)rE r< r. backlogauthkeys r rI zListener.__init__ s #G = W(= #" 6 .v 6 Y )'7 ;DN +GVW EDN z'5'A => >
r c | j t d | j j }| j ,t || j t || j |S )zz
Accept a connection on the bound socket or named pipe of `self`.
Returns a `Connection` object.
zlistener is closed)r rQ acceptr deliver_challengeanswer_challenge)rE cs r r zListener.accept sW >> !./ / NN ! ! # == $ a / Q
.r c P | j }|d| _ |j yy)zA
Close the bound socket or named pipe of `self`.
N)r rX )rE listeners r rX zListener.close s) >> !DN NN r c . | j j S r )r _addressrM s r r< zListener.address s ~~&&&r c . | j j S r )r _last_acceptedrM s r
last_acceptedzListener.last_accepted s ~~,,,r c | S r r rM s r r zListener.__enter__ r r c $ | j y r r r s r r zListener.__exit__ r r )NNr N) r r r r rI r rX r r< r r r r r r r r sH
' ' - -r r c |xs t | }t | |dk( r t | }n t | }|t |t
s t
d |t || t || |S )z=
Returns a connection to the address of a `Listener`
r r ) r= r5
PipeClient SocketClientr r r r r )r< r. r r s r r r sq
,|G,FV
w !:gu#=9::G$!W% Hr c N | rot j \ }}|j d |j d t |j }t |j }||fS t j \ }}t |d }t |d }||fS )L
Returns pair of connection objects at either end of a pipe
TFrH rG )r4
socketpair setblockingr detachr( pipe)duplexs1s2c1c2fd1fd2s r r r s &&(FB NN4 NN4 BIIK(BBIIK(B 2v
wwyHCC%0BC%0B2v
r c
t d }| r>t j }t j t j z }t
t
}}n(t j }t j }dt
}}t j ||t j z t j z t j t j z t j z d||t j t j }t j ||dt j t j t j t j }t j" |t j dd t j$ |d }|j' d \ } }
t) || } t) || } | | fS ) r r r r NTr r r
)r/ r PIPE_ACCESS_DUPLEX GENERIC_READ
GENERIC_WRITEBUFSIZEPIPE_ACCESS_INBOUNDCreateNamedPipeFILE_FLAG_OVERLAPPED FILE_FLAG_FIRST_PIPE_INSTANCEPIPE_TYPE_MESSAGEPIPE_READMODE_MESSAGE PIPE_WAITNMPWAIT_WAIT_FOREVERNULL
CreateFile
OPEN_EXISTINGSetNamedPipeHandleStateConnectNamedPiper r )
r r< openmodeaccessobsizeibsizeh1h2r _r r r s
r r r ( s` $I. 11H ))G,A,AAF $gFF 22H **F FF
$
$ X < << 1 12 % %(E(E E
vvw ; ; LL
VQ g.C.C ( (',, '' --tT --bTB
//53 B
0
B
02v
r c $ e Zd ZdZddZd Zd Zy)r zO
Representation of a socket which is bound to an address and listening
c t j t t | | _ t j dk( r9| j j t j t j d | j j d | j j | | j j | | j j | _ || _ d | _ |dk( rCt# j$ | s.t# j& | t j( |fd | _ y d | _ y # t $ r | j j w xY w)Nposixr Tr r args exitpriority)r4 getattr_socketr( name
setsockopt
SOL_SOCKET SO_REUSEADDRr bindlisten getsocknamer rQ rX _familyr r r; Finalizeunlink_unlink)rE r< r. r s r rI zSocketListener.__init__X s }}WVV%<= ww'! ''(9(9(.(;(;Q@ LL $ $T * LL g & LL ( LL 4 4 6DM " Y t'H'H'Q ==biiwjq DL DL LL s B!?D "&D NN=t}} M l::(($--8qDJr c
~ t j t j z }|r|t j z }t j | j
|t j t j z t j z t j t t t j t j S r )
r r r r! r r r" r# r$ PIPE_UNLIMITED_INSTANCESr r% r& )rE rM flagss r rN zPipeListener._new_handle s ..1M1MME>>>**
u))G,I,II!!"00'7,,gll
r c L | j j | j | j j d } t j
|d } t j |j gdt } |j d \ }}t | S # |j t j | xY w# |j d \ }}w xY w# t $ r2}|j t j k7 r Y d }~t | S d }~ww xY w)Nr Tr F)rO appendrN popr r* r r r r r r rQ r
ERROR_NO_DATAr )rE rF r resr1 r r s r r zPipeListener.accept s % %d&6&6&8 9''++A.F
$ --fF $!88
E85C 3 3D 9FAs!&) )IIK''/ 3 3D 9FAs
::!6!66 7 "&) )!
s0 C( &B$ $(C C C%( D#1 D D#c h t j d| | D ] }t j | y )Nz closing listener with address=%r)r rP r r )queuer< rF s r rQ z$PipeListener._finalize_pipe_listener s) NN=w G ##F+ r r )F) r r r r rI rN r staticmethodrQ r r r r r s*
*.
,
,r r c . t } t j | d t j | t j t j
z dt j t j t j t j } t j |t j dd t! | S # t $ rB}|j t j t j fvs t | r Y d}~nd}~ww xY w )zU
Return a connection object connected to the pipe given by `address`
r N)r r
WaitNamedPiper' r r r& r( r rQ r ERROR_SEM_TIMEOUTERROR_PIPE_BUSYr r) r# r )r< r hr s r r r s
O
%%gt4&&W 1 1G4I4I Iw||W%:%:00',, ''
w,,dD a
::g&?&?&-&=&=&? ?BPQRBS CT
s BC D8D
D( s #CHALLENGE#s #WELCOME#s #FAILURE#> md5 sha256 sha384 sha3_256 sha3_384c # 2 K | ] }t | y wr )r| ).0r1 s r rk F s 7&6c!f&6s c t | t v rd| fS | j d rG| j ddt dz x}dkD r(| d| }|t
v r| |dz d }|j
d |fS t d | )
a Returns a digest name and the payload for a response hash.
If a legacy protocol is detected based on the message length
or contents the digest name returned will be empty to indicate
legacy mode where MD5 and no digest prefix should be sent.
r$ { }r r NasciizRunsupported message length, missing digest prefix, or unsupported digest: message=)r| _LEGACY_LENGTHSr: find_MAX_DIGEST_LEN_ALLOWED_DIGESTSdecoder )messagecurlydigestpayloads r _get_digest_name_and_payloadr| Q s 7|&
7{4 ,,tQ(9: :a?5! % % eAgh'G==)72 2
/&-Z
1 2 2r c ddl }t | d }|s" |j | |d j S |j | || j }d|j d |fz S # t $ r d}Y Dw xY w)a Create a MAC based on authkey and message
The MAC algorithm defaults to HMAC-MD5, unless MD5 is not available or
the message has a '{digest_name}' prefix. For legacy HMAC-MD5, the response
is the raw MAC, otherwise the response is prefixed with '{digest_name}',
e.g. b'{sha256}abcdefg...'
Note: The MAC protects the entire message including the digest_name prefix.
r Nmd5sha256 {%s}%srr )hmacr| newrz r, encode)r rx r digest_nameresponses r _create_responser k s .w7:K #88GWe4;;= = xx+6==?H **73X> >> # #K #s A. . A<;A<c
d ddl }t | \ }}|xs d} |j | || j }t
| t
| k7 r&t d|dt
| dt
| |j || s t d y# t $ r t d|d w xY w)
a` Verify MAC challenge
If our message did not include a digest_name prefix, the client is allowed
to select a stronger digest_name from _ALLOWED_DIGESTS.
In case our message is prefixed, a client cannot downgrade to a weaker
algorithm, because the MAC is calculated over the entire message
including the '{digest_name}' prefix.
r Nr~ zresponse_digest=z unsupportedz expected z of length z got zdigest received was wrong)r r| r rz r, r r| compare_digest)r rx r r response_digest response_macexpecteds r _verify_challenger s $@$J!O\%.OE88GWo>EEG 8}L))!O.k#h- I<()+, , x 6!"=>> 7
E!%5_$6l"CDDEs !B B/r c t |t s#t dj t | t j t }d|j d |fz }| j t |z | j d } t ||| | j t y # t $ r | j t w xY w)N Authkey must be bytes, not {0!s}r rr )r r r, formatr7 r( urandomMESSAGE_LENGTHr ro
_CHALLENGErz r _WELCOMEr _FAILURE)
connectionr r rx r s r r r s gu % . 5 5d7m DF F jj (G;--g6@@G *w./$$S)H('7H5
h' h'
s
B0 0 Cc t |t s#t dj t | | j d }|j
t st d| |t t d }t | t k rt dt | d t || }| j | | j d }|t k7 r t d y )Nr r z,Protocol error, expected challenge: message=zchallenge too short: z byteszdigest sent was rejected)r r r, r r7 rz r: r r r| _MD5ONLY_MESSAGE_LENGTHr ro r )r r rx rz r s r r r s gu % . 5 5d7m DF F##C(G j )!?wjAC Cc*o&'G
7|--!$9#g, v"NOO
gw
/F&!$$S)H8!"<== r c e Zd Zd Zd Zd Zy)ConnectionWrapperc n || _ || _ || _ dD ] }t || }t | || y )N)ra rX r rz ro )_conn_dumps_loadsr8 setattr)rE connrr r attrrt s r rI zConnectionWrapper.__init__ s:
KD$%C D$ $ Lr c \ | j | }| j j | y r )r r ro )rE rt rG s r ru zConnectionWrapper.send s" KK
a r c X | j j }| j | S r )r rz r rF s r r zConnectionWrapper.recv s" JJ ! ! #{{1~ r N)r r r rI ru r r r r r r s %! r r c T t j | fd d d d j d S )Nr utf-8) xmlrpclibrr r )rt s r
_xml_dumpsr s& ??C64tQ 7 > >w GGr c X t j | j d \ \ }}|S )Nr )r r rw )rG rt methods r
_xml_loadsr s$ __QXXg%67NFSF Jr c e Zd Zd Zy) XmlListenerc b dd l ma t j | }t |t t S r )
xmlrpc.clientclientr r r r r r rs s r r zXmlListener.accept s" )ood# j*==r N)r r r r r r r r r s >r r c J dd l ma t t | i |t
t S r )r r r r r r r )r6 kwdss r XmlClientr s % VT 2T 2J
KKr c t | }g }|rt j |d| }|t k( r |S t |cxk rt t | z k r
n n
|t z }nAt |cxk rt t | z k rn t d |t z }n t d |j || ||dz d }d}|r|S )NFzShould not get herer r ) listr r r r r| r
r rV )handlesr LreadyrY s r _exhaustive_waitr s
M00E7CCl" #>
A(>>}$!SD+;c!f+DD ##899 ''"#899 LL3 #a%& AG r c V |t }n|dk rd}nt |dz dz }t | } i g }t }t } | D ] } t |d } t j | dd \ }}|t
j k( r!|j | | |j < d|rDt j dd dk\ r* |j d \ }
}|st! |d
rd|_ |j% | d} t+ j- | }|D ] }|j/ |D ]e } |j d \ }
}|t
j0 k7 s, |j }|j% | |dk( sRt! |d
s_d|_ g |j3 fd |D | D cg c] }||v s| c}S # t $ r"} d| j }}|t vr Y d} ~ d} ~ ww xY w# t $ r} | j }Y d} ~ >d} ~ ww xY w# t& $ r | |j) < Y w xY w# t $ r } | j }|t vr Y d} ~ d} ~ ww xY w# |D ] }|j/ |D ] } |j d \ }
}n+# t $ r } | j }|t vr Y d} ~ nd} ~ ww xY w|t
j0 k7 sX |j }|j% | |dk( s~t! |d
sd|_ w xY wc c}w )
Wait till an object in object_list is ready/readable.
Returns list of those objects in object_list which are ready/readable.
Nr r^ g ?ra Trq ) rq Fr c 3 ( K | ] }| y wr r )rj rb waithandle_to_objs r rk zwait..S s I=a .q 1=s )r intr setr8 r r rQ r
_ready_errorsr rV r r1 getwindowsversionr r3 r addAttributeErrorrA r keysr r update) object_listr ov_list
ready_objects
ready_handlesora r r r r1 r s @r r r s- ? G
q[G'D.3./G;'
6 8 $ $Q 1F
"")"2"268Q"EC
g 6 66 r*67)"((3
#"7"7"9"1"="G 1)+)?)?)F3 $'716J+K7; 4%))!,"#= !@ -->-C-C-Ew OM 3 3D 9FAs
'999)"((3A!%%a(ax #1&:;37A 0 I= II&=;a!}*<;==_ # ""&
C m3 ! 4" $+ 1&'jj 1- & 978%akkm49N **C-/ 0 3 3D 9FAs **C-/ 0 '999)"((3A!%%a(ax #1&:;37A 0 " >s I4 H% G:AI4 H AI4 I L&
L& G? G:4I4 :G??I4 H" H I4 H""I4 % II4 II4 I1I,,I14 L#J'&L#' K 0K
L#
K L#&%L# L#
L# PollSelectorc t 5 }| D ]" }|j |t j $ |t j
|z } |j
| }|r(|D cg c] \ }}|j c}}cddd S |'t j
z
}|dk r |cddd S ec c}}w # 1 sw Y yxY w)r Nr )
_WaitSelectorregister selectors
EVENT_READr r selectfileobj)r r selectorrt deadliner keyeventss r r r b s _"!!#y';';< # " >>+g5 0=BCUMS&CKKUC _ *"*T^^-="="Q;#( _ D _s$ AB8%B2;B8 B81B88Cc | j }t j |t j t j 5 }ddlm} |j | }t || j | j ffcd d d S # 1 sw Y y xY w)Nr )resource_sharer) ra r4 fromfdr SOCK_STREAMr$ r DupSocketrebuild_connectionrG rH )r rF rG r dss r reduce_connectionr ~ s`
]]66>>63E3E
F! ) **1-B%DMM4=='II G
F
Fs 6BB
c X | j }t |j || S r r r )r rG rH socks r r r s" yy{$++-8<r s 3
1 **OO !
;
69 N H<<7 N H - & 0
F
F&T Tn ] ]@M Mh;v ;|
* <<7&&X)V )X& <<76,v 6,p!>
r @B 7&677 *O<24?8?2(5 (*>% >*
H>( >L <<7( ..0M0MNML>`
y.)!..
!00
)6 <<7J = Iz#45K
: I~'=>F2 Iz#45s#
||w
Gs H8 8II