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

�=?h�6�@s�
dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZddlmZ
ddlm	Z	
gd�
Z
dZdZdZ
dZd	Zd
ZdZd
adad
d�Zdd�Zdd�Zdd�Zdd�Zd?dd�
Zdd�Zdd�Ze�Zdd�Zdd �Ze��Z e
�!�Z"d!d"�Z#d#d$�Z$iZ%e
�!�Z&Gd%d&�d&e'�Z(d?d'd(�
Z)d)d*�Z*da+eee)e	j,e	j-fd+d,�
Z.e�/e.�

Gd-d.�d.e'�Z0Gd/d0�d0ej1�Z2ze�3d1�
Z4Wne5y�


d2Z4Yn
wd3d4�Z6d5d6�Z7d7d8�Z8d9d:�Z9d;d<�Z:d=d>�Z;d
S)@�N)
�_args_from_interpreter_flags�
)
�process)�	sub_debug�debug�info�sub_warning�
get_logger�
log_to_stderr�get_temp_dir�register_after_fork�
is_exiting�Finalize�ForkAwareThreadLock�ForkAwareLocal�close_all_fds_except�SUBDEBUG�
SUBWARNING��
���multiprocessingz+[%(levelname)s/%(processName)s] %(message)sFc
G� trtj
t|g|
�
R�
dSdS�
N)�_logger�logr��msg�args�r �;/opt/alt/python310/lib64/python3.10/multiprocessing/util.pyr,�

�rc
Grr)rr�DEBUGrr r r!r0r"rc
Grr)rr�INFOrr r r!r4r"rc
Grr)rrrrr r r!r8r"rc
Cs�d
dl}|�
�
zAts<|�t�
ad
t_ttd�r#t�t	�

t�
t	�

n tj�t	dif�

tj�
t	dif�

W|��
tSW|��
tSW|��
tS|��
w)z0
    Returns logger used by multiprocessing
    r
N�
unregisterr )�loggingZ_acquireLockrZ	getLogger�LOGGER_NAMEZ	propagate�hasattr�atexitr%�_exit_function�registerZ
_exithandlers�remove�appendZ_releaseLock)
r&r r r!r	<s(








��
�r	c
CsJd
dl}
t
�}|
�t�
}|
��}|�|�

|�|�

|r!|�|�

dat	S)zB
    Turn on logging and add a handler which prints to stderr
    r
NT)
r&r	Z	Formatter�DEFAULT_LOGGING_FORMATZ
StreamHandlerZsetFormatterZ
addHandlerZsetLevel�_log_to_stderrr)�levelr&ZloggerZ	formatterZhandlerr r r!r
Ws










r
cCs tj
d
krdSttd�rdSdS)NZlinuxTZgetandroidapilevelF)�sys�platformr(r r r r!�#_platform_supports_abstract_socketsls







r3c

CsD|sd
St|t
�r|ddkSt|t�r|ddkStd|�d��
�
)NFr
�
zaddress type of z
 unrecognized)�
isinstance�bytes�str�	TypeError)
Zaddressr r r!�is_abstract_socket_namespacets








r9cCs*||
�

t�
�}|du
rd|jd
<dSdS)N�tempdir)r�current_process�_config)�rmtreer:r;r r r!�_remove_temp_dir�s


�r>cCsft�
�j�d
�
}|dur1ddl}
ddl}|jdd�
}td|�
tdt	|
j
|fdd�
|t�
�jd
<|S)Nr:r
zpymp-)
�prefixzcreated temp directory %si����)r�exitpriority)rr;r<�get�shutil�tempfileZmkdtemprrr>r=)r:rBrCr r r!r�s





�
rcCsftt
���
}|��
|D]$\\}
}}}z||�

Wqty0
}
ztd
|�
WYd}~qd}~w
wdS)Nz after forker raised exception %s)�list�_afterfork_registry�items�sort�	Exceptionr)rF�indexZident�func�obj�
er r r!�_run_after_forkers�s






���rMcCs|tt
t�
t|�
|
f<dSr)rE�next�_afterfork_counter�id)rKrJr r r!r�s
rc@sFeZ
dZd
Zddd�
Zdeeejfdd�
Z	dd	�Z
d
d�Zdd
�ZdS)rzA
    Class which supports object finalization using weakrefs
    r NcCs�|du
rt|t
�std
�|t|�
��
�
|
du
rt�|
|�|_n|dur'td�
�
||_	||_
|p0i|_|tt
�
f|_t��|_|t|j<dS)Nz3Exitpriority ({0!r}) must be None or int, not {1!s}z+Without object, exitpriority cannot be None)r5�intr8�format�type�weakref�ref�_weakref�
ValueError�	_callback�_args�_kwargsrN�_finalizer_counter�_key�os�getpid�_pid�_finalizer_registry)�selfrK�callbackr�kwargsr@r r r!�__init__�s 



��








zFinalize.__init__cCs�z||j=Wnt
y


|d
�

YdSw|j|�kr"|d�

d}n|d|j|j|j�
|j|ji|j�
�
}d|_|_|_|_|_|S)zQ
        Run the callback unless it has already been called or cancelled
        zfinalizer no longer registeredz+finalizer ignored because different processNz/finalizer calling %s with args %s and kwargs %s)r\�KeyErrorr_rXrYrZrV)raZwrr`rr^�resr r r!�__call__�s 


�


��

zFinalize.__call__c

CsDzt|j
=Wn
ty


Yd
Swd
|_|_|_|_|_
d
S)z3
        Cancel finalization of the object
        N)r`r\rerVrXrYrZ�
rar r r!�cancel�s


��
zFinalize.cancelc

Cs
|jt
vS)
zS
        Return whether this finalizer is still waiting to invoke callback
        )r\r`rhr r r!�still_active�s
zFinalize.still_activec
	Cs�z|��}
Wn
t
tfy


d}
Yn
w|
durd
|jjSd|jjt|jd|j�f}|jr8|dt|j�
7}|j	rD|dt|j	�
7}|j
ddu
rV|dt|j
d�
7}|dS)	Nz<%s object, dead>z<%s object, callback=%s�__name__z, args=z	, kwargs=r
z, exitpriority=�
>)rV�AttributeErrorr8�	__class__rk�getattrrXrYr7rZr\)rarK�
xr r r!�__repr__�s$



�


�





zFinalize.__repr__)r NN)
rk�
__module__�__qualname__�__doc__rdr`rr]r^rgrirjrqr r r r!r�s



�rc
	s�td
urd
S�
d
urdd��n�
f
dd���f
dd�t
t�
D�
}
|
jdd�

|
D]'}t�|�
}|d
u
rOtd	|�
z|�
Wq(tyN


d
d
l}|��
Yq(wq(�
d
urZt��
d
Sd
S)z�
    Run all finalizers whose exit priority is not None and at least minpriority

    Finalizers with highest priority are called first; finalizers with
    the same priority will be called in reverse order of creation.
    Nc

Ss|d
du
S�Nr
r �
�
pr r r!�<lambda>
sz!_run_finalizers.<locals>.<lambda>c

s|d
du
o|d
�kSrur rv)
�minpriorityr r!rx
�c
sg|]}
�|
�
r|
�qSr r )�.0�key)
�
fr r!�
<listcomp>#
rzz#_run_finalizers.<locals>.<listcomp>T)
�reversez
calling %sr
)	r`rDrGrArrH�	traceback�	print_exc�clear)ry�keysr|�	finalizerr�r )r}ryr!�_run_finalizers
s*












��
�r�cCstptd
uS)z6
    Returns true if the process is shutting down
    N)
�_exitingr r r r!r
8
sr
cCs�tsBd
a|d�

|
d�

|d�

|�du
r9|�D]}|j
r(|d|j�
|j��
q|�D]}|d|j�
|��
q,|
d�

|�
dSdS)NTzprocess shutting downz2running all "atexit" finalizers with priority >= 0r
z!calling terminate() for daemon %szcalling join() for process %sz)running the remaining "atexit" finalizers)r�Zdaemon�nameZ_popenZ	terminate�join)rrr��active_childrenr;rwr r r!r*@
s"	








�





�r*c@s,eZ
dZd
d�Zdd�Zdd�Zdd�Zd	S)
rc

Cs.t�
�|_|jj|_|jj|_t|tj�
dSr)�	threadingZLock�_lock�acquire�releaserr�_at_fork_reinitrhr r r!rdq
s






zForkAwareThreadLock.__init__c

Cs|j�
�
dSr)r�r�rhr r r!r�w
s
z#ForkAwareThreadLock._at_fork_reinitc

C�
|j�
�Sr)r��	__enter__rhr r r!r�z
s

zForkAwareThreadLock.__enter__c
Gs|jj
|
�Sr)r��__exit__)rarr r r!r�}
�
zForkAwareThreadLock.__exit__N)rkrrrsrdr�r�r�r r r r!rp
s

rc@seZ
dZd
d�Zdd�ZdS)rc

Cst|d
d��
dS)Nc

Sr�r)�__dict__r�)
rKr r r!rx�
s
z)ForkAwareLocal.__init__.<locals>.<lambda>)
rrhr r r!rd�
s
zForkAwareLocal.__init__c

Cst|�
d
fS)Nr )
rSrhr r r!�
__reduce__�
r�zForkAwareLocal.__reduce__N)rkrrrsrdr�r r r r!r�
s
r�SC_OPEN_MAX�
c
Csbt|�
d
t
g}|��
|d
t
ksJd�
�
tt|�
d�
D]}
t�||
d||
d�
qdS)N���zfd too larger)rD�MAXFDrG�range�lenr]�
closerange)�fds�
ir r r!r�
s




�rc
	Cs�tj
durdSztj
��
Wnttfy


Yn
wzt�tjtj�}zt|d
dd�t_
WWdS


t�|�

�ttfyD


YdSw)Nzutf-8F)�encoding�closefd)	r1�stdin�close�OSErrorrWr]�open�devnull�O_RDONLY)
�fdr r r!�_close_stdin�
s"





�








�r�c	CsPztj
��
Wnttfy


Yn
wztj��
WdSttfy'


YdSwr)r1�stdout�flushrmrW�stderrr r r r!�_flush_std_streams�
s



�


�r�cCs�d
dl}t
ttt|��
�
}t��\}}z(|�|
t�|�
g
d|dddddddd||ddddddd�Wt�	|�

t�	|�

St�	|�

t�	|�

w)Nr
Tr�F)
�_posixsubprocess�tuple�sorted�maprQr]�pipeZ	fork_exec�fsencoder�)�pathrZpassfdsr�Zerrpipe_readZ
errpipe_writer r r!�spawnv_passfds�
s







�


�
r�cGs|D]}
t�
|
�

qd
S)z/Close each file descriptor given as an argumentN)r]r�)r�r�r r r!�	close_fds�
s
�r�cCsZd
dlm
}
t��
d
dlm}

|
j��
d
dlm}
|j	��
t
�
|��
|��
dS)zKCleanup multiprocessing resources when multiprocessing tests
    completed.r
)
�support)
�
forkserver)
�resource_trackerN)
�testr�rZ_cleanuprr�Z_forkserverZ_stopr�Z_resource_trackerr�Z
gc_collectZ
reap_children)r�r�r�r r r!�_cleanup_tests�
s




r�r)<r]�	itertoolsr1rTr)r��
subprocessr�r�__all__ZNOTSETrr#r$rr'r.rr/rrrrr	r
r3r9Zabstract_sockets_supportedr>rZWeakValueDictionaryrE�countrOrMrr`r[�objectrr�r
r�r�r;r*r+rZlocalr�sysconfr�rHrr�r�r�r�r�r r r r!�<module>
sr	












	
	

V,


�
*



�