3
\ @ s d dddgZ ddlZddlZddlZddlZddlZddlmZ ddlm Z dd l
m Z m Z dd
lm
Z
dd lmZ dd lmZ dd
lmZ dd Ze jeje dd dD Zed ek rdd ZxeD ]Ze jee qW G dd deZf i fddZdd ZG d d d eZ d d Z d d! Z G d"d# d#eZ G d$d% d%eZ e j!e j"fe j#e j$fd&Z%G d'd d eZ&G d(d) d)e'Z(G d*d deZ)d+d, Z*i fd-d.Z+dd0d1Z,G d2d3 d3eZ-G d4d5 d5eZ.dd6d7Z/G d8d9 d9e)Z0G d:d; d;e)Z1G dd? d?e)Z3G d@dA dAe)Z4G dBdC dCe)Z5G dDdE dEe)Z6e+dFdZ7G dZd[ d[e7Z8e+d\dZ9d]deie9_:e+dfdZ;e+dgdZe>jdwej? e>jdxej? e>jdyej@e3 e>jdzejAe1 e>jd{ejBe1 e>jd|ejCe1 e>jd}ejDe1 e>jd~ejEe2 e>jdejFe4 e>jde
jGe= e>jdee8 e>jdeHe9 e>jd5e.e6 e>jd7e/e; e>jd3e-e5 e>jdee0dd e>jdsdd dS ) BaseManager SyncManager BaseProxyToken N)
format_exc )
connection) reductionget_spawning_popen)pool)process)util) get_contextc C s t j | j| j ffS )N)arraytypecodetobytes)a r 0/usr/lib64/python3.6/multiprocessing/managers.py reduce_array$ s r c C s g | ]}t ti | qS r )typegetattr).0namer r r
( s r itemskeysvaluesc C s t t | ffS )N)list)objr r r rebuild_as_list* s r c @ s4 e Zd ZdZdZdd Zdd Zd d
Zd d Zd
S )r z4
Type to uniquely indentify a shared object
typeidaddressidc C s ||| | _ | _| _d S )N)r! r" r# )selfr! r" r# r r r __init__9 s zToken.__init__c C s | j | j| jfS )N)r! r" r# )r$ r r r __getstate__< s zToken.__getstate__c C s |\| _ | _| _d S )N)r! r" r# )r$ stater r r __setstate__? s zToken.__setstate__c C s d| j j| j| j| jf S )Nz %s(typeid=%r, address=%r, id=%r)) __class____name__r! r" r# )r$ r r r __repr__B s zToken.__repr__N)r! r" r# ) r*
__module__ __qualname____doc__ __slots__r% r& r( r+ r r r r r 3 s c C s8 | j ||||f | j \}}|dkr*|S t||dS )zL
Send a message to manager using connection `c` and return response
z#RETURNN)sendrecvconvert_to_error)cr#
methodnameargskwdskindresultr r r dispatchJ s
r9 c C s\ | dkr |S | dkr,t |tks$tt|S | dkrPt |tksDttd| S tdS d S )Nz#ERRORz
#TRACEBACKz#UNSERIALIZABLEzUnserializable message: %s
zUnrecognized message type)r strAssertionError RemoteError
ValueError)r7 r8 r r r r2 T s r2 c @ s e Zd Zdd ZdS )r< c C s& ddd d t | jd dd S )N
-K r )r: r5 )r$ r r r __str__a s zRemoteError.__str__N)r* r, r- rA r r r r r< ` s r< c C s6 g }x,t | D ] }t| |}t|r|j| qW |S )z4
Return a list of names of methods of `obj`
)dirr callableappend)r tempr funcr r r all_methodsh s
rG c C s dd t | D S )zP
Return a list of names of methods of `obj` which do not start with '_'
c S s g | ]}|d dkr|qS )r _r )r r r r r r w s z"public_methods..)rG )r r r r public_methodss s rI c @ s e Zd ZdZdddddddd d
g Zd d Zd
d Zdd Zdd Zdd Z dd Z
dd Z dd Z e e e
dZ
d d Zd d Zd d! Zd"d# Zd$d% Zd&d' Zd(d) Zd*d+ Zd,d- Zd.S )/ServerzM
Server class which runs in a process controlled by a manager object
shutdowncreateaccept_connection get_methods
debug_infonumber_of_objectsdummyincrefdecrefc C sl t |tst|| _tj|| _t| \}}||dd| _| jj | _ dd f fi| _
i | _ i | _ t
j | _d S )N )r" Zbacklog0)
isinstancebytesr; registryr AuthenticationStringauthkeylistener_clientlistenerr" id_to_objid_to_refcountid_to_local_proxy_obj threadingLockmutex)r$ rX r" rZ
serializerListenerClientr r r r% s
zServer.__init__c C s t j | _| tj _zZt j| jd}d|_|j y x| jj
sN| jj d q6W W n t t
fk
rj Y nX W dtjtjkrtjd tjt_tjt_tjd X dS )z(
Run the server forever
)targetTr Nzresetting stdout, stderrr )r` Event
stop_eventr current_process_manager_serverThreadaccepterdaemonstartis_setwaitKeyboardInterrupt
SystemExitsysstdout
__stdout__r
debug
__stderr__stderrexit)r$ rl r r r
serve_forever s
zServer.serve_foreverc C sP xJy| j j }W n tk
r& wY nX tj| j|fd}d|_|j qW d S )N)rf r5 T)r\ ZacceptOSErrorr` rk handle_requestrm rn )r$ r3 tr r r rl s zServer.accepterc ' C sL d } }}yTt j|| j t j|| j |j }|\}}}}|| jksTtd| t| |}W n tk
r~ dt f} Y n>X y||f||}W n tk
r dt f} Y n
X d|f} y|j
| W nt tk
r> }
zVy|j
dt f W n tk
r Y nX t j d| t j d| t j d|
W Y dd}
~
X nX |j
dS )z)
Handle a new connection
Nz%r unrecognizedz
#TRACEBACKz#RETURNzFailure to send message: %rz ... request was %rz ... exception was %r)r Zdeliver_challengerZ Zanswer_challenger1 publicr; r Exceptionr r0 r
infoclose) r$ r3 funcnamer8 requestignorer5 r6 rF msger r r r| s4 zServer.handle_requestc D C s t jdtj j |j}|j}| j}x| jj syBd }}| }|\}}} }
y|| \}} } W n^ t
k
r }
zBy| j | \}} } W n& t
k
r } z
|
W Y dd}~X nX W Y dd}
~
X nX || krt d|t
|| f t||}y|| |
}W n, tk
r& } zd|f}W Y dd}~X nPX | o8| j|d}|rn| j|||\}}t|| j|}d||ff}nd|f}W n t k
r |dkrdt f}nNy,| j| }|| |||f| |
}d|f}W n tk
r dt f}Y nX Y nP tk
r" t jdtj j tjd Y n tk
r@ dt f}Y nX yDy || W n2 tk
r } z|d
t f W Y dd}~X nX W q( tk
r } zBt jd tj j t jd | t jd
| |j tjd W Y dd}~X q(X q(W dS )zQ
Handle requests from the proxies in a particular process/thread
z$starting server thread to service %rNz+method %r of %r object is not in exposed=%rz#ERRORz#PROXYz#RETURNz
#TRACEBACKz$got EOF -- exiting thread serving %rr z#UNSERIALIZABLEz exception in thread serving %rz ... message was %rz ... exception was %rr )r
rv r` current_threadr r1 r0 r] rh ro KeyErrorr_ AttributeErrorr r r getrL r r" r fallback_mappingEOFErrorrs ry r r )r$ connr1 r0 r] r4 r r identr5 r6 exposed gettypeidkeZ second_keZfunctionresr r r! ZridentZrexposedtokenZ
fallback_funcr8 r r r serve_client sx (
$ zServer.serve_clientc C s |S )Nr )r$ r r r r r r fallback_getvalue& s zServer.fallback_getvaluec C s t |S )N)r: )r$ r r r r r r fallback_str) s zServer.fallback_strc C s t |S )N)repr)r$ r r r r r r
fallback_repr, s zServer.fallback_repr)rA r+ z #GETVALUEc C s d S )Nr )r$ r3 r r r rQ 5 s z Server.dummyc C s| | j l g }t| jj }|j xD|D ]<}|dkr(|jd|| j| t| j| d dd f q(W dj|S Q R X dS )zO
Return some info --- useful to spot problems with refcounting
rU z %s: refcount=%s
%sr Nr@ r> ) rb r r^ r sortrD r: r] join)r$ r3 r8 r r r r r rO 8 s
$zServer.debug_infoc C s
t | jS )z*
Number of shared objects
)lenr^ )r$ r3 r r r rP G s zServer.number_of_objectsc C sL z:yt jd |jd W n ddl}|j Y nX W d| jj X dS )z'
Shutdown this process
z!manager received shutdown message#RETURNNr )r N)r
rv r0 traceback print_excrh set)r$ r3 r r r r rK N s
zServer.shutdownc O s | j | j| \}}}}|dkrBt|dkr4| s8t|d } n
|||} |dkr\t| }|dk rt|tksttt|t| }dt| }
t j
d||
| t ||f| j |
< |
| j
krd| j
|
< W dQ R X | j||
|
t|fS )z>
Create a new shared object and return its id
Nr r z%xz&%r callable returned object with id %r)rb rX r r; rI r dictr r# r
rv r r] r^ rR tuple) r$ r3 r! r5 r6 rC r method_to_typeid proxytyper r r r r rL [ s$
z
Server.createc C s t | j|j d S )zL
Return the methods of the shared object indicated by token
r )r r] r# )r$ r3 r r r r rN z s zServer.get_methodsc C s" |t j _|jd | j| dS )z=
Spawn a new thread to serve this connection
#RETURNN)r N)r` r r r0 r )r$ r3 r r r r rM s
zServer.accept_connectionc C s | j y| j| d7 < W nh tk
r } zL|| jkrrd| j|< | j| | j|< | j| \}}}tjd| n|W Y d d }~X nX W d Q R X d S )Nr z&Server re-enabled tracking & INCREF %r)rb r^ r r_ r] r
rv )r$ r3 r r r r r r r r rR s
z
Server.increfc C s || j kr$|| jkr$tjd| d S | j@ | j | dks>t| j | d8 < | j | dkrf| j |= W d Q R X || j krd f d f| j|< tjd| | j | j|= W d Q R X d S )NzServer DECREF skipping %rr r zdisposing of obj with id %r)r^ r_ r
rv rb r; r] )r$ r3 r r r r rS s
z
Server.decrefN)r* r, r- r. r~ r% rz rl r| r r r r r rQ rO rP rK rL rN rM rR rS r r r r rJ } s.
"Q
rJ c @ s e Zd ZdgZdZdZdZdS )Statevaluer r N)r* r, r- r/ INITIALSTARTEDSHUTDOWNr r r r r s r )pickleZ xmlrpclibc @ s e Zd ZdZi ZeZd!ddZdd Zdd Z df fd
d Z
e df fd d
Z dd Z
d"ddZdd Zdd Zdd Zdd Zedd Zed d Ze d#d d ZdS )$r z!
Base class for managers
Nr c C s\ |d krt j j}|| _t j|| _t | _tj| j_ || _
t | \| _ | _
|pTt | _d S )N)r ri rZ _addressrY _authkeyr _stater r _serializerr[ Z _Listener_Clientr _ctx)r$ r" rZ rc Zctxr r r r% s
zBaseManager.__init__c C s( | j jtjkstt| j| j| j| j S )zX
Return server object with serve_forever() method and address attribute
)
r r r r r; rJ _registryr r r )r$ r r r
get_server s
zBaseManager.get_serverc C s8 t | j \}}|| j| jd}t|dd tj| j_dS )z>
Connect manager object to the server process
)rZ NrQ ) r[ r r r r9 r r r r )r$ rd re r r r r connect s zBaseManager.connectc C s | j jtjkst|dk r,t| r,tdtjdd\}}| j j
t | j | j
| j| j| j|||fd| _djdd | jjD }t | jd | | j_| jj |j |j | _|j tj| j _tj| t | j | j| j| j| j | j fd
d | _ dS ) z@
Spawn a server process for this manager object
Nz initializer must be a callableF)Zduplex)rf r5 :c s s | ]}t |V qd S )N)r: )r ir r r s z$BaseManager.start..r? r )r5 exitpriority) r r r r r; rC TypeErrorr ZPiper ZProcessr _run_serverr r r r _processr Z _identityr* r rn r r1 r r
Finalize_finalize_managerr rK )r$ initializerinitargsreaderwriterr r r r rn s(
zBaseManager.startc C sN |dk r|| | j ||||}|j|j |j tjd|j |j dS )z@
Create a server, report its address and run it
Nzmanager serving at %r)_Serverr0 r" r r
r rz ) clsrX r" rZ rc r r r serverr r r r s zBaseManager._run_serverc O sd | j jtjkstd| j| j| jd}z t|dd|f| |\}}W d|j X t
|| j||fS )zP
Create a new shared object; return the token and exposed tuple
zserver not yet started)rZ NrL ) r r r r r; r r r r9 r r )r$ r! r5 r6 r r# r r r r _create% s
zBaseManager._createc C s* | j dk r&| j j| | j j s&d| _ dS )zC
Join the manager process (if it has been spawned)
N)r r is_alive)r$ timeoutr r r r 1 s
zBaseManager.joinc
C s. | j | j| jd}z t|ddS |j X dS )zS
Return some info about the servers shared objects and connections
)rZ NrO )r r r r9 r )r$ r r r r _debug_info: s zBaseManager._debug_infoc
C s. | j | j| jd}z t|ddS |j X dS )z5
Return the number of shared objects
)rZ NrP )r r r r9 r )r$ r r r r _number_of_objectsD s z BaseManager._number_of_objectsc C s, | j jtjkr| j | j jtjks(t| S )N)r r r r rn r r; )r$ r r r __enter__N s zBaseManager.__enter__c C s | j d S )N)rK )r$ exc_typeexc_valexc_tbr r r __exit__T s zBaseManager.__exit__c C s | j rtjd y,|||d}zt|dd W d|j X W n tk
rR Y nX | jdd | j rtjd t| drtjd | j | jd
d | j rtjd t j
|_ y t j
|= W n tk
r Y nX dS ) zQ
Shutdown the manager process; will be registered as a finalizer
z#sending shutdown message to manager)rZ NrK g ?)r zmanager still alive terminatez'trying to `terminate()` manager processg?z#manager still alive after terminate)r r
r r9 r r r hasattrr r r r r _address_to_localr )r r" rZ r' r r r r r r W s.
z BaseManager._finalize_managerc C s | j S )N)r )r$ r r r w s zBaseManager.Tc
s d| j kr| jj | _ dkr"t |p0t dd}|p@t dd}|rxHt|j D ]8\}}t|tkstt d| t|tksTt d| qTW ||| f| j< |rƇ fdd} | _
t | | dS )z9
Register a typeid with the manager type
r N _exposed__method_to_typeid_z%r is not a stringc s` t jd | jf||\}} || j| | j|d}| j|j| jd}t|d d|jf |S )Nz)requesting creation of a shared %r object)managerrZ r )rZ rS ) r
rv r r r r r" r9 r# )r$ r5 r6 r Zexpproxyr )r r! r r rE s z"BaseManager.register..temp) __dict__r copy AutoProxyr r r r r: r; r* setattr)
r r! rC r r r
create_methodkeyr rE r )r r! r registery s
zBaseManager.register)NNr N)N)NNNNT)r* r, r- r. r rJ r r% r r rn classmethodr r r r r r r staticmethodr propertyr" r r r r r r s*
$
c @ s e Zd Zdd Zdd ZdS )ProcessLocalSetc C s t j| dd d S )Nc S s | j S )N)clear)r r r r r s z*ProcessLocalSet.__init__..)r
register_after_fork)r$ r r r r% s zProcessLocalSet.__init__c C s t | f fS )N)r )r$ r r r
__reduce__ s zProcessLocalSet.__reduce__N)r* r, r- r% r r r r r r s r c @ s e Zd ZdZi Zej ZdddZdd Z f i fd d
Z
d d Z d
d Z e
dd Zdd Zdd Zdd Zdd Zdd ZdS ) r z.
A base for proxies of shared objects
NTFc
C s t j8 t jj|jd }|d kr:tj t f}|t j|j< W d Q R X |d | _|d | _ || _
| j
j | _ || _
|| _t| d | _|| _|d k rtj|| _n"| j
d k r| j
j| _n tj j| _|r| j tj| t j d S )Nr r )r _mutexr r r" r
ZForkAwareLocalr _tls_idset_tokenr# _id_managerr r[ r _owned_by_managerr rY r ri rZ _increfr _after_fork) r$ r rc r rZ r rR
manager_ownedZ tls_idsetr r r r% s*
zBaseProxy.__init__c C sd t jd tj j}tj jdkr4|dtj j 7 }| j| jj | j
d}t |d d|f || j _
d S )Nz making connection to managerZ
MainThread|)rZ rM )r
rv r ri r r` r r r r" r r9 r r )r$ r r r r r _connect s
zBaseProxy._connectc C s y | j j}W n6 tk
rB tjdtj j | j | j j}Y nX |j | j
|||f |j \}}|dkrp|S |dkr|\}}| j j
|j d } | jj|_| || j| j | j|d}
| j|j| jd}t|dd|jf |
S t||dS )
zW
Try to call a method of the referrent and return a copy of the result
z#thread %r does not own a connectionz#RETURNz#PROXYr )r rZ r )rZ NrS )r r r r
rv r` r r r r0 r r1 r r r! r r" r r r r9 r# r2 ) r$ r4 r5 r6 r r7 r8 r r r r r r r _callmethod s,
zBaseProxy._callmethodc C s
| j dS )z9
Get a copy of the value of the referent
z #GETVALUE)r )r$ r r r _getvalue s zBaseProxy._getvaluec C s | j rtjd| jj d S | j| jj| jd}t|d d| j f tjd| jj | j
j | j | j oj| j j
}tj| tj| j| j|| j| j
| jfdd| _d S )Nz%owned_by_manager skipped INCREF of %r)rZ rR z INCREF %r
)r5 r )r r
rv r r# r r" r r9 r r addr r r r _decrefr Z_close)r$ r r' r r r r s
zBaseProxy._increfc C s |j | j |d ks |jtjkry2tjd| j || j|d}t|d d| jf W q t k
r } ztjd| W Y d d }~X qX ntjd| j | rt
|drtjdt j j
|jj |`d S )Nz DECREF %r)rZ rS z... decref failed %sz%DECREF %r -- manager already shutdownr z-thread %r has no more proxies so closing conn)discardr# r r r r
rv r" r9 r r r` r r r r )r rZ r' ZtlsZidsetr r r r r r r s
zBaseProxy._decrefc C sH d | _ y | j W n0 tk
rB } ztjd| W Y d d }~X nX d S )Nzincref failed: %s)r r r r
r )r$ r r r r r 9 s
zBaseProxy._after_forkc C s^ i }t d k r| j|d< t| ddrB| j|d< tt| j| j|ffS tt| | j| j|ffS d S )NrZ _isautoFr ) r
r r r RebuildProxyr r r r )r$ r6 r r r r A s
zBaseProxy.__reduce__c C s | j S )N)r )r$ memor r r __deepcopy__N s zBaseProxy.__deepcopy__c C s dt | j| jjt| f S )Nz <%s object, typeid %r at %#x>)r r* r r! r# )r$ r r r r+ Q s zBaseProxy.__repr__c C s4 y
| j dS tk
r. t| dd d S X dS )zV
Return representation of the referent (or a fall-back if that fails)
r+ Nr z; '__str__()' failed>r )r r r )r$ r r r rA U s
zBaseProxy.__str__)NNNTF)r* r, r- r. r r
ZForkAwareThreadLockr r% r r r r r r r r r r+ rA r r r r r s
(
c C s t tj dd}|rT|j|jkrTtjd| d|d< |j|jkrT|j|j |j|j< |j ddopt tj dd }| ||fd|i|S ) z5
Function used for unpickling proxy objects.
rj Nz*Rebuild a proxy owned by manager, token=%rTr rR Z _inheritingF)
r r ri r" r
rv r# r_ r] pop)rF r rc r6 r rR r r r r b s r c
C sr t |}y || |f S tk
r( Y nX i }x |D ]}td||f | q4W t| tf|}||_||| |f< |S )zB
Return a proxy type whose methods are given by `exposed`
zLdef %s(self, *args, **kwds):
return self._callmethod(%r, args, kwds))r r execr r r )r r _cacheZdicmeth ProxyTyper r r
MakeProxyTypew s
r Tc
C s t | d }|dkrB|| j|d}zt|dd| f}W d|j X |dkrX|dk rX|j}|dkrjtj j}td| j |}|| ||||d} d| _
| S )z*
Return an auto-proxy for `token`
r N)rZ rN z
AutoProxy[%s])r rZ rR T) r[ r" r9 r r r ri rZ r r! r )
r rc r rZ r rR r r r r r r r r s
r c @ s e Zd Zdd Zdd ZdS ) Namespacec K s | j j| d S )N)r update)r$ r6 r r r r% s zNamespace.__init__c C s^ t | jj }g }x,|D ]$\}}|jds|jd||f qW |j d| jjdj|f S )NrH z%s=%rz%s(%s)z, ) r r r
startswithrD r r) r* r )r$ r rE r r r r r r+ s
zNamespace.__repr__N)r* r, r- r% r+ r r r r r s r c @ s8 e Zd Zd ddZdd Zdd Zdd ZeeeZd
S ) ValueTc C s || _ || _d S )N) _typecode_value)r$ r r lockr r r r% s zValue.__init__c C s | j S )N)r )r$ r r r r s z Value.getc C s
|| _ d S )N)r )r$ r r r r r s z Value.setc C s dt | j| j| jf S )Nz
%s(%r, %r))r r* r r )r$ r r r r+ s zValue.__repr__N)T) r* r, r- r% r r r+ r r r r r r r s
r c C s t j | |S )N)r )r Zsequencer r r r Array s r c @ s8 e Zd ZdZdd Zdd Zd d
Zd d Zd
d ZdS )
IteratorProxy__next__r0 throwr c C s | S )Nr )r$ r r r __iter__ s zIteratorProxy.__iter__c G s | j d|S )Nr )r )r$ r5 r r r r s zIteratorProxy.__next__c G s | j d|S )Nr0 )r )r$ r5 r r r r0 s zIteratorProxy.sendc G s | j d|S )Nr )r )r$ r5 r r r r s zIteratorProxy.throwc G s | j d|S )Nr )r )r$ r5 r r r r s zIteratorProxy.closeN)r r0 r r ) r* r, r- r r
r r0 r r r r r r r
s r
c @ s2 e Zd Zd
ZdddZdd Zd d
Zd d ZdS )
AcquirerProxyacquirereleaseTNc C s" |d kr|fn||f}| j d|S )Nr )r )r$ Zblockingr r5 r r r r s zAcquirerProxy.acquirec C s
| j dS )Nr )r )r$ r r r r s zAcquirerProxy.releasec C s
| j dS )Nr )r )r$ r r r r s zAcquirerProxy.__enter__c C s
| j dS )Nr )r )r$ r r r r r r r s zAcquirerProxy.__exit__)r r )TN)r* r, r- r r r r r r r r r r s
r c @ s4 e Zd ZdZdddZd d
Zd d Zdd
dZdS )ConditionProxyr r rp notify
notify_allNc C s | j d|fS )Nrp )r )r$ r r r r rp s zConditionProxy.waitc C s
| j dS )Nr )r )r$ r r r r s zConditionProxy.notifyc C s
| j dS )Nr )r )r$ r r r r s zConditionProxy.notify_allc C sh | }|r|S |d k r$t j | }nd }d }x6|sb|d k rP|t j }|dkrPP | j| | }q.W |S )Nr )timeZ monotonicrp )r$ Z predicater r8 ZendtimeZwaittimer r r wait_for s
zConditionProxy.wait_for)r r rp r r )N)N)r* r, r- r rp r r r r r r r r s
r c @ s2 e Zd ZdZdd Zdd Zd d
Zdd d
Zd S )
EventProxyro r r rp c C s
| j dS )Nro )r )r$ r r r ro s zEventProxy.is_setc C s
| j dS )Nr )r )r$ r r r r s zEventProxy.setc C s
| j dS )Nr )r )r$ r r r r s zEventProxy.clearNc C s | j d|fS )Nrp )r )r$ r r r r rp s zEventProxy.wait)ro r r rp )N)r* r, r- r ro r r rp r r r r r s
r c @ sN e Zd ZdZdddZdd Zd
d Zed d
Zedd Z edd Z
dS ) BarrierProxy__getattribute__rp abortresetNc C s | j d|fS )Nrp )r )r$ r r r r rp
s zBarrierProxy.waitc C s
| j dS )Nr )r )r$ r r r r s zBarrierProxy.abortc C s
| j dS )Nr )r )r$ r r r r s zBarrierProxy.resetc C s | j ddS )Nr parties)r )r )r$ r r r r s zBarrierProxy.partiesc C s | j ddS )Nr n_waiting)r )r )r$ r r r r s zBarrierProxy.n_waitingc C s | j ddS )Nr broken)r )r )r$ r r r r s zBarrierProxy.broken)r rp r r )N) r* r, r- r rp r r r r r r r r r r r s
r c @ s( e Zd Zd Zdd Zdd Zdd Zd
S ) NamespaceProxyr __setattr__ __delattr__c C s0 |d dkrt j| |S t j| d}|d|fS )Nr rH r r )objectr )r$ r
callmethodr r r __getattr__ s zNamespaceProxy.__getattr__c C s4 |d dkrt j| ||S t j| d}|d||fS )Nr rH r r )r! r r )r$ r r r" r r r r % s zNamespaceProxy.__setattr__c C s0 |d dkrt j| |S t j| d}|d|fS )Nr rH r r )r! r r )r$ r r" r r r r * s zNamespaceProxy.__delattr__N)r r r )r* r, r- r r# r r r r r r r s r c @ s* e Zd ZdZdd Zdd ZeeeZdS )
ValueProxyr r c C s
| j dS )Nr )r )r$ r r r r 3 s zValueProxy.getc C s | j d|fS )Nr )r )r$ r r r r r 5 s zValueProxy.setN)r r )r* r, r- r r r r r r r r r r$ 1 s r$
BaseListProxy__add__ __contains__ __delitem__ __getitem____len____mul__ __reversed____rmul__ __setitem__rD countextendindexinsertr removereverser __imul__c @ s e Zd Zdd Zdd ZdS ) ListProxyc C s | j d|f | S )Nr0 )r )r$ r r r r __iadd__A s zListProxy.__iadd__c C s | j d|f | S )Nr5 )r )r$ r r r r r5 D s zListProxy.__imul__N)r* r, r- r7 r5 r r r r r6 @ s r6 DictProxyr
r r r has_keypopitem
setdefaultr Iterator
ArrayProxy PoolProxyapply apply_asyncr imapimap_unorderedr map map_asyncstarmap
starmap_asyncr Z AsyncResult)r@ rD rF rA rB c @ s e Zd Zdd Zdd ZdS )r> c C s | S )Nr )r$ r r r r d s zPoolProxy.__enter__c C s | j d S )N)r )r$ r r r r r r r f s zPoolProxy.__exit__N)r* r, r- r r r r r r r> c s c @ s e Zd ZdZdS )r 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.
N)r* r, r- r. r r r r r m s QueueZ
JoinableQueuerg ra RLock SemaphoreBoundedSemaphore ConditionBarrierPoolr r F)r r )r )r r r )NNNT)T)r& r' r( r) r* r+ r, r- r. rD r/ r0 r1 r2 r r3 r4 r r5 )r' r( r) r
r* r. r r r r9 r r r r: r; r r )r* r) r. ) r? r@ r rA rB r rC rD rE rF r )I__all__rs r` r Zqueuer r r r contextr r
r r r
r r r Z
view_typesr r Z view_typer! r r9 r2 r r< rG rI rJ r rd re Z XmlListenerZ XmlClientr[ r r r r r r r r r r r
r r r r r r$ r% r6 r8 r r= Z
BasePoolProxyr> r rG rg ra rH rI rJ rK rL rM r r r r r s
;
]
4