File: //usr/lib/python3.5/multiprocessing/__pycache__/popen_forkserver.cpython-35.pyc
Fa @ 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)utilPopenc @ 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.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)_fdssuperr )r process_obj) __class__r
r r " s zPopen.__init__c C s! | j j | t | j d S)Nr )r appendlen)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)NwbclosefdT)r Zget_preparation_data_nameioBytesIOr Zset_spawning_popenr dumpr Zconnect_to_new_processr sentinelr ZFinalizeoscloseopenwrite getbuffer
read_unsignedpid)r r Z prep_dataZbufwfr
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( OSErrorEOFError)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