+ i<cs^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI H t ^RI H t ^RI H t ^RIHt^RI Ht^RI Ht^RI Ht.ROtR t]P*!R 4t^ t!R R ]4tRR RRR/RlltRtRtRt]!4t]P>t]P@t ]PBt!]PDt"R#)N)AuthenticationError) connection)process) reduction)resource_tracker)spawn)utiliZqcsJa]tRt^#toRtRtRtRtRtRt Rt Rt Vt R #) ForkServercsRVnRVnRVnRVnRVn\ P !4VnR.VnR#)N__main__) _forkserver_authkey_forkserver_address_forkserver_alive_fd_forkserver_pid_inherited_fds threadingZLock_lock_preload_modulesself&3/usr/lib64/python3.14/multiprocessing/forkserver.py__init__ZForkServer.__init__%sB#' #' $(!#"^^% !+ csVP;_uu_4VP4RRR4R# +'giR#;iN)r_stop_unlockedrrr_stopZForkServer._stop.s# ZZZ    !ZZZs 0 A cslVPfR#\P!VP4RVn\P!VP^4RVn\ P !VP4'g!\P!VP4RVnRVn R#r) r oscloser waitpidris_abstract_socket_namespacer Zunlinkr rrrrZForkServer._stop_unlocked3s    '  **+$(! 4''+#001I1IJJ IId.. /#' #' rc s\;QJdRV4F 'dK RM RM !RV44'g \R4hWnR#)z>Set list of module names to try to load in forkserver process.c3sD"TFp\V4\JxK R#5ir)ZtypeZstr)Z.0Zmods& rZ Z4ForkServer.set_forkserver_preload..Es=}49#}s FTz&module_names must be a list of stringsN)ZallZ TypeErrorr)rZ modules_namess&&rset_forkserver_preloadZ!ForkServer.set_forkserver_preloadCs5s=}=sss=}===DE E -rc sVP#)z|Return list of fds inherited from parent process. This returns None if the current process was not started by fork server. )rrrrget_inherited_fdsZForkServer.get_inherited_fdsIs """rc svVP4\V4^,\8d \R4h\P!\P 4;_uu_4pVP VP4\P!4wr4\P!4wrVWTVP\P!4.pWq, pVPR4\P!VP!44p\P"!WP$4\P&!WP$4VP)4?\*P,!W'4W63\P.!V4\P.!V4uuRRR4# TP)4?i;i \P.!T4\P.!T4h;i \P.!T4\P.!T4i;i +'giR#;i)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 fdsTN)ensure_runninglenMAXFDS_TO_SENDZ ValueErrorsocketAF_UNIXZconnectr rpiper rZgetfdZ setblockingr Connectionfilenoanswer_challenger deliver_challenge_detachrZsendfdsr) rfdsZclientZparent_rchild_wchild_rZparent_wZallfdsZwrapped_clients && rconnect_to_new_processZ!ForkServer.connect_to_new_processQs  s8a<> )^, , ]]6>> * *f NN433 4 " H " G(A(A&,,.0F MF """4(!+!6!6v}}!G'//*,D,DF00*,D,DF#**,&!!&1) !!9+ *$#**,& ""!!9+ * *sJ#A4H'5GAF.)G7,H'.GG/G33G66.H$$H'' H8 c  szVP;_uu_4\P!4VPe\P !VP\P 4wrV'g RRR4R#\P!VP4RVn RVn RVnRVnR p/pVP'dP\P!R4pRV9d VR,VR&RV9d VR,VR&RV9d VR,VR&\P!\P4;_uu_4p\ P"!R4pVP%V4\&P(!V4'g\P*!VR4VP-4\P.!4wr\P.!4wrVP14W.p WR &W6P14WPV3,p\P2!4p V .\&P4!4,pVR V., p\&P6!WV 4p\P!T4\P!T 4\P8!\:4Tn \P<!YP4\P!T 4Ypn YnYnRRR4RRR4R# \P!T 4\P!T 4h;i \P!T4\P!T 4i;i \P!T 4i;i +'giL;i +'giR#;i) 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. NZignoresys_pathZinit_main_from_path main_pathsys_argvr%i authkey_rz-czCfrom multiprocessing.forkserver import main; main(%d, %d, %r, **%r))rrr!r rrWNOHANGrr r r rrZget_preparation_datar$r%rZarbitrary_addressZbindrrZchmodZlistenr&r(Zget_executableZ_args_from_interpreter_flagsZspawnv_passfdsZurandom _AUTHKEY_LENwrite)rpidZstatusZcmdZmain_kwsdatalistenerZaddressalive_rZalive_wr3Z authkey_wZ fds_to_passZexeZargss& rr!ZForkServer.ensure_running{sZZZ  + + -##/ jj)=)=rzzJ Z223+/(+/(,0)'+$,CH$$$11(;%+/ +;HZ((D0,01F,GH[)%+/ +;HZ(v~~..($66yA g&88AAHHWe,!$&779 ')wwy$ (#+??#4g"IK,5[)OO-w8M8M$&&C..0C54#D#D#FFDT3K'D--cEC HHW%HHY'(/1zz,/GD,HHY(@(@AHHY'+2(,3)'*$K/9ZbHHW%HHY'HHW%HHY'HHY'E/.9ZZsiAN)=C N) BN $B L2,N ?M;(N N)/M M  .M8 8N ;N N  N& !N)) N: )r r r r rrrN) Z__name__Z __module__Z __qualname__Z__firstlineno__rrrrr r/r!Z__static_attributes__Z__classdictcell__)Z __classdict__s@rrr#s0-" ( . #("TH+H+rrr2r3c sFVe4\P!V\4p\P!V4MRpV'dVeV\P R&VeV\P R&RV9dKVeGR\P!4n \P!V4\P!4= VFp\V4K \P!4\P !4\P"!4wr\P$!V R4\P$!V R4Rp \&P(V \&P*\&P,/p V P/4U Uu/uFwrV \&P&!W4bK pp p\&P0!V 4/p\2P2!\2P4VR7;_uu_4p\6P8!4;_uu_4pVP;4\<nVPAV\6PB4VPAV\6PB4VPAV \6PB4VPE4UUu.uFwppVPFNK pppV'gK9TT9d\HhT T9d\P!T R 4\PJ!R \PL4wppT^8XdMpTPQTR4pTe<\PR!T4p\UTT4\P!T4K\XPZ!R T,4KTT9Ed$TP]4^,;_uu_4pT'de\^P`!TPc44p\^Pd!TT4\^Pf!TT4TPi4?\jPl!T\n^,4p\uT4\n8d$\wR Py\uT444hTvpppTP4\Pz!4pT^8Xd^pTP4TP4TTY.pTP}TP44\P!4\P@!\P4\TTTT4p\P!4\P!T4MG\UTT4TTT&\P!T4TFp \P!T 4K RRR4EK4EK7 \P!T4i;i \P!4= i;i \dEKFi;iuupp iuuppi \NdEKi;i \VdELi;i TPi4?i;i \p\V\r3dTP4RRR4EKi;i \dJ\P!\P!4!\PP4ELi;i \P!4\P!T4i;i \VdELi;i +'giEK;i \d-p!T!P\P8wdhRp!?!EKRp!?!ii;i +'giM;iRRR4R# +'giR#;i) zRun forkserver.Nr:NNNr TFcsR#r)Z_unuseds*rsigchld_handlerZmain..sigchld_handlers r)r(iz.forkserver: waitpid returned unexpected pid %dzToo many ({0:n}) fds to send)NrZreadr5rsysZargvZpathrZcurrent_processZ _inheritingrZimport_main_pathZ __import__Z ImportErrorrZ_flush_std_streamsZ _close_stdinr&Z set_blockingsignalZSIGCHLDZSIGINTZSIG_IGNitems set_wakeup_fdr$r% selectorsZDefaultSelectorZ getsockname _forkserverr ZregisterZ EVENT_READZselectZfileobjZ SystemExitrr4ZChildProcessErrorZpopZwaitstatus_to_exitcode write_signedZBrokenPipeErrorwarningsZwarnZacceptrr'r(r*r)r+rZrecvfdsr#EOFErrorrr" RuntimeErrorZformatZforkZextendZvaluesatexitZ_clearZ_exit_function _serve_oneZ ExceptionZ excepthookZexc_infoZstderrZflushZ_run_exitfuncsZ_exitZOSErrorerrnoZ ECONNABORTED)"Z listener_fdr:Zpreloadr1r0r2r3ZauthkeyZmodnameZsig_rZsig_wr<handlerssigvalZ old_handlersZ pid_to_fdr9ZselectorZkeyZeventsZrfdsr7Zstsr-Z returncodeZsZ wrapped_sr,r.code unused_fdsfdZes"&&&&&$$ rmainrQs ggi6G HHY   "CHHQK  "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!56c =E__=NO=NMS&CKK=NDOtd?%$D=GGE5)"')zz"bjj'AHC!8!"+--T":".)+)B)B3)GJ% ,Wj AHHW-%MM+>@C+DEt#!*1--%&,6,A,A!((*,M !2$.$@$@,5w%@$.$?$?,5w%@%.$5$5$7(1"+"3"3A~7I"JCs8n4". > 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.-$C HHY ++-9  .8(P 1"!"$3% $%.%.$5$5$7(1!)/;NO%GGI$%.- %.$-3 #  ? # 0 0 23!' 5 5 7 " $3% $%c.--r 77e0001 S % $ ; : : :sWW  W: "X 6^A;]2 \8$X<\8 -\87(X4\8 X, A\8>\# ,Y -.X> 3Y A*\# 9B Z ,\# 1 \ =:\# 7\8?]2 W W7: X  X \8 X) $\8(X) )\8, X; 7\8:X; ;\8>YY &Z:\# ;\8]2 Z\# A[[! [[! !-\\#  \ \# \  \# # \5.\82]2 5\88 ]/  ]* #]2 *]/ /]2 2 ^ =^ ^ csz\P!R4VP4FwrE\P!WE4K VFp\P!V4K Vv\ n\Pn \ n \P!V4p\P!W4pV#)ir=)r?rAr@rrrCr rZ_resource_trackerZ_fdrZduprZ_main) r.r,rOrKrLrMrPZparent_sentinelrNs &&&& rrIrIrs NN$ c%   %("[%''+ ffWoO ;;w 0D Krcs\\P4p\V4pV'd/\P !W4pV^8Xd \ R4hW#RpK6\PV4^,#)rzunexpected EOFN)Z bytearray SIGNED_STRUCTZsizeZ memoryviewrZreadintorFZunpack)rPr8ZunreadZcounts& r read_signedrSs_ ]'' (D  F  B' A:+, ,    %a ((rcs\PV4pV'd/\P!W4pV^8Xd \ R4hW#RpK6R#)rzshould not get hereN)rRZpackrr6rG)rPZnZmsgZnbytess&& rrDrDsD   Q C "" Q;45 5'l r)r!r r/r)NN)#rHrJrrBr?r$Zstructr>rrEZrrrZcontextrrrrZ__all__r#ZStructrRr5ZobjectrrQrIrSrDrCr!r r/rr;rrrTs  ! % c"  `+`+Lff%)fR. )l ++11$;;$;;r