*jШ / S Qr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK
J r SSK
J r J
r
SSKJr \R r SSKrSSKrSSKJrJrJrJr S rS
r\ R8 " 5 r S r S r S /r \!" \S
5 ( a S
r \ S
/-
r \R2 S:X a Sr \ S/-
r \4S jr"S r#S r$S r%S r& " S S5 r'\( a " S S\'5 r( " S S\'5 r) " S S\*5 r+SDS jr,\R2 S:w a SES jr-OSES jr- " S S \*5 r.S! r/\R2 S:X a " S" S#\*5 r0S$ r1S%r2S&r3S'r4S(r5\6" 1 S)k5 r7\8" S* \7 5 5 r9S+r:S,r;\:\;4rS/ r?SFS0\@4S1 jjrAS0\@4S2 jrB " S3 S4\*5 rCS5 rDS6 rE " S7 S8\+5 rFS9 rG\R2 S:X a! S: rH\R \R 1rKSGS; jrLO0SSKMrM\!" \MS<5 ( a
\MR rOO \MR rOSGS= jrL\R2 S:X a3 S> rQS? rR\R " \)\Q5 S@ rTSA rU\R " \(\T5 gSB rQSC rR\R " \)\Q5 g! \ a \R2 S:X a e Sr GNf = f)H)ClientListenerPipewait N )util)AuthenticationErrorBufferTooShort) reduction)
WAIT_OBJECT_0WAIT_ABANDONED_0 WAIT_TIMEOUTINFINITEwin32i g 4@d AF_INETAF_UNIXAF_PIPEc 2 [ R " 5 U - $ Ntime monotonic)timeouts A/opt/alt/python313/lib64/python3.13/multiprocessing/connection.py
_init_timeoutr = s >> g %% c 2 [ R " 5 U : $ r r )ts r _check_timeoutr @ s >> a r c U S:X a gU S:X aX [ R R [ R " 5 S[ R
" S5 R
5 35 $ U S:X aJ S[ R " 5 [ [ 5 [ R
" S5 R
5 4- $ [ S 5 e)
Nr ) localhostr r zsock- r z\\.\pipe\pyc-%d-%d-%s zunrecognized family) ospathjoinr get_temp_dirurandomhexgetpidnext
_mmap_counter
ValueErrorfamilys r arbitrary_addressr1 G s 9 ww||D - - / #BJJqM$5$5$7#8 9; ; 9 (d= 12::a=3D3D3FGH I .//r c [ R S:w a U S:X a [ SU - 5 e[ R S:X a+ U S:X a$ [ [ U 5 ( d [ SU - 5 eg g g )Nr r z Family %s is not recognized.r )sysplatformr. hasattrsocketr/ s r _validate_familyr7 Y sf ||w 6Y#67&@AA
||w 6Y#6vv&& ;f DE E ' $7 r c [ U 5 [ :X a g[ U 5 [ L a U R S5 ( a g[ U 5 [ L d [ R
" U 5 ( a g[
SU - 5 e)Nr z\\r r z address type of %r unrecognized)typetuplestr
startswithr is_abstract_socket_namespacer. )addresss r address_typer? e sb G}
g # '"4"4V"<"<
g # !B!B7!K!K:WDEEr c \ rS rSrSrSS jrS rS rS rS r S r
\ S 5 r \ S
5 r
\ S 5 rS rS
rSS jrS rSS jrSS jrS rSS jrS rS rSrg) _ConnectionBasex Nc UR 5 nUS: a [ S5 eU( d U( d [ S5 eXl X l X0l g )Nr zinvalid handlez6at least one of `readable` and `writable` must be True) __index__r. _handle _readable _writable)selfhandlereadablewritables r __init___ConnectionBase.__init__{ sI !!# A: -. . HJ
J !!r c @ U R b U R 5 g g r rE _closerH s r __del___ConnectionBase.__del__ s << # KKM $r c 4 U R c [ S5 eg )Nhandle is closed)rE OSErrorrQ s r
_check_closed _ConnectionBase._check_closed s << ,- - r c < U R ( d [ S5 eg )Nzconnection is write-only)rF rV rQ s r _check_readable _ConnectionBase._check_readable s ~~45 5 r c < U R ( d [ S5 eg )Nzconnection is read-only)rG rV rQ s r _check_writable _ConnectionBase._check_writable s ~~34 4 r c j U R ( a SU l OU R 5 [ S5 e)NFzbad message length)rG rF closerV rQ s r _bad_message_length#_ConnectionBase._bad_message_length s% >> "DN JJL*++r c U R S L $ r rE rQ s r closed_ConnectionBase.closed s ||t##r c U R $ r )rF rQ s r rJ _ConnectionBase.readable ~~ r c U R $ r )rG rQ s r rK _ConnectionBase.writable ri r c : U R 5 U R $ r )rW rE rQ s r fileno_ConnectionBase.fileno s ||r c h U R b U R 5 S U l g g ! S U l f = fr rO rQ s r r` _ConnectionBase.close s1 << #
$
# $ $ s ( 1c x U R 5 U R 5 [ U5 nUR S: a UR S5 nUR
nUS: a [
S5 eXR: a [
S5 eUc XR-
nO$US: a [
S5 eX#- U: a [
S5 eU R XBX#- 5 g )Nr Br zoffset is negativezbuffer length < offsetzsize is negativez buffer length < offset + size)rW r]
memoryviewitemsizecastnbytesr. _send_bytes)rH bufoffsetsizemns r
send_bytes_ConnectionBase.send_bytes s sO ::>s A
HH A: 12 2 : 56 6 <:D
AX /0 0
]Q
<= = &-01r c U R 5 U R 5 U R [ R U5 5 g r )rW r] rw _ForkingPicklerdumpsrH objs r send_ConnectionBase.send s3 ..s34r c U R 5 U R 5 Ub US: a [ S5 eU R U5 nUc U R 5 UR 5 $ )Nr znegative maxlength)rW rZ r. _recv_bytesra getvalue)rH maxlengthrx s r
recv_bytes_ConnectionBase.recv_bytes sa
Y] 12 2 y) ; $ $ &||~ r c U R 5 U R 5 [ U5 nUR nU[ U5 - nUS: a [ S5 eX%: a [ S5 eU R
5 nUR 5 nXRU- : a [ UR 5 5 eUR S5 UR X2U- X'- U- 5 UsS S S 5 $ ! , ( d f g = f)Nr znegative offsetzoffset too large) rW rZ rs rt lenr. r tellr
r seekreadinto)rH rx ry r{ rt bytesizeresultrz s r recv_bytes_into _ConnectionBase.recv_bytes_into s
_zzH #a&(Hz !233" !344%%'F;;=D4-'$V__%677 KKN OOA 0 %} 9 ;
<! __s B*C
C.c U R 5 U R 5 U R 5 n[ R UR 5 5 $ r )rW rZ r r loads getbuffer)rH rx s r recv_ConnectionBase.recv s? $$S]]_55r c d U R 5 U R 5 U R U5 $ r )rW rZ _pollrH r s r poll_ConnectionBase.poll s) zz'""r c U $ r rQ s r __enter___ConnectionBase.__enter__ r c $ U R 5 g r r` rH exc_type exc_valueexc_tbs r __exit___ConnectionBase.__exit__
r )rE rF rG )TT)r Nr )r )g )__name__
__module__ __qualname____firstlineno__rE rL rR rW rZ r] ra propertyre rJ rK rm r` r} r r r r r r r __static_attributes__r r r rA rA x s G ".65, $ $
$2(5 26# r rA c X \ rS rSrSrSr\R 4S jrS r S
S jr
S r S r S r
g) PipeConnectioni FNc f U R nUb UR 5 U" U R 5 g r )_send_ovcancelrE )rH _CloseHandleovs r rP PipeConnection._close s% B~ &r c U R b [ S5 e[ R " U R USS9u p#X l U[ R
:X a' [ R " UR /S[ 5 nS U l UR S5 u pSU[ R :X a [ [ R S5 eg ! UR 5 e = f! S U l UR S5 u pSf = f)Nz/concurrent send_bytes() calls are not supportedT
overlappedFrU )r r. _winapi WriteFilerE ERROR_IO_PENDINGWaitForMultipleObjectseventr r GetOverlappedResultERROR_OPERATION_ABORTEDrV errnoEPIPE)rH rx r errwaitresnwrittens r rw PipeConnection._send_bytes! s }}( "5 6 6 '' cdKGB M
='222 % < <
E8 5G !%
" 6 6t <
g555 ekk+=>> 6
$
" 6 6t <
#s ;C CC C8c U R ( a SU l [ R " 5 $ Uc SO [ US5 n [ R
" U R USS9u p4 U[ R :X a' [ R " UR /S[ 5 nUR S5 u pdUS:X a6 [ R " 5 nUR UR 5 5 U$ U[ R :X a U R! X15 $ [+ S5 e! UR 5 e = f! UR S5 u pdUS:X a: [ R " 5 nUR UR 5 5 Us s $ U[ R :X a U R! X15 s s $ f = f! [" a* nUR$ [ R& :X a [( ee S nAff = f)NF Tr r z.shouldn't get here; expected KeyboardInterrupt)_got_empty_messageioBytesIOminr ReadFilerE r r r r r r writer ERROR_MORE_DATA_get_more_datarV winerrorERROR_BROKEN_PIPEEOFError RuntimeError) rH maxsizebsizer r r nreadfes r r PipeConnection._recv_bytes; s &&*/'zz|# &C4E % . .t||U;? AGBD '":"::&-&D&D!#
E8'=G &(%;%;D%A
!8 "
A GGBLLN 3#$H G$;$; ;#'#6#6r#C C < OP P! %'%;%;D%A
!8 "
A GGBLLN 3#$H G$;$; ;#'#6#6r#C C < zzW%>%>> & s\ "F5 #;D AF5 -$F5 D11D4 4AF2F5 'F2/F5 1F22F5 5
G)?%G$$G)c U R ( d' [ R " U R 5 S S:w a g[ [ U /U5 5 $ )Nr T)r r
PeekNamedPiperE boolr r s r r PipeConnection._poll[ s> '' --dll;A>!CdVW-. .r c UR 5 n[ R " 5 nUR U5 [ R
" U R 5 S nUb" [ U5 U- U: a U R 5 [ R " U R USS9u pUR S5 u pvUR UR 5 5 U$ )Nr Tr ) r r r r r r rE r ra r r )rH r r rx r leftr rbytess r r PipeConnection._get_more_dataa s ,,.C
A
GGCL(( 6q9D"s3x$'@((* &&t||TdKGB 006KF
GGBLLN #Hr )r r r )r r r r r r r CloseHandlerP rw r r r r r r r r r s3 #&-&9&9 ' (4 Q@ /
r r c \ rS rSr\( a) \R 4S jr\R r \R r O(\ R 4S jr\ R r \ R r \ 4S jr\ 4S jrS rS S jrS rS
rg)
Connectioniq c ( U" U R 5 g r rd rH rP s r rP Connection._closex 4<< r c ( U" U R 5 g r rd r s r rP r } r r c b [ U5 n U" U R U5 nX4- nUS:X a g XS nM$ Nr )r rE )rH rx r remainingr| s r _sendConnection._send s= H dllC(A NIA~b'C r c [ R " 5 nU R nUnUS: aL U" XE5 n[ U5 nUS:X a XQ:X a [ e[ S5 eUR
U5 XW- nUS: a ML U$ )Nr z got end of file during message)r r rE r r rV r )rH rz readrx rI r chunkr| s r _recvConnection._recv sv jjl !m+EE
AAv $"N!"BCC IIe NI !m
r c [ U5 nUS: ab [ R " SS5 n[ R " SU5 nU R U5 U R U5 U R U5 g [ R " SU5 nUS: a# U R U5 U R U5 g U R XA- 5 g )Ni!i!Qi @ )r structpackr )rH rx r|
pre_headerheaders r rw Connection._send_bytes s H z> T2.J[[q)F JJz " JJv JJsO [[q)F5y
6"
3
6<(r Nc " U R S5 n[ R " SUR 5 5 u nUS:X a8 U R S5 n[ R " SUR 5 5 u nUb X1: a g U R U5 $ )N r r r$ r )r r unpackr )rH r rx rz s r r Connection._recv_bytes so jjm
dCLLN3 2:**Q-CMM$ 7ED 4>zz$ r c 2 [ U /U5 n[ U5 $ r )r r )rH r rs r r Connection._poll s $ !Awr r r )r r r r r _multiprocessing closesocketrP r _writer _readr% r` r r r r rw r r r r r r r r q sj 0 < < !!&& %% " ! % % ). r r c V \ rS rSrS S jrS rS r\S 5 r\S 5 r S r
S r S
r g) r i Nc \ U=( d! U=( a [ U5 =( d [ n[ U5 Ub [ U[ 5 ( d [ S5 eUS:X aQ U( a [
X5 U l O^[ R " 5 H n[ U5 n [
X5 U l O( O%U=( d [ U5 n[# XU5 U l X@l g ! [ aE nU[ : a e UR [ R [ R 4; a e S nAM S nAff = f)N authkey should be a byte stringr )r? default_familyr7
isinstancebytes TypeError PipeListener _listener itertoolscountr1 rV _MAX_PIPE_ATTEMPTSr r ERROR_PIPE_BUSYERROR_ACCESS_DENIEDSocketListener_authkey)rH r> r0 backlogauthkeyattemptsr s r rL Listener.__init__ s #G = W(= #" z'5'A'A => > Y !-g!? ) 1H / 7G")5g)G !2 :!26!:G +GW EDN
# "#'99 ! ::g.E.E.5.I.I.K K ! K"s C
D+&:D&&D+c U R c [ S5 eU R R 5 nU R b* [ XR 5 [ XR 5 U$ )Nzlistener is closed)r rV acceptr deliver_challengeanswer_challenge)rH cs r r" Listener.accept sS >> !./ / NN ! ! # == $ a / Q
.r c R U R nUb S U l UR 5 g g r )r r` )rH listeners r r` Listener.close s) >> !DN NN r c . U R R $ r )r _addressrQ s r r> Listener.address s ~~&&&r c . U R R $ r )r _last_acceptedrQ s r
last_acceptedListener.last_accepted s ~~,,,r c U $ r r rQ s r r Listener.__enter__ r r c $ U R 5 g r r r s r r Listener.__exit__ r r )r r )NNr N)
r r r r rL r" r` r r> r/ r r r r r r r r sC 8
' ' - -r r c U=( d [ U 5 n[ U5 US:X a [ U 5 nO [ U 5 nUb [ U[
5 ( d [
S5 eUb [ X25 [ X25 U$ )Nr r ) r? r7
PipeClient SocketClientr r r r$ r# )r> r0 r r% s r r r sp
,|G,FV
w !:gu#=#=9::$!% Hr c H U ( an [ R " 5 u pUR S5 UR S5 [ UR 5 5 n[ UR 5 5 nX44$ [
R " 5 u pV[ USS9n[ USS9nX44$ )NTFrK rJ )r6
socketpair setblockingr detachr% pipe)duplexs1s2c1c2fd1fd2s r r r & s &&(FB NN4 NN4 BIIK(BBIIK(B v
wwyHCC%0BC%0Bv
r c P U ( a= [ R n[ R [ R - n[ [ pCO'[ R
n[ R nS[ pC[ R " 5 H n[ S5 n [ R " Xa[ R - [ R - [ R [ R - [ R - SX4[ R [ R 5 n O [ R, " WUS[ R [ R. [ R [ R 5 n [ R0 " U [ R S S 5 [ R2 " WSS9n
U
R5 S5 u p[7 XpS9n
[7 XS9nX4$ ! [" aF nU[$ : a e UR& [ R( [ R* 4; a e S nAGM S nAff = f)Nr r r Tr r9 r: ) r PIPE_ACCESS_DUPLEX GENERIC_READ
GENERIC_WRITEBUFSIZEPIPE_ACCESS_INBOUNDr r r1 CreateNamedPipeFILE_FLAG_OVERLAPPED FILE_FLAG_FIRST_PIPE_INSTANCEPIPE_TYPE_MESSAGEPIPE_READMODE_MESSAGE PIPE_WAITNMPWAIT_WAIT_FOREVERNULLrV r r r r
CreateFile
OPEN_EXISTINGSetNamedPipeHandleStateConnectNamedPiper r )r? openmodeaccessobsizeibsizer r> h1r h2r _r rB rC s r r r 9 s 11H ))G,A,AAF $gF 22H **F F!)H' 2G
,,(D(D D99 :--0M0MM%%&vw'C'CLL *&
VQ g.C.C ( (',, '' --tT --bTB
//5 B
0
B
0v
+
11::g&=&=&-&A&A&C CC
s B G
H% :H H%c * \ rS rSrSS jrS rS rSrg)r in c [ R " [ [ U5 5 U l [ R S:X a9 U R R [ R [ R S5 U R R S5 U R R U5 U R R U5 U R R 5 U l X l S U l US:X aG [" R$ " U5 ( d, [" R& " U [ R( U4SS9U l g S U l g ! [ a U R R 5 e f = f)Nposixr Tr r args exitpriority)r6 getattr_socketr% name
setsockopt
SOL_SOCKET SO_REUSEADDRr< bindlisten getsocknamer+ rV r` _familyr. r r= Finalizeunlink_unlink)rH r> r0 r s r rL SocketListener.__init__r s
}}WVV%<= ww'! ''(9(9(.(;(;Q@ LL $ $T * LL g & LL ( LL 4 4 6DM " Y t'H'H'Q'Q ==biiwjq DL DL LL s B=E
&E0c U R R 5 u ol UR S5 [ UR 5 5 $ NT)rf r" r. r< r r= rH ss r r" SocketListener.accept s7 !% !4!4!6
d!((*%%r c U R R 5 U R nUb S U l U" 5 g g ! U R nUb S U l U" 5 f f = fr )rf r` rq )rH rp s r r` SocketListener.close s[ LL \\F! # " \\F! # "s ; A)r+ rn r. rf rq N)r )r r r r rL r" r` r r r r r r n s 2&
r r c [ U 5 n[ R " [ [ U5 5 nUR S5 UR U 5 [ UR
5 5 sS S S 5 $ ! , ( d f g = frt )r? r6 re r< connectr r= )r> r0 rv s r r7 r7 sU '
"F / 1Q
d '!((*%
2 1 1s ;A55
Bc > \ rS rSrSS jrS S jrS r\S 5 rSr g)
r i Nc
Xl U R SS9/U l S U l [ R
" SU R 5 [ R " U [ R U R U R 4SS9U l g )NT)firstz listener created with address=%rr rb )
r+ _new_handle
_handle_queuer. r sub_debugro r _finalize_pipe_listenerr` )rH r> r s r rL PipeListener.__init__ sj #M"&"2"2"2">!?D "&D NN=t}} M l::(($--8qDJr c
[ R [ R - nU( a U[ R - n[ R " U R
U[ R [ R - [ R - [ R [ [ [ R [ R 5 $ r )
r rG rM rN rL r+ rO rP rQ PIPE_UNLIMITED_INSTANCESrJ rR rS )rH r~ flagss r r PipeListener._new_handle s ..1M1MME>>>**
u))G,I,II!!"00'7,,gll
r c 8 U R R U R 5 5 U R R S5 n [ R
" USS9n [ R " UR /S[ 5 n UR S5 u pE[ U5 $ ! UR 5 [ R " U5 e = f! UR S5 u pEf = f! [ a) nUR [ R :w a e S nAN}S nAff = f)Nr Tr F)r appendr popr rW r r r r r r rV r
ERROR_NO_DATAr )rH rI r resr^ r r s r r" PipeListener.accept s % %d&6&6&8 9''++A.F
$ --fF $!88
E85C 3 3D 9FA!&) )IIK''/ 3 3D 9FAs
::!6!66 7
s0 C& 'B" ")C C C#&
D0 DDc p [ R " SU5 U H n[ R " U5 M g )Nz closing listener with address=%r)r r r r )queuer> rI s r r $PipeListener._finalize_pipe_listener s) NN=w G ##F+ r )r+ r r. r` r )F)
r r r r rL r r" staticmethodr r r r r r r s%
*.
,
,r r c F [ 5 n [ R " U S5 [ R " U [ R [ R
- S[ R [ R [ R [ R 5 n [ R " U[ R S S 5 [! U5 $ ! [ aI nUR [ R [ R 4; d [ U5 ( a e S nAOS nAff = fGM )N r )r r
WaitNamedPiperT rH rI rS rU rM rV r ERROR_SEM_TIMEOUTr r rV rP r )r> r hr s r r6 r6 s
O
%%gt4&&W 1 1G4I4I Iw||W%:%:00',, ''
w,,dD a
::g&?&?&-&=&=&? ?BPQRBSBS CT
s B
C
D ?DD ( s #CHALLENGE#s #WELCOME#s #FAILURE#> md5 sha256 sha384 sha3_256 sha3_384c # 8 # U H n[ U5 v M g 7fr )r ).0r^ s r r ` s 7&6c!ff&6s c [ U 5 [ ; a SU 4$ U R S5 ( aI U R SS[ S- 5 =nS: a) U SU nU[
; a XS- S nUR
S5 U4$ [ SU < 35 e) N { }r r asciizRunsupported 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 k s 7|&
7{4 ,,tQ(9: :a?5! % % Agh'G==)72 2
/&-Z
1 2 2r c SS K n[ U5 S nU( d! UR XS5 R 5 $ UR XU5 R 5 nSUR S5 U4- $ ! [ a Sn NDf = f)Nr md5sha256 {%s}%sr )hmacr newr r. encode)r r r digest_nameresponses r _create_responser s .w7:K #88Ge4;;= = xx+6==?H **73X> >> # #K #s A1 1 B ?B c
z SS K n[ U5 u pEU=( d Sn UR XU5 R 5 n[
U5 [
U5 :w a' [ SU< S[
U5 S[
U5 35 eUR Xe5 ( d [ S5 eg ! [ a [ SU< S35 ef = f) Nr r zresponse_digest=z unsupportedz expected z of length z got zdigest received was wrong)r r r r r. r r compare_digest)r r r r response_digest response_macexpecteds r _verify_challenger s $@$J!O%.OE88Go>EEG 8}L))!O.k#h- I<()+, , x 6 6!"=>> 7
E!%5_$6l"CDDEs B B:r c [ U[ 5 ( d# [ SR [ U5 5 5 e[
R " [ 5 nSUR S5 U4- nU R [ U- 5 U R S5 n [ XU5 U R [ 5 g ! [ a U R [ 5 e f = f)N Authkey must be bytes, not {0!s}r r )r r r. formatr9 r% r) MESSAGE_LENGTHr r}
_CHALLENGEr r _WELCOMEr _FAILURE)
connectionr r r r s r r# r# s gu % % . 5 5d7m DF F jj (G;--g6@@G *w./$$S)H('H5
h' h'
s B5 5!Cc [ U[ 5 ( d# [ SR [ U5 5 5 eU R S5 nUR
[ 5 ( d [ SU< 35 eU[ [ 5 S n[ U5 [ : a [ S[ U5 S35 e[ X5 nU R U5 U R S5 nU[ :w a [ S5 eg )Nr r z,Protocol error, expected challenge: message=zchallenge too short: z byteszdigest sent was rejected)r r r. r r9 r r< r r r _MD5ONLY_MESSAGE_LENGTHr r} r )r r r r r s r r$ r$ s gu % % . 5 5d7m DF F##C(G j ) )!?wjAC Cc*o&'G
7|--!$9#g, v"NOO
g
/F&!$$S)H8!"<== r c & \ rS rSrS rS rS rSrg)ConnectionWrapperi c h Xl X l X0l S H n[ X5 n[ XU5 M g )N)rm r` r r r} )_conn_dumps_loadsre setattr)rH connr r attrr s r rL ConnectionWrapper.__init__ s0
KD$%C D $ Lr c \ U R U5 nU R R U5 g r )r r r} )rH r rv s r r ConnectionWrapper.send s" KK
a r c X U R R 5 nU R U5 $ r )r r r ru s r r ConnectionWrapper.recv s" JJ ! ! #{{1~ r )r r r N)r r r r rL r r r r r r r r s %! r r c T [ R U 4S S S S5 R S5 $ )Nr utf-8) xmlrpclibr r )r s r
_xml_dumpsr s& ??C64tQ 7 > >w GGr c V [ R U R S5 5 u u pU$ )Nr )r r r )rv r methods r
_xml_loadsr s" __QXXg%67NFS Jr c \ rS rSrS rSrg) XmlListeneri c b SS K Jq [ R U 5 n[ U[ [ 5 $ r )
xmlrpc.clientclientr r r" r r r r s r r" XmlListener.accept s" )ood# j*==r r N)r r r r r" r r r r r r s >r r c J SS K Jq [ [ U 0 UD6[
[ 5 $ r )r r r r r r r )rc kwdss r XmlClientr s % VT 2T 2J
KKr c ^ [ U 5 m/ n[ T5 S: au [ R " TSU5 nUR U4S jU 5 5 U( a8 [
T5 VVs/ s H u pEXCS U- s=: a U; d M O M UPM! snnmSnT( a [ T5 S: a TS S OTn[ R " USU5 nU[ :X a U$ [ Us=:: a [ [ T5 - : a
O O
U[ - nO9[ Us=:: a [ [ T5 - : a
O O
U[ - nO [ S5 eUR TU 5 TUS- S mSnT( a M U$ ! [ a / s $ f = fs snnf )N< Fc 3 . ># U H
nTU v M g 7fr r )r iLs r r #_exhaustive_wait.. s +s!1s r zShould not get herer )
listr r BatchedWaitForMultipleObjects TimeoutErrorextend enumerater r r r
r r )handlesr readyr r r short_Lr s @r _exhaustive_waitr sc
M q6B;
;;AugN
LL+s+ +#,Q<M<4111vz3L3LQ3LQ<MG #A afG00%ICl" #>
A(>>}$!SD+;c!f+DD''"#899 LL3 #a%& AG a )
Ns# E% 'E7E7E7% E43E4c ^ Uc [ nOUS: a SnO[ US- S- 5 n[ U 5 n 0 m / n[ 5 n[ 5 n U H n [ US5 n [
R " U" 5 SS5 u pxU[
R :X a" UR U5 UT UR ' Mf U( aO [ R " 5 S S S: a3 UR S5 u pU( d [! US 5 ( a SUl UR% U5 SnM [+ T R- 5 U5 nU H nUR/ 5 M U Ho n UR S5 u pU[
R0 :w d M- T UR nUR% U5 US:X d MU [! US 5 ( d Mh SUl Mq UR3 U 4S
jU 5 5 U Vs/ s H oUU; d M
UPM sn$ ! [ a# n S U R pU[ ; a e S n A GNS n A ff = f! [ a n U R n S n A GN_S n A ff = f! [& a UT UR) 5 ' GM% f = f! [ a" n U R nU[ ; a e S n A GN1S n A ff = f! U H nUR/ 5 M U H n UR S5 u pO.! [ a! n U R nU[ ; a e S n A OS n A ff = fU[
R0 :w d M\ T UR nUR% U5 US:X d M [! US 5 ( d M SUl M f = fs snf ) Nr r g ?rm Tr )r# r Fr c 3 . ># U H
nTU v M g 7fr r )r r waithandle_to_objs r r wait..y s I=a .q 1=r )r intr setre r r rV r
_ready_errorsr r r r3 getwindowsversionr r5 r addAttributeErrorrD r keysr r update) object_listr ov_list
ready_objects
ready_handlesorm r r r r^ r s @r r r . s, ? G
q[G'D.3./G;'
6 8 $ $Q 1F
"")"2"268Q"E
g 6 66 r*67)"((3
#"7"7"9"1"="G 1)+)?)?)F $'716J+K+K7; 4%))!,"#= !@ -->-C-C-Ew OM 3 3D 9FA
'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
J$ I G< 9M#>L M# $M#M# M# PollSelectorc [ 5 nU H# nUR U[ R 5 M% Ub [ R
" 5 U- n UR
U5 nU( a* U VVs/ s H u pgUR PM snnsS S S 5 $ Ub) W[ R
" 5 -
nUS: a UsS S S 5 $ Mp s snnf ! , ( d f g = fr )
_WaitSelectorregister selectors
EVENT_READr r selectfileobj)r r selectorr deadliner keyeventss r r r s _"!!#y';';< # " >>+g5 0=BCUMSCKKUC _ *"*T^^-="="Q;#( _ D _s$ A#C.CC"C?C
Cc * U R 5 n[ R " U[ R [ R 5 nSSKJn UR U5 n[ X@R U R 44sS S S 5 $ ! , ( d f g = f)Nr )resource_sharer) rm r6 fromfdr SOCK_STREAMr r DupSocketrebuild_connectionrJ rK )r rI rv r dss r reduce_connectionr s^
]]66>>63E3E
F! ) **1-B%MM4=='II G
F
Fs 5B
Bc V U R 5 n[ UR 5 X5 $ r r= r )r rJ rK socks r r r s yy{$++-<r= s 3
1 **OO !
;
69 N H<<7 N H - & 0$
F
F&T Tn ] ]@M MhGv GT
* <<7&/j)V )X& <<76,v 6,p!>
r @B 7&677 *O<24?8?2(5 (*>% >*
H>( >L <<7 @ ..0M0MNML>`
y.))!..
!00
)6 <<7J = z#45K
: ~'=>F2 z#45$
||w
Gs
I I43I4