*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)
z7
Return an arbitrary free address for the given family
r ) 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 eggg)z<
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_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)zQ
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? 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 SL $ )z True if the connection is closedNrE rQ s r closed_ConnectionBase.closed s ||t##r c U R $ )z"True if the connection is readable)rF rQ s r rJ _ConnectionBase.readable ~~ r c U R $ )z"True if the connection is writable)rG rQ s r rK _ConnectionBase.writable ri r c : U R 5 U R $ )z+File descriptor or handle of the connection)rW rE rQ s r fileno_ConnectionBase.fileno s ||r c h U R b U R 5 SU l gg! SU l f = f)zClose the connectionNrO 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) z,Send the bytes data from a bytes-like objectr Br zoffset is negativezbuffer length < offsetNzsize 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)zSend a (picklable) objectN)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 $ )z'
Receive bytes data as a bytes object.
r 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 UsSSS5 $ ! , ( d f g= f)zY
Receive bytes data into a writeable bytes-like object.
Return the number of bytes read.
r znegative offsetzoffset too largeN) 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 $ )z Receive a (picklable) object)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 $ )z/Whether there is any input available to be read)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 \ \ rS rSrSrSrSr\R 4S jr S r
S S jr S r S r
S
rg) PipeConnectioni z
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 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 a3 [ R " UR /S[ 5 nU[ :X d eS U l UR S5 u pSU[ R :X a [ [ R S5 eUS:X d eU[! U5 :X d eg ! UR 5 e = f! S U l UR S5 u pSf = f)Nz/concurrent send_bytes() calls are not supportedT
overlappedFrU r )r r. _winapi WriteFilerE ERROR_IO_PENDINGWaitForMultipleObjectseventr r r GetOverlappedResultERROR_OPERATION_ABORTEDrV errnoEPIPEr )rH rx r errwaitresnwrittens r rw PipeConnection._send_bytes! s }}( "5 6 6 '' cdKGB M
='222 % < <
E8 5G"m333
!%
" 6 6t <
g555 ekk+=>>!8O8s3x' ''
$
" 6 6t <
#s AC+ +C>>D D c U R ( a SU l [ R " 5 $ Uc SO [ US5 n [ R
" U R USS9u p4 U[ R :X a3 [ R " UR /S[ 5 nU[ :X d eUR 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 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#*m#; ;#;
&(%;%;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] "G #AD* *AG 9$G *D==E AF>G 'F>;G =F>>G
G5 %G00G5c 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 nUS: d eUb" [ U5 U- U: a U R 5 [ R " U R USS9u pUR S5 u pvUS:X d eXu:X d eUR UR 5 5 U$ )Nr r 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!8O8"s3x$'@((* &&t||TdKGB 006KF!8O8> !>
GGBLLN #Hr )r r r )r r r r __doc__r r r CloseHandlerP rw r r r r r r r r r s8
#&-&9&9 ' (4 Q@ /
r r c \ rS rSrSr\( 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 zc
Connection class based on an arbitrary file descriptor (Unix only), or
a socket handle (Windows).
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 r _multiprocessing closesocketrP r _writer _readr% r` r r r r rw r r r r r r r r q so
0 < < !!&& %% " ! % % ). r r c Z \ rS rSrSrS S jrS rS r\S 5 r \S 5 r
S r S
r S r
g)
r i 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 \ 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$ )zb
Accept a connection on the bound socket or named pipe of `self`.
Returns a `Connection` object.
zlistener is closed)r rV acceptr deliver_challengeanswer_challenge)rH cs r r# Listener.accept sS >> !./ / NN ! ! # == $ a / Q
.r c R U R nUb SU l UR 5 gg)z1
Close the bound socket or named pipe of `self`.
N)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 r rL r# r` r r> r0 r r r r r r r r sH 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$ )z5
Returns a connection to the address of a `Listener`
r 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$ )<
Returns pair of connection objects at either end of a pipe
TFrK rJ )r6
socketpair setblockingr detachr% pipe)duplexs1s2c1c2fd1fd2s r r r & s &&(FB NN4 NN4 BIIK(BBIIK(B v
wwyHCC%0BC%0Bv
r c ` 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 SS5 [ R2 " WSS9n
U
R5 S5 u pU S:X d e[7 XpS9n
[7 XS9nX4$ ! [" aF nU[$ : a e UR& [ R( [ R* 4; a e SnAGM SnAff = f) r: r r r NTr r; 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 )rA openmodeaccessobsizeibsizer r> h1r h2r _r rD rE 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
//5axx
B
0
B
0v
+
11::g&=&=&-&A&A&C CC
s B G
H-':H((H-c . \ rS rSrSrSS jrS rS rSrg) r in zG
Representation of a socket which is bound to an address and listening
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)rh 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 )rh r` rs )rH rr s r r` SocketListener.close s[ LL \\F! # " \\F! # "s ; A)r, rp r/ rh rs N)r ) 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 sSSS5 $ ! , ( d f g= f)zG
Return a connection object connected to the socket given by `address`
TN)r? r6 rg r> connectr r? )r> r0 rw s r r8 r8 sU '
"F / 1Q
d '!((*%
2 1 1s ;A55
Bc B \ rS rSrSrS S jrS
S jrS r\S 5 r Sr
g) r i z
Representation of a named pipe
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 rd )
r, _new_handle
_handle_queuer/ r sub_debugrq 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 rI rO rP rN r, rQ rR rS PIPE_UNLIMITED_INSTANCESrL rT rU )rH r flagss r r PipeListener._new_handle s ..1M1MME>>>**
u))G,I,II!!"00'7,,gll
r c Z U R R U R 5 5 U R R S5 n [ R
" USS9n [ R " UR /S[ 5 n UR S5 u pEUS:X d e [ U5 $ ! UR 5 [ R " U5 e = f! UR S5 u pEUS:X d ef = f! [ a) nUR [ R :w a e S nANS nAff = f)Nr Tr F)r appendr popr rY 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 !8O8!&) )IIK''/ 3 3D 9FA !8O8
::!6!66 7
s0 C7 'B+ +)CC C47
D* D%%D*c 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 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 SS5 [! U5 $ ! [ aI nUR [ R [ R 4; d [ U5 ( a e SnAOSnAff = fGM )zE
Return a connection object connected to the pipe given by `address`
r N)r r
WaitNamedPiperV rJ rK rU rW rO rV r ERROR_SEM_TIMEOUTr r rX rR r )r> r hr s r r7 r7 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$ [ S U < 35 e)
zReturns 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 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 k s 7|&
7{4 ,,tQ(9: :a?5! % % Agh'G==)72 2
/&-Z
1 2 2r c SSK n[ U5 S nU( d! UR XS5 R 5 $ UR XU5 R 5 nSUR S5 U4- $ ! [ a Sn NDf = f)ao 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}%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 SSK n[ U5 u pEU=( d Sn UR XU5 R 5 n[
U5 [
U5 :w a' [ SU< S[
U5 S[
U5 35 eUR Xe5 ( d [ S 5 eg! [ a [ SU< S35 ef = f)
aH 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 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[
[ : d S5 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}zprotocol constraintr r )r r r. formatr9 MESSAGE_LENGTH_MD5ONLY_MESSAGE_LENGTHr% r) r r}
_CHALLENGEr r _WELCOMEr _FAILURE)
connectionr r r r s r r$ r$ s gu % % . 5 5d7m DF F 3 3J5JJ 3jj (G;--g6@@G *w./$$S)H('H5
h' h'
s ( C
!C+c [ 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 r r 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_loadsrg 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 rw s r r ConnectionWrapper.send s" KK
a r c X U R R 5 nU R U5 $ r )r r r rv 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 )rw 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 )re 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 SS S: a3 UR S 5 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 SU R pU[ ; a e Sn A GNSn A ff = f! [ a n U R n Sn A GN_Sn A ff = f! [& a UT UR) 5 ' GM% f = f! [ a" n U R nU[ ; a e Sn A GN1Sn A ff = f! U H nUR/ 5 M U H n UR S5 u pO.! [ a! n U R nU[ ; a e Sn A OSn A ff = fU[
R0 :w d M\ T UR nUR% U5 US:X d M [! US
5 ( d M SUl M f = fs snf )
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 ?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 setrg 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 snnsSSS5 $ Ub) W[ R
" 5 -
nUS: a UsSSS5 $ Mp s snnf ! , ( d f g= f)r Nr )
_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 rw 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