3
\ @ s d dl Z d dlZd dlZd dlZd dlZddlmZmZmZ ddl m
Z
ddl m Z dgZ dZ
ejdkoreed d
Zejj jd ZG d d deZdS )
N ) reductionget_spawning_popenset_spawning_popen)spawn)utilPopeni Zwin32frozenFzpythonservice.exec @ s> e Zd ZdZdZdd Zdd Zddd Zd
d Zd d
Z dS )r z@
Start a subprocess to run the code of a process object
r c C s t j|j}tjd d\}}tj|d}t jtj |d}dj
dd |D }t |ddd}y4tj t j
|d d d dd d d \}} }
} tj| W n tj| Y nX |
| _d | _|| _t|| _tj| tj| jf t| z tj|| tj|| W d td X W d Q R X d S )
Nr )Z
parent_pidZ pipe_handle c s s | ]}d | V qdS )z"%s"N ).0xr r 9/usr/lib64/python3.6/multiprocessing/popen_spawn_win32.py ) s z!Popen.__init__..wbT)closefdF)r Zget_preparation_data_name_winapiZ
CreatePipemsvcrtZopen_osfhandleZget_command_lineosgetpidjoinopenZ
CreateProcessZget_executableZ CloseHandlepid
returncode_handleintsentinelr ZFinalizer r dump) selfZ process_objZ prep_dataZrhandleZwhandleZwfdcmdZto_childZhpZhtr tidr r r __init__ s2
zPopen.__init__c C s t j|| jS )N)r Z duplicater )r Zhandler r r duplicate_for_childE s zPopen.duplicate_for_childNc C st | j d krn|d krtj}ntdt|d d }tjt| j|}|tjkrntj| j}|t krht
j }|| _ | j S )Nr i g ?) r r ZINFINITEmaxr ZWaitForSingleObjectr Z
WAIT_OBJECT_0ZGetExitCodeProcess TERMINATEsignalSIGTERM)r timeoutZmsecsrescoder r r waitI s
z
Popen.waitc C s | j ddS )Nr )r( )r+ )r r r r pollY s z
Popen.pollc C sL | j d krHytjt| jt W n& tk
rF | jddd krB Y nX d S )Ng ?)r( )r r ZTerminateProcessr r r% OSErrorr+ )r r r r terminate\ s
zPopen.terminate)N)
__name__
__module__ __qualname____doc__methodr" r# r+ r, r. r r r r r s %
)r r r& sysr contextr r r r r __all__r% platformgetattrZWINEXE
executablelowerendswithZ
WINSERVICEobjectr r r r r s