B � fZ �@s>ddlZddlZddlZddlmZdgZGdd�de�ZdS)�N�)�util�Popenc@s`eZdZdZdd�Zdd�Zejfdd�Zdd d �Z dd�Z d d�Zdd�Zdd�Z dd�ZdS)r�forkcCs"t��d|_d|_|�|�dS)N)rZ_flush_std_streams� returncode� finalizer�_launch)�self�process_obj�r�?/opt/alt/python37/lib64/python3.7/multiprocessing/popen_fork.py�__init__szPopen.__init__cCs|S)Nr)r �fdrrr�duplicate_for_childszPopen.duplicate_for_childc Csz|jdkrtyt�|j|�\}}Wn"tk rB}zdSd}~XYnX||jkrtt�|�rht�|�|_nt�|�|_|jS)N)r�os�waitpid�pid�OSError�WIFSIGNALED�WTERMSIG�WEXITSTATUS)r �flagr�sts�errr�polls z Popen.pollNcCsN|jdkrH|dk r0ddlm}||jg|�s0dS|�|dkrBtjnd�S|jS)Nr)�waitg)rZmultiprocessing.connectionr�sentinelrr�WNOHANG)r �timeoutrrrrr)s z Popen.waitcCsZ|jdkrVyt�|j|�Wn8tk r0Yn&tk rT|jdd�dkrP�YnXdS)Ng��?)r)rr�killr�ProcessLookupErrorrr)r Zsigrrr�_send_signal3s zPopen._send_signalcCs|�tj�dS)N)r!�signal�SIGTERM)r rrr� terminate=szPopen.terminatecCs|�tj�dS)N)r!r"�SIGKILL)r rrrr@sz Popen.killc Csrd}t��\}}t��|_|jdkrJzt�|�|��}Wdt�|�Xn$t�|�t�|tj|f�|_ ||_ dS)Nrr)r�piperr�close� _bootstrap�_exitrZFinalizerr)r r �codeZparent_rZchild_wrrrrCs z Popen._launchcCs|jdk r|��dS)N)r)r rrrr'Rs zPopen.close)N)�__name__� __module__�__qualname__�methodr rrrrrr!r$rrr'rrrrr s )r�sysr"�r�__all__�objectrrrrr�s