*j(/ S SK r S SKrS SKrSSKJr SSKJr Sr " S S\5 r " S S \5 r " S
S \5 r
" S S
\5 r " S S\ 5 r
" S S\R 5 r " S S\
5 r\R" S:w a " S S\R 5 r " S S\R 5 r " S S\R 5 r " S S \
5 r " S S \
5 r " S S \
5 r\" 5 \" 5 \" 5 S!.r\R" S":X a \" \S# 5 rO@\" \S$ 5 rO4 " S% S\R 5 r " S& S \
5 rS#\" 5 0r\" \S# 5 rS' r\R6 " 5 r S( r S) r S* r g)+ N )process) reduction c \ rS rSrSrg) ProcessError r N__name__
__module__ __qualname____firstlineno____static_attributes__r >/opt/alt/python313/lib64/python3.13/multiprocessing/context.pyr r r r c \ rS rSrSrg)BufferTooShort r Nr
r r r r r r r r c \ rS rSrSrg) TimeoutError r Nr
r r r r r r r r c \ rS rSrSrg)AuthenticationError r Nr
r r r r r r r r c \ rS rSr\r\r\r\r\" \ R 5 r
\" \ R 5 r \" \ R 5 r S r
S rS$S jrS rS rS%S jrS&S
jrS&S jrS rS'S
jrS(S jrS(S jrS r S)S jrS rS r SS.S jr SS.S jr S r S r S%S jr!S r"S r#S r$S%S jr%S*S jr&S*S jr'\(S! 5 r)\)RT S" 5 r)S# r+Sr,g)+ BaseContext c L [ R " 5 nUc [ S5 eU$ )Nz cannot determine number of cpus)os cpu_countNotImplementedError)selfnums r r! BaseContext.cpu_count) s# lln ;%&GH HJr c Z SSK Jn U" U R 5 S9nUR 5 U$ )Nr ) SyncManagerctx)managersr' get_contextstart)r# r' ms r ManagerBaseContext.Manager1 s( * D , , . / r Tc SSK Jn U" U5 $ )Nr )Pipe)
connectionr1 )r# duplexr1 s r r1 BaseContext.Pipe< s $F|r c 6 SSK Jn U" U R 5 S9$ )Nr )Lockr( ) synchronizer6 r+ )r# r6 s r r6 BaseContext.LockA s %((*++r c 6 SSK Jn U" U R 5 S9$ )Nr )RLockr( )r7 r: r+ )r# r: s r r: BaseContext.RLockF &))+,,r Nc 6 SSK Jn U" XR 5 S9$ )Nr ) Conditionr( )r7 r> r+ )r# lockr> s r r> BaseContext.ConditionK s *#3#3#566r c 6 SSK Jn U" XR 5 S9$ )Nr ) Semaphorer( )r7 rB r+ )r# valuerB s r rB BaseContext.SemaphoreP s *$4$4$677r c 6 SSK Jn U" XR 5 S9$ )Nr )BoundedSemaphorer( )r7 rF r+ )r# rC rF s r rF BaseContext.BoundedSemaphoreU s 1 +;+;+=>>r c 6 SSK Jn U" U R 5 S9$ )Nr )Eventr( )r7 rI r+ )r# rI s r rI BaseContext.EventZ r< r c 8 SSK Jn U" XX0R 5 S9$ )Nr )Barrierr( )r7 rL r+ )r# partiesactiontimeoutrL s r rL BaseContext.Barrier_ s (w5E5E5GHHr c 6 SSK Jn U" XR 5 S9$ )Nr )Queuer( )queuesrR r+ )r# maxsizerR s r rR BaseContext.Queued s !W"2"2"455r c 6 SSK Jn U" XR 5 S9$ )Nr )
JoinableQueuer( )rS rW r+ )r# rT rW s r rW BaseContext.JoinableQueuei s ) W*:*:*<==r c 6 SSK Jn U" U R 5 S9$ )Nr ) SimpleQueuer( )rS rZ r+ )r# rZ s r rZ BaseContext.SimpleQueuen s 't / / 122r r c : SSK Jn U" XX4U R 5 S9$ )Nr )Pool)context)poolr] r+ )r# processes initializerinitargsmaxtasksperchildr] s r r] BaseContext.Pools s$ IH , , .0 0r c SSK Jn U" U/UQ76 $ )Nr )RawValue) sharedctypesrf )r# typecode_or_typeargsrf s r rf BaseContext.RawValuez s *(0400r c SSK Jn U" X5 $ )Nr )RawArray)rg rl )r# rh size_or_initializerrl s r rl BaseContext.RawArray s *(>>r )r? c D SSK Jn U" U/UQ7UU R 5 S.6$ )Nr )Valuer? r) )rg rp r+ )r# rh r? ri rp s r rp BaseContext.Value s/ '% - -4 ))+- -r c : SSK Jn U" XUU R 5 S9$ )Nr )Arrayrq )rg rt r+ )r# rh rm r? rt s r rt BaseContext.Array s# '% ))+- -r c t [ [ SS5 ( a" U R SS9S; a SSKJn U" 5 g g g )NfrozenFT)
allow_none)spawnNr )freeze_support)getattrsysget_start_methodry rz )r# rz s r rz BaseContext.freeze_support s=
C5 ) )))T):oM - N
*r c SSK Jn U" 5 $ )Nr )
get_logger)utilr )r# r s r r BaseContext.get_logger s %|r c SSK Jn U" U5 $ )Nr )
log_to_stderr)r r )r# levelr s r r BaseContext.log_to_stderr s ' U##r c SSK Jn g )Nr )r2 ) r2 )r# r2 s r allow_connection_pickling%BaseContext.allow_connection_pickling s !r c SSK Jn U" U5 g )Nr )set_executable)ry r )r#
executabler s r r BaseContext.set_executable s
*z"r c SSK Jn U" U5 g )Nr )set_forkserver_preload)
forkserverr )r# module_namesr s r r "BaseContext.set_forkserver_preload s 7 |,r c ~ Uc U $ [ U nUR 5 U$ ! [ a [ SU- 5 S ef = f)Nzcannot find context for %r)_concrete_contextsKeyError
ValueError_check_available)r# methodr) s r r+ BaseContext.get_context sU >K N$V,C
N 9F BC M Ns " <c U R $ N)_namer# rx s r r} BaseContext.get_start_method s zzr c [ S5 e)Nz+cannot set start method of concrete context)r r# r forces r set_start_method BaseContext.set_start_method s FGGr c 4 [ 5 R S5 $ Nr )globalsgetr# s r reducerBaseContext.reducer s y}}[))r c U[ 5 S' g r )r )r# r s r r r s !* + r c g r r r s r r BaseContext._check_available s r )Tr )r )NN)r )NNr NF)-r r r
r r r r r staticmethodr current_processparent_processactive_childrenr! r. r1 r6 r: r> rB rF rI rL rR rW rZ r] rf rl rp rt rz r r r r r r+ r} r propertyr setterr r r r r r r s L#N L-"7#:#:;O!'"8"89N"7#:#:;O
,
-
7
8
?
-
I
6
>
3
?A "01
?
37 - DH - $
!#-H * *
^^+ +
r r c 8 \ rS rSrSr\S 5 r\S 5 rSrg)Process Nc \ [ R 5 R R U 5 $ r )_default_contextr+ r _Popen) process_objs r r Process._Popen s" ++-55<<[IIr c Z [ R 5 R R 5 $ r )r r+ r _after_forkr r r r Process._after_fork s ++-55AACCr r r r r
r
_start_methodr r r r r r r r r s1 MJ J D Dr r c P ^ \ rS rSr\rS rSU 4S jjrS S jrS S jrS r Sr
U =r $ )
DefaultContext c Xl S U l g r )r _actual_context)r# r^ s r __init__DefaultContext.__init__ s ' # r c | > Uc* U R c U R U l U R $ [ TU ]
U5 $ r )r r superr+ )r# r __class__s r r+ DefaultContext.get_context s> >##+'+'<'<$'' '7&v. .r c U R b U( d [ S5 eUc U( a S U l g U R U5 U l g )Nz context has already been set)r RuntimeErrorr+ r s r r DefaultContext.set_start_method sA +E => > >e#'D # / / 7 r c z U R c U( a g U R U l U R R $ r )r r r r s r r} DefaultContext.get_start_method s4 '#'#8#8D ##)))r c [ R S:X a S/$ [ R S:X a SS/OSS/n[ R ( a UR S5 U$ )Nwin32ry darwinforkr )r| platformr HAVE_SEND_HANDLEappend)r# methodss r get_all_start_methods$DefaultContext.get_all_start_methods
sM <<7 "9 +.<<8+Cw'&RYIZG))|,Nr )r r r r ) r r r
r r r r+ r r} r r
__classcell__)r s @r r r s& G$/8* r r r c ( \ rS rSrSr\S 5 rSrg) ForkProcessi r c SSK Jn U" U 5 $ Nr )Popen)
popen_forkr r r s r r ForkProcess._Popen s )% %r r Nr r r
r r r r r r r r r r s
&
&r r c 8 \ rS rSrSr\S 5 r\S 5 rSrg) SpawnProcessi" ry c SSK Jn U" U 5 $ r )popen_spawn_posixr r s r r SpawnProcess._Popen$ 0% %r c g r r r r r r SpawnProcess._after_fork)
r r Nr r r r r r " -
&
&
r r c ( \ rS rSrSr\S 5 rSrg)ForkServerProcessi. r c SSK Jn U" U 5 $ r )popen_forkserverr r s r r ForkServerProcess._Popen0 s /% %r r Nr r r r r r . s $
&
&r r c \ rS rSrSr\rSrg) ForkContexti5 r r N)r r r
r r r r r r r r r r 5 s r r c \ rS rSrSr\rSrg) SpawnContexti9 ry r Nr r r
r r r r r r r r r r 9 r r c " \ rS rSrSr\rS rSrg)ForkServerContexti= r c D [ R ( d [ S5 eg )Nz%forkserver start method not available)r r r r s r r "ForkServerContext._check_available@ s -- !HII .r r N) r r r
r r r r r r r r r r r = s # Jr r )r ry r r ry r c 8 \ rS rSrSr\S 5 r\S 5 rSrg)r iR ry c SSK Jn U" U 5 $ r )popen_spawn_win32r r s r r r T r r c g r r r r r r r Y r r r Nr r r r r r R r r c \ rS rSrSr\rSrg)r i^ ry r Nr r r r r r ^ r r c ( [ U [ l g r )r r r )r s r _force_start_methodr k s '9&'A$r c $ [ [ SS 5 $ )Nspawning_popen)r{ _tlsr r r get_spawning_popenr
t s 4)4 00r c U [ l g r )r r )popens r set_spawning_popenr
w s
Dr c \ [ 5 c! [ S[ U 5 R - 5 eg )NzF%s objects should only be shared between processes through inheritance)r
r typer )objs r assert_spawningr z s4 #
#%)#Y%7%7
8 $r ) r r| threadingr r r __all__ Exceptionr r r r objectr BaseProcessr r r r r r r r r r r r localr r
r
r r r r r s
9 \ < , ~
& ~
HDg!! D&[ &Z <<7&g)) &
w**
&G / / & k { JK J
')
||x **