+
    i-  c                   s(   ^ RI t ^ RIt^ RIt^RIHt ^RIHt R)t ! R R]4      t ! R R]4      t	 ! R R	]4      t
 ! R
 R]4      t ! R R]4      t ! R R]P                  4      t ! R R]4      t]P"                  R8w  d    ! R R]P                  4      t ! R R]P                  4      t ! R R]P                  4      t ! R R]4      t ! R R]4      t ! R R]4      tR]! 4       R ]! 4       R!]! 4       /t]P2                  '       d"   ]P"                  R"8w  d   ]! ]R!,          4      tMH]! ]R ,          4      tM8 ! R# R]P                  4      t ! R$ R]4      tR ]! 4       /t]! ]R ,          4      tR% t]P8                  ! 4       tR& tR' tR( t R# )*    N)process	reductionc                   s    ] tR t^tRtR# )ProcessError N__name__
__module____qualname____firstlineno____static_attributes__r       0/usr/lib64/python3.14/multiprocessing/context.pyr   r          r   r   c                   s    ] tR t^tRtR# )BufferTooShortr   Nr   r   r   r   r   r      r   r   r   c                   s    ] tR t^tRtR# )TimeoutErrorr   Nr   r   r   r   r   r      r   r   r   c                   s    ] tR t^tRtR# )AuthenticationErrorr   Nr   r   r   r   r   r      r   r   r   c                   s  a  ] tR t^t o ]t]t]t]t]! ]	P                  4      t
]! ]	P                  4      t]! ]	P                  4      tR tR tR#R ltR tR tR$R ltR%R	 ltR%R
 ltR tR&R ltR'R ltR'R ltR tR(R ltR tR tRR/R ltRR/R ltR tR t R$R lt!R t"R t#R t$R$R lt%R)R lt&R)R lt'](R 4       t)])PT                  R  4       t)R! t+R"t,V t-R# )*BaseContextc                sN    \         P                  ! 4       pVf   \        R4      hV# )Nzcannot determine number of cpus)os	cpu_countZNotImplementedError)selfZnum   & r   r   ZBaseContext.cpu_count)   s#    lln;%&GHHJr   c                s`    ^RI Hp V! V P                  4       R7      pVP                  4        V# )   )SyncManagerctx)Zmanagersr   get_contextZstart)r   r   Zms   &  r   ManagerZBaseContext.Manager1   s(     	*D,,./		r   Tc                    ^RI Hp V! V4      # )r   )Pipe)
connectionr   )r   Zduplexr      && r   r   ZBaseContext.Pipe<   s    $F|r   c                <    ^RI Hp V! V P                  4       R7      # )r   )Lockr   )synchronizer"   r   )r   r"   r   r   r"   ZBaseContext.LockA   s    %((*++r   c                r!   )r   )RLockr   )r#   r$   r   )r   r$   r   r   r$   ZBaseContext.RLockF       &))+,,r   Nc                <    ^RI Hp V! WP                  4       R7      # )r   )	Conditionr   )r#   r'   r   )r   lockr'   r    r   r'   ZBaseContext.ConditionK   s    *#3#3#566r   c                r&   )r   )	Semaphorer   )r#   r)   r   )r   valuer)   r    r   r)   ZBaseContext.SemaphoreP   s    *$4$4$677r   c                r&   )r   )BoundedSemaphorer   )r#   r+   r   )r   r*   r+   r    r   r+   ZBaseContext.BoundedSemaphoreU   s    1+;+;+=>>r   c                r!   )r   )Eventr   )r#   r,   r   )r   r,   r   r   r,   ZBaseContext.EventZ   r%   r   c                s>    ^RI Hp V! WW0P                  4       R7      # )r   )Barrierr   )r#   r-   r   )r   ZpartiesZactionZtimeoutr-   s   &&&& r   r-   ZBaseContext.Barrier_   s    (w5E5E5GHHr   c                r&   )r   )Queuer   )queuesr.   r   )r   maxsizer.   r    r   r.   ZBaseContext.Queued   s    !W"2"2"455r   c                r&   )r   )JoinableQueuer   )r/   r1   r   )r   r0   r1   r    r   r1   ZBaseContext.JoinableQueuei   s    )W*:*:*<==r   c                r!   )r   )SimpleQueuer   )r/   r2   r   )r   r2   r   r   r2   ZBaseContext.SimpleQueuen   s    't//122r   c                s@    ^RI Hp V! WW4V P                  4       R7      # )r   )Pool)context)Zpoolr3   r   )r   Z	processesZinitializerZinitargsZmaxtasksperchildr3   s   &&&&& r   r3   ZBaseContext.Pools   s$     	IH ,,.0 	0r   c                s"    ^RI Hp V! V.VO5!  # )r   )RawValue)sharedctypesr5   )r   typecode_or_typeargsr5   s   &&* r   r5   ZBaseContext.RawValuez   s    *(0400r   c                s    ^RI Hp V! W4      # )r   )RawArray)r6   r9   )r   r7   size_or_initializerr9   s   &&& r   r9   ZBaseContext.RawArray   s    *(>>r   r(   c               sF    ^RI Hp V! V.VO5RVRV P                  4       / # )r   )Valuer(   r   )r6   r;   r   )r   r7   r(   r8   r;   s   &&$* r   r;   ZBaseContext.Value   s4    '% - -4 -))+- 	-r   c               s@    ^RI Hp V! WVV P                  4       R7      # )r   )Array)r(   r   )r6   r<   r   )r   r7   r:   r(   r<   s   &&&$ r   r<   ZBaseContext.Array   s#    '%))+- 	-r   c                s    V P                  4       R 8X  d)   \        \        RR4      '       d   ^RIHp V! 4        R# R# R# )spawnZfrozenF)freeze_supportN)get_start_methodgetattrsysr=   r>   )r   r>   r   r   r>   ZBaseContext.freeze_support   s5       "g-'#x2O2O- 3P-r   c                s    ^RI Hp V! 4       # )r   )
get_logger)utilrB   )r   rB   r   r   rB   ZBaseContext.get_logger   s     	%|r   c                r   )r   )log_to_stderr)rC   rD   )r   ZlevelrD   r    r   rD   ZBaseContext.log_to_stderr   s    'U##r   c                s    ^RI Hp R# )r   )r   N) r   )r   r   r   r   allow_connection_picklingZ%BaseContext.allow_connection_pickling   s     	!r   c                "    ^RI Hp V! V4       R# )r   )set_executableN)r=   rH   )r   Z
executablerH   r    r   rH   ZBaseContext.set_executable   s    
 	*z"r   c                rG   )r   )set_forkserver_preloadN)
forkserverrI   )r   Zmodule_namesrI   r    r   rI   Z"BaseContext.set_forkserver_preload   s     	7|,r   c                s    Vf   V #  \         V,          pTP                  4        T#   \         d    \        RT,          4      R hi ; i)Nzcannot find context for %r)_concrete_contextsZKeyError
ValueError_check_available)r   methodr   r    r   r   ZBaseContext.get_context   sU    >K	N$V,C 	
  	N9FBCM	Ns	   ' Ac                s    V P                   # N)_namer   Z
allow_none   &&r   r?   ZBaseContext.get_start_method   s    zzr   c                s    \        R 4      h)z+cannot set start method of concrete context)rL   r   rN   Zforce   &&&r   set_start_methodZBaseContext.set_start_method   s    FGGr   c                s4    \        4       P                  R 4      # r   )globalsZgetr      &r   reducerBaseContext.reducer   s     y}}[))r   c                s     V\        4       R &   R# )r   N)rV   )r   r   rR   r   rY   rZ      s    !*	+r   c                    R # rO   r   rW   rX   r   rM   ZBaseContext._check_available   s    r   r   )TrO   )r   )NN)r    )NNr   NF).r   r   r	   r
   r   r   r   r   staticmethodr   Zcurrent_processZparent_processZactive_childrenr   r   r   r"   r$   r'   r)   r+   r,   r-   r.   r1   r2   r3   r5   r9   r;   r<   r>   rB   rD   rF   rH   rI   r   r?   rU   ZpropertyrY   ZsetterrM   r   __classdictcell____classdict__   @r   r   r      s    L#NL-"7#:#:;O!'"8"89N"7#:#:;O	
,
-
7
8
?
-
I
6
>
3
01
?
-$ --4 -$
!#-H * *
 ^^+ + r   r   c                   sD   a  ] tR t^t o Rt]R 4       t]R 4       tRtV t	R# )ProcessNc                s\    \         P                  4       P                  P                  V 4      # rO   )_default_contextr   rb   _Popen)process_objrX   r   rd   ZProcess._Popen   s"    ++-55<<[IIr   c                 sZ    \         P                  4       P                  P                  4       # rO   )rc   r   rb   _after_forkr   r   r   rf   ZProcess._after_fork   s     ++-55AACCr   r   
r   r   r	   r
   _start_methodr]   rd   rf   r   r^   r_   ra   r   rb   rb      s4     MJ J D Dr   rb   c                   sZ   a a ] tR t^t o]tR tRV 3R lltRR ltRR ltR t	Rt
VtV ;t# )	DefaultContextc                s     Wn         R V n        R # rO   )rc   _actual_context)r   r4   rR   r   __init__ZDefaultContext.__init__   s     '#r   c                s   < Vf,   V P                   f   V P                  V n         V P                   # \        SV `  V4      # rO   )rj   rc   Zsuperr   )r   rN   	__class__s   &&r   r   ZDefaultContext.get_context   s>    >##+'+'<'<$'''7&v..r   c                s    V P                   e   V'       g   \        R4      hVf   V'       d
   R V n         R # V P                  V4      V n         R # )Nzcontext has already been set)rj   RuntimeErrorr   rS   rT   r   rU   ZDefaultContext.set_start_method   sA    +E=>>>e#'D #//7r   c                s    V P                   f   V'       d   R # V P                  V n         V P                   P                  # rO   )rj   rc   rP   rQ   rR   r   r?   ZDefaultContext.get_start_method   s4    '#'#8#8D ##)))r   c                s   a V P                   P                  4       oS.pVP                  V3R  l\         4       4       V# )c              3   s8   <"   T F  qS8w  g   K  Vx  K  	  R # 5irO   r   )Z.0Znamedefaults   & r   Z	<genexpr>Z7DefaultContext.get_all_start_methods.<locals>.<genexpr>  s      "
/T7?DD/s   
)rc   r?   ZextendrK   )r   Zstart_method_namesrn   s   & @r   get_all_start_methodsZ$DefaultContext.get_all_start_methods  sB    ''88:%Y!! "
/"
 	
 "!r   )rj   rc   rO   r\   )r   r   r	   r
   rb   rk   r   rU   r?   ro   r   r^   Z__classcell__)rl   r`   s   @@r   ri   ri      s(     G$/8*" "r   ri   Zwin32c                   4   a  ] tR tRt o Rt]R 4       tRtV tR# )ForkProcessi  forkc                    ^RI Hp V! V 4      # r   )Popen)Z
popen_forkru   re   ru   r   r   rd   ZForkProcess._Popen  s    )%%r   r   N	r   r   r	   r
   rh   r]   rd   r   r^   r_   ra   r   rq   rq     s     		& 
	&r   rq   c                   D   a  ] tR tRt o Rt]R 4       t]R 4       tRtV t	R# )SpawnProcessi  r=   c                rs   rt   )Zpopen_spawn_posixru   rv   r   r   rd   SpawnProcess._Popen      0%%r   c                 r[   rO   r   r   r   r   rf   SpawnProcess._after_fork"       r   r   Nrg   r_   ra   r   ry   ry     0     		& 
	& 
	 
	r   ry   c                   rp   )ForkServerProcessi'  rJ   c                rs   rt   )Zpopen_forkserverru   rv   r   r   rd   ZForkServerProcess._Popen)  s    /%%r   r   Nrw   r_   ra   r   r   r   '  s     $		& 
	&r   r   c                       ] tR tRtRt]tRtR# )ForkContexti.  rr   r   N)r   r   r	   r
   rP   rq   rb   r   r   r   r   r   r   .  s    r   r   c                   r   )SpawnContexti2  r=   r   Nr   r   r	   r
   rP   ry   rb   r   r   r   r   r   r   2      r   r   c                   s.   a  ] tR tRt o Rt]tR tRtV t	R# )ForkServerContexti6  rJ   c                sH    \         P                  '       g   \        R 4      hR# )z%forkserver start method not availableN)r   HAVE_SEND_HANDLErL   rW   rX   r   rM   Z"ForkServerContext._check_available9  s    --- !HII .r   r   N)
r   r   r	   r
   rP   r   rb   rM   r   r^   r_   ra   r   r   r   6  s     #	J 	Jr   r   rr   r=   rJ   Zdarwinc                   rx   )ry   iL  r=   c                rs   rt   )Zpopen_spawn_win32ru   rv   r   r   rd   rz   N  r{   r   c                 r[   rO   r   r   r   r   rf   r|   S  r}   r   r   Nrg   r_   ra   r   ry   ry   L  r~   r   c                   r   )r   iX  r=   r   Nr   r   r   r   r   r   X  r   r   c                 s2    \         V ,          \        n        R # rO   )rK   rc   rj   )rN   rX   r   _force_start_methodr   e  s    '9&'A$r   c                  s$    \        \        R R4      # )spawning_popenN)r@   _tlsr   r   r   get_spawning_popenr   n  s    4)400r   c                 s    V \         n        R # rO   )r   r   )ZpopenrX   r   set_spawning_popenr   q  s
    Dr   c                 sh    \        4       f&   \        R\        V 4      P                  ,          4      hR # )NzF%s objects should only be shared between processes through inheritance)r   rm   Ztyper   )ZobjrX   r   assert_spawningr   t  s4    ##%)#Y%7%78 	 $r   r   )!r   rA   Z	threadingrE   r   r   Z__all__Z	Exceptionr   r   r   r   Zobjectr   ZBaseProcessrb   ri   Zplatformrq   ry   r   r   r   r   rK   r   rc   r   Zlocalr   r   r   r   r   r   r   <module>r      s   	 
   
	9 		\ 		< 		, 	x& x|Dg!! D%"[ %"X <<7&g)) &
w** 
&G// &k { JK J 	') !!!cllh&>)*<\*JK)*<W*EF
w** 
{ 
 	 &&8&ABB 1 r   