File: //opt/alt/python38/lib64/python3.8/multiprocessing/__pycache__/popen_fork.cpython-38.pyc
U
i�f
� @ s6 d dl Z d dlZddlmZ dgZG dd� de�ZdS )� N� )�util�Popenc @ s` e Zd ZdZdd� Zdd� Zejfdd�Zdd d
�Z d d � Z
d
d� Z dd� Z dd� Z
dd� ZdS )r �forkc C s" t �� d | _d | _| �|� d S �N)r Z_flush_std_streams�
returncode� finalizer�_launch)�self� process_obj� r �?/opt/alt/python38/lib64/python3.8/multiprocessing/popen_fork.py�__init__ s zPopen.__init__c C s |S r r )r
�fdr r r
�duplicate_for_child s zPopen.duplicate_for_childc
C s� | j d kr�zt�| j|�\}}W n( tk
rH } z
W Y �d S d }~X Y nX || jkr�t�|�rnt�|� | _ n$t�|�s�td� |���t�
|�| _ | j S )NzStatus is {:n}) r �os�waitpid�pid�OSError� WIFSIGNALED�WTERMSIG� WIFEXITED�AssertionError�format� WEXITSTATUS)r
�flagr �sts�er r r
�poll s
z
Popen.pollNc C sN | j d krH|d k r0ddlm} || jg|�s0d S | �|dkrBtjnd�S | j S )Nr )�waitg )r Zmultiprocessing.connectionr �sentinelr r �WNOHANG)r
�timeoutr r r r
r ( s
z
Popen.waitc C sZ | j d krVzt�| j|� W n8 tk
r0 Y n& tk
rT | jdd�d krP� Y nX d S )Ng�������?)r" )r r �killr �ProcessLookupErrorr r )r
Zsigr r r
� _send_signal2 s
zPopen._send_signalc C s | � tj� d S r )r% �signal�SIGTERM�r
r r r
� terminate< s zPopen.terminatec C s | � tj� d S r )r% r& �SIGKILLr( r r r
r# ? s z
Popen.killc C s� d}t �� \}}t �� \}}t �� | _| jdkrdz$t �|� t �|� |j|d�}W 5 t �|� X n0t �|� t �|� t�| tj ||f�| _
|| _ d S )Nr r )Zparent_sentinel) r �piper r �_exit�close�
_bootstrapr ZFinalizeZ close_fdsr r )r
r �codeZparent_rZchild_wZchild_rZparent_wr r r
r B s
�z
Popen._launchc C s | j d k r| � � d S r )r r( r r r
r- U s
z Popen.close)N)�__name__�
__module__� __qualname__�methodr r r r! r r r% r) r# r r- r r r r
r s
)r r& � r �__all__�objectr r r r r
�<module> s