
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
 rd d l m Z n Xd   Z e j e j e  g  d d d f D] Z  e! e" i  e      ^ qDZ# 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.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyt   __init__P   s    c         C   s   |  j  |  j |  j f S(   N(   R   R   R   (   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyt   __getstate__S   s    c         C   s   | \ |  _  |  _ |  _ d  S(   N(   R   R   R   (   R   t   state(    (    s.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyt   __repr__Y   s    (   R   R   R   (   t   __name__t
   __module__t   __doc__t	   __slots__R   R    R"   R#   (    (    (    s.   /usr/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.   /usr/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.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyt   __str__x   s    (   R$   R%   R8   (    (    (    s.   /usr/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.   /usr/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.   /usr/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.   /usr/lib/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.   /usr/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.   /usr/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 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   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyt   serve_client   sl    				
			
c         C   s   | S(   N(    (   R   R   R   R>   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyt   fallback_getvalue+  s    c         C   s
   t  |  S(   N(   R3   (   R   R   R   R>   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyt   fallback_str.  s    c         C   s
   t  |  S(   N(   t   repr(   R   R   R   R>   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyt   fallback_repr1  s    R8   R#   s	   #GETVALUEc         C   s   d  S(   N(    (   R   R+   (    (    s.   /usr/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.   /usr/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.   /usr/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 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.   /usr/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.   /usr/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.   /usr/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.   /usr/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.   /usr/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.   /usr/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.   /usr/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.   /usr/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.   /usr/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.   /usr/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.   /usr/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.   /usr/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  |  Vq d  S(   N(   R3   (   t   .0t   i(    (    s.   /usr/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.   /usr/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.   /usr/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.   /usr/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.   /usr/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.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyt   _number_of_objectsL  s    c         C   s   |  S(   N(    (   R   (    (    s.   /usr/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.   /usr/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
 rn 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.   /usr/lib/python2.7/multiprocessing/managers.pyR   \  s.    
c         C   s   |  j  S(   N(   R   (   R   (    (    s.   /usr/lib/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   (    s.   /usr/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.   /usr/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.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyR     R   (   R	   t   register_after_fork(   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR     s    c         C   s   t  |   d f S(   N(    (   R2   (   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR     s    (   R$   R%   R   R   (    (    (    s.   /usr/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.   /usr/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.   /usr/lib/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   #PROXYiR   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   (    (    s.   /usr/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.   /usr/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.   /usr/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.   /usr/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.   /usr/lib/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.   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR   ?  s    c         C   s
   |  j    S(   N(   R   (   R   t   memo(    (    s.   /usr/lib/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   (    (    s.   /usr/lib/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.   /usr/lib/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.   /usr/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.   /usr/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(   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.   /usr/lib/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.   /usr/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.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyR#     s    
(   R$   R%   R   R#   (    (    (    s.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyR     s    	c         C   s   |  j  S(   N(   R  (   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR|     s    c         C   s   | |  _  d  S(   N(   R  (   R   R   (    (    s.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyR#     s    (	   R$   R%   Rh   R   R|   R   R#   R   R   (    (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR    s
   			c         C   s   t  j  |  |  S(   N(   R   (   R   t   sequenceR  (    (    s.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyt   __iter__  s    c         G   s   |  j  d |  S(   NR  (   R   (   R   R-   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR    s    c         G   s   |  j  d |  S(   NR  (   R   (   R   R-   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR    s    c         G   s   |  j  d |  S(   NR(   (   R   (   R   R-   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR(     s    c         G   s   |  j  d |  S(   NR  (   R   (   R   R-   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR    s    c         G   s   |  j  d |  S(   NRm   (   R   (   R   R-   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyRm     s    (   R  R  R(   R  Rm   (	   R$   R%   R   R  R  R  R(   R  Rm   (    (    (    s.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyR     s    c         C   s   |  j  d  S(   NR   (   R   (   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR     s    c         C   s   |  j  d  S(   NR   (   R   (   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR     s    c         C   s   |  j  d  S(   NR   (   R   (   R   R   R   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR     s    (   R   R   (   R$   R%   R   Rh   R   R   R   R   (    (    (    s.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyR    s    c         C   s   |  j  d  S(   NR  (   R   (   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR    s    c         C   s   |  j  d  S(   NR  (   R   (   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR    s    (   R   R   R  R  R  N(   R$   R%   R   RW   R  R  R  (    (    (    s.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyR!    s    c         C   s   |  j  d  S(   NR   (   R   (   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR     s    c         C   s   |  j  d  S(   NR   (   R   (   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR     s    c         C   s   |  j  d | f  S(   NR  (   R   (   R   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR    s    (   R!  R   R   R  N(   R$   R%   R   R!  R   R   RW   R  (    (    (    s.   /usr/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.   /usr/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.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyR%    s    (   R#  R$  R%  (   R$   R%   R   R(  R$  R%  (    (    (    s.   /usr/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.   /usr/lib/python2.7/multiprocessing/managers.pyR|     s    c         C   s   |  j  d | f  S(   NR   (   R   (   R   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR     s    (   R|   R   (   R$   R%   R   R|   R   R   R   (    (    (    s.   /usr/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(   NR8  (   R   (   R   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyt   __iadd__  s    c         C   s   |  j  d | f  |  S(   NR=  (   R   (   R   R   (    (    s.   /usr/lib/python2.7/multiprocessing/managers.pyR=     s    (   R$   R%   R?  R=  (    (    (    s.   /usr/lib/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.   /usr/lib/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.   /usr/lib/python2.7/multiprocessing/managers.pyt   <module>$   s   ."	4
			
 ,

	
		