� e ft �@scddlZddlZddlZddlZddlmZdgZGdd�de�ZdS)�N�)�util�Popenc@sgeZdZdZdd�Zdd�Zejdd�Zdd d �Z dd�Z d d�ZdS)r�forkcCs4tjj�tjj�d|_|j|�dS)N)�sys�stdout�flush�stderr� returncode�_launch)�self�process_obj�r�?/opt/alt/python34/lib64/python3.4/multiprocessing/popen_fork.py�__init__s zPopen.__init__cCs|S)Nr)r�fdrrr�duplicate_for_childszPopen.duplicate_for_childcCs�|jdkr�xhytj|j|�\}}WnAtk rt}z!|jtjkr^wndSWYdd}~XqXPqW||jkr�tj|�r�tj|�|_q�tj |�|_q�n|jS)N) r �os�waitpid�pid�OSError�errnoZEINTR�WIFSIGNALED�WTERMSIG�WEXITSTATUS)rZflagr�sts�errr�pollsz Popen.pollNcCsp|jdkri|dk rGddlm}||jg|�sGdSn|j|dkrbtjnd�S|jS)Nr)�waitg)r Zmultiprocessing.connectionr�sentinelrr�WNOHANG)r�timeoutrrrrr/s"z Popen.waitcCst|jdkrpytj|jtj�Wqptk r=Yqptk rl|jdd�dkrh�nYqpXndS)Nr!g��?) r r�killr�signal�SIGTERM�ProcessLookupErrorrr)rrrr� terminate9s zPopen.terminatecCs�d}tj�\}}tj�|_|jdkr�zEtj|�dtjkrnddl}|j�n|j �}Wdtj |�Xn/tj|�tj|tj|f�||_ dS)Nrr�random)r�piperr�closer�modulesr'Zseed� _bootstrap�_exitrZFinalizer)rr �codeZparent_rZchild_wr'rrrrCs z Popen._launch)�__name__� __module__�__qualname__�methodrrrr rrr&rrrrrrs ) rrr#r�r�__all__�objectrrrrr�s