� e f��@s�ddlZddlZddlZddlZddlZddlmZddlmZddlmZdgZ ej dkr�e dg7Z Gd d�de�Zn#e d g7Z Gdd �d e�Z Gdd �d e�Ze�ZejZdS)�N�)�process)� reduction)�util�stop�win32� DupSocketc@s.eZdZdZdd�Zdd�ZdS)rzPicklable wrapper for a socket.cs:|j��fdd�}tj|�j�|_dS)Ncs �j|�}|j|�dS)N)�shareZ send_bytes)�conn�pidr )�new_sock��D/opt/alt/python34/lib64/python3.4/multiprocessing/resource_sharer.py�sendsz DupSocket.__init__..send)�dup�_resource_sharer�register�close�_id)�selfZsockrr )rr�__init__szDupSocket.__init__c Cs8tj|j�� }|j�}tj|�SWdQXdS)z1Get the socket. This should only be called once.N)r�get_connectionrZ recv_bytes�socketZ fromshare)rr r r r r�detach$szDupSocket.detachN)�__name__� __module__�__qualname__�__doc__rrr r r rrs�DupFdc@s.eZdZdZdd�Zdd�ZdS)rz-Wrapper for fd which can be used at any time.csLtj|��fdd�}�fdd�}tj||�|_dS)Ncstj|�|�dS)N)rZsend_handle)r r)�new_fdr rr1szDupFd.__init__..sendcstj��dS)N)�osrr )rr rr3szDupFd.__init__..close)r rrrr)r�fdrrr )rrr/szDupFd.__init__c Cs,tj|j��}tj|�SWdQXdS)z-Get the fd. This should only be called once.N)rrrrZrecv_handle)rr r r rr7szDupFd.detachN)rrrrrrr r r rr-sc@sseZdZdZdd�Zdd�Zedd��Zdd d �Zdd�Z d d�Z dd�ZdS)�_ResourceSharerz-Manager for resouces using background thread.cCs\d|_i|_g|_tj�|_d|_d|_d|_t j |tj�dS)Nr) �_key�_cache� _old_locks� threading�Lock�_lock� _listener�_address�_threadrZregister_after_forkr"� _afterfork)rr r rr?s z_ResourceSharer.__init__c Cse|j�V|jdkr&|j�n|jd7_||f|j|j<|j|jfSWdQXdS)z+Register resource, returning an identifier.Nr)r(r*�_startr#r$)rrrr r rrIs z_ResourceSharer.registercCsTddlm}|\}}||dtj�j�}|j|tj�f�|S)zs `