
][\                 @   s   d  d l  Z  d  d l Z d d l m Z e j s@ e d   n  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   6/usr/lib/python3.4/multiprocessing/popen_forkserver.py__init__   s    z_DupFd.__init__c             C   s   t  j   |  j S)N)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                   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    	zPopen.__init__c             C   s!   |  j  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 | 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  QXt	 j |  j  |  _ d  S)NwbclosefdT)r   Zget_preparation_data_nameioBytesIOr   Zset_spawning_popenr   dumpr   Zconnect_to_new_processr   sentinelr   ZFinalizeoscloseopenwrite	getbufferread_unsignedpid)r   r   Z	prep_dataZbuf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  |  _  Wq t t	 f k
 r d |  _  Yq Xn  |  j  S)Nr   )wait   )

returncodeZmultiprocessing.connectionr-   r#   WNOHANGr"   r   r(   OSErrorEOFError)r   Zflagr-   Ztimeoutr   r   r   poll:   s    z
Popen.poll)r   r   r   methodr
   ZDupFdr   r   r,   r#   r0   r3   r   r   )r   r   r	      s   )r   r#    r   ZHAVE_SEND_HANDLEImportErrorr   r   r   r   r   __all__objectr
   r	   r   r   r   r   <module>   s   		
