+ NV-j<^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 R/RlltRtRtRt]!4t]P>t]P@t ]PBt!]PDt"R#)N)AuthenticationError) connection)process) reduction)resource_tracker)spawn)utilqcJa]tRt^#toRtRtRtRtRtRt Rt Rt Vt R #) ForkServercRVnRVnRVnRVnRVn\ P !4VnR.VnR#)N__main__) _forkserver_authkey_forkserver_address_forkserver_alive_fd_forkserver_pid_inherited_fds threadingLock_lock_preload_modulesselfs&h/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/multiprocess/forkserver.py__init__ForkServer.__init__%sB#' #' $(!#"^^% !+ cVP;_uu_4VP4RRR4R# +'giR#;iN)r_stop_unlockedrs&r_stopForkServer._stop.s# ZZZ    !ZZZs 0 A clVPfR#\P!VP4RVn\P!VP^4RVn\ P !VP4'g!\P!VP4RVnRVn R#r ) roscloserwaitpidr is_abstract_socket_namespacerunlinkrrs&rr!ForkServer._stop_unlocked3s    '  **+$(! 4''+#001I1IJJ IId.. /#' #' rc \;QJdRV4F 'dK RM RM !RV44'g \R4hWnR#)z>Set list of module names to try to load in forkserver process.c3D"TFp\V4\JxK R#5ir )typestr).0mods& r 4ForkServer.set_forkserver_preload..Es=}49#}s FTz&module_names must be a list of stringsN)all TypeErrorr)r modules_namess&&rset_forkserver_preload!ForkServer.set_forkserver_preloadCs5s=}=sss=}===DE E -rc VP#)z|Return list of fds inherited from parent process. This returns None if the current process was not started by fork server. )rrs&rget_inherited_fdsForkServer.get_inherited_fdsIs """rc VP4VP'gQh\V4^,\8d \ R4h\ P !\ P 4;_uu_4pVPVP4\P!4wr4\P!4wrVWTVP\P!4.pWq, pVPR4\P !VP#44p\P$!WP4\P&!WP4VP)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_runningrlenMAXFDS_TO_SEND ValueErrorsocketAF_UNIXconnectrr%piperrgetfd setblockingr Connectionfilenoanswer_challengedeliver_challenge_detachrsendfdsr&) rfdsclientparent_rchild_wchild_rparent_wallfdswrapped_clients && rconnect_to_new_process!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+ * *sJ7A4H;,5G"AG")G ,H;GG/HH  .H88H;; I c  TVP;_uu_4\P!4VPe\P !VP\P 4wrV'g RRR4R#\P!VP4RVn RVn RVnRVnR p/pVP'd=\P!R4pRV9d 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. Nignoresys_pathinit_main_from_path main_pathrAi authkey_rz-cz@from multiprocess.forkserver import main; main(%d, %d, %r, **%r))rrr<rr%r'WNOHANGr&rrrrrget_preparation_datar@rArarbitrary_addressbindr r(chmodlistenrCrGget_executable_args_from_interpreter_flagsspawnv_passfdsurandom _AUTHKEY_LENwrite)rpidstatuscmdmain_kwsdatalisteneraddressalive_ralive_wr[ authkey_w fds_to_passexeargss& rr<ForkServer.ensure_running{sZZZ  + + -##/ jj)=)=rzzJ Z223+/(+/(,0)'+$,CH$$$11(;%+/ +;HZ((D0,01F,GH[)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/5Z^HHW%HHY'HHW%HHY'HHY'E/.5ZZsiAN=B:N7BN B L,N ?M( (N 3N/L4 4L77.M% %N (N N  N N N' )rrrrrrrN) __name__ __module__ __qualname____firstlineno__rr"r!r6r9rTr<__static_attributes____classdictcell__) __classdict__s@rr r #s0-" ( . #("TF+F+rr r[c Veb\P!V\4p\V4\8XgQ\V4 R\ 24h\P!V4MRpV'dVeV\ P R&RV9dKVeGR\P!4n \P!V4\P!4= VFp\V4K \P!4\P !4\P"!4wr\P$!VR4\P$!V R4Rp \&P(V \&P*\&P,/p V P/4U U u/uFwrV \&P&!W4bK pp p \&P0!V 4/p\2P2!\2P4VR 7;_uu_4p\6P8!4;_uu_4pVP;4\<nVPAV\6PB4VPAV\6PB4VPAV\6PB4VPE4UUu.uFwppVPFNK pppV'gK9TT9d*\P!T^4R8XgQR 4h\HhTT9d\P!TR 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\T4\n8d$\uR Pw\T444hTvpppTP 4\Px!4pT^8Xd^pTP 4TP 4TTY.pTP{TP}44\~P!4\~P@!\P4\TTTT4p\~P!4\P!T4MG\UTT4TTT&\P!T4TFp\P!T4K RRR4EKWEKZ \P!T4i;i \P!4= i;i \dEKii;iuup p iuuppi \NdEKi;i \VdELi;i TPi4?i;i \p\V\r3dTP 4RRR4EKi;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.Nz < r:NNNrTFcR#r )_unuseds*rsigchld_handlermain..sigchld_handlers r)rGz Not at EOF?iz.forkserver: waitpid returned unexpected pid %dzToo many ({0:n}) fds to send)Mr%readrfr=r&syspathrcurrent_process _inheritingrimport_main_path __import__ ImportErrorr _flush_std_streams _close_stdinrC set_blockingsignalSIGCHLDSIGINTSIG_IGNitems set_wakeup_fdr@rA selectorsDefaultSelector getsockname _forkserverrregister EVENT_READselectfileobj SystemExitr'r\ChildProcessErrorpopwaitstatus_to_exitcode write_signedBrokenPipeErrorwarningswarnacceptrrFrGrIrHrJrrecvfdsr>EOFErrorr RuntimeErrorformatforkextendvaluesatexit_clear_exit_function _serve_one Exception excepthookexc_infostderrflush_run_exitfuncs_exitOSErrorerrno ECONNABORTED)! listener_fdropreloadrZrXr[authkeymodnamesig_rsig_wrhandlerssigval old_handlers pid_to_fdrmselectorkeyeventsrfdsrhstsrO returncodes wrapped_srLrPcode unused_fdsfdes!&&&&&$ rmainrs  ggi6Gw<</ SCL>\N1S S/ HHY   "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!56b =E__=NO=NMS&CKK=NDOtd?777A.#5D}D5$$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.-$} HHY ++-9  .8(P 1"!"$3% $%.%.$5$5$7(1!)/;NO%GGI$%.- %.$-3 #  ? # 0 0 23!' 5 5 7 " $3% $%c.--r 77e0001 Q % $ ; : : :sAW?-X X4""Y _ +A;^, ']2;Y ]2 A]21(Y4]2 Y&A]28] :,Z '.Y8 3Z A*] 3B [ >,] + ] 7:] 1]29^, ?XX14 YY ]2 Y# ]2"Y# #]2& Y5 1]24Y5 5]28Z  Z &[4] 5]2=^, [] A\\ \\ -]] ]] ]]  ]/(]2,^, /]22 ^) = ^$ ^, $^) )^, , ^< 7_  _ cz\P!R4VP4FwrE\P!WE4K VFp\P!V4K Vv\ n\Pn \ n \P!V4p\P!W4pV#)r)rrrr%r&rrr_resource_tracker_fdrdupr_main) rPrLrrrrrparent_sentinelrs &&&& rrrms NN$ c%   %("[%''+ ffWoO ;;w 0D Krc\\P4p\V4pV'd/\P !W4pV^8Xd \ R4hW#RpK6\PV4^,#)rzunexpected EOFN) bytearray SIGNED_STRUCTsize memoryviewr%readintorunpack)rrlunreadcounts& r read_signedrs_ ]'' (D  F  B' A:+, ,    %a ((rc\PV4pV'd/\P!W4pV^8Xd \ R4hW#RpK6R#)rzshould not get hereN)rpackr%rgr)rnmsgnbytess&& rrrsD   Q C "" Q;45 5'l r)r<r9rTr6)NN)#rrr%rrr@structrrrrrrcontextrrrr __all__r>Structrrfobjectr rrrrrr<r9rTr6rrrrs  ! % c"  ^+^+HccL. )l ++11$;;$;;r