��]��@s�ddlZddlZddlmZejs=ed��ddlmZddlmZddlmZddlm Z dd lm Z d gZGdd�de�Z Gd d �d ej�ZdS)�N�)� reductionz,No support for sending fds between processes)�context)� forkserver)� popen_fork)�spawn)�util�Popenc@s(eZdZdd�Zdd�ZdS)�_DupFdcCs ||_dS)N)�ind)�selfr�r �5/opt/alt/python35/lib64/python3.5/popen_forkserver.py�__init__sz_DupFd.__init__cCstj�|jS)N)rZget_inherited_fdsr)rr r r�detachsz _DupFd.detachN)�__name__� __module__�__qualname__rrr r r rr sr csXeZdZdZeZ�fdd�Zdd�Zdd�Ze j dd �Z�S) r rcsg|_t�j|�dS)N)�_fds�superr)r�process_obj)� __class__r rr"s zPopen.__init__cCs!|jj|�t|j�dS)Nr)r�append�len)r�fdr r r�duplicate_for_child&szPopen.duplicate_for_childcCs�tj|j�}tj�}tj|�z$tj||�tj||�Wdtjd�Xt j |j�\|_}t j|tj|jf�t|ddd��}|j|j��WdQRXt j|j�|_dS)N�wb�closefdT)rZget_preparation_data�_name�io�BytesIOr�set_spawning_popenr�dumprZconnect_to_new_processr�sentinelr�Finalize�os�close�open�write� getbuffer� read_unsigned�pid)rrZ prep_data�buf�w�fr r r�_launch*s z Popen._launchcCs�|jdkr�ddlm}|tjkr4dnd}||jg|�sSdSytj|j�|_Wn!tt fk r�d|_YnX|jS)Nr)�wait��) � returncode�multiprocessing.connectionr0r%�WNOHANGr#rr*�OSError�EOFError)r�flagr0�timeoutr r r�poll:sz Popen.poll)rrr�methodr �DupFdrrr/r%r4r9r r )rrr s)rr%�r�HAVE_SEND_HANDLE�ImportErrorrrrrr�__all__�objectr r r r r r�s