B
     S]                 @   sp   d dl Z d dlZddlmZmZ ddlmZ ddlmZ ddlmZ dgZ	G dd	 d	e
ZG d
d dejZdS )    N   )	reductionset_spawning_popen)
popen_fork)spawn)utilPopenc               @   s   e Zd Zdd Zdd ZdS )_DupFdc             C   s
   || _ d S )N)fd)selfr
    r   2lib/python3.7/multiprocessing/popen_spawn_posix.py__init__   s    z_DupFd.__init__c             C   s   | j S )N)r
   )r   r   r   r   detach   s    z_DupFd.detachN)__name__
__module____qualname__r   r   r   r   r   r   r	      s   r	   c                   s4   e Zd ZdZeZ fddZdd Zdd Z  Z	S )r   r   c                s   g | _ t | d S )N)_fdssuperr   )r   process_obj)	__class__r   r   r      s    zPopen.__init__c             C   s   | j | |S )N)r   append)r   r
   r   r   r   duplicate_for_child"   s    zPopen.duplicate_for_childc             C   sB  ddl m} | }| j| t|j}t	 }t
|  zt|| t|| W d t
d  X d  } } }}	z~t \}}t \}}	tj||d}
| j||g tt |
| j| _|| _t|	ddd}||  W d Q R X W d |d k	rt| tj|f| _x(|||	fD ]}|d k	rt| qW X d S )Nr   )semaphore_tracker)
tracker_fdZpipe_handlewbF)closefd) r   Zgetfdr   r   r   Zget_preparation_data_nameioBytesIOr   r   dumpospipeZget_command_lineextendr   Zspawnv_passfdsZget_executablepidsentinelopenwrite	getbufferZFinalizeclose	finalizer)r   r   r   r   Z	prep_datafpZparent_rZchild_wZchild_rZparent_wcmdfr
   r   r   r   _launch&   s6    



zPopen._launch)
r   r   r   methodr	   ZDupFdr   r   r/   __classcell__r   r   )r   r   r      s
   )r   r"   contextr   r   r   r   r   r   __all__objectr	   r   r   r   r   r   <module>   s   
