/opt/alt/python27/lib64/python2.7/multiprocessing
Edit: /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyc (39790B)
[
bc @ s d d d d g Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m
Z
m Z m Z m
Z
m Z m Z d d l m Z d d l m Z m Z m Z m Z d d
l m Z m Z y d d l m Z Wn! e k
rd d l m Z n Xd Z e j e j e g d
d d f D] Z e! e" i e ^ qDZ# d e$ f d YZ% f i d Z& d Z' d e( f d YZ) d Z* d Z+ d e$ f d YZ, d e$ f d YZ- i e j. e j/ f d 6e j0 e j1 f d 6Z2 d e$ f d YZ3 d e4 f d YZ5 d e$ f d YZ6 d! Z7 i d" Z8 e9 e9 e9 e: d# Z; d$ e$ f d% YZ< d& e$ f d' YZ= e: d( Z> d) e6 f d* YZ? d+ e6 f d, YZ@ d- e@ f d. YZA d/ e6 f d0 YZB d1 e6 f d2 YZC d3 e6 f d4 YZD e8 d5 d6 d7 d8 d9 d: d; d< d= d> d? d@ dA dB dC dD dE dF dG dH dI dJ dK f ZE dL eE f dM YZF e8 dN d7 d8 d: dO d< d@ dP dQ dR dS d
d dG dT dU dV d f ZG i dW dO 6eG _H e8 dX d< d: d@ d; dA f ZI e8 dY dZ d[ d\ d] d^ d_ d` da db f ZJ i dc d[ 6dc da 6dW d] 6dW d^ 6eJ _H d e3 f dd YZK eK j de e j eK j df e j eK j dg e jL eB eK j dh e jM e@ eK j di e jN e@ eK j dj e jO e@ eK j dk e jP e@ eK j dl e jQ eA eK j dm e
eJ eK j dn eR eF eK j do eS eG eK j d& e= eD eK j dp e> eI eK j d$ e< eC eK j dW dq e? dr eT eK j dc dr eT d S(s t BaseManagert SyncManagert BaseProxyt TokeniN( t
format_exc( t Processt current_processt active_childrent Poolt utilt
connection( t AuthenticationString( t exitt Popent assert_spawningt ForkingPickler( t Finalizet info( t
PicklingErrorc C s t j | j | j f f S( N( t arrayt typecodet tostring( t a( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt reduce_array@ s t itemst keyst valuesc B s8 e Z d Z d Z d Z d Z d Z d Z RS( s4
Type to uniquely indentify a shared object
t typeidt addresst idc C s! | | | | _ | _ | _ d S( N( R R R ( t selfR R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __init__P s c C s | j | j | j f S( N( R R R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __getstate__S s c C s | \ | _ | _ | _ d S( N( R R R ( R t state( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __setstate__V s c C s d | j | j | j f S( Ns# Token(typeid=%r, address=%r, id=%r)( R R R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __repr__Y s ( R R R ( t __name__t
__module__t __doc__t __slots__R R R" R# ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR J s c C sN | j | | | | f | j \ } } | d k r; | St | | d S( sL
Send a message to manager using connection `c` and return response
s #RETURNN( t sendt recvt convert_to_error( t cR t
methodnamet argst kwdst kindt result( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt dispatcha s
c C s~ | d k r | S| d k r> t | t k s4 t t | S| d k rp t | t k sb t t d | St d Sd S( Ns #ERRORs
#TRACEBACKs #UNSERIALIZABLEs Unserializable message: %s
s Unrecognized message type( t typet strt AssertionErrort RemoteErrort
ValueError( R/ R0 ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR* k s
R5 c B s e Z d Z RS( c C s) d d d d t | j d d d S( Ns
t -iK i ( R3 R- ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __str__x s ( R$ R% R8 ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR5 w s c C sO g } xB t | D]4 } t | | } t | d r | j | q q W| S( s4
Return a list of names of methods of `obj`
t __call__( t dirt getattrt hasattrt append( t objt tempt namet func( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt all_methods s c C s- g t | D] } | d d k r
| ^ q
S( sP
Return a list of names of methods of `obj` which do not start with '_'
i t _( RB ( R> R@ ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt public_methods s t Serverc B s e Z d Z d d d d d d d d d g Z d
Z d Z d Z d
Z d Z d Z d Z
i e d 6e
d 6e d 6Z d Z d Z
d Z d Z d Z d Z d Z d Z d Z RS( sM
Server class which runs in a process controlled by a manager object
t shutdownt createt accept_connectiont get_methodst
debug_infot number_of_objectst dummyt increft decrefc C s t | t s t | | _ t | | _ t | \ } } | d | d d | _ | j j | _ i d d f d 6| _
i | _ t j
| _ d | _ d S( NR t backlogi t 0i ( ( t
isinstancet bytesR4 t registryR t authkeyt listener_clientt listenerR t Nonet id_to_objt id_to_refcountt threadingt RLockt mutext stop( R RS R RT t
serializert Listenert Client( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c C s | t _ z yl xe y | j j } Wn t t f k
rD q n Xt j d | j d | f } t | _
| j q WWn t t
f k
r n XWd d | _ | j j Xd S( s(
Run the server forever
t targetR- Ni ( R t _manager_serverRV t acceptt OSErrort IOErrorRZ t Threadt handle_requestt Truet daemont startt KeyboardInterruptt
SystemExitR] t close( R R+ t t( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt
serve_forever s c C s d } } } yv t j | | j t j | | j | j } | \ } } } } | | j k st t d | t | | } Wn t k
r d t
f } nF Xy | | | | } Wn t k
r d t
f } n
Xd | f } y | j | Wnq t k
rp}
y | j d t
f Wn t k
r<n Xt j
d | t j
d | t j
d |
n X| j d S( s)
Handle a new connection
s %r unrecognizeds
#TRACEBACKs #RETURNs Failure to send message: %rs ... request was %rs ... exception was %rN( RW R
t deliver_challengeRT t answer_challengeR) t publicR4 R; t ExceptionR R( R R Rm ( R R+ t funcnameR0 t requestt ignoreR- R. RA t msgt e( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRg s4
c C s t j d t j j | j } | j } | j } x| j sy d } } | } | \ } } } }
| | \ } } } | | k r t
d | t | | f n t | | }
y |
| |
} Wn t
k
r } d | f } np X| o| j | d } | rP| j | | | \ } } t | | j | } d | | f f } n d | f } Wn t
k
r| d k rd t f } q?y8 | j | } | | | | | | |
} d | f } Wq?t
k
rd t f } q?XnV t k
r t j d t j j t j d n t
k
r>d t f } n Xy; y | | Wn& t
k
rx} | d t f n XWq7 t
k
r} t j d
t j j t j d | t j d | | j t j d
q7 Xq7 Wd S( sQ
Handle requests from the proxies in a particular process/thread
s$ starting server thread to service %rs+ method %r of %r object is not in exposed=%rs #ERRORs #PROXYs #RETURNs
#TRACEBACKs$ got EOF -- exiting thread serving %ri s #UNSERIALIZABLEs exception in thread serving %rs ... message was %rs ... exception was %ri N( R t debugRZ t current_threadR@ R) R( RX R] RW t AttributeErrorR2 R; Rs t getRG R R R t fallback_mappingt EOFErrort sysR R Rm ( R t connR) R( RX R, R> Ru t identR- R. t exposedt gettypeidt functiont resRx Rw R t ridentt rexposedt tokent
fallback_funcR0 ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt serve_client sl
c C s | S( N( ( R R R R> ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt fallback_getvalue+ s c C s
t | S( N( R3 ( R R R R> ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt fallback_str. s c C s
t | S( N( t repr( R R R R> ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt
fallback_repr1 s R8 R# s #GETVALUEc C s d S( N( ( R R+ ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRL : s c C s | j j z g } | j j } | j xS | D]K } | d k r6 | j d | | j | t | j | d d f q6 q6 Wd j | SWd | j j Xd S( sO
Return some info --- useful to spot problems with refcounting
RP s %s: refcount=%s
%si iK s
N(
R\ t acquireRX R t sortR= RY R3 t joint release( R R+ R0 R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRJ = s
'c C s t | j d S( s*
Number of shared objects
i ( t lenRX ( R R+ ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRK O s c C s z y t j d | j d t j t j k rZ t j d t j t _ t j t _ n t j d x( t
D] } t j d | j qq Wx( t
D] } t j d | j q Wt j t j
d Wn d d l } | j n XWd t d Xd S(
s'
Shutdown this process
s! manager received shutdown messages #RETURNs resetting stdout, stderri s& terminating a child process of managers manager exiting with exitcode 0iN( s #RETURNN( R Ry R( RW R t stdoutt
__stdout__t
__stderr__t stderrt _run_finalizersR t terminateR R t tracebackt print_excR ( R R+ t pR ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRF U s*
c O s\ | j j z:| j | \ } } } } | d k ra t | d k rN | sT t | d } n | | | } | d k r t | } n | d k r t | t k s t t | t | } n d t
| }
t j d | |
| t
| | f | j |
<|
| j k r&d | j |
Create a new shared object and return its id
i i s %xs& %r callable returned object with id %rN( R\ R RS RW R R4 RD R2 t dictt listR R Ry t setRX RY RM t tupleR ( R R+ R R- R. t callableR t method_to_typeidt proxytypeR> R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRG u s(
c C s t | j | j d S( sL
Return the methods of the shared object indicated by token
i ( R RX R ( R R+ R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRI s c C s- | t j _ | j d | j | d S( s=
Spawn a new thread to serve this connection
s #RETURNN( s #RETURNN( RZ Rz R@ R( RW R ( R R+ R@ ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRH s
c C s9 | j j z | j | c d 7
Connect manager object to the server process
RT RL N(
RU R R R R1 RW R R R R ( R R_ R` R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt connect s c C sg | j j t j k s t | d k rF t | d rF t d n t j d t
\ } } t d t | j
d | j | j | j | j | | | f | _ d j d | j j D } t | j d | | j _ | j j | j | j | _ | j t j | j _ t j | t | j d | j | j | j | j | j f d d
| _ d S( s@
Spawn a server process for this manager object
R9 s initializer must be a callablet duplexRa R- t :c s s | ] } t | Vq d S( N( R3 ( t .0t i( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pys
s R7 t exitpriorityi N( R R R R R4 RW R< t TypeErrorR
t Pipet FalseR R2 t _run_serverR R R R t _processR t _identityR$ R@ Rj Rm R) R R R t _finalize_managerR RF ( R t initializert initargst readert writerR ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRj s(
c C sl | d k r | | n | j | | | | } | j | j | j t j d | j | j d S( s@
Create a server, report its address and run it
s manager serving at %rN( RW t _ServerR( R Rm R R Ro ( t clsRS R RT R^ R R R t server( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s
c O s | j j t j k s! t d | j | j d | j } z) t | d d | f | | \ } } Wd | j
Xt | | j | | f S( sP
Create a new shared object; return the token and exposed tuple
s server not yet startedRT RG N( R R R R R4 R R R R1 RW Rm R ( R R R- R. R R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt _create0 s !) c C s | j j | d S( sC
Join the manager process (if it has been spawned)
N( R R ( R t timeout( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR < s c C sA | j | j d | j } z t | d d SWd | j Xd S( sS
Return some info about the servers shared objects and connections
RT RJ N( R R R R1 RW Rm ( R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt _debug_infoB s c C sA | j | j d | j } z t | d d SWd | j Xd S( s5
Return the number of shared objects
RT RK N( R R R R1 RW Rm ( R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt _number_of_objectsL s c C s | S( N( ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __enter__V s c C s | j d S( N( RF ( R t exc_typet exc_valt exc_tb( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __exit__Y s c C s | j r t j d y8 | | d | } z t | d d Wd | j XWn t k
rd n X| j d d | j r t j d t | d r t j d | j | j d d
| j r t j d q q q n t
j | _ y t
j | =Wn t k
rn Xd S( sQ
Shutdown the manager process; will be registered as a finalizer
s# sending shutdown message to managerRT RF NR g?s manager still aliveR s' trying to `terminate()` manager processg?s# manager still alive after terminate( t is_aliveR R R1 RW Rm Rs R R< R R R R R t _address_to_localt KeyError( t processR RT R! R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR \ s.
c C s | j S( N( R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt | t c
s$ d | j k r$ | j j | _ n d k r9 t n | pN t d d } | pf t d d } | r xa | j D]P \ } } t | t k s t d | t | t k s| t d | q| Wn | | | f | j <| r f d } | _
t | | n d S( s9
Register a typeid with the manager type
R t _exposed_t _method_to_typeid_s %r is not a stringc s t j d | j | | \ } } | | j d | d | j d | } | j | j d | j } t | d d | j f | S( Ns) requesting creation of a shared %r objectt managerRT R RN (
R Ry R R R R R R1 RW R ( R R- R. R t expt proxyR ( R R ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR? s N( t __dict__R t copyRW t AutoProxyR; R R2 R3 R4 R$ t setattr(
R R R R R R t
create_methodt keyR R? ( ( R R s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt register~ s ")
N( ( ( R$ R% R& R RE R RW R R R R Rj t classmethodR R R R R R R t staticmethodR t propertyR Rh R ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s*
$
t ProcessLocalSetc B s e Z d Z d Z RS( c C s t j | d d S( Nc S s
| j S( N( t clear( R> ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR R ( R t register_after_fork( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c C s t | d f S( N( ( R2 ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s ( R$ R% R R ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c B s e Z d Z i Z e j Z d d d e d Z d Z
d
i d Z d Z d Z
e d Z d Z d Z d Z d
Z d Z RS( s.
A base for proxies of shared objects
c C s; t j j zP t j j | j d } | d k r\ t j t f } | t j | j s 0x%x( R2 R$ R R R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR# O s c C s8 y | j d SWn t k
r3 t | d d SXd S( sV
Return representation of the referent (or a fall-back if that fails)
R# is ; '__str__()' failed>N( R Rs R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR8 S s
N( ( R$ R% R& R R t ForkAwareThreadLockR RW Rh R R R R R R R R R R R# R8 ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s %
c C s t t d d } | r? | j | j k r? | j | j d S| j d t od t t d t } | | | d | | Sd S( s
Function used for unpickling proxy objects.
If possible the shared object is returned, or otherwise a proxy for it.
Rb i RM t _inheritingN( R; R RW R RX R t popRh R ( RA R R^ R. R RM ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR ` s c B s e | } y | | | f SWn e k
r1 n Xi } x | D] } d | | f | Uq? We | e f | } | | _ | | | | f <| S( sB
Return a proxy type whose methods are given by `exposed`
sL def %s(self, *args, **kwds):
return self._callmethod(%r, args, kwds)( R R R2 R R ( R@ R t _cachet dict metht ProxyType( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt
MakeProxyTypeu s
c
C s t | d } | d k r\ | | j d | } z t | d d | f } Wd | j Xn | d k r | d k r | j } n | d k r t j } n t d | j | } | | | d | d | d | } t
| _ | S( s*
Return an auto-proxy for `token`
i RT RI Ns
AutoProxy[%s]R RM ( RU RW R R1 Rm R R RT R R Rh R (
R R^ R RT R RM R R R
R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s t Namespacec B s e Z d Z d Z RS( c K s | j j | d S( N( R t update( R R. ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c C ss | j j } g } x= | D]5 \ } } | j d s | j d | | f q q W| j d t j d | S( NRC s %s=%rs
Namespace(%s)s , ( R R t
startswithR= R R3 R ( R R R? R@ R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR# s
( R$ R% R R# ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s t Valuec B s> e Z e d Z d Z d Z d Z e e e Z RS( c C s | | _ | | _ d S( N( t _typecodet _value( R R R t lock( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c C s | j S( N( R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR| s c C s
| | _ d S( N( R ( R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c C s d t | j | j | j f S( Ns
%s(%r, %r)( R2 R$ R R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR# s ( R$ R% Rh R R| R R# R R ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s
c C s t j | | S( N( R ( R t sequenceR ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt Array s t
IteratorProxyc B sD e Z d Z d Z d Z d Z d Z d Z d
Z RS( t __next__t nextR( t throwRm c C s | S( N( ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __iter__ s c G s | j d | S( NR ( R ( R R- ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c G s | j d | S( NR ( R ( R R- ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c G s | j d | S( NR( ( R ( R R- ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR( s c G s | j d | S( NR ( R ( R R- ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c G s | j d | S( NRm ( R ( R R- ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRm s ( R R R( R Rm ( R$ R% R R R R R( R Rm ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s t
AcquirerProxyc B s5 e Z d Z e d Z d Z d Z d Z RS( R R c C s | j d | f S( NR ( R ( R t blocking( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R R R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s ( R R ( R$ R% R Rh R R R R ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s
t ConditionProxyc B s, e Z d Z d d Z d Z d Z RS(
R R t waitt notifyt
notify_allc C s | j d | f S( NR ( R ( R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s ( R R R R R N( R$ R% R RW R R R ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s t
EventProxyc B s5 e Z d Z d Z d Z d Z d d Z RS(
t is_setR R R c C s
| j d S( NR! ( R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR! s c C s
| j d S( NR ( R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s c C s | j d | f S( NR ( R ( R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s ( R! R R R N( R$ R% R R! R R RW R ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s
t NamespaceProxyc B s) e Z d Z d Z d Z d Z RS( t __getattribute__t __setattr__t __delattr__c C sB | d d k r t j | | St j | d } | d | f S( Ni RC R R# ( t objectR# ( R R t
callmethod( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __getattr__ s c C sH | d d k r# t j | | | St j | d } | d | | f S( Ni RC R R$ ( R& R$ R# ( R R R R' ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR$ s c C sB | d d k r t j | | St j | d } | d | f S( Ni RC R R% ( R& R% R# ( R R R' ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR% s ( R# R$ R% ( R$ R% R R( R$ R% ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR" s t
ValueProxyc B s/ e Z d Z d Z d Z e e e Z RS( R| R c C s
| j d S( NR| ( R ( R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR| s c C s | j d | f S( NR ( R ( R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s ( R| R ( R$ R% R R| R R R ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR) s t
BaseListProxyt __add__t __contains__t __delitem__t __delslice__t __getitem__t __getslice__t __len__t __mul__t __reversed__t __rmul__t __setitem__t __setslice__R= t countt extendt indext insertR t removet reverseR t __imul__t ListProxyc B s e Z d Z d Z RS( c C s | j d | f | S( NR8 ( R ( R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __iadd__ s c C s | j d | f | S( NR= ( R ( R R ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR= s ( R$ R% R? R= ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR> s t DictProxyR R R R| t has_keyt popitemt
setdefaultR
t Iteratort
ArrayProxyt PoolProxyt applyt apply_asyncRm t imapt imap_unorderedR t mapt map_asyncR t AsyncResultc B s e Z d Z RS( s(
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.
( R$ R% R& ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR C s t Queuet
JoinableQueuet Eventt LockR[ t Semaphoret BoundedSemaphoret ConditionR R R R R R (U t __all__t osR t weakrefRZ R RN R R t multiprocessingR R R R R R
t multiprocessing.processR t multiprocessing.forkingR R
R R t multiprocessing.utilR R t cPickleR t ImportErrorR R R R@ R2 R; t
view_typesR& R R1 R* Rs R5 RB RD RE R R_ R` t XmlListenert XmlClientRU R R R R R R RW Rh R R R R R R R R R" R) R* R> R@ R RE RF R RP RQ R[ RR RS RT R R R ( ( ( s= /opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt $ s ."
4
,