ÿØÿà 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\hJ D / S Qr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSK
J r SSK J
r
SSKJrJrJr SSK Jr SS K Jr SS
K Jr SS K Jr SS K Jr S
r\ R1 S5 S r\R6 " \R \5 S V s/ s H n \ " \ " 0 U 5 " 5 5 PM sn r S r \ H r \R6 " \ \ 5 M C C " S S\!5 r"S0 4S jr#S r$ " S S\%5 r&S r'S r( " S S \!5 r) " S S \!5 r*\
RV \
RX 4\
RZ \
R\ 4S .r/ " S! S"\!5 r0 " S# S$\15 r2 " S% S&\!5 r3S' r40 4S( jr5 ScS) jr6 " S* S+\!5 r7 " S, S-\!5 r8SdS. jr9 " S/ S0\35 r: " S1 S2\35 r; " S3 S4\;5 r< " S5 S6\35 r= " S7 S8\35 r> " S9 S:\35 r? " S; S<\35 r@\5" S=S>5 rA " S? S@\A5 rB\5" SASB5 rCSCSD0\ClD " SE SA\C5 rE\5" SFSG5 rF\5" SHSI5 rGSJSJSJSDSDSK.\GlD " SL SH\G5 rH " SM SN\05 rI\IR7 SO\R 5 \IR7 SP\R 5 \IR7 SQ\R \=5 \IR7 SR\R \;5 \IR7 SS\R \;5 \IR7 ST\R \;5 \IR7 SU\R \;5 \IR7 SV\R \<5 \IR7 SW\R \>5 \IR7 SX\R \H5 \IR7 SY\S\B5 \IR7 SZ\T\E5 \IR7 S-\8\@5 \IR7 S[\9\F5 \IR7 S+\7\?5 \IR7 SD\:SS\9 \IR7 SJSS]9 \( a! " S^ S_5 rU " S` Sa\)5 rV " Sb S\05 rWgg! \ a Sr GNf = fs sn f )e) BaseManager SyncManager BaseProxyToken N)getpid)
format_exc )
connection) reductionget_spawning_popen ProcessError)pool)process)util) get_context)
shared_memoryTSharedMemoryManagerFc Z [ R U R U R 5 44$ N)arraytypecodetobytes)as //usr/lib/python3.13/multiprocessing/managers.py reduce_arrayr / s ;;QYY[1 11 )itemskeysvaluesc & [ [ U 5 44$ r )listobjs r rebuild_as_listr$ 4 s $s) r c 4 \ rS rSrSrSrS rS rS rS r Sr
g )
r > z+
Type to uniquely identify a shared object
typeidaddressidc . XUsU l U l U l g r r' )selfr( r) r* s r __init__Token.__init__D s 06,dlDGr c H U R U R U R 4$ r r' r, s r __getstate__Token.__getstate__G s T\\47733r c . Uu U l U l U l g r r' r, states r __setstate__Token.__setstate__J s /4,dlDGr c U R R < SU R < SU R < SU R < S3$ )Nz(typeid=z
, address=z, id=)) __class____name__r( r) r* r0 s r __repr__Token.__repr__M s- ''dllDGGM Mr )r) r* r( N) r;
__module__ __qualname____firstlineno____doc__ __slots__r- r1 r6 r< __static_attributes__ r r r r > s$ ,IE45Mr r rD c U R XX445 U R 5 u pVUS:X a U$ [ XV5 e! Af = f)zD
Send a message to manager using connection `c` and return response
#RETURN)sendrecvconvert_to_error)cr*
methodnameargskwdskindresults r dispatchrP U sD FFBD '(668LD y
t,, s : =c U S:X a U$ U S; aX [ U[ 5 ( d$ [ SR X[ U5 5 5 eU S:X a [ SU- 5 $ [ U5 $ [
SR U 5 5 $ )N#ERROR)
#TRACEBACK#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strrT zUnserializable message: %s
z Unrecognized message type {!r})
isinstancestr TypeErrorformattype RemoteError
ValueError)rN rO s r rI rI b s x
2 2&#&&@GG$v,01
1 $ $ = FG G v& &:AA$GHHr c \ rS rSrS rSrg)rZ q c > S[ U R S 5 - S- $ )NzM
---------------------------------------------------------------------------
r zK---------------------------------------------------------------------------)rV rL r0 s r __str__RemoteError.__str__r s $s499Q<'886ABr rD N)r; r> r? r@ r_ rC rD r r rZ rZ q s Cr rZ c / n[ U 5 H1 n[ X5 n[ U5 ( d M UR U5 M3 U$ )z,
Return a list of names of methods of `obj`
)dirgetattrcallableappend)r# tempnamefuncs r all_methodsri y s= DCs! D>> KK Kr c X [ U 5 Vs/ s H oS S:w d M
UPM sn$ s snf )zH
Return a list of names of methods of `obj` which do not start with '_'
r _)ri )r# rg s r public_methodsrl s+ ) - @ -TaC D - @@ @s ''c \ rS rSrSr/ SQrS rS rS rS r S r
S r S
r S r
S r\
\\ S
.rS rS rS rS rS rS rS rS rS rSrg)Server zE
Server class which runs in a process controlled by a manager object
) shutdowncreateaccept_connection get_methods
debug_infonumber_of_objectsdummyincrefdecrefc ~ [ U[ 5 ( d$ [ SR U[ U5 5 5 eXl [ R " U5 U l [ U u pVU" USS9U l
U R R U l SS0U l 0 U l
0 U l [ R " 5 U l g )Nz&Authkey {0!r} is type {1!s}, not bytes )r) backlog0NrD )rU bytesrW rX rY registryr AuthenticationStringauthkeylistener_clientlistenerr) id_to_objid_to_refcountid_to_local_proxy_obj threadingLockmutex)r, r r) r
serializerListenerClients r r- Server.__init__ s '5))8??T'],-
- !
33G< *:6 !#>
}},, z* %'" ^^%
r c [ R " 5 U l U [ R " 5 l [ R " U R S9nSUl UR 5 U R R 5 ( d< U R R S5 U R R 5 ( d M< [ R [ R :w aH [" R$ " S5 [ R [ l [ R& [ l [ R* " S5 g! [ [ 4 a Nf = f! [ R [ R :w aH [" R$ " S5 [ R [ l [ R& [ l [ R* " S5 f = f)z
Run the server forever
)targetTr zresetting stdout, stderrr N)r Event
stop_eventr current_process_manager_serverThreadaccepterdaemonstartis_setwaitKeyboardInterrupt
SystemExitsysstdout
__stdout__r debug
__stderr__stderrexit)r, r s r
serve_foreverServer.serve_forever s& $//+48 !1 ''t}}=H "HO NN
//0022OO((+ //0022
zzS^^+
56 ^^
^^
HHQK &z2
zzS^^+
56 ^^
^^
HHQKs+ 5E ,AE EE EE BG c U R R 5 n[ R " U R
U4S9nSUl UR 5 MT ! [ a Mb f = f)NTr rL )r acceptOSErrorr r handle_requestr r )r, rJ ts r r Server.accepter sa
MM((* (;(;1$GAAH
GGI
s A
A$#A$c S n [ R " XR 5 [ R " XR 5 UR 5 nUu p4pVX@R
; d
SU- 5 e[
X5 n U" U/UQ70 UD6nSU4n UR U 5 g ! [ a S[ 5 4n N+f = f! [ a S[ 5 4n NGf = f! [ a| n
UR S[ 5 45 O! [ a Of = f[ R " SU 5 [ R " SU5 [ R " SU
5 S n
A
g S n
A
ff = f)Nz%r unrecognizedrF rS zFailure to send message: %rz ... request was %r ... exception was %r) r
deliver_challenger answer_challengerH publicrc Exceptionr rG r info) r, rJ requestignorefuncnamerL rM rh rO msges r _handle_requestServer._handle_request sC * ( (LL 9 ' '<< 8ffhG+2 (Fd{{* H,=,H H*4*D
* a/$/$/ !&) 2
FF3K
3#Z\2
3 / .C / 2
jl34
II3S 9 II+W 5 II-q 1 1 2s[ A9B= > B! C !B:9B:=CC
E $D ?E
D
E D
AEE c U R U5 UR 5 g! [ a N f = f! UR 5 f = f)z
Handle a new connection
N)r r closer, conns r r Server.handle_request s@ &
JJL
JJLs $
14 14 Ac n [ R " S[ R " 5 R 5 UR
nUR nU R nU R R 5 ( d S=pVU" 5 nUu pp XH u pkn X[; a [ SU< S[ U5 < SU < 35 e[ Xe5 n U" U 0 U
D6nU =( a U R US5 nU( a4 U R! UUU5 u nn[# UU R$ U5 nSUU44nOSU4n U" W5 U R R 5 ( d M gg! [ a- n
U R U u pkn Sn
A
N! [ a U
ef = fSn
A
ff = f! [& a nSU4n SnANzSnAff = f! [ aS Wc S [) 5 4n N U R* U nU" XWW/W Q70 W
D6nSU4n N! [& a S [) 5 4n Nf = f[, aN [ R " S
[ R " 5 R 5 [. R0 " S 5 GN4[& a S [) 5 4n GNLf = f! [& a U" S [) 5 45 GNef = f! [& a n[ R2 " S
[ R " 5 R 5 [ R2 " SW5 [ R2 " SU5 UR5 5 [. R0 " S5 SnAGNSnAff = f)zA
Handle requests from the proxies in a particular process/thread
z$starting server thread to service %rNzmethod z of z object is not in exposed=#PROXYrF rR rS z$got EOF -- exiting thread serving %rr rT z exception in thread serving %rz ... message was %rr r )r r r current_threadrg rH rG r r r KeyErrorr AttributeErrorrY rc getrq r r) r r fallback_mappingEOFErrorr r r r )r, r rH rG r rK r# r identrL rM exposed gettypeidkefunctionresr( ridentrexposedtokenr r
fallback_funcrO s r serve_clientServer.serve_client s
9 ++-22 4 yyyyNN //((**5
3#''
&07-4!.7.>+C) ,(#T#Y9
#33 /"D1D1C ' J9==T+JF +/;;tVS+I( %fdllF C '(E): ; (# ..
<Iw //((** !! 6 6u = 0i# ! ! !" ! (#Q-C( "
; %' 6C;(,(=(=j(I
!. s" 59" =A" )& 1$ ; +Z\ :;
A$335::<
3#Z\2
3 ! <+Z\:;<
:!002779 /5 115
s 9F& E 0F& F AF& F& &I4
F E3.F& 3
F FFF&
F#F F& F##F& &I1!G%%G?;I1>G??AI1I10I14 JJ JJ
L4!BL//L4c U$ r rD r, r r r# s r fallback_getvalueServer.fallback_getvalueB s
r c [ U5 $ r rV r s r fallback_strServer.fallback_strE s 3xr c [ U5 $ r )reprr s r
fallback_reprServer.fallback_reprH s Cyr )r_ r< #GETVALUEc g r rD r, rJ s r rv Server.dummyQ s r c
U R / n[ U R R 5 5 nUR 5 U HQ nUS:w d M UR SU< SU R U < S[
U R U S 5 SS < 35 MS SR U5 sSSS5 $ ! , ( d f g= f) z?
Return some info --- useful to spot problems with refcounting
r| z z: refcount=z
r NK
) r r! r r sortre rV r join)r, rJ rO r r s r rt Server.debug_infoT s
ZZF++0023D IIK C<MM#($*=*=e*D#&t~~e' r? r@ rA r r- r r r r r r r r r rv rt ru rp rq rs rr rw rx rC rD r r rn rn s NF&$, 2<
O b %
% ( ""%H2 "*r rn c & \ rS rSrS/rSrSrSrSrg)Statei valuer r rD N) r; r> r? r@ rB INITIALSTARTEDSHUTDOWNrC rD r r r r s IGGHr r )pickle xmlrpclibc \ rS rSrSr0 r\r SSS.S jjrS r S r
SS jr \ SS
j5 r
S rSS jrS
rS rS rS r\S 5 r\S 5 r\ SS j5 rSrg)r i z
Base class for managers
Ng ?)shutdown_timeoutc Z Uc [ R " 5 R nXl [ R " U5 U l [
5 U l [ R U R l X0l
[ U u U l U l
U=( d
[ 5 U l XPl g r )r r r _addressr _authkeyr _stater r _serializerr _Listener_Clientr _ctx_shutdown_timeout)r, r) r r ctxr s r r- BaseManager.__init__ sx ? --/77G
44W=
g !MM %'6z'B$ (;= !1 r c U R R [ R :w a U R R [ R :X a [ S5 eU R R [ R :X a [ S5 e[ SR U R R 5 5 e[ U R U R U R U R 5 $ )zH
Return server object with serve_forever() method and address attribute
Already started serverManager has shut downUnknown state {!r})
r r r r r r
r rX rn _registryr
r r r0 s r
get_serverBaseManager.get_server s ;;
-{{ EMM1"#;<<""enn4"#:;;"(// 0A0ABD DdnndmmmmT%5%57 7r c [ U R u pU" U R U R S9n[ USS5 [
R U R l g)z.
Connect manager object to the server process
r Nrv ) r r r
r rP r r r r )r, r r r s r connectBaseManager.connect sG +4+;+;<dmmT]];tW% !MM r c
U R R [ R :w a U R R [ R :X a [ S5 eU R R [ R :X a [ S5 e[ SR U R R 5 5 eUb [ U5 ( d [ S5 e[ R " SS9u p4U R R [ U 5 R U R U R" U R$ U R& XAU4S9U l S R+ S
U R( R, 5 5 n[ U 5 R. S - U- U R( l U R( R3 5 UR5 5 UR7 5 U l UR5 5 [ R U R l [8 R: " U [ U 5 R< U R( U R" U R$ U R U R> U R@ 4S S
9U l! g)z0
Spawn a server process for this manager object
r r r Nz initializer must be a callableF)duplexr :c 3 8 # U H n[ U5 v M g 7fr r ).0is r $BaseManager.start..3 s A)@AQ)@s -r rL exitpriority)"r r r r r r
r rX rd rW r
Piper ProcessrY _run_serverr r
r r _processr _identityr; rg r r rH r Finalize_finalize_managerr r rp )r, initializerinitargsreaderwriterr s r r BaseManager.start s ;;
-{{ EMM1"#;<<""enn4"#:;;"(// 0A0ABD D "8K+@+@ <= = $ 6 )):))..$-- ""FC *
A )@)@AA !$Z 0 0C 7% ?
"MM
$t*..--
t{{,, 6 68
r c V [ R " [ R [ R 5 Ub U" U6 U R XX45 nUR UR
5 UR
5 [ R " SUR
5 UR 5 g)z0
Create a server, report its address and run it
Nzmanager serving at %r)
signalSIGINTSIG_IGN_ServerrG r) r r r r ) clsr r) r r r7 r4 r5 servers r r/ BaseManager._run_serverE sv
fmmV^^4 " " XD FNN#
)6>>: r c N U R R [ R :X d S5 eU R U R
U R S9n [ USSU4U- U5 u pVUR 5 [ XR
U5 U4$ ! UR 5 f = f)z@
Create a new shared object; return the token and exposed tuple
zserver not yet startedr Nrq )
r r r r r r
r rP r r )r, r( rL rM r r* r s r _createBaseManager._create\ s {{ EMM1K3KK1||DMM4==|A "4x&4 NKB JJLV]]B/88
JJLs B B$c U R bC U R R U5 U R R 5 ( d SU l ggg)z3
Join the manager process (if it has been spawned)
N)r0 r is_aliver, timeouts r r BaseManager.joinh sD == $ MM w '==))++ $
, %r c U R U R U R S9n [ USS5 UR 5 $ ! UR 5 f = f)zC
Return some info about the servers shared objects and connections
r Nrt r r
r rP r r s r _debug_infoBaseManager._debug_infoq sB ||DMM4==|A D$ 5 JJLDJJL A Ac U R U R U R S9n [ USS5 UR 5 $ ! UR 5 f = f)z%
Return the number of shared objects
r Nru rJ r s r _number_of_objects BaseManager._number_of_objects{ sC ||DMM4==|A D$(;< JJLDJJLrM c U R R [ R :X a U R 5 U R R [ R
:w a U R R [ R :X a [
S5 eU R R [ R :X a [
S5 e[
SR U R R 5 5 eU $ )NzUnable to start serverr r ) r r r r r r r
r rX r0 s r __enter__BaseManager.__enter__ s ;;
- JJL ;;
-{{ EMM1"#;<<""enn4"#:;;"(// 0A0ABD D r c $ U R 5 g r )rp r, exc_typeexc_valexc_tbs r __exit__BaseManager.__exit__ s
r c U R " 5 ( Ga
[ R " S5 U" XS9n [ USS5 UR 5 U R " US9 U R " 5 ( a [ R " S5 [ U S5 ( a [ R " S5 U R " 5 U R " US9 U R " 5 ( a8 [ R " S 5 U R " 5 U R " 5 [ R Ul [ R U g! UR 5 f = f! [
a GN f = f! [ a gf = f)
zA
Shutdown the manager process; will be registered as a finalizer
z#sending shutdown message to managerr Nrp )rG zmanager still alive terminatez'trying to `terminate()` manager processz#manager still alive after terminate)rE r r rP r r r hasattrr\ killr r r r _address_to_localr )r r) r r5 r r r s r r3 BaseManager._finalize_manager s$ II; <
w8! T44JJL
LL!1 2 !! /07K00II GH%%'LL)9: '')) "GH nn ++G4% JJL
$ s: E"
E
E" ;E3
E E" "
E0/E03
F ?F c U R $ r )r
r0 s r r) BaseManager.address s }} r c ^^ SU R ; a U R R 5 U l Tc [ mU=( d
[ TSS5 nU=( d
[ TSS5 nU( aZ [ UR
5 5 H= u px[ U5 [ L d
SU- 5 e[ U5 [ L a M5 SU- 5 e X$UT4U R T' U( a UU4S jn TU l [ U TU 5 gg)z)
Register a typeid with the manager type
r N _exposed__method_to_typeid_z%r is not a stringc > [ R " ST5 U R " T/UQ70 UD6u p4T" X0R U U R US9nU R UR U R S9n[ US SUR 45 U$ )Nz)requesting creation of a shared %r objectmanagerr r r rx ) r r rB r r r r) rP r* ) r, rL rM r expproxyr r r( s r rf "BaseManager.register..temp s
FO !\\& @4 @4 @
!++T MM3 ||EMM4==|ItX{; r ) __dict__r copy AutoProxyrc r! r rY rV r; setattr)
r> r( rd r r r
create_methodkeyr rf s
` ` r registerBaseManager.register s cll * MM . . 0CM !IBWY T B+ J"9.BDI "#3#9#9#; <
CyC'C)=)CC'E{c)G+?%+GG) =
/!
f
#DM C & r )
r r r
r r r0 r r r rp )NNr Nr} r )NNNNT)r; r> r? r@ rA r rn r= r- r r r classmethodr/ rB r rK rO rR rY staticmethodr3 propertyr) rr rC rD r r r r s IG>F 2/2 2
7 *)V /1 ,
9% D EI6:%' %'r r c \ rS rSrS rS rSrg)ProcessLocalSeti c 4 [ R " U S 5 g )Nc " U R 5 $ r )clearr" s r *ProcessLocalSet.__init__.. s
399;r )r register_after_forkr0 s r r- ProcessLocalSet.__init__ s '>?r c [ U 5 S4$ r} )rY r0 s r
__reduce__ProcessLocalSet.__reduce__ s Dz2~ r rD N)r; r> r? r@ r- r rC rD r r rx rx s
@ r rx c \ rS rSrSr0 r\R " 5 rSr SS jr
S r S0 4S jr S r
S
r\S 5 rS rS
rS rS rS rSrg)r i z&
A base for proxies of shared objects
r Nc [ R [ R R UR S 5 nUc< [
R " 5 [ 5 4nU[ R UR ' [ R U l [ =R S-
sl S S S 5 WS U l
US U l Xl U R R U l X0l X l [" U S U l Xpl Ub [( R* " U5 U l OMU R b U R R, U l O$[( R. " 5 R0 U l U( a U R3 5 [
R4 " U [ R6 5 g ! , ( d f GN= f)Nr r ) r _mutexr_ r r) r ForkAwareLocalrx _next_serial_serial_tls _all_serials_tokenr* _id_managerr r r _owned_by_managerr r r r r _increfr~ _after_fork) r, r r rh r r rw
manager_owned tls_serialss r r- BaseProxy.__init__ sB
#5599%--NK" " 1 1 3_5F F =H ++EMM:$11DL " "a ' " N
(N ;;>>
%&z215 "/ # 8 8 ADM
]]
& MM 2 2DM # 3 3 5 = =DM LLN y'<'<=Q
s BF22
Gc [ R " S5 [ R " 5 R n[
R " 5 R S:w a% US[
R " 5 R - -
nU R U R R U R S9n[ US SU45 X R l
g )Nz making connection to manager
MainThread|r rr )r r r r rg r r r r r) r rP r r
)r, rg r s r _connectBaseProxy._connect) s
12&&(-- # # % * *l : C)224999 9D||DKK / / |Gt 04': # r rD c U R R nUR U R XU45 UR 5 u pVUS:X a U$ US:X a Uu pxU R R UR S n U R R Ul U " XR" U R U R$ US9n
U R' UR U R$ S9n[) USSUR* 45 U
$ [- XV5 e! [ a^ [ R " S[
R " 5 R 5 U R 5 U R R n GN\f = f! Af = f) zF
Try to call a method of the referent and return a copy of the result
z#thread %r does not own a connectionrF r rg r Nrx )r r
r r r r r rg r rG r rH r r r( r r) r r r rP r* rI ) r, rK rL rM r rN rO r r r rj s r _callmethodBaseProxy._callmethod2 s= (99''D
488Zt45yy{ 9 M
X
#NG
// =bAI KK / /EM ''
wE <<
t}}<ED T4EHH; 7L "40 0/ ( JJ< //166
8 MMO99''D (2 s D
E8
A$E54E58E;c $ U R S5 $ )z)
Get a copy of the value of the referent
r r r0 s r _getvalueBaseProxy._getvalueS s ,,r c U R ( a, [ R " SU R R 5 g U R U R R U R S9n[ US SU R 45 [ R " SU R R 5 U R R U R 5 U R =( a U R R n[ R " U [ R" U R U R U R UU R$ U R U R
4SS9U l g )Nz%owned_by_manager skipped INCREF of %rr rw z INCREF %r
r+ )r r r r r* r r) r rP r r addr r r r2 r _decrefr _close)r, r r5 s r r BaseProxy._increfY s ! ! JJ> O ||DKK / / |GtX{3
; / dll+
6$--"6"6mm )##++t||T]]E))T . . > r c t UR U5 Ub UR [ R :X aM [ R
" SU R 5 U" U R US9n[ US SU R 45 O![ R
" SU R 5 U( dc [ US5 ( aQ [ R
" S[ R " 5 R 5 UR R 5 U?g g g ! [ a! n[ R
" SU5 S nANS nAff = f)Nz DECREF %rr rx z... decref failed %sz%DECREF %r -- manager already shutdownr
z-thread %r has no more proxies so closing conn)discardr r r r r r* r) rP r r] r r rg r
r ) r serialr r5 tlsidsetr r r s r r BaseProxy._decrefm s
f =EKK5== 8
6
;1 u}}g>tX{;
JJ> I l33 JJF //166
8 NN " 4u
6
1155
6s A D
D7D22D7c S U l U R 5 g ! [ a# n[ R " SU- 5 S nAg S nAff = f)Nzincref failed: %s)r r r r r )r, r s r r BaseProxy._after_fork s<
/ LLN / II)A- . . /s
AAAc 0 n[ 5 b U R US' [ U SS5 ( a3 U R US' [ [
U R U R U44$ [ [ U 5 U R U R U44$ )Nr _isautoFr ) r r rc rd RebuildProxyrn r r rY r, rM s r r BaseProxy.__reduce__ s + "mmDO 4E * * "nnDO T-=-=tDF
F !$Zd.>.>EG
Gr c " U R 5 $ r )r )r, memos r __deepcopy__BaseProxy.__deepcopy__ s ~~ r c r S[ U 5 R U R R [ U 5 4- $ )Nz <%s object, typeid %r at %#x>)rY r; r r( r* r0 s r r< BaseProxy.__repr__ s3 .T
##T[[%7%7DBC Cr c h U R S5 $ ! [ a [ U 5 SS S- s $ f = f)zF
Return representation of the referent (or a fall-back if that fails)
r< Nr z; '__str__()' failed>)r r r r0 s r r_ BaseProxy.__str__ s= =##J/ / =:cr?%<< < =s 11) r r r r r r r r r r r NNNTF)r; r> r? r@ rA r_ r ForkAwareThreadLockr r r- r r r r ru r r r r r< r_ rC rD r r r r s{
%
%
'F L26HM*>X$ ,.B B- ( 0/ G C=r r c [ [ R " 5 SS5 nU( a UR UR :X af [ R
" SU5 SUS' UR UR ; a0 UR UR UR UR ' UR SS5 =( a% [ [ R " 5 SS5 ( + nU " X4SU0UD6$ ) z-
Function used for unpickling proxy objects.
r Nz*Rebuild a proxy owned by manager, token=%rTr rw _inheritingF)
rc r r r) r r r* r r pop)rh r r rM r? rw s r r r s W,,.0A4
HF
&..EMM1
?G $_ 88677 7 *
( ( 2
4 E G++-}e DD 9& 9D 99r c [ U5 n X U4 $ ! [ a Of = f0 nU H n[ SU< SU< S3U5 M [ U [ 4U5 nXl XRX4' U$ )z:
Return a proxy type whose methods are given by `exposed`
zdef z:(self, /, *args, **kwds):
return self._callmethod(z
, args, kwds))r r execrY r rd )rg r _cachedicmeth ProxyTypes r
MakeProxyTyper s GnG
Wo&&
C 6:DBCF H TI<-I! 'D? s
c h [ U S nUc1 U" U R US9n [ USSU 45 nUR 5 Uc Ub UR nUc [
R " 5 R n[ SU R - U5 n U " XX#XVS9n
SU
l
U
$ ! UR 5 f = f)z"
Return an auto-proxy for `token`
r Nr rs z
AutoProxy[%s])rh r rw r T) r r) rP r r r r r r r( r ) r r rh r r rw r r r r rj s r rn rn s
j)!,Gu}}g6 tT=5(CG JJL7.""))+33 o >22DIIdODDr rD N)r; r> r? r@ r- r< rC rD r r r r s
#Er r c B \ rS rSrSS jrS rS rS r\" \\5 r Sr
g) Valuei c Xl X l g r _typecode_value)r, r r locks r r- Value.__init__ s ! r c U R $ r r r0 s r r Value.get s {{r c Xl g r r r, r s r r Value.set s r c l [ U 5 R < SU R < SU R < S3$ )Nr r r9 )rY r; r r r0 s r r< Value.__repr__ s! !$Z 0 0$..$++NNr r NT) r; r> r? r@ r- r r r< rv r rC rD r r r r s# O S# Er r c . [ R " X5 $ r )r )r sequencer s r Arrayr s ;;x **r c 6 \ rS rSrSrS rS rS rS rS r Sr
g )
IteratorProxyi )__next__rG throwr c U $ r rD r0 s r __iter__IteratorProxy.__iter__ r c & U R SU5 $ )Nr r r, rL s r r IteratorProxy.__next__ s
D11r c & U R SU5 $ )NrG r r s r rG IteratorProxy.send s --r c & U R SU5 $ )Nr r r s r r IteratorProxy.throw ..r c & U R SU5 $ )Nr r r s r r IteratorProxy.close r r rD N) r; r> r? r@ rd r r rG r r rC rD r r r r s 6I2.//r r c 4 \ rS rSrSrS S jrS rS rS rSr g)
AcquirerProxyi$ )acquirereleaseNc 8 Uc U4OX4nU R SU5 $ Nr r )r, blockingrG rL s r r AcquirerProxy.acquire& s% %o{H3F 400r c $ U R S5 $ Nr r r0 s r r AcquirerProxy.release) **r c $ U R S5 $ r r r0 s r rR AcquirerProxy.__enter__+ r r c $ U R S5 $ r r rU s r rY AcquirerProxy.__exit__- r r rD )TN)
r; r> r? r@ rd r r rR rY rC rD r r r r $ s &I1+++r r c < \ rS rSrSrS S jrS
S jrS rS S jrSr g) ConditionProxyi1 )r r r notify
notify_allNc ( U R SU45 $ Nr r rF s r r ConditionProxy.wait3
33r c ( U R SU45 $ )Nr r )r, ns r r ConditionProxy.notify5 s 1$//r c $ U R S5 $ )Nr
r r0 s r r
ConditionProxy.notify_all7 s --r c U" 5 nU( a U$ Ub [ R " 5 U- nOS nS nU( dE Ub! U[ R " 5 -
nUS:: a U$ U R W5 U" 5 nU( d ME U$ )Nr )time monotonicr )r, predicaterG rO endtimewaittimes r wait_forConditionProxy.wait_for9 s M nn&0GGH""T^^%55q=
IIh [F
&
r rD r )r )
r; r> r? r@ rd r r r
r rC rD r r r r 1 s FI40.r r c 4 \ rS rSrSrS rS rS rS S jrSr g)
EventProxyiL )r r r{ r c $ U R S5 $ )Nr r r0 s r r EventProxy.is_setN s ))r c $ U R S5 $ Nr r r0 s r r EventProxy.setP &&r c $ U R S5 $ )Nr{ r r0 s r r{ EventProxy.clearR ((r Nc ( U R SU45 $ r r rF s r r EventProxy.waitT r r rD r )
r; r> r? r@ rd r r r{ r rC rD r r r r L s 2I*')4r r c ^ \ rS rSrSrS S jrS rS r\S 5 r \S 5 r
\S 5 r S
r g) BarrierProxyiX )__getattribute__r abortresetNc ( U R SU45 $ r r rF s r r BarrierProxy.waitZ r r c $ U R S5 $ )Nr/ r r0 s r r/ BarrierProxy.abort\ r) r c $ U R S5 $ )Nr0 r r0 s r r0 BarrierProxy.reset^ r) r c & U R SS5 $ )Nr. )partiesr r0 s r r8 BarrierProxy.parties` s 2LAAr c & U R SS5 $ )Nr. ) n_waitingr r0 s r r; BarrierProxy.n_waitingc s 2NCCr c & U R SS5 $ )Nr. )brokenr r0 s r r> BarrierProxy.brokenf s 2K@@r rD r )
r; r> r? r@ rd r r/ r0 rv r8 r; r> rC rD r r r- r- X sR >I4))
B B
D D
A Ar r- c * \ rS rSrSrS rS rS rSrg)NamespaceProxyik )r. __setattr__ __delattr__c ~ US S:X a [ R X5 $ [ R U S5 nU" SU45 $ )Nr rk r r. )objectr. r, rq
callmethods r __getattr__NamespaceProxy.__getattr__m s@ q6S=**45 5,,T=A
,sf55r c US S:X a [ R XU5 $ [ R U S5 nU" SX45 $ )Nr rk r rB )rE rB r. )r, rq r rG s r rB NamespaceProxy.__setattr__r sA q6S=%%d7 7,,T=A
-# 66r c ~ US S:X a [ R X5 $ [ R U S5 nU" SU45 $ )Nr rk r rC )rE rC r. rF s r rC NamespaceProxy.__delattr__w s? q6S=%%d0 0,,T=A
-#00r rD N) r; r> r? r@ rd rH rB rC rC rD r r rA rA k s BI6
7
1r rA c Z \ rS rSrSrS rS r\" \\5 r\ " \
R 5 r Sr
g)
ValueProxyi~ )r r c $ U R S5 $ )Nr r r0 s r r ValueProxy.get r& r c ( U R SU45 $ r$ r r s r r ValueProxy.set s x00r rD N)r; r> r? r@ rd r r rv r rt types GenericAlias__class_getitem__rC rD r r rO rO ~ s. I'1 S# E#E$6$67r rO
BaseListProxy)__add__ __contains__ __delitem__ __getitem____len____mul__ __reversed____rmul__ __setitem__re countextendindexinsertr removereverser __imul__c D \ rS rSrS rS r\" \R 5 r Sr
g) ListProxyi c , U R SU45 U $ )Nrb r r s r __iadd__ListProxy.__iadd__ s E8, r c , U R SU45 U $ )Nrg r r s r rg ListProxy.__imul__ s eX. r rD N) r; r> r? r@ rk rg rt rT rU rV rC rD r r ri ri s $E$6$67r ri DictProxy)rY rZ r[ r r\ r` r{ rm r r r r popitem
setdefaultr r r Iteratorc 8 \ rS rSr\" \R 5 rSrg)ro i rD N) r; r> r? r@ rt rT rU rV rC rD r r ro ro s #E$6$67r
ArrayProxy)r\ r[ r` PoolProxy) apply apply_asyncr imapimap_unorderedr map map_asyncstarmap
starmap_asyncr\ AsyncResult)rw r{ r} rx ry c \ rS rSrS rS rSrg)ru i c U $ r rD r0 s r rR PoolProxy.__enter__ r r c $ U R 5 g r )r\ rU s r rY PoolProxy.__exit__ s r rD N)r; r> r? r@ rR rY rC rD r r ru ru s r c \ rS rSrSrSrg)r i a
Subclass of `BaseManager` which supports a number of shared object types.
The types registered are those intended for the synchronization
of threads, plus `dict`, `list` and `Namespace`.
The `multiprocessing.Manager()` function creates started instances of
this class.
rD N)r; r> r? r@ rA rC rD r r r r s r r Queue
JoinableQueuer r RLock SemaphoreBoundedSemaphore ConditionBarrierPoolr! r r )r rp )rp c H \ rS rSrSr/ 4S jrS rS rS rS r S r
S r S
r g ) _SharedMemoryTrackeri z+Manages one or more shared memory segments.c Xl X l g r shared_memory_context_name
segment_names)r, rg r s r r- _SharedMemoryTracker.__init__ s .2 +!. r c [ R " SU< S[ 5 35 U R R U5 g)z6Adds the supplied shared memory block name to tracker.zRegister segment in pid N)r r r r re r, segment_names r register_segment%_SharedMemoryTracker.register_segment s3 JJ*<*:(68*M N % %l 3r c [ R " SU< S[ 5 35 U R R U5 [
R " U5 nUR 5 UR 5 g)zvCalls unlink() on the shared memory block with the supplied name
and removes it from the list of blocks being tracked.zDestroy segment r N) r r r r re r SharedMemoryr unlink)r, r segments r destroy_segment$_SharedMemoryTracker.destroy_segment sX
JJ),)9&(L M % %l 3#00 >G MMO NN r c R U R SS H nU R U5 M g)z r? r@ rA r- r r r r r1 r6 rC rD r r r r s, 5/1 / 4
3
I "r r c Z \ rS rSr\R
/ SQ- rS rS rS rS r S r
S r S r g
) SharedMemoryServeri
)
track_segmentrelease_segment
list_segmentsc $ [ R " U /UQ70 UD6 U R n[ U[ 5 ( a [
R " U5 n[ SU S[ 5 35 U l [ R " S[ 5 35 g )Nshm_rk z"SharedMemoryServer started by pid ) rn r- r) rU r~ osfsdecoder r shared_memory_contextr r )r, rL kwargsr) s r r- SharedMemoryServer.__init__ sq OOD 24 26 2llG'5)) ++g.$tG9AfhZ%@A
& JJ;FH:F Gr c [ U R U S S5 ( a U R US' [ R " XU/UQ70 UD6$ )z|Create a new distributed-shared object (not backed by a shared
memory block) and return its id to be used in a Proxy Object.r _shared_memory_proxyr )r] r r rn rq )r, rJ r( rL r s r rq SharedMemoryServer.create sL t}}V,R02HII262L2L./==&B4B6B Br c ` U R R 5 [ R X5 $ )zACall unlink() on all tracked shared memory, terminate the Server.)r r rn rp r s r rp SharedMemoryServer.shutdown# s# & & - - /??4+ +r c : U R R U5 g)z?Adds the supplied shared memory block name to Server's tracker.N)r r r, rJ r s r r SharedMemoryServer.track_segment( s & & 7 7 Er c : U R R U5 g)z|Calls unlink() on the shared memory block with the supplied name
and removes it from the tracker instance inside the Server.N)r r r s r r "SharedMemoryServer.release_segment, s
& & 6 6| Dr c . U R R $ )zVReturns a list of names of shared memory blocks that the Server
is currently tracking.)r r r s r r SharedMemoryServer.list_segments1 s --;; ;r )r N)
r; r> r? r@ rn r r- rq rp r r r rC rD r r r r
s6 FG H C ,
F E
r? r@ rA r r= r- r r r r rC rD r r r r 7 s* %
O O A
r r r )X__all__r r r: r queuer rT r r r r r r
contextr r r
r r r r r HAS_SHMEMre ImportErrorr rr rY rc
view_typesr$ view_typerE r rP rI r rZ ri rl rn r r r XmlListener XmlClientr r r rx r r r rn r r r r r r r r- rA rO rW ri _BaseDictProxyre ro rt
BasePoolProxyru r r r r r r r r r r r! r r r r )rg s 0r r s] A
@ @ * I NN() 2 5;; -4M
N4MDd72t$&'4M
N
I
y/2
z MF M. &(b
I C) C AF*V F*Z
F ##Z%6%67 )):+?+?@t'& t't c w= w=z:* )+ , 8<7<:
E
E
F
+ /I /
+I
+] 6 4 4A9 A&1Y 1&8 8 o 0
8
8 { -
% !8 8 < *
k ,
! " $
+ Wekk * _ekk 2 Wiooz : VY^^] ; Wioo} = [)"5"5} E ')C)C"$ [)"5"5~ F Y 1 1< @ VTYY 2 VT9 - VT9 - WeZ 0 WeZ 0 [)^ < Z= N ]% 8
"" ""J*k >g
% I Os P P PP