python (3.11.7)
eC t g d Z ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl
m Z ddl m
Z
ddlmZmZmZ ddl mZ dd l mZ dd
l mZ dd l mZ dd l mZ d
Ze d n
# e$ r dZY nw xY wd Z ej ej e d dD Z d Z e D ]Z ej e e [ [ G d de Z di fdZ!d Z" G d de# Z$d Z%d Z& G d d e Z' G d d e Z(e
j) e
j* fe
j+ e
j, fd!Z- G d" d#e Z. G d$ d%e/ Z0 G d& d'e Z1d( Z2i fd)Z3 dcd*Z4 G d+ d,e Z5 G d- d.e Z6ddd/Z7 G d0 d1e1 Z8 G d2 d3e1 Z9 G d4 d5e9 Z: G d6 d7e1 Z; G d8 d9e1 Z< G d: d;e1 Z= G d< d=e1 Z> e3d>d? Z? G d@ dAe? Z@ e3dBdC ZAdDdEieA_B e3dFdG ZC e3dHdI ZDdJdJdJdEdEdKeD_B G dL dHeD ZE G dM dNe. ZFeF dOejG eF dPejG eF dQejH e; eF dRejI e9 eF dSejJ e9 eF dTejK e9 eF dUejL e9 eF dVejM e: eF dWejN e< eF dXejO eE eF dYePe@ eF dZeQeA eF d.e6e> eF d[e7eC eF d,e5e= eF dEe8d\ eF dJd] er+ G d^ d_ ZR G d` dae' ZS G db de. ZTdS dS )e) BaseManager SyncManager BaseProxyToken N)getpid)
format_exc )
connection) reductionget_spawning_popen ProcessError)pool)process)util) get_context)
shared_memoryTSharedMemoryManagerFc P t j | j | ffS N)arraytypecodetobytes)as L/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/multiprocessing/managers.py reduce_arrayr / s ;QYY[[1 11 c X g | ]'}t t i | (S )typegetattr.0names r
<listcomp>r$ 3 s3
N
N
NDd$72t$$&&''
N
N
Nr )itemskeysvaluesc 0 t t | ffS r )listobjs r rebuild_as_listr, 4 s $s)) r c , e Zd Z dZd Zd Zd Zd ZdS )r typeidaddressidc 2 |||c| _ | _ | _ d S r r. )selfr/ r0 r1 s r __init__zToken.__init__D s 06,dlDGGGr c * | j | j | j fS r r. r3 s r __getstate__zToken.__getstate__G s T\4733r c 0 |\ | _ | _ | _ d S r r. r3 states r __setstate__zToken.__setstate__J s /4,dlDGGGr c P | j j d| j d| j d| j dS )Nz(typeid=z
, address=z, id=)) __class____name__r/ r0 r1 r6 s r __repr__zToken.__repr__M s4 '''dlllDGGGM Mr N)r?
__module__ __qualname__ __slots__r4 r7 r; r@ r r r r r > sd ,IE E E4 4 45 5 5M M M M Mr r r c | ||||f | \ }}|dk r|S t || )N#RETURN)sendrecvconvert_to_error)cr1
methodnameargskwdskindresults r dispatchrO U sU FFB
D$ '(((6688LD& y
4
(
((r c 8 | dk r|S | dv rmt |t s1t d || t | | dk rt d|z S t | S t
d | S )N#ERROR)
#TRACEBACK#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strrS zUnserializable message: %s
z Unrecognized message type {!r})
isinstancestr TypeErrorformatr RemoteError
ValueError)rM rN s r rH rH _ s x
2 2 2&#&& 1@GGD$v,,0 01 1
1 $ $ $ = FGG G v&& &:AA$GGHHHr c e Zd Zd ZdS )rX c B dt | j d z dz S )NzM
---------------------------------------------------------------------------
r zK---------------------------------------------------------------------------)rU rK r6 s r __str__zRemoteError.__str__o s $s49Q<'8'886ABr N)r? rA rB r\ r r r rX rX n s( C C C C Cr rX c g }t | D ]6}t | | }t | r| | 7|S r )dirr callableappend)r+ tempr# funcs r all_methodsrc v sX DC sD!! D>> KK Kr c 6 d t | D S )Nc * g | ]}|d dk |S )r _r r! s r r$ z"public_methods.<locals>.<listcomp> s! @ @ @TaC D r )rc r* s r public_methodsrg s& A @[ - - @ @ @@r c e Zd Z g dZd Zd Zd Zd Zd Zd Z d Z
d Z d
Z e e e
d Z
d Zd
Zd Zd Zd Zd Zd Zd Zd ZdS )Server) shutdowncreateaccept_connection get_methods
debug_infonumber_of_objectsdummyincrefdecrefc t |t s0t d |t | || _ t
j | | _ t | \ }} ||d | _
| j
j | _ ddi| _ i | _
i | _ t j | _ d S )Nz&Authkey {0!r} is type {1!s}, not bytes )r0 backlog0Nr )rT bytesrV rW r registryr AuthenticationStringauthkeylistener_clientlistenerr0 id_to_objid_to_refcountid_to_local_proxy_obj threadingLockmutex)r3 ry r0 r{
serializerListenerClients r r4 zServer.__init__ s '5)) -8??T']], ,- -
- !
3G<< *:6& !"===
}, z* %'" ^%%
r c ` t j | _ | t j _ t j | j }d|_ | | j
s3| j d | j
3n# t t f$ r Y nw xY wt j t j k r@t# j d t j t _ t j t _ t j d d S # t j t j k r@t# j d t j t _ t j t _ t j d w xY w)N)targetTr zresetting stdout, stderrr )r Event
stop_eventr current_process_manager_serverThreadaccepterdaemonstartis_setwaitKeyboardInterrupt
SystemExitsysstdout
__stdout__r debug
__stderr__stderrexit)r3 r s r
serve_foreverzServer.serve_forever sU $/++48 !!1 't}===H "HO NN
/0022 ,O((+++ /0022 ,%z2
zS^++
5666 ^
^
HQKKKKK zS^++
5666 ^
^
HQKKKKs1 5D= )A B6 5D= 6C
D= C
D= =A0F-c | j }n# t $ r Y (w xY wt j | j |f }d|_ | c)NTr rK )r} acceptOSErrorr r handle_requestr r )r3 rI ts r r zServer.accepter st
M((**
(;1$GGGAAH
GGIII s
**c d } t j || j t j || j | }|\ }}}}t | | } ||g|R i |}d|f} n@# t $ r dt f} Y n$w xY w# t $ r dt f} Y nw xY w | | d S # t $ r}
| dt f n# t $ r Y nw xY wt j
d| t j
d| t j
d|
Y d }
~
d S d }
~
ww xY w)NrE rR zFailure to send message: %rz ... request was %r ... exception was %r) r
deliver_challenger{ answer_challengerG r Exceptionr rF r info) r3 rI requestignorefuncnamerK rL rb rN msges r _handle_requestzServer._handle_request s * (DL 9 9 9 '4< 8 8 8ffhhG+2 (FHdD4**D
* a/$///$// !&)
3
3
3#Z\\2
3 / / / .CCC / 2
FF3KKKKK 2 2 2
jll34444
I3S 9 9 9 I+W 5 5 5 I-q 1 1 1 1 1 1 1 1 1 2s[ A B $ A5 5BBB21B26C
E#C<;E<
D ED AEEc | | n# t $ r Y nw xY w| d S # | w xY wr )r r closer3 conns r r zServer.handle_request sh & & & & D
JJLLLLLDJJLLLLs ?
&? &? Ac D t j dt j j |j }|j }| j }| j s d x}} | }|\ }}} }
|| \ }} } n:# t $ r-}
| j | \ }} } n# t $ r |
w xY wY d }
~
nd }
~
ww xY w|| vr%t d|dt | d| t || } || i |
}| o| |d }|r7| ||| \ }}t# || j | }d||ff}n d|f}n# t& $ r}d|f}Y d }~nd }~ww xY wn# t $ rX |dt) f}nB | j | } || |||g| R i |
}d|f}n # t& $ r dt) f}Y nw xY wY nit, $ rB t j d t j j t/ j d
Y n t& $ r dt) f}Y nw xY w || n)# t& $ r |d t) f Y nw xY wn# t& $ r}t j d t j j t j d
| t j d| | t/ j d Y d }~nd }~ww xY w| j d S d S )Nz$starting server thread to service %rzmethod z of z object is not in exposed=#PROXYrE rQ rR z$got EOF -- exiting thread serving %rr rS z exception in thread serving %rz ... message was %rr r )r r r current_threadr# rG rF r~ r r KeyErrorr AttributeErrorr r getrk r r0 r r fallback_mappingEOFErrorr r r r )r3 r rG rF r~ rJ r+ r identrK rL exposed gettypeidkefunctionresr/ ridentrexposedtokenr r
fallback_funcrN s r serve_clientzServer.serve_client sI
9 +--2 4 4 4 yyN /((** D 5
3#''
S $&&07-z4!.7.>+C)) ! ! !! 6u = 0Wii# ! ! ! ! '0iiii! W,,(.#T#YYYY9
#3
33 /"(D1D11C ' J9==T+J+JF /+/;;tVS+I+I( %fdlF C C '(E): ; (# . ! ( ( (#Q-CCCCCC( "
;
;
; %' 6CC;(,(=j(I
!. $s" 59" " " =A" " )& 1$ ; ; ; +Z\\ :;
A$355:< < <
3
3
3#Z\\2
3
<DIIII < < <D+Z\\:;;;;;<
:!02279 9 9 /555 11555
} /((** D D D D D s E. 3 B ?E.
B7 B B2
B**B2-E. 2B77<E. 4E <AE.
E* E% E. %E**E. . H5 F-,H5-G
H5 G
H5AH5H54H5: I I0 #I,)I0 +I,,I0 0
L:A=K<<Lc |S r r r3 r r r+ s r fallback_getvaluezServer.fallback_getvalue? s
r c t | S r rU r s r fallback_strzServer.fallback_strB s
3xxr c t | S r )reprr s r
fallback_reprzServer.fallback_reprE s Cyyr )r\ r@ #GETVALUEc d S r r r3 rI s r rp z Server.dummyN s r c
| j 5 g }t | j }| |D ]W}|dk rO| d|d| j | dt
| j | d d d Xd | cd d d S # 1 swxY w Y d S )Nrv z z: refcount=z
r K
) r r) r r& sortr` rU r~ join)r3 rI rN r& r s r rn zServer.debug_infoQ s* Z % %F+002233D IIKKK
H
HC<<MMM#(55$*=e*D*D*D#&t~e'<Q'?#@#@"#E#E#G H H H 99V$$ % % % % % % % % % % % % % % % % % %s B+CCCc , t | j S r )lenr r s r ro zServer.number_of_objectsa s 4&'''r c
t j d | d n # dd l}| Y nxY w| j d S # | j w xY w)Nz!manager received shutdown messagerE Nr )r r rF traceback print_excr set)r3 rI r s r rj zServer.shutdownh s " J: ; ; ;
FF$ % % % % " ! ! ! ! ! O ! ! ! ! !DO ! ! ! !s )- A' A A' 'Bc | j 5 | j | \ }}}}|-|st | dk rt d |d } n ||i |} |t | }|dt |t s0t d |t | t | t | z }dt | z }
t j
d||
| t | |f| j |
< |
| j vr
d| j |
< d d d n # 1 swxY w Y | ||
|
t% | fS )Nr z4Without callable, must have one non-keyword argumentr z,Method_to_typeid {0!r}: type {1!s}, not dictz%xz&%r callable returned object with id %r)r ry r rY rg rT dictrV rW r r) r1 r r r r~ r rq tuple) r3 rI r/ rK rL r_ r method_to_typeid proxytyper+ r s r rk z
Server.createu s Z / /mF+
;Hg / PCIINN$NP P P1g h---(-- +!"2D99 G#FMM ,d3C.D.DF FG G G w--$/?*@*@@2c77NE J? O O O%(#g,,8H$IDN5 !D ///-.#E*7 / / / / / / / / / / / / / / /:
Au eGnn$$s DD++D/2D/c N t | j |j d S )Nr )r r~ r1 )r3 rI r s r rm zServer.get_methods s% T^EH-a0111r c |t j _ | d | | d S )Nr )r r r# rF r )r3 rI r# s r rl zServer.accept_connection sG +/ ""' !!! ! r c D | j 5 | j |xx dz
cc< nh# t $ r[}|| j v rFd| j |< | j | | j |< | j | \ }}}t j d| n|Y d }~nd }~ww xY wd d d d S # 1 swxY w Y d S )Nr z&Server re-enabled tracking & INCREF %r)r r r r r~ r r )r3 rI r r r+ r r s r rq z
Server.incref s(
Z
#E***a/****
D 66612D'. 259 N5).2nU.C+C)J GOOOO H POOOO
s7 B B
BAB ;B BBB Bc , || j vr || j v rt j d| d S | j 5 | j | dk r:t d || j | | j | | j |xx dz cc< | j | dk r| j |= d d d n # 1 swxY w Y || j vrId| j |< t j d| | j 5 | j |= d d d d S # 1 swxY w Y d S d S )NzServer DECREF skipping %rr z+Id {0!s} ({1!r}) has refcount {2:n}, not 1+r )Nr Nzdisposing of obj with id %r)r r r r r AssertionErrorrW r~ )r3 rI r s r rr z
Server.decref s + + + T/ / / J2E : : : F
Z / /"5)Q..$AHH t~e 4 +E24 45 5 5
& & &! + & & &"5)Q..'. / / / / / / / / / / / / / / / + + + %5DN5 ! J4e < < <
*
*N5)
*
*
*
*
*
*
*
*
*
*
*
*
*
*
*
*
*
* , +s$ A:B77B;>B;1 DD D N)r? rA rB publicr4 r r r r r r r r r rp rn ro rj rk rm rl rq rr r r r ri ri sX N N NF& & &$ , 2 2 2<
O O O b %
% % % ( ( ( " " ""% "% "%H2 2 2 $* * * * *r ri c e Zd ZdgZdZdZdZdS )Statevaluer r N)r? rA rB rC INITIALSTARTEDSHUTDOWNr r r r r s$ IGGHHHr r )pickle xmlrpclibc e Zd Z i ZeZ ddddZd Zd Zdd Z e
dd
Z d Z dd Z
d
Zd Zd Zd Zed Zed Ze
dd ZdS )r Nr g ?)shutdown_timeoutc F |t j j }|| _ t j | | _ t
| _ t j | j _ || _
t | \ | _ | _
|p
t | _ || _ d S r )r r r{ _addressrz _authkeyr _stater r _serializerr| _Listener_Clientr _ctx_shutdown_timeout)r3 r0 r{ r ctxr s r r4 zBaseManager.__init__ s ? -//7G
4W==
gg !M %'6z'B$ (;== !1 r c | j j t j k r~| j j t j k rt d | j j t j k rt d t d | j j t | j | j
| j | j S )NAlready started serverManager has shut downUnknown state {!r})
r r r r r r
r rW ri _registryr r r r6 s r
get_serverzBaseManager.get_server s ;
- -{ EM11"#;<<<"en44"#:;;;"(// 0ABBD D DdndmmT%57 7 7r c t | j \ }} || j | j }t |d d t
j | j _ d S )Nr{ rp ) r| r r r rO r r r r )r3 r r r s r connectzBaseManager.connect sW +4+;<&vdmT];;;tW%%% !M r r c
d | j j t j k r~| j j t j k rt d | j j t j k rt d t d | j j | t | st d t j d \ }}| j
t | j | j | j | j | j |||f | _ d d | j j D }t | j d
z |z | j _ | j | | | _ | t j | j _ t9 j | t | j | j | j | j | j | j | j fd | _! d S )
Nr r r z initializer must be a callableF)duplexr :c 3 4 K | ]}t | V d S r r )r" is r <genexpr>z$BaseManager.start.<locals>.<genexpr>1 s( AAAQAAAAAAr -r rK exitpriority)"r r r r r r
r rW r_ rV r
Piper Processr _run_serverr r r r _processr _identityr? r# r r rG r Finalize_finalize_managerr r rj )r3 initializerinitargsreaderwriterr s r r zBaseManager.start s ;
- -{ EM11"#;<<<"en44"#:;;;"(// 0ABBD D D "8K+@+@ " <== = $ 666 ))::).$- "FKC *
AA )@AAAAA !$ZZ 0C 7% ?
"M
$t**.-
t{, 68
r c P t j t j t j | || | |||| }| |j | t j d|j | d S )Nzmanager serving at %r)
signalSIGINTSIG_IGN_ServerrF r0 r r r r ) clsry r0 r{ r r r r servers r r zBaseManager._run_serverC s
fmV^444 " K " " XwDD FN###
)6>::: r c | | j | j } t |d d|f|z | \ }}| n# | w xY wt || j | |fS )Nr rk )r r r rO r r )r3 r/ rK rL r r1 r s r _createzBaseManager._createZ s ||DM4=|AA "4x&4 NNKB JJLLLLDJJLLLLVT]B//88s A A)c | j <| j | | j s d | _ d S d S d S r )r r is_aliver3 timeouts r r zBaseManager.joinf sZ = $ M w ' ' '=))++
% $
% $
%
%r c | | j | j } t |d d | S # | w xY w)Nr rn r r r rO r r s r _debug_infozBaseManager._debug_infoo sW ||DM4=|AA D$ 55 JJLLLLDJJLLLL A A c | | j | j } t |d d | S # | w xY w)Nr ro r) r s r _number_of_objectsz BaseManager._number_of_objectsy sX ||DM4=|AA D$(;<< JJLLLLDJJLLLLr+ c | j j t j k r| | j j t j k r~| j j t j k rt
d | j j t j k rt
d t
d | j j | S )NzUnable to start serverr r ) r r r r r r r
r rW r6 s r __enter__zBaseManager.__enter__ s ;
- - JJLLL ;
- -{ EM11"#;<<<"en44"#:;;;"(// 0ABBD D D r c . | d S r )rj r3 exc_typeexc_valexc_tbs r __exit__zBaseManager.__exit__ s
r c | j r,t j d ||| } t |d d | n# | w xY wn# t
$ r Y nw xY w | j | | j rt j d t | d rut j d | j | j | | j r2t j d | j | j t j |_ t j |= d S # t $ r Y d S w xY w) Nz#sending shutdown message to managerr rj )r' zmanager still alive terminatez'trying to `terminate()` manager processz#manager still alive after terminate)r% r r rO r r r hasattrr7 killr r r r _address_to_localr )r r0 r{ r: r r r s r r z BaseManager._finalize_manager s 7 ' I; < < <
ww888! T4444JJLLLLDJJLLLLL
GL!1 2 2 2 2 w !!
' /0007K00 'I GHHH%G%''' GL)9::::'w')) ' "GHHH$ $ n +G444 DD s:
A5 A A5 A11A5 5
BB
E
E-,E-c | j S r )r r6 s r r0 zBaseManager.address s
} r Tc j d| j vr | j | _ t |pt dd }|pt dd }|r't | D ]\ }}|||f| j < |r fd} | _ t | | d S d S )Nr _exposed__method_to_typeid_c t j d | j g|R i |\ }} || j | | j | }| |j | j }t |d d|j f |S )Nz)requesting creation of a shared %r objectmanagerr{ r r rr ) r r r# r r r r0 rO r1 ) r3 rK rL r expproxyr r r/ s r ra z"BaseManager.register.<locals>.temp s
FOOO )T\& @4 @ @ @4 @ @
s! 4+T M3 ||EM4=|IItX{;;; r ) __dict__r copy AutoProxyr r) r% r? setattr)
r r/ r_ r r r
create_methodkeyr ra s
` ` r registerzBaseManager.register s cl * * M . . 0 0CM !IBWY T B B+ J"9.BDII H "#3#9#9#;#; < <
H
H
UU
g /!
f '
#DM C & & & & & ' 'r )NNr Nrw r )NNNNT)r? rA rB r ri r r4 r r r classmethodr r# r r* r- r/ r5 staticmethodr propertyr0 rJ r r r r r s^ IG>F 2/2 2 2 2 2 2
7
7
7 * * *) ) ) )V /1 [ ,
9
9
9% % % % \ D X EI6:%' %' %' [%' %' %'r r c e Zd Zd Zd ZdS )ProcessLocalSetc 2 t j | d d S )Nc * | S r )clearr* s r <lambda>z*ProcessLocalSet.__init__.<locals>.<lambda> s 399;; r )r register_after_forkr6 s r r4 zProcessLocalSet.__init__ s '>'>?????r c $ t | dfS rw )r r6 s r
__reduce__zProcessLocalSet.__reduce__ s Dzz2~ r N)r? rA rB r4 rV r r r rO rO s5 @ @ @ r rO c e Zd Z i Z ej Z ddZd Zdi fdZ d Z
d Z e d
Z
d Zd Zd
Zd Zd ZdS )r NTFc t j 5 t j |j d }|5t j t f}|t j |j < d d d n # 1 swxY w Y |d | _ |d | _ || _
| j
j | _ || _
|| _ t | d | _ || _ |t% j | | _ n6| j
| j
j | _ n t% j j | _ |r| t j | t j d S )Nr r )r _mutexr: r r0 r ForkAwareLocalrO _tls_idset_tokenr1 _id_managerr r| r _owned_by_managerr rz r r r{ _increfrT _after_fork) r3 r r rA r{ r rq
manager_owned tls_idsets r r4 zBaseProxy.__init__ s
G G!377
tLLI / 1 1?3D3D D =F +EM: G G G G G G G G G G G G G G G aL
l ;>
%&z215 "/ # 8 A ADMM
]
& M 2DMM # 3 5 5 =DM LLNNN y'<=====s A A66A:=A:c \ t j d t j j }t j j dk r |dt j j z z
}| | j j | j
}t |d d|f || j _
d S )Nz making connection to manager
MainThread|r rl )r r r r r# r r r r] r0 r rO r[ r
)r3 r# r s r _connectzBaseProxy._connect s
1222&((- # % % *l : : C)24499 9D||DK / |GGt 04'::: # r r c | j j }n[# t $ rN t j dt j j | | j j }Y nw xY w| | j
|||f | \ }}|dk r|S |dk r|\ }}| j j
|j d } | j j |_ | || j | j | j | }
| |j | j }t) |d d|j f |
S t- || )Nz#thread %r does not own a connectionrE r r@ r rr )r[ r
r r r r r r# rh rF r^ rG r_ r r/ r] r0 r r r rO r1 rH ) r3 rJ rK rL r rM rN r r r rC s r _callmethodzBaseProxy._callmethod) s[ (9'DD ( ( ( J< /116
8
8
8 MMOOO9'DDD (
48Zt4555yy{{ f 9 M
X
#NGU
/ =bAI K /EM It'
w E <<
t}<EED T4EH; 7 7 7L tV,,,s AA('A(c . | d S )Nr rk r6 s r _getvaluezBaseProxy._getvalueG s ,,,r c
| j r!t j d| j j d S | | j j | j }t |d d| j f t j d| j j | j
| j | j o | j j
}t j | t j | j | j || j | j
| j fd | _ d S )Nz%owned_by_manager skipped INCREF of %rr rq z INCREF %r
r )r` r r r] r1 r r0 r rO r^ r\ addr_ r r r _decrefr[ _close)r3 r r: s r ra zBaseProxy._increfM s ! J> O O O F||DK / |GGtX{333
; /// !!!
6$-"6m )#+t}e)T[$,8 r c 8 | | j ||j t j k rr t j d| j || j | }t |d d| j f nF# t $ r }t j d| Y d }~n"d }~ww xY wt j d| j |sXt |d rJt j dt j j
|j |`d S d S d S )Nz DECREF %rr rr z... decref failed %sz%DECREF %r -- manager already shutdownr
z-thread %r has no more proxies so closing conn)discardr1 r r r r r r0 rO r r8 r r r# r
r )r r{ r: tlsidsetr r r s r rr zBaseProxy._decrefa s?
eh =EK5= 8 8
6
;111 wu}g>>>tX{;;;;
6
6
6
1155555555
6
J> I I I l33 JF /116
8
8
8 N " " " s AA8 8
B!B B!c d | _ | d S # t $ r"}t j d|z Y d }~d S d }~ww xY w)Nzincref failed: %s)r_ ra r r r )r3 r s r rb zBaseProxy._after_forkz sf
/ LLNNNNN / / / I)A- . . . . . . . . . /s
A AA c i }t
| j |d< t | dd r&| j |d< t t
| j | j |ffS t t | | j | j |ffS )Nr{ _isautoFr ) r r r r= RebuildProxyrF r] r r r3 rL s r rV zBaseProxy.__reduce__ s + "mDO 4E * * G "nDO T-=tDF
F !$ZZd.>EG
Gr c * | S r )rn )r3 memos r __deepcopy__zBaseProxy.__deepcopy__ s ~~ r c d dt | j | j j t | fz S )Nz <%s object, typeid %r at %#x>)r r? r] r/ r1 r6 s r r@ zBaseProxy.__repr__ s/ .T
#T[%7DBC Cr c | d S # t $ r t | d d dz cY S w xY w)Nr@ rj z; '__str__()' failed>)rk r r r6 s r r\ zBaseProxy.__str__ s[ =##J// / = = =::crc?%<< < < < =s $??NNNTF)r? rA rB r: r ForkAwareThreadLockrY r4 rh rk rn ra rL rr rb rV r r@ r\ r r r r r s
%T
%
'
'F26HM'> '> '> '>R$ $ $ ,.B - - - -<- - - ( \ 0/ / / G G G C C C= = = = =r r c t t j dd }|rW|j |j k rGt j d| d|d< |j |j vr |j |j |j |j < | dd o"t t j dd } | ||fd|i|S )Nr z*Rebuild a proxy owned by manager, token=%rTrc rq _inheritingF)
r r r r0 r r r1 r r~ pop)rb r r rL r! rq s r r{ r{ s W,..0A4
H
HF
+&.EM11
?GGG $_ 867 7 7 *
( 2
4 E G+--}e D DD 4z 9 9& 9D 9 99r c t | } || |f S # t $ r Y nw xY wi }|D ]}t d|d|d| t | t f| }||_ ||| |f< |S )Nzdef z:(self, /, *args, **kwds):
return self._callmethod(z
, args, kwds))r r execr r r= )r# r _cachedicmeth ProxyTypes r
MakeProxyTyper s GnnG
tWo&&
C H H 6:ddDDDBCF H H H H TI<--I!I 'FD'? s
))c t | d }|T || j | } t |d d| f }| n# | w xY w| ||j }|t j j }t d| j z | } | | ||||| }
d|
_
|
S )Nr r rm z
AutoProxy[%s])rA r{ rq rc T) r| r0 rO r r r r r{ r r/ rz ) r r rA r{ r rq rc r r r rC s r rF rF s j)!,Gwu}g666 tT=5(CCG JJLLLLDJJLLLL7.")++3 o <gFFI IeZ' #=
B
B
BEEM Ls A A(c e Zd Zd Zd ZdS ) Namespacec : | j | d S r )rD updater| s r r4 zNamespace.__init__ s
T"""""r c 2 t | j }g }|D ]4\ }}| d s| |d| 5| | j j dd | dS )Nrf =(, r= ) r) rD r%
startswithr` r r> r? r )r3 r% ra r# r s r r@ zNamespace.__repr__ s T]((**++ 5 5KD%??3''
5 tttUU 3444 >222DIIdOOOODDr N)r? rA rB r4 r@ r r r r r s7 # # #E E E E Er r c @ e Zd ZddZd Zd Zd Z eee ZdS )ValueTc " || _ || _ d S r ) _typecode_value)r3 r r locks r r4 zValue.__init__ s ! r c | j S r r r6 s r r z Value.get s
{r c || _ d S r r r3 r s r r z Value.set s
r c P t | j d| j d| j dS )Nr r r= )r r? r r r6 s r r@ zValue.__repr__ s* !$ZZ 0 0 0$...$+++NNr NT) r? rA rB r4 r r r@ rM r r r r r r sc O O O HS# EEEr r c , t j | | S r )r )r sequencer s r Arrayr s ;x * **r c 0 e Zd ZdZd Zd Zd Zd Zd ZdS )
IteratorProxy)__next__rF throwr c | S r r r6 s r __iter__zIteratorProxy.__iter__ r c . | d| S )Nr rm r3 rK s r r zIteratorProxy.__next__ s
D111r c . | d| S )NrF rm r s r rF zIteratorProxy.send s ---r c . | d| S )Nr rm r s r r zIteratorProxy.throw ...r c . | d| S )Nr rm r s r r zIteratorProxy.close r r N) r? rA rB r= r r rF r r r r r r r
sd 6I 2 2 2. . ./ / // / / / /r r c , e Zd ZdZddZd Zd Zd ZdS )
AcquirerProxy)acquirereleaseTNc @ ||fn||f}| d| S Nr rm )r3 blockingr' rK s r r zAcquirerProxy.acquire s, %o{{Hg3F 4000r c , | d S Nr rm r6 s r r zAcquirerProxy.release ***r c , | d S r rm r6 s r r/ zAcquirerProxy.__enter__ r r c , | d S r rm r1 s r r5 zAcquirerProxy.__exit__! r r )TN)r? rA rB r= r r r/ r5 r r r r r sZ &I1 1 1 1+ + ++ + ++ + + + +r r c 0 e Zd ZdZddZd dZd ZddZdS )
ConditionProxy)r r r notify
notify_allNc 0 | d|f S Nr rm r& s r r zConditionProxy.wait'
333r r c 0 | d|f S )Nr rm )r3 ns r r zConditionProxy.notify) s 1$///r c , | d S )Nr rm r6 s r r zConditionProxy.notify_all+ s ---r c | }|r|S |t j |z }nd }d }|s@| |t j z
}|dk rn!| | | }|@|S )Nr )time monotonicr )r3 predicater' rN endtimewaittimes r wait_forzConditionProxy.wait_for- s M n&&0GGGH !""T^%5%55q== IIh Y[[F
!
r r )r )r? rA rB r= r r r r r r r r r % sd FI4 4 4 40 0 0 0. . . r r c , e Zd ZdZd Zd Zd ZddZdS )
EventProxy)r r rR r c , | d S )Nr rm r6 s r r zEventProxy.is_setB s )))r c , | d S Nr rm r6 s r r zEventProxy.setD &&&r c , | d S )NrR rm r6 s r rR zEventProxy.clearF (((r Nc 0 | d|f S r rm r& s r r zEventProxy.waitH r r r )r? rA rB r= r r rR r r r r r r @ sZ 2I* * *' ' ') ) )4 4 4 4 4 4r r c h e Zd ZdZd dZd Zd Zed Zed Z ed Z
dS )
BarrierProxy)__getattribute__r abortresetNc 0 | d|f S r rm r& s r r zBarrierProxy.waitN r r c , | d S )Nr rm r6 s r r zBarrierProxy.abortP r r c , | d S )Nr rm r6 s r r zBarrierProxy.resetR r r c . | dd S )Nr )partiesrm r6 s r r zBarrierProxy.partiesT s 2LAAAr c . | dd S )Nr ) n_waitingrm r6 s r r zBarrierProxy.n_waitingW s 2NCCCr c . | dd S )Nr )brokenrm r6 s r r zBarrierProxy.brokenZ s 2K@@@r r ) r? rA rB r= r r r rM r r r r r r r r L s >I4 4 4 4) ) )) ) )
B B XB
D D XD
A A XA A Ar r c $ e Zd ZdZd Zd Zd ZdS )NamespaceProxy)r __setattr__ __delattr__c |d dk rt | | S t | d } |d|f S )Nr rf rk r )objectr r3 rI
callmethods r __getattr__zNamespaceProxy.__getattr__a sO q6S==**455 5,,T=AA
z,sf555r c |d dk r t | || S t | d } |d||f S )Nr rf rk r )r r r )r3 rI r r s r r zNamespaceProxy.__setattr__f sR q6S==%%dC77 7,,T=AA
z-#u 666r c |d dk rt | | S t | d } |d|f S )Nr rf rk r )r r r r s r r zNamespaceProxy.__delattr__k sN q6S==%%dC00 0,,T=AA
z-#000r N)r? rA rB r= r r r r r r r r _ sF BI6 6 6
7 7 7
1 1 1 1 1r r c V e Zd ZdZd Zd Z eee Z ee j
Z dS )
ValueProxy)r r c , | d S )Nr rm r6 s r r zValueProxy.gett r r c 0 | d|f S r rm r s r r zValueProxy.setv s x000r N) r? rA rB r= r r rM r rK types GenericAlias__class_getitem__r r r r r r sW I' ' '1 1 1 HS# E# E$677r r
BaseListProxy)__add__ __contains__ __delitem__ __getitem____len____mul__ __reversed____rmul__ __setitem__r` countextendindexinsertr removereverser __imul__c e Zd Zd Zd ZdS ) ListProxyc 4 | d|f | S )Nr rm r s r __iadd__zListProxy.__iadd__ s E8,,, r c 4 | d|f | S )Nr
rm r s r r
zListProxy.__imul__ s eX... r N)r? rA rB r r
r r r r r s2 r r DictProxy)r r r r r r rR rE r r% r& r popitem
setdefaultr r' r Iterator
ArrayProxy)r r r PoolProxy) apply apply_asyncr imapimap_unorderedr map map_asyncstarmap
starmap_asyncr7 AsyncResult)r r r r r c e Zd Zd Zd ZdS )r c | S r r r6 s r r/ zPoolProxy.__enter__ r r c . | d S r )r7 r1 s r r5 zPoolProxy.__exit__ s r N)r? rA rB r/ r5 r r r r r s2 r c e Zd ZdS )r N)r? rA rB r r r r r s r r Queue
JoinableQueuer r RLock SemaphoreBoundedSemaphore ConditionBarrierPoolr) r r )r rH )rH c > e Zd Z g fdZd Zd Zd Zd Zd Zd Z dS ) _SharedMemoryTrackerc " || _ || _ d S r shared_memory_context_name
segment_names)r3 r# r0 s r r4 z _SharedMemoryTracker.__init__ s .2D +!.D r c t j d|dt | j | d S )NzRegister segment in pid )r r r r0 r` r3 segment_names r register_segmentz%_SharedMemoryTracker.register_segment sG D JM<MM688MM N N N % %l 3 3 3 3 3r c t j d|dt | j | t j | }| | d S )NzDestroy segment r2 ) r r r r0 r r SharedMemoryr unlink)r3 r4 segments r destroy_segmentz$_SharedMemoryTracker.destroy_segment sw
E JL,LL&((LL M M M % %l 3 3 3#0 >>G MMOOO NN r c V | j d d D ]}| | d S r )r0 r: r3 s r r8 z_SharedMemoryTracker.unlink sA J $ 2111 5
3
3 $$\2222
3
3r c t j d| j j dt | d S )NzCall z .__del__ in )r r r> r? r r8 r6 s r __del__z _SharedMemoryTracker.__del__ s= JNt~ 6NNFHHNN O O O KKMMMMMr c | j | j fS r r. r6 s r r7 z!_SharedMemoryTracker.__getstate__ s 3T5GH Hr c | j | d S r )r4 r9 s r r; z!_SharedMemoryTracker.__setstate__ s DM5 ! ! ! !r N)
r? rA rB r4 r5 r: r8 r= r7 r; r r r r, r, s 5/1 / / / / 4 4 4
3 3 3
I I I " " " " "r r, c J e Zd Zej g dz Zd Zd Zd Zd Zd Z d Z
dS ) SharedMemoryServer)
track_segmentrelease_segment
list_segmentsc " t j | g|R i | | j }t |t rt j | }t d| dt | _ t j dt d S )Nshm_rf z"SharedMemoryServer started by pid ) ri r4 r0 rT rx osfsdecoder, r shared_memory_contextr r )r3 rK kwargsr0 s r r4 zSharedMemoryServer.__init__ s OD 24 2 2 26 2 2 2lG'5))
/ +g..$%@G%@%@fhh%@%@AA
& JFFHHFF G G G G Gr c t | j | d d r
| j |d< t j | ||g|R i |S )Nrj _shared_memory_proxyrI )r8 ry rI ri rk )r3 rI r/ rK rJ s r rk zSharedMemoryServer.create s\
M
t}V,R02HII
M262L./=q&B4BBB6BB Br c l | j t | | S r )rI r8 ri rj r s r rj zSharedMemoryServer.shutdown s. O & - - / / /??4++ +r c < | j | d S r )rI r5 r3 rI r4 s r rB z SharedMemoryServer.track_segment s" M & 7 7 E E E E Er c < | j | d S r )rI r: rO s r rC z"SharedMemoryServer.release_segment s%
K & 6 6| D D D D Dr c | j j S r )rI r0 r s r rD z SharedMemoryServer.list_segments! s
&-; ;r N) r? rA rB ri r r4 rk rj rB rC rD r r r rA rA s FFFG H H H C C C , , ,
F F F E E E
< < < < <r rA c 2 e Zd Z eZd Zd Zd Zd Zd Z dS )r c t j dk rddlm} | t j | g|R i | t j | j j
dt d S )Nposixr )resource_trackerz created by pid ) rG r# rU ensure_runningr r4 r r r> r? r )r3 rK rJ rU s r r4 z SharedMemoryManager.__init__3 s w'!! /..... //111 7 7 7 7 7 7 7 J$.1MM688MM N N N N Nr c d t j | j j dt d S )Nz.__del__ by pid )r r r> r? r r6 s r r= zSharedMemoryManager.__del__? s/ J$.1MM688MM N N N N Nr c | j j t j k r~| j j t j k rt d | j j t j k rt d t d | j j | | j | j
| j | j S )Nz"Already started SharedMemoryServerz!SharedMemoryManager has shut downr )
r r r r r r
r rW r r r r r r6 s r r z SharedMemoryManager.get_serverB s N{ EM11;$
55&'KLLL[&%.88&'JKKK&,33DK4EFFH H H<<
$
t/?A A
Ar c . | | j | j 5 }t j d d| } t |d d|j f n(# t $ r}| |d }~ww xY w d d d n # 1 swxY w Y |S )Nr T)rk sizerB ) r r r r r7 rO r#
BaseExceptionr8 )r3 r[ r smsr s r r7 z SharedMemoryManager.SharedMemoryO s
4 dmT] CC
t#0dNNN T4 38+FFFF$ JJLLLG G
Js4 B
AB
A: A55A::B
BBc < | | j | j 5 }t j | } t |d d|j j f n-# t $ r }|j |d }~ww xY w d d d n # 1 swxY w Y |S )Nr rB )
r r r r
ShareableListrO shmr# r\ r8 )r3 r r slr s r r_ z!SharedMemoryManager.ShareableList[ s
F dmT] CC
t"0:: T4 26;.IIII$ FMMOOOG J
Is4 B AB
B!A<<BBBBN)
r? rA rB rA r r4 r= r r7 r_ r r r r r ' st %
O
O
O O O O A A A
r r r )U__all__r r r r queuer r rG r r r rV r
contextr r r
r r r r r HAS_SHMEMr` ImportErrorr rJ
view_typesr, view_typer r rO rH r rX rc rg ri r r r XmlListener XmlClientr| r r rO r r{ r rF r r r r r r r r r r r r r r> r
BasePoolProxyr r r# r r r% r& r' r( r) r* r) r r, rA r r r r <module>rl s A
@
@
@ @ @ @ @ @ @ @ @ @ * I NN()))) III2 2 2 5; - - -
N
N4M
N
N
N
3 3IIy/2222
z M M M M MF M M M. &(b ) ) ) )
I
I
I C C C C C) C C C A A AG* G* G* G* G*V G* G* G*\
F #Z%67 ):+?@ t' t' t' t' t'& t' t' t't c m= m= m= m= m= m= m= m=f: : :* )+ , 8<7< :
E
E
E
E
E
E
E
E
F
+ + + + / / / / /I / / /
+
+
+
+
+I
+
+
+ ] 6 4 4 4 4 4 4 4 4A A A A A9 A A A&1 1 1 1 1Y 1 1 1&8 8 8 8 8 8 8 8
o 0
M+ (
]< *
k ,
! " $ $
+ Wek * * * _ek 2 2 2 Wioz : : : VY^] ; ; ; Wio} = = = [)"5} E E E ')C"$ $ $ [)"5~ F F F Y 1< @ @ @ VTY 2 2 2 VT9 - - - VT9 - - - WeZ 0 0 0 WeZ 0 0 0 [)^ < < < Z= N N N ]% 8 8 8
Q"" "" "" "" "" "" "" ""J*< *< *< *< *<V *< *< *<Z> > > > >k > > > > >gQ Qs A8 8BB
Browse
Usage
Versions