관리-도구
편집 파일: managers.cpython-36.opt-2.pyc
3 \� � @ s� d dddgZ ddlZddlZddlZddlZddlZddlmZ ddlm Z dd l m Z m Z dd lm Z dd lmZ dd lmZ dd lmZ dd� Ze jeje� dd� d�D �Zed ek r�dd� ZxeD ]Ze jee� q�W G dd� de�Zf i fdd�Zdd� ZG d d � d e�Z d d � Z d d!� Z G d"d#� d#e�Z G d$d%� d%e�Z e j!e j"fe j#e j$fd&�Z%G d'd � d e�Z&G d(d)� d)e'�Z(G d*d� de�Z)d+d,� Z*i fd-d.�Z+d�d0d1�Z,G d2d3� d3e�Z-G d4d5� d5e�Z.d�d6d7�Z/G d8d9� d9e)�Z0G d:d;� d;e)�Z1G d<d=� d=e1�Z2G d>d?� d?e)�Z3G d@dA� dAe)�Z4G dBdC� dCe)�Z5G dDdE� dEe)�Z6e+dFd��Z7G dZd[� d[e7�Z8e+d\d��Z9d]deie9_:e+dfd��Z;e+dgd��Z<dsdsdsdededt�e<_:G dudg� dge<�Z=G dvd� de&�Z>e>jdwej?� e>jdxej?� e>jdyej@e3� e>jdzejAe1� e>jd{ejBe1� e>jd|ejCe1� e>jd}ejDe1� e>jd~ejEe2� e>jdejFe4� e>jd�e jGe=� e>jd�ee8� e>jd�eHe9� e>jd5e.e6� e>jd7e/e;� e>jd3e-e5� e>jdee0d�d�� e>jdsd�d�� dS )�� BaseManager� SyncManager� BaseProxy�Token� N)� format_exc� )� connection)� reduction�get_spawning_popen)�pool)�process)�util)� get_contextc C s t j | j| j� ffS )N)�array�typecode�tobytes)�a� r �0/usr/lib64/python3.6/multiprocessing/managers.py� reduce_array$ s r c C s g | ]}t ti |�� ��qS r )�type�getattr)�.0�namer r r � <listcomp>( s r �items�keys�valuesc C s t t | �ffS )N)�list)�objr r r �rebuild_as_list* s r c @ s0 e Zd Zd Zdd� Zdd� Zdd � Zd d � Zd S )r �typeid�address�idc C s ||| | _ | _| _d S )N)r! r" r# )�selfr! r" r# r r r �__init__9 s zToken.__init__c C s | j | j| jfS )N)r! r" r# )r$ r r r � __getstate__< s zToken.__getstate__c C s |\| _ | _| _d S )N)r! r" r# )r$ �stater r r � __setstate__? s zToken.__setstate__c C s d| j j| j| j| jf S )Nz %s(typeid=%r, address=%r, id=%r))� __class__�__name__r! r" r# )r$ r r r �__repr__B s zToken.__repr__N)r! r" r# )r* � __module__� __qualname__� __slots__r% r& r( r+ r r r r r 3 s c C s8 | j ||||f� | j� \}}|dkr*|S t||��d S )Nz#RETURN)�send�recv�convert_to_error)�cr# � methodname�args�kwds�kind�resultr r r �dispatchJ s r8 c C s< | dkr |S | dkr t |�S | dkr0t d| �S td�S d S )Nz#ERRORz #TRACEBACKz#UNSERIALIZABLEzUnserializable message: %s zUnrecognized message type)� RemoteError� ValueError)r6 r7 r r r r1 T s r1 c @ s e Zd Zdd� ZdS )r9 c C s& ddd d t | jd � dd S )N� �-�K r )�strr4 )r$ r r r �__str__a s zRemoteError.__str__N)r* r, r- r? r r r r r9 ` s r9 c C s6 g }x,t | �D ] }t| |�}t|�r|j|� qW |S )N)�dirr �callable�append)r �tempr �funcr r r � all_methodsh s rE c C s dd� t | �D �S )Nc S s g | ]}|d dkr|�qS )r �_r )r r r r r r w s z"public_methods.<locals>.<listcomp>)rE )r r r r �public_methodss s rG c @ s� e Zd Zddddddddd g Zd d � Zd d � Zdd� Zdd� Zdd� Zdd� Z dd� Z dd� Z e e e d�Z dd � Z d d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Zd-S ).�Server�shutdown�create�accept_connection� get_methods� debug_info�number_of_objects�dummy�incref�decrefc C s^ || _ tj|�| _t| \}}||dd�| _| jj| _dd f fi| _i | _i | _ t j � | _ d S )N� )r" Zbacklog�0) �registryr �AuthenticationString�authkey�listener_client�listenerr" � id_to_obj�id_to_refcount�id_to_local_proxy_obj� threading�Lock�mutex)r$ rT r" rV � serializer�Listener�Clientr r r r% � s zServer.__init__c C s� t j� | _| tj� _zZt j| jd�}d|_|j � y x| jj � sN| jj d� q6W W n t t fk rj Y nX W d tjtjkr�tjd� tjt_tjt_tjd� X d S )N)�targetTr zresetting stdout, stderrr )r\ �Event� stop_eventr �current_process�_manager_server�Thread�accepter�daemon�start�is_set�wait�KeyboardInterrupt� SystemExit�sys�stdout� __stdout__r �debug� __stderr__�stderr�exit)r$ rh r r r � serve_forever� s zServer.serve_foreverc C sP xJy| j j� }W n tk r& wY nX tj| j|fd�}d|_|j� qW d S )N)rb r4 T)rX Zaccept�OSErrorr\ rg �handle_requestri rj )r$ r2 �tr r r rh � s zServer.accepterc ' C s4 d } }}y>t j|| j� t j|| j� |j� }|\}}}}t| |�}W n tk rh dt� f} Y n>X y||f|�|�}W n tk r� dt� f} Y n X d|f} y|j| � W nr tk �r& } zTy|jdt� f� W n tk r� Y nX t j d| � t j d|� t j d| � W Y d d } ~ X nX |j � d S )Nz #TRACEBACKz#RETURNzFailure to send message: %rz ... request was %rz ... exception was %r) r Zdeliver_challengerV Zanswer_challenger0 r � Exceptionr r/ r �info�close) r$ r2 �funcnamer7 �request�ignorer4 r5 rD �msg�er r r rx � s2 zServer.handle_requestc D C s� t jdtj� j� |j}|j}| j}�x�| jj � �s�yBd }}|� }|\}}} } y|| \}} } W n^ t k r� } zBy| j | \}} } W n& t k r� } z | �W Y d d }~X nX W Y d d } ~ X nX || kr�t d|t |�| f ��t||�}y|| | �}W n, tk �r& } zd|f}W Y d d }~X nPX | �o8| j|d �}|�rn| j|||�\}}t|| j|�}d||ff}nd|f}W n� t k �r� |d k�r�dt� f}nNy,| j| }|| |||f| �| �}d|f}W n tk �r� dt� f}Y nX Y nP tk �r" t jdtj� j� tjd� Y n tk �r@ dt� f}Y nX yDy ||� W n2 tk �r� } z|d t� f� W Y d d }~X nX W q( tk �r� } zBt jd tj� j� t jd |� t jd |� |j� tjd � W Y d d }~X q(X q(W d S )Nz$starting server thread to service %rz+method %r of %r object is not in exposed=%rz#ERRORz#PROXYz#RETURNz #TRACEBACKz$got EOF -- exiting thread serving %rr z#UNSERIALIZABLEz exception in thread serving %rz ... message was %rz ... exception was %rr )r rr r\ �current_threadr r0 r/ rY rd rk �KeyErrorr[ �AttributeErrorr r rz �getrJ r r" r �fallback_mapping�EOFErrorro ru r{ r| )r$ �connr0 r/ rY r3 r r~ �identr4 r5 �exposed� gettypeid�keZ second_keZfunction�resr� r� r! ZridentZrexposed�tokenZ fallback_funcr7 r r r � serve_client� sx ( $ zServer.serve_clientc C s |S )Nr )r$ r� r� r r r r �fallback_getvalue& s zServer.fallback_getvaluec C s t |�S )N)r> )r$ r� r� r r r r � fallback_str) s zServer.fallback_strc C s t |�S )N)�repr)r$ r� r� r r r r � fallback_repr, s zServer.fallback_repr)r? r+ z #GETVALUEc C s d S )Nr )r$ r2 r r r rO 5 s z Server.dummyc C s| | j �l g }t| jj� �}|j� xD|D ]<}|dkr(|jd|| j| t| j| d �d d� f � q(W dj|�S Q R X d S )NrS z %s: refcount=%s %sr r= r; ) r^ r rZ r �sortrB r> rY �join)r$ r2 r7 r r� r r r rM 8 s $zServer.debug_infoc C s t | j�S )N)�lenrZ )r$ r2 r r r rN G s zServer.number_of_objectsc C sL z:yt jd� |jd� W n dd l}|j� Y nX W d | jj� X d S )Nz!manager received shutdown message�#RETURNr )r� N)r rr r/ � traceback� print_excrd �set)r$ r2 r� r r r rI N s zServer.shutdownc O s� | j �� | j| \}}}}|d kr,|d } n |||�} |d krFt| �}|d k r^t|�t|� }dt| � } tjd|| � | t|�|f| j| < | | j kr�d| j | < W d Q R X | j || � | t |�fS )Nr z%xz&%r callable returned object with id %r) r^ rT rG r r# r rr r� rY rZ rP �tuple) r$ r2 r! r4 r5 rA r� �method_to_typeid� proxytyper r� r r r rJ [ s z Server.createc C s t | j|j d �S )Nr )r� rY r# )r$ r2 r� r r r rL z s zServer.get_methodsc C s" |t j� _|jd� | j|� d S )N�#RETURN)r� N)r\ r� r r/ r� )r$ r2 r r r r rK � s zServer.accept_connectionc C s� | j �� y| j| d7 < W nh tk r� } zL|| jkrrd| j|< | j| | j|< | j| \}}}tjd|� n|�W Y d d }~X nX W d Q R X d S )Nr z&Server re-enabled tracking & INCREF %r)r^ rZ r� r[ rY r rr )r$ r2 r� r� r r� r� r r r rP � s z Server.increfc C s� || j kr$|| jkr$tjd|� d S | j�. | j | d8 < | j | dkrT| j |= W d Q R X || j kr�d f d f| j|< tjd|� | j� | j|= W d Q R X d S )NzServer DECREF skipping %rr r zdisposing of obj with id %r)rZ r[ r rr r^ rY )r$ r2 r� r r r rQ � s z Server.decrefN)r* r, r- Zpublicr% rv rh rx r� r� r� r� r� rO rM rN rI rJ rL rK rP rQ r r r r rH } s, "Q rH c @ s e Zd ZdgZdZdZdZdS )�State�valuer r � N)r* r, r- r. �INITIAL�STARTED�SHUTDOWNr r r r r� � s r� )�pickleZ xmlrpclibc @ s� e Zd Zi ZeZd dd�Zdd� Zdd� Zdf fd d �Z e df fd d ��Z d d� Z d!dd�Z dd� Zdd� Zdd� Zdd� Zedd� �Zedd � �Ze d"d d ��ZdS )#r Nr� c C s\ |d krt j� j}|| _t j|�| _t� | _tj| j_ || _ t | \| _ | _ |pTt� | _d S )N)r re rV �_addressrU �_authkeyr� �_stater� r� � _serializerrW Z _Listener�_Clientr �_ctx)r$ r" rV r_ Zctxr r r r% � s zBaseManager.__init__c C s t | j| j| j| j�S )N)rH � _registryr� r� r� )r$ r r r � get_server� s zBaseManager.get_serverc C s8 t | j \}}|| j| jd�}t|d d� tj| j_d S )N)rV rO ) rW r� r� r� r8 r� r� r� r� )r$ r` ra r� r r r �connect� s zBaseManager.connectc C s� |d k rt |� rtd��tjdd�\}}| jjt| �j| j| j | j | j |||fd�| _ dj dd� | j jD ��}t| �jd | | j _| j j� |j� |j� | _ |j� tj| j_tj| t| �j| j | j | j | j| jfd d �| _ d S ) Nz initializer must be a callableF)Zduplex)rb r4 �:c s s | ]}t |�V qd S )N)r> )r �ir r r � <genexpr>� s z$BaseManager.start.<locals>.<genexpr>r< r )r4 � exitpriority) rA � TypeErrorr ZPiper� ZProcessr � _run_serverr� r� r� r� �_processr� Z _identityr* r rj r| r0 r� r� r� r� r �Finalize�_finalize_managerr� rI )r$ � initializer�initargs�reader�writerr� r r r rj � s& zBaseManager.startc C sN |d k r||� | j ||||�}|j|j� |j� tjd|j� |j� d S )Nzmanager serving at %r)�_Serverr/ r" r| r r{ rv ) �clsrT r" rV r_ r� r� r� �serverr r r r� s zBaseManager._run_serverc O sN | j | j| jd�}z t|d d|f| |�\}}W d |j� X t|| j|�|fS )N)rV rJ )r� r� r� r8 r| r )r$ r! r4 r5 r� r# r� r r r �_create% s zBaseManager._createc C s* | j d k r&| j j|� | j j� s&d | _ d S )N)r� r� �is_alive)r$ �timeoutr r r r� 1 s zBaseManager.joinc C s. | j | j| jd�}z t|d d�S |j� X d S )N)rV rM )r� r� r� r8 r| )r$ r� r r r � _debug_info: s zBaseManager._debug_infoc C s. | j | j| jd�}z t|d d�S |j� X d S )N)rV rN )r� r� r� r8 r| )r$ r� r r r �_number_of_objectsD s z BaseManager._number_of_objectsc C s | j jtjkr| j� | S )N)r� r� r� r� rj )r$ r r r � __enter__N s zBaseManager.__enter__c C s | j � d S )N)rI )r$ �exc_type�exc_val�exc_tbr r r �__exit__T s zBaseManager.__exit__c C s� | j � r�tjd� y,|||d�}zt|d d� W d |j� X W n tk rR Y nX | jdd� | j � r�tjd� t| d�r�tjd� | j� | jd d� | j � r�tjd � t j |_ y t j |= W n tk r� Y nX d S ) Nz#sending shutdown message to manager)rV rI g �?)r� zmanager still alive� terminatez'trying to `terminate()` manager processg�������?z#manager still alive after terminate)r� r r{ r8 r| rz r� �hasattrr� r� r� r� r �_address_to_localr� )r r" rV r' r� r� r r r r� W s. z BaseManager._finalize_managerc C s | j S )N)r� )r$ r r r �<lambda>w s zBaseManager.<lambda>Tc s� d| j kr| jj� | _� d kr"t� |p0t� dd �}|p@t� dd �}|r`xt|j� �D ]\}}qTW |||� f| j�< |r�� �fdd�} �| _t| �| � d S )Nr� � _exposed_�_method_to_typeid_c s` t jd�� | j�f|�|�\}}� || j| | j|d�}| j|j| jd�}t|d d|jf� |S )Nz)requesting creation of a shared %r object)�managerrV r� )rV rQ ) r rr r� r� r� r� r" r8 r# )r$ r4 r5 r� Zexp�proxyr� )r� r! r r rC � s z"BaseManager.register.<locals>.temp) �__dict__r� �copy� AutoProxyr r r r* �setattr) r� r! rA r� r� r� � create_method�keyr� rC r )r� r! r �registery s zBaseManager.register)NNr� N)N)NNNNT)r* r, r- r� rH r� r% r� r� rj � classmethodr� r� r� r� r� r� r� � staticmethodr� �propertyr" r� r r r r r � s( $ c @ s e Zd Zdd� Zdd� ZdS )�ProcessLocalSetc C s t j| dd� � d S )Nc S s | j � S )N)�clear)r r r r r� � s z*ProcessLocalSet.__init__.<locals>.<lambda>)r �register_after_fork)r$ r r r r% � s zProcessLocalSet.__init__c C s t | �f fS )N)r )r$ r r r � __reduce__� s zProcessLocalSet.__reduce__N)r* r, r- r% r� r r r r r� � s r� c @ s| e Zd Zi Zej� Zddd�Zdd� Zf i fdd �Z d d � Z d d � Z e dd� �Z dd� Zdd� Zdd� Zdd� Zdd� ZdS )r NTFc C s� t j�8 t jj|jd �}|d kr:tj� t� f}|t j|j< W d Q R X |d | _|d | _ || _ | j j | _ || _ || _t| d | _|| _|d k r�tj|�| _n"| j d k r�| j j| _n tj� j| _|r�| j� tj| t j� d S )Nr r )r �_mutexr� r� r" r ZForkAwareLocalr� �_tls�_idset�_tokenr# �_id�_managerr� rW r� �_owned_by_managerr rU r� re rV �_increfr� � _after_fork) r$ r� r_ r� rV r� rP � manager_ownedZ tls_idsetr r r r% � s* zBaseProxy.__init__c C sd t jd� tj� j}tj� jdkr4|dtj� j 7 }| j| jj | j d�}t |d d|f� || j _ d S )Nz making connection to managerZ MainThread�|)rV rK )r rr r re r r\ r� r� r� r" r� r8 r� r )r$ r r� r r r �_connect� s zBaseProxy._connectc C s� y | j j}W n6 tk rB tjdtj� j� | j� | j j}Y nX |j | j |||f� |j � \}}|dkrp|S |dkr�|\}}| j j |j d } | jj|_| || j| j | j|d�} | j|j| jd�}t|d d|jf� | S t||��d S ) Nz#thread %r does not own a connectionz#RETURNz#PROXYr )r� rV r� )rV rQ ���)r� r r� r rr r\ r� r r� r/ r� r0 r� r� r! r� r" r� r� r� r8 r# r1 ) r$ r3 r4 r5 r� r6 r7 r� r� r� r� r r r � _callmethod� s, zBaseProxy._callmethodc C s | j d�S )Nz #GETVALUE)r� )r$ r r r � _getvalue s zBaseProxy._getvaluec C s� | j rtjd| jj� d S | j| jj| jd�}t|d d| j f� tjd| jj� | j j | j � | j oj| j j }tj| tj| j| j|| j| j | jfdd�| _d S )Nz%owned_by_manager skipped INCREF of %r)rV rP z INCREF %r� )r4 r� )r� r rr r� r# r� r" r� r8 r� r� �addr� r� r� r �_decrefr� Z_close)r$ r� r' r r r r� s zBaseProxy._increfc C s� |j | j� |d ks |jtjkr�y2tjd| j� || j|d�}t|d d| jf� W q� t k r� } ztjd|� W Y d d }~X q�X ntjd| j� | r�t |d�r�tjdt j � j � |jj� |`d S )Nz DECREF %r)rV rQ z... decref failed %sz%DECREF %r -- manager already shutdownr z-thread %r has no more proxies so closing conn)�discardr# r� r� r� r rr r" r8 rz r� r\ r� r r r| )r� rV r' ZtlsZidsetr� r� r� r r r r� s zBaseProxy._decrefc C sH d | _ y | j� W n0 tk rB } ztjd| � W Y d d }~X nX d S )Nzincref failed: %s)r� r� rz r r{ )r$ r� r r r r� 9 s zBaseProxy._after_forkc C s^ i }t � d k r| j|d< t| dd�rB| j|d< tt| j| j|ffS tt| �| j| j|ffS d S )NrV �_isautoFr� ) r r� r r� � RebuildProxyr� r� r� r )r$ r5 r r r r� A s zBaseProxy.__reduce__c C s | j � S )N)r� )r$ �memor r r � __deepcopy__N s zBaseProxy.__deepcopy__c C s dt | �j| jjt| �f S )Nz <%s object, typeid %r at %#x>)r r* r� r! r# )r$ r r r r+ Q s zBaseProxy.__repr__c C s4 y | j d�S tk r. t| �d d� d S X d S )Nr+ r z; '__str__()' failed>r� )r� rz r� )r$ r r r r? U s zBaseProxy.__str__)NNNTF)r* r, r- r� r ZForkAwareThreadLockr� r% r� r� r� r� r� r� r� r� r� r+ r? r r r r r � s ( c C s� t tj� dd �}|rT|j|jkrTtjd|� d|d< |j|jkrT|j|j |j|j< |j dd�opt tj� dd� }| ||fd|i|��S )Nrf z*Rebuild a proxy owned by manager, token=%rTr� rP Z _inheritingF) r r re r" r rr r# r[ rY �pop)rD r� r_ r5 r� rP r r r r� b s r� c C sr t |�}y || |f S tk r( Y nX i }x |D ]}td||f |� q4W t| tf|�}||_||| |f< |S )NzLdef %s(self, *args, **kwds): return self._callmethod(%r, args, kwds))r� r� �execr r r� )r r� �_cacheZdic�meth� ProxyTyper r r � MakeProxyTypew s r� Tc C s� t | d }|d krB|| j|d�}zt|d d| f�}W d |j� X |d krX|d k rX|j}|d krjtj� j}td| j |�}|| ||||d�} d| _ | S )Nr )rV rL z AutoProxy[%s])r� rV rP T) rW r" r8 r| r� r re rV r� r! r� ) r� r_ r� rV r� rP r� r� r� r� r r r r� � s r� c @ s e Zd Zdd� Zdd� ZdS )� Namespacec K s | j j|� d S )N)r� �update)r$ r5 r r r r% � s zNamespace.__init__c C s^ t | jj� �}g }x,|D ]$\}}|jd�s|jd||f � qW |j� d| jjdj|�f S )NrF z%s=%rz%s(%s)z, ) r r� r � startswithrB r� r) r* r� )r$ r rC r r� r r r r+ � s zNamespace.__repr__N)r* r, r- r% r+ r r r r r� � s r� c @ s8 e Zd Zd dd�Zdd� Zdd� Zdd � Zeee�Zd S ) �ValueTc C s || _ || _d S )N)� _typecode�_value)r$ r r� �lockr r r r% � s zValue.__init__c C s | j S )N)r )r$ r r r r� � s z Value.getc C s || _ d S )N)r )r$ r� r r r r� � s z Value.setc C s dt | �j| j| jf S )Nz %s(%r, %r))r r* r r )r$ r r r r+ � s zValue.__repr__N)T) r* r, r- r% r� r� r+ r� r� r r r r r� � s r� c C s t j | |�S )N)r )r Zsequencer r r r �Array� s r c @ s8 e Zd ZdZdd� Zdd� Zd d � Zd d � Zd d� ZdS )� IteratorProxy�__next__r/ �throwr| c C s | S )Nr )r$ r r r �__iter__� s zIteratorProxy.__iter__c G s | j d|�S )Nr )r� )r$ r4 r r r r � s zIteratorProxy.__next__c G s | j d|�S )Nr/ )r� )r$ r4 r r r r/ � s zIteratorProxy.sendc G s | j d|�S )Nr )r� )r$ r4 r r r r � s zIteratorProxy.throwc G s | j d|�S )Nr| )r� )r$ r4 r r r r| � s zIteratorProxy.closeN)r r/ r r| ) r* r, r- r� r r r/ r r| r r r r r � s r c @ s2 e Zd Zd Zddd�Zdd� Zd d � Zd d � ZdS )� AcquirerProxy�acquire�releaseTNc C s" |d kr|fn||f}| j d|�S )Nr )r� )r$ Zblockingr� r4 r r r r � s zAcquirerProxy.acquirec C s | j d�S )Nr )r� )r$ r r r r � s zAcquirerProxy.releasec C s | j d�S )Nr )r� )r$ r r r r� � s zAcquirerProxy.__enter__c C s | j d�S )Nr )r� )r$ r� r� r� r r r r� � s zAcquirerProxy.__exit__)r r )TN)r* r, r- r� r r r� r� r r r r r � s r c @ s4 e Zd ZdZddd�Zd d � Zd d � Zdd d�ZdS )�ConditionProxyr r rl �notify� notify_allNc C s | j d|f�S )Nrl )r� )r$ r� r r r rl � s zConditionProxy.waitc C s | j d�S )Nr )r� )r$ r r r r � s zConditionProxy.notifyc C s | j d�S )Nr )r� )r$ r r r r � s zConditionProxy.notify_allc C sh |� }|r|S |d k r$t j� | }nd }d }x6|sb|d k rP|t j� }|dkrPP | j|� |� }q.W |S )Nr )�timeZ monotonicrl )r$ Z predicater� r7 ZendtimeZwaittimer r r �wait_for� s zConditionProxy.wait_for)r r rl r r )N)N)r* r, r- r� rl r r r r r r r r � s r c @ s2 e Zd ZdZdd� Zdd� Zd d � Zdd d �Zd S )� EventProxyrk r� r� rl c C s | j d�S )Nrk )r� )r$ r r r rk s zEventProxy.is_setc C s | j d�S )Nr� )r� )r$ r r r r� s zEventProxy.setc C s | j d�S )Nr� )r� )r$ r r r r� s zEventProxy.clearNc C s | j d|f�S )Nrl )r� )r$ r� r r r rl s zEventProxy.wait)rk r� r� rl )N)r* r, r- r� rk r� r� rl r r r r r � s r c @ sN e Zd ZdZddd�Zdd � Zd d � Zed d � �Zedd� �Z edd� �Z dS )� BarrierProxy�__getattribute__rl �abort�resetNc C s | j d|f�S )Nrl )r� )r$ r� r r r rl s zBarrierProxy.waitc C s | j d�S )Nr )r� )r$ r r r r s zBarrierProxy.abortc C s | j d�S )Nr )r� )r$ r r r r s zBarrierProxy.resetc C s | j dd�S )Nr �parties)r )r� )r$ r r r r s zBarrierProxy.partiesc C s | j dd�S )Nr � n_waiting)r )r� )r$ r r r r s zBarrierProxy.n_waitingc C s | j dd�S )Nr �broken)r )r� )r$ r r r r s zBarrierProxy.broken)r rl r r )N) r* r, r- r� rl r r r� r r r r r r r r s r c @ s( e Zd Zd Zdd� Zdd� Zdd � Zd S ) �NamespaceProxyr � __setattr__� __delattr__c C s0 |d dkrt j| |�S t j| d�}|d|f�S )Nr rF r� r )�objectr )r$ r� � callmethodr r r � __getattr__ s zNamespaceProxy.__getattr__c C s4 |d dkrt j| ||�S t j| d�}|d||f�S )Nr rF r� r )r r r )r$ r� r� r r r r r % s zNamespaceProxy.__setattr__c C s0 |d dkrt j| |�S t j| d�}|d|f�S )Nr rF r� r )r r r )r$ r� r r r r r * s zNamespaceProxy.__delattr__N)r r r )r* r, r- r� r r r r r r r r s r c @ s* e Zd ZdZdd� Zdd� Zeee�ZdS ) � ValueProxyr� r� c C s | j d�S )Nr� )r� )r$ r r r r� 3 s zValueProxy.getc C s | j d|f�S )Nr� )r� )r$ r� r r r r� 5 s zValueProxy.setN)r� r� )r* r, r- r� r� r� r� r� r r r r r 1 s r � BaseListProxy�__add__� __contains__� __delitem__� __getitem__�__len__�__mul__� __reversed__�__rmul__� __setitem__rB �count�extend�index�insertr� �remove�reverser� �__imul__c @ s e Zd Zdd� Zdd� ZdS )� ListProxyc C s | j d|f� | S )Nr* )r� )r$ r� r r r �__iadd__A s zListProxy.__iadd__c C s | j d|f� | S )Nr/ )r� )r$ r� r r r r/ D s zListProxy.__imul__N)r* r, r- r1 r/ r r r r r0 @ s r0 � DictProxyr r� r� r� �has_key�popitem� setdefaultr� �Iterator� ArrayProxy� PoolProxy�apply� apply_asyncr| �imap�imap_unorderedr� �map� map_async�starmap� starmap_asyncr� Z AsyncResult)r: r> r@ r; r< c @ s e Zd Zdd� Zdd� ZdS )r8 c C s | S )Nr )r$ r r r r� d s zPoolProxy.__enter__c C s | j � d S )N)r� )r$ r� r� r� r r r r� f s zPoolProxy.__exit__N)r* r, r- r� r� r r r r r8 c s c @ s e Zd ZdS )r N)r* r, r- r r r r r m s �QueueZ JoinableQueuerc r] �RLock� Semaphore�BoundedSemaphore� Condition�Barrier�Poolr �dictF)r� r� )r� )r r r )NNNT)T)r r! r" r# r$ r% r& r' r( rB r) r* r+ r, r� r- r. r� r/ )r! r" r# r r$ r( r� r� r� r3 r r r� r4 r5 r� r )r$ r# r( ) r9 r: r| r; r< r� r= r> r? r@ r� )I�__all__ro r\ r Zqueuer r� r � r �contextr r r r r r r r� Z view_typesr r Z view_typer r r8 r1 rz r9 rE rG rH r� r` ra Z XmlListenerZ XmlClientrW r r� r� r r� r� r� r� r� r r r r r r r r r r0 r2 r� r7 Z BasePoolProxyr8 r rA rc r] rB rC rD rE rF rG rH r r r r �<module> s� ; ] 4