ff/ D 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 g d Zd
Z ej d Z G d d
e ZddZd Zd Zd Z e Zej Z ej Z ej Z ej Z dS ) N )
connection)process) reduction)resource_tracker)spawn)util)ensure_runningget_inherited_fdsconnect_to_new_processset_forkserver_preload qc 8 e Zd Zd Zd Zd Zd Zd Zd Zd Z dS )
ForkServerc ~ d | _ d | _ d | _ d | _ t j | _ dg| _ d S )N__main__)_forkserver_address_forkserver_alive_fd_forkserver_pid_inherited_fds threadingLock_lock_preload_modulesselfs A/opt/alt/python311/lib64/python3.11/multiprocessing/forkserver.py__init__zForkServer.__init__" sA #' $(! # " ^%%
!+ c n | j 5 | d d d d S # 1 swxY w Y d S N)r _stop_unlockedr s r _stopzForkServer._stop* s
Z " " ! ! ! " " " " " " " " " " " " " " " " " "s *..c | j d S t j | j d | _ t j | j d d | _ t j | j st j | j d | _ d S )Nr ) r oscloser waitpidr is_abstract_socket_namespacer unlinkr s r r# zForkServer._stop_unlocked/ s ' F *+++$(!
4'+++ # 01IJJ 0 Id. / / /#' r c d t d |D st d || _ dS )z>Set list of module names to try to load in forkserver process.c 3 B K | ]}t | t u V d S r" )typestr).0mods r <genexpr>z4ForkServer.set_forkserver_preload.<locals>.<genexpr>@ s- ==499#======r z&module_names must be a list of stringsN)all TypeErrorr )r
modules_namess r r
z!ForkServer.set_forkserver_preload> s? ==}===== F DEE E - r c | j S )zReturn list of fds inherited from parent process.
This returns None if the current process was not started by fork
server.
)r r s r r z ForkServer.get_inherited_fdsD s
""r c | t | dz t k rt d t j t j 5 }| | j t j \ }}t j \ }}||| j
t j g}||z
} t j || ||ft j | t j | cddd S # t j | t j | xY w# t j | t j | w xY w# 1 swxY w Y 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
lenMAXFDS_TO_SEND
ValueErrorsocketAF_UNIXconnectr r& piper r getfdr sendfdsr' )r fdsclientparent_rchild_wchild_rparent_wallfdss r r z!ForkServer.connect_to_new_processL s
s88a<> ) ) ^,, ,
]6>
*
* "f NN43 4 4 4 " Hg " GX w(A&,..0F cMF
"!&&111 ) !!!!!!! " " " " " " " "
""""""!!!!!!!! " " " " " " " " " "s7 A(E.D (E.+D>>E*E++E..E25E2c | j 5 t j | j et j | j t j \ }}|s ddd dS t j | j d| _ d| _ d| _ d}| j
r9ddh t j d } fd|
D }ni }t j t j 5 }t! j d }| | t' j | st j |d | t j \ }} | |g} || || j
|fz }t j }
|
gt' j z } | d |gz
} t' j |
| | }n# t j | xY w t j | n# t j | w xY w|| _ || _ || _ ddd n # 1 swxY w Y ddd dS # 1 swxY w Y dS )
zMake 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_pathsys_pathignorec $ i | ] \ }}|v ||
S rM )r/ xy desired_keyss r
<dictcomp>z-ForkServer.ensure_running.<locals>.<dictcomp> s) KKKAl9J9J19J9J9Jr r< i z-c) r r r
r r& r( WNOHANGr' r r r r get_preparation_dataitemsr; r< r arbitrary_addressbindr r) chmodlistenr> filenoget_executable _args_from_interpreter_flagsspawnv_passfds)
r pidstatuscmddatalisteneraddressalive_ralive_w fds_to_passexeargsrP s
@r r
zForkServer.ensure_runningi s Z 1 + 1 + + - - -#/ j)=rz J J V 1 + 1 + 1 + 1 + 1 + 1 + 1 + 1 + 2333+/(,0)'+$,C $
+Z 8 1(;;KKKK KKK v~..
+($6yAA
g&&&8AA -HWe,,,!!! $&799 &#+??#4#4g">KHOO - -w8M " "C .00C 54#D#F#FFDT3K'D -c4EECCHW%%%
HW%%%%BHW%%%%+2(,3)'*$3
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+11 + 1 + 1 + 1 + 1 + 1 + 1 + 1 + 1 + 1 + 1 + 1 + 1 + 1 + 1 + 1 + 1 + 1 +si AI)BI)+A=I)A=G'&H'G>>HIH--I I)I I)I I))I-0I-N)
__name__
__module__ __qualname__r r$ r# r
r r r
rM r r r r s} - - -" " "
(
(
( . . . # # #" " ":8+ 8+ 8+ 8+ 8+r r c
|rd|v r[|Ydt j _ t j | t j `n# t j `w xY w|D ]"} t | # t $ r Y w xY wt j t j
\ }}t j |d t j |d d }t j
|t j t j i} d | D }
t j | i } t% j t$ j | 5 } t) j 5 }
| t. _ |
| t( j |
|t( j |
|t( j d |
D }|rn"||v r*t j |d d
k s
J d t: ||v rt j |d t j d
t j \ }}n# t@ $ r Y nw xY w|dk rn{| ! |d }|Kt j" | } tG || n# tH $ r Y nw xY wt j% | ntM j' d|z | |v r| ( d 5 }tS j* |tV d z }tY | tV k r/t[ d. tY | |^}}}|% t j/ }|dk rd } | % |
% ||||g}|0 | 1 te ||||
}nM# tf $ r@ ti j5 ti j6 th j7 8 Y nw xY wt j9 | nm# t j9 | w xY w tG || n# tH $ r Y nw xY w|| |< t j% | |D ]}t j% | ddd n # 1 swxY w Y n-# tt $ r }|j; tv j< k r Y d}~nd}~ww xY wY# 1 swxY w Y ddd dS # 1 swxY w Y dS )zRun forkserver.r NTFc d S r" rM )_unuseds r sigchld_handlerz main.<locals>.sigchld_handler s r c @ i | ]\ }}|t j || S rM )signal)r/ sigvals r rQ zmain.<locals>.<dictcomp> s: 8 8 8"c sC00 8 8 8r )rY c " g | ] \ }}|j
S rM )fileobj)r/ keyeventss r
<listcomp>zmain.<locals>.<listcomp> s OOOMS&CKOOOr r r z Not at EOF?i r z.forkserver: waitpid returned unexpected pid %dz Too many ({0:n}) fds to send)=r current_process _inheritingr import_main_path
__import__ ImportErrorr _close_stdinr& r> set_blockingrp SIGCHLDSIGINTSIG_IGNrT
set_wakeup_fdr; r< selectorsDefaultSelector getsockname _forkserverr register
EVENT_READselectread
SystemExitr( rR ChildProcessErrorpopwaitstatus_to_exitcode write_signedBrokenPipeErrorr' warningswarnacceptr recvfdsr9 r8 RuntimeErrorformatforkextendvalues
_serve_one Exceptionsys
excepthookexc_infostderrflush_exitOSErrorerrno ECONNABORTED) listener_fdrc preloadrI rJ modnamesig_rsig_wrn handlers old_handlers pid_to_fdra selectorrfdsr] stsrD
returncodesrA rE code
unused_fdsfdes r mainr s Y%:48G # % % 1
:&y111+--99G+--99999 G
7####
799LE5OE5!!!OE5!!!
v~
H 8 8&.nn&6&68 8 8L I v~k : : : Yh " $ $Y(0*2*>*>*@*@ '(I$8999'9#7888%!5666Q P
OOX__=N=NOOOD
d?? 77A..#555}555$$D==GE5)))E"')z"bj'A'AHC 0 " " " !E" !88 !"+--T":":".)+)B3)G)GJ % ,Wj A A A A#2 % % % $ % HW - - - - %M +>@C+D E E E+E0 t##! **1- $- ' />A3E F F s88n44". > E E$'HH!. !.#/ #/ / 25.3 gii !88#$D / ( 0 0 0 ( 0 0 0.5wu-M
* 1 1)2B2B2D2D E E E'1'32<2>(@ (@ $- 3 3 3 # ? ? #
0 0 2 2 2 2 2 3 !# % ,Wc : : : :#2 % % % $ % .5IcN HW - - -&) - - " I$- $- $- $- $- $- $- $- $- $- $- $- $- $- $-L
7e 000 10000
_Q Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y YsC A
A 'A77
BBU)B U*A+T"I98T9
JTJ6T=K
T
KTKAT*BTA'P,+R,AQ6 3R5Q6 6R9TR$ $T(R98T9
S TS 5T; TT TT TU
T= T83U8T==UU U U
UU !U c ` t j d | D ]\ }}t j || |D ]}t j | |^t
_ t j _ t
_
t j | }t j
| | }|S )Nrx )rp r rT r& r' r r r _resource_tracker_fdr dupr _main) rE rA r r rq rr r parent_sentinelr s r r r + s
NN$$ S
c3
%("[%'+ fWooO ;w 0 0D Kr c d}t j }t | |k rNt j | |t | z
}|st d ||z
}t | |k Nt | d S )Nr zunexpected EOFr )
SIGNED_STRUCTsizer8 r& r EOFErrorunpack)r r` lengthr s r read_signedr B s D
F
d))f
GBT* + + -+,, , d))f
% %a ((r c t | }|r8t j | | }|dk rt d ||d }|6d S d S )Nr zshould not get here)r packr& writer )r nmsgnbytess r r r L sq
Q
C
"c"" Q;; 455 5&''l r )NN) r r& r rp r; structr r r r r contextr r r r __all__r9 Structr objectr r r r r r r
r r r
rM r r <module>r s
% % %
c""
A+ A+ A+ A+ A+ A+ A+ A+NA A A AH .) ) ) jll + 1 $; $; r