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 ]

U

e5d�+�@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
jdk�
rRGdd�dej�ZGdd�dej�ZGdd�dej�ZGdd�de
�ZGdd�de
�ZGdd �d e
�Ze�e�e�d!�Ze
jd"k�
rDeed#�
Zneed$�
Zn8Gd%d�dej�ZGd&d�de
�Zd#e�i
Zeed#�
Zd'd(�Ze��Zd)d*�Zd+d,�Zd-d.�Zd
S)/�N�
)
�process)
�	reduction�c
@seZ
dZd
S)�ProcessErrorN��__name__�
__module__�__qualname__rrr�//usr/lib64/python3.8/multiprocessing/context.pyrs
rc
@seZ
dZd
S)�BufferTooShortNrrrrrrs
rc
@seZ
dZd
S)�TimeoutErrorNrrrrrr
s
r
c
@seZ
dZd
S)�AuthenticationErrorNrrrrrrs
rc@sX
eZ
dZeZeZeZeZeej	�
Z	eej
�
Z
eej�
Zd
d�Zdd�Z
dCdd�
Zdd	�Zd
d�ZdDd
d�
ZdEdd�
ZdFdd�
Zdd�ZdGdd�
ZdHdd�
ZdIdd�
Zdd�ZdJd d!�
Zd"d#�Zd$d%�Zdd&�
d'd(�Zdd&�
d)d*�Zd+d,�Zd-d.�ZdKd/d0�
Z d1d2�Z!d3d4�Z"d5d6�Z#dLd7d8�
Z$dMd:d;�
Z%dNd<d=�
Z&e'd>d?��
Z(e(j)d@d?��
Z(dAdB�Z*dS)O�BaseContextc
Cs"t�
�}
|
d
krtd�
�
n|
Sd
S)z(Returns the number of CPUs in the systemNzcannot determine number of cpus)�os�	cpu_count�NotImplementedError)�selfZnumrrrr)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.ManagerTcCsd
dlm
}
||
�
S)z1Returns two connection object connected by a piper)
�Pipe)�
connectionr)rZduplexrrrrr<s
zBaseContext.Pipec
Csd
dlm
}

|
|��d�
S)z#Returns a non-recursive lock objectr)
�Lockr)�synchronizerr)rrrrrrAs
zBaseContext.Lockc
Csd
dlm
}

|
|��d�
S)zReturns a recursive lock objectr)
�RLockr)rrr)rrrrrrFs
zBaseContext.RLockNcCsd
dlm
}
||
|��d�S)zReturns a condition objectr)
�	Conditionr)rr r)r�lockr rrrr Ks
zBaseContext.ConditionrcCsd
dlm
}
||
|��d�S)zReturns a semaphore objectr)
�	Semaphorer)rr"r)r�valuer"rrrr"Ps
zBaseContext.SemaphorecCsd
dlm
}
||
|��d�S)z"Returns a bounded semaphore objectr)
�BoundedSemaphorer)rr$r)rr#r$rrrr$Us
zBaseContext.BoundedSemaphorec
Csd
dlm
}

|
|��d�
S)zReturns an event objectr)
�Eventr)rr%r)rr%rrrr%Zs
zBaseContext.EventcCs d
dlm
}
||
|||��d�S)zReturns a barrier objectr)
�Barrierr)rr&r)rZparties�actionZtimeoutr&rrrr&_s
zBaseContext.Barrierr
cCsd
dlm
}
||
|��d�S)�Returns a queue objectr)
�Queuer)�queuesr)r)r�maxsizer)rrrr)ds
zBaseContext.QueuecCsd
dlm
}
||
|��d�S)r(r)
�
JoinableQueuer)r*r,r)rr+r,rrrr,is
zBaseContext.JoinableQueuec
Csd
dlm
}

|
|��d�
S)r(r)
�SimpleQueuer)r*r-r)rr-rrrr-ns
zBaseContext.SimpleQueuercCs"d
dlm
}
||
||||��d�S)zReturns a process pool objectr)
�Pool)
�context)Zpoolr.r)rZ	processesZinitializerZinitargsZmaxtasksperchildr.rrrr.ss


�zBaseContext.PoolcGsd
dlm
}
||
f
|��S)zReturns a shared objectr)
�RawValue)�sharedctypesr0)r�typecode_or_type�argsr0rrrr0zs
zBaseContext.RawValuecCsd
dlm
}
||
|�S)zReturns a shared arrayr)
�RawArray)r1r4)rr2�size_or_initializerr4rrrr4s
zBaseContext.RawArray)
r!c
Gs&d
dlm
}
||
f
|�||��d��
S)z$Returns a synchronized shared objectr)
�Value�r!r)r1r6r)rr2r!r3r6rrrr6�s

�zBaseContext.Valuec
Cs d
dlm
}
||
|||��d�S)z#Returns a synchronized shared arrayr)
�Arrayr7)r1r8r)rr2r5r!r8rrrr8�s

�zBaseContext.Arrayc
Cs,tj
d
kr(ttdd�r(ddlm}

|
�
dS)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�spawnr;)rr;rrrr;�s

zBaseContext.freeze_supportc
Csd
dlm
}

|
�S)zZReturn package logger -- if it does not already exist then
        it is created.
        r)
�
get_logger)�utilr@)rr@rrrr@�s
zBaseContext.get_loggercCsd
dlm
}
||
�
S)z8Turn on logging and add a handler which prints to stderrr)
�
log_to_stderr)rArB)r�levelrBrrrrB�s
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_picklingcCsd
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)r?rF)r�
executablerFrrrrF�s
zBaseContext.set_executablecCsd
dlm
}
||
�

dS)zkSet list of module names to try to load in forkserver process.
        This is really just a hint.
        r)
�set_forkserver_preloadN)�
forkserverrH)rZmodule_namesrHrrrrH�s
z"BaseContext.set_forkserver_preloadcCsH|
dkr|Szt|
}Wn"t
k
r:


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







zBaseContext.get_contextFc
Cs|jS�
N)
�_name�rZ
allow_nonerrr�get_start_method�s
zBaseContext.get_start_methodcCstd
�
�
dS)Nz+cannot set start method of concrete context)
rL�rrNZforcerrr�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�szBaseContext.reducercCs|
t�d
<dS)Nr)
rU)rrrrrrX�sc


CsdSrOrrWrrrrM�s
zBaseContext._check_available)
T)
N)
r)
r)NN)
r
)
r
)NNrN)
N)
N)
F)
F)+rr	r
rrr
r�staticmethodrZcurrent_processZparent_processZactive_childrenrrrrrr r"r$r%r&r)r,r-r.r0r4r6r8r;r@rBrErFrHrrRrT�propertyrX�setterrMrrrrrsR















�









rc@seZ
dZd
Zedd��
Zd
S)�ProcessNc

Cst�
�j�|�
SrO)�_default_contextrr\�_Popen)
�process_objrrrr^�szProcess._Popen�rr	r
Z
_start_methodrYr^rrrrr\�s


r\csFeZ
dZeZd
d�Zd
�f
dd�	Zddd�
Zdd	d
�
Zdd�Z�Z	S)�DefaultContextcCs|
|_d|_
dSrO)r]�_actual_context)rr/rrr�__init__�s

zDefaultContext.__init__Ncs0|
dkr |jdkr|j
|_|jSt��|
�
SdSrO)rbr]�superr)rrN�
�	__class__rrr�s





zDefaultContext.get_contextFcCs<|jdk	r|st
d
�
�
|
dkr,|r,d|_dS|�|
�
|_dS)Nzcontext has already been set)rb�RuntimeErrorrrSrrrrT�s





zDefaultContext.set_start_methodcCs"|jdkr|
rdS|j
|_|jjSrO)rbr]rPrQrrrrR�s






zDefaultContext.get_start_methodc
CsBtj
d
krdg
Stj
dkr"ddgnddg}
tjr:|
�d�

|
SdS)Nr9r?�darwin�forkrI)r<r=r�HAVE_SEND_HANDLE�append)r�methodsrrr�get_all_start_methods
s






z$DefaultContext.get_all_start_methods)
N)
F)
F)
rr	r
r\rcrrTrRrm�
__classcell__rrrerra�s


rar9c@seZ
dZd
Zedd��
ZdS)�ForkProcessric
Csd
dlm
}

|
|�
S�Nr)
�Popen)Z
popen_forkrq�r_rqrrrr^
s
zForkProcess._PopenNr`rrrrro
s


roc@seZ
dZd
Zedd��
ZdS)�SpawnProcessr?c
Csd
dlm
}

|
|�
Srp)Zpopen_spawn_posixrqrrrrrr^
s
�SpawnProcess._PopenNr`rrrrrs
s


rsc@seZ
dZd
Zedd��
ZdS)�ForkServerProcessrIc
Csd
dlm
}

|
|�
Srp)Zpopen_forkserverrqrrrrrr^ 
s
zForkServerProcess._PopenNr`rrrrru
s


ruc
@seZ
dZd
ZeZdS)�ForkContextriN)rr	r
rPror\rrrrrv%
s

rvc
@seZ
dZd
ZeZdS��SpawnContextr?N�rr	r
rPrsr\rrrrrx)
s

rxc@seZ
dZd
ZeZdd�ZdS)�ForkServerContextrIc

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

z"ForkServerContext._check_availableN)rr	r
rPrur\rMrrrrrz-
s


rz)rir?rIrhr?ric@seZ
dZd
Zedd��
ZdS)rsr?c
Csd
dlm
}

|
|�
Srp)Zpopen_spawn_win32rqrrrrrr^D
s
rtNr`rrrrrsB
s


c
@seZ
dZd
ZeZdSrwryrrrrrxI
s

c

Cst|t
_dSrO)rJr]rb)
rNrrr�_force_start_methodV
s
r{cCstt
d
d�S)N�spawning_popen)r>�_tlsrrrr�get_spawning_popen_
s
r~c

Cs
|t_
dSrO)r}r|)
�popenrrr�set_spawning_popenb
s
r�c

Cs t�dkrt
d
t|�
j�
�
dS)NzF%s objects should only be shared between processes through inheritance)r~rg�typer)
�objrrr�assert_spawninge
s




��r�) rr<Z	threadingrDrr�__all__�	Exceptionrrr
r�objectrZBaseProcessr\rar=rorsrurvrxrzrJr]r{Zlocalr}r~r�r�rrrr�<module>
sL


?,

��