U
iÛf
ã @ 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 ú?/opt/alt/python38/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 krzzt | j|¡\}}W n( tk
rH } z
W Y ¢d S d }~X Y nX || jkrzt |¡rnt |¡ | _ n t |¡| _ | j S r )r ÚosÚwaitpidÚpidÚOSErrorÚ WIFSIGNALEDÚWTERMSIGÚ 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
Ú s