python (3.12.0)
̑e
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 j1 d d Z ej6 ej e dD cg c] } e e i | c} Z d Z e D ] Z ej6 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
jV e
jX fe
jZ e
j\ fd Z/ G d! d"e! Z0 G d# d$e1 Z2 G d% d&e! Z3d' Z4i fd(Z5 dbd)Z6 G d* d+e! Z7 G d, d-e! Z8dcd.Z9 G d/ d0e3 Z: G d1 d2e3 Z; G d3 d4e; Z< G d5 d6e3 Z= G d7 d8e3 Z> G d9 d:e3 Z? G d; d<e3 Z@ e5d=d> ZA G d? d@eA ZB e5dAdB ZCdCdDieC_D e5dEdF ZE e5dGdH ZFdIdIdIdDdDdJeF_D G dK dGeF ZG G dL dMe0 ZHeHj7 dNej eHj7 dOej eHj7 dPej e= eHj7 dQej e; eHj7 dRej e; eHj7 dSej e; eHj7 dTej e; eHj7 dUej e< eHj7 dVej e> eHj7 dWej eG eHj7 dXeReB eHj7 dYeSeC eHj7 d-e8e@ eHj7 dZe9eE eHj7 d+e7e? eHj7 dDe:d[ eHj7 dId\ er! G d] d^ ZT G d_ d`e) ZU G da de0 ZVyy# e$ r dZY w xY wc c} w )d) BaseManager SyncManager BaseProxyToken N)getpid)
format_exc )
connection) reductionget_spawning_popen ProcessError)pool)process)util) get_context)
shared_memoryTSharedMemoryManagerFc Z t j | j | j ffS N)arraytypecodetobytes)as L/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/multiprocessing/managers.py reduce_arrayr / s ;;QYY[1 11 )itemskeysvaluesc & t t | ffS r )listobjs r rebuild_as_listr$ 4 s $s) r c * e Zd Z dZd Zd Zd Zd Zy)r typeidaddressidc 0 |||c| _ | _ | _ y r r& )selfr' r( r) s r __init__zToken.__init__D s 06,dlDGr c H | j | j | j fS r r& r+ s r __getstate__zToken.__getstate__G s T\\47733r c . |\ | _ | _ | _ y r r& r+ states r __setstate__zToken.__setstate__J s /4,dlDGr c | j j d| j d| j d| j dS )Nz(typeid=z
, address=z, id=)) __class____name__r' r( r) r. s r __repr__zToken.__repr__M s- ''dllDGGM Mr N)r7
__module__ __qualname__ __slots__r, r/ r3 r8 r r r r > s$ ,IE45Mr r r< c z | j ||||f | j \ }}|dk( r|S t || )N#RETURN)sendrecvconvert_to_error)cr)
methodnameargskwdskindresults r dispatchrH U sG FFB
D$ '(668LD& y
4
((r c | dk( r|S | dv rSt |t s%t dj || t | | dk( rt d|z S t | S t
dj | S )N#ERROR)
#TRACEBACK#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strrL zUnserializable message: %s
z Unrecognized message type {!r})
isinstancestr TypeErrorformattype RemoteError
ValueError)rF rG s r rA rA _ s x
2 2&#&@GGD$v,01
1 $ $ = FG G v& &:AA$GHHr c e Zd Zd Zy)rR c > dt | j d z dz S )NzM
---------------------------------------------------------------------------
r zK---------------------------------------------------------------------------)rN rD r. s r __str__zRemoteError.__str__o s $s499Q<'886ABr N)r7 r9 r: rV r< r r rR rR n s Cr rR c ~ g }t | D ]+ }t | | }t | s|j | - |S r )dirgetattrcallableappend)r# tempnamefuncs r all_methodsr_ v sG DC sD! D> KK Kr c R t | D cg c]
}|d dk7 s | c}S c c}w )Nr _)r_ )r# r] s r public_methodsrb s, ) - @TaC D @@ @s
$$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 Zy)Server) shutdowncreateaccept_connection get_methods
debug_infonumber_of_objectsdummyincrefdecrefc z t |t s$t dj |t | || _ t
j | | _ t | \ }} ||d | _
| j j | _ ddi| _ i | _
i | _ t j | _ y )Nz&Authkey {0!r} is type {1!s}, not bytes )r( backlog0Nr< )rM bytesrO rP rQ registryr AuthenticationStringauthkeylistener_clientlistenerr( id_to_objid_to_refcountid_to_local_proxy_obj threadingLockmutex)r+ rt r( rv
serializerListenerClients r r, zServer.__init__ s '5)8??T'],-
- !
33G< *:6& !"=
}},, z* %'" ^^%
r c t j | _ | t j _ t j | j }d|_ |j | j j s6| j j d | j j s6t j t j k7 rGt# j$ d t j t _ t j& t _ t j* d y # t t f$ r Y w xY w# t j t j k7 rGt# 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)r+ r s r
serve_foreverzServer.serve_forever s% $//+48 !1 ''t}}=H "HO NN
//002OO((+ //002
zzS^^+
56 ^^
^^
HHQK &z2
zzS^^+
56 ^^
^^
HHQKs+ 7E -AD; ;E
E E
E A?Gc | j j }t j | j
|f }d|_ |j U# t $ r Y aw xY w)NTr rD )rx acceptOSErrorr| r handle_requestr r )r+ rB ts r r zServer.accepter sa
MM((* (;(;1$GAAH
GGI
s A A#"A#c d } t j || j t j || j |j }|\ }}}}t | | } ||g|i |}d|f} |j | y # t $ r dt f} Y *w xY w# t $ r dt f} Y Ew xY w# t $ rx}
|j dt f n# t $ r Y nw xY wt j d| t j d| t j d|
Y d }
~
y d }
~
ww xY w)Nr> rK zFailure to send message: %rz ... request was %r ... exception was %r) r
deliver_challengerv answer_challenger@ rY Exceptionr r? r info) r+ rB requestignorefuncnamerD rE r^ rG msges r _handle_requestzServer._handle_request s2 * ( (DLL 9 ' '4<< 8ffhG+2 (FHdD4*D
* a/$/$/ !&) 2
FF3K
3#Z\2
3 / .C / 2
jl34
II3S 9 II+W 5 II-q 1 1 2s[ A#B& ( B 9C B#"B#&B>=B> E C'&D=' C30D=2C33AD==Ec | j | |j y # t $ r Y w xY w# |j w xY wr )r r closer+ conns r r zServer.handle_request sE &
JJL
JJLs % 14 14 Ac & t j dt j j |j
}|j }| j }| j j s d x}} | }|\ }}} }
|| \ }} } || vr t d|dt | d| t || } || i |
}| xr | j |d }|r4| j! ||| \ }}t# || j$ | }d||ff}nd|f} | | j j sy y # t $ r.}
| j | \ }} } n# t $ r |
w xY wY d }
~
d }
~
ww xY w# t& $ r}d|f}Y d }~sd }~ww xY w# t $ rQ
dt) f}n? | j* | } || |g i
}d|f}n# t& $ r dt) f}Y nw xY wY t, $ rK t j d t j j t/ j0 d
Y &t& $ r dt) f}Y =w xY w# t& $ r |d t) f Y Uw xY w# t& $ r}t j2 d t j j t j2 d
t j2 d| |j5 t/ j0 d Y d }~d }~ww xY w)Nz$starting server thread to service %rzmethod z of z object is not in exposed=#PROXYr> rJ rK z$got EOF -- exiting thread serving %rr rL z exception in thread serving %rz ... message was %rr r )r r r| current_threadr] r@ r? ry r r KeyErrorr{ AttributeErrorrQ rY getrf r r( r r fallback_mappingEOFErrorr r r r )r+ r r@ r? ry rC r# r identrD rE exposed gettypeidkefunctionresr' ridentrexposedtokenr r
fallback_funcrG s r serve_clientzServer.serve_client s
9 ++-22 4 yyyyNN //((*5
3#''
S &07-z4!.7.>+C) W,(#T#Y9
#3
3 /"D1D1C ' J9==T+JF +/;;tVS+I( %fdllF C '(E): ; (# ..
<Iw //((* !! 6 6u = 0Wi# ! ! '0!" ! (#Q-C( "
; %' 6C;(,(=(=j(I
!. $s" 59" =A" )& 1$ ; +Z\ :;
A$335::<
3#Z\2
3 ! <+Z\:;<
:!002779 /5 115
s 3F D= -F =E7 AF I = E4EE/ E''E/*F /E44F 7 F F F FF I*"G
I
G%"I$G%%I*AI<III62I9 5I66I9 9 LBL Lc |S r r< r+ r r r# s r fallback_getvaluezServer.fallback_getvalue? s
r c t | S r rN r s r fallback_strzServer.fallback_strB s 3xr c t | S r )reprr s r
fallback_reprzServer.fallback_reprE s Cyr )rV r8 #GETVALUEc y r r< r+ rB s r rk z Server.dummyN s r c
t | j 5 g }t | j j }|j |D ]K }|dk7 s |j d|d| j | dt
| j | d d d M dj | cd d d S # 1 sw Y y xY w)Nrq z z: refcount=z
r K
) r~ r! rz r sortr[ rN ry join)r+ rB rG r r s r ri zServer.debug_infoQ s ZZ %F++0023D IIK
HC<MM#($*=*=e*D#&t~~e'<Q'?#@"#E#G H
H
99V$ % % %s A B.AB..B7c . t | j S r )lenrz r s r rj zServer.number_of_objectsa s 4&&''r c t j d |j d | j
j
y # dd l}|j Y 3xY w# | j
j
w xY w)Nz!manager received shutdown messager> Nr )r r r? traceback print_excr set)r+ rB r s r re zServer.shutdownh s_ " JJ: ;
FF$ %
OO ! " ! OO !s &A A A A;c p | j 5 | j | \ }}}}|!|st | dk7 r t d |d } n ||i |} | t | }|Kt |t s$t dj |t | t | t | z }dt | z }
t j d||
| t | |f| j |
< |
| j vrd| j |
< d d d | j# |
|
t% fS # 1 sw Y (xY w)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~ rt r rS rb rM dictrO rP rQ r! r) r r r ry rz rl tuple) r+ rB r' rD rE rZ r method_to_typeid proxytyper# r s r rf z
Server.createu sR ZZ /mmF+
;Hg / CIN$NP P1g --(- +!"2D9#FMM ,d3C.DFG G w-$/?*@@2c7NE JJ? O%(#g,8H$IDNN5 !D / //-.##E*7 /:
Au eGn$$= / /s C7D,,D5c N t | j |j d S )Nr )r ry r) )r+ rB r s r rh zServer.get_methods s& T^^EHH-a011r c | |t j _ |j d | j | y )Nr )r| r r] r? r )r+ rB r] s r rg zServer.accept_connection s5 +/ "' ! ! r c F | j 5 | j |xx dz
cc< d d d y # t $ r\}|| j v rBd| j |< | j | | j |< t j d| n|Y d }~id }~ww xY w# 1 sw Y y xY w)Nr z&Server re-enabled tracking & INCREF %r)r~ rz r r{ ry r r )r+ rB r r s r rl z
Server.incref s
ZZ
##E*a/*
D 6 6612D''. 2259 NN5)JJ GO H P
s, B/ BAB
BBBB c l || j vr%|| j v rt j d| y | j 5 | j | dk r6t dj
|| j | | j | | j |xx dz cc< | j | dk( r
| j |= d d d || j vrHd| j |< t j d| | j 5 | j |= d d d y y # 1 sw Y `xY w# 1 sw Y y xY w)NzServer DECREF skipping %rr z+Id {0!s} ({1!r}) has refcount {2:n}, not 1+r )Nr< Nzdisposing of obj with id %r)rz r{ r r r~ AssertionErrorrP ry )r+ rB r s r rm z
Server.decref s0 ++ + T// / JJ2E :
ZZ /""5)Q.$AHH t~~e 4 ++E245 5
&! + &""5)Q.''. / ++ + %5DNN5 ! JJ4e <
*NN5)
*
* , / /$
*
*s A?D D* D'*D3N)r7 r9 r: publicr, r r r r r r r r r rk ri rj re rf rh rg rl rm r< r r rd rd s NF&$, 2<
O b %
% ( ""%H2 "*r rd c e Zd ZdgZdZdZdZy)Statevaluer r N)r7 r9 r: r; INITIALSTARTEDSHUTDOWNr< r r r r s IGGHr r )pickle xmlrpclibc e Zd Z i ZeZ ddddZd Zd ZddZ e
dd Z d Z dd
Z
d Zd Zd
Zd Zed Zed Ze
dd Zy)r Ng ?)shutdown_timeoutc P | t j j }|| _ t j | | _ t
| _ t j | j _ || _
t | \ | _ | _
|xs
t | _ || _ y r )r r rv _addressru _authkeyr _stater r _serializerrw _Listener_Clientr _ctx_shutdown_timeout)r+ r( rv r ctxr s r r, zBaseManager.__init__ s~ ? --/77G
44W=
g !MM %'6z'B$ (;= !1 r c | j j t j k7 r| j j t j k( r t d | j j t j k( r t d t dj | j j t | j | j | j | j S )NAlready started serverManager has shut downUnknown state {!r})
r r r r r r
r rP rd _registryr r r r. s r
get_serverzBaseManager.get_server s ;;
-{{ EMM1"#;<<""enn4"#:;;"(// 0A0ABD DdnndmmmmT%5%57 7r c t | j \ }} || j | j }t |d d t
j | j _ y )Nrv rk ) rw r r r rH r r r r )r+ r r r s r connectzBaseManager.connect sN +4+;+;<&dmmT]];tW% !MM r c
| j j t j k7 r| j j t j k( r t d | j j t j k( r t d t dj | j j |t | s t d t j d \ }}| j j t | j | j | j" | j$ | j& |||f | _ dj+ d | j( j, D }t | j. d
z |z | j( _ | j( j3 |j5 |j7 | _ |j5 t j | j _ t9 j: | t | j< | j( | j" | j$ | j | j> | j@ fd | _! y )
Nr r r z initializer must be a callableF)duplexr :c 3 2 K | ] }t | y wr r ).0is r <genexpr>z$BaseManager.start.<locals>.<genexpr>0 s AAQAs -r rD exitpriority)"r r r r r r
r rP rZ rO r
Piper ProcessrQ _run_serverr r r r _processr _identityr7 r] r r r@ r Finalize_finalize_managerr r re )r+ initializerinitargsreaderwriterr s r r zBaseManager.start s ;;
-{{ EMM1"#;<<""enn4"#:;;"(// 0A0ABD D "8K+@ <= = $ 6 )):))..$-- ""FKC *
A )@)@AA !$Z 0 0C 7% ?
"MM
$t*..--
t{{,, 6 68
r c V t j t j t j | || | j |||| }|j |j
|j
t j d|j
|j y )Nzmanager serving at %r)
signalSIGINTSIG_IGN_Serverr? r( r r r r ) clsrt r( rv r r r r servers r r zBaseManager._run_serverB s
fmmV^^4 " " XwD FNN#
)6>>: r c | j | j | j } t |d d|f|z | \ }}|j t || j | |fS # |j w xY w)Nr rf )r r r rH r r )r+ r' rD rE r r) r s r _createzBaseManager._createY sr ||DMM4==|A "4x&4 NKB JJLVT]]B/88
JJLs A) )A;c | j >| j j | | j j sd | _ y y y r )r r is_aliver+ timeouts r r zBaseManager.joine sF == $ MM w '==))+ $
, %r c | j | j | j } t |d d |j S # |j w xY w)Nr ri r r r rH r r s r _debug_infozBaseManager._debug_infon sG ||DMM4==|A D$ 5 JJLDJJL A Ac | j | j | j } t |d d |j S # |j w xY w)Nr rj r% r s r _number_of_objectsz BaseManager._number_of_objectsx sH ||DMM4==|A D$(;< JJLDJJLr' c | j j t j k( r| j | j j t j
k7 r| j j t j k( r t
d | j j t j k( r t
d t
dj | j j | S )NzUnable to start serverr r ) r r r r r r r
r rP r. s r __enter__zBaseManager.__enter__ s ;;
- JJL ;;
-{{ EMM1"#;<<""enn4"#:;;"(// 0A0ABD D r c $ | j y r )re r+ exc_typeexc_valexc_tbs r __exit__zBaseManager.__exit__ s
r c | j rt j d ||| } t |d d |j | j | | j rt j d t | d rt j d | j | j | | j r7t j d | j | j t j |_ t j |= y # |j w xY w# t
$ r Y w xY w# t $ r Y y w xY w) Nz#sending shutdown message to managerr re )r# zmanager still alive terminatez'trying to `terminate()` manager processz#manager still alive after terminate)r! r r rH r r r hasattrr3 killr r r r _address_to_localr )r r( rv r2 r r r s r r z BaseManager._finalize_manager s/ 7 II; <
w8! T44JJL
GLL!1 2 w ! /07K0II GH%G%%' GLL)9:'w'') "GH$ $ nn ++G4% JJL
$ s:
E
E E /E& EE E#"E#& E21E2c | j S r )r r. s r r( zBaseManager.address s }} r c ^ d| j vr | j j | _ t |xs
t dd }|xs
t dd }|r!t |j
D ] \ }} |||f| j < |rfd} | _ t | | y y )Nr _exposed__method_to_typeid_c ( t j d | j g|i |\ }} || j | | j | }| j |j | j }t |d d|j f |S )Nz)requesting creation of a shared %r objectmanagerrv r r rm ) r r r r r r r( rH r) ) r+ rD rE r expproxyr r r' s r r\ z"BaseManager.register.<locals>.temp s
FO )T\\& @4 @4 @
s!4++T MM3 ||EMM4==|ItX{; r ) __dict__r copy AutoProxyrY r! r r7 setattr)
r r' rZ r r r
create_methodkeyr r\ s
` ` r registerzBaseManager.register s cll * MM . . 0CM !IBWY T B+ J"9.BDI "#3#9#9#; <
H
U
H
g /!
f
#DM C & r )NNr Nrr r )NNNNT)r7 r9 r: r rd r r, r r r classmethodr r r r& r) r+ r1 staticmethodr propertyr( rF r< r r r r s IG>F 2/2 2
7 *)V /1 ,
9% D EI6:%' %'r r c e Zd Zd Zd Zy)ProcessLocalSetc 2 t j | d y )Nc " | j S r )clearr" s r <lambda>z*ProcessLocalSet.__init__.<locals>.<lambda> s 399; r )r register_after_forkr. s r r, zProcessLocalSet.__init__ s '>?r c t | dfS rr )rQ r. s r
__reduce__zProcessLocalSet.__reduce__ s Dz2~ r N)r7 r9 r: r, rR r< r r rK rK s
@ r rK c e Zd Z i Z ej
Z ddZd Zdi fdZ d Z
d Z e d Z
d Zd
Zd Zd Zd
Zy)r Nc t j 5 t j j |j d }|;t j t f}|t j |j < d d d d | _ |d | _ || _
| j j | _ || _
|| _ t | d | _ || _ |t% j& | | _ nK| j | j j( | _ n#t% j* j, | _ |r| j/ t j0 | t j2 y # 1 sw Y xY w)Nr r )r _mutexr6 r r( r ForkAwareLocalrK _tls_idset_tokenr) _id_managerr rw r _owned_by_managerr ru r r rv _increfrP _after_fork) r+ r r r= rv r rl
manager_owned tls_idsets r r, zBaseProxy.__init__ s6
G!3377
tLI / / 1?3D D =F ++EMM: G aL
l ;;>>
%&z215 "/ # 8 8 ADM
]]
& MM 2 2DM # 3 3 5 = =DM LLN y'<'<=K G Gs A(E<<Fc t j d t j j }t j j dk7 r$|dt j j z z
}| j | j j | j }t |d d|f || j _
y )Nz making connection to manager
MainThread|r rg )r r r r r] r| r r rY r( r rH rW r
)r+ r] r s r _connectzBaseProxy._connect s
12&&(-- # # % * *l : C)224999 9D||DKK / / |Gt 04': # r r< c | j j }|j | j |||f |j \ }}|dk( r|S |dk( r|\ }}| j j |j d } | j j |_ | || j" | j | j$ | }
| j' |j | j$ }t) |d d|j* f |
S t- || # t $ r\ t j dt j j | j | j j }Y aw xY w)Nz#thread %r does not own a connectionr> r r< r rm )rW r
r r r r| r r] rd r? rZ r@ r[ r r' rY r( r r r rH r) rA ) r+ rC rD rE r rF rG r r r r? s r _callmethodzBaseProxy._callmethod( sA (99''D
488Zt45yy{ f 9 M
X
#NGU
// =bAI KK / /EM t''
wE <<
t}}<ED T4EHH; 7L tV,,- ( JJ< //166
8 MMO99''D (s D A!E;:E;c & | j d S )Nr rg r. s r _getvaluezBaseProxy._getvalueF s ,,r c
| j r+t j d| j j y | j | j j | j }t |d d| j f t j d| j j | j j | j | j xr | j j }t j | t j | j | j || j" | j | j
fd | _ y )Nz%owned_by_manager skipped INCREF of %rr rl z INCREF %r
r
)r\ r r rY r) r r( r rH rZ rX addr[ r r r _decrefrW _close)r+ r r2 s r r] zBaseProxy._increfL s ! ! JJ> O ||DKK / / |GtX{3
; / !
6$--"6"6mm )##++t}}e))T[[$,,8 r c j |j | j | |j t j k( rO t j d| j || j | }t |d d| j f n t j d| j |s\t |d rOt j dt j j |j j |`y y y # t $ r }t j d| Y d }~d }~ww xY w)Nz DECREF %rr rm 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( rH r r4 r| r r] r
r )r rv r2 tlsidsetr r r s r rn zBaseProxy._decref` s
ehh =EKK5== 8
6
;1 u}}g>tX{;
JJ> I l3 JJF //166
8 NN " 4u
6
1155
6s A
D D2D--D2c d | _ | j y # t $ r"}t j d|z Y d }~y d }~ww xY w)Nzincref failed: %s)r[ r] r r r )r+ r s r r^ zBaseProxy._after_forky s<
/ LLN / II)A- . . /s AA Ac
i }t | j |d< t | dd r3| j |d< t t
| j | j |ffS t t | | j | j |ffS )Nrv _isautoFr ) r r rY r9 RebuildProxyrB rY r rQ r+ rE s r rR zBaseProxy.__reduce__ s + "mmDO 4E * "nnDO T-=-=tDF
F !$Zd.>.>EG
Gr c " | j S r )rj )r+ memos r __deepcopy__zBaseProxy.__deepcopy__ s ~~ r c r dt | j | j j t | fz S )Nz <%s object, typeid %r at %#x>)rQ r7 rY r' r) r. s r r8 zBaseProxy.__repr__ s3 .T
##T[[%7%7DBC Cr c h | j d S # t $ r t | d d dz cY S w xY w)Nr8 rf z; '__str__()' failed>)rg r r r. s r rV zBaseProxy.__str__ sB =##J/ / =:cr?%<< < =s 11NNNTF)r7 r9 r: r6 r ForkAwareThreadLockrU r, rd rg rj r] rH rn r^ rR r{ r8 rV r< r r r r su
%T
%
%
'F26HM'>R$ ,.B -<- ( 0/ G C=r r c t t j dd }|r||j |j k( rct j
d| d|d< |j |j vr0|j |j |j |j < |j dd xr t t j dd } | ||fd|i|S )Nr z*Rebuild a proxy owned by manager, token=%rTr_ rl _inheritingF)
rY r r r( r r r) r{ ry pop)r^ r r rE r rl s r rw rw s W,,.0A4
HF
&..EMM1
?G $_ 88677 7 *
( ( 2
4 E G++-}e DD z 9& 9D 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 execrQ r r9 )r] r _cachedicmeth ProxyTypes r
MakeProxyTyper s GnG
tWo&&
C H 6:DBCF HH TI<-I!I 'FD'? s !!c r t | d }|4 || j | } t |d d| f }|j || |j }| t j j }t d| j z | } | | ||||| }
d|
_
|
S # |j w xY w)Nr r rh z
AutoProxy[%s])r= rv rl r_ T) rw r( rH r r r r rv r r' rv ) r r r= rv r rl r_ r r r r? s r rB rB s j)!,Gu}}g6 tT=5(CG JJL7.""))+33 o <gFI eZ' #=
BEEM L
JJLs B$ $B6c e Zd Zd Zd Zy) Namespacec : | j j | y r )r@ updaterx s r r, zNamespace.__init__ s
T"r c & t | j j }g }|D ]- \ }}|j d r|j |d| / |j | j j ddj | dS )Nra =(, r5 ) r! r@ r
startswithr[ r r6 r7 r )r+ r r\ r] r s r r8 zNamespace.__repr__ sv T]]((*+ 5KD%??3' tU 34 5
>>22DIIdODDr N)r7 r9 r: r, r8 r< r r r r s
#Er r c 8 e Zd ZddZd Zd Zd Z eee Zy)Valuec || _ || _ y r ) _typecode_value)r+ r r locks r r, zValue.__init__ s ! r c | j S r r r. s r r z Value.get s {{r c || _ y r r r+ r s r r z Value.set s r c f t | j d| j d| j dS )Nr r r5 )rQ r7 r r r. s r r8 zValue.__repr__ s! !$Z 0 0$..$++NNr NT) r7 r9 r: r, r r r8 rI r r< r r r r s# O S# Er r c . t j | | S r )r )r sequencer s r Arrayr s ;;x **r c . e Zd ZdZd Zd Zd Zd Zd Zy)
IteratorProxy)__next__r? throwr c | S r r< r. s r __iter__zIteratorProxy.__iter__ r c & | j d| S )Nr ri r+ rD s r r zIteratorProxy.__next__
s
D11r c & | j d| S )Nr? ri r s r r? zIteratorProxy.send s --r c & | j d| S )Nr ri r s r r zIteratorProxy.throw ..r c & | j d| S )Nr ri r s r r zIteratorProxy.close r r N) r7 r9 r: r9 r r r? r r r< r r r r s 6I2.//r r c * e Zd ZdZddZd Zd Zd Zy)
AcquirerProxy)acquirereleaseNc 8 ||fn||f}| j d| S Nr ri )r+ blockingr# rD s r r zAcquirerProxy.acquire s' %o{Hg3F 400r c $ | j d S Nr ri r. s r r zAcquirerProxy.release **r c $ | j d S r ri r. s r r+ zAcquirerProxy.__enter__ r r c $ | j d S r ri r- s r r1 zAcquirerProxy.__exit__ r r )TN)r7 r9 r: r9 r r r+ r1 r< r r r r s &I1+++r r c . e Zd ZdZddZddZd ZddZy) ConditionProxy)r r r notify
notify_allNc ( | j d|f S Nr ri r" s r r zConditionProxy.wait&
33r c ( | j d|f S )Nr ri )r+ ns r r zConditionProxy.notify( s 1$//r c $ | j d S )Nr ri r. s r r zConditionProxy.notify_all* s --r c | }|r|S |t j |z }nd }d }|s<| |t j z
}|dk r |S | j | }|s<|S )Nr )time monotonicr )r+ predicater# rG endtimewaittimes r wait_forzConditionProxy.wait_for, s~ M nn&0GGH""T^^%55q=
IIh [F
r r )r )r7 r9 r: r9 r r r r r< r r r r $ s FI40.r r c * e Zd ZdZd Zd Zd ZddZy)
EventProxy)r r rN r c $ | j d S )Nr ri r. s r r zEventProxy.is_setA s ))r c $ | j d S Nr ri r. s r r zEventProxy.setC &&r c $ | j d S )NrN ri r. s r rN zEventProxy.clearE ((r Nc ( | j d|f S r ri r" s r r zEventProxy.waitG r r r )r7 r9 r: r9 r r rN r r< r r r r ? s 2I*')4r r c T e Zd ZdZd dZd Zd Zed Zed Z ed Z
y)
BarrierProxy)__getattribute__r abortresetNc ( | j d|f S r ri r" s r r zBarrierProxy.waitM r r c $ | j d S )Nr ri r. s r r zBarrierProxy.abortO r r c $ | j d S )Nr ri r. s r r zBarrierProxy.resetQ r r c & | j dd S )Nr )partiesri r. s r r zBarrierProxy.partiesS s 2LAAr c & | j dd S )Nr ) n_waitingri r. s r r zBarrierProxy.n_waitingV s 2NCCr c & | j dd S )Nr )brokenri r. s r r zBarrierProxy.brokenY s 2K@@r r ) r7 r9 r: r9 r r r rI r r r r< r r r r K sR >I4))
B B
D D
A Ar r c " e Zd ZdZd Zd Zd Zy)NamespaceProxy)r __setattr__ __delattr__c ~ |d dk( rt j | | S t j | d } |d|f S )Nr ra rg r )objectr r+ rE
callmethods r __getattr__zNamespaceProxy.__getattr__` sB q6S=**45 5,,T=A
,sf55r c |d dk( rt j | || S t j | d } |d||f S )Nr ra rg r )r r r )r+ rE r r s r r zNamespaceProxy.__setattr__e sE q6S=%%dC7 7,,T=A
-#u 66r c ~ |d dk( rt j | | S t j | d } |d|f S )Nr ra rg r )r r r r s r r zNamespaceProxy.__delattr__j sA q6S=%%dC0 0,,T=A
-#00r N)r7 r9 r: r9 r r r r< r r r r ^ s BI6
7
1r r c R e Zd ZdZd Zd Z eee Z ee j Z y)
ValueProxy)r r c $ | j d S )Nr ri r. s r r zValueProxy.gets r r c ( | j d|f S r ri r s r r zValueProxy.setu s x00r N) r7 r9 r: r9 r r rI r rG types GenericAlias__class_getitem__r< r r r r q s. I'1 S# E#E$6$67r r
BaseListProxy)__add__ __contains__ __delitem__ __getitem____len____mul__ __reversed____rmul__ __setitem__r[ countextendindexinsertr removereverser __imul__c e Zd Zd Zd Zy) ListProxyc , | j d|f | S )Nr ri r s r __iadd__zListProxy.__iadd__ s E8, r c , | j d|f | S )Nr ri r s r r zListProxy.__imul__ s eX. r N)r7 r9 r: r
r r< r r r r s r r DictProxy)r r r r r r rN rA r r r r popitem
setdefaultr r r Iterator
ArrayProxy)r r r PoolProxy) apply apply_asyncr imapimap_unorderedr map map_asyncstarmap
starmap_asyncr3 AsyncResult)r r r r r c e Zd Zd Zd Zy)r c | S r r< r. s r r+ zPoolProxy.__enter__ r r c $ | j y r )r3 r- s r r1 zPoolProxy.__exit__ s r N)r7 r9 r: r+ r1 r< r r r r s r c e Zd Zy)r N)r7 r9 r: r< r r r r s r r Queue
JoinableQueuer r} RLock SemaphoreBoundedSemaphore ConditionBarrierPoolr! r r )r rD )rD c < e Zd Z g fdZd Zd Zd Zd Zd Zd Z y) _SharedMemoryTrackerc || _ || _ y r shared_memory_context_name
segment_names)r+ r] r, s r r, z _SharedMemoryTracker.__init__ s .2D +!.D r c t j d|dt | j j | y )NzRegister segment in pid )r r r r, r[ r+ segment_names r register_segmentz%_SharedMemoryTracker.register_segment s6 D JJ*<*:(68*M N % %l 3r c t j d|dt | j j | t j | }|j |j y )NzDestroy segment r. ) r r r r, r r SharedMemoryr unlink)r+ r0 segments r destroy_segmentz$_SharedMemoryTracker.destroy_segment s\
E JJ),)9&(L M % %l 3#00 >G MMO NN r c P | j d d D ] }| j | y r )r, r6 r/ s r r4 z_SharedMemoryTracker.unlink s- J $ 2 21 5
3 $$\2
3r c t j d| j j dt | j y )NzCall z .__del__ in )r r r6 r7 r r4 r. s r __del__z _SharedMemoryTracker.__del__ s1 JJt~~ 6 6 7|FH:N O KKMr c 2 | j | j fS r r* r. s r r/ z!_SharedMemoryTracker.__getstate__ s 33T5G5GH Hr c " | j | y r )r, r1 s r r3 z!_SharedMemoryTracker.__setstate__ s DMM5 !r N)
r7 r9 r: r, r1 r6 r4 r9 r/ r3 r< r r r( r( s, 5/1 / 4
3
I "r r( c R e Zd Zej g dz Zd Zd Zd Zd Zd Z d Z
y) SharedMemoryServer)
track_segmentrelease_segment
list_segmentsc t j | g|i | | j }t |t rt j | }t d| dt | _ t j dt y )Nshm_ra z"SharedMemoryServer started by pid ) rd r, r( rM rs osfsdecoder( r shared_memory_contextr r )r+ rD kwargsr( s r r, zSharedMemoryServer.__init__ sn OOD 24 26 2llG'5) ++g.$tG9AfhZ%@A
& JJ;FH:F Gr c t | j | d d r| j |d< t j | ||g|i |S )Nrf _shared_memory_proxyrE )r4 rt rE rd rf )r+ rB r' rD rF s r rf zSharedMemoryServer.create sQ
M
t}}V,R02HI262L2L./==q&B4B6B Br c d | j j t j | | S r )rE r4 rd re r s r re zSharedMemoryServer.shutdown s( O & & - - /??4+ +r c < | j j | y r )rE r1 r+ rB r0 s r r> z SharedMemoryServer.track_segment s M & & 7 7 Er c < | j j | y r )rE r6 rK s r r? z"SharedMemoryServer.release_segment s
K & & 6 6| Dr c 0 | j j S r )rE r, r s r r@ z SharedMemoryServer.list_segments s
&--;; ;r N) r7 r9 r: rd r r, rf re r> r? r@ r< r r r= r= s6 FG H C ,
F E
<r r= c 0 e Zd Z eZd Zd Zd Zd Zd Z y)r c t j dk( rddlm} |j t j | g|i | t j | j j dt y )Nposixr )resource_trackerz created by pid ) rC r] rQ ensure_runningr r, r r r6 r7 r )r+ rD rF rQ s r r, z SharedMemoryManager.__init__2 s\ ww'! / //1 7 7 7 JJ$..1122B68*M Nr c p t j | j j dt y )Nz.__del__ by pid )r r r6 r7 r r. s r r9 zSharedMemoryManager.__del__> s' JJ$..1122B68*M Nr c | j j t j k7 r| j j t j k( r t d | j j t j k( r t d t dj | j j | j | j | j | j | j S )Nz"Already started SharedMemoryServerz!SharedMemoryManager has shut downr )
r r r r r r
r rP r r r r r r. s r r z SharedMemoryManager.get_serverA s N{{ EMM1;;$$
5&'KLL[[&&%..8&'JKK&,33DKK4E4EFH H<<
$
t/?/?A
Ar c . | j | j | j 5 }t j d d| } t |d d|j f d d d |S # t $ r}|j |d }~ww xY w# 1 sw Y S xY w)Nr T)rf sizer> ) r r r r r3 rH r]
BaseExceptionr4 )r+ rW r smsr s r r3 z SharedMemoryManager.SharedMemoryN s
4 dmmT]] C
t#00dN T4 388+F
J % JJLG
Js) B
A'' B0BBB
Bc P | j | j | j 5 }t j | } t |d d|j j f d d d |S # t $ r!}|j j |d }~ww xY w# 1 sw Y S xY w)Nr r> )
r r r r
ShareableListrH shmr] rX r4 )r+ r r slr s r r[ z!SharedMemoryManager.ShareableListZ s
F dmmT]] C
t"00: T4 266;;.I
I % FFMMOG
Is) B #A.. B7 BBBB%N)
r7 r9 r: r= r r, r9 r r3 r[ r< r r r r & s* %
O O A
r r~ r )W__all__r r| r r queuer r rC r r r rR r
contextr r r
r r r r r HAS_SHMEMr[ ImportErrorr rF rQ rY
view_typesr$ view_typer r rH rA r rR r_ rb rd r r r XmlListener XmlClientrw r r rK r rw r rB 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( r= r )r] s 0r <module>rh sW A
@ @ * I NN() 2 5;; -4M
NDd$72t$&'
N
3IIy/23
z MF M. &(b )
I C) C AF*V F*Z
F ##Z%6%67 )):+?+?@t'& t't c m= m=f:* )+ , 8<7<:
E
E
F
+ /I /
+I
+] 6 4 4A9 A&1Y 1&8 8 o 0
+ (
< *
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*<V *<Z>k >g
]% I Os O; P ;PP
Browse
Usage
Versions