*j*4 t S SK r S SKrS SKrS SKrS SKrS SKrS SKrS SKrS SKrS SK r SSK
J r SSK
J r SSK
Jr SSK
Jr SSK
Jr SSK
Jr / S QrS
r\R( " S 5 r " S S
\5 rSSS.S jjrS rS rS r\" 5 r \ R: r \ R< r \ R> r \ R@ r g) N )
connection)process) reduction)resource_tracker)spawn)util)ensure_runningget_inherited_fdsconnect_to_new_processset_forkserver_preload qc > \ rS rSrS rS rS rS rS rS r S r
S r g
)
ForkServer! c S U l S U l S U l S U l [ R
" 5 U l S/U l g )N__main__)_forkserver_address_forkserver_alive_fd_forkserver_pid_inherited_fds threadingLock_lock_preload_modulesselfs A/opt/alt/python313/lib64/python3.13/multiprocessing/forkserver.py__init__ForkServer.__init__# s: #' $(! # " ^^%
!+ c p U R U R 5 S S S 5 g ! , ( d f g = fN)r _stop_unlockedr s r _stopForkServer._stop+ s
ZZ ! ZZs '
5c V U R c g [ R " U R 5 S U l [ R " U R S5 S U l [
R " U R 5 ( d [ R " U R 5 S U l g )Nr ) r oscloser waitpidr is_abstract_socket_namespacer unlinkr s r r% ForkServer._stop_unlocked0 sz ' **+$(!
4''+ # 001I1IJJ IId.. /#' r" c T [ S U 5 5 ( d [ S5 eXl g)z>Set list of module names to try to load in forkserver process.c 3 D # U H n[ U5 [ L v M g 7fr$ )typestr).0mods r 4ForkServer.set_forkserver_preload..A s =}49#}s z&module_names must be a list of stringsN)all TypeErrorr )r
modules_namess r r
!ForkServer.set_forkserver_preload? s% =}=== DE E - r" c U R $ )z|Return 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 ForkServer.get_inherited_fdsE s """r" c U R 5 [ U5 S- [ : a [ S5 e[ R " [ R
5 nUR
U R 5 [ R " 5 u p4[ R " 5 u pVXTU R [ R " 5 /nXq-
n [ R " X'5 X64[ R " U5 [ R " U5 sSSS5 $ ! [ R " U5 [ R " U5 e = f! [ R " U5 [ R " U5 f = f! , ( d f g= f)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 !ForkServer.connect_to_new_processM s
s8a<> ) ^, ,
]]6>>
*f NN433 4 " H " G (A(A&,,.0F MF
"!!&1 ) !!! +
*
""!!! +
*s1 A0E8D ,E8/EE.E55E88
Fc p U R [ R " 5 U R bw [ R
" U R [ R 5 u pU( d
SSS5 g[ R " U R 5 SU l SU l SU l Sn0 nSnU R ( a= [ R " S5 nSU; a US US' SU; a US US' SU; a US n[ R " [ R 5 n[ R " S5 nUR# U5 [$ R& " U5 ( d [ R( " US 5 UR+ 5 [ R, " 5 u p UR/ 5 U /n X7R/ 5 XR U4- n[ R0 " 5 n U /[$ R2 " 5 - n
U
S
U/-
n
Ub X-
n
[$ R4 " XU 5 n [ R " U 5 Xl Xl Xl SSS5 SSS5 g! [ R " U
5 e = f! [ R " U 5 f = f! , ( d f NN= f! , ( d f g= f) 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.
Nzfimport sys; from multiprocessing.forkserver import main; main(%d, %d, %r, sys_argv=sys.argv[1:], **%r)ignoresys_pathinit_main_from_path main_pathsys_argvrC i z-c)r r r
r r) r+ WNOHANGr* r r r r get_preparation_datarB rC r arbitrary_addressbindr r, chmodlistenrE filenoget_executable _args_from_interpreter_flagsspawnv_passfds)r pidstatuscmdmain_kwsrU datalisteneraddressalive_ralive_w fds_to_passexeargss r r
ForkServer.ensure_runningj s8 ZZ + + -##/ jj)=)=rzz J Z 223+/(,0)'+$CC HH$$ 11(; %+/
+;HZ((D0,01F,GH[) % #J /H v~~.($66yA
g&88AAHHWe,! $&779 &#+??#4g">KOO -w8M8M $ & &C ..0C 54#D#D#FFDT3K'D + ( --cEC
HHW%+2(,3)'*$7 /E ZlHHW%HHW%1 /.E ZsQ A J'2B-J' BJ!BI &(JJ' I88I;;JJ
J$ J''
J5)r r r r r r N) __name__
__module__ __qualname____firstlineno__r r& r% r
r r r
__static_attributes__ r" r r r ! s& -"
( . #":D+r" r )rU c
U( a Ub U[ R SS& Ub U[ R SS& SU; aI UbF S[ R " 5 l [ R " U5 [ R " 5 ?U H n [ U5 M [ R " 5 [ R " 5 [ R " 5 u px[ R " US5 [ R " US5 S n [ R" U [ R$ [ R& 0n
U
R) 5 V V s0 s H u pU [ R " X5 _M n
n n [ R* " U5 0 n[, R, " [, R. U S9 n[0 R2 " 5 nUR5 5 [6 l UR; U[0 R< 5 UR; U[0 R< 5 UR; U[0 R< 5 UR? 5 VVs/ s H u nnUR@ PM nnnU( a OM9 UU; a( [ RB " US5 S:X d S 5 e[D eUU; a [ RB " US
5 [ RF " S [ RH 5 u nnUS :X a OjURM US5 nUb: [ RN " U5 n [Q UU5 [ RT " U5 O[V RX " S
U- 5 M UU; Ga UR[ 5 S n[\ R^ " U[` S- 5 n[c U5 [` : a# [e SRg [c U5 5 5 eUtnnnURU 5 [ Rh " 5 nUS :X a Sn URU 5 URU 5 UUXx/n U Rk URm 5 5 [n Rp " 5 [n R: " [ Rr 5 [u UUU U
5 n[n R " 5 [ R " U5 OG [Q UU5 UUU' [ RT " U5 U H n [ RT " U 5 M SSS5 O GM ! [ R " 5 ?f = f! [ a GM f = fs sn n f s snnf ! [J a GM f = f! [R a GN6f = f! [v aH [ Rx " [ Rz " 5 6 [ R| R 5 GN,f = f! [n R " 5 [ R " U5 f = f! [R a GN4f = f! , ( d f GN= f! [ a* n U R [ R :w a e Sn A GN5Sn A ff = f! , ( d f O= fSSS5 g! , ( d f g= f)zRun forkserver.Nr TFc g r$ rr )_unuseds r sigchld_handler main..sigchld_handler s r" )r\ r r" z Not at EOF?i r z.forkserver: waitpid returned unexpected pid %dz Too many ({0:n}) fds to send)Esysargvpathr current_process _inheritingr import_main_path
__import__ ImportErrorr _flush_std_streams _close_stdinr) rE set_blockingsignalSIGCHLDSIGINTSIG_IGNitems
set_wakeup_fdrB rC selectorsDefaultSelector getsockname _forkserverr register
EVENT_READselectfileobjread
SystemExitr+ rV ChildProcessErrorpopwaitstatus_to_exitcode write_signedBrokenPipeErrorr* warningswarnacceptr recvfdsr@ r? RuntimeErrorformatforkextendvaluesatexit_clear_exit_function
_serve_one Exception
excepthookexc_infostderrflush_run_exitfuncs_exitOSErrorerrno ECONNABORTED) listener_fdrg preloadrT rR rU modnamesig_rsig_wrv handlerssigval old_handlers pid_to_fdre selectorkeyeventsrfdsr` stsrK
returncodesrH rL code
unused_fdsfdes r mainr s% "CHHQK "CHHQK Y%:48G # # % 1
:&&y1++-9 G
7#
!779LEOOE5!OOE5!
v~~
H '/nn&68&6
s00&6 8 I v~~k :h " " $*2*>*>*@ '(I$8$89'9#7#78%!5!56S
=E__=NO=NMS&CKK=NDO
d? 777A.#5D}D5$$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.5w-M
* 1 1)2B2B2D E &
&0C0C D'1'32<2>(@ !' 5 5 7 " % ,Wc : .5IcN HHW -&) " '*M .- $O Y ++-9
.8( P 1 " !" $3 % $ %D $- 3 # ? #
0 0 2 3 !' 5 5 7 "
$3 % $ %C .-R
77e 0 00 1
s
% $
; : :sD T
T'
#T9.Y!A;Y XT?
-AX(U/2X" U.A X:BW>B U(
,W>: W-:W> XY
T$'
T65T6?X
UXUX
U%!X$U%%X(AV: 6V=9V: :V==-W* *W>-
W; 7W>:W; ;W>>
X
X Y
X
Y X?9Y?YY
Y Y!!
Y/c z [ R " S5 UR 5 H u pE[ R " XE5 M U H n[ R " U5 M Ut[
l [ R l [
l
[ R " U 5 n[ R " X5 nU$ )Nrx )r r r r) r* r r r _resource_tracker_fdr dupr _main) rL rH r r r r r parent_sentinelr s r r r D s
NN$
c %
%("[%''+ ffWoO ;;w 0D Kr" c Sn[ R n[ U5 U: aI [ R " X[ U5 -
5 nU( d [ S5 eX-
n[ U5 U: a MI [ R
U5 S $ )Nr" zunexpected EOFr )
SIGNED_STRUCTsizer? r) r EOFErrorunpack)r rd lengthr s r read_signedr [ sq D
F
d)f
GGBT* ++, , d)f
%a ((r" c [ R U5 nU( a5 [ R " X5 nUS:X a [ S5 eX#S nU( a M4 g g )Nr zshould not get here)r packr) writer )r nmsgnbytess r r r e sF
Q
C
"" Q; 45 5'l #r" )NN)!r r r) r r rB structry r r r r contextr r r r __all__r@ Structr objectr r r r r r r
r r r
rr r" r r s
%
c"
M+ M+fMM`.) l ++ 11 $;; $;; r"