֦i/ b 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 Zej8 Z ej: Z ej< Z ej> Z y) N )
connection)process) reduction)resource_tracker)spawn)util)ensure_runningget_inherited_fdsconnect_to_new_processset_forkserver_preload qc 6 e Zd Zd Zd Zd Zd Zd Zd Zd Z y)
ForkServerc ~ d | _ d | _ d | _ d | _ t j
| _ dg| _ y )N__main__)_forkserver_address_forkserver_alive_fd_forkserver_pid_inherited_fds threadingLock_lock_preload_modulesselfs 3/usr/lib64/python3.12/multiprocessing/forkserver.py__init__zForkServer.__init__" s: #' $(! # " ^^%
!+ c f | j 5 | j d d d y # 1 sw Y y xY wN)r _stop_unlockedr s r _stopzForkServer._stop* s
ZZ ! ZZs '0c B | j y t j | j d | _ t j | j d d | _ t j | j s t j | j d | _ y )Nr ) r oscloser waitpidr is_abstract_socket_namespacer unlinkr s r r# zForkServer._stop_unlocked/ sw ' **+$(!
4''+ # 001I1IJ IId.. /#' r c L t d |D s t d || _ y)z>Set list of module names to try to load in forkserver process.c 3 > K | ] }t | t u y wr" )typestr).0mods r z4ForkServer.set_forkserver_preload..@ s =}49#}s z&module_names must be a list of stringsN)all TypeErrorr )r
modules_namess r r
z!ForkServer.set_forkserver_preload> s$ =}== DE 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 | j t | dz t k\ r t d t j t j
5 }|j
| 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 sw Y yxY w)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
s8a<> ) ^, ,
]]6>>
*f NN433 4 " Hg " GX w(A(A&,,.0F cMF
"!!&&1 ) !!! +
*
""!!! +
*s1 A1E2D *E2-E E,E//E22E;c 4 | j 5 t j | j qt j
| j t j \ }}|s
ddd yt j | j d| _ d| _ d| _ d}| j rBddh}t j d }|j D ci c]
\ }}||v s || }}}ni }t j t j 5 }t! j" d } |j% | t' j( | st j* | d |j- t j. \ }
} |j1 |
g} ||j1 |
| j |fz }t j2 }
|
gt' j4 z }|d|gz
}t' j6 |
|| } t j |
| | _ | | _ || _ ddd ddd yc c}}w # t j | xY w# t j |
w xY w# 1 sw Y MxY w# 1 sw Y yxY w) 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_pathignorer< 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 pidstatuscmd desired_keysdataxylisteneraddressalive_ralive_w fds_to_passexeargss r r
zForkServer.ensure_runningi s& ZZ + + -##/ jj)=)=rzz J V Z 223+/(,0)'+$,C $$ +Z 8 11(;)- K Al9J1 K v~~.($66yA
g&88AHHWe,! $&779 &#+??#4g">KHOO -w8M8M " "C ..0C 54#D#D#FFDT3K'D --c4EC
HHW%+2(,3)'*$3 /1 Z( L,HHW%HHW%- /.1 Zsi AJ+A.J I&I+)JA9JA=I
*J6JJ
I%%I((I??JJ JJN)
__name__
__module__ __qualname__r r$ r# r
r r r
r r r r s% -"
( . #":8+r r c
|rq||t j dd d|v rE|Cdt j _ t j | t j `|D ] } t | t j t j \ }}t j |d t j |d d }t j |t j t j" i} | j% D
ci c] \ }
} |
t j |
| } }
} t j& | i }
t) j( t( j* | 5 }t- j. 5 }|j1 t2 _ |j7 |t, j8 |j7 |t, j8 |j7 |t, j8 |j; D cg c] \ }}|j< }}}|rn0||v rt> ||v rt j@ |d t jB dt jD \ }}|d k( rne|
jI |d }|8t jJ | } tM || t jP | ntS jT d
|z ||v rK|jW d 5 }tY jZ |t\ d z }t_ | t\ kD r#ta d jc t_ | |^}}}|jQ t jd }|d k( rld } |jQ |jQ ||||g}|jg |
ji tk |||| }t jv | nC tM || ||
|< t jP | |D ] } t jP | ddd <# t j `w xY w# t $ r Y w xY wc c} }
w c c}}w # tF $ r Y w xY w# tN $ r Y w xY w# tl $ rF t jn t jp t jr ju Y w xY w# t jv | w xY w# tN $ r Y
w xY w# 1 sw Y xY w# tx $ r)} | jz tz j| k7 r Y d} ~ d} ~ ww xY w# 1 sw Y nxY w ddd y# 1 sw Y yxY w)
zRun forkserver.Nr TFc y r" rh )_unuseds r sigchld_handlerz main..sigchld_handler s r )rS i r z.forkserver: waitpid returned unexpected pid %dr z Too many ({0:n}) fds to send)?syspathr current_process _inheritingr import_main_path
__import__ ImportErrorr _close_stdinr& r> set_blockingsignalSIGCHLDSIGINTSIG_IGNrN
set_wakeup_fdr; r< selectorsDefaultSelector getsockname _forkserverr register
EVENT_READselectfileobj
SystemExitreadr( rL ChildProcessErrorpopwaitstatus_to_exitcode write_signedBrokenPipeErrorr' warningswarnacceptr recvfdsr9 r8 RuntimeErrorformatforkextendvalues
_serve_one Exception
excepthookexc_infostderrflush_exitOSErrorerrno ECONNABORTED) listener_fdr` preloadrI rJ modnamesig_rsig_wrl handlerssigval old_handlers pid_to_fdr^ selectorkeyeventsrfdsrW stsrD
returncodesrA rE code
unused_fdsfdes r mainr s "CHHQK Y%:48G # # % 1
:&&y1++-9 G
7# 779LE5OOE5!OOE5!
v~~
H '/nn&68&6
c sC00&6 8 I v~~k :h " " $*2*>*>*@ '(I$8$89'9#7#78%!5!56P
=E__=NO=NMS&CKK=NDO
d? %$D=GGE5) "')zz"bjj'AHC !8 !"+--T":".)+)B)B3)GJ % ,Wj A HHW - %MM +>@C+D E+ 0 t#! *1- ' / />A3E F s8n4". > E E$'H!.#/ / 25.3 ggi !8#$D / ( 0 ( 0.5wu-M
* 1 1)2B2B2D E'1'32<2>(@ !# % ,Wc : .5IcN HHW -&) " '*G .S Q ++-9
&8( P 1 " !" $3 % $ %@ $- 3 # ? #
0 0 2 3 !#
$3 % $ %= .-L
77e 0 00 1
m
% $ $
; : :s6 P= ' Q!Q&1U%A;UTQ,
,,T'Q2 /T0 R=6T3T;U=Q Q#"Q#,T2 Q?;T>Q??T R TRTA S! S$ S! !S$$S; ;T> T T
T TT T U # UUU UU U%%U.c n t j d |j D ] \ }}t j || |D ] }t j | |^t
_ t j _ t
_
t j | }t j | | }|S )Nrm )rw r{ rN r& r' r r r _resource_tracker_fdr dupr _main) rE rA r r r r r parent_sentinelr s r r r - s
NN$S
c3 %
%("[%''+ ffWoO ;;w 0D Kr c d}t j }t | |k rCt j | |t | z
}|s t d ||z
}t | |k rCt j
| d S )Nr zunexpected EOFr )
SIGNED_STRUCTsizer8 r& r EOFErrorunpack)r r[ lengthr s r read_signedr D su D
F
d)f
GGBT* ++, , d)f
%a ((r c t j | }|r/t j | | }|dk( r t d ||d }|r.y y )Nr zshould not get here)r packr& writer )r nmsgnbytess r r r N sH
Q
C
"c" Q; 45 5&'l r )NN) r r& r| rw r; structrn r r r r contextr r r r __all__r9 Structr objectr r r r r r r
r r r
rh r r r s
%
c"
A+ A+NCL.) l ++ 11 $;; $;; r