ó
|
]\¬Qc @ 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 TokeniÿÿÿÿN( 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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt __init__P s c C s | j | j | j f S( N( R R R ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt __getstate__S s c C s | \ | _ | _ | _ d S( N( R R R ( R t state( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt __repr__Y s ( s typeids addresss id( t __name__t
|
__module__t __doc__t __slots__R R R" R# ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt __str__x s ( R$ R% R8 ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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_serverRV t acceptt OSErrort IOErrorRZ t Threadt handle_requestt Truet daemont startt KeyboardInterruptt
|
SystemExitR] t close( R R+ t t( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRg ¿ s4 c C së t j d t j j | j } | j } | j } x°| j sæy 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
|
råd 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 debugRZ t current_threadR@ R) R( RX R] RW t AttributeErrorR2 R; Rs t getRG R R R t fallback_mappingt EOFErrort sysR t reprR 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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt serve_clientá sl
|
|
c C s | S( N( ( R R R R> ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt fallback_getvalue+ s c C s
|
t | S( N( R3 ( R R R R> ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt fallback_str. s c C s
|
t | S( N( R ( R R R R> ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt fallback_repr1 s R8 R# s #GETVALUEc C s d S( N( ( R R+ ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRJ = s
|
'c C s t | j d S( s*
|
Number of shared objects
|
i ( t lenRX ( R R+ ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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 0iÿÿÿÿN( 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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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 |
|
<n | j | |
|
|
|
t | f SWd | j j Xd S( s>
|
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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRH ¡ s c C s9 | j j z | j | c d 7<Wd | j j Xd S( Ni ( R\ R RY R ( R R+ R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRM © s c C s | j j zj | j | d k s) t | j | c d 8<| j | d k rv | j | =| j | =t j d | n Wd | j j Xd S( Ni i s disposing of obj with id %r( R\ R RY R4 RX R Ry R ( R R+ R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRN ° s ( R$ R% R& Rr R Ro Rg R R R R R} RL RJ RK RF RG RI RH RM RN ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRE s. " J
|
& t Statec B s# e Z d g Z d Z d Z d Z RS( t valuei i i ( R$ R% R' t INITIALt STARTEDt SHUTDOWN( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR¤ ¿ s t picklet xmlrpclibc B sà e Z d Z i Z e Z d d d d Z d Z d Z d Z
|
d d d Z e d d d Z d Z d d Z d
|
Z d Z d Z d Z e d Z e d Z e d d d d e d Z RS( s!
|
Base class for managers
|
R© c C sq | d k r t j } n | | _ t | | _ t | _ t j | j _ | | _
|
t | \ | _ | _ d S( N( RW R RT t _addressR t _authkeyR¤ t _stateR¦ R¥ t _serializerRU t _Listenert _Client( R R RT R^ ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR Ù s c C s% t | j | j | j | j f f S( N( R2 t from_addressR« R¬ R® ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt
|
__reduce__ã s c C s: | j j t j k s t t | j | j | j | j S( sX
|
Return server object with serve_forever() method and address attribute
|
(
|
R R¥ R¤ R¦ R4 RE t _registryR« R¬ R® ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt
|
get_serverç s c C sN t | j \ } } | | j d | j } t | d d t j | j _ d S( s>
|
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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pys <genexpr>
|
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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt _number_of_objectsL s c C s | S( N( ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRÁ \ s.
|
c C s | j S( N( R« ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt <lambda>| s 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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRÖ ¬ s ( R t register_after_fork( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR « s c C s t | d f S( N( ( R2 ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR² s ( R$ R% R R² ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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 <n Wd t j j
|
X| d | _ | d | _ | | _ | j j | _ | | _ | | _ t | d | _ | d k rá t | | _ n0 | j d k r| j j | _ n t j | _ | r$| j n t j | t j d S( Ni i ( R t _mutexR RÓ R| R RW R t ForkAwareLocalRæ R t _tlst _idsett _tokenR t _idt _managerR® RU R° R R¬ R RT t _increfRè t _after_fork( R R R^ RÙ RT R RM t tls_idset( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR » s, c C s t j d t j } t j j d k rH | d t j j 7} n | j | j j d | j } t
|
| d d | f | | j _ d S( Ns making connection to managert
|
MainThreadt |RT RH ( R Ry R R@ RZ Rz R° Rí R R¬ R1 RW Rë R
|
( R R@ R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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 #PROXYiÿÿÿÿRÙ RT R RN N( Rë R
|
R{ R Ry RZ Rz R@ Rõ R( Rî R) Rï R³ R R® R¬ R° R R1 RW R R* ( R R, R- R. R R/ R0 R R R£ RÛ ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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 ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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( NRT RM s INCREF %rR- Rº i
|
( R° Rí R R¬ R1 RW Rî R Ry R Rì t addRï R R R t _decrefRë t _close( R R R! ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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 %rRT RN s ... decref failed %ss% DECREF %r -- manager already shutdownR
|
s- thread %r has no more proxies so closing conn( t discardR RW R¥ R¤ R§ R Ry R R1 Rs R< RZ Rz R@ R
|
Rm ( R RT R! t tlst idsetR° R Rx ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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( RW Rï Rð Rs R R ( R Rx ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRñ 6 s
|
c C s i } t j r" | j | d <n t | d t r] | j | d <t t | j | j | f f St t
|
| | j | j | f f Sd S( NRT t _isautoR ( R t thread_is_spawningR¬ R; R½ R× t RebuildProxyRÞ Rí R® R2 ( R R. ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR² > s c C s
|
| j S( N( R÷ ( R t memo( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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( R2 R$ Rí R R ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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# iÿÿÿÿs ; '__str__()' failed>N( Rö Rs R ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR8 R s N( ( R$ R% R& RÓ R t ForkAwareThreadLockRé RW Rh R Rõ Rö R÷ Rð Rä Rù Rñ R² R R# R8 ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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Ô R2 R R× ( R@ R t _cachet dict metht ProxyType( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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 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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR# ª s
|
( R$ R% R R# ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR ´ s c C s | j S( N( R ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR| · s c C s | | _ d S( N( R ( R R¥ ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR# » s ( R$ R% Rh R R| R R# Rå R¥ ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR ³ s
|
c C s t j | | S( N( R ( R t sequenceR ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt __iter__É s c G s | j d | S( NR ( Rö ( R R- ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR Ë s c G s | j d | S( NR ( Rö ( R R- ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR Í s c G s | j d | S( NR( ( Rö ( R R- ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR( Ï s c G s | j d | S( NR ( Rö ( R R- ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR Ñ s c G s | j d | S( NRm ( Rö ( R R- ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRm Ó s ( s __next__s nexts sends throws close( R$ R% R× R R R R( R Rm ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR Ù s c C s | j d S( NR ( Rö ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR Û s c C s | j d S( NR ( Rö ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRÍ Ý s c C s | j d S( NR ( Rö ( R RÎ RÏ RÐ ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRÑ ß s ( s acquires release( R$ R% R× Rh R R RÍ RÑ ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR æ s c C s | j d S( NR ( Rö ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR è s c C s | j d S( NR ( Rö ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR ê s ( s acquires releases waits notifys
|
notify_allN( R$ R% R× RW R R R ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR ï s c C s | j d S( NR ( Rö ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR ñ s c C s | j d S( NRç ( Rö ( R ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyRç ó s c C s | j d | f S( NR ( Rö ( R RÊ ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR õ s ( s is_sets sets clears waitN( R$ R% R× R R Rç RW R ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR$ s ( s __getattribute__s __setattr__s __delattr__( R$ R% R× R' R# R$ ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR| s c C s | j d | f S( NR ( Rö ( R R¥ ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR s ( s gets set( R$ R% R× R| R Rå R¥ ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/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( NR7 ( Rö ( R R¥ ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt __iadd__ s c C s | j d | f | S( NR< ( Rö ( R R¥ ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR< s ( R$ R% R> R< ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR= s t DictProxyRç RÝ R| t has_keyt popitemt
|
setdefaultR t
|
ArrayProxyt PoolProxyt applyt apply_asyncRm 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& ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyR ? s t Queuet JoinableQueuet Eventt LockR[ t Semaphoret BoundedSemaphoret ConditionR R R R R£ Rà (U t __all__t osR t weakrefRZ R RM 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? RC RD RØ R RO RP R[ RQ RR RS R R R½ ( ( ( s` /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/multiprocessing/managers.pyt <module>$ sª ." 4
|
|
ÿ ,
|
Ø
|
«
|
|
