← Back
Editing: popen_forkserver.cpython-35.pyc
��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
Save File
Cancel