← Back
Editing: managers.cpython-37.pyc
B � f� � @ s� d dddgZ ddlZddlZddlZddlZddlZddlmZ ddlm Z dd l m Z m Z m Z dd lmZ dd lmZ dd lmZ dd lmZ dd� Ze �eje� dd� dD �Zed ek r�dd� ZxeD ]Ze �ee� q�W G dd� de�Zdi fdd�Zdd� ZG dd � 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,ddd/d0�Z-G d1d2� d2e�Z.G d3d4� d4e�Z/ded5d6�Z0G d7d8� d8e*�Z1G d9d:� d:e*�Z2G d;d<� d<e2�Z3G d=d>� d>e*�Z4G d?d@� d@e*�Z5G dAdB� dBe*�Z6G dCdD� dDe*�Z7e,dEdF�Z8G dGdH� dHe8�Z9e,dIdJ�Z:dKdLie:_;e,dMdN�Z<e,dOdP�Z=dQdQdQdLdLdR�e=_;G dSdO� dOe=�Z>G dTd� de'�Z?e?�dUej@� e?�dVej@� e?�dWejAe4� e?�dXejBe2� e?�dYejCe2� e?�dZejDe2� e?�d[ejEe2� e?�d\ejFe3� e?�d]ejGe5� e?�d^ejHe>� e?�d_ee9� e?�d`eIe:� e?�d4e/e7� e?�d6e0e<� e?�d2e.e6� e?jdLe1dadb� e?jdQdadc� dS )f� BaseManager� SyncManager� BaseProxy�Token� N)� format_exc� )� connection)� reduction�get_spawning_popen� ProcessError)�pool)�process)�util)� get_contextc C s t j | j| �� ffS )N)�array�typecode�tobytes)�a� r �=/opt/alt/python37/lib64/python3.7/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 @ s4 e Zd ZdZdZdd� Zdd� Zdd� Zd d � Zd S ) r z3 Type to uniquely identify a shared object )�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+ � __module__� __qualname__�__doc__� __slots__r& r' r) r, r r r r r 3 s r c C s8 | � ||||f� | �� \}}|dkr*|S t||��dS )zL Send a message to manager using connection `c` and return response z#RETURNN)�send�recv�convert_to_error)�cr$ � methodname�args�kwds�kind�resultr r r �dispatchJ s r: c C sd | dkr |S | dkrRt |t�s4td�|| t|����| dkrHtd| �S t|�S ntd�| ��S d S )Nz#ERROR)z #TRACEBACKz#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strz#UNSERIALIZABLEzUnserializable message: %s z Unrecognized message type {!r})� isinstance�str� TypeError�formatr � RemoteError� ValueError)r8 r9 r r r r3 T s r3 c @ s e Zd Zdd� ZdS )r? c C s dt | jd � d S )NzM --------------------------------------------------------------------------- r zK---------------------------------------------------------------------------)r< r6 )r% r r r �__str__d s zRemoteError.__str__N)r+ r- r. rA r r r r r? c s r? c C s6 g }x,t | �D ] }t| |�}t|�r|�|� qW |S )z4 Return a list of names of methods of `obj` )�dirr �callable�append)r �tempr �funcr r r � all_methodsk s rG c C s dd� t | �D �S )zP Return a list of names of methods of `obj` which do not start with '_' c S s g | ]}|d dkr|�qS )r �_r )r r r r r r z s z"public_methods.<locals>.<listcomp>)rG )r r r r �public_methodsv s rI c @ s� e Zd ZdZdddddddd d g Zd d � Zd d� Zdd� Zdd� Zdd� Z dd� Z dd� Z dd� Z e e e d�Z d d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.S )/�ServerzM Server class which runs in a process controlled by a manager object �shutdown�create�accept_connection� get_methods� debug_info�number_of_objects�dummy�incref�decrefc C sx t |t�s td�|t|����|| _t�|�| _t | \}}||dd�| _ | j j | _ ddi| _ i | _ i | _t�� | _d S )Nz&Authkey {0!r} is type {1!s}, not bytes� )r# Zbacklog�0)Nr )r; �bytesr= r> r �registryr �AuthenticationString�authkey�listener_client�listenerr# � id_to_obj�id_to_refcount�id_to_local_proxy_obj� threading�Lock�mutex)r% rW r# rY � serializer�Listener�Clientr r r r& � s zServer.__init__c C s� t �� | _| t�� _zZt j| jd�}d|_|� � y x| j� � sN| j� d� q6W W n t t fk rj Y nX W dtjtjkr�t�d� tjt_tjt_t�d� X dS )z( Run the server forever )�targetTr Nzresetting 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% rk r r r � serve_forever� s zServer.serve_foreverc C sP xJy| j �� }W n tk r& wY nX tj| j|fd�}d|_|�� qW d S )N)re r6 T)r[ Zaccept�OSErrorr_ rj �handle_requestrl rm )r% r4 �tr r r rk � s zServer.accepterc C sL d } }}yTt �|| j� t �|| j� |�� }|\}}}}|| jksTtd| ��t| |�}W n tk r~ dt � f} Y n>X y||f|�|�}W n tk r� dt � f} Y n X d|f} y|� | � W nt tk �r> } zTy|� dt � f� W n tk �r Y nX t � d| � t � d|� t � d| � W dd} ~ X Y nX |� � dS )z) Handle a new connection Nz%r unrecognizedz #TRACEBACKz#RETURNzFailure to send message: %rz ... request was %rz ... exception was %r)r Zdeliver_challengerY Zanswer_challenger2 �public�AssertionErrorr � Exceptionr r1 r �info�close) r% r4 �funcnamer9 �request�ignorer6 r7 rF �msg�er r r r{ � s4 zServer.handle_requestc C s� t �dt�� j� |j}|j}| j}�x�| j� � �s�yBd }}|� }|\}}} } y|| \}} } W n^ t k r� } z@y| j | \}} } W n& t k r� } z| �W dd}~X Y nX W dd} ~ X Y nX || kr�t d|t |�| f ��t||�}y|| | �}W n, tk �r& } z d|f}W dd}~X Y nPX | �o8| �|d�}|�rn| �|||�\}}t|| j|�}d||ff}nd|f}W n� t k �r� |dk�r�dt� f}nNy,| j| }|| |||f| �| �}d|f}W n tk �r� dt� f}Y nX Y nP tk �r" t �dt�� j� t�d � Y n tk �r@ dt� f}Y nX yDy ||� W n2 tk �r� } z|d t� f� W dd}~X Y nX W q( tk �r� } z@t �d t�� j� t �d |� t �d |� |�� t�d� W dd}~X Y q(X q(W dS )zQ Handle requests from the proxies in a particular process/thread z$starting server thread to service %rNz+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 ru r_ �current_threadr r2 r1 r\ rg rn �KeyErrorr^ �AttributeErrorr r r �getrL r r# r �fallback_mapping�EOFErrorrr rx r� r� )r% �connr2 r1 r\ r5 r r� �identr6 r7 �exposed� gettypeid�keZ second_keZfunctionZresr� r� r" ZridentZrexposed�tokenZ fallback_funcr9 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_repr2 s zServer.fallback_repr)rA r, z #GETVALUEc C s d S )Nr )r% r4 r r r rQ ; s z Server.dummyc C s| | j �l g }t| j�� �}|�� xD|D ]<}|dkr(|�d|| j| t| j| d �dd� f � q(W d�|�S Q R X dS )zO Return some info --- useful to spot problems with refcounting rU z %s: refcount=%s %sr N�K � ) ra r r] r �sortrD r< r\ �join)r% r4 r9 r r� r r r rO > s $zServer.debug_infoc C s t | j�S )z* Number of shared objects )�lenr] )r% r4 r r r rP N s zServer.number_of_objectsc C sL z:yt �d� |�d� W n ddl}|�� Y nX W d| j�� X dS )z' Shutdown this process z!manager received shutdown message)z#RETURNNr N)r ru r1 � traceback� print_excrg �set)r% r4 r� r r r rK U s zServer.shutdownc O s� t | �dkr| ^}}}} nz| s(td��nld|krDtdt | �d ��|�d�}t | �dkrf| ^}}} n.d|kr�tdt | �d ��|�d�}| ^}} t| �} |j�� |j| \}}}}|dkr�|s�t | �dkr�td ��| d } n || |�} |dkr�t| �}|dk �r4t|t ��s$td � |t |����t |�t |� }d t | � } t�d || � | t|�|f|j| < | |jk�rxd |j| < W dQ R X |�|| � | t|�fS )z> Create a new shared object and return its id � z8descriptor 'create' of 'Server' object needs an argumentr" z7create expected at least 2 positional arguments, got %dr � r4 Nz4Without callable, must have one non-keyword argumentr z,Method_to_typeid {0!r}: type {1!s}, not dictz%xz&%r callable returned object with id %r)r� r= �pop�tuplera rW r@ rI r; �dictr> r r r$ r ru r� r\ r] rR ) r6 r7 r% r4 r" rC r� �method_to_typeid� proxytyper r� r r r rL b sN z Server.createc C s t | j|j d �S )zL Return the methods of the shared object indicated by token r )r� r\ r$ )r% r4 r� r r r rN � s zServer.get_methodsc C s" |t �� _|�d� | �|� dS )z= Spawn a new thread to serve this connection )z#RETURNNN)r_ r� r r1 r� )r% r4 r r r r rM � s zServer.accept_connectionc C s� | j �� y| j| d7 < W nh tk r� } zJ|| jkrrd| j|< | j| | j|< | j| \}}}t�d|� n|�W d d }~X Y nX W d Q R X d S )Nr z&Server re-enabled tracking & INCREF %r)ra r] r� r^ r\ r ru )r% r4 r� r� r r� r� r r r rR � s z Server.increfc C s� || j kr$|| jkr$t�d|� d S | j�Z | j | dkrXtd�|| j| | j | ���| j | d8 < | j | dkr�| j |= W d Q R X || j kr�d| j|< t�d|� | j� | j|= W d Q R X d S )NzServer DECREF skipping %rr z+Id {0!s} ({1!r}) has refcount {2:n}, not 1+r )Nr Nzdisposing of obj with id %r)r] r^ r ru ra r~ r> r\ )r% r4 r� r r r rS � s$ z Server.decrefN)r+ r- r. r/ r} r& ry rk r{ r� r� r� r� r� rQ rO rP rK rL rN rM rR rS r r r r rJ � s. "Q 8rJ c @ s e Zd ZdgZdZdZdZdS )�State�valuer r r� N)r+ r- r. r0 �INITIAL�STARTED�SHUTDOWNr r r r r� � s r� )�pickleZ xmlrpclibc @ s� e Zd ZdZi ZeZd"dd�Zdd� Zdd � Z d#d d �Z e d$d d��Z dd� Z d%dd�Zdd� Zdd� Zdd� Zdd� Zedd � �Zed d � �Ze d&d d!��ZdS )'r z! Base class for managers Nr� c C s\ |d krt �� j}|| _t �|�| _t� | _tj| j_ || _ t | \| _ | _ |pTt� | _d S )N)r rh rY �_addressrX �_authkeyr� �_stater� r� � _serializerrZ Z _Listener�_Clientr �_ctx)r% r# rY rb Zctxr r r r& � s zBaseManager.__init__c C sf | j jtjkrP| j jtjkr&td��n*| j jtjkr>td��ntd�| j j���t| j | j | j | j �S )zX Return server object with serve_forever() method and address attribute zAlready started serverzManager has shut downzUnknown state {!r}) r� r� r� r� r� r r� r> rJ � _registryr� r� r� )r% r r r � get_server s zBaseManager.get_serverc C s8 t | j \}}|| j| jd�}t|dd� tj| j_dS )z> Connect manager object to the server process )rY NrQ ) rZ r� r� r� r: r� r� r� r� )r% rc rd r� r r r �connect s zBaseManager.connectr c C s4 | j jtjkrP| j jtjkr&td��n*| j jtjkr>td��ntd�| j j���|dk rht|�sht d��t j dd�\}}| j j t| �j| j| j| j| j|||fd�| _d �d d � | jjD ��}t| �jd | | j_| j�� |�� |�� | _|�� tj| j _t j | t| �j | j| j| j| j | j fd d�| _ dS )z@ Spawn a server process for this manager object zAlready started serverzManager has shut downzUnknown state {!r}Nz initializer must be a callableF)Zduplex)re r6 �:c s s | ]}t |�V qd S )N)r< )r �ir r r � <genexpr>1 s z$BaseManager.start.<locals>.<genexpr>�-r )r6 � exitpriority)!r� r� r� r� r� r r� r> rC r= r ZPiper� ZProcessr � _run_serverr� r� r� r� �_processr� Z _identityr+ r rm r� r2 r �Finalize�_finalize_managerr� rK )r% � initializer�initargs�reader�writerr� r r r rm s4 zBaseManager.startc C sN |dk r||� | � ||||�}|�|j� |�� t�d|j� |�� dS )z@ Create a server, report its address and run it Nzmanager serving at %r)�_Serverr1 r# r� r r� ry ) �clsrW r# rY rb r� r� r� �serverr r r r� C s zBaseManager._run_serverc O sv | ^}}} t | �} |jjtjks(td��|j|j|jd�}z t |dd|f| |�\}}W d|� � X t ||j|�|fS )zP Create a new shared object; return the token and exposed tuple zserver not yet started)rY NrL ) r� r� r� r� r� r~ r� r� r� r: r� r )r6 r7 r% r" r� r$ r� r r r �_createW s zBaseManager._createc C s* | j dk r&| j �|� | j �� s&d| _ dS )zC Join the manager process (if it has been spawned) N)r� r� �is_alive)r% �timeoutr r r r� f s zBaseManager.joinc C s. | j | j| jd�}z t|dd�S |�� X dS )zS Return some info about the servers shared objects and connections )rY NrO )r� r� r� r: r� )r% r� r r r � _debug_infoo s zBaseManager._debug_infoc C s. | j | j| jd�}z t|dd�S |�� X dS )z5 Return the number of shared objects )rY NrP )r� r� r� r: r� )r% r� r r r �_number_of_objectsy s z BaseManager._number_of_objectsc C sj | j jtjkr| �� | j jtjkrf| j jtjkr<td��n*| j jtjkrTtd��ntd�| j j���| S )NzUnable to start serverzManager has shut downzUnknown state {!r}) r� r� r� r� rm r� r r� r> )r% r r r � __enter__� s zBaseManager.__enter__c C s | � � d S )N)rK )r% �exc_type�exc_val�exc_tbr r r �__exit__� s zBaseManager.__exit__c C s� | � � r�t�d� y,|||d�}zt|dd� W d|�� X W n tk rR Y nX | jdd� | � � r�t�d� t| d�r�t�d � | �� | jd d� | � � r�t�d � t j |_ y t j |= W n tk r� Y nX dS ) zQ Shutdown the manager process; will be registered as a finalizer z#sending shutdown message to manager)rY NrK g �?)r� zmanager still alive� terminatez'trying to `terminate()` manager processg�������?z#manager still alive after terminate)r� r r� r: r� r r� �hasattrr� r� r� r� r �_address_to_localr� )r r# rY r( r� r� r r r r� � s. z BaseManager._finalize_managerc C s | j S )N)r� )r% r r r r# � s zBaseManager.addressTc s� d| j kr| j�� | _� dkr"t� |p0t� dd�}|p@t� dd�}|r�xHt|�� �D ]8\}}t|�tkstt d| ��t|�tksTt d| ��qTW |||� f| j�< |rƇ �fdd�} �| _ t | �| � dS )z9 Register a typeid with the manager type r� N� _exposed_�_method_to_typeid_z%r is not a stringc s` t �d�� | j�f|�|�\}}� || j| | j|d�}| j|j| jd�}t|d d|jf� |S )Nz)requesting creation of a shared %r object)�managerrY r� )rY rS ) r ru r� r� r� r� r# r: r$ )r% r6 r7 r� Zexp�proxyr� )r� r" r r rE � s z"BaseManager.register.<locals>.temp) �__dict__r� �copy� AutoProxyr r r r r< r~ r+ �setattr) r� r" rC r� r� r� � create_method�keyr� rE r )r� r" r �register� s zBaseManager.register)NNr� N)Nr )Nr )N)NNNNT)r+ r- r. r/ r� rJ r� r& r� r� rm � 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 �| dd� � d S )Nc S s | � � S )N)�clear)r r r r �<lambda>� � z*ProcessLocalSet.__init__.<locals>.<lambda>)r �register_after_fork)r% r r r r& � s zProcessLocalSet.__init__c C s t | �dfS )Nr )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 ZdZi Ze�� Zd dd�Zdd� Z d i fd d �Z d d � Z dd� Z e dd� �Zdd� Zdd� Zdd� Zdd� Zdd� ZdS ) r z. A base for proxies of shared objects NTFc C s� t j�8 t j�|jd �}|d kr:t�� t� f}|t j|j< W d Q R X |d | _|d | _ || _ | j j | _ || _ || _t| d | _|| _|d k r�t�|�| _n"| j d k r�| j j| _n t�� j| _|r�| �� t�| t j� d S )Nr r )r �_mutexr� r� r# r ZForkAwareLocalr� �_tls�_idset�_tokenr$ �_id�_managerr� rZ r� �_owned_by_managerr rX r� rh rY �_increfr� � _after_fork) r% r� rb r� rY r� rR � manager_ownedZ tls_idsetr r r r& � s* zBaseProxy.__init__c C sd t �d� t�� j}t�� jdkr4|dt�� j 7 }| j| jj | j d�}t |d d|f� || j _ d S )Nz making connection to managerZ MainThread�|)rY rM )r ru r rh r r_ r� r� r� r# r� r: r� r )r% r r� r r r �_connect s zBaseProxy._connectr c C s� y | j j}W n6 tk rB t�dt�� j� | �� | j j}Y nX |� | j |||f� |� � \}}|dkrp|S |dkr�|\}}| j j |j d } | jj|_| || j| j | j|d�} | j|j| jd�}t|dd|jf� | S t||��dS ) zV Try to call a method of the referent and return a copy of the result z#thread %r does not own a connectionz#RETURNz#PROXY���)r� rY r� )rY NrS )r� r r� r ru r_ r� r r� r1 r� r2 r� r� r" r� r# r� r� r� r: r$ r3 ) r% r5 r6 r7 r� r8 r9 r� r� r� r� r r r � _callmethod& s, zBaseProxy._callmethodc C s | � d�S )z9 Get a copy of the value of the referent z #GETVALUE)r� )r% r r r � _getvalueD s zBaseProxy._getvaluec C s� | j rt�d| jj� d S | j| jj| jd�}t|d d| j f� t�d| jj� | j � | j � | j oj| j j }tj| tj| j| j|| j| j | jfdd�| _d S )Nz%owned_by_manager skipped INCREF of %r)rY rR z INCREF %r� )r6 r� )r� r ru r� r$ r� r# r� r: r� r� �addr� r� r� r �_decrefr� Z_close)r% r� r( r r r r� J s zBaseProxy._increfc C s� |� | j� |d ks |jtjkr�y2t�d| j� || j|d�}t|d d| jf� W q� t k r� } zt�d|� W d d }~X Y q�X nt�d| j� |s�t |d�r�t�dt � � j � |j�� |`d S )Nz DECREF %r)rY rS z... decref failed %sz%DECREF %r -- manager already shutdownr z-thread %r has no more proxies so closing conn)�discardr$ r� r� r� r ru r# r: r r� r_ r� r r r� )r� rY r( ZtlsZidsetr� r� r� r r r r� ^ s zBaseProxy._decrefc C sH d | _ y | �� W n0 tk rB } zt�d| � W d d }~X Y nX d S )Nzincref failed: %s)r� r� r r r� )r% r� r r r r� w 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 )NrY �_isautoFr� ) r r� r r� � RebuildProxyr� r� r� r )r% r7 r r r r� s zBaseProxy.__reduce__c C s | � � S )N)r� )r% Zmemor r r � __deepcopy__� 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, � s zBaseProxy.__repr__c C s4 y | � d�S tk r. t| �dd� d S X dS )zV Return representation of the referent (or a fall-back if that fails) r, Nr� z; '__str__()' failed>)r� r r� )r% r r r rA � s zBaseProxy.__str__)NNNTF)r+ r- r. r/ r� r ZForkAwareThreadLockr� r& r� r� r� r� r� r� r� r� r� r, rA r r r r r � s ( c C s� t t�� dd�}|rT|j|jkrTt�d|� d|d< |j|jkrT|j|j |j|j< |� dd�opt t�� dd� }| ||fd|i|��S ) z5 Function used for unpickling proxy objects. ri Nz*Rebuild a proxy owned by manager, token=%rTr� rR Z _inheritingF) r r rh r# r ru r$ r^ r\ r� )rF r� rb r7 r� rR r r r r� � s r� c C sr t |�}y || |f S tk r( Y nX i }x |D ]}td||f |� q4W t| tf|�}||_||| |f< |S )zB Return a proxy type whose methods are given by `exposed` zLdef %s(self, *args, **kwds): return self._callmethod(%r, args, kwds))r� r� �execr r r� )r r� �_cacheZdicZmeth� ProxyTyper r r � MakeProxyType� s r Tc C s� t | d }|dkrB|| j|d�}zt|dd| f�}W d|�� X |dkrX|dk rX|j}|dkrjt�� j}td| j |�}|| ||||d�} d| _ | S )z* Return an auto-proxy for `token` r N)rY rN z AutoProxy[%s])r� rY rR T) rZ r# r: r� r� r rh rY r r" r� ) r� rb r� rY r� rR r� r� r� r� r r r r� � s r� c @ s e Zd Zdd� Zdd� ZdS )� Namespacec K s | j �|� d S )N)r� �update)r% r7 r r r r& � s zNamespace.__init__c C s^ t | j�� �}g }x,|D ]$\}}|�d�s|�d||f � qW |�� d| jjd�|�f S )NrH z%s=%rz%s(%s)z, ) r r� r � startswithrD r� r* r+ r� )r% r rE 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 � | |�S )N)r )r Zsequencer r r r �Array s r c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) � IteratorProxy)�__next__r1 �throwr� c C s | S )Nr )r% r r r �__iter__ s zIteratorProxy.__iter__c G s | � d|�S )Nr )r� )r% r6 r r r r s zIteratorProxy.__next__c G s | � d|�S )Nr1 )r� )r% r6 r r r r1 s zIteratorProxy.sendc G s | � d|�S )Nr )r� )r% r6 r r r r s zIteratorProxy.throwc G s | � d|�S )Nr� )r� )r% r6 r r r r� s zIteratorProxy.closeN) r+ r- r. r� r r r1 r r� r r r r r s r c @ s2 e Zd ZdZd dd�Zdd� Zdd � Zd d � ZdS ) � AcquirerProxy)�acquire�releaseTNc C s" |d kr|fn||f}| � d|�S )Nr )r� )r% Zblockingr� r6 r r r r s zAcquirerProxy.acquirec C s | � d�S )Nr )r� )r% r r r r s zAcquirerProxy.releasec C s | � d�S )Nr )r� )r% r r r r� s zAcquirerProxy.__enter__c C s | � d�S )Nr )r� )r% r� r� r� r r r r� s zAcquirerProxy.__exit__)TN)r+ r- r. r� r r r� r� r r r r r s r c @ s6 e Zd ZdZd dd�Zd dd�Zdd � Zdd d �ZdS )�ConditionProxy)r r ro �notify� notify_allNc C s | � d|f�S )Nro )r� )r% r� r r r ro $ s zConditionProxy.waitr c C s | � d|f�S )Nr )r� )r% �nr r r r & s zConditionProxy.notifyc C s | � d�S )Nr )r� )r% r r r r ( s zConditionProxy.notify_allc C sh |� }|r|S |d k r$t �� | }nd }d }x6|sb|d k rP|t �� }|dkrPP | �|� |� }q.W |S )Nr )�timeZ monotonicro )r% Z predicater� r9 ZendtimeZwaittimer r r �wait_for* s zConditionProxy.wait_for)N)r )N)r+ r- r. r� ro r r r r r r r r " s r c @ s2 e Zd ZdZdd� Zdd� Zdd� Zd d d �ZdS ) � EventProxy)rn r� r� ro c C s | � d�S )Nrn )r� )r% r r r rn ? s zEventProxy.is_setc C s | � d�S )Nr� )r� )r% r r r r� A s zEventProxy.setc C s | � d�S )Nr� )r� )r% r r r r� C s zEventProxy.clearNc C s | � d|f�S )Nro )r� )r% r� r r r ro E s zEventProxy.wait)N)r+ r- r. r� rn r� r� ro r r r r r = s r c @ sN e Zd ZdZddd�Zdd� Zdd� Zed d � �Zed d � �Z ed d� �Z dS )� BarrierProxy)�__getattribute__ro �abort�resetNc C s | � d|f�S )Nro )r� )r% r� r r r ro K s zBarrierProxy.waitc C s | � d�S )Nr )r� )r% r r r r M s zBarrierProxy.abortc C s | � d�S )Nr )r� )r% r r r r O s zBarrierProxy.resetc C s | � dd�S )Nr )�parties)r� )r% r r r r Q s zBarrierProxy.partiesc C s | � dd�S )Nr )� n_waiting)r� )r% r r r r T s zBarrierProxy.n_waitingc C s | � dd�S )Nr )�broken)r� )r% r r r r W s zBarrierProxy.broken)N) r+ r- r. r� ro r r r� r r r r r r r r I s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �NamespaceProxy)r � __setattr__� __delattr__c C s0 |d dkrt �| |�S t �| d�}|d|f�S )Nr rH r� r )�objectr )r% r� � callmethodr r r � __getattr__^ s zNamespaceProxy.__getattr__c C s4 |d dkrt �| ||�S t �| d�}|d||f�S )Nr rH r� r )r! r r )r% r� r� r" r r r r c s zNamespaceProxy.__setattr__c C s0 |d dkrt �| |�S t �| d�}|d|f�S )Nr rH r� r )r! r r )r% r� r" r r r r h s zNamespaceProxy.__delattr__N)r+ r- r. r� r# r r r r r r r \ s r c @ s* e Zd ZdZdd� Zdd� Zeee�ZdS )� ValueProxy)r� r� c C s | � d�S )Nr� )r� )r% r r r r� q s zValueProxy.getc C s | � d|f�S )Nr� )r� )r% r� r r r r� s s zValueProxy.setN)r+ r- r. r� r� r� r� r� r r r r r$ o s r$ � BaseListProxy)�__add__� __contains__� __delitem__� __getitem__�__len__�__mul__� __reversed__�__rmul__� __setitem__rD �count�extend�index�insertr� �remove�reverser� �__imul__c @ s e Zd Zdd� Zdd� ZdS )� ListProxyc C s | � d|f� | S )Nr0 )r� )r% r� r r r �__iadd__ s zListProxy.__iadd__c C s | � d|f� | S )Nr5 )r� )r% r� r r r r5 � s zListProxy.__imul__N)r+ r- r. r7 r5 r r r r r6 ~ s r6 � DictProxy)r' r( r) r r* r. r� r� r� r r r� �popitem� setdefaultr r r �Iterator� ArrayProxy)r* r) r. � PoolProxy) Zapply� apply_asyncr� �imap�imap_unorderedr� �map� map_async�starmap� starmap_asyncr� Z AsyncResult)r> rB rD r? r@ c @ s e Zd Zdd� Zdd� ZdS )r= c C s | S )Nr )r% r r r r� � s zPoolProxy.__enter__c C s | � � d S )N)r� )r% r� r� r� r r r r� � s zPoolProxy.__exit__N)r+ r- r. r� r� r r r r r= � s c @ s e Zd ZdZdS )r a( 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. N)r+ r- r. r/ r r r r r � s �QueueZ JoinableQueuerf r` �RLock� Semaphore�BoundedSemaphore� Condition�Barrier�Poolr r� F)r� r� )r� )NNNT)T)J�__all__rr r_ r Zqueuer r� r � r �contextr r r r r r r r r� Z view_typesr r! Z view_typer! r r: r3 r r? rG rI rJ r� rc rd Z XmlListenerZ XmlClientrZ r r� r� r r� r r� r r r r r r r r r r$ r% r6 r8 r� r< Z BasePoolProxyr= r rE rf r` rF rG rH rI rJ rK r� r r r r �<module> s� \ w 4
Save File
Cancel