Cov 0 d dl Z d dlZd dlZddlmZ ddlmZ dZ G d de Z G d d e Z G d
d e Z
G d d
e Z G d de Z
G d dej Z G d de
Zej dk r G d dej Z G d dej Z G d dej Z G d d e
Z G d d e
Z G d d e
Z e e e d!Zej d"k r eed# ZnP eed$ Zn> G d% dej Z G d& d e
Zd# e iZ eed# Zd' Z ej Z d( Z d) Z d* Z dS )+ N )process) reduction c e Zd ZdS ) ProcessErrorN__name__
__module__ __qualname__r >/opt/alt/python311/lib64/python3.11/multiprocessing/context.pyr r Dr
r c e Zd ZdS )BufferTooShortNr r r
r r r r r
r c e Zd ZdS ) TimeoutErrorNr r r
r r r r r
r c e Zd ZdS )AuthenticationErrorNr r r
r r r r r
r c e Zd ZeZeZeZeZ eej Z eej
Z
eej Z d Z d Z
d&dZd Zd Zd'dZd(d
Zd(d Zd Zd)d
Zd*dZd*dZd Z d+dZd Zd ZdddZ dddZ d Z d Z d'dZ d Z!d Z"d Z#d'd Z$d,d!Z%d,d"Z&e'd# Z(e(j) d$ Z(d% Z*dS )- BaseContextc N t j }|t d |S )z(Returns the number of CPUs in the systemNz cannot determine number of cpus)os cpu_countNotImplementedError)selfnums r r zBaseContext.cpu_count) s& lnn ;%&GHH HJr
c v ddl m} || }| |S )zReturns a manager associated with a running server process
The managers methods such as `Lock()`, `Condition()` and `Queue()`
can be used to create shared objects.
r ) SyncManagerctx)managersr get_contextstart)r r ms r ManagerzBaseContext.Manager1 sF *))))) KD , , . . / / / r
Tc $ ddl m} || S )z1Returns two connection object connected by a piper )Pipe)
connectionr( )r duplexr( s r r( zBaseContext.Pipe< s" $$$$$$tF||r
c J ddl m} || S )z#Returns a non-recursive lock objectr )Lockr ) synchronizer, r# )r r, s r r, zBaseContext.LockA s3 %%%%%%t((**++++r
c J ddl m} || S )z Returns a recursive lock objectr )RLockr )r- r/ r# )r r/ s r r/ zBaseContext.RLockF 3 &&&&&&u))++,,,,r
Nc L ddl m} ||| S )zReturns a condition objectr ) Conditionr )r- r2 r# )r lockr2 s r r2 zBaseContext.ConditionK s5 ******y4#3#3#5#56666r
r c L ddl m} ||| S )zReturns a semaphore objectr ) Semaphorer )r- r5 r# )r valuer5 s r r5 zBaseContext.SemaphoreP s5 ******yD$4$4$6$67777r
c L ddl m} ||| S )z"Returns a bounded semaphore objectr )BoundedSemaphorer )r- r8 r# )r r6 r8 s r r8 z BaseContext.BoundedSemaphoreU s6 111111 4+;+;+=+=>>>>r
c J ddl m} || S )zReturns an event objectr )Eventr )r- r: r# )r r: s r r: zBaseContext.EventZ r0 r
c P ddl m} ||||| S )zReturns a barrier objectr )Barrierr )r- r< r# )r partiesactiontimeoutr< s r r< zBaseContext.Barrier_ s9 ((((((wwT5E5E5G5GHHHHr
r c L ddl m} ||| S )Returns a queue objectr )Queuer )queuesrB r# )r maxsizerB s r rB zBaseContext.Queued s5 !!!!!!uW$"2"2"4"45555r
c L ddl m} ||| S )rA r )
JoinableQueuer )rC rF r# )r rD rF s r rF zBaseContext.JoinableQueuei s5 )))))) }W$*:*:*<*<====r
c J ddl m} || S )rA r ) SimpleQueuer )rC rH r# )r rH s r rH zBaseContext.SimpleQueuen s3 ''''''{t / / 1 12222r
r c R ddl m} |||||| S )z Returns a process pool objectr )Pool)context)poolrJ r# )r processes initializerinitargsmaxtasksperchildrJ s r rJ zBaseContext.Pools sG tI{H6F , , . .0 0 0 0r
c ddl m} ||g|R S )zReturns a shared objectr )RawValue) sharedctypesrR )r typecode_or_typeargsrR s r rR zBaseContext.RawValuez s- ******x(040000r
c & ddl m} ||| S )zReturns a shared arrayr )RawArray)rS rW )r rT size_or_initializerrW s r rW zBaseContext.RawArray s( ******x(*=>>>r
)r3 c L ddl m} ||g|R || dS )z$Returns a synchronized shared objectr )Valuer3 r! )rS rZ r# )r rT r3 rU rZ s r rZ zBaseContext.Value sR ''''''u% - - -4 ))++- - - -r
c P ddl m} ||||| S )z#Returns a synchronized shared arrayr )Arrayr[ )rS r] r# )r rT rX r3 r] s r r] zBaseContext.Array sD ''''''u%': ))++- - - -r
c z t j dk r(t t dd rddlm} | dS dS dS )zCheck whether this is a fake forked process in a frozen executable.
If so then run code specified by commandline and exit.
win32frozenFr )freeze_supportN)sysplatformgetattrspawnra )r ra s r ra zBaseContext.freeze_support sV <7 " "wsHe'D'D " - - - - - - N # " " "r
c " ddl m} | S )zZReturn package logger -- if it does not already exist then
it is created.
r )
get_logger)utilrg )r rg s r rg zBaseContext.get_logger s" %$$$$$z||r
c $ ddl m} || S )z8Turn on logging and add a handler which prints to stderrr )
log_to_stderr)rh rj )r levelrj s r rj zBaseContext.log_to_stderr s$ '''''' }U###r
c ddl m} dS )zVInstall support for sending connections and sockets
between processes
r )r) N) r) )r r) s r allow_connection_picklingz%BaseContext.allow_connection_pickling s ! r
c ( ddl m} || dS )zSets the path to a python.exe or pythonw.exe binary used to run
child processes instead of sys.executable when using the 'spawn'
start method. Useful for people embedding Python.
r )set_executableN)re rp )r
executablerp s r rp zBaseContext.set_executable s,
*)))))z"""""r
c ( ddl m} || dS )zkSet list of module names to try to load in forkserver process.
This is really just a hint.
r )set_forkserver_preloadN)
forkserverrs )r module_namesrs s r rs z"BaseContext.set_forkserver_preload s- 766666 |,,,,,r
c || S t | }n!# t $ r t d|z d w xY w| |S )Nzcannot find context for %r)_concrete_contextsKeyError
ValueError_check_available)r methodr! s r r# zBaseContext.get_context sj >K N$V,CC N N N 9F BCC M N
s
2Fc | j S N)_namer
allow_nones r get_start_methodz BaseContext.get_start_method s
zr
c t d )Nz+cannot set start method of concrete context)ry r r{ forces r set_start_methodz BaseContext.set_start_method s FGGGr
c D t d S )z_Controls how objects will be reduced to a form that can be
shared with other processes.r )globalsgetr s r reducerzBaseContext.reducer s yy}}[)))r
c ( |t d< d S )Nr )r )r r s r r zBaseContext.reducer s !* + r
c d S r} r r s r rz z BaseContext._check_available s r
)Tr} )r )NN)r )NNr NF)+r
r r r r r r staticmethodr current_processparent_processactive_childrenr r& r( r, r/ r2 r5 r8 r: r< rB rF rH rJ rR rW rZ r] ra rg rj rn rp rs r# r r propertyr setterrz r r
r r r s L#N L-"l7#:;;O!\'"899N"l7#:;;O
, , ,
- - -
7 7 7 7
8 8 8 8
? ? ? ?
- - -
I I I I
6 6 6 6
> > > >
3 3 3
?A "0 0 0 01 1 1
? ? ?
37 - - - - - DH - - - - - $ $ $ $
! ! !# # #- - - H H H H * * X*
^+ + ^+
r
r c > e Zd ZdZed Zed ZdS )ProcessNc d t j | S r} )_default_contextr# r _Popen) process_objs r r zProcess._Popen s% ++--5<<[IIIr
c b t j S r} )r r# r _after_forkr r
r r zProcess._after_fork s# ++--5AACCCr
r
r r
_start_methodr r r r r
r r r sU MJ J \J D D \D D Dr
r c @ e Zd ZeZd Zd fd Zd dZd dZd Z xZ S )
DefaultContextc " || _ d | _ d S r} )r _actual_context)r rK s r __init__zDefaultContext.__init__ s ' # r
Nc ~ || j | j | _ | j S t | S r} )r r superr# )r r{ __class__s r r# zDefaultContext.get_context s= >#+'+'<$' '77&&v.. .r
Fc | j |st d | |r d | _ d S | | | _ d S )Nz context has already been set)r RuntimeErrorr# r s r r z DefaultContext.set_start_method sQ +E + =>> > >e>#'D F # / / 7 7 r
c H | j |rd S | j | _ | j j S r} )r r r~ r s r r z DefaultContext.get_start_method s/ '
t#'#8D #))r
c t j dk rdgS t j dk rddgnddg}t j r| d |S )Nr_ re darwinforkrt )rb rc r HAVE_SEND_HANDLEappend)r methodss r get_all_start_methodsz$DefaultContext.get_all_start_methods sZ <7 " "9 +.<8+C+Cw''&RYIZG)
-|,,,Nr
r} r )
r
r r r r r# r r r
__classcell__)r s @r r r s G$ $ $/ / / / / /8 8 8 8* * * * r
r r_ c ( e Zd ZdZed ZdS ) ForkProcessr c $ ddl m} || S Nr )Popen)
popen_forkr r r s r r zForkProcess._Popen s$ ) ) ) ) ) )5%% %r
Nr
r r r r r r r
r r r s2
& &
& & &r
r c > e Zd ZdZed Zed ZdS ) SpawnProcessre c $ ddl m} || S r )popen_spawn_posixr r s r r zSpawnProcess._Popen $ 0 0 0 0 0 05%% %r
c d S r} r r r
r r zSpawnProcess._after_fork"
Dr
Nr r r
r r r M
& &
&
r
r c ( e Zd ZdZed ZdS )ForkServerProcessrt c $ ddl m} || S r )popen_forkserverr r s r r zForkServerProcess._Popen) s$ / / / / / /5%% %r
Nr r r
r r r ' s2 $
& &
& & &r
r c e Zd ZdZeZdS ) ForkContextr N)r
r r r~ r r r r
r r r . s r
r c e Zd ZdZeZdS SpawnContextre Nr
r r r~ r r r r
r r r 2 r
r c e Zd ZdZeZd ZdS )ForkServerContextrt c < t j st d d S )Nz%forkserver start method not available)r r ry r s r rz z"ForkServerContext._check_available9 s) -
J !HIII
J
Jr
N)r
r r r~ r r rz r r
r r r 6 s2 # J J J J Jr
r )r re rt r re r c > e Zd ZdZed Zed ZdS )r re c $ ddl m} || S r )popen_spawn_win32r r s r r zSpawnProcess._PopenM r r
c d S r} r r r
r r zSpawnProcess._after_forkR r r
Nr r r
r r r K r r
c e Zd ZdZeZdS r r r r
r r r W r r
c 4 t | t _ d S r} )rw r r )r{ s r _force_start_methodr d s '9&'A$$$r
c . t t dd S )Nspawning_popen)rd _tlsr r
r get_spawning_popenr m s 4)4 0 00r
c | t _ d S r} )r r )popens r set_spawning_popenr p s Dr
c j t $t dt | j z d S )NzF%s objects should only be shared between processes through inheritance)r r typer
)objs r assert_spawningr s s> #
#%)#YY%7
8 $#r
) r rb threadingrm r r __all__ Exceptionr r r r objectr BaseProcessr r rc r r r r r r rw r r localr r r r r r
r r s
9 \ < , x
x
x
x
x
& x
x
x
|D D D D Dg! D D D% % % % %[ % % %X <7& & & & &g) & & &
w*
& & & & &G / & & & k { J J J J JK J J J
''))
|x *>**