ee0lSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK J r SSK J r SSK Jr SSK Jr SSK Jr SSK Jr /S QrS r\R("S 5r"S S \5rSSjrSrSrSr\"5r\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_preloadqc>\rSrSrSrSrSrSrSrSr Sr S r g ) ForkServer!cSUlSUlSUlSUl[R "5UlS/Ulg)N__main__)_forkserver_address_forkserver_alive_fd_forkserver_pid_inherited_fds threadingLock_lock_preload_modulesselfs @/opt/imh/python3.13/lib/python3.13/multiprocessing/forkserver.py__init__ForkServer.__init__#s:#' $(!#"^^% !+ cpUR UR5 SSS5 g!,(df  g=fN)r_stop_unlockedrs r_stopForkServer._stop+s ZZ    !ZZs' 5cVURcg[R"UR5 SUl[R"URS5 SUl[ R "UR5(d [R"UR5 SUlg)Nr) roscloserwaitpidr is_abstract_socket_namespacerunlinkrs rr%ForkServer._stop_unlocked0sz    '  **+$(! 4''+#001I1IJJ IId.. /#' r"cT[SU55(d [S5eXlg)z>Set list of module names to try to load in forkserver process.c3D# UHn[U5[Lv M g7fr$)typestr).0mods r 4ForkServer.set_forkserver_preload..As=}49#}s z&module_names must be a list of stringsN)all TypeErrorr)r modules_namess rr !ForkServer.set_forkserver_preload?s%=}===DE E -r"cUR$)z|Return list of fds inherited from parent process. This returns None if the current process was not started by fork server. )rrs rr ForkServer.get_inherited_fdsEs """r"cUR5 [U5S-[:a [S5e[R"[R 5nUR UR5 [R"5up4[R"5upVXTUR[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!,(df  g=f)aRequest 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_UNIXconnectrr)piperrgetfdrsendfdsr*)rfdsclientparent_rchild_wchild_rparent_wallfdss rr !ForkServer.connect_to_new_processMs  s8a<> )^, , ]]6>> *f NN433 4 " H " G(A(A&,,.0F MF "!!&1) !!!+ * ""!!!+ *s1A0E8D,E8/EE.E55E88 Fc|UR [R"5 URbw[R "UR[R 5upU(d SSS5 g[R"UR5 SUl SUlSUlSnUR(aFSS1n[R"S5nUR5VVs0sHupgXd;dM Xg_M nnnO0n[R"[R5n[ R""S5n UR%U 5 [&R("U 5(d[R*"U S5 UR-5 [R."5upUR15U /n X8R15XRU4-n[R2"5n U /[&R4"5-nUSU/- n[&R6"XU 5n[R"U 5 Xl XlXlSSS5 SSS5 gs snnf! [R"U 5 e=f![R"U 5 f=f!,(df  NT=f!,(df  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. NzCfrom multiprocessing.forkserver import main; main(%d, %d, %r, **%r) main_pathsys_pathignorerCiz-c)rrr rr)r+WNOHANGr*rrrrget_preparation_dataitemsrBrCrarbitrary_addressbindr r,chmodlistenrEfilenoget_executable_args_from_interpreter_flagsspawnv_passfds)rpidstatuscmd desired_keysdataxylisteneraddressalive_ralive_w fds_to_passexeargss rr ForkServer.ensure_runningjsZZ  + + -##/ jj)=)=rzzJ Z223+/(,0)'+$,C$$ +Z8 11(;)-K9JKv~~.($66yA g&88AAHHWe,!$&779  &#+??#4g">KOO-w8M8M ""C..0C54#D#D#FFDT3K'D--cEC HHW%+2(,3)'*$3/1Z(L,HHW%HHW%-/.1ZsiAJ-2A5J-' I6I<*J-&BJ(A=I%&(JJ-J-%I>>JJJ J* &J-- J;)rrrrrrN) __name__ __module__ __qualname____firstlineno__r r&r%r r r r __static_attributes__r"rrr!s%-" (. #":8+r"rc  U(azUbU[RSS&SU;aIUbFS[R"5l[ R "U5 [R"5?UHn[U5 M [R"5 [R"5upg[R"US5 [R"US5 Sn[RU[R [R"0n U R%5V V s0sHupU [R"X5_M n n n [R&"U5 0n [(R("[(R*US9n[,R."5nUR15[2lUR7U[,R85 UR7U[,R85 UR7U[,R85 UR;5VVs/sHunnUR<PM nnnU(aOM9UU;a([R>"US5S:XdS 5e[@eUU;a[R>"US 5 [RB"S [RD5unnUS :XaOjU RIUS5nUb:[RJ"U5n[MUU5 [RP"U5 O[RRT"S U-5 MUU;GaURW5S n[XRZ"U[\S-5n[_U5[\:a#[aSRc[_U555eUtnnnURQ5 [Rd"5nUS :XaSnURQ5 URQ5 UUXg/nURgU Ri55 [jRl"5 [jR6"[Rn5 [qUUUU 5n[jR|"5 [R~"U5 OG[MUU5 UU U'[RP"U5 UHn[RP"U5 M SSS5 OGM![R"5?f=f![a GMf=fs sn n fs snnf![Fa GMf=f![Na GN6f=f![raH [Rt"[Rv"56 [RxR{5 GN,f=f![jR|"5 [R~"U5 f=f![Na GN4f=f!,(df  GN=f![a*nUR[R:waeSnAGN5SnAff=f!,(df  O=fSSS5 g!,(df  g=f)zRun forkserver.NrTFcgr$rs)_unuseds rsigchld_handlermain..sigchld_handlers r")r[rr"z Not at EOF?irz.forkserver: waitpid returned unexpected pid %dzToo many ({0:n}) fds to send)Csyspathrcurrent_process _inheritingrimport_main_path __import__ ImportErrorr _close_stdinr)rE set_blockingsignalSIGCHLDSIGINTSIG_IGNrV set_wakeup_fdrBrC selectorsDefaultSelector getsockname _forkserverrregister EVENT_READselectfileobjread SystemExitr+rTChildProcessErrorpopwaitstatus_to_exitcode write_signedBrokenPipeErrorr*warningswarnacceptrrecvfdsr@r? RuntimeErrorformatforkextendvaluesatexit_clear_exit_function _serve_one Exception excepthookexc_infostderrflush_run_exitfuncs_exitOSErrorerrno ECONNABORTED) listener_fdrhpreloadrQrRmodnamesig_rsig_wrwhandlerssigval old_handlers pid_to_fdrfselectorkeyeventsrfdsr_stsrK returncodesrHrLcode unused_fdsfdes rmainrs  "CHHQK  Y%:48G # # % 1 :&&y1++-9G 7#  779LEOOE5!OOE5!  v~~  H'/nn&68&6 s00&68 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 AHHW-%MM+>@C+DE+0t#!*1-'//>A3EFs8n4". > 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 :.5IcNHHW-&) " '*M.-$OQ++-9  &8(P 1"!"$3% $%D$-3 #  ? # 0 0 23!' 5 5 7 " $3% $%C.-R 77e0001 s % $ ; : :sDS"3 S<"#TX6A;XW%)T AW%(T2W%7 T,A W%BWB T=",W W:WW%X"S9< T  T W% T)$W%(T))W%, T:6W%9T::W%=AV VV V-V? ?W W WW W W" W% X"W%% X/XXXX X* &X66 Ycz[R"S5 UR5HupE[R"XE5 M UHn[R"U5 M Ut[ l[Rl [ l [R"U5n[R"X5nU$)Nry)rrrVr)r*rrr_resource_tracker_fdrdupr_main) rLrHrrrrrparent_sentinelrs rrr1s NN$ c%   %("[%''+ ffWoO ;;w 0D Kr"cSn[Rn[U5U:aI[R"X[U5- 5nU(d [ S5eX- n[U5U:aMI[R U5S$)Nr"zunexpected EOFr) SIGNED_STRUCTsizer?r)rEOFErrorunpack)rrclengthrs r read_signedrHsq D   F d)f  GGBT* ++, ,  d)f     %a ((r"c[RU5nU(a5[R"X5nUS:Xa [ S5eX#SnU(aM4gg)Nrzshould not get here)rpackr)writer)rnmsgnbytess rrrRsF   Q C "" Q;45 5'l #r")NN)!rrr)rrrBstructrzrrrrcontextrrrr __all__r@Structrobjectrrrrrrr r r r rsr"rrs   % c" A+A+NFR.)l ++11$;;$;;r"