관리-도구
편집 파일: managers.cpython-310.opt-2.pyc
o 6��f�� � @ sP g d �Z ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ddlmZmZmZ ddl mZ dd l mZ dd l mZ dd l mZ zdd l mZ W n eyk d ZY nw dZe �d� dd� Ze�eje� dd� dD �Z e d e ur�dd� Z e D ]Z e�e e � q�G dd� de �Z!di fdd�Z"d d � Z#G 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,e0�Z1G d-d.� d.e �Z2d/d0� Z3i fd1d2�Z4 dmd3d4�Z5G d5d6� d6e �Z6G d7d8� d8e �Z7dnd9d:�Z8G d;d<� d<e2�Z9G d=d>� d>e2�Z:G d?d@� d@e:�Z;G dAdB� dBe2�Z<G dCdD� dDe2�Z=G dEdF� dFe2�Z>G dGdH� dHe2�Z?e4dIdJ�Z@G dKdL� dLe@�ZAe4dMdN�ZBdOdPieB_Ce4dQdR�ZDe4dSdT�ZEdUdUdUdPdPdV�eE_CG dWdS� dSeE�ZFG dXdY� dYe/�ZGeG�dZejH� eG�d[ejH� eG�d\ejIe<� eG�d]ejJe:� eG�d^ejKe:� eG�d_ejLe:� eG�d`ejMe:� eG�daejNe;� eG�dbejOe=� eG�dcejPeF� eG�dde eA� eG�deeQeB� eG�d8e7e?� eG�d:e8eD� eG�d6e6e>� eGjdPe9d df� eGjdUd dg� e�r&G dhdi� di�ZRG djdk� dke(�ZSG dld� de/�ZTdS dS )o)� BaseManager� SyncManager� BaseProxy�Token� N)�getpid)� format_exc� )� connection)� reduction�get_spawning_popen� ProcessError)�pool)�process)�util)� get_context)� shared_memoryFT�SharedMemoryManagerc C s t j | j| �� ffS �N)�array�typecode�tobytes)�a� r �?/opt/alt/python310/lib64/python3.10/multiprocessing/managers.py� reduce_array/ � r c C s g | ] }t ti |�� ��qS r )�type�getattr��.0�namer r r � <listcomp>3 � r! )�items�keys�valuesc C s t t | �ffS r )�list��objr r r �rebuild_as_list5 � r) c @ s2 e Zd Z dZdd� Zdd� Zdd� Zdd � Zd S ) r ��typeid�address�idc C s |||| _ | _| _d S r r+ )�selfr, r- r. r r r �__init__D s zToken.__init__c C s | j | j| jfS r r+ �r/ r r r � __getstate__G � zToken.__getstate__c C s |\| _ | _| _d S r r+ �r/ �stater r r � __setstate__J r 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. r1 r r r �__repr__M s �zToken.__repr__N)r8 � __module__� __qualname__� __slots__r0 r2 r6 r9 r r r r r > s r r c C s6 | � ||||f� | �� \}}|dkr|S t||��)N�#RETURN)�send�recv�convert_to_error)�cr. � methodname�args�kwds�kind�resultr r r �dispatchU s rG c C s^ | dkr|S | dv r(t |t�std�|| t|����| dkr$td| �S t|�S td�| ��S )N�#ERROR)� #TRACEBACK�#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strrJ zUnserializable message: %s z Unrecognized message type {!r})� isinstance�str� TypeError�formatr � RemoteError� ValueError)rE rF r r r r@ _ s �� r@ c @ s e Zd Zdd� ZdS )rO c C s dt | jd � d S )NzM --------------------------------------------------------------------------- r zK---------------------------------------------------------------------------)rL rC r1 r r r �__str__o s zRemoteError.__str__N)r8 r: r; rQ r r r r rO n s rO c C s4 g }t | �D ]}t| |�}t|�r|�|� q|S r )�dirr �callable�append)r( �tempr �funcr r r � all_methodsv s �rW c C s dd� t | �D �S )Nc S s g | ] }|d dkr|�qS )r �_r r r r r r! � r" z"public_methods.<locals>.<listcomp>)rW r' r r r �public_methods� s rY c @ s� e Zd Z g d�Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z e e e d�Z dd� Zdd� Zdd� Zdd � 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 sx t |t�std�|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 )rK �bytesrM rN r �registryr �AuthenticationString�authkey�listener_client�listenerr- � id_to_obj�id_to_refcount�id_to_local_proxy_obj� threading�Lock�mutex)r/ rh r- rj � serializer�Listener�Clientr r r r0 � s �� zServer.__init__c C s� t �� | _| t�� _zGt j| jd�}d|_|� � z| j� � s+| j� d� | j� � r W n t t fy7 Y nw W tjtjkrLt�d� tjt_tjt_t�d� d S tjtjkrft�d� tjt_tjt_t�d� w )N)�targetTr zresetting stdout, stderrr )rp �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/ r| r r r � serve_forever� s4 ���� � zServer.serve_foreverc C sF z| j �� }W n ty Y q w tj| j|fd�}d|_|�� q)NT�rv rC )rl Zaccept�OSErrorrp r{ �handle_requestr} r~ )r/ rA �tr r r r| � s ��zServer.accepterc C s$ d }z t �|| j� t �|| j� |�� }|\}}}}t| |�}W n ty/ dt� f}Y n!w z ||g|�R i |��} W n tyK dt� f}Y nw d| f}z|�|� W d S ty� } z-z |�dt� f� W n tys Y nw t � d|� t � d|� t � d| � W Y d } ~ d S d } ~ ww )NrI r= zFailure to send message: %rz ... request was %r� ... exception was %r) r Zdeliver_challengerj Zanswer_challenger? r � Exceptionr r> r �info) r/ rA �request�ignore�funcnamerC rD rV �msgrF �er r r �_handle_request� s: � � � ��zServer._handle_requestc C sL z z| � |� W n ty Y nw W |�� d S W |�� d S |�� w r )r� r� �close�r/ �connr r r r� � s �� �zServer.handle_requestc C s� t �dt�� j� |j}|j}| j}| j� � �sez�d }}|� }|\}}} } z || \}} } W n& t yV } zz | j | \}} } W n t yK | �w W Y d } ~ nd } ~ ww || vrft d|t |�| f ��t||�}z || i | ��}W n ty� } z d|f}W Y d }~n*d }~ww | o�| �|d �}|r�| �|||�\}}t|| j|�}d||ff}nd|f}W n` t y� |d u r�dt� f}n(z| j| }|| |||g| �R i | ��}d|f}W n ty� dt� f}Y nw Y n& t�y t �dt�� j� t�d� Y n t�y dt� f}Y nw zz||� W n t�y* |d t� f� Y nw W n1 t�y] } z$t �d t�� j� t �d |� t �d |� |�� t�d � W Y d }~nd }~ww | j� � rd S d S )Nz$starting server thread to service %rz+method %r of %r object is not in exposed=%rrH �#PROXYr= rI z$got EOF -- exiting thread serving %rr rJ z exception in thread serving %rz ... message was %rr� r )r r� rp �current_threadr r? r> rm rx r �KeyErrorro �AttributeErrorr r r� �getr\ r r- r �fallback_mapping�EOFErrorr� r� r� r� )r/ r� r? r> rm rB r( r� �identrC rD �exposed� gettypeid�keZfunction�resr� r� r, ZridentZrexposed�tokenZ fallback_funcrF r r r � serve_client� s� � � � ��� �� ��� ��� ���� ��� ���zServer.serve_clientc C s |S r r �r/ r� r� r( r r r �fallback_getvalue? � zServer.fallback_getvaluec C � t |�S r �rL r� r r r � fallback_strB � zServer.fallback_strc C r� r )�reprr� r r r � fallback_reprE r� zServer.fallback_repr)rQ r9 � #GETVALUEc C s d S r r �r/ rA r r r ra N r� z Server.dummyc C s� | j �; g }t| j�� �}|�� |D ] }|dkr2|�d|| j| t| j| d �d d� f � qd�|�W d � S 1 sBw Y d S )Nre z %s: refcount=%s %sr �K � ) rr r& rn r$ �sortrT rL rm �join)r/ rA rF r$ r� r r r r_ Q s ���$�zServer.debug_infoc C s t | j�S r )�lenrn r� r r r r` a s zServer.number_of_objectsc C sb z)z t �d� |�d� W n dd l}|�� Y W | j�� d S W | j�� d S | j�� w )Nz!manager received shutdown message�r= Nr )r r� r> � traceback� print_excrx �set)r/ rA r� r r r r[ h s �zServer.shutdownc O s | j �q | j| \}}}}|d u r#|st|�dkr td��|d } n||i |��} |d u r2t| �}|d urMt|t�sEtd�|t |����t |�t |� }dt | � } t � d|| � | t|�|f| j| < | | jvrnd| j| < W d � n1 sxw Y | �|| � | t|�fS )Nr z4Without 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)rr rh r� rP rY rK �dictrM rN r r& r. r r� r� rm rn rb �tuple) r/ rA r, rC rD rS r� �method_to_typeid� proxytyper( r� r r r r\ u s< �� �� � � z Server.createc C s t | j|j d �S )Nr )r� rm r. )r/ rA r� r r r r^ � s zServer.get_methodsc C s$ |t �� _|�d� | �|� d S )Nr� )rp r� r r> r� )r/ rA r r r r r] � s zServer.accept_connectionc C s� | j �R z | j| d7 < W n5 tyD } z)|| jv r8d| j|< | j| | j|< | j| \}}}t�d|� n|�W Y d }~n d }~ww W d � d S W d � d S 1 sXw Y d S )Nr z&Server re-enabled tracking & INCREF %r)rr rn r� ro rm r r� )r/ rA r� r� r( r� r� r r r rb � s$ � ����� "�z Server.increfc C s� || j vr|| jv rt�d|� d S | j�2 | j | dkr,td�|| j| | j | ���| j | d8 < | j | dkr@| j |= W d � n1 sJw Y || j vryd| j|< t�d|� | j� | j|= W d � d S 1 srw Y d S 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)rn ro r r� rr �AssertionErrorrN rm )r/ rA r� r r r rc � s0 ��� � "��z Server.decrefN)r8 r: r; �publicr0 r� r| r� r� r� r� r� r� r� ra r_ r` r[ r\ r^ r] rb rc r r r r rZ � s2 Q� $ rZ c @ s e Zd ZdgZdZdZdZdS )�State�valuer r � N)r8 r: r; r< �INITIAL�STARTED�SHUTDOWNr r r r r� � s r� )�pickleZ xmlrpclibc @ s� e Zd Z i ZeZ d!dd�Zdd� Zdd� Zd"d d �Z e d"d d ��Z dd� Z d#dd�Z dd� Zdd� Zdd� Zdd� Zedd� �Zed d � �Ze d$d d ��ZdS )%r Nr� c C s\ |d u r t �� j}|| _t �|�| _t� | _tj| j_ || _ t | \| _ | _ |p*t� | _d S r )r ry rj �_addressri �_authkeyr� �_stater� r� � _serializerrk Z _Listener�_Clientr �_ctx)r/ r- rj rs �ctxr r r r0 � s zBaseManager.__init__c C sd | j jtjkr'| j jtjkrtd��| j jtjkr td��td�| j j���t| j | j | j | j �S )N�Already started server�Manager has shut down�Unknown state {!r}) r� r� r� r� r� r r� rN rZ � _registryr� r� r� r1 r r r � get_server� s � �zBaseManager.get_serverc C s: t | j \}}|| j| jd�}t|d d� tj| j_d S )N�rj ra ) rk r� r� r� rG r� r� r� r� )r/ rt ru r� r r r �connect s zBaseManager.connectr c C s2 | j jtjkr'| j jtjkrtd��| j jtjkr td��td�| j j���|d ur3t|�s3t 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 �| _ d S )Nr� r� r� z initializer must be a callableF)Zduplexr� �:c s s � | ]}t |�V qd S r r� )r �ir r r � <genexpr>0 s � z$BaseManager.start.<locals>.<genexpr>�-r �rC Z exitpriority)!r� r� r� r� r� r r� rN rS rM r ZPiper� ZProcessr � _run_serverr� r� r� r� �_processr� Z _identityr8 r r~ r� r? r �Finalize�_finalize_managerr� r[ )r/ � initializer�initargs�reader�writerr� r r r r~ s@ � �� � �zBaseManager.startc C s` t � t jt j� |d ur||� | �||||�}|�|j� |�� t�d|j� |� � d S )Nzmanager serving at %r) �signal�SIGINT�SIG_IGN�_Serverr> r- r� r r� r� ) �clsrh r- rj rs r� r� r� �serverr r r r� B s zBaseManager._run_serverc O sX | j | j| jd�}zt|d d|f| |�\}}W |�� n|�� w t|| j|�|fS )Nr� r\ )r� r� r� rG r� r )r/ r, rC rD r� r. r� r r r �_createY s zBaseManager._createc C s4 | j d ur| j �|� | j �� sd | _ d S d S d S r )r� r� �is_alive�r/ �timeoutr r r r� e s �zBaseManager.joinc C �6 | j | j| jd�}z t|d d�W |�� S |�� w )Nr� r_ �r� r� r� rG r� r� r r r � _debug_infon � zBaseManager._debug_infoc C r� )Nr� r` r� r� r r r �_number_of_objectsx r� z BaseManager._number_of_objectsc C sf | j jtjkr | �� | j jtjkr1| j jtjkr td��| j jtjkr(td��td�| j j���| S )NzUnable to start serverr� r� ) r� r� r� r� r~ r� r r� rN r1 r r r � __enter__� s �zBaseManager.__enter__c C � | � � d S r )r[ �r/ �exc_typeZexc_valZexc_tbr r r �__exit__� � zBaseManager.__exit__c C s� | � � rZt�d� z|||d�}z t|d d� W |�� n|�� w W n ty- Y nw | jdd� | � � rZt�d� t| d�rZt�d� | �� | jdd� | � � rZt�d � t j |_ zt j |= W d S tyo Y d S w ) Nz#sending shutdown message to managerr� r[ g �?)r� zmanager still alive� terminatez'trying to `terminate()` manager processz#manager still alive after terminate)r� r r� rG r� r� r� �hasattrr� r� r� r� r �_address_to_localr� )r r- rj r5 r� r� r r r r� � s4 � �z BaseManager._finalize_managerc C � | j S r )r� r1 r r r r- � s zBaseManager.addressTc s� d| j vr | j�� | _� d u rt� |pt� dd �}|p!t� dd �}|r/t|�� �D ]\}}q*|||� f| j�< |rL� �fdd�} �| _t| �| � d S d S )Nr� � _exposed_�_method_to_typeid_c sf t �d�� | j�g|�R i |��\}}� || j| | j|d�}| j|j| jd�}t|d d|jf� |S )Nz)requesting creation of a shared %r object��managerrj r� r� rc ) r r� r� r� r� r� r- rG r. )r/ rC rD r� Zexp�proxyr� �r� r, r r rU � s �z"BaseManager.register.<locals>.temp) �__dict__r� �copy� AutoProxyr r& r# r8 �setattr) r� r, rS r� r� r� � create_method�keyr� rU r r r �register� s$ � � �zBaseManager.register)NNr� Nrf r )NNNNT)r8 r: r; r� rZ r� r0 r� r� r~ � classmethodr� r� r� r� r� r� r� � staticmethodr� �propertyr- r r r r r r � s6 � + � �r c @ � e Zd Zdd� Zdd� ZdS )�ProcessLocalSetc C s t �| dd� � d S )Nc S � | � � S r )�clearr' r r r �<lambda>� s z*ProcessLocalSet.__init__.<locals>.<lambda>)r �register_after_forkr1 r r r r0 � r zProcessLocalSet.__init__c C s t | �dfS rf )r r1 r r r � __reduce__� r� zProcessLocalSet.__reduce__N)r8 r: r; r0 r r r r r r � � r c @ s� e Zd Z i Ze�� Z ddd�Zdd� Zdi fd d �Z d d � Z d d� Z e dd� �Z dd� Zdd� Zdd� Zdd� Zdd� ZdS ) r NTFc C s� t j�! t j�|jd �}|d u r t�� t� f}|t j|j< W d � n1 s'w Y |d | _|d | _ || _ | j j | _ || _ || _t| d | _|| _|d urYt�|�| _n| j d urd| j j| _nt�� j| _|rp| �� t�| t j� d S )Nr r )r �_mutexr� r� r- r ZForkAwareLocalr �_tls�_idset�_tokenr. �_id�_managerr� rk r� �_owned_by_managerr ri r� ry rj �_increfr � _after_fork) r/ r� rs r rj r� rb � manager_ownedZ tls_idsetr r r r0 � s. � � zBaseProxy.__init__c C sd t �d� t�� j}t�� jdkr|dt�� j 7 }| j| jj | j d�}t |d d|f� || j _ d S )Nz making connection to managerZ MainThread�|r� r] )r r� r ry r rp r� r� r r- r� rG r r )r/ r r� r r r �_connect s zBaseProxy._connectr c C s� z| j j}W n ty! t�dt�� j� | �� | j j}Y nw |� | j |||f� |� � \}}|dkr8|S |dkrn|\}}| j j |j d } | jj|_| || j| j | j|d�} | j|j| jd�}t|d d|jf� | S t||��)Nz#thread %r does not own a connectionr= r� ���r r� rc )r r r� r r� rp r� r r! r> r r? r r� r, r r- r� r� r� rG r. r@ ) r/ rB rC rD r� rE rF r� r� r� r r r r � _callmethod% s4 � � � zBaseProxy._callmethodc C s | � d�S )Nr� �r# r1 r r r � _getvalueC s zBaseProxy._getvaluec C s� | j r t�d| jj� d S | j| jj| jd�}t|d d| j f� t�d| jj� | j � | j � | j o5| j j }tj| tj| j| j|| j| j | jfdd�| _d S )Nz%owned_by_manager skipped INCREF of %rr� rb z INCREF %r� r� )r r r� r r. r� r- r� rG r r �addr r� r� r �_decrefr Z_close)r/ r� r5 r r r r I s � �zBaseProxy._increfc C s� |� | j� |d u s|jtjkrBzt�d| j� || j|d�}t|d d| jf� W n t yA } z t�d|� W Y d }~n d }~ww t�d| j� |sbt |d�rdt�dt � � j � |j�� |`d S d S d S )Nz DECREF %rr� rc z... decref failed %sz%DECREF %r -- manager already shutdownr z-thread %r has no more proxies so closing conn)�discardr. r� r� r� r r� r- rG r� r� rp r� r r r� )r� rj r5 ZtlsZidsetr� r� r� r r r r( ] s$ ��� �zBaseProxy._decrefc C sJ d | _ z| �� W d S ty$ } zt�d| � W Y d }~d S d }~ww )Nzincref failed: %s)r r r� r r� )r/ r� r r r r v s ��zBaseProxy._after_forkc C sZ i }t � d ur | j|d< t| dd�r!| j|d< tt| j| j|ffS tt| �| j| j|ffS )Nrj �_isautoFr� ) r r� r r� � RebuildProxyr r r� r �r/ rD r r r r ~ s ��zBaseProxy.__reduce__c C r r )r% )r/ Zmemor r r � __deepcopy__� r� zBaseProxy.__deepcopy__c C s dt | �j| jjt| �f S )Nz <%s object, typeid %r at %#x>)r r8 r r, r. r1 r r r r9 � s �zBaseProxy.__repr__c C s6 z| � d�W S ty t| �d d� d Y S w )Nr9 r" z; '__str__()' failed>)r# r� r� r1 r r r rQ � s �zBaseProxy.__str__�NNNTF)r8 r: r; r� r ZForkAwareThreadLockr r0 r! r# r% r r r( r r r- r9 rQ r r r r r � s$ �) r c C s� t t�� dd �}|r+|j|jkr+t�d|� d|d< |j|jvr+|j|j |j|j< |� dd�o9t t�� dd� }| ||fd|i|��S )Nrz z*Rebuild a proxy owned by manager, token=%rTr rb Z _inheritingF) r r ry r- r r� r. ro rm �pop)rV r� rs rD r� rb r r r r+ � s � �r+ c C sp t |�}z|| |f W S ty Y nw i }|D ] }td||f |� qt| tf|�}||_||| |f< |S )NzOdef %s(self, /, *args, **kwds): return self._callmethod(%r, args, kwds))r� r� �execr r r� )r r� �_cacheZdicZmeth� ProxyTyper r r � MakeProxyType� s$ ��� r3 c C s� t | d }|d u r&|| j|d�}zt|d d| f�}W |�� n|�� w |d u r1|d ur1|j}|d u r:t�� j}td| j |�} | | |||||d�} d| _ | S )Nr r� r^ z AutoProxy[%s])r rj rb r T) rk r- rG r� r� r ry rj r3 r, r* ) r� rs r rj r� rb r r� r� r2 r r r r r � s" �r c @ r )� Namespacec K s | j �|� d S r )r �updater, r r r r0 � r3 zNamespace.__init__c C sZ t | j�� �}g }|D ]\}}|�d�s |�d||f � q |�� d| jjd�|�f S )NrX z%s=%rz%s(%s)z, ) r& r r# � startswithrT r� r7 r8 r� )r/ r# rU r r� r r r r9 � s �zNamespace.__repr__N)r8 r: r; r0 r9 r r r r r4 � r r4 c @ s8 e Zd Zd dd�Zdd� Zdd� Zdd � Zeee�Zd S ) �ValueTc C � || _ || _d S r )� _typecode�_value)r/ r r� �lockr r r r0 � � zValue.__init__c C r� r �r: r1 r r r r� � s z Value.getc C s || _ d S r r= �r/ r� r r r r� � � z Value.setc C s dt | �j| j| jf S )Nz %s(%r, %r))r r8 r9 r: r1 r r r r9 � s zValue.__repr__N�T) r8 r: r; r0 r� r� r9 r r� r r r r r7 � s r7 c C s t � | |�S r )r )r �sequencer; r r r �Array� r� rB c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) � IteratorProxy)�__next__r> �throwr� c C � | S r r r1 r r r �__iter__ r� zIteratorProxy.__iter__c G � | � d|�S )NrD r$ �r/ rC r r r rD r� zIteratorProxy.__next__c G rH )Nr> r$ rI r r r r> r� zIteratorProxy.sendc G rH )NrE r$ rI r r r rE r� zIteratorProxy.throwc G rH )Nr� r$ rI r r r r� r� zIteratorProxy.closeN) r8 r: r; r� rG rD r> rE r� r r r r rC s rC c @ s2 e Zd ZdZd dd�Zdd� Zdd � Zd d � ZdS ) � AcquirerProxy)�acquire�releaseTNc C s" |d u r|fn||f}| � d|�S �NrK r$ )r/ Zblockingr� rC r r r rK s zAcquirerProxy.acquirec C � | � d�S �NrL r$ r1 r r r rL r? zAcquirerProxy.releasec C rN rM r$ r1 r r r r� r? zAcquirerProxy.__enter__c C rN rO r$ r� r r r r� r? zAcquirerProxy.__exit__)TN)r8 r: r; r� rK rL r� r� r r r r rJ s rJ c @ s6 e Zd ZdZd dd�Zd dd�Zdd � Zd d d �ZdS )�ConditionProxy)rK rL r� �notify� notify_allNc C � | � d|f�S �Nr� r$ r� r r r r� # r* zConditionProxy.waitr c C rS )NrQ r$ )r/ �nr r r rQ % r* zConditionProxy.notifyc C rN )NrR r$ r1 r r r rR ' r? zConditionProxy.notify_allc C sj |� }|r|S |d urt �� | }nd }d }|s3|d ur)|t �� }|dkr) |S | �|� |� }|r|S )Nr )�time� monotonicr� )r/ Z predicater� rF ZendtimeZwaittimer r r �wait_for) s" ��zConditionProxy.wait_forr )r )r8 r: r; r� r� rQ rR rX r r r r rP ! s rP c @ s2 e Zd ZdZdd� Zdd� Zdd� Zd d d �ZdS ) � EventProxy)r r� r r� c C rN )Nr r$ r1 r r r r > r? zEventProxy.is_setc C rN �Nr� r$ r1 r r r r� @ r? zEventProxy.setc C rN )Nr r$ r1 r r r r B r? zEventProxy.clearNc C rS rT r$ r� r r r r� D r* zEventProxy.waitr )r8 r: r; r� r r� r r� r r r r rY < s rY c @ sN e Zd ZdZddd�Zdd� Zdd� Zed d � �Zed d � �Z ed d� �Z dS )� BarrierProxy)�__getattribute__r� �abort�resetNc C rS rT r$ r� r r r r� J r* zBarrierProxy.waitc C rN )Nr] r$ r1 r r r r] L r? zBarrierProxy.abortc C rN )Nr^ r$ r1 r r r r^ N r? zBarrierProxy.resetc C � | � dd�S )Nr\ )�partiesr$ r1 r r r r` P � zBarrierProxy.partiesc C r_ )Nr\ )� n_waitingr$ r1 r r r rb S ra zBarrierProxy.n_waitingc C r_ )Nr\ )�brokenr$ r1 r r r rc V ra zBarrierProxy.brokenr ) r8 r: r; r� r� r] r^ r r` rb rc r r r r r[ H s r[ c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �NamespaceProxy)r\ � __setattr__� __delattr__c C s0 |d dkr t �| |�S t �| d�}|d|f�S )Nr rX r# r\ )�objectr\ �r/ r � callmethodr r r � __getattr__] � zNamespaceProxy.__getattr__c C s4 |d dkr t �| ||�S t �| d�}|d||f�S )Nr rX r# re )rg re r\ )r/ r r� ri r r r re b s zNamespaceProxy.__setattr__c C s0 |d dkr t �| |�S t �| d�}|d|f�S )Nr rX r# rf )rg rf r\ rh r r r rf g rk zNamespaceProxy.__delattr__N)r8 r: r; r� rj re rf r r r r rd [ s rd c @ s4 e Zd ZdZdd� Zdd� Zeee�Zee j �Z dS )� ValueProxy)r� r� c C rN )Nr� r$ r1 r r r r� p r? zValueProxy.getc C rS rZ r$ r> r r r r� r r* zValueProxy.setN) r8 r: r; r� r� r� r r� r �types� GenericAlias�__class_getitem__r r r r rl n s rl � BaseListProxy)�__add__� __contains__� __delitem__� __getitem__�__len__�__mul__� __reversed__�__rmul__� __setitem__rT �count�extend�index�insertr/ �remove�reverser� �__imul__c @ r )� ListProxyc C � | � d|f� | S )Nr{ r$ r> r r r �__iadd__� � zListProxy.__iadd__c C r� )Nr� r$ r> r r r r� � r� zListProxy.__imul__N)r8 r: r; r� r� r r r r r� s r� � DictProxy)rr rs rt rG ru ry r r r� r# r$ r/ �popitem� setdefaultr5 r% rG �Iterator� ArrayProxy)ru rt ry � PoolProxy) Zapply� apply_asyncr� �imap�imap_unorderedr� �map� map_async�starmap� starmap_asyncr� Z AsyncResult)r� r� r� r� r� c @ r )r� c C rF r r r1 r r r r� � r� zPoolProxy.__enter__c C r� r )r� r� r r r r� � r� zPoolProxy.__exit__N)r8 r: r; r� r� r r r r r� � r c @ s e Zd ZdS )r N)r8 r: r; r r r r r � s r �QueueZ JoinableQueuerw rq �RLock� Semaphore�BoundedSemaphore� Condition�Barrier�Poolr& r� )r� r )r c @ sJ e Zd Z g fdd�Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dS )�_SharedMemoryTrackerc C r8 r �Zshared_memory_context_name� segment_names)r/ r r� r r r r0 � r< z _SharedMemoryTracker.__init__c C s* t �d|�dt� � �� | j�|� d S )NzRegister segment � in pid )r r� r r� rT �r/ � segment_namer r r �register_segment� s z%_SharedMemoryTracker.register_segmentc C sD t �d|�dt� � �� | j�|� t�|�}|�� |�� d S )NzDestroy segment r� ) r r� r r� r~ r � SharedMemoryr� �unlink)r/ r� Zsegmentr r r �destroy_segment� s z$_SharedMemoryTracker.destroy_segmentc C s$ | j d d � D ]}| �|� qd S r )r� r� r� r r r r� � s �z_SharedMemoryTracker.unlinkc C s( t �d| jj� dt� � �� | �� d S )NzCall z .__del__ in )r r� r7 r8 r r� r1 r r r �__del__� s z _SharedMemoryTracker.__del__c C s | j | jfS r r� r1 r r r r2 � r� z!_SharedMemoryTracker.__getstate__c C s | j |� d S r )r0 r4 r r r r6 � r* z!_SharedMemoryTracker.__setstate__N) r8 r: r; r0 r� r� r� r� r2 r6 r r r r r� � s r� c @ sJ e Zd Zejg d� Zdd� Zdd� Zdd� Zdd � Zd d � Z d d � Z dS )�SharedMemoryServer)� track_segment�release_segment� list_segmentsc O s` t j| g|�R i |�� | j}t|t�rt�|�}td|� dt� � ��| _ t � dt� � �� d S )NZshm_rX z"SharedMemoryServer started by pid ) rZ r0 r- rK rg �os�fsdecoder� r �shared_memory_contextr r� )r/ rC �kwargsr- r r r r0 � s �zSharedMemoryServer.__init__c O s< t | j| d d�r| j|d< tj| ||g|�R i |��S )Nr" Z_shared_memory_proxyr� )r� rh r� rZ r\ )r/ rA r, rC r� r r r r\ s zSharedMemoryServer.createc C s | j �� t�| |�S r )r� r� rZ r[ r� r r r r[ s zSharedMemoryServer.shutdownc C � | j �|� d S r )r� r� �r/ rA r� r r r r� s z SharedMemoryServer.track_segmentc C r� r )r� r� r� r r r r� s z"SharedMemoryServer.release_segmentc C s | j jS r )r� r� r� r r r r� s z SharedMemoryServer.list_segmentsN) r8 r: r; rZ r� r0 r\ r[ r� r� r� r r r r r� � s � r� c @ s: e Zd Z eZdd� Zdd� Zdd� Zdd� Zd d � Z d S ) r c O sT t jdkrddlm} |�� tj| g|�R i |�� t�| j j � dt � � �� d S )N�posixr )�resource_trackerz created by pid ) r� r � r� Zensure_runningr r0 r r� r7 r8 r )r/ rC r� r� r r r r0 / s z SharedMemoryManager.__init__c C s t �| jj� dt� � �� d S )Nz.__del__ by pid )r r� r7 r8 r r1 r r r r� ; s zSharedMemoryManager.__del__c C sf | j jtjkr'| j jtjkrtd��| j jtjkr td��td�| j j���| �| j | j | j | j �S )Nz"Already started SharedMemoryServerz!SharedMemoryManager has shut downr� ) r� r� r� r� r� r r� rN r� r� r� r� r� r1 r r r r� ? s � �z SharedMemoryManager.get_serverc C s� | j | j| jd��/}tjd d|d�}z t|d d|jf� W n ty0 } z|�� |�d }~ww W d � |S 1 s<w Y |S )Nr� T)r\ �sizer� ) r� r� r� r r� rG r � BaseExceptionr� )r/ r� r� Zsmsr� r r r r� L s ��� ��z SharedMemoryManager.SharedMemoryc C s� | j | j| jd��.}t�|�}z t|d d|jjf� W n ty/ } z|j� � |�d }~ww W d � |S 1 s;w Y |S )Nr� r� ) r� r� r� r � ShareableListrG Zshmr r� r� )r/ rA r� Zslr� r r r r� X s ��� ��z!SharedMemoryManager.ShareableListN) r8 r: r; r� r� r0 r� r� r� r� r r r r r # s r. r@ )U�__all__r� rp r� r �queuerV rm r� r r� r r� r �contextr r r r r r r r � ImportErrorZ HAS_SHMEMrT r r Z view_typesr& r) Z view_typerg r rG r@ r� rO rW rY rZ r� rt ru Z XmlListenerZ XmlClientrk r r� r r r+ r3 r r4 r7 rB rC rJ rP rY r[ rd rl rp r� r� r� r� Z BasePoolProxyr� r r� rw rq r� r� r� r� r� r� r� r� r� r r r r r �<module> s� � P � w 4 � � � �%-�