3
\p @ sp d dl Z d dlZddlmZmZ ddlmZ ddlmZ ddlmZ dgZ G dd d e
Z G d
d dej Z dS ) N ) reductionset_spawning_popen)
popen_fork)spawn)utilPopenc @ s e Zd Zdd Zdd ZdS )_DupFdc C s
|| _ d S )N)fd)selfr
r 9/usr/lib64/python3.6/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 Zd ZdZeZ fddZdd Zdd Z Z S )r r c s g | _ t j| d S )N)_fdssuperr )r process_obj) __class__r r
r s zPopen.__init__c C s | j j| |S )N)r append)r r
r r r
duplicate_for_child" s zPopen.duplicate_for_childc
C s@ ddl m} |j }| jj| tj|j}tj }t
| z t j || t j || W d t
d X d } } }} z~t
j \}}t
j \}} tj||d}
| jj||g tjtj |
| j| _|| _t| ddd} | j|j W d Q R X W d |d k rtj| t
j|f x(||| fD ]} | d k r t
j| q W X d S )Nr )semaphore_tracker)
tracker_fdZ pipe_handlewbF)closefd) r Zgetfdr r r Zget_preparation_data_nameioBytesIOr r dumpospipeZget_command_lineextendr Zspawnv_passfdsZget_executablepidsentinelopenwrite getbufferZFinalizeclose)
r r r r Z prep_datafpZparent_rZchild_wZchild_rZparent_wcmdfr
r r r
_launch& s6
z
Popen._launch)
r r r methodr ZDupFdr r r.
__classcell__r r )r r
r s
)
r r" contextr r r r r r __all__objectr r r r r r
s