B
/G
$ @ s d dddgZ ddlZddlZddlZddlZddlZddlmZ ddlm Z dd l
m Z m Z m
Z
dd
lmZ dd lmZ dd lmZ dd
lmZ dd Ze eje dd dD Zed ek rdd ZxeD ]Ze ee qW G dd deZdi fddZdd ZG dd d e Z 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,ddd/d0Z-G d1d2 d2eZ.G d3d4 d4eZ/ded5d6Z0G d7d8 d8e*Z1G d9d: d:e*Z2G d;d< d d>e*Z4G d?d@ d@e*Z5G dAdB dBe*Z6G dCdD dDe*Z7e,dEdFZ8G dGdH dHe8Z9e,dIdJZ:dKdLie:_;e,dMdNZG dTd de'Z?e?dUej@ e?dVej@ e?dWejAe4 e?dXejBe2 e?dYejCe2 e?dZejDe2 e?d[ejEe2 e?d\ejFe3 e?d]ejGe5 e?d^ejHe> e?d_ee9 e?d`eIe: e?d4e/e7 e?d6e0e< e?d2e.e6 e?jdLe1dadb e?jdQdadc dS )f BaseManager SyncManager BaseProxyToken N)
format_exc )
connection) reductionget_spawning_popen ProcessError)pool)process)util) get_contextc C s t j | j| ffS )N)arraytypecodetobytes)a r =/opt/alt/python37/lib64/python3.7/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 Zdd Zd d
Zd S ) r z3
Type to uniquely identify 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+
__module__ __qualname____doc__ __slots__r& r' r) r, r r r r r 3 s r c C s8 | ||||f | \}}|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
r: c C sd | dkr |S | dkrRt |ts4td|| t|| dkrHtd| S t|S ntd| S d S )Nz#ERROR)z
#TRACEBACKz#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strz#UNSERIALIZABLEzUnserializable message: %s
z Unrecognized message type {!r})
isinstancestr TypeErrorformatr RemoteError
ValueError)r8 r9 r r r r3 T s
r3 c @ s e Zd Zdd ZdS )r? c C s dt | jd d S )NzM
---------------------------------------------------------------------------
r zK---------------------------------------------------------------------------)r< r6 )r% r r r __str__d s zRemoteError.__str__N)r+ r- r. rA r r r r r? c s r? c C s6 g }x,t | D ] }t| |}t|r|| qW |S )z4
Return a list of names of methods of `obj`
)dirr callableappend)r tempr funcr r r all_methodsk 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 z s z"public_methods..)rG )r r r r public_methodsv 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 sx t |ts td|t||| _t|| _t | \}}||dd| _
| j
j | _ ddi| _ i | _
i | _t | _d S )Nz&Authkey {0!r} is type {1!s}, not bytes )r# Zbacklog0)Nr )r; bytesr= r> r registryr
AuthenticationStringauthkeylistener_clientlistenerr# id_to_objid_to_refcountid_to_local_proxy_obj threadingLockmutex)r% rW r# rY
serializerListenerClientr r r r& s
zServer.__init__c C s t | _| t _zZt j| jd}d|_| y x| j
sN| j d q6W W n t t
fk
rj Y nX W dtjtjkrtd tjt_tjt_td 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% rk r r r
serve_forever s
zServer.serve_foreverc C sP xJy| j }W n tk
r& wY nX tj| j|fd}d|_| qW d S )N)re r6 T)r[ ZacceptOSErrorr_ rj handle_requestrl rm )r% r4 tr r r rk s zServer.accepterc C s4 d } }}y>t || j t || j | }|\}}}}t| |}W n tk
rh dt f} Y n>X y||f||}W n tk
r dt f} Y n
X d|f} y|| W nr tk
r& }
zRy|dt f W n tk
r Y nX t
d| t
d| t
d|
W dd}
~
X Y nX | dS )z)
Handle a new connection
Nz
#TRACEBACKz#RETURNzFailure to send message: %rz ... request was %rz ... exception was %r) r Zdeliver_challengerY Zanswer_challenger2 r Exceptionr r1 r infoclose) r% r4 funcnamer9 requestignorer6 r7 rF msger r r r{ s2 zServer.handle_requestc
C s t dt j |j}|j}| j}x| j syBd }}| }|\}}} }
y|| \}} } W n^ t
k
r }
z@y| j | \}} } W n& t
k
r } z|
W dd}~X Y nX W dd}
~
X Y nX || krt d|t
|| f t||}y|| |
}W n, tk
r& } z d|f}W dd}~X Y nPX | o8| |d}|rn| |||\}}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 dt j td Y n tk
r@ dt f}Y nX yDy || W n2 tk
r } z|d
t f W dd}~X Y nX W q( tk
r } z@t d t j t d | t d
| | td W dd}~X Y 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 ru r_ current_threadr r2 r1 r\ rg rn KeyErrorr^ AttributeErrorr r r} getrL r r# r fallback_mappingEOFErrorrr rx r~ r )r% connr2 r1 r\ r5 r r identr6 r7 exposed gettypeidkeZ second_keZfunctionZresr r r" ZridentZrexposedtokenZ
fallback_funcr9 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_repr2 s zServer.fallback_repr)rA r, z #GETVALUEc C s d S )Nr )r% r4 r r r rQ ; s z Server.dummyc
C s| | j l g }t| j }| xD|D ]<}|dkr(|d|| j| t| j| d dd f q(W d|S Q R X dS )zO
Return some info --- useful to spot problems with refcounting
rU z %s: refcount=%s
%sr NK
) ra r r] r sortrD r< r\ join)r% r4 r9 r r r r r rO > s
$zServer.debug_infoc C s
t | jS )z*
Number of shared objects
)lenr] )r% r4 r r r rP N s zServer.number_of_objectsc C sL z:yt d |d W n ddl}| Y nX W d| j X dS )z'
Shutdown this process
z!manager received shutdown message)z#RETURNNr N)r ru r1 traceback print_excrg set)r% r4 r r r r rK U s
zServer.shutdownc O s t | dkr| ^}}}} nz| s(tdnld|krDtdt | d |d}t | dkrf| ^}}} n.d|krtdt | d |d}| ^}} t| } |j |j| \}}}}|dkr|st | dkrtd | d
} n
|| |} |dkrt| }|dk r4t|t s$td
|t |t |t | }d t
| }
td
||
| t||f|j|
< |
|jkrxd
|j|
< W dQ R X |||
|
t|fS )z>
Create a new shared object and return its id
z8descriptor 'create' of 'Server' object needs an argumentr" z7create expected at least 2 positional arguments, got %dr r4 Nz4Without 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 r= poptuplera rW r@ rI r; dictr> r r r$ r ru r r\ r] rR ) r6 r7 r% r4 r" rC r method_to_typeid proxytyper r r r r rL b sN
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% r4 r r r r rN s zServer.get_methodsc C s" |t _|d | | dS )z=
Spawn a new thread to serve this connection
)z#RETURNNN)r_ r r r1 r )r% r4 r r r r rM s
zServer.accept_connectionc C s | j y| j| d7 < W nh tk
r } zJ|| jkrrd| j|< | j| | j|< | j| \}}}td| n|W d d }~X Y nX W d Q R X d S )Nr z&Server re-enabled tracking & INCREF %r)ra r] r r^ r\ r ru )r% r4 r r r r r r r r rR s
z
Server.increfc C s || j kr$|| jkr$td| d S | jZ | j | dkrXtd|| j| | j | | j | d8 < | j | dkr| j |= W d Q R X || j krd| j|< td| | j | j|= W d Q R X 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 ru ra AssertionErrorr> r\ )r% r4 r r r r rS s$
z
Server.decrefN)r+ r- r. r/ Zpublicr& ry rk r{ r r r r r rQ rO rP rK rL rN rM rR rS r r r r rJ s.
"Q
8rJ c @ s e Zd ZdgZdZdZdZdS )Statevaluer r r N)r+ r- r. r0 INITIALSTARTEDSHUTDOWNr r r r r s r )pickleZ xmlrpclibc @ s e Zd ZdZi ZeZd"ddZdd Zdd Z d#d d Z
e d$d
dZ 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}|| _t || _t | _tj| j_ || _
t | \| _ | _
|pTt | _d S )N)r
rh rY _addressrX _authkeyr _stater r _serializerrZ Z _Listener_Clientr _ctx)r% r# rY rb Zctxr r r r& s
zBaseManager.__init__c C sf | j jtjkrP| j jtjkr&tdn*| j jtjkr>tdntd| j jt| j | j
| j | j S )zX
Return server object with serve_forever() method and address attribute
zAlready started serverzManager has shut downzUnknown state {!r})
r r r 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
)rY NrQ ) rZ r r r r: r r r r )r% rc rd r r r r connect s zBaseManager.connectr c C s4 | j jtjkrP| j jtjkr&tdn*| j jtjkr>tdntd| j j|dk rht|sht dt
j dd\}}| j j
t| j| j| j| j| j|||fd| _d d
d | jjD }t| jd | | j_| j | | | _| tj| j _t j | t| j | j| j| j| j | j fd
d| _ dS )z@
Spawn a server process for this manager object
zAlready started serverzManager has shut downzUnknown state {!r}Nz initializer must be a callableF)Zduplex)re r6 :c s s | ]}t |V qd S )N)r< )r ir r r 1 s z$BaseManager.start..-r )r6 exitpriority)!r r r r r r r r> rC r= r ZPiper ZProcessr _run_serverr r r r _processr Z _identityr+ r rm r r2 r Finalize_finalize_managerr rK )r% initializerinitargsreaderwriterr r r r rm s4
zBaseManager.startc C sN |dk r|| | ||||}||j | td|j | dS )z@
Create a server, report its address and run it
Nzmanager serving at %r)_Serverr1 r# r r r~ ry ) clsrW r# rY rb r r r serverr r r r C s zBaseManager._run_serverc O s` | ^}}} t | } |j|j|jd}z t|dd|f| |\}}W d| X t||j||fS )zP
Create a new shared object; return the token and exposed tuple
)rY NrL )r r r r r: r r )r6 r7 r% r" r r$ r r r r _createW s
zBaseManager._createc C s* | j dk r&| 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 f s
zBaseManager.joinc C s. | j | j| jd}z t|ddS | X dS )zS
Return some info about the servers shared objects and connections
)rY NrO )r r r r: r )r% r r r r _debug_infoo s zBaseManager._debug_infoc C s. | j | j| jd}z t|ddS | X dS )z5
Return the number of shared objects
)rY NrP )r r r r: r )r% r r r r _number_of_objectsy s z BaseManager._number_of_objectsc C sj | j jtjkr| | j jtjkrf| j jtjkr )r% r r r __enter__ s
zBaseManager.__enter__c C s | d S )N)rK )r% exc_typeexc_valexc_tbr r r __exit__ s zBaseManager.__exit__c C s | rtd y,|||d}zt|dd W d| X W n tk
rR Y nX | jdd | rtd t| drtd | | jd
d | rtd 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)rY NrK g ?)r zmanager still alive terminatez'trying to `terminate()` manager processg?z#manager still alive after terminate)r r r~ r: r r} r hasattrr r r r r _address_to_localr )r
r# rY r( r r r r r r s.
z BaseManager._finalize_managerc C s | j S )N)r )r% r r r r# s zBaseManager.addressTc
s d| j kr| j | _ dkr"t |p0t dd}|p@t dd}|r`xt| D ]\}}qTW ||| f| j< |r fdd} | _t| | dS )z9
Register a typeid with the manager type
r N _exposed__method_to_typeid_c s` t d | jf||\}} || j| | j|d}| j|j| jd}t|d d|jf |S )Nz)requesting creation of a shared %r object)managerrY r )rY rS ) r ru r r r r r# r: r$ )r% r6 r7 r Zexpproxyr )r r" r r rE s z"BaseManager.register..temp) __dict__r copy AutoProxyr r r r+ setattr)
r r" rC r r r
create_methodkeyr rE r )r r" r register s
zBaseManager.register)NNr N)Nr )Nr )N)NNNNT)r+ r- r. r/ r rJ r r& r r rm 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 | dd d S )Nc S s | S )N)clear)r r r r z*ProcessLocalSet.__init__..)r register_after_fork)r% r r r r& s zProcessLocalSet.__init__c C s t | dfS )Nr )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 Ze Zd ddZdd Z d i fd
d Z
d d
Z dd Z e
dd Zdd Zdd Zdd Zdd Zdd ZdS ) r z.
A base for proxies of shared objects
NTFc C s t j8 t j|jd }|d kr:t t f}|t j|j< W d Q R X |d | _|d | _ || _
| j
j | _ || _
|| _t| d | _|| _|d k rt|| _n"| j
d k r| j
j| _n t j| _|r| t| t j d S )Nr r )r _mutexr r r# r ZForkAwareLocalr _tls_idset_tokenr$ _id_managerr rZ r _owned_by_managerr
rX r rh rY _increfr _after_fork) r% r rb r rY r rR
manager_ownedZ tls_idsetr r r r& s*
zBaseProxy.__init__c C sd t d t j}t jdkr4|dt j 7 }| j| jj | j
d}t |d d|f || j _
d S )Nz making connection to managerZ
MainThread|)rY rM )r ru r
rh r r_ r r r r# r r: r r )r% r r r r r _connect s
zBaseProxy._connectr c C s y | j j}W n6 tk
rB tdt j | | j j}Y nX | | j
|||f | \}}|dkrp|S |dkr|\}}| j j
|j d } | jj|_| || j| j | j|d}
| j|j| jd}t|dd|jf |
S t||dS ) zV
Try to call a method of the referent and return a copy of the result
z#thread %r does not own a connectionz#RETURNz#PROXY)r rY r )rY NrS )r r r r ru r_ r r r r1 r r2 r r r" r r# r r r r: r$ r3 ) r% r5 r6 r7 r r8 r9 r r r r r r r _callmethod& s,
zBaseProxy._callmethodc C s
| dS )z9
Get a copy of the value of the referent
z #GETVALUE)r )r% r r r _getvalueD s zBaseProxy._getvaluec C s | j rtd| jj d S | j| jj| jd}t|d d| j f td| jj | j
| j | j oj| j j
}tj| tj| j| j|| j| j
| jfdd| _d S )Nz%owned_by_manager skipped INCREF of %r)rY rR z INCREF %r
)r6 r )r r ru r r$ r r# r r: r r addr r r r _decrefr Z_close)r% r r( r r r r J s
zBaseProxy._increfc
C s | | j |d ks |jtjkry2td| j || j|d}t|d d| jf W q t k
r } ztd| W d d }~X Y qX ntd| j |st
|drtdt j
|j |`d S )Nz DECREF %r)rY 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 ru r# r: r} r r_ r r r r )r rY r( ZtlsZidsetr r r r r r r ^ s
zBaseProxy._decrefc
C sH d | _ y | W n0 tk
rB } ztd| W d d }~X Y nX d S )Nzincref failed: %s)r r r} r r~ )r% r r r r r w 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 )NrY _isautoFr ) r
r r r RebuildProxyr r r r )r% r7 r r r r s
zBaseProxy.__reduce__c C s | S )N)r )r% Zmemor r r __deepcopy__ 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, s zBaseProxy.__repr__c C s4 y
| 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 rA 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 t dd}|rT|j|jkrTtd| d|d< |j|jkrT|j|j |j|j< | ddopt t dd }| ||fd|i|S ) z5
Function used for unpickling proxy objects.
ri Nz*Rebuild a proxy owned by manager, token=%rTr rR Z _inheritingF)
r r
rh r# r ru r$ r^ r\ r )rF r rb r7 r rR r r r r 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 _cacheZdicZmeth ProxyTyper r r
MakeProxyType s
r Tc
C s t | d }|dkrB|| j|d}zt|dd| f}W d| X |dkrX|dk rX|j}|dkrjt j}td| j |}|| ||||d} d| _
| S )z*
Return an auto-proxy for `token`
r N)rY rN z
AutoProxy[%s])r rY rR T) rZ r# r: r r r
rh rY r r" r )
r rb r rY r rR r r r r r r r r s
r c @ s e Zd Zdd Zdd ZdS ) Namespacec K s | j | d S )N)r update)r% r7 r r r r& s zNamespace.__init__c C s^ t | j }g }x,|D ]$\}}|ds|d||f qW | d| jjd|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 | |S )N)r )r Zsequencer r r r Array s r c @ s8 e Zd ZdZdd Zdd Zdd Zdd Zd
d Zd S )
IteratorProxy)__next__r1 throwr c C s | S )Nr )r% r r r __iter__ s zIteratorProxy.__iter__c G s | d|S )Nr )r )r% r6 r r r r s zIteratorProxy.__next__c G s | d|S )Nr1 )r )r% r6 r r r r1
s zIteratorProxy.sendc G s | d|S )Nr
)r )r% r6 r r r r
s zIteratorProxy.throwc G s | d|S )Nr )r )r% r6 r r r r s zIteratorProxy.closeN) r+ r- r. r r r r1 r
r r r r r r s r c @ s2 e Zd ZdZd ddZdd Zdd Zd
d ZdS )
AcquirerProxy)acquirereleaseTNc C s" |d kr|fn||f}| d|S )Nr
)r )r% Zblockingr r6 r r r r
s zAcquirerProxy.acquirec C s
| dS )Nr )r )r% r r r r s zAcquirerProxy.releasec C s
| dS )Nr
)r )r% r r r r s zAcquirerProxy.__enter__c C s
| dS )Nr )r )r% r r r r r r r s zAcquirerProxy.__exit__)TN)r+ r- r. r r
r r r r r r r r s
r c @ s6 e Zd ZdZd ddZd
ddZdd Zdd
d ZdS )ConditionProxy)r
r ro notify
notify_allNc C s | d|fS )Nro )r )r% r r r r ro $ s zConditionProxy.waitr c C s | d|fS )Nr )r )r% nr r r r & s zConditionProxy.notifyc C s
| dS )Nr )r )r% r r r r ( s zConditionProxy.notify_allc C sh | }|r|S |d k r$t | }nd }d }x6|sb|d k rP|t }|dkrPP | | | }q.W |S )Nr )timeZ monotonicro )r% Z predicater r9 ZendtimeZwaittimer r r wait_for* s
zConditionProxy.wait_for)N)r )N)r+ r- r. r ro r r r r r r r r " s
r c @ s2 e Zd ZdZdd Zdd Zdd Zd d d
ZdS )
EventProxy)rn r r ro c C s
| dS )Nrn )r )r% r r r rn ? s zEventProxy.is_setc C s
| dS )Nr )r )r% r r r r A s zEventProxy.setc C s
| dS )Nr )r )r% r r r r C s zEventProxy.clearNc C s | d|fS )Nro )r )r% r r r r ro E s zEventProxy.wait)N)r+ r- r. r rn r r ro r r r r r = s
r c @ sN e Zd ZdZdddZdd Zdd Zed d
Zed d Z ed
d Z
dS ) BarrierProxy)__getattribute__ro abortresetNc C s | d|fS )Nro )r )r% r r r r ro K s zBarrierProxy.waitc C s
| dS )Nr )r )r% r r r r M s zBarrierProxy.abortc C s
| dS )Nr )r )r% r r r r O s zBarrierProxy.resetc C s | ddS )Nr )parties)r )r% r r r r Q s zBarrierProxy.partiesc C s | ddS )Nr ) n_waiting)r )r% r r r r T s zBarrierProxy.n_waitingc C s | ddS )Nr )broken)r )r% r r r r W s zBarrierProxy.broken)N) r+ r- r. r ro r r r r r r r r r r r I s
r c @ s( e Zd ZdZdd Zdd Zdd ZdS ) NamespaceProxy)r __setattr__ __delattr__c C s0 |d dkrt | |S t | d}|d|fS )Nr rH r r )objectr )r% r
callmethodr r r __getattr__^ s zNamespaceProxy.__getattr__c C s4 |d dkrt | ||S t | d}|d||fS )Nr rH r r )r r r )r% r r r! r r r r c s zNamespaceProxy.__setattr__c C s0 |d dkrt | |S t | d}|d|fS )Nr rH r r )r r r )r% r r! r r r r h s zNamespaceProxy.__delattr__N)r+ r- r. r r" r r r r r r r \ s r c @ s* e Zd ZdZdd Zdd ZeeeZdS )
ValueProxy)r r c C s
| dS )Nr )r )r% r r r r q s zValueProxy.getc C s | d|fS )Nr )r )r% r r r r r s s zValueProxy.setN)r+ r- r. r r r r r r r r r r# o 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 | d|f | S )Nr/ )r )r% r r r r __iadd__ s zListProxy.__iadd__c C s | d|f | S )Nr4 )r )r% r r r r r4 s zListProxy.__imul__N)r+ r- r. r6 r4 r r r r r5 ~ s r5 DictProxy)r& r' r( r r) r- r r r r r r popitem
setdefaultr r r Iterator
ArrayProxy)r) r( r- PoolProxy) Zapply apply_asyncr imapimap_unorderedr map map_asyncstarmap
starmap_asyncr Z AsyncResult)r= rA rC r> r? c @ s e Zd Zdd Zdd ZdS )r< c C s | S )Nr )r% r r r r s zPoolProxy.__enter__c C s | d S )N)r )r% r r r r r r r s zPoolProxy.__exit__N)r+ r- r. r r r r r r r< 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 s QueueZ
JoinableQueuerf r` RLock SemaphoreBoundedSemaphore ConditionBarrierPoolr r F)r r )r )NNNT)T)J__all__rr r_ r Zqueuer r r r contextr r
r r r
r r r r Z
view_typesr r! Z view_typer r r: r3 r} r? rG rI rJ r rc rd Z XmlListenerZ XmlClientrZ r r r r r r r r r r r r r r r r r# r$ r5 r7 r r; Z
BasePoolProxyr< r rD rf r` rE rF rG rH rI rJ r r r r r s
\
w
4