//usr/lib64/lib64//lib64//python2.7/
ۜSec @ 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: d< d@ dO dP dQ dR d
d dG dS dT dU d f ZG e8 dV d< d: d@ d; dA f ZH e8 dW dX dY dZ d[ d\ d] d^ d_ d` f ZI i da dY 6da d_ 6db d[ 6db d\ 6eI _J d e3 f dc YZK eK j dd e j eK j de e j eK j df e jL eB eK j dg e jM e@ eK j dh e jN e@ eK j di e jO e@ eK j dj e jP e@ eK j dk e jQ eA eK j dl e
eI eK j dm eR eF eK j dn eS eG eK j d& e= eD eK j do e> eH eK j d$ e< eC eK j db dp e? dq eT eK j da dq eT d S(r 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( ( s0 /usr/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 ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt __init__P s c C s | j | j | j f S( N( R R R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt __getstate__S s c C s | \ | _ | _ | _ d S( N( R R R ( R t state( ( s0 /usr/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 ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt __repr__Y s ( s typeids addresss id( t __name__t
__module__t __doc__t __slots__R R R" R# ( ( ( s0 /usr/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( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt dispatcha s
c C sN | d k r | S| d k r& t | S| d k r@ t d | St d Sd S( Ns #ERRORs
#TRACEBACKs #UNSERIALIZABLEs Unserializable message: %s
s Unrecognized message type( t RemoteErrort
ValueError( R/ R0 ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR* k s
R2 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 ( t strR- ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt __str__x s ( R$ R% R6 ( ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR2 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( ( s0 /usr/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 _( R@ ( R< R> ( ( s0 /usr/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 | \ } } | d | d d | _ | j j | _ i d d f d 6| _ i | _ t j
| _ d | _ d S( NR t backlogi t 0i ( (
t registryR t authkeyt listener_clientt listenerR t Nonet id_to_objt id_to_refcountt threadingt RLockt mutext stop( R RO R RP t
serializert Listenert Client( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C s | t _ z yk xd y | j j } Wn t t f k
rD q n Xt j d | j d | f } t | _
| j q Wn t t
f k
r n XWd d | _ | j j Xd S( s(
Run the server forever
t targetR- Ni ( R t _manager_serverRR t acceptt OSErrort IOErrorRV t Threadt handle_requestt Truet daemont startt KeyboardInterruptt
SystemExitRY t close( R R+ t t( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt
serve_forever s c C s` d } } } yW t j | | j t j | | j | j } | \ } } } } 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
rQ}
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
#TRACEBACKs #RETURNs Failure to send message: %rs ... request was %rs ... exception was %rN(
RS R
t deliver_challengeRP t answer_challengeR) R9 t ExceptionR R( R R Ri ( R R+ t funcnameR0 t requestt ignoreR- R. R? t msgt e( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRc s2
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
r{} | 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 debugRV t current_threadR> R) R( RT RY RS t AttributeErrort typeR9 Rn t getRE R R R t fallback_mappingt EOFErrort sysR t reprR Ri ( R t connR) R( RT R, R< Rp t identR- R. t exposedt gettypeidt functiont resRs Rr R t ridentt rexposedt tokent
fallback_funcR0 ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt serve_client sl
c C s | S( N( ( R R} R~ R< ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt fallback_getvalue+ s c C s
t | S( N( R5 ( R R} R~ R< ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt fallback_str. s c C s
t | S( N( R| ( R R} R~ R< ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt
fallback_repr1 s R6 R# s #GETVALUEc C s d S( N( ( R R+ ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRJ : 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
RN s %s: refcount=%s
%si iK s
N(
RX t acquireRT R t sortR; RU R5 t joint release( R R+ R0 R R~ ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRH = s
'c C s t | j d S( s*
Number of shared objects
i ( t lenRT ( R R+ ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRI 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 Rt R( RS R{ t stdoutt
__stdout__t
__stderr__t stderrt _run_finalizersR t terminateR R t tracebackt print_excR ( R R+ t pR ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRD U s*
c O s% | j j z| j | \ } } } } | d k rB | d } n | | | } | d k rl t | } n | d k r 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 s %xs& %r callable returned object with id %rN( RX R RO RS RB t listR R Rt t setRT RU RK t tupleR ( R R+ R R- R. t callableR t method_to_typeidt proxytypeR< R~ ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRE u s$
c C s t | j | j d S( sL
Return the methods of the shared object indicated by token
i ( R RT R ( R R+ R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRG s c C s- | t j _ | j d | j | d S( s=
Spawn a new thread to serve this connection
s #RETURNN( s #RETURNN( RV Ru R> R( RS R ( R R+ R> ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRF s
c C s9 | j j z | j | c d 7
Connect manager object to the server process
RP RJ N(
RQ R R R R1 RS R R R R ( R R[ R\ R} ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt connect s c C sL | d k r+ t | d r+ 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
R7 s initializer must be a callablet duplexR] R- t :c s s | ] } t | Vq d S( N( R5 ( t .0t i( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pys
s R4 t exitpriorityi N( RS R: t TypeErrorR
t Pipet FalseR Rw t _run_serverR R R R t _processR t _identityR$ R> Rf Ri R) R R R R R R t _finalize_managerR RD ( R t initializert initargst readert writerR~ ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRf 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( RS t _ServerR( R Ri R R Rk ( t clsRO R RP RZ R R R t server( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s
c O sk | 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
RP RE N( R R R R1 RS Ri R ( R R R- R. R} R R ( ( s0 /usr/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( ( s0 /usr/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
RP RH N( R R R R1 RS Ri ( R R} ( ( s0 /usr/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
RP RI N( R R R R1 RS Ri ( R R} ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt _number_of_objectsL s c C s | S( N( ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt __enter__V s c C s | j d S( N( RD ( R t exc_typet exc_valt exc_tb( ( s0 /usr/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 managerRP RD NR g?s manager still aliveR s' trying to `terminate()` manager processg?s# manager still alive after terminate( t is_aliveR R R1 RS Ri Rn R R: R R R R R t _address_to_localt KeyError( t processR RP R! R R} ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR \ s.
c C s | j S( N( R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt | s c
s d | j k r$ | j j | _ n d k r9 t n | pN t d d } | pf t d d } | r x | j 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_c 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 managerRP R RL (
R Rt R R R R R R1 RS R ( R R- R. R t expt proxyR} ( R R ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR= s N( t __dict__R t copyRS t AutoProxyR9 R R$ t setattr(
R R R R R R t
create_methodt keyR R= ( ( R R s0 /usr/lib64/python2.7/multiprocessing/managers.pyt register~ s
N( ( ( R$ R% R& R RC R RS R R R R Rf t classmethodR R R R R R R t staticmethodR t propertyR Rd R ( ( ( s0 /usr/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< ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s ( R t register_after_fork( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C s t | d f S( N( ( Rw ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s ( R$ R% R R ( ( ( s0 /usr/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 RV Ru R R R R R1 RS R R
( R R> R} ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt _connect s
c C s5 y | j j } Wn@ t k
rR t j d t j j | j | j j } n X| j | j
| | | f | j \ } } | d k r | S| d k r"| \ } } | j j
| j d } | | | j d | j d | j d | }
| j | j d | j } t | d d | j f |
St | | d S(
sW
Try to call a method of the referrent and return a copy of the result
s# thread %r does not own a connections #RETURNs #PROXYiR RP R RL N( R R
Rv R Rt RV Ru R> R R( R R) R R R R R R R R1 RS R R* ( R R, R- R. R} R/ R0 R R R R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt _callmethod s*
c C s
| j d S( s9
Get a copy of the value of the referent
s #GETVALUE( R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt _getvalue s c C s | j | j j d | j } t | d d | j f t j d | j j | j
j | j | j or | j j
} t j | t j d | j | j | | j | j
| j f d d | _ d S( NRP RK s INCREF %rR- R i
( R R R R R1 RS R R Rt R R t addR R R R t _decrefR t _close( R R} R! ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR
s c C s | j | j | d k s. | j t j k r yE t j d | j | | j d | } t | d d | j f Wq t
k
r } t j d | q Xn t j d | j | r t | d r t j d t j
j | j j | ` n d S( Ns DECREF %rRP RL s ... decref failed %ss% DECREF %r -- manager already shutdownR
s- thread %r has no more proxies so closing conn( t discardR RS R R R R Rt R R1 Rn R: RV Ru R> R
Ri ( R RP R! t tlst idsetR R} Rs ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s
c C sB d | _ y | j Wn$ t k
r= } t j d | n Xd S( Ns incref failed: %s( RS R R Rn R R ( R Rs ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR 6 s
c C s i } t j r" | j | d s
c C s
| j S( N( R ( R t memo( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt __deepcopy__K s c C s* d t | j | j j d t | f S( Ns <%s object, typeid %r at %s>s 0x%x( Rw R$ R R R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR# N 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 Rn R| ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR6 R s
N( ( R$ R% R& R R t ForkAwareThreadLockR RS Rd R R R R R R R R R R R# R6 ( ( ( s0 /usr/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.
R^ i RK t _inheritingN( R9 R RS R RT R t popRd R ( R? R RZ R. R RK ( ( s0 /usr/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( sC
Return an proxy type whose methods are given by `exposed`
sL def %s(self, *args, **kwds):
return self._callmethod(%r, args, kwds)( R R Rw R R ( R> R t _cachet dict metht ProxyType( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt
MakeProxyTypet 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 RP RG Ns
AutoProxy[%s]R RK ( RQ RS R R1 Ri R R RP R R Rd R (
R RZ R RP R RK R R} R R ( ( s0 /usr/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. ( ( s0 /usr/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( NRA s %s=%rs
Namespace(%s)s , ( R R t
startswithR; R R5 R ( R R R= R> R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR# s
( R$ R% R R# ( ( ( s0 /usr/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( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C s | j S( N( R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRx s c C s
| | _ d S( N( R ( R R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C s d t | j | j | j f S( Ns
%s(%r, %r)( Rw R$ R R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR# s ( R$ R% Rd R Rx R R# R R ( ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR
s
c C s t j | | S( N( R ( R t sequenceR
( ( s0 /usr/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 throwRi c C s | S( N( ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt __iter__ s c G s | j d | S( NR ( R ( R R- ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c G s | j d | S( NR ( R ( R R- ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c G s | j d | S( NR( ( R ( R R- ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR( s c G s | j d | S( NR ( R ( R R- ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c G s | j d | S( NRi ( R ( R R- ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRi s ( s __next__s nexts sends throws close( R$ R% R R R R R( R Ri ( ( ( s0 /usr/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( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R R R R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s ( s acquires release( R$ R% R Rd R R R R ( ( ( s0 /usr/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 ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s ( s acquires releases waits notifys
notify_allN( R$ R% R RS R R R ( ( ( s0 /usr/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 ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C s
| j d S( NR ( R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C s | j d | f S( NR ( R ( R R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s ( s is_sets sets clears waitN( R$ R% R R R R RS R ( ( ( s0 /usr/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 RA R R ( t objectR ( R R t
callmethod( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt __getattr__ s c C sH | d d k r# t j | | | St j | d } | d | | f S( Ni RA R R ( R! R R ( R R R R" ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s c C sB | d d k r t j | | St j | d } | d | f S( Ni RA R R ( R! R R ( R R R" ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s ( s __getattribute__s __setattr__s __delattr__( R$ R% R R# R R ( ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s t
ValueProxyc B s/ e Z d Z d Z d Z e e e Z RS( Rx R c C s
| j d S( NRx ( R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRx
s c C s | j d | f S( NR ( R ( R R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR s ( s gets set( R$ R% R Rx R R R ( ( ( s0 /usr/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( NR3 ( R ( R R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt __iadd__ s c C s | j d | f | S( NR8 ( R ( R R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR8 s ( R$ R% R: R8 ( ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR9 s t DictProxyR R Rx t has_keyt popitemt
setdefaultR t
ArrayProxyt PoolProxyt applyt apply_asyncRi t imapt imap_unorderedR t mapt map_asyncR t AsyncResultt Iteratorc 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& ( ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR ? s t Queuet
JoinableQueuet Eventt LockRW t Semaphoret BoundedSemaphoret ConditionR R t dictR R R (U t __all__t osR{ t weakrefRV R RI 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> Rw R9 t
view_typesR! R R1 R* Rn R2 R@ RB RC R R[ R\ t XmlListenert XmlClientRQ R R R R R R RS Rd R R R
R R R R R R R$ R% R9 R; R? R@ R R RK RL RW RM RN RO R RP R ( ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt $ s ."
4
,