File: //lib64/python3.8/multiprocessing/__pycache__/forkserver.cpython-38.opt-1.pyc
U
e5dó0 ã @ sþ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
ddl m Z ddl m
Z
ddl mZ ddl mZ ddl mZ d d
d d gZd
Ze d¡ZG dd„ deƒZddd„Zdd„ Zdd„ Zdd„ Zeƒ Zej Z ej Z ej Z ej Z dS )é Né )Ú
connection)Úprocess)Ú reduction)Úresource_tracker)Úspawn)ÚutilÚensure_runningÚget_inherited_fdsÚconnect_to_new_processÚset_forkserver_preloadé Úqc @ sD e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zd d
„ Zd d „ Zd
d„ Z dS )Ú
ForkServerc C s. d | _ d | _d | _d | _t ¡ | _dg| _d S )NÚ__main__)Ú_forkserver_addressÚ_forkserver_alive_fdÚ_forkserver_pidÚ_inherited_fdsÚ threadingZLockÚ_lockÚ_preload_modules©Úself© r ú2/usr/lib64/python3.8/multiprocessing/forkserver.pyÚ__init__" s
zForkServer.__init__c C s | j | ¡ W 5 Q R X d S ©N)r Ú_stop_unlockedr r r r Ú_stop* s zForkServer._stopc C sV | j d krd S t | j¡ d | _t | j d¡ d | _ t | j¡sLt | j¡ d | _d S )Nr ) r ÚosÚcloser Úwaitpidr Ú is_abstract_socket_namespacer Úunlinkr r r r r / s
zForkServer._stop_unlockedc C s& t dd„ | jD ƒƒs tdƒ‚|| _dS )z>Set list of module names to try to load in forkserver process.c s s | ]}t |ƒtkV qd S r )ÚtypeÚstr)Ú.0Úmodr r r Ú <genexpr>@ s z4ForkServer.set_forkserver_preload.<locals>.<genexpr>z&module_names must be a list of stringsN)Úallr Ú TypeError)r Z
modules_namesr r r r > s z!ForkServer.set_forkserver_preloadc C s | j S )z”Return list of fds inherited from parent process.
This returns None if the current process was not started by fork
server.
)r r r r r r
D s z ForkServer.get_inherited_fdsc
C sà | ¡ t|ƒd tkr tdƒ‚t tj¡ª}| | j¡ t ¡ \}}t ¡ \}}||| j
t ¡ g}||7 }zNz&t ||¡ ||fW W ¢4W 5 Q R £ S t
|¡ t
|¡ ‚ Y nX W 5 t
|¡ t
|¡ X W 5 Q R X dS )a; Request forkserver to create a child process.
Returns a pair of fds (status_r, data_w). The calling process can read
the child process's pid and (eventually) its returncode from status_r.
The calling process should write to data_w the pickled preparation and
process data.
é z too many fdsN)r ÚlenÚMAXFDS_TO_SENDÚ
ValueErrorÚsocketÚAF_UNIXZconnectr r Úpiper r Zgetfdr! r Zsendfds)r ÚfdsZclientZparent_rÚchild_wÚchild_rZparent_wZallfdsr r r r L s( ÿ
z!ForkServer.connect_to_new_processc s | j ~ t ¡ | jdk r`t | jtj¡\}}|sBW 5 Q R £ dS t | j¡ d| _ d| _d| _d}| j
r”ddh‰ t d¡}‡ fdd„|
¡ D ƒ}ni }t tj¡Ø}t d¡}| |¡ t |¡sÐt |d ¡ | ¡ t ¡ \}}ztzV| ¡ |g} || ¡ || j
|f; }t ¡ }
|
gt ¡ } | d
|g7 } t |
| | ¡}W n t |¡ ‚ Y nX W 5 t |¡ X || _ || _|| _W 5 Q R X W 5 Q R X dS ) zíMake sure that a fork server is running.
This can be called from any process. Note that usually a child
process will just reuse the forkserver started by its parent, so
ensure_running() will do nothing.
NzCfrom multiprocessing.forkserver import main; main(%d, %d, %r, **%r)Ú main_pathÚsys_pathÚignorec s i | ]\}}|ˆ kr||“qS r r )r' ÚxÚy©Z desired_keysr r Ú
<dictcomp>„ s z-ForkServer.ensure_running.<locals>.<dictcomp>r1 i€ z-c) r r r r r r" ÚWNOHANGr! r r r r Zget_preparation_dataÚitemsr0 r1 r Zarbitrary_addressZbindr r# ÚchmodZlistenr2 ÚfilenoZget_executableZ _args_from_interpreter_flagsZspawnv_passfds) r ÚpidZstatusÚcmdÚdataÚlistenerZaddressÚalive_rZalive_wZ fds_to_passZexeÚargsr r; r r i sN
ÿ
zForkServer.ensure_runningN)
Ú__name__Ú
__module__Ú __qualname__r r r r r
r r r r r r r s r c C sà |rdd|kr8|dk r8dt ¡ _zt |¡ W 5 t ¡ `X |D ]&}z t|ƒ W q< tk
r` Y q<X q<t ¡ t
¡ \}}t |d¡ t |d¡ dd„ }t j
|t jt ji} dd„ | ¡ D ƒ}
t |¡ i } tjtj| d ú} t ¡ ä}
| ¡ t_|
| tj¡ |
|tj¡ |
|tj¡ znd
d „ |
¡ D ƒ}|r"qBq"||krPt ‚||krBt |d ¡ zt d
t j ¡\}}W n t k
r˜ Y qBY nX |dkr¨qB| !|d¡}|dk r0t "|¡rØt #|¡ }n&t $|¡sôt%d &||¡ƒ‚t '|¡}zt(||ƒ W n t)k
r" Y nX t *|¡ nt+ ,d| ¡ qf| |krŒ| -¡ d ,}t. /|t0d ¡}t1|ƒt0krŒt2d &t1|ƒ¡ƒ‚|^}}}| *¡ t 3¡ }|dkr4d}zpz<| *¡ |
*¡ ||||g}| 5| 6¡ ¡ t7||||
ƒ}W n. t8k
r t9j:t9 ;¡ Ž t9j< =¡ Y nX W 5 t 4|¡ X nNzt(||ƒ W n t)k
rX Y nX || |< t *|¡ |D ]}t *|¡ qpW 5 Q R X W n4 t>k
r } z|j?t?j@kr²‚ W 5 d}~X Y nX q W 5 Q R X W 5 Q R X dS )zRun forkserver.r NTFc W s d S r r )Z_unusedr r r Úsigchld_handler¼ s z main.<locals>.sigchld_handlerc S s i | ]\}}|t ||¡“qS r )Úsignal)r' ÚsigÚvalr r r r< Æ s ÿ zmain.<locals>.<dictcomp>)r@ c S s g | ]\}}|j ‘qS r )Zfileobj)r' ÚkeyZeventsr r r Ú
<listcomp>Ú s zmain.<locals>.<listcomp>i éÿÿÿÿr zChild {0:n} status is {1:n}z.forkserver: waitpid returned unexpected pid %dr z Too many ({0:n}) fds to send)Ar Zcurrent_processZ _inheritingr Zimport_main_pathÚ
__import__Ú ImportErrorr Z _close_stdinr r2 Ú set_blockingrK ÚSIGCHLDÚSIGINTÚSIG_IGNr> Ú
set_wakeup_fdr0 r1 Ú selectorsZDefaultSelectorZ getsocknameÚ _forkserverr ÚregisterZ
EVENT_READZselectÚ
SystemExitÚreadr" r= ÚChildProcessErrorÚpopÚ WIFSIGNALEDÚWTERMSIGÚ WIFEXITEDÚAssertionErrorÚformatÚ WEXITSTATUSÚ write_signedÚBrokenPipeErrorr! ÚwarningsÚwarnZacceptr Zrecvfdsr. r- Ú RuntimeErrorÚforkÚ_exitÚextendÚvaluesÚ
_serve_oneÚ ExceptionÚsysÚ
excepthookÚexc_infoÚstderrÚflushÚOSErrorÚerrnoZ ECONNABORTED)Z listener_fdrE Zpreloadr6 r7 ÚmodnameZsig_rZsig_wrJ ÚhandlersZ old_handlersZ pid_to_fdrD ZselectorZrfdsrA Ústsr4 Ú
returncodeÚsr3 r5 ÚcodeÚ
unused_fdsÚfdÚer r r Úmain§ sÔ
üÿ
ÿ
ÿÿ
ÿ
ÿÿ
þ
r€ c C sh t d¡ | ¡ D ]\}}t ||¡ q|D ]}t |¡ q,|^t_tj_ t_
t | ¡}t
| |¡}|S )NrP )rK rW r> r r! rY r r Z_resource_trackerZ_fdr Údupr Z_main) r5 r3 r} rx rL rM r~ Zparent_sentinelr| r r r rn 1 s
þ
rn c C sN d}t j}t|ƒ|k r@t | |t|ƒ ¡}|s6tdƒ‚||7 }q
t |¡d S )Nó zunexpected EOFr )Ú
SIGNED_STRUCTÚsizer- r r\ ÚEOFErrorZunpack)r~ rC Zlengthr{ r r r Ú read_signedH s
r† c C s< t |¡}|r8t | |¡}|dkr*tdƒ‚||d … }q
d S )Nr zshould not get here)rƒ Zpackr Úwriteri )r~ ÚnÚmsgÚnbytesr r r re R s
re )NN) rv r rX rK r0 Zstructrp r rg Ú r r Úcontextr r r r Ú__all__r. ZStructrƒ Úobjectr r€ rn r† re rY r r
r r r r r r Ú<module> s> ÿ