File: //lib64/python3.8/multiprocessing/__pycache__/popen_fork.cpython-38.pyc
U
e5d
ã @ s6 d dl Z d dlZddlmZ dgZG dd„ deƒZdS )é Né )ÚutilÚPopenc @ s` e Zd ZdZdd„ Zdd„ Zejfdd„Zdd d
„Z d d „ Z
d
d„ Z dd„ Z dd„ Z
dd„ ZdS )r Úforkc C s" t ¡ d | _d | _| |¡ d S ©N)r Z_flush_std_streamsÚ
returncodeÚ finalizerÚ_launch)ÚselfÚ process_obj© r ú2/usr/lib64/python3.8/multiprocessing/popen_fork.pyÚ__init__ s zPopen.__init__c C s |S r r )r
Úfdr r r
Úduplicate_for_child s zPopen.duplicate_for_childc
C s˜ | j d kr’zt | j|¡\}}W n( tk
rH } z
W Y ¢d S d }~X Y nX || jkr’t |¡rnt |¡ | _ n$t |¡s†td |¡ƒ‚t
|¡| _ | j S )NzStatus is {:n}) r ÚosÚwaitpidÚpidÚOSErrorÚ WIFSIGNALEDÚWTERMSIGÚ WIFEXITEDÚAssertionErrorÚformatÚ WEXITSTATUS)r
Úflagr ÚstsÚer r r
Úpoll s
z
Popen.pollNc C sN | j d krH|d k r0ddlm} || jg|ƒs0d S | |dkrBtjnd¡S | j S )Nr )Úwaitg )r Zmultiprocessing.connectionr Úsentinelr r ÚWNOHANG)r
Útimeoutr r r r
r ( s
z
Popen.waitc C sZ | j d krVzt | j|¡ W n8 tk
r0 Y n& tk
rT | jddd krP‚ Y nX d S )Ngš™™™™™¹?)r" )r r Úkillr ÚProcessLookupErrorr r )r
Zsigr r r
Ú _send_signal2 s
zPopen._send_signalc C s | tj¡ d S r )r% ÚsignalÚSIGTERM©r
r r r
Ú terminate< s zPopen.terminatec C s | tj¡ d S r )r% r& ÚSIGKILLr( r r r
r# ? s z
Popen.killc C s˜ d}t ¡ \}}t ¡ \}}t ¡ | _| jdkrdz$t |¡ t |¡ |j|d}W 5 t |¡ X n0t |¡ t |¡ t | tj ||f¡| _
|| _ d S )Nr r )Zparent_sentinel) r Úpiper r Ú_exitÚcloseÚ
_bootstrapr ZFinalizeZ close_fdsr r )r
r ÚcodeZparent_rZchild_wZchild_rZparent_wr r r
r B s
ÿz
Popen._launchc C s | j d k r| ¡ d S r )r r( r r r
r- U s
z Popen.close)N)Ú__name__Ú
__module__Ú __qualname__Úmethodr r r r! r r r% r) r# r r- r r r r
r s
)r r& Ú r Ú__all__Úobjectr r r r r
Ú<module> s