← Back
Editing: managers.pyc
� { fc @ 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 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( ( 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 ( R R R ( 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 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 ( ( s0 /usr/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 ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt __str__x s ( R$ R% R8 ( ( ( s0 /usr/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( ( 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 _( RB ( 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 � 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( ( s0 /usr/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( ( s0 /usr/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( ( s0 /usr/lib64/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 r�d 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 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 ( ( 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( R3 ( R R� R� R> ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt fallback_str. s c C s t | � S( N( t repr( R R� R� R> ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt fallback_repr1 s R8 R# s #GETVALUEc C s d S( N( ( R R+ ( ( s0 /usr/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� ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRJ = s 'c C s t | j � d S( s* Number of shared objects i ( t lenRX ( R R+ ( ( s0 /usr/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 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� ( ( s0 /usr/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 | <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� ( ( s0 /usr/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� ( ( s0 /usr/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@ ( ( s0 /usr/lib64/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� ( ( s0 /usr/lib64/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� ( ( s0 /usr/lib64/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 ( ( ( s0 /usr/lib64/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( ( ( s0 /usr/lib64/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^ ( ( s0 /usr/lib64/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 ( ( s0 /usr/lib64/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 ( ( s0 /usr/lib64/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� ( ( s0 /usr/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( ( s0 /usr/lib64/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� ( ( s0 /usr/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( ( s0 /usr/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� ( ( 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 RT RJ N( R� R� R� R1 RW Rm ( 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 RT RK N( R� R� R� R1 RW Rm ( 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( RF ( 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 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� ( ( 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 <lambda>| 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 ( s0 /usr/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 s0 /usr/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� ( ( ( 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� � R� ( R t register_after_fork( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR � s c C s t | � d f S( N( ( R2 ( 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 <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( ( s0 /usr/lib64/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� ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt _connect� s c C sD 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 r1| \ } } | j j | j d } | j j | _ | | | 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� R� R1 RW 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( 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! ( ( 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 %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 ( ( 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( RW R� R� Rs R R ( R Rx ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR� 7 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. ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR� ? s c C s | j � S( N( R� ( R t memo( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt __deepcopy__L 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 ( ( s0 /usr/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# i����s ; '__str__()' failed>N( R� Rs R� ( R ( ( s0 /usr/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 ( ( ( 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. Rb i RM t _inheritingN( R; R RW R RX R t popRh R� ( RA R� R^ R. R� RM ( ( 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( 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( ( s0 /usr/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� ( ( 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( NRC s %s=%rs Namespace(%s)s , ( R� R t startswithR= R� R3 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.pyR| � 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)( R2 R$ R R ( R ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR# � s ( R$ R% Rh R R| 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 throwRm 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( NRm ( R� ( R R- ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyRm � s ( R R R( R Rm ( R$ R% R� R R R R( R Rm ( ( ( 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 ( R� R� ( R$ R% R� Rh 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 ( R� R� R R R N( R$ R% R� RW 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 ( R! R� R� R N( R$ R% R� R! R� R� RW 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 RC 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 RC 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 RC R� R% ( R& R% R# ( R R� R' ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR% s ( R# R$ R% ( 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( 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 | f � S( NR� ( R� ( R R� ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyR� s ( R| R� ( R$ R% R� R| 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( NR8 ( R� ( R R� ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt __iadd__ s c C s | j d | f � | S( NR= ( 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 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& ( ( ( s0 /usr/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� ( ( ( s0 /usr/lib64/python2.7/multiprocessing/managers.pyt <module>$ s� ." 4 � , � �
Save File
Cancel