� e f��@s�ddlZddlZddlZddlZddlZddlZddlZddlmZdddddgZ ej d kp�eed �o�eed�o�eejd�ZGd d�dej �ZejZddd�Zej d krfe dddg7Z ddlZdddd�Zdd�Zdd�Zdd�ZGdd�de�Znje dddg7Z ddlZej dkZdd�Zdd�Zdd�Zdd�Zd d�Zd!d"�ZGd#d$�d$�Zeee�j �e�d%d&�Z!eee"j#�e!�eee$j%�e!�d'd(�Z&d)d*�Z'eej(e&�ej d kr�d+d,�Z)d-d.�Z*eeje)�n(d/d,�Z)d0d.�Z*eeje)�dS)1�N�)�context�send_handle�recv_handle�ForkingPickler�register�dump�win32�CMSG_LEN� SCM_RIGHTS�sendmsgcsgeZdZdZiZejZ�fdd�Ze dd��Z e ddd��Zej Z �S) rz)Pickler subclass used by multiprocessing.cs9t�j|�|jj�|_|jj|j�dS)N)�super�__init__�_copyreg_dispatch_table�copy�dispatch_table�update�_extra_reducers)�self�args)� __class__��>/opt/alt/python34/lib64/python3.4/multiprocessing/reduction.pyr%szForkingPickler.__init__cCs||j|r.r3r4r0r/r?r5r6)rrCrrrr;tszDupHandle.detach)r"r#r$r%rr;rrrrr+cs�DupFd�sendfds�recvfds�darwincCs~tjd|�}tt|�dg�}|j|gtjtj|fg�trz|jd�dkrzt d��ndS)z,Send an array of fds over an AF_UNIX socket.�i�r�Az%did not receive acknowledgement of fdN) �array�bytes�lenr�socket� SOL_SOCKETr�ACKNOWLEDGEr:�RuntimeError)�sockZfds�msgrrrrE�s %cCsTtjd�}|j|}|jdtj|��\}}}}|rZ|rZt�ny�trs|jd�nt|�dkr�t dt|��n|d\}} } |tj kr(| tjkr(t| �|jdkr�t�n|j | �t|�d|dkst�t|�SWnttfk rCYnXt d��dS) z/Receive an array of fds over an AF_UNIX socket.rHrrJzreceived %d items of ancdatarrIzInvalid data receivedN)rK�itemsizeZrecvmsgrNr �EOFErrorrPr7rMrQrOr� ValueErrorZ frombytes�AssertionError�list� IndexError)rR�size�aZ bytes_sizerSZancdata�flagsZaddrZ cmsg_levelZ cmsg_typeZ cmsg_datarrrrF�s, ' c Cs>tj|j�tjtj��}t||g�WdQXdS)z&Send a handle over a local connection.N)rN�fromfd�fileno�AF_UNIX�SOCK_STREAMrE)r8r2r9�srrrr�s$c Cs?tj|j�tjtj��}t|d�dSWdQXdS)z)Receive a handle over a local connection.rrN)rNr]r^r_r`rF)r8rarrrr�s$cCsatj�}|dk r.|j|j|��StrQddlm}|j|�Std��dS)zReturn a wrapper for an fd.Nr)�resource_sharerz&SCM_RIGHTS appears not to be available)rZget_spawning_popenrDZduplicate_for_child�HAVE_SEND_HANDLE�rbrV)�fdZ popen_objrbrrrrD�s cCsE|jdkr(t|j|jjffSt|j|jjffSdS)N)�__self__�getattrr�__func__r")�mrrr�_reduce_method�srjc@seZdZdd�ZdS)�_CcCsdS)Nr)rrrr�f�sz_C.fN)r"r#r$rlrrrrrk�srkcCst|j|jffS)N)rg�__objclass__r")rirrr�_reduce_method_descriptor�srncCs"t|j|j|jpiffS)N)�_rebuild_partial�funcr�keywords)�prrr�_reduce_partial�srscCstj|||�S)N)� functools�partial)rprrqrrrro�srocCs#ddlm}t||�ffS)Nr)� DupSocket)rbrv�_rebuild_socket)rarvrrr�_reduce_socket�srxcCs |j�S)N)r;)Zdsrrrrw�srwcCs1t|j��}t||j|j|jffS)N)rDr^rw�familyr�proto)ra�dfrrrrx�scCs%|j�}tj|||d|�S)Nr^)r;rN)r{ryrrzrerrrrw�s)+r&rtrr<r(rN�sysrdr�__all__�platform�hasattrrcZPicklerrrrr.r,r-rr�objectr+rKrPrErFrDrjrkrrlrnrX�append�int�__add__rsrorurxrwrrrr� s^ #