Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]

o

�=?hM-�@s�
dd
lZdd
l
Z
dd
lZddlmZ
ddlmZ
dZGdd�de�ZGdd	�d	e�Z	Gd
d�de�Z
Gdd
�d
e�ZGdd�de�Z
Gdd�dej�ZGdd�de
�Ze
jdkr�Gdd�dej�ZGdd�dej�ZGdd�dej�ZGdd�de
�ZGdd�de
�ZGdd �d e
�Ze�e�e�d!�Ze
jd"kr�eed#�
Zn#eed$�
ZnGd%d�dej�ZGd&d�de
�Zd#e�i
Zeed#�
Zd'd(�Ze��Zd)d*�Zd+d,�Zd-d.�Zd
S)/�N�
)
�process)
�	reduction�c
@�eZ
dZd
S)�ProcessErrorN��__name__�
__module__�__qualname__rrr�>/opt/alt/python310/lib64/python3.10/multiprocessing/context.pyr�
rc
@r)�BufferTooShortNrrrrrrr
rc
@r)�TimeoutErrorNrrrrrrr
rc
@r)�AuthenticationErrorNrrrrrrr
rc@s\
eZ
dZeZeZeZeZeej	�
Z	eej
�
Z
eej�
Zd
d�Zdd�Z
dCdd�
Zdd	�Zd
d�ZdDd
d�
ZdEdd�
ZdEdd�
Zdd�ZdFdd�
ZdGdd�
ZdGdd�
Zdd�Z		dHd d!�
Zd"d#�Zd$d%�Zdd&�
d'd(�Zdd&�
d)d*�Zd+d,�Zd-d.�ZdDd/d0�
Z d1d2�Z!d3d4�Z"d5d6�Z#dDd7d8�
Z$dId:d;�
Z%dId<d=�
Z&e'd>d?��
Z(e(j)d@d?��
Z(dAdB�Z*dS)J�BaseContextc
Cst�
�}
|
d
urtd�
�
|
S)z(Returns the number of CPUs in the systemNzcannot determine number of cpus)�os�	cpu_count�NotImplementedError)�selfZnumrrrr)s

zBaseContext.cpu_countc
Cs&d
dlm
}

|
|��d�
}|��
|S)z�Returns 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)
�SyncManager�
�ctx)Zmanagersr�get_context�start)rr�
mrrr�Manager1s


zBaseContext.ManagerTcC�d
dlm
}
||
�
S)z1Returns two connection object connected by a piper)
�Pipe)�
connectionr)rZduplexrrrrr<�
zBaseContext.Pipec
C�d
dlm
}

|
|��d�
S)z#Returns a non-recursive lock objectr)
�Lockr)�synchronizer"r)rr"rrrr"A�
zBaseContext.Lockc
Cr!)zReturns a recursive lock objectr)
�RLockr)r#r%r)rr%rrrr%Fr$zBaseContext.RLockNcC�d
dlm
}
||
|��d�S)zReturns a condition objectr)
�	Conditionr)r#r'r)r�lockr'rrrr'K�
zBaseContext.ConditionrcCr&)zReturns a semaphore objectr)
�	Semaphorer)r#r*r)r�valuer*rrrr*Pr)zBaseContext.SemaphorecCr&)z"Returns a bounded semaphore objectr)
�BoundedSemaphorer)r#r,r)rr+r,rrrr,Ur)zBaseContext.BoundedSemaphorec
Cr!)zReturns an event objectr)
�Eventr)r#r-r)rr-rrrr-Zr$zBaseContext.EventcC� d
dlm
}
||
|||��d�S)zReturns a barrier objectr)
�Barrierr)r#r/r)rZparties�actionZtimeoutr/rrrr/_s
zBaseContext.Barrierr
cCr&)�Returns a queue objectr)
�Queuer)�queuesr2r)r�maxsizer2rrrr2dr)zBaseContext.QueuecCr&)r1r)
�
JoinableQueuer)r3r5r)rr4r5rrrr5ir)zBaseContext.JoinableQueuec
Cr!)r1r)
�SimpleQueuer)r3r6r)rr6rrrr6nr$zBaseContext.SimpleQueuercCs"d
dlm
}
||
||||��d�S)zReturns a process pool objectr)
�Pool)
�context)Zpoolr7r)rZ	processesZinitializerZinitargsZmaxtasksperchildr7rrrr7ss


�zBaseContext.PoolcGsd
dlm
}
||
g
|�
R�S)zReturns a shared objectr)
�RawValue)�sharedctypesr9)r�typecode_or_type�argsr9rrrr9zr)zBaseContext.RawValuecCsd
dlm
}
||
|�S)zReturns a shared arrayr)
�RawArray)r:r=)rr;�size_or_initializerr=rrrr=s

zBaseContext.RawArray)
r(c
Gs(d
dlm
}
||
g
|�
R||��d��
S)z$Returns a synchronized shared objectr)
�Value�r(r)r:r?r)rr;r(r<r?rrrr?�s

�zBaseContext.Valuec
Cr.)z#Returns a synchronized shared arrayr)
�Arrayr@)r:rAr)rr;r>r(rArrrrA�s

�zBaseContext.Arrayc
Cs4tj
d
krttdd�rddlm}

|
�
dSdSdS)z�Check whether this is a fake forked process in a frozen executable.
        If so then run code specified by commandline and exit.
        �win32�frozenFr)
�freeze_supportN)�sys�platform�getattr�spawnrD)rrDrrrrD�s


�zBaseContext.freeze_supportc
Csd
dlm
}

|
�S)zZReturn package logger -- if it does not already exist then
        it is created.
        r)
�
get_logger)�utilrI)rrIrrrrI�s
zBaseContext.get_loggercCr)z8Turn on logging and add a handler which prints to stderrr)
�
log_to_stderr)rJrK)r�levelrKrrrrK�r zBaseContext.log_to_stderrc
Csd
dlm
}

dS)zVInstall support for sending connections and sockets
        between processes
        r)
rN)�r)rrrrr�allow_connection_pickling�sz%BaseContext.allow_connection_picklingcC�d
dlm
}
||
�

dS)z�Sets 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)rHrP)r�
executablerPrrrrP�s
zBaseContext.set_executablecCrO)zkSet list of module names to try to load in forkserver process.
        This is really just a hint.
        r)
�set_forkserver_preloadN)�
forkserverrR)rZmodule_namesrRrrrrR�s
z"BaseContext.set_forkserver_preloadcCsB|
dur|Szt|
}Wnt
y


td
|
�
d�w|��
|S)Nzcannot find context for %r)�_concrete_contexts�KeyError�
ValueError�_check_available)r�methodrrrrr�s





�
zBaseContext.get_contextFc
Cs|jS�
N)
�_name�rZ
allow_nonerrr�get_start_method�s
zBaseContext.get_start_methodcCstd
�
�
)Nz+cannot set start method of concrete context)
rV�rrXZforcerrr�set_start_method�s
zBaseContext.set_start_methodc

Cst��
d
�
S)z_Controls how objects will be reduced to a form that can be
        shared with other processes.r)�globals�get�
rrrr�reducer�szBaseContext.reducercCs|
t�d
<dS)Nr)
r_)rrrrrrb��c


C�dSrYrrarrrrW�s
zBaseContext._check_available)
TrY)
r)NN)
r
)NNrN�
F)+r	r
rrrrr�staticmethodrZcurrent_processZparent_processZactive_childrenrrrr"r%r'r*r,r-r/r2r5r6r7r9r=r?rArDrIrKrNrPrRrr\r^�propertyrb�setterrWrrrrrsT
















�








rc@s(eZ
dZd
Zedd��
Zedd��
Zd
S)�ProcessNc

Cst�
�j�|�
SrY)�_default_contextrri�_Popen)
�process_objrrrrk�szProcess._PopencCst�
�j��SrY)rjrri�_after_forkrrrrrm�rczProcess._after_fork�r	r
r�
_start_methodrfrkrmrrrrri�s




ricsFeZ
dZeZd
d�Zd
�f
dd�	Zddd�
Zdd	d
�
Zdd�Z�Z	S)�DefaultContextcCs|
|_d|_
dSrY)rj�_actual_context)rr8rrr�__init__�s


zDefaultContext.__init__Ncs,|
dur|jdur
|j
|_|jSt��|
�
SrY)rqrj�superr)rrX�
�	__class__rrr�s





zDefaultContext.get_contextFcCs<|jdu
r|st
d
�
�
|
dur|rd|_dS|�|
�
|_dS)Nzcontext has already been set)rq�RuntimeErrorrr]rrrr^�s





zDefaultContext.set_start_methodcCs"|jdur
|
r	dS|j
|_|jjSrY)rqrjrZr[rrrr\�s






zDefaultContext.get_start_methodc
Cs>tj
d
krdg
Stj
dkrddgnddg}
tjr|
�d�

|
S)NrBrH�darwin�forkrS)rErFr�HAVE_SEND_HANDLE�append)r�methodsrrr�get_all_start_methods
s






z$DefaultContext.get_all_start_methodsrYre)
r	r
rrirrrr^r\r|�
__classcell__rrrtrrp�s


rprBc@�eZ
dZd
Zedd��
ZdS)�ForkProcessrxc
C�d
dlm
}

|
|�
S�Nr)
�Popen)Z
popen_forkr��rlr�rrrrk
r zForkProcess._PopenN�r	r
rrorfrkrrrrr
�


rc@�(eZ
dZd
Zedd��
Zedd��
ZdS)�SpawnProcessrHc
Cr�r�)Zpopen_spawn_posixr�r�rrrrk
r �SpawnProcess._Popenc
CrdrYrrrrrrm"
��SpawnProcess._after_forkNrnrrrrr�
�




r�c@r~)�ForkServerProcessrSc
Cr�r�)Zpopen_forkserverr�r�rrrrk)
r zForkServerProcess._PopenNr�rrrrr�'
r�r�c
@�eZ
dZd
ZeZdS)�ForkContextrxN)r	r
rrZrrirrrrr�.
�

r�c
@r���SpawnContextrHN�r	r
rrZr�rirrrrr�2
r�r�c@seZ
dZd
ZeZdd�ZdS)�ForkServerContextrSc

Cstj
std
�
�
dS)Nz%forkserver start method not available)rryrVrarrrrW9
s

�z"ForkServerContext._check_availableN)r	r
rrZr�rirWrrrrr�6
s


r�)rxrHrSrwrHrxc@r�)r�rHc
Cr�r�)Zpopen_spawn_win32r�r�rrrrkM
r r�c
CrdrYrrrrrrmR
r�r�Nrnrrrrr�K
r�c
@r�r�r�rrrrr�W
r�c

Cst|t
_dSrY)rTrjrq)
rXrrr�_force_start_methodd
s
r�cCstt
d
d�S)N�spawning_popen)rG�_tlsrrrr�get_spawning_popenm
s
r�c

Cs
|t_
dSrY)r�r�)
�popenrrr�set_spawning_popenp
s

r�c

Cs t�durt
d
t|�
j�
�
dS)NzF%s objects should only be shared between processes through inheritance)r�rv�typer	)
�objrrr�assert_spawnings
s




���r�) rrEZ	threadingrMrr�__all__�	Exceptionrrrr�objectrZBaseProcessrirprFrr�r�r�r�r�rTrjr�Zlocalr�r�r�r�rrrr�<module>
sL


?

,

�
�