��Yf� � @ s� d d l Z d d l Z d d l 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 d l m
Z
d
g Z Gd d � d e � Z
Gd
d
� d
e j � Z d S)� N� )� reductionz,No support for sending fds between processes)�context)�
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
�E/opt/alt/python35/lib64/python3.5/multiprocessing/popen_forkserver.py�__init__ s z_DupFd.__init__c C s t j � | j S)N)r Zget_inherited_fdsr )r r
r
r �detach s z
_DupFd.detachN)�__name__�
__module__� __qualname__r r r
r
r
r r
s r
c sX e Z d Z d Z e Z � f d d � Z d d � Z d d � Z e j
d d � Z � S)
r r c s g | _ t � j | � d S)N)�_fds�superr )r � process_obj)� __class__r
r r " s zPopen.__init__c C s! | j j | � t | j � d S)Nr )r �append�len)r �fdr
r
r �duplicate_for_child& s zPopen.duplicate_for_childc C s� t j | j � } t j � } t j | � z$ t j | | � t j | | � Wd t j d � Xt j
| j � \ | _ } t
j | t j | j f � t | d d d �� } | j | j � � Wd QRXt j | j � | _ d S)N�wb�closefdT)r Zget_preparation_data�_name�io�BytesIOr Zset_spawning_popenr �dumpr Zconnect_to_new_processr �sentinelr ZFinalize�os�close�open�write� getbuffer�
read_unsigned�pid)r r Z prep_dataZbuf�w�fr
r
r �_launch* s
z
Popen._launchc C s� | j d k r� d d l m } | t j k r4 d n d } | | j g | � sS d Sy t j | j � | _ Wn! t t f k
r� d | _ Yn X| j S)Nr )�wait� )
�
returncodeZmultiprocessing.connectionr- r# �WNOHANGr" r r( �OSError�EOFError)r Zflagr- Ztimeoutr
r
r �poll: s z
Popen.poll) r r r �methodr
ZDupFdr r r, r# r0 r3 r
r
)r r r s )r r# � r ZHAVE_SEND_HANDLE� ImportErrorr r r r r �__all__�objectr
r r
r
r
r �<module> s