a
    ze                     @   s   d dl Z d dlZddlmZmZ ejs.edddl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_popenz,No support for sending fds between processes)
forkserver)
popen_fork)spawn)utilPopenc                   @   s   e Zd Zdd Zdd ZdS )_DupFdc                 C   s
   || _ d S N)ind)selfr    r   6/usr/lib/python3.9/multiprocessing/popen_forkserver.py__init__   s    z_DupFd.__init__c                 C   s   t  | j S r   )r   Zget_inherited_fdsr   )r   r   r   r   detach   s    z_DupFd.detachN)__name__
__module____qualname__r   r   r   r   r   r   r
      s   r
   c                       sB   e Zd ZdZeZ fddZdd Zdd Ze	j
fdd	Z  ZS )
r	   r   c                    s   g | _ t | d S r   )_fdssuperr   )r   process_obj	__class__r   r   r   !   s    zPopen.__init__c                 C   s   | j | t| j d S )Nr   )r   appendlen)r   fdr   r   r   duplicate_for_child%   s    zPopen.duplicate_for_childc                 C   s   t |j}t }t|  z$t|| t|| W td  n
td  0 t	| j
\| _}t|}t| tj|| jf| _t|ddd}||  W d    n1 s0    Y  t| j| _d S )NwbT)closefd)r   Zget_preparation_data_nameioBytesIOr   r   dumpr   Zconnect_to_new_processr   sentinelosdupr   Finalize	close_fds	finalizeropenwrite	getbufferread_signedpid)r   r   Z	prep_databufwZ	_parent_wfr   r   r   _launch)   s    

,zPopen._launchc              	   C   sp   | j d u rjddlm} |tjkr$dnd }|| jg|s:d S zt| j| _ W n tt	fyh   d| _ Y n0 | j S )Nr   )wait   )

returncodemultiprocessing.connectionr3   r%   WNOHANGr$   r   r-   OSErrorEOFError)r   flagr3   timeoutr   r   r   poll=   s    
z
Popen.poll)r   r   r   methodr
   DupFdr   r   r2   r%   r7   r<   __classcell__r   r   r   r   r	      s   )r!   r%   contextr   r   HAVE_SEND_HANDLEImportError r   r   r   r   __all__objectr
   r	   r   r   r   r   <module>   s   
